Home
last modified time | relevance | path

Searched refs:lk (Results 1 – 25 of 137) sorted by relevance

123456

/ohos5.0/foundation/resourceschedule/ffrt/interfaces/kits/cpp/
H A Dcondition_variable.h51 …std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp, Pred&& pred) noex… in wait_until() argument
54 if (wait_until(lk, tp) == cv_status::timeout) { in wait_until()
64 return _wait_for(lk, tp - Clock::now()); in wait_until()
70 return _wait_for(lk, sleep_time); in wait_for()
77 … return wait_until(lk, std::chrono::steady_clock::now() + sleepTime, std::forward<Pred>(pred)); in wait_for()
81 void wait(std::unique_lock<mutex>& lk, Pred&& pred) in wait() argument
84 wait(lk); in wait()
88 void wait(std::unique_lock<mutex>& lk) in wait() argument
90 ffrt_cond_wait(this, lk.mutex()); in wait()
105 …cv_status _wait_for(std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& dur) no… in _wait_for() argument
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/sync/
H A Dwait_queue.cpp42 lk->unlock(); in ThreadWait()
45 lk->lock(); in ThreadWait()
48 bool WaitQueue::ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, in ThreadWaitUntil() argument
62 lk->unlock(); in ThreadWaitUntil()
76 lk->lock(); in ThreadWaitUntil()
80 void WaitQueue::SuspendAndWait(mutexPrivate* lk) in SuspendAndWait() argument
85 ThreadWait(&ctx->wn, lk, LegacyMode(task), task); in SuspendAndWait()
101 lk->lock(); in SuspendAndWait()
131 return ThreadWaitUntil(&ctx->wn, lk, tp, LegacyMode(task), task); in SuspendAndWaitUntil()
167 lk->lock(); in SuspendAndWaitUntil()
[all …]
H A Dwait_queue.h57 std::mutex lk; member
64 void SuspendAndWait(mutexPrivate* lk);
65 bool SuspendAndWaitUntil(mutexPrivate* lk, const TimePoint& tp) noexcept;
93 void ThreadWait(WaitUntilEntry* wn, mutexPrivate* lk, bool legacyMode, CPUEUTask* task);
94 …bool ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, const TimePoint& tp, bool legacyMode, C…
/ohos5.0/foundation/multimedia/image_effect/frameworks/native/render_environment/render_thread/worker/
H A Drender_thread.h78 std::unique_lock<std::mutex> lk(cvMutex); in AddTask()
79 …cvFull.wait(lk, [this]() { return (m_localMsgQueue->GetSize() < this->qSize) || (!m_isWorking); }); in AddTask()
85 lk.unlock(); in AddTask()
92 std::unique_lock<std::mutex> lk(cvMutex); in ClearTask()
96 lk.unlock(); in ClearTask()
126 std::unique_lock<std::mutex> lk(cvMutex); in Run()
127 bool cvRet = cvEmpty.wait_for(lk, std::chrono::milliseconds(TIME_FOR_WAITING_TASK), in Run()
132 lk.unlock(); in Run()
138 lk.unlock(); in Run()
/ohos5.0/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/
H A Dfuture.h38 std::unique_lock lk(this->m_mtx); in wait()
39 wait_(lk); in wait()
45 std::unique_lock<mutex> lk(m_mtx); in wait_for()
53 std::unique_lock<mutex> lk(m_mtx); in wait_until()
79 std::unique_lock<mutex> lk(this->m_mtx); in set_value()
88 std::unique_lock<mutex> lk(this->m_mtx); in set_value()
96 std::unique_lock lk(this->m_mtx); in get()
97 this->wait_(lk); in get()
115 std::unique_lock<mutex> lk(this->m_mtx);
123 std::unique_lock lk(this->m_mtx);
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp308 std::unique_lock lk(mtx);
309 cv.wait_for(lk, 1us);
317 std::unique_lock lk(mtx); in __anonc91b23f72f02() local
318 cv.wait_for(lk, 1us); in __anonc91b23f72f02()
340 std::unique_lock lk(mtx); in NotifyOneTest() local
372 std::unique_lock lk(mtx); in WaitUntilTimeoutTest() local
404 std::unique_lock lk(mtx); in WaitUtilFlagTest_1() local
431 std::unique_lock lk(mtx); in WaitUtilFlagTest_2() local
441 std::unique_lock lk(mtx); in WaitUtilFlagTest_2() local
459 std::unique_lock lk(mtx); in WaitForTest_1() local
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/
H A Dble_adapter.cpp177 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in EnableTask() local
251 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in DisableTask() local
317 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartOrStopAdvAndScan() local
481 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetLocalAddress() local
489 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetLocalName() local
497 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in SetLocalName() local
562 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in ReadRemoteDeviceNameByGatt() local
639 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartPair() local
670 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in CancelPairing() local
704 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in RemovePairWithDisConnect() local
[all …]
H A Dble_central_manager_impl.cpp331 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in AdvertisingReportTask() local
389 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in ExAdvertisingReportTask() local
436 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in AddPeripheralDevice() local
543 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in HandleAddBleScanFilterResult() local
555 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in HandleDeleteBleScanFilterResult() local
567 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in HandleStartBleScanFilterResult() local
579 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in HandleStopBleScanFilterResult() local
632 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in ScanSetEnableResultTask() local
664 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in ScanExSetEnableResultTask() local
728 std::lock_guard<std::recursive_mutex> lk(pimpl->mutex_); in StartOrStopScan() local
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/hfp_hf/
H A Dhfp_hf_service.cpp168 std::lock_guard<std::recursive_mutex> lk(mutex_); in Connect() local
192 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect() local
215 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices() local
228 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState() local
247 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum() local
268 std::lock_guard<std::recursive_mutex> lk(mutex_); in ConnectSco() local
290 std::lock_guard<std::recursive_mutex> lk(mutex_); in DisconnectSco() local
312 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates() local
329 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState() local
347 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetScoState() local
[all …]
/ohos5.0/foundation/multimedia/av_codec/test/unittest/hcodec_test/helper/
H A Dtester_capi.cpp42 lock_guard<mutex> lk(tester->inputMtx_); in OnNeedInputData() local
55 lock_guard<mutex> lk(tester->outputMtx_); in OnNewOutputData() local
66 lock_guard<mutex> lk(tester->inputMtx_); in OnNeedInputBuffer() local
198 lock_guard<mutex> lk(inputMtx_); in ClearAllBuffer() local
202 lock_guard<mutex> lk(outputMtx_); in ClearAllBuffer() local
210 lock_guard<mutex> lk(inputMtx_); in ClearAllBuffer() local
214 lock_guard<mutex> lk(outputMtx_); in ClearAllBuffer() local
358 unique_lock<mutex> lk(inputMtx_); in WaitForInput() local
360 inputCond_.wait(lk, [this] { in WaitForInput()
397 unique_lock<mutex> lk(inputMtx_); in WaitForInput() local
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/
H A Dwifi_direct_event_queue.h31 std::lock_guard<std::mutex> lk(m_); in Push()
38 std::unique_lock<std::mutex> lk(m_); in WaitAndPop()
39 c_.wait(lk, [&] { return !queue_.empty(); }); in WaitAndPop()
48 std::lock_guard<std::mutex> lk(m_); in Process()
56 std::lock_guard<std::mutex> lk(m_); in Clear()
/ohos5.0/commonlibrary/c_utils/base/src/
H A Dthread_ex.cpp108 std::lock_guard<std::mutex> lk(lock_); in Start() local
144 std::unique_lock<std::mutex> lk(lock_); in NotifyExitSync() local
148 cvThreadExited_.wait(lk); in NotifyExitSync()
158 std::lock_guard<std::mutex> lk(lock_); in NotifyExitAsync() local
169 std::lock_guard<std::mutex> lk(lock_); in IsExitPending() local
175 std::lock_guard<std::mutex> lk(lock_); in IsRunning() local
196 std::unique_lock<std::mutex> lk(self->lock_); in ThreadStart() local
/ohos5.0/foundation/graphic/graphic_3d/3d_widget_adapter/src/
H A Dgraphics_task.cpp69 std::lock_guard<std::mutex> lk(messageQueueMut_); in PushSyncMessage() local
81 std::lock_guard<std::mutex> lk(messageQueueMut_); in PushAsyncMessage() local
98 std::lock_guard<std::mutex> lk(messageQueueMut_); in ~GraphicsTask() local
132 std::unique_lock<std::mutex> lk(messageQueueMut_); in EngineThread() local
133 messageQueueCnd_.wait(lk, [this] { return !messageQueue_.empty(); }); in EngineThread()
137 lk.unlock(); in EngineThread()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/hfp_ag/
H A Dhfp_ag_service.cpp153 std::lock_guard<std::recursive_mutex> lk(mutex_); in Connect() local
184 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect() local
204 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices() local
216 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState() local
237 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState() local
254 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum() local
265 std::lock_guard<std::recursive_mutex> lk(mutex_); in ProcessEvent() local
321 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates() local
338 std::lock_guard<std::recursive_mutex> lk(mutex_); in ConnectSco() local
362 std::lock_guard<std::recursive_mutex> lk(mutex_); in DisconnectSco() local
[all …]
/ohos5.0/foundation/multimedia/image_framework/plugins/manager/src/framework/
H A Dplugin_fw.cpp43 UniqueWriteGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in Register() local
51 UniqueReadGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in CreateObject() local
61 UniqueReadGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in CreateObject() local
71 UniqueReadGuard<RWLock> lk(DelayedRefSingleton<PluginInfoLock>::GetInstance().rwLock_); in PluginFwGetClassInfo() local
/ohos5.0/drivers/peripheral/codec/hal/idl_service/src/
H A Dcomponent_mgr.cpp37 std::lock_guard<std::mutex> lk(mutex_); in CreateComponentInstance() local
64 std::lock_guard<std::mutex> lk(mutex_); in DeleteComponentInstance() local
100 std::lock_guard<std::mutex> lk(mutex_); in AddComponentByLibName() local
112 std::lock_guard<std::mutex> lk(mutex_); in CleanComponent() local
128 std::lock_guard<std::mutex> lk(mutex_); in GetCoreOfComponent() local
/ohos5.0/drivers/peripheral/codec/hal/v2.0/hdi_impl/src/
H A Dcomponent_mgr.cpp38 std::lock_guard<std::mutex> lk(mutex_); in CreateComponentInstance() local
65 std::lock_guard<std::mutex> lk(mutex_); in DeleteComponentInstance() local
100 std::lock_guard<std::mutex> lk(mutex_); in AddComponentByLibName() local
112 std::lock_guard<std::mutex> lk(mutex_); in CleanComponent() local
128 std::lock_guard<std::mutex> lk(mutex_); in GetCoreOfComponent() local
H A Dcomponent_node.cpp78 std::unique_lock<std::shared_mutex> lk(callbackMutex_); in ~ComponentNode() local
82 std::unique_lock<std::shared_mutex> lk(mapMutex_); in ~ComponentNode() local
266 std::shared_lock<std::shared_mutex> lk(callbackMutex_); in OnEvent() local
284 std::shared_lock<std::shared_mutex> lk(callbackMutex_); in OnEmptyBufferDone() local
301 std::shared_lock<std::shared_mutex> lk(callbackMutex_); in OnFillBufferDone() local
353 std::unique_lock<std::shared_mutex> lk(mapMutex_); in UseBuffer() local
385 std::unique_lock<std::shared_mutex> lk(mapMutex_); in AllocateBuffer() local
415 std::unique_lock<std::shared_mutex> lk(mapMutex_); in FreeBuffer() local
497 std::unique_lock<std::shared_mutex> lk(mapMutex_); in GenerateBufferId() local
514 std::shared_lock<std::shared_mutex> lk(mapMutex_); in GetBufferInfoByHeader() local
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dcpu_monitor.cpp157 std::lock_guard lk(workerCtrl.lock); in TimeoutCount() local
164 std::lock_guard lk(workerCtrl.lock); in WakeupSleep() local
184 std::lock_guard lk(workerCtrl.lock); in RollbackDestroy() local
194 std::lock_guard lk(workerCtrl.lock); in TryDestroy() local
202 std::unique_lock lk(workerCtrl.lock); in SleepingWorkerNum() local
209 std::lock_guard lk(workerCtrl.lock); in WakedWorkerNum() local
216 std::lock_guard lk(workerCtrl.lock); in IntoDeepSleep() local
223 std::lock_guard lk(workerCtrl.lock); in WakeupDeepSleep() local
235 std::lock_guard lk(workerCtrl.lock); in OutOfPollWait() local
245 std::lock_guard lk(workerCtrl.lock); in IsExceedDeepSleepThreshold() local
/ohos5.0/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_thread_pool_test.cpp180 std::unique_lock<std::mutex> lk(g_mutex); in TestFuncAddWait() local
183 g_cv.wait(lk, [] {return g_ready;}); in TestFuncAddWait()
189 std::unique_lock<std::mutex> lk(g_mutex); in TestFuncSubWait() local
192 g_cv.wait(lk, [] {return g_ready;}); in TestFuncSubWait()
220 std::lock_guard<std::mutex> lk(g_mutex);
264 std::lock_guard<std::mutex> lk(g_mutex);
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/classic/
H A Dclassic_adapter.cpp535 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetBondableMode() local
543 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in SetBondableMode() local
558 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartBtDiscovery() local
585 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in CancelBtDiscovery() local
606 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in IsBtDiscovering() local
614 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetBtDiscoveryEndMillis() local
999 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in HandleInquiryResult() local
1026 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in FindRemoteDevice() local
1042 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in HandleInquiryComplete() local
1066 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in DiscoverRemoteName() local
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/
H A Dhid_host_service.cpp151 std::lock_guard<std::recursive_mutex> lk(mutex_); in Connect() local
176 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect() local
271 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates() local
288 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState() local
308 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices() local
322 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState() local
342 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum() local
384 std::lock_guard<std::recursive_mutex> lk(mutex_); in ProcessEvent() local
436 std::lock_guard<std::recursive_mutex> lk(mutex_); in HidHostFindDeviceByLcid() local
/ohos5.0/drivers/peripheral/codec/hal/src/
H A Dcodec_death_recipient.cpp36 std::lock_guard<std::mutex> lk(g_mutex); in RegisterService() local
59 std::lock_guard<std::mutex> lk(g_mutex); in CleanMapperOfDiedService() local
90 std::lock_guard<std::mutex> lk(g_mutex); in RemoveDestoryedComponent() local
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/
H A Dpan_service.cpp160 std::lock_guard<std::recursive_mutex> lk(mutex_); in Disconnect() local
184 std::lock_guard<std::recursive_mutex> lk(mutex_); in SetTethering() local
330 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDevicesByStates() local
347 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetDeviceState() local
366 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectDevices() local
381 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetConnectState() local
402 std::lock_guard<std::recursive_mutex> lk(mutex_); in GetMaxConnectNum() local
443 std::lock_guard<std::recursive_mutex> lk(mutex_); in ProcessEvent() local
494 std::lock_guard<std::recursive_mutex> lk(mutex_); in PanFindDeviceByLcid() local
/ohos5.0/base/security/security_component_manager/services/security_component_service/sa/sa_main/
H A Dsec_comp_manager.cpp65 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in AddSecurityComponentToList() local
96 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in DeleteSecurityComponentFromList() local
187 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in NotifyProcessForeground() local
203 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in NotifyProcessBackground() local
223 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in NotifyProcessDied() local
246 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in ExitSaProcess() local
272 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in ExitWhenAppMgrDied() local
322 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in AddSecurityComponentProcess() local
395 OHOS::Utils::UniqueWriteGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in UpdateSecurityComponent() local
511 OHOS::Utils::UniqueReadGuard<OHOS::Utils::RWLock> lk(this->componentInfoLock_); in ReportSecurityComponentClickEvent() local
[all …]

123456