Home
last modified time | relevance | path

Searched refs:lck (Results 1 - 25 of 94) sorted by relevance

1234

/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_condition.cpp56 std::unique_lock lck(lock_); in HWTEST_F()
57 cond.wait(lck, [&] { return a == 1; }); in HWTEST_F()
63 std::unique_lock lck(lock_); in HWTEST_F()
79 std::unique_lock lck(lock_); in HWTEST_F()
80 cond.wait(lck, [&] { return a == 1; }); in HWTEST_F()
85 std::unique_lock lck(lock_); in HWTEST_F()
86 cond.wait(lck, [&] { return a == 1; }); in HWTEST_F()
92 std::unique_lock lck(lock_); in HWTEST_F()
109 std::unique_lock lck(lock_); in HWTEST_F()
110 cond.wait_for(lck, 10 in HWTEST_F()
[all...]
/foundation/filemanagement/dfs_service/frameworks/native/cloud_file_kit_inner/src/data_sync/
H A Dsync_state_manager.cpp27 std::unique_lock<std::shared_mutex> lck(syncMutex_); in UpdateSyncState()
35 std::unique_lock<std::shared_mutex> lck(syncMutex_); in CheckAndSetPending()
65 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetCleaningFlag()
72 std::unique_lock<std::shared_mutex> lck(syncMutex_); in ClearCleaningFlag()
84 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetDisableCloudFlag()
91 std::unique_lock<std::shared_mutex> lck(syncMutex_); in ClearDisableCloudFlag()
103 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetStopSyncFlag()
/foundation/multimedia/audio_framework/services/audio_service/client/include/
H A Daudio_timer.h43 std::unique_lock<std::mutex> lck(timerMutex); in ~AudioTimer()
55 std::unique_lock<std::mutex> lck(timerMutex); in StartTimer()
63 std::unique_lock<std::mutex> lck(timerMutex); in StopTimer()
90 std::unique_lock<std::mutex> lck(timerMutex); in TimerLoopFunc()
95 if (!timerCtrl.wait_for(lck, std::chrono::seconds(timeoutDuration), in TimerLoopFunc()
102 timerCtrl.wait(lck, [this] { return CheckTimerStarted(); }); in TimerLoopFunc()
/foundation/resourceschedule/ffrt/src/util/
H A Dts_list.h30 std::unique_lock<std::shared_mutex> lck(mtx_); in emplace_back()
37 std::unique_lock<std::shared_mutex> lck(mtx_); in push_back()
43 std::shared_lock<std::shared_mutex> lck(mtx_); in get_all()
49 std::unique_lock<std::shared_mutex> lck(mtx_); in claim()
/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dring_buffer.h46 OSAL::ScopedLock lck(writeMutex_); in ReadBuffer()
53 writeCondition_.Wait(lck); in ReadBuffer()
79 OSAL::ScopedLock lck(writeMutex_); in WriteBuffer()
85 writeCondition_.Wait(lck); in WriteBuffer()
105 OSAL::ScopedLock lck(writeMutex_); in SetActive()
133 OSAL::ScopedLock lck(writeMutex_); in Clear()
141 OSAL::ScopedLock lck(writeMutex_); in Seek()
/foundation/multimedia/media_foundation/interface/inner_api/osal/utils/
H A Dring_buffer.h46 AutoLock lck(writeMutex_); in ReadBuffer()
53 writeCondition_.Wait(lck); in ReadBuffer()
79 AutoLock lck(writeMutex_); in WriteBuffer()
85 writeCondition_.Wait(lck); in WriteBuffer()
105 AutoLock lck(writeMutex_); in SetActive()
119 AutoLock lck(writeMutex_); in SetReadBlocking()
152 AutoLock lck(writeMutex_); in Clear()
161 AutoLock lck(writeMutex_); in SetTail()
172 AutoLock lck(writeMutex_); in Seek()
205 AutoLock lck(writeMutex in SetHead()
[all...]
/foundation/resourceschedule/ffrt/src/tm/
H A Dscpu_task.cpp61 std::unique_lock<decltype(parent->mutex_)> lck(parent->mutex_); in DecChildRef()
69 lck.unlock(); in DecChildRef()
77 lck.unlock(); in DecChildRef()
101 std::lock_guard<decltype(mutex_)> lck(mutex_); in DecWaitDataRef()
125 std::unique_lock<decltype(mutex_)> lck(mutex_); in RecycleTask()
128 lck.unlock(); in RecycleTask()
H A Dscpu_task.h77 std::unique_lock<decltype(root->mutex_)> lck(root->mutex_); in ~RootTaskCtxWrapper()
79 lck.unlock(); in ~RootTaskCtxWrapper()
/foundation/communication/ipc/ipc/test/auxiliary/native/src/
H A Dfoo_service.cpp59 std::unique_lock<std::mutex> lck(mutex_); in WaitForAsyncReply()
60 cv_.wait_for(lck, std::chrono::milliseconds(timeout), [&]() { in WaitForAsyncReply()
68 std::unique_lock<std::mutex> lck(mutex_); in SendAsyncReply()
75 std::unique_lock<std::mutex> lck(decTimeMutex_); in ~FooStub()
81 std::unique_lock<std::mutex> lck(decTimeMutex_); in CleanDecTimes()
87 std::unique_lock<std::mutex> lck(decTimeMutex_); in GetDecTimes()
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/drawing_ndk/drawing_utils/
H A Dnative_pixel_map_manager.cpp26 std::lock_guard<std::mutex> lck(mutex_); in Register()
32 std::lock_guard<std::mutex> lck(mutex_); in Unregister()
38 std::lock_guard<std::mutex> lck(mutex_); in GetNativePixelMapType()
/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/
H A Dmock.h50 std::unique_lock<std::mutex> lck(mtx_); in Wait()
52 cv_.wait(lck); in Wait()
58 std::unique_lock<std::mutex> lck(mtx_); in Notify()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/
H A Dgatt_service_base.h38 std::lock_guard<std::mutex> lck(mutexRunningState_); in InRunningState()
43 std::lock_guard<std::mutex> lck(mutexRunningState_); in Start()
48 std::lock_guard<std::mutex> lck(mutexRunningState_); in Stop()
/foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/src/
H A Dcloud_file_kit_impl.cpp59 std::lock_guard<std::mutex> lck(dataSyncManagerMutex_); in GetDataSyncManager()
69 std::lock_guard<std::mutex> lck(cloudAssetsDownloaderMutex_); in GetCloudAssetsDownloader()
79 std::lock_guard<std::mutex> lck(cloudSyncHelperMutex_); in GetCloudSyncHelper()
91 std::lock_guard<std::mutex> lck(cloudDatabaseMutex_); in GetCloudDatabase()
/foundation/ability/ability_runtime/frameworks/native/appkit/ability_delegator/
H A Dability_delegator.cpp41 std::unique_lock<std::mutex> lck(mutexMonitor_); in AddAbilityMonitor()
57 std::unique_lock<std::mutex> lck(mutexStageMonitor_); in AddAbilityStageMonitor()
73 std::unique_lock<std::mutex> lck(mutexMonitor_); in RemoveAbilityMonitor()
86 std::unique_lock<std::mutex> lck(mutexStageMonitor_); in RemoveAbilityStageMonitor()
95 std::unique_lock<std::mutex> lck(mutexMonitor_); in ClearAllMonitors()
101 std::unique_lock<std::mutex> lck(mutexMonitor_); in GetMonitorsNum()
107 std::unique_lock<std::mutex> lck(mutexStageMonitor_); in GetStageMonitorsNum()
195 std::unique_lock<std::mutex> lck(mutexAbilityProperties_); in GetAbilityState()
222 std::unique_lock<std::mutex> lck(mutexAbilityProperties_); in GetCurrentTopAbility()
375 std::unique_lock<std::mutex> lck(mutexMonitor in PostPerformStart()
[all...]
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_policy_callback.cpp179 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
207 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
236 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
264 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
265 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
289 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
290 g_cv.wait_for(lck, st in HWTEST_F()
[all...]
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/conn_vpn_manager_test/
H A Dut_net_policy_callback.cpp179 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
180 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
207 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
208 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
236 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
237 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
264 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
265 g_cv.wait_for(lck, std::chrono::seconds(10)); in HWTEST_F()
289 std::unique_lock<std::mutex> lck(g_callbackMutex); in HWTEST_F()
290 g_cv.wait_for(lck, st in HWTEST_F()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/server/src/
H A Dbluetooth_gatt_client_server.cpp68 std::lock_guard<std::mutex> lck(impl_->registerMutex_);
244 std::lock_guard<std::mutex> lck(owner_.pimpl->registerMutex_); in OnRemoteDied()
292 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RegisterApplication()
322 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in DeregisterApplication()
351 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in Connect()
369 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in Disconnect()
380 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in DiscoveryServices()
395 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in ReadCharacteristic()
415 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in WriteCharacteristic()
429 std::lock_guard<std::mutex> lck(pimp in SignedWriteCharacteristic()
[all...]
H A Dbluetooth_gatt_server_server.cpp67 std::lock_guard<std::mutex> lck(impl_->registerMutex_);
253 std::lock_guard<std::mutex> lck(owner_.pimpl->registerMutex_); in OnRemoteDied()
313 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in AddService()
328 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in ClearServices()
356 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in NotifyClient()
377 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RemoveService()
395 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondCharacteristicRead()
417 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondCharacteristicWrite()
436 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondDescriptorRead()
458 std::lock_guard<std::mutex> lck(pimp in RespondDescriptorWrite()
[all...]
/foundation/communication/wifi/wifi/base/state_machine/src/
H A Dmessage_queue.cpp72 std::unique_lock<std::mutex> lck(mMtxQueue); in AddMessageToQueue()
107 std::unique_lock<std::mutex> lck(mMtxQueue); in DeleteMessageFromQueue()
148 std::unique_lock<std::mutex> lck(mMtxQueue); // Data queue lock in GetNextMessage()
173 std::unique_lock<std::mutex> lck(mtxBlock); // mCvQueue lock in GetNextMessage()
175 if (mCvQueue.wait_for(lck, std::chrono::milliseconds(nextBlockTime)) == std::cv_status::timeout) { in GetNextMessage()
/foundation/resourceschedule/ffrt/src/sched/
H A Dmulti_workgroup.cpp90 std::lock_guard<std::mutex> lck(wgLock); in CreateRSWorkGroup()
109 std::lock_guard<std::mutex> lck(wgLock); in LeaveRSWorkGroup()
124 std::lock_guard<std::mutex> lck(wgLock); in JoinRSWorkGroup()
148 std::lock_guard<std::mutex> lck(wgLock); in DestoryRSWorkGroup()
216 std::lock_guard<std::mutex> lck(wgLock); in WorkgroupCreate()
239 std::lock_guard<std::mutex> lck(wgLock); in WorkgroupClear()
/foundation/resourceschedule/ffrt/src/eu/
H A Dworker_manager.cpp23 std::shared_lock<std::shared_mutex> lck(tgwrap.tgMutex); in JoinRtg()
39 std::unique_lock<std::shared_mutex> lck(tgwrap.tgMutex); in JoinTG()
66 std::unique_lock<std::shared_mutex> lck(tgwrap.tgMutex); in LeaveTG()
/foundation/distributeddatamgr/data_share/frameworks/native/common/include/
H A Dcallbacks_manager.h98 std::lock_guard<decltype(mutex_)> lck(mutex_); in AddObservers()
123 std::lock_guard<decltype(mutex_)> lck(mutex_); in GetKeys()
172 std::lock_guard<decltype(mutex_)> lck(mutex_); in DelObservers()
192 std::lock_guard<decltype(mutex_)> lck(mutex_); in DelObservers()
210 std::lock_guard<decltype(mutex_)> lck(mutex_); in GetEnabledObservers()
234 std::lock_guard<decltype(mutex_)> lck(mutex_); in EnableObservers()
280 std::lock_guard<decltype(mutex_)> lck(mutex_); in DisableObservers()
321 std::lock_guard<decltype(mutex_)> lck(mutex_); in GetAllSubscriberSize()
331 std::lock_guard<decltype(mutex_)> lck(mutex_); in GetAllSubscriberSize()
342 std::lock_guard<decltype(mutex_)> lck(mutex in SetObserversNotifiedOnEnabled()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_kv_backup_test.cpp224 std::unique_lock<std::mutex> lck(count); in HWTEST_F()
225 g_kvBackupVar.wait(lck, [&]{return exportFlag;}); in HWTEST_F()
251 std::unique_lock<std::mutex> lck(count); in HWTEST_F()
252 g_kvBackupVar.wait(lck, [&]{return exportFlag;}); in HWTEST_F()
309 std::unique_lock<std::mutex> lck(count); in HWTEST_F()
310 g_kvBackupVar.wait(lck, [&]{return importFlag;}); in HWTEST_F()
360 std::unique_lock<std::mutex> lck(count); in HWTEST_F()
361 g_kvBackupVar.wait(lck, [&]{return rekeyFlag;}); in HWTEST_F()
405 std::unique_lock<std::mutex> lck(count); in HWTEST_F()
406 g_kvBackupVar.wait(lck, [ in HWTEST_F()
[all...]
/foundation/ability/ability_runtime/frameworks/native/ability/native/
H A Dability_post_event_timeout.cpp66 std::lock_guard<std::mutex> lck(mtx_); in TimeEnd()
81 std::lock_guard<std::mutex> lck(mtx_); in TimeOutProc()
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/sync_rule/
H A Duser_status_listener.cpp56 std::lock_guard<std::mutex> lck(obsVecMutex_); in AddObserver()
62 std::lock_guard<std::mutex> lck(obsVecMutex_); in NotifyUserUnlocked()

Completed in 11 milliseconds

1234