/ohos5.0/foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
H A D | condition_variable.h | 51 …std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp, Pred&& pred) noex… in wait_until() 62 …cv_status wait_until(std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& … in wait_until() 68 …cv_status wait_for(std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleep_ti… in wait_for() 75 …std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleepTime, Pred&& pred) noe… in wait_for() 81 void wait(std::unique_lock<mutex>& lk, Pred&& pred) in wait() 88 void wait(std::unique_lock<mutex>& lk) in wait() 105 …cv_status _wait_for(std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& dur) no… in _wait_for()
|
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/ |
H A D | ble_adapter.cpp | 177 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 D | ble_central_manager_impl.cpp | 331 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 D | hfp_hf_service.cpp | 168 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/commonlibrary/c_utils/base/src/ |
H A D | thread_ex.cpp | 108 std::lock_guard<std::mutex> lk(lock_); in Start() local 144 std::unique_lock<std::mutex> lk(lock_); in NotifyExitSync() local 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/multimedia/image_framework/plugins/manager/src/framework/ |
H A D | plugin_fw.cpp | 43 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 D | component_mgr.cpp | 37 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
|
H A D | codec_death_recipient.cpp | 36 std::lock_guard<std::mutex> lk(g_mutex); in CleanResourceOfDiedService() local 55 std::unique_lock<std::mutex> lk(g_mutex); in RegisterDeathRecipientService() local 83 std::unique_lock<std::mutex> lk(g_mutex); in RemoveMapperOfDestoryedComponent() local
|
/ohos5.0/drivers/peripheral/codec/hal/v2.0/hdi_impl/src/ |
H A D | component_mgr.cpp | 38 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 D | component_node.cpp | 78 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/graphic/graphic_3d/3d_widget_adapter/src/ |
H A D | graphics_task.cpp | 69 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
|
/ohos5.0/foundation/resourceschedule/ffrt/src/sync/ |
H A D | wait_queue.cpp | 31 void WaitQueue::ThreadWait(WaitUntilEntry* wn, mutexPrivate* lk, bool legacyMode, CPUEUTask* task) in ThreadWait() 48 bool WaitQueue::ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, in ThreadWaitUntil() 80 void WaitQueue::SuspendAndWait(mutexPrivate* lk) in SuspendAndWait() 125 bool WaitQueue::SuspendAndWaitUntil(mutexPrivate* lk, const TimePoint& tp) noexcept in SuspendAndWaitUntil() 214 std::unique_lock<std::mutex> lk(we->wl); in Notify() local
|
H A D | shared_mutex.cpp | 109 std::unique_lock<std::mutex> lk(ctx->wn.wl); in Wait() local 137 std::unique_lock<std::mutex> lk(wue->wl); in NotifyOne() local 158 std::unique_lock<std::mutex> lk(wue->wl); in NotifyAll() local
|
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/hfp_ag/ |
H A D | hfp_ag_service.cpp | 153 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/av_codec/test/unittest/hcodec_test/helper/ |
H A D | tester_capi.cpp | 42 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 80 lock_guard<mutex> lk(tester->outputMtx_); in OnNewOutputBuffer() 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 397 unique_lock<mutex> lk(inputMtx_); in WaitForInput() local [all …]
|
H A D | tester_codecbase.cpp | 37 lock_guard<mutex> lk(tester_->inputMtx_); in OnInputBufferAvailable() local 71 lock_guard<mutex> lk(tester_->outputMtx_); in OnOutputBufferAvailable() local 160 lock_guard<mutex> lk(inputMtx_); in ClearAllBuffer() local 164 lock_guard<mutex> lk(outputMtx_); in ClearAllBuffer() local 400 unique_lock<mutex> lk(inputMtx_); in WaitForInput() local 461 unique_lock<mutex> lk(outputMtx_); in WaitForOutput() local
|
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/ |
H A D | cpu_monitor.cpp | 157 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/base/security/security_component_manager/services/security_component_service/sa/sa_main/ |
H A D | sec_comp_manager.cpp | 65 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 …]
|
/ohos5.0/drivers/peripheral/codec/hal/src/ |
H A D | codec_death_recipient.cpp | 36 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/classic/ |
H A D | classic_adapter.cpp | 535 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 D | hid_host_service.cpp | 151 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/foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/ |
H A D | pan_service.cpp | 160 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/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/src/ |
H A D | network_latency_controller.cpp | 73 std::unique_lock<std::mutex> lk(mtx); in Init() local 147 std::unique_lock<std::mutex> lk(mtx); in AddRequest() local 160 std::unique_lock<std::mutex> lk(mtx); in DelRequest() local
|
/ohos5.0/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
H A D | image_codec_list.cpp | 34 std::lock_guard<std::mutex> lk(g_heifCodecMtx); in OnRemoteDied() local 48 lock_guard<mutex> lk(g_heifCodecMtx); in GetManager() local
|
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/ble_scan_filter/src/ |
H A D | ble_scan_filter_lsf.cpp | 47 std::lock_guard<std::recursive_mutex> lk(mutex_); in CommandTimeout() local 192 std::lock_guard<std::recursive_mutex> lk(mutex_); in AddBleScanFilter() local 218 std::lock_guard<std::recursive_mutex> lk(mutex_); in DeleteBleScanFilter() local 240 std::lock_guard<std::recursive_mutex> lk(mutex_); in StartBleScanFilter() local 261 std::lock_guard<std::recursive_mutex> lk(mutex_); in StopBleScanFilter() local 617 std::lock_guard<std::recursive_mutex> lk(filter->mutex_); in HciVendorClosedCallback() local 653 std::lock_guard<std::recursive_mutex> lk(mutex_); in BleScanFilterCommandComplete() local
|