Home
last modified time | relevance | path

Searched refs:uniqueLock (Results 1 – 25 of 36) sorted by relevance

12

/ohos5.0/base/hiviewdfx/hiview/plugins/performance/executor/
H A DThrTaskContainer.cpp39 std::unique_lock <std::mutex> uniqueLock(mut); in PostTask() local
62 std::unique_lock <std::mutex> uniqueLock(mut); in Entry() local
66 cv.wait(uniqueLock); in Entry()
76 uniqueLock.unlock(); in Entry()
78 uniqueLock.lock(); in Entry()
/ohos5.0/base/hiviewdfx/hiview/plugins/performance/timer/
H A DSceneTimerOhImpl.cpp61 std::unique_lock<std::mutex> uniqueLock(mut); in Loop() local
66 cv.wait_for(uniqueLock, interval); in Loop()
71 cv.wait(uniqueLock); in Loop()
77 std::unique_lock<std::mutex> uniqueLock(mut); in FillRecordAndNotify() local
88 std::unique_lock<std::mutex> uniqueLock(mut); in ValidateDuplication() local
96 std::unique_lock<std::mutex> uniqueLock(mut); in ValidateExistence() local
172 std::unique_lock<std::mutex> uniqueLock(mut); in RemoveRecordAndNotify() local
H A DAppTimerAdapter.cpp31 std::lock_guard<std::mutex> uniqueLock(mut); in Start() local
40 std::lock_guard<std::mutex> uniqueLock(mut); in Stop() local
50 std::lock_guard<std::mutex> uniqueLock(mut); in Expired() local
/ohos5.0/foundation/ai/intelligent_voice_framework/utils/
H A Dthread_wrapper.cpp29 std::unique_lock uniqueLock(mutex_); in Start() local
56 std::unique_lock uniqueLock(mutex_); in Join() local
61 uniqueLock.unlock(); in Join()
63 uniqueLock.lock(); in Join()
/ohos5.0/base/location/services/location_geocode/geocode/source/
H A Dgeo_convert_service.cpp150 std::unique_lock<std::mutex> uniqueLock(mutex_); in ConnectService() local
152 connectCondition_.wait_for(uniqueLock, in ConnectService()
166 std::unique_lock<std::mutex> uniqueLock(mutex_); in NotifyConnected() local
173 std::unique_lock<std::mutex> uniqueLock(mutex_); in NotifyDisConnected() local
287 std::unique_lock<std::mutex> uniqueLock(mutex_); in IsConnect() local
383 std::unique_lock<std::mutex> uniqueLock(mutex_); in ResetServiceProxy() local
401 std::unique_lock<std::mutex> uniqueLock(mutex_); in UnRegisterGeoServiceDeathRecipient() local
415 std::unique_lock<std::mutex> uniqueLock(mutex_); in SendGeocodeRequest() local
433 std::unique_lock<std::mutex> uniqueLock(connectStateMutex_); in GetServiceConnectState() local
439 std::unique_lock<std::mutex> uniqueLock(connectStateMutex_); in SetServiceConnectState() local
[all …]
/ohos5.0/base/location/frameworks/native/locator_sdk/source/
H A Dgeo_convert_callback_host.cpp68 std::unique_lock<std::mutex> uniqueLock(mutex_); in OnResults() local
77 std::unique_lock<std::mutex> uniqueLock(mutex_); in OnErrorReport() local
86 std::unique_lock<std::mutex> uniqueLock(mutex_); in GetResult() local
88 uniqueLock, std::chrono::seconds(GEOCODE_TIME_OUT), [this]() { return ready_; }); in GetResult()
/ohos5.0/base/location/services/location_network/network/source/
H A Dnetwork_ability.cpp64 std::unique_lock<ffrt::mutex> uniqueLock(connMutex_); in ~NetworkAbility() local
161 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in ConnectNlpService() local
195 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in ResetServiceProxy() local
202 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in NotifyConnected() local
209 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in NotifyDisConnected() local
308 std::unique_lock<ffrt::mutex> uniqueLock(connMutex_); in DisconnectAbilityConnect() local
329 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in RequestNetworkLocation() local
357 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in RemoveNetworkLocation() local
518 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in RegisterNlpServiceDeathRecipient() local
531 std::unique_lock<ffrt::mutex> uniqueLock(nlpServiceMutex_); in UnregisterNlpServiceDeathRecipient() local
[all …]
/ohos5.0/foundation/multimodalinput/input/uinput/
H A Dinject_thread.cpp29 std::unique_lock<std::mutex> uniqueLock(mutex_); in InjectFunc() local
31 conditionVariable_.wait(uniqueLock); in InjectFunc()
/ohos5.0/drivers/peripheral/input/ddk_service/src/emit_event_manager/
H A Dinject_thread.cpp58 std::unique_lock<std::mutex> uniqueLock(mutex_); in InjectFunc() local
60 conditionVariable_.wait(uniqueLock, [this] { in InjectFunc()
/ohos5.0/foundation/filemanagement/app_file_service/services/backup_sa/include/module_app_gallery/
H A Dapp_gallery_service_connection.h73 std::unique_lock<std::mutex> uniqueLock(T::connectMutex); in ConnectExtAbility()
74 T::conditionVal_.wait_for(uniqueLock, std::chrono::seconds(CONNECT_TIME)); in ConnectExtAbility()
/ohos5.0/drivers/peripheral/usb/ddk/host/src/
H A Dddk_uevent_queue.cpp158 std::unique_lock<std::mutex> uniqueLock(queueLock_); in Init() local
159 conditionVariable_.wait(uniqueLock, [this] { in Init()
165 uniqueLock.unlock(); in Init()
/ohos5.0/base/notification/distributed_notification_service/frameworks/ans/src/
H A Dpush_callback_stub.cpp88 std::unique_lock<std::mutex> uniqueLock(pushCallBackParam->callBackMutex); in OnRemoteRequest() local
100 … pushCallBackParam->callBackCondition.wait(uniqueLock, [=]() {return pushCallBackParam->ready; }); in OnRemoteRequest()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_db_proxy_test.cpp100 std::unique_lock<std::mutex> uniqueLock(processMutex); in Sync() local
101 cv.wait(uniqueLock, [&syncProcess]() { in Sync()
427 std::unique_lock<std::mutex> uniqueLock(processMutex);
428 cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [&finished]() { in __anon9cf3a58a0602()
502 std::unique_lock<std::mutex> uniqueLock(waitMutex);
503 …waitCv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MAX_TIMEOUT), [&currentCount, sc… in __anon9cf3a58a0802()
733 std::unique_lock<std::mutex> uniqueLock(processMutex);
734 cv.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MIN_TIMEOUT), [&callCount]() { in __anon9cf3a58a0c02()
H A Ddistributeddb_cloud_kv_syncer_test.cpp183 std::unique_lock<std::mutex> uniqueLock(dataMutex); in BlockSync() local
184 cv.wait(uniqueLock, [&finish]() { in BlockSync()
635 std::unique_lock<std::mutex> uniqueLock(dataMutex);
636 cv.wait(uniqueLock, [&finish]() { return finish; }); in __anon644cd9970f02()
/ohos5.0/base/update/updateservice/services/engine/src/
H A Dupdate_notify.cpp97 std::unique_lock<std::mutex> uniqueLock(connectMutex_); in HandleMessage() local
98 conditionVal_.wait_for(uniqueLock, std::chrono::seconds(UPDATE_APP_CONNECT_TIMEOUT)); in HandleMessage()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_thread_pool_test.cpp66 std::unique_lock<std::mutex> uniqueLock(countLock_); in SafeExit() local
67 countCv_.wait(uniqueLock, [this]() { in SafeExit()
475 std::unique_lock<std::mutex> uniqueLock(dataMutex);
477 cv.wait(uniqueLock, [&finishedTaskCount]() { in __anonbed5c56d1002()
/ohos5.0/base/hiviewdfx/hiview/plugins/eventlogger/
H A Dactive_key_event.cpp41 std::unique_lock<ffrt::mutex> uniqueLock(mutex_); in ~ActiveKeyEvent() local
89 std::unique_lock<ffrt::mutex> uniqueLock(mutex_); in InitSubscribe() local
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/
H A Dcloudsync_fuzzer.cpp78 std::unique_lock<std::mutex> uniqueLock(mutex_); in WaitForFinish() local
80 cv_.wait_for(uniqueLock, std::chrono::milliseconds(DBConstant::MAX_TIMEOUT), [this]() { in WaitForFinish()
326 std::unique_lock<std::mutex> uniqueLock(dataMutex); in KvBlockSync() local
327 cv.wait(uniqueLock, [&finish]() { in KvBlockSync()
/ohos5.0/foundation/communication/netmanager_ext/frameworks/native/netshareclient/src/
H A Dnetworkshare_client.cpp225 std::unique_lock<std::mutex> uniqueLock(g_mutexCv); in GetProxy() local
226 g_cv.wait_for(uniqueLock, std::chrono::seconds(WAIT_REMOTE_TIME_SEC), in GetProxy()
/ohos5.0/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_ring_cache.cpp108 std::unique_lock<std::mutex> uniqueLock(cacheMutex_); in ReConfig() local
114 uniqueLock.unlock(); // unlock as Enqueue will lock in ReConfig()
/ohos5.0/foundation/multimodalinput/input/test/unittest/common/src/
H A Devent_util_test.cpp157 std::unique_lock<std::mutex> uniqueLock(mutex_); in GetEventDump() local
161 if (conditionVariable_.wait_for(uniqueLock, in GetEventDump()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_multi_sub_user_test.cpp301 std::unique_lock<std::mutex> uniqueLock(dataMutex); in BlockSync() local
302 cv.wait(uniqueLock, [&finish]() { in BlockSync()
394 std::unique_lock<std::mutex> uniqueLock(dataMutex); in CallSync() local
395 cv.wait(uniqueLock, [&finish]() { in CallSync()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_check_sync_test.cpp107 std::unique_lock<std::mutex> uniqueLock(dataMutex); in BlockSync() local
108 cv.wait(uniqueLock, [&finish]() { in BlockSync()
136 std::unique_lock<std::mutex> uniqueLock(dataMutex); in BlockPrioritySync() local
137 cv.wait(uniqueLock, [&finish]() { in BlockPrioritySync()
500 std::unique_lock<std::mutex> uniqueLock(dataMutex); in PriorityAndNormalSync() local
501 cv.wait(uniqueLock, [&normalFinish]() { in PriorityAndNormalSync()
1310 std::unique_lock<std::mutex> uniqueLock(dataMutex); in __anonc8f560be1402() local
1311 cv.wait(uniqueLock, [&finish]() { in __anonc8f560be1402()
/ohos5.0/base/notification/distributed_notification_service/frameworks/js/napi/src/manager/
H A Dnapi_push_callback.cpp101 std::unique_lock<std::mutex> uniqueLock(callBackParam->callBackMutex); in CallBackReturn() local
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_remove_device_data_test.cpp827 std::unique_lock<std::mutex> uniqueLock(dataMutex1);
828 cv1.wait(uniqueLock, [&finish1] { in __anonca7e63500902()
833 std::unique_lock<std::mutex> uniqueLock(dataMutex2);
834 cv2.wait(uniqueLock, [&finish2] { in __anonca7e63500a02()

12