Home
last modified time | relevance | path

Searched refs:wait_for (Results 1 - 25 of 161) sorted by relevance

1234567

/third_party/python/Lib/test/test_asyncio/
H A Dtest_waitfor.py45 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...]
H A Dtest_sslproto.py281 asyncio.wait_for(client(srv.addr),
344 asyncio.wait_for(client(srv.addr),
441 asyncio.wait_for(client(srv.addr),
496 await asyncio.wait_for(
502 asyncio.wait_for(client(srv.addr),
584 await asyncio.wait_for(
625 await asyncio.wait_for(
/base/telephony/core_service/test/unittest/core_service_gtest/
H A Dnetwork_search_test_callback_stub.cpp71 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 Dpep384_macrocheck.py82 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 Dime_setting_listener_test_impl.cpp40 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 Dinput_method_engine_listener_impl.cpp90 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 Dkeyboard_listener_test_impl.cpp82 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 Dtext_listener.cpp218 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 Devent.h59 // 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()
H A Dconditionvariable.h53 // wait_for() blocks the current fiber or thread until the predicate is
58 MARL_NO_EXPORT inline bool wait_for(
150 bool ConditionVariable::wait_for( in wait_for() function in marl::ConditionVariable
/base/telephony/core_service/services/sim/src/
H A Dsim_state_manager.cpp188 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 Dsim_sms_controller.cpp152 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()
H A Desim_file.cpp58 if (openChannelCv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in SyncOpenChannel()
76 if (openChannelCv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in SyncOpenChannel()
94 if (closeChannelCv_.wait_for(lck, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in SyncCloseChannel()
118 if (!getEidCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in ObtainEid()
137 if (!allProfileInfoCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in GetEuiccProfileInfoList()
156 if (!euiccInfo1Cv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in GetEuiccInfo()
676 if (!disableProfileCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in DisableProfile()
696 if (!smdsAddressCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in ObtainSmdsAddress()
716 if (!rulesAuthTableCv_.wait_for(lock, std::chrono::seconds(WAIT_TIME_LONG_SECOND_FOR_ESIM), in ObtainRulesAuthTable()
736 if (!euiccChallengeCv_.wait_for(loc in ObtainEuiccChallenge()
[all...]
/base/powermgr/battery_manager/test/systemtest/src/
H A Dbattery_event_system_test.cpp432 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 Ddomain_account_client_module_test.cpp241 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 Ddomain_account_client_mock_plugin_so_module_test.cpp406 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 Daccount_iam_client_test.cpp248 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 Daccount_iam_callback_service_test.cpp111 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 Dinteraction_drag_drawing_test.cpp216 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 Dinteraction_manager_test.cpp345 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...]
/base/sensors/miscdevice/services/miscdevice_service/src/
H A Dvibrator_thread.cpp78 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()
/base/inputmethod/imf/frameworks/common/
H A Dblock_data.h46 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 Dfsck.c250 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()
/base/msdp/device_status/test/unittest/intention/drag/src/
H A Ddrag_manager_test.cpp486 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
517 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
549 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
585 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
623 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
660 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
695 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
730 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
765 EXPECT_TRUE(futureFlag.wait_for(std::chrono::milliseconds(PROMISE_WAIT_SPAN_MS)) != in HWTEST_F()
800 EXPECT_TRUE(futureFlag.wait_for(st in HWTEST_F()
[all...]
/base/account/os_account/services/accountmgr/test/unittest/account_iam/
H A Daccount_iam_manager_test.cpp583 testCallback->cv.wait_for( in HWTEST_F()
605 testCallback->cv.wait_for( in HWTEST_F()
613 testCallback->cv.wait_for( in HWTEST_F()
703 testCallback->cv.wait_for( in HWTEST_F()
711 testCallback->cv.wait_for( in HWTEST_F()
734 testCallback->cv.wait_for( in HWTEST_F()
742 testCallback->cv.wait_for( in HWTEST_F()

Completed in 27 milliseconds

1234567