| /foundation/multimedia/audio_framework/frameworks/native/audiocapturer/test/unittest/capturer_test/src/ |
| H A D | audio_fast_capturer_unit_test.cpp | 124 cv.wait_for(lock, 1s, [&count] { in HWTEST_F()
|
| /foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | threaded_task_queue.cpp | 112 addCondition_.wait_for(lock, std::chrono::microseconds(delta.ToMicroseconds())); in ProcessTasks()
|
| /foundation/multimedia/audio_framework/services/audio_service/common/src/ |
| H A D | audio_thread_task.cpp | 144 cond_.wait_for(lock, std::chrono::milliseconds(TIME_OUT_MS), in RunJob()
|
| /foundation/filemanagement/user_file_service/services/native/file_access_service/src/ |
| H A D | file_access_ext_connection.cpp | 71 if (!connectLockInfo_.condition.wait_for(lock, std::chrono::seconds(WAIT_TIME), in ConnectFileExtAbility()
|
| /foundation/graphic/graphic_2d/rosen/modules/composer/hdi_backend/src/ |
| H A D | hdi_framebuffer_surface.cpp | 141 bufferCond_.wait_for(lock, 1000ms, [this]() { return !availableBuffers_.empty(); }); in GetFramebuffer()
|
| /foundation/filemanagement/user_file_service/interfaces/inner_api/file_access/src/ |
| H A D | app_file_access_ext_connection.cpp | 81 if (!connectLockInfo_.condition.wait_for(lock, std::chrono::seconds(WAIT_TIME), in ConnectFileExtAbility()
|
| /foundation/multimedia/av_session/services/session/adapter/ |
| H A D | ability_manager_adapter.cpp | 98 auto waitStatus = syncCon_.wait_for(lock, std::chrono::milliseconds(timeout)); in WaitForTimeout()
|
| /foundation/multimedia/camera_framework/services/camera_service/include/avcodec/common/ |
| H A D | audio_record.h | 131 canReleased_.wait_for(lock, std::chrono::milliseconds(BUFFER_RELEASE_EXPIREATION_TIME), in ReleaseAudioBuffer()
|
| /foundation/multimedia/camera_framework/frameworks/js/camera_napi/src/ |
| H A D | camera_napi_worker_queue_keeper.cpp | 123 isMatchCondition = workerCond_.wait_for(lock, std::chrono::milliseconds(WORKER_TIMEOUT), in ConsumeWorkerQueueTask()
|
| /foundation/multimedia/camera_framework/services/camera_service/src/avcodec/common/ |
| H A D | frame_record.cpp | 48 canReleased_.wait_for(lock, std::chrono::milliseconds(BUFFER_RELEASE_EXPIREATION_TIME), in ReleaseSurfaceBuffer()
|
| /foundation/multimedia/ringtone_library/services/ringtone_restore/src/ |
| H A D | ringtone_rdb_transaction.cpp | 76 transactionCV_.wait_for(cvLock, chrono::milliseconds(RDB_TRANSACTION_WAIT_MS), in BeginTransaction()
|
| /foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/ |
| H A D | task_scheduler.cpp | 96 auto res = future.wait_for(span); in PostSyncTask()
|
| /foundation/communication/netmanager_base/utils/common_utils/include/ |
| H A D | delayed_queue.h | 49 needRunCondition_.wait_for(needRunLock, std::chrono::seconds(1), [this] { return !needRun_; });
in DelayedQueue()
|
| /foundation/communication/ipc/ipc/test/auxiliary/native/src/ |
| H A D | foo_service.cpp | 60 cv_.wait_for(lck, std::chrono::milliseconds(timeout), [&]() { in WaitForAsyncReply()
|
| /foundation/communication/netstack/utils/common_utils/include/ |
| H A D | thread_pool.h | 152 needRunCondition_.wait_for(lock, std::chrono::seconds(timeout_),
in Sleep()
|
| /foundation/communication/nfc/interfaces/inner_api/controller/ |
| H A D | nfc_sa_client.cpp | 91 auto wait = locatorCond_.wait_for(lock, std::chrono::milliseconds(NFC_LOADSA_TIMEOUT_MS), [this] { in WaitLoadStateChange()
|
| /foundation/communication/wifi/wifi/utils/src/ |
| H A D | wifi_sa_manager.cpp | 72 auto wait = locatorCon_.wait_for(lock, std::chrono::milliseconds(WIFI_LOADSA_TIMEOUT_MS), [this] { in WaitLoadStateChange()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/provider/src/ |
| H A D | datashare_uv_queue.cpp | 77 if (uvEntry->condition.wait_for(lock, std::chrono::seconds(WAIT_TIME), [uvEntry] { return uvEntry->done; })) { in SyncCall()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | ref_object.cpp | 141 cv.wait_for(lock, std::chrono::seconds(seconds)); in WaitLockedUntil()
|
| /foundation/distributedhardware/distributed_audio/services/audiotransport/receiverengine/src/ |
| H A D | av_receiver_engine_adapter.cpp | 123 auto status = chnCreatedCondVar_.wait_for(lock, std::chrono::milliseconds(WAIT_TIMEOUT_MS), in WaitForChannelCreated()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/ |
| H A D | task_board.cpp | 37 auto status = conVar_.wait_for(lock, std::chrono::milliseconds(TASK_TIMEOUT_MS), in WaitForALLTaskFinish()
|
| /foundation/filemanagement/dfs_service/services/clouddisk_database/src/ |
| H A D | clouddisk_rdb_transaction.cpp | 82 transactionCvMap_[idx_].wait_for(cvLock, chrono::milliseconds(RDB_TRANSACTION_WAIT_MS), in BeginTransaction()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/componentmanager/ |
| H A D | component_enable.cpp | 59 auto waitStatus = conVar_.wait_for(lock, std::chrono::milliseconds(ENABLE_TIMEOUT_MS), in Enable()
|
| /foundation/distributedhardware/distributed_input/sinkhandler/src/ |
| H A D | distributed_input_sink_handler.cpp | 62 auto waitStatus = proxyConVar_.wait_for(lock, std::chrono::milliseconds(INPUT_LOAD_SA_TIMEOUT_MS), in InitSink()
|
| /foundation/communication/dhcp/frameworks/native/src/ |
| H A D | dhcp_sa_manager.cpp | 71 auto wait = locatorCon_.wait_for(lock, std::chrono::milliseconds(DHCP_LOADSA_TIMEOUT_MS), [this] { in WaitLoadStateChange()
72 DHCP_LOGI("DhcpSaLoadManager wait_for"); in WaitLoadStateChange()
|