| /foundation/multimedia/player_framework/services/services/monitor/client/ |
| H A D | monitor_client.cpp | 145 clickCond_.wait_for(lock, std::chrono::seconds(TIME_INTERVAL), [this] { in ClickThread()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_restore.cpp | 149 MEDIA_INFO_LOG("DoRdbBackup: wait_for [start]"); in DoRdbBackup()
151 MediaLibraryRestore::GetInstance().cv_.wait_for(lock, std::chrono::seconds(SLEEP_SECONDS), in DoRdbBackup()
153 MEDIA_INFO_LOG("DoRdbBackup: wait_for [end]"); in DoRdbBackup()
|
| H A D | medialibrary_rdb_transaction.cpp | 75 transactionCV_.wait_for(cvLock, chrono::milliseconds(RDB_TRANSACTION_WAIT_MS), in PrepareForTransaction()
|
| /foundation/multimedia/player_framework/services/dfx/ |
| H A D | dfx_log_dump.cpp | 144 cond_.wait_for(lock, std::chrono::seconds(timeout), in TaskProcessor()
|
| /foundation/multimodalinput/input/service/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 103 auto res = future.wait_for(span); in PostSyncTask()
|
| /foundation/communication/netmanager_base/test/netconnmanager/unittest/net_conn_manager_test/ |
| H A D | net_conn_callback_test.cpp | 42 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()
|
| /foundation/communication/netstack/frameworks/cj/http/src/ |
| H A D | net_http_cache_proxy.cpp | 130 cj_cacheNeedRunCondition.wait_for(lock, std::chrono::seconds(WRITE_INTERVAL), in RunCacheWithSize()
|
| /foundation/communication/wifi/wifi/base/state_machine/src/ |
| H A D | message_queue.cpp | 174 LOGD("mCvQueue wait_for: %{public}d", nextBlockTime); in GetNextMessage()
175 if (mCvQueue.wait_for(lck, std::chrono::milliseconds(nextBlockTime)) == std::cv_status::timeout) { in GetNextMessage()
|
| /foundation/communication/netstack/frameworks/js/napi/http/cache/cache_proxy/src/ |
| H A D | cache_proxy.cpp | 141 g_cacheNeedRunCondition.wait_for(lock, std::chrono::seconds(WRITE_INTERVAL), in RunCacheWithSize()
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/ |
| H A D | ffrt_utils.cpp | 55 auto status = future.wait_for(std::chrono::milliseconds(timeoutMs)); in SubmitTimeoutTask()
|
| /foundation/distributedhardware/distributed_audio/services/audiotransport/senderengine/src/ |
| H A D | av_sender_engine_adapter.cpp | 136 auto status = chnCreatedCondVar_.wait_for(lock, std::chrono::milliseconds(WAIT_TIMEOUT_MS), in WaitForChannelCreated()
|
| /foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/camera_sink/src/ |
| H A D | dcamera_sink_handler.cpp | 78 producerCon_.wait_for(lock, std::chrono::minutes(interval), [this] { in InitSink()
|
| /foundation/distributedhardware/distributed_input/sourcehandler/src/ |
| H A D | distributed_input_source_handler.cpp | 61 auto waitStatus = proxyConVar_.wait_for(lock, std::chrono::milliseconds(INPUT_LOAD_SA_TIMEOUT_MS), in InitSource()
|
| /foundation/distributedhardware/distributed_screen/interfaces/innerkits/native_cpp/screen_sink/src/ |
| H A D | dscreen_sink_handler.cpp | 88 auto waitStatus = proxyConVar_.wait_for(lock, std::chrono::milliseconds(SCREEN_LOADSA_TIMEOUT_MS), in InitSink()
|
| /foundation/graphic/graphic_2d/graphic_test/graphic_test_framework/src/ |
| H A D | rs_graphic_test_director.cpp | 54 cv_.wait_for(lock, std::chrono::milliseconds(ms), [&] { return ready_; }); in Wait()
|
| /test/testfwk/arkxtest/testserver/src/client/ |
| H A D | test_server_client.cpp | 51 auto wait = locatorCond_.wait_for(lock, std::chrono::milliseconds(TESTSERVER_LOAD_TIMEOUT_MS), [this] { in WaitLoadStateChange()
|
| /test/xts/hats/hdf/display/composer/benchmark/ |
| H A D | display_benchmark_ut_test.cpp | 102 ret = vblankCondition_.wait_for(lck, std::chrono::milliseconds(ms), [=] { return hasVblank_; });
in WaitVblank()
|
| /foundation/barrierfree/accessibility/services/test/xts/src/sa_perform_action_test/ |
| H A D | sa_perform_action_xts.cpp | 489 ffrt::future_status waitFocus = focusFuture.wait_for(std::chrono::milliseconds(timeOut)); in FindFocusedElementByConnection()
533 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElement()
604 ffrt::future_status waitAction = actionFuture.wait_for(std::chrono::milliseconds(timeOut)); in ExecuteActionOnA11yFocused()
673 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterCaptionObserver()
718 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterEnableAbilityListsObserver()
1411 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in DisableUITestAbility()
1906 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetParentElementRecursively()
|
| /foundation/barrierfree/accessibility/services/test/xts/src/samgr_register_element_test/ |
| H A D | samgr_register_element_test.cpp | 489 ffrt::future_status waitFocus = focusFuture.wait_for(std::chrono::milliseconds(timeOut)); in FindFocusedElementByConnection()
533 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElement()
604 ffrt::future_status waitAction = actionFuture.wait_for(std::chrono::milliseconds(timeOut)); in ExecuteActionOnA11yRegisterElementFocused()
673 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterCaptionObserver()
718 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterEnableAbilityListsObserver()
1411 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in DisableUITestAbility()
1916 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetParentElementRecursively()
|
| /foundation/multimedia/audio_framework/services/audio_service/client/src/ |
| H A D | capturer_in_client.cpp | 1063 bool stopWaiting = cbThreadCv_.wait_for(threadStartlock, std::chrono::milliseconds(SHORT_TIMEOUT_IN_MS), [this] { in SetCaptureMode()
1099 bool stopWaiting = cbThreadCv_.wait_for(stateLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in WaitForRunning()
1328 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in StartAudioStream()
1374 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in PauseAudioStream()
1426 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in StopAudioStream()
1521 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in FlushAudioStream()
1624 bool isTimeout = !readDataCV_.wait_for(readLock, in HandleCapturerRead()
|
| /foundation/barrierfree/accessibility/services/aams/src/ |
| H A D | accessible_ability_manager_service.cpp | 489 ffrt::future_status waitFocus = focusFuture.wait_for(std::chrono::milliseconds(timeOut)); in FindFocusedElementByConnection()
533 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElement()
604 ffrt::future_status waitAction = actionFuture.wait_for(std::chrono::milliseconds(timeOut)); in ExecuteActionOnAccessibilityFocused()
673 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterCaptionObserver()
718 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterEnableAbilityListsObserver()
1416 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in DisableUITestAbility()
1921 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetParentElementRecursively()
2346 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetAllConfigs()
2500 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterConfigObserver()
|
| /base/hiviewdfx/hilog/services/hilogd/ |
| H A D | log_persister.cpp | 350 if (cv_status::timeout == m_receiveLogCv.wait_for(lk, waitTime)) { in ReceiveLogLoop()
426 if (cv_status::timeout == logPersisterPtr->m_receiveLogCv.wait_for(lk, waitTime)) { in Refresh()
|
| /base/inputmethod/imf/test/unittest/cpp_test/src/ |
| H A D | input_method_dfx_test.cpp | 176 bool result = watcher->watcherCv_.wait_for(lock, std::chrono::seconds(1)) != std::cv_status::timeout; in WriteAndWatch()
179 IMSA_HILOGE("RemoveListener ret = %{public}d, wait_for result = %{public}s", ret, result ? "true" : "false"); in WriteAndWatch()
199 bool result = watcher->watcherCvImeChange_.wait_for(lock, std::chrono::seconds(1)) != std::cv_status::timeout; in WriteAndWatchImeChange()
202 IMSA_HILOGE("RemoveListener ret = %{public}d, wait_for result = %{public}s", ret, result ? "true" : "false"); in WriteAndWatchImeChange()
|
| /base/account/os_account/services/accountmgr/test/unittest/ohos_account/ |
| H A D | ohos_account_manager_test.cpp | 234 subscriberPtr->cv.wait_for( in HWTEST_F()
276 subscriberPtr->cv.wait_for( in HWTEST_F()
|
| /base/telephony/core_service/frameworks/cj/telephony_radio/src/ |
| H A D | telephony_radio_impl.cpp | 256 asyncContext->cv.wait_for( in GetNetworkSelectionMode()
369 asyncContext->cv.wait_for( in IsRadioOn()
|