| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_waitfor.py | 45 asyncio.wait_for(t.run(), t.TASK_TIMEOUT * 2)) 56 await asyncio.wait_for(t.run(), t.TASK_TIMEOUT / 2) 69 ret = await asyncio.wait_for(fut, 0) 87 await asyncio.wait_for(foo(), 0) 116 await asyncio.wait_for(fut, timeout) 142 await asyncio.wait_for(fut, 0.1) 154 res = await asyncio.wait_for(coro(), timeout=None) 161 task = asyncio.wait_for(fut, timeout=0.2) 172 result = await asyncio.wait_for(inner(), timeout=.01) 191 await asyncio.wait_for(inner_tas [all...] |
| /base/telephony/core_service/test/unittest/core_service_gtest/ |
| H A D | network_search_test_callback_stub.cpp | 71 getNetworkModeCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForGetNetworkModeCallback() 77 setNetworkModeCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForSetNetworkModeCallback() 83 setRadioStateCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForSetRadioStateCallback() 89 getRadioStateCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForGetRadioStateCallback() 95 getNetworkSearchInformationCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForGetNetworkSearchInformationCallback() 101 setPreferredNetworkCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForSetPreferredNetworkCallback() 107 getPreferredNetworkCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForGetPreferredNetworkCallback() 113 setNrOptionModeCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForSetNrOptionModeCallback() 119 getNrOptionModeCv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitForGetNrOptionModeCallback()
|
| /third_party/python/Tools/scripts/ |
| H A D | pep384_macrocheck.py | 82 wait_for = -1 91 wait_for = status - 1 94 wait_for = status - 1 97 if status == wait_for: 99 wait_for = -1 104 wait_for = status - 1
|
| /base/inputmethod/imf/test/common/src/ |
| H A D | ime_setting_listener_test_impl.cpp | 40 imeSettingListenerCv_.wait_for(lock, std::chrono::seconds(TIMEOUT_SECONDS), in WaitPanelHide() 47 imeSettingListenerCv_.wait_for(lock, std::chrono::seconds(TIMEOUT_SECONDS), in WaitPanelShow() 55 imeSettingListenerCv_.wait_for(lock, std::chrono::seconds(SWITCH_IME_WAIT_TIME), []() { return isImeChange_; }); in WaitImeChange() 62 imeSettingListenerCv_.wait_for(lock, std::chrono::seconds(SWITCH_IME_WAIT_TIME), in WaitTargetImeChange() 70 imeSettingListenerCv_.wait_for(lock, std::chrono::seconds(SWITCH_IME_WAIT_TIME), in WaitImeChange()
|
| H A D | input_method_engine_listener_impl.cpp | 90 imeListenerCv_.wait_for(lock, std::chrono::seconds(TIMEOUT_SECONDS), []() { return isInputStart_; }); in WaitInputStart() 96 imeListenerCv_.wait_for(lock, std::chrono::seconds(TIMEOUT_SECONDS), []() { return isInputFinish_; }); in WaitInputFinish() 102 imeListenerCv_.wait_for(lock, std::chrono::seconds(1), [&windowId]() { return windowId_ == windowId; }); in WaitSetCallingWindow() 109 imeListenerCv_.wait_for(lock, std::chrono::seconds(1), in WaitSendPrivateCommand() 117 imeListenerCv_.wait_for(lock, std::chrono::seconds(1), [state]() { in WaitKeyboardStatus()
|
| H A D | keyboard_listener_test_impl.cpp | 82 kdListenerCv_.wait_for(lock, std::chrono::seconds(1), [&keyCode]() { return keyCode == keyCode_; }); in WaitKeyEvent() 88 kdListenerCv_.wait_for(lock, std::chrono::seconds(1), []() { return cursorHeight_ > 0; }); in WaitCursorUpdate() 94 kdListenerCv_.wait_for(lock, std::chrono::seconds(1), [&newBegin]() { return newBegin == newBegin_; }); in WaitSelectionChange() 100 kdListenerCv_.wait_for(lock, std::chrono::seconds(1), [&text]() { return text == text_; }); in WaitTextChange() 106 kdListenerCv_.wait_for(lock, std::chrono::seconds(1), in WaitEditorAttributeChange()
|
| H A D | text_listener.cpp | 218 textListenerCv_.wait_for(lock, std::chrono::seconds(KEYBOARD_STATUS_WAIT_TIME_OUT), in WaitSendKeyboardStatusCallback() 226 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [info]() { return info == info_; }); in WaitNotifyPanelStatusInfoCallback() 233 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [height]() { return height_ == height; }); in WaitNotifyKeyboardHeightCallback() 240 textListenerCv_.wait_for(lock, std::chrono::seconds(1), in WaitSendPrivateCommandCallback() 247 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [insertText]() { return insertText_ == insertText; }); in WaitInsertText() 253 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [direction]() { return direction_ == direction; }); in WaitMoveCursor() 259 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [length]() { return deleteForwardLength_ == length; }); in WaitDeleteForward() 265 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [length]() { return deleteBackwardLength_ == length; }); in WaitDeleteBackward() 271 textListenerCv_.wait_for(lock, std::chrono::seconds(1), [functionKey]() { return key_ == functionKey; }); in WaitSendFunctionKey() 277 textListenerCv_.wait_for(loc in WaitHandleExtendAction() [all...] |
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| H A D | event.h | 59 // wait_for() blocks until the event is signaled, or the timeout has been 61 // If the timeout was reached, then wait_for() return false. 66 MARL_NO_EXPORT inline bool wait_for( 71 // If the timeout was reached, then wait_for() return false. 114 MARL_NO_EXPORT inline bool wait_for( 159 bool Event::Shared::wait_for( in wait_for() function in marl::Event::Shared 162 if (!cv.wait_for(lock, duration, [&] { return signalled; })) { in wait_for() 203 bool Event::wait_for(const std::chrono::duration<Rep, Period>& duration) const { in wait_for() function in marl::Event 204 return shared->wait_for(duration); in wait_for()
|
| /base/telephony/core_service/services/sim/src/ |
| H A D | sim_state_manager.cpp | 188 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND)) == std::cv_status::timeout) { in UnlockPin() 222 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND)) == std::cv_status::timeout) { in UnlockPuk() 256 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AlterPin() 299 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND)) == std::cv_status::timeout) { in SetLockState() 338 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in GetLockState() 373 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UnlockPin2() 407 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UnlockPuk2() 441 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AlterPin2() 472 if (cv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in RefreshSimState() 494 if (cv_.wait_for(lc in UnlockSimLock() [all...] |
| H A D | sim_sms_controller.cpp | 152 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in UpdateSmsIcc() 181 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in DelSmsIcc() 208 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_SECOND)) == std::cv_status::timeout) { in AddSmsToIcc() 241 if (processWait_.wait_for(lock, std::chrono::seconds(WAIT_TIME_TEN_SECOND)) == std::cv_status::timeout) { in ObtainAllSmsOfIcc()
|
| /base/powermgr/battery_manager/test/systemtest/src/ |
| H A D | battery_event_system_test.cpp | 432 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 454 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 477 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 500 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 523 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 546 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 569 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 592 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 618 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) { in HWTEST_F() 627 if (g_cv.wait_for(lc in HWTEST_F() [all...] |
| /base/account/os_account/frameworks/domain_account/test/moduletest/src/ |
| H A D | domain_account_client_module_test.cpp | 241 testCallback->cv.wait_for(
in HWTEST_F() 265 testCallback->cv.wait_for(
in HWTEST_F() 280 testCallbackSec->cv.wait_for(lock,
in HWTEST_F() 304 testCallback->cv.wait_for(
in HWTEST_F() 359 testCallback->cv.wait_for(
in HWTEST_F() 417 testCallback->cv.wait_for(
in HWTEST_F() 433 testAuthCallback->cv.wait_for(lock,
in HWTEST_F() 568 testCallback->cv.wait_for(
in HWTEST_F() 584 testAuthCallback->cv.wait_for(lock,
in HWTEST_F() 613 testCallback->cv.wait_for(
in HWTEST_F() [all...] |
| H A D | domain_account_client_mock_plugin_so_module_test.cpp | 406 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 448 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 487 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 578 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 623 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 681 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 761 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F() 830 testCallback->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in HWTEST_F()
|
| /base/account/os_account/frameworks/account_iam/test/unittest/src/ |
| H A D | account_iam_client_test.cpp | 248 ptr->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in Wait() 255 ptr->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME),
in Wait() 298 testCallback->cv.wait_for(
in HWTEST_F() 325 testCallback->cv.wait_for(
in HWTEST_F() 335 testCallback->cv.wait_for(
in HWTEST_F() 356 testCallback->cv.wait_for(
in HWTEST_F() 378 testCallback->cv.wait_for(
in HWTEST_F() 385 testCallback->cv.wait_for(
in HWTEST_F() 420 testCallback->cv.wait_for(
in HWTEST_F() 427 testCallback->cv.wait_for(
in HWTEST_F() [all...] |
| H A D | account_iam_callback_service_test.cpp | 111 testCallback->cv.wait_for(
in HWTEST_F() 133 testCallback->cv.wait_for(
in HWTEST_F() 141 testCallback->cv.wait_for(
in HWTEST_F()
|
| /base/msdp/device_status/test/unittest/frameworks/src/ |
| H A D | interaction_drag_drawing_test.cpp | 216 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 261 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 306 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 351 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 393 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 435 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 477 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 519 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 556 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 604 ASSERT_TRUE(futureFlag.wait_for(st in HWTEST_F() [all...] |
| H A D | interaction_manager_test.cpp | 345 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in EnableCooperate() 665 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 873 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 942 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != std::future_status::timeout); in HWTEST_F() 1104 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F() 1145 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F() 1194 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F() 1241 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F() 1291 ASSERT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F() 1335 ASSERT_TRUE(futureFlag.wait_for(st in HWTEST_F() [all...] |
| /kernel/linux/linux-5.10/drivers/gpu/drm/v3d/ |
| H A D | v3d_mmu.c | 40 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all() 52 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all() 59 ret = wait_for(!(V3D_READ(V3D_MMUC_CONTROL) & in v3d_mmu_flush_all()
|
| /kernel/linux/linux-6.6/drivers/gpu/drm/v3d/ |
| H A D | v3d_mmu.c | 40 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all() 52 ret = wait_for(!(V3D_READ(V3D_MMU_CTL) & in v3d_mmu_flush_all() 59 ret = wait_for(!(V3D_READ(V3D_MMUC_CONTROL) & in v3d_mmu_flush_all()
|
| /base/sensors/miscdevice/services/miscdevice_service/src/ |
| H A D | vibrator_thread.cpp | 78 cv_.wait_for(vibrateLck, std::chrono::milliseconds(info.duration), [this] { return exitFlag_.load(); });
in PlayOnce() 99 cv_.wait_for(vibrateLck, std::chrono::milliseconds(info.duration), [this] { return exitFlag_.load(); });
in PlayEffect() 123 cv_.wait_for(vibrateLck, std::chrono::milliseconds(delayTime), [this] { return exitFlag_.load(); });
in PlayCustomByHdHptic() 186 cv_.wait_for(vibrateLck, std::chrono::milliseconds(delayTime), [this] { return exitFlag_.load(); });
in PlayCompositeEffect()
|
| /kernel/linux/linux-6.6/fs/fscache/ |
| H A D | cookie.c | 383 struct fscache_cookie *wait_for) in fscache_wait_on_collision() 385 enum fscache_cookie_state *statep = &wait_for->state; in fscache_wait_on_collision() 387 wait_var_event_timeout(statep, fscache_cookie_is_dropped(wait_for), in fscache_wait_on_collision() 389 if (!fscache_cookie_is_dropped(wait_for)) { in fscache_wait_on_collision() 391 candidate->debug_id, wait_for->debug_id); in fscache_wait_on_collision() 392 wait_var_event(statep, fscache_cookie_is_dropped(wait_for)); in fscache_wait_on_collision() 403 struct fscache_cookie *cursor, *wait_for = NULL; in fscache_hash_cookie() local 416 wait_for = fscache_get_cookie(cursor, in fscache_hash_cookie() 428 if (wait_for) { in fscache_hash_cookie() 429 fscache_wait_on_collision(candidate, wait_for); in fscache_hash_cookie() 382 fscache_wait_on_collision(struct fscache_cookie *candidate, struct fscache_cookie *wait_for) fscache_wait_on_collision() argument [all...] |
| /base/inputmethod/imf/frameworks/common/ |
| H A D | block_data.h | 46 cv_.wait_for(lock, std::chrono::milliseconds(INTERVAL), [this]() { return isSet_; }); in GetValue() 54 cv_.wait_for(lock, std::chrono::milliseconds(INTERVAL), [this]() { return isSet_; }); in GetValue()
|
| /third_party/toybox/toys/pending/ |
| H A D | fsck.c | 250 static int wait_for(int for_all) in wait_for() function 323 if ((ret |= wait_for(1)) > 4) return ret; //destruction in filesys. in scan_all() 347 && (TT.nr_run >= TT.max_nr_run))) ret |= wait_for(0); in scan_all() 351 ret |= wait_for(1); in scan_all() 411 toys.exitval |= wait_for(0); in fsck_main() 414 toys.exitval |= wait_for(1); in fsck_main()
|
| /kernel/linux/linux-5.10/drivers/mmc/host/ |
| H A D | sh_mmcif.c | 234 enum sh_mmcif_wait_for wait_for; member 588 host->state, host->wait_for); in sh_mmcif_error_manage() 592 host->state, host->wait_for); in sh_mmcif_error_manage() 596 host->state, host->wait_for); in sh_mmcif_error_manage() 628 host->wait_for = MMCIF_WAIT_FOR_READ; in sh_mmcif_single_read() 652 host->wait_for = MMCIF_WAIT_FOR_READ_END; in sh_mmcif_read_block() 668 host->wait_for = MMCIF_WAIT_FOR_MREAD; in sh_mmcif_multi_read() 708 host->wait_for = MMCIF_WAIT_FOR_WRITE; in sh_mmcif_single_write() 732 host->wait_for = MMCIF_WAIT_FOR_WRITE_END; in sh_mmcif_write_block() 748 host->wait_for in sh_mmcif_multi_write() [all...] |
| /kernel/linux/linux-6.6/drivers/mmc/host/ |
| H A D | sh_mmcif.c | 233 enum sh_mmcif_wait_for wait_for; member 589 host->state, host->wait_for); in sh_mmcif_error_manage() 593 host->state, host->wait_for); in sh_mmcif_error_manage() 597 host->state, host->wait_for); in sh_mmcif_error_manage() 629 host->wait_for = MMCIF_WAIT_FOR_READ; in sh_mmcif_single_read() 653 host->wait_for = MMCIF_WAIT_FOR_READ_END; in sh_mmcif_read_block() 669 host->wait_for = MMCIF_WAIT_FOR_MREAD; in sh_mmcif_multi_read() 709 host->wait_for = MMCIF_WAIT_FOR_WRITE; in sh_mmcif_single_write() 733 host->wait_for = MMCIF_WAIT_FOR_WRITE_END; in sh_mmcif_write_block() 749 host->wait_for in sh_mmcif_multi_write() [all...] |