Home
last modified time | relevance | path

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

12345678910>>...21

/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...]
/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()
/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...]
/foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/src/
H A Ddevice_networking_collect_test.cpp82 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
122 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
152 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
184 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
221 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
256 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
292 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
485 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
515 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in HWTEST_F()
543 caseDoneCondition_.wait_for(loc in HWTEST_F()
[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...]
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dcondition_variable.cpp54 auto status = cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs)); in WaitFor()
64 return cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), pred); in WaitFor()
/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...]
/foundation/CastEngine/castengine_wifi_display/services/utils/
H A Dtimeout_timer.cpp69 waitSignal_.wait_for(waitLock, std::chrono::milliseconds(TIMER_TIMEOUT)); in StartTimer()
88 waitSignal_.wait_for(waitLock, std::chrono::milliseconds(TIMER_TIMEOUT)); in StopTimer()
114 cancelSignal_.wait_for(taskLock, std::chrono::seconds(timeout_)); in MainLoop()
/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...]
/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()
/foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_stability_test/
H A Dui_extension_stability_test.cpp157 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilProcessCreated()
168 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilProcessDied()
179 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in CheckProcessNotDied()
191 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilAbilityForeground()
203 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(TEST_TIMEOUT_MS), in WaitUntilAbilityBackground()
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_policy_callback.cpp180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
265 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
290 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/conn_vpn_manager_test/
H A Dut_net_policy_callback.cpp180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
265 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
290 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
/foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_connect_module_test/
H A Dui_extension_connect_module_test.cpp157 auto waitStatus = connection->connectCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilConnectDone()
169 auto waitStatus = connection->connectCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilDisConnectDone()
180 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilProcessCreated()
191 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilProcessDied()
202 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in CheckProcessNotDied()
214 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilAbilityForeground()
226 auto waitStatus = observer->observerCondation_.wait_for(lock, std::chrono::milliseconds(CONNECT_TIMEOUT_MS), in WaitUntilAbilityBackground()
/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()
/foundation/bundlemanager/bundle_tool/frameworks/src/
H A Dstatus_receiver_impl.cpp62 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultCode()
72 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultMsg()
/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessible_ability_channel.cpp100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByAccessibilityId()
153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText()
206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo()
258 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch()
372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction()
428 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetWindow()
502 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetWindows()
575 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition()
623 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SendSimulateGesture()
657 ffrt::future_status wait = syncFuture.wait_for(st in SetTargetBundleName()
[all...]
/foundation/multimedia/player_framework/frameworks/native/player/test/unittest/src/
H A Dplayer_mock.cpp59 condVarPrepare_.wait_for(lockPrepare, std::chrono::seconds(waitsecond)); in PrepareSync()
71 condVarPlay_.wait_for(lockPlay, std::chrono::seconds(waitsecond)); in PlaySync()
83 condVarPause_.wait_for(lockPause, std::chrono::seconds(waitsecond)); in PauseSync()
95 condVarStop_.wait_for(lockStop, std::chrono::seconds(waitsecond)); in StopSync()
107 condVarReset_.wait_for(lockReset, std::chrono::seconds(waitsecond)); in ResetSync()
119 condVarSeek_.wait_for(lockSeek, std::chrono::seconds(waitsecond)); in SeekSync()
131 condVarSpeed_.wait_for(lockSpeed, std::chrono::seconds(waitsecond)); in SpeedSync()
143 condVarTrackDone_.wait_for(lockTrackDone, std::chrono::seconds(waitsecond)); in TrackSync()
158 condVarTrackInfoUpdate_.wait_for(lock, std::chrono::seconds(waitsecond), [this]() { in TrackInfoUpdateSync()
251 condVarText_.wait_for(loc in SubtitleTextUpdate()
[all...]

Completed in 18 milliseconds

12345678910>>...21