Home
last modified time | relevance | path

Searched refs:lck (Results 1 – 25 of 154) sorted by relevance

1234567

/ohos5.0/base/telephony/core_service/services/sim/src/
H A Dsim_state_manager.cpp36 std::lock_guard<std::mutex> lck(mtx_); in Init() local
64 std::lock_guard<std::mutex> lck(mtx_); in RegisterCoreNotify() local
74 std::lock_guard<std::mutex> lck(mtx_); in UnRegisterCoreNotify() local
82 std::lock_guard<std::mutex> lck(mtx_); in HasSimCard() local
140 std::unique_lock<std::mutex> lck(ctx_); in SyncCmdResponse() local
152 std::unique_lock<std::mutex> lck(ctx_); in UnlockPin() local
186 std::unique_lock<std::mutex> lck(ctx_); in UnlockPuk() local
220 std::unique_lock<std::mutex> lck(ctx_); in AlterPin() local
263 std::unique_lock<std::mutex> lck(ctx_); in SetLockState() local
302 std::unique_lock<std::mutex> lck(ctx_); in GetLockState() local
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_condition.cpp56 std::unique_lock lck(lock_); in __anone2a138be0102() local
63 std::unique_lock lck(lock_); in __anone2a138be0502() local
79 std::unique_lock lck(lock_); in __anone2a138be0802() local
85 std::unique_lock lck(lock_); in __anone2a138be0c02() local
92 std::unique_lock lck(lock_); in __anone2a138be1002() local
109 std::unique_lock lck(lock_); in __anone2a138be1302() local
117 std::unique_lock lck(lock_); in __anone2a138be1702() local
134 std::unique_lock lck(lock_); in __anone2a138be1a02() local
135 status = cond.wait_for(lck, 100ms); in __anone2a138be1a02()
149 std::unique_lock lck(lock_);
[all …]
H A Dut_csync.cpp210 std::unique_lock lck(lock_); in __anonc91b23f70d02() local
211 cond.wait(lck, [&] { return a == 1; }); in __anonc91b23f70d02()
217 std::unique_lock lck(lock_); in __anonc91b23f71102() local
233 std::unique_lock lck(lock_); in __anonc91b23f71402() local
234 cond.wait(lck, [&] { return a == 1; }); in __anonc91b23f71402()
239 std::unique_lock lck(lock_); in __anonc91b23f71802() local
245 std::unique_lock lck(lock_); in __anonc91b23f71c02() local
252 std::unique_lock lck(lock_); in __anonc91b23f72002() local
268 std::unique_lock lck(lock_); in __anonc91b23f72302() local
275 std::unique_lock lck(lock_); in __anonc91b23f72702() local
[all …]
/ohos5.0/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() local
35 std::unique_lock<std::shared_mutex> lck(syncMutex_); in CheckAndSetPending() local
65 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetCleaningFlag() local
72 std::unique_lock<std::shared_mutex> lck(syncMutex_); in ClearCleaningFlag() local
84 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetDisableCloudFlag() local
91 std::unique_lock<std::shared_mutex> lck(syncMutex_); in ClearDisableCloudFlag() local
103 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetStopSyncFlag() local
/ohos5.0/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/merge_node/
H A Dmerge_node.cpp26 std::unique_lock<std::mutex> lck(mtx_); in ~MergeNode() local
43 std::unique_lock<std::mutex> lck(mtx_); in Start() local
57 std::unique_lock<std::mutex> lck(mtx_); in Stop() local
79 std::unique_lock<std::mutex> lck(mtx_); in DeliverBuffers() local
89 std::unique_lock<std::mutex> lck(mtx_); in DealSecondBuffer() local
108 std::unique_lock<std::mutex> lck(mtx_); in MergeBuffers() local
119 std::unique_lock<std::mutex> lck(mtx_); in MergeBuffers() local
124 cv_.wait(lck, [this] { return !mergeVec_.empty(); }); in MergeBuffers()
/ohos5.0/foundation/multimedia/media_foundation/interface/inner_api/osal/utils/
H A Dring_buffer.h46 AutoLock lck(writeMutex_);
53 writeCondition_.Wait(lck);
79 AutoLock lck(writeMutex_); in WriteBuffer()
85 writeCondition_.Wait(lck); in WriteBuffer()
105 AutoLock lck(writeMutex_);
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()
/ohos5.0/base/powermgr/battery_manager/test/systemtest/src/
H A Dbattery_event_system_test.cpp428 std::unique_lock<std::mutex> lck(g_mtx);
448 std::unique_lock<std::mutex> lck(g_mtx);
449 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) {
469 std::unique_lock<std::mutex> lck(g_mtx);
470 if (g_cv.wait_for(lck, std::chrono::seconds(TIME_OUT)) == std::cv_status::timeout) {
490 std::unique_lock<std::mutex> lck(g_mtx);
511 std::unique_lock<std::mutex> lck(g_mtx);
532 std::unique_lock<std::mutex> lck(g_mtx);
553 std::unique_lock<std::mutex> lck(g_mtx);
574 std::unique_lock<std::mutex> lck(g_mtx);
[all …]
/ohos5.0/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()
/ohos5.0/foundation/ability/ability_runtime/frameworks/native/appkit/ability_delegator/
H A Dability_delegator.cpp41 std::unique_lock<std::mutex> lck(mutexMonitor_); in AddAbilityMonitor() local
73 std::unique_lock<std::mutex> lck(mutexMonitor_); in RemoveAbilityMonitor() local
95 std::unique_lock<std::mutex> lck(mutexMonitor_); in ClearAllMonitors() local
101 std::unique_lock<std::mutex> lck(mutexMonitor_); in GetMonitorsNum() local
375 std::unique_lock<std::mutex> lck(mutexMonitor_); in PostPerformStart() local
425 std::unique_lock<std::mutex> lck(mutexMonitor_); in PostPerformScenceCreated() local
453 std::unique_lock<std::mutex> lck(mutexMonitor_); in PostPerformScenceRestored() local
481 std::unique_lock<std::mutex> lck(mutexMonitor_); in PostPerformScenceDestroyed() local
509 std::unique_lock<std::mutex> lck(mutexMonitor_); in PostPerformForeground() local
537 std::unique_lock<std::mutex> lck(mutexMonitor_); in PostPerformBackground() local
[all …]
/ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dring_buffer.h46 OSAL::ScopedLock lck(writeMutex_);
53 writeCondition_.Wait(lck);
79 OSAL::ScopedLock lck(writeMutex_); in WriteBuffer()
85 writeCondition_.Wait(lck); in WriteBuffer()
105 OSAL::ScopedLock lck(writeMutex_);
133 OSAL::ScopedLock lck(writeMutex_); in Clear()
141 OSAL::ScopedLock lck(writeMutex_); in Seek()
/ohos5.0/foundation/communication/ipc/ipc/test/auxiliary/native/src/
H A Dfoo_service.cpp59 std::unique_lock<std::mutex> lck(mutex_); in WaitForAsyncReply() local
60 cv_.wait_for(lck, std::chrono::milliseconds(timeout), [&]() { in WaitForAsyncReply()
68 std::unique_lock<std::mutex> lck(mutex_); in SendAsyncReply() local
75 std::unique_lock<std::mutex> lck(decTimeMutex_); in ~FooStub() local
81 std::unique_lock<std::mutex> lck(decTimeMutex_); in CleanDecTimes() local
87 std::unique_lock<std::mutex> lck(decTimeMutex_); in GetDecTimes() local
/ohos5.0/foundation/resourceschedule/ffrt/src/tm/
H A Dscpu_task.cpp59 std::unique_lock<decltype(parent->mutex_)> lck(parent->mutex_); in DecChildRef() local
67 lck.unlock(); in DecChildRef()
75 lck.unlock(); in DecChildRef()
99 std::lock_guard<decltype(mutex_)> lck(mutex_); in DecWaitDataRef() local
123 std::unique_lock<decltype(mutex_)> lck(mutex_); in RecycleTask() local
126 lck.unlock(); in RecycleTask()
/ohos5.0/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);
180 g_cv.wait_for(lck, std::chrono::seconds(10));
207 std::unique_lock<std::mutex> lck(g_callbackMutex);
208 g_cv.wait_for(lck, std::chrono::seconds(10));
236 std::unique_lock<std::mutex> lck(g_callbackMutex);
237 g_cv.wait_for(lck, std::chrono::seconds(10));
264 std::unique_lock<std::mutex> lck(g_callbackMutex);
265 g_cv.wait_for(lck, std::chrono::seconds(10));
289 std::unique_lock<std::mutex> lck(g_callbackMutex);
290 g_cv.wait_for(lck, std::chrono::seconds(10));
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/server/src/
H A Dbluetooth_gatt_client_server.cpp68 std::lock_guard<std::mutex> lck(impl_->registerMutex_); in OnSystemStateChange() local
292 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RegisterApplication() local
322 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in DeregisterApplication() local
351 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in Connect() local
369 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in Disconnect() local
380 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in DiscoveryServices() local
395 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in ReadCharacteristic() local
415 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in WriteCharacteristic() local
429 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in SignedWriteCharacteristic() local
444 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in ReadDescriptor() local
[all …]
H A Dbluetooth_gatt_server_server.cpp67 std::lock_guard<std::mutex> lck(impl_->registerMutex_); in OnSystemStateChange() local
313 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in AddService() local
328 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in ClearServices() local
356 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in NotifyClient() local
377 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RemoveService() local
395 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondCharacteristicRead() local
417 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondCharacteristicWrite() local
436 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondDescriptorRead() local
458 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RespondDescriptorWrite() local
471 std::lock_guard<std::mutex> lck(pimpl->registerMutex_); in RegisterApplication() local
[all …]
/ohos5.0/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()
/ohos5.0/base/hiviewdfx/faultloggerd/services/
H A Dfault_logger_pipe.cpp142 std::lock_guard<std::mutex> lck(pipeMapsMutex_); in FaultLoggerPipeMap() local
148 std::lock_guard<std::mutex> lck(pipeMapsMutex_); in ~FaultLoggerPipeMap() local
157 std::lock_guard<std::mutex> lck(pipeMapsMutex_); in Set() local
166 std::lock_guard<std::mutex> lck(pipeMapsMutex_); in Check() local
180 std::lock_guard<std::mutex> lck(pipeMapsMutex_); in Get() local
189 std::lock_guard<std::mutex> lck(pipeMapsMutex_); in Del() local
/ohos5.0/base/powermgr/power_manager/services/zidl/src/
H A Dpower_mgr_async_reply.cpp41 std::unique_lock<std::mutex> lck(mutex_); in SendAsyncReply() local
44 lck.unlock(); in SendAsyncReply()
50 std::unique_lock<std::mutex> lck(mutex_); in WaitForAsyncReply() local
51 cv_.wait_for(lck, std::chrono::milliseconds(timeout), [this]() { in WaitForAsyncReply()
/ohos5.0/commonlibrary/c_utils/base/src/
H A Dsemaphore_ex.cpp31 std::unique_lock<std::mutex> lck(mutex_); in Wait() local
33 cv_.wait(lck); in Wait()
39 std::unique_lock<mutex> lck(mutex_); in Post() local
/ohos5.0/foundation/resourceschedule/ffrt/src/sched/
H A Dmulti_workgroup.cpp91 std::lock_guard<std::mutex> lck(wgLock); in CreateRSWorkGroup() local
110 std::lock_guard<std::mutex> lck(wgLock); in LeaveRSWorkGroup() local
125 std::lock_guard<std::mutex> lck(wgLock); in JoinRSWorkGroup() local
149 std::lock_guard<std::mutex> lck(wgLock); in DestoryRSWorkGroup() local
216 std::lock_guard<std::mutex> lck(wgLock); in WorkgroupCreate() local
238 std::lock_guard<std::mutex> lck(wgLock); in WorkgroupClear() local
/ohos5.0/foundation/communication/wifi/wifi/base/state_machine/src/
H A Dmessage_queue.cpp72 std::unique_lock<std::mutex> lck(mMtxQueue); in AddMessageToQueue() local
107 std::unique_lock<std::mutex> lck(mMtxQueue); in DeleteMessageFromQueue() local
148 std::unique_lock<std::mutex> lck(mMtxQueue); // Data queue lock in GetNextMessage() local
173 std::unique_lock<std::mutex> lck(mtxBlock); // mCvQueue lock in GetNextMessage() local
175 … if (mCvQueue.wait_for(lck, std::chrono::milliseconds(nextBlockTime)) == std::cv_status::timeout) { in GetNextMessage()
/ohos5.0/foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/src/
H A Dcloud_file_kit_impl.cpp64 std::lock_guard<std::mutex> lck(dataSyncManagerMutex_); in GetDataSyncManager() local
74 std::lock_guard<std::mutex> lck(cloudAssetsDownloaderMutex_); in GetCloudAssetsDownloader() local
84 std::lock_guard<std::mutex> lck(cloudSyncHelperMutex_); in GetCloudSyncHelper() local
96 std::lock_guard<std::mutex> lck(cloudDatabaseMutex_); in GetCloudDatabase() local
/ohos5.0/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() local
32 std::lock_guard<std::mutex> lck(mutex_); in Unregister() local
38 std::lock_guard<std::mutex> lck(mutex_); in GetNativePixelMapType() local
/ohos5.0/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()
/ohos5.0/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()

1234567