| /foundation/multimedia/media_foundation/src/osal/task/ffrt/ |
| H A D | condition_variable.cpp | 54 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()
|
| /foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/src/ |
| H A D | device_networking_collect_test.cpp | 82 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...] |
| /foundation/bundlemanager/bundle_tool/frameworks/src/ |
| H A D | status_receiver_impl.cpp | 62 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/CastEngine/castengine_wifi_display/services/utils/ |
| H A D | timeout_timer.cpp | 69 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()
|
| /foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_stability_test/ |
| H A D | ui_extension_stability_test.cpp | 157 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 D | ut_net_policy_callback.cpp | 180 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 D | ut_net_policy_callback.cpp | 180 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 D | ui_extension_connect_module_test.cpp | 157 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()
|
| /foundation/barrierfree/accessibility/frameworks/aafwk/src/ |
| H A D | accessible_ability_channel_client.cpp | 93 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo()
149 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition()
193 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction()
263 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByAccessibilityId()
351 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText()
392 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch()
|
| /foundation/barrierfree/accessibility/services/aams/src/ |
| H A D | accessible_ability_channel.cpp | 100 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 D | player_mock.cpp | 59 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...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/ |
| H A D | hid_host_hogp.cpp | 171 if (cvfull_.wait_for(lock, in SendGetReport()
211 if (cvfull_.wait_for(lock, in SendSetReport()
373 if (cvfull_.wait_for(lock, in GetPnpInformation()
403 if (cvfull_.wait_for(lock, in GetHidInformation()
441 if (cvfull_.wait_for(lock, in GetBatteryInformation()
460 if (cvfull_.wait_for(lock, in GetHidReportMap()
492 if (cvfull_.wait_for(lock, in GetExternalRptRefInfo()
514 if (cvfull_.wait_for(lock, in GetExternalCfgInfo()
550 if (cvfull_.wait_for(lock, in GetHidReport()
662 if (cvfull_.wait_for(loc in SetInputReportNotification()
[all...] |
| /foundation/multimedia/av_codec/services/engine/codec/video/hcodec/ |
| H A D | msg_handle_loop.cpp | 83 if (!m_replyCond.wait_for(lock, chrono::milliseconds(waitMs), pred)) { in SendSyncMsg()
131 m_threadCond.wait_for(lock, chrono::microseconds(processUs - nowUs)); in MainLoop()
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
| H A D | msg_handle_loop.cpp | 84 if (!m_replyCond.wait_for(lock, chrono::milliseconds(waitMs), pred)) { in SendSyncMsg()
133 m_threadCond.wait_for(lock, chrono::microseconds(processUs - nowUs)); in MainLoop()
|
| /foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | condition_variable.h | 68 cv_status wait_for(std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleep_time) noexcept
74 bool wait_for(
|
| /foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcamerahdf/ |
| H A D | dcamera_hdf_operate.cpp | 97 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] { in WaitLoadCameraService()
113 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] { in WaitLoadProviderService()
|
| /foundation/distributedhardware/distributed_audio/services/audiohdiproxy/src/ |
| H A D | daudio_hdf_operate.cpp | 96 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] {
in WaitLoadService()
109 hdfOperateCon_.wait_for(lock, std::chrono::milliseconds(WAIT_TIME), [this] {
in WaitLoadService()
|
| /foundation/filemanagement/dfs_service/utils/system/include/ |
| H A D | dfsu_thread.h | 66 sleepCv_.wait_for(lock, std::chrono::milliseconds(interval), [this]() { return !this->running_; }); in RunLoop()
91 sleepCv_.wait_for(lock, std::chrono::milliseconds(duration), [this]() { return !this->running_; }); in RunLoopFlexible()
|
| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_condition.cpp | 110 cond.wait_for(lck, 100ms, [&] { return a == 1; }); in HWTEST_F()
135 status = cond.wait_for(lck, 100ms); in HWTEST_F()
150 status = cond.wait_for(lck, 100ms); in HWTEST_F()
|
| /foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/src/ |
| H A D | mock_bundle_status.cpp | 34 std::future_status status = future.wait_for(std::chrono::seconds(1)); in GetResultCode()
|
| H A D | mock_status_receiver.cpp | 48 if (future.wait_for(std::chrono::seconds(WAIT_TIME)) == std::future_status::ready) { in GetResultCode()
|
| /foundation/communication/netmanager_base/utils/common_utils/include/ |
| H A D | tiny_count_down_latch.h | 37 return conditionVar_.wait_for(lk, time, [this] { return count_ == 0; }); in Await()
|
| /foundation/communication/netmanager_base/test/netstatsmanager/unittest/net_stats_manager_test/ |
| H A D | net_stats_callback_test.cpp | 36 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | semaphore_utils.cpp | 36 bool result = cv_.wait_for(lock, std::chrono::seconds(waitSecond), in WaitSemaphore()
|
| /foundation/barrierfree/accessibility/services/test/xts/src/asac_register_elemnt_operator_test/ |
| H A D | asac_ability_channel_benchmark.cpp | 100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByA11yBenchmarkId()
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()
|