| /foundation/multimedia/av_codec/services/media_engine/filters/ |
| H A D | decoder_surface_filter.cpp | 394 prerollDoneCond_.wait_for(lock, std::chrono::milliseconds(PREROLL_WAIT_TIME), in DoWaitPrerollDone()
|
| /foundation/multimedia/audio_framework/services/audio_service/server/src/ |
| H A D | audio_service.cpp | 676 releaseEndpointCV_.wait_for(lock, std::chrono::milliseconds(delayInMs), [this, endpointName] { in DelayCallReleaseEndpoint()
|
| /foundation/multimedia/av_codec/test/unittest/video_test/vcodec_framework_test/func_sample/sample/ |
| H A D | venc_sample.cpp | 598 bool isNotTimeout = signal_->cond_.wait_for(lock, chrono::seconds(SAMPLE_TIMEOUT), lck); in WaitForEos()
|
| H A D | vdec_sample.cpp | 528 bool isNotTimeout = signal_->cond_.wait_for(lock, chrono::seconds(SAMPLE_TIMEOUT), lck); in WaitForEos()
|
| /foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/ |
| H A D | ithumbnail_helper.cpp | 185 bool ret = thumbnailWait->cond_.wait_for(lck, chrono::milliseconds(waitMs), in WaitFor()
|
| /foundation/systemabilitymgr/samgr/frameworks/native/source/ |
| H A D | system_ability_manager_proxy.cpp | 628 auto waitStatus = callback->cv_.wait_for(lock, std::chrono::seconds(timeout), in LoadSystemAbility()
|
| /foundation/systemabilitymgr/safwk/services/safwk/src/ |
| H A D | local_ability_manager.cpp | 714 if (!startPhaseCV_.wait_for(lck, std::chrono::seconds(MAX_SA_STARTUP_TIME), in WaitForTasks()
|
| /foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/src/ |
| H A D | device_status_collect_manager_test.cpp | 89 caseDoneCondition_.wait_for(lock, std::chrono::milliseconds(MAX_WAIT_TIME), in PostTask()
|
| /foundation/communication/netstack/frameworks/cj/http/src/ |
| H A D | net_http_client_exec.cpp | 386 staticVariable_.conditionVariable.wait_for(l, std::chrono::seconds(CONDITION_TIMEOUT_S), [] { in RunThread()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 437 notTimeout = retryCv_.wait_for(retryUniqueLock, std::chrono::milliseconds(timeout), retryFunc); in RetryUntilTimeout()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | generic_syncer.cpp | 68 bool engineFinalize = engineFinalizeCv_.wait_for(cvLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), in ~GenericSyncer()
|
| H A D | sync_engine.cpp | 1201 bool isTimeout = execTaskCv_.wait_for(closeLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), in WaitingExecTaskExist()
|
| /foundation/distributedhardware/device_manager/services/service/src/softbus/ |
| H A D | mine_softbus_listener.cpp | 613 if (!g_publishLnnNotify.wait_for(locker, timeout, [] { return g_publishLnnFlag; })) { in PublishDeviceDiscovery()
|
| /foundation/filemanagement/app_file_service/frameworks/native/backup_ext/src/ |
| H A D | sub_ext_extension.cpp | 639 execOnProcessCon_.wait_for(lock, std::chrono::seconds(BConstants::CALL_APP_ON_PROCESS_TIME_INTERVAL),
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/componentmanager/ |
| H A D | component_manager.cpp | 463 std::future_status status = iter.second.wait_for(std::chrono::seconds(UNINIT_COMPONENT_TIMEOUT_SECONDS)); in WaitForResult()
|
| /foundation/window/window_manager/wm/src/ |
| H A D | window_extension_session_impl.cpp | 464 if (isConsumedFuture.wait_for(std::chrono::milliseconds(DISPATCH_KEY_EVENT_TIMEOUT_TIME_MS)) == in NotifyKeyEvent()
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | managers.py | 1069 def wait_for(self, predicate, timeout=None): member in ConditionProxy
|
| /base/account/os_account/frameworks/osaccount/native/test/moduletest/ |
| H A D | os_account_manager_module_test.cpp | 287 ptr->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME), in Wait()
324 ptr->cv.wait_for(lock, std::chrono::seconds(WAIT_TIME), in Wait()
|
| /base/customization/enterprise_device_management/services/edm/src/ |
| H A D | enterprise_device_mgr_ability.cpp | 417 waitSignal_.wait_for(lock, std::chrono::milliseconds(TIMER_TIMEOUT), [this] { return this->notifySignal_; }); in UnloadPluginTask()
|
| /base/inputmethod/imf/services/src/ |
| H A D | peruser_session.cpp | 1319 return imeStopCv_.wait_for(lock, std::chrono::milliseconds(STOP_IME_TIME), [this]() { return !isSwitching_; });
|
| /base/security/security_guard/frameworks/js/napi/ |
| H A D | security_guard_napi.cpp | 391 if (future.wait_for(span) == std::future_status::timeout) { in RequestSecurityModelResultExecute()
|
| /base/telephony/core_service/services/network_search/src/ |
| H A D | network_search_manager.cpp | 1924 if (cv_.wait_for(lck, std::chrono::seconds(GET_SSB_WAIT_TIME_SECOND)) == std::cv_status::timeout) { in GetNrSsbId()
|
| /base/telephony/ril_adapter/test/unittest/ril_adapter_gtest/ |
| H A D | ril_callback_test.cpp | 39 cv_.wait_for(callbackLock, std::chrono::seconds(timeoutSecond)); in WaitFor()
|
| /foundation/ability/ability_runtime/frameworks/native/ability/native/ |
| H A D | fa_ability_thread.cpp | 914 if (!cv_.wait_for(lock, std::chrono::milliseconds(PREPARE_TO_TERMINATE_TIMEOUT_MILLISECONDS), condition)) { in CreateAbilityName()
|
| H A D | js_service_extension_context.cpp | 585 if (calldata->condition.wait_for(lock, std::chrono::seconds(callerTimeOut)) == std::cv_status::timeout) { in GetCallExecute()
|