| /foundation/arkui/ace_engine/frameworks/base/network/ |
| H A D | download_manager_impl.cpp | 321 downloadCondition->cv.wait_for( in HandleDownloadResult()
346 downloadCondition->cv.wait_for( in HandleDownloadResult()
|
| /foundation/multimedia/audio_framework/services/audio_service/server/src/ |
| H A D | none_mix_engine.cpp | 140 cvFading_.wait_for( in Stop()
194 cvFading_.wait_for( in Pause()
|
| /foundation/multimedia/av_codec/frameworks/native/avcodec/ |
| H A D | avcodec_audio_codec_impl.cpp | 346 inputCondition_.wait_for(lock2, std::chrono::milliseconds(MILLISECONDS), in ProduceInputBuffer()
376 outputCondition_.wait_for(lock2, std::chrono::milliseconds(MILLISECONDS), in ConsumerOutputBuffer()
|
| /foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/common/ |
| H A D | hdi_codec.cpp | 193 condition_.wait_for(lock, std::chrono::milliseconds(TIMEOUT_MS), in SendCommand()
228 condition_.wait_for(lock, std::chrono::milliseconds(TIMEOUT_MS), [this] { return outputOmxBuffer_ != nullptr; }); in FillThisBuffer()
|
| /foundation/multimedia/player_framework/frameworks/native/audio_haptic/ |
| H A D | audio_haptic_player_impl.cpp | 334 bool waitResult = condStartVibrate_.wait_for(lockWait, std::chrono::seconds(waitTime), in StartVibrate()
350 waitResult = condStartVibrate_.wait_for(lockWait, std::chrono::milliseconds(delay), in StartVibrate()
|
| /foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_sub_manage/ |
| H A D | wifi_p2p_manager.cpp | 109 p2pEnableCond.wait_for(locker, std::chrono::milliseconds(P2P_ENABLE_WAIT_MS));
in AutoStartP2pService()
148 p2pEnableCond.wait_for(locker, std::chrono::milliseconds(P2P_ENABLE_WAIT_MS));
in AutoStopP2pService()
|
| /foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/src/ |
| H A D | screen_source_trans.cpp | 131 sessionCond_.wait_for(lck, std::chrono::seconds(SESSION_WAIT_SECONDS), [this]() { return isChannelReady_; }); in Start()
419 auto status = dataCond_.wait_for( in FeedChannelData()
|
| /kernel/linux/linux-6.6/drivers/gpu/drm/i915/gt/ |
| H A D | intel_gt_mcr.c | 396 err = wait_for(intel_uncore_read_fw(gt->uncore,
889 ret = wait_for(done, slow_timeout_ms); in intel_gt_mcr_wait_for_reg()
|
| /foundation/multimedia/media_foundation/src/buffer/avbuffer_queue/ |
| H A D | avbuffer_queue.cpp | 265 bool AVBufferQueueImpl::wait_for(std::unique_lock<std::mutex>& lock, int32_t timeoutMs) in wait_for() function in OHOS::Media::AVBufferQueueImpl
269 return requestCondition.wait_for( in wait_for()
302 if (!wait_for(lock, timeoutMs)) { in RequestBuffer()
303 MEDIA_LOG_D("FALSE_RETURN_V wait_for(lock, timeoutMs)"); in RequestBuffer()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 474 cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [&finished]() { in HWTEST_F()
549 waitCv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MAX_TIMEOUT), [¤tCount, scheduleCount]() { in HWTEST_F()
739 cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [&callCount]() { in HWTEST_F()
|
| /foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/output_control/src/ |
| H A D | output_controller.cpp | 388 clockCon_.wait_for(lock, std::chrono::nanoseconds(rereadTime), in WaitRereadClockFailed()
396 clockCon_.wait_for(lock, std::chrono::nanoseconds(GREATER_HALF_REREAD_TIME), in WaitRereadClockFailed()
493 sleepCon_.wait_for(lock, std::chrono::nanoseconds(sleep_), in SyncClock()
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_subprocess.py | 132 task = asyncio.wait_for(task, 60.0)
150 task = asyncio.wait_for(task, support.LONG_TIMEOUT)
530 await asyncio.wait_for(transport._wait(), 5)
|
| /foundation/multimedia/audio_framework/services/audio_service/client/src/ |
| H A D | renderer_in_client.cpp | 941 bool stopWaiting = cbThreadCv_.wait_for(threadStartlock, std::chrono::milliseconds(SHORT_TIMEOUT_IN_MS), [this] { in SetRenderMode()
975 bool stopWaiting = cbThreadCv_.wait_for(stateLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in WaitForRunning()
1257 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in StartAudioStream()
1274 stopWaiting = dataConnectionCV_.wait_for( in StartAudioStream()
1311 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in PauseAudioStream()
1366 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in StopAudioStream()
1467 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in FlushAudioStream()
1539 bool stopWaiting = callServerCV_.wait_for(waitLock, std::chrono::milliseconds(OPERATION_TIMEOUT_IN_MS), [this] { in DrainAudioStream()
|
| /foundation/ai/intelligent_voice_framework/utils/ |
| H A D | timer_mgr.cpp | 235 cv_.wait_for(lock, chrono::microseconds(item.tgtUs - now)); in Run()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/local/src/ |
| H A D | cast_local_file_channel_client.cpp | 88 cond_.wait_for(lock, std::chrono::milliseconds(CREATE_CHANNEL_TIMEOUT - cost.count())); in WaitCreateChannel()
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/local/src/ |
| H A D | cast_local_file_channel_client.cpp | 88 cond_.wait_for(lock, std::chrono::milliseconds(CREATE_CHANNEL_TIMEOUT - cost.count())); in WaitCreateChannel()
|
| /foundation/ability/ability_runtime/interfaces/inner_api/uri_permission/src/ |
| H A D | uri_permission_manager_client.cpp | 186 auto waitStatus = loadSaVariable_.wait_for(lock, std::chrono::milliseconds(LOAD_SA_TIMEOUT_MS), in LoadUriPermService()
|
| /foundation/arkui/ace_engine/frameworks/base/thread/ |
| H A D | cancelable_callback.h | 139 if (timeoutMs != 0ms && std::future_status::timeout == future.wait_for(timeoutMs)) { in WaitUntilComplete()
|
| /foundation/arkui/ace_engine/interfaces/inner_api/form_render/src/ |
| H A D | form_renderer_dispatcher_impl.cpp | 67 if (serializedResultData->cv.wait_for(lock, std::chrono::milliseconds(PROCESS_WAIT_TIME)) == in DispatchPointerEvent()
|
| /foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | future.cpp | 41 if (cond_.wait_for(lock, std::chrono::microseconds(time.ToMicroseconds())) == std::cv_status::timeout) { in WaitFor()
|
| /foundation/multimedia/media_foundation/src/buffer/avbuffer_queue/include/ |
| H A D | avbuffer_queue_impl.h | 130 bool wait_for(std::unique_lock<std::mutex>& lock, int32_t timeoutMs);
|
| /foundation/multimedia/player_framework/frameworks/native/soundpool/ |
| H A D | sound_id_manager.cpp | 157 queueDataValid_.wait_for( in DoParser()
|
| /foundation/multimedia/player_framework/services/utils/include/ |
| H A D | task_queue.h | 161 auto isFinished = cond_.wait_for(lock, std::chrono::milliseconds(milliseconds), in GetResultWithTimeLimit()
|
| /foundation/multimedia/player_framework/services/utils/ |
| H A D | task_queue.cpp | 169 (void)cond_.wait_for(lock, std::chrono::nanoseconds(diff)); in TaskProcessor()
|
| /foundation/communication/netmanager_ext/frameworks/js/napi/mdns/src/ |
| H A D | mdns_exec.cpp | 70 if (!observer->cv_.wait_for(lk, std::chrono::seconds(SYNC_TIMEOUT), [=]() { return observer->resolved_; })) { in ExecResolveLocalService()
|