Home
last modified time | relevance | path

Searched refs:locker (Results 1 - 25 of 51) sorted by relevance

123

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_locker.cpp20 std::shared_ptr<CloudLocker> &locker) in BuildCloudLock()
22 locker = std::make_shared<CloudLocker>(); in BuildCloudLock()
25 locker = nullptr; in BuildCloudLock()
27 locker->finalize_ = finalize; in BuildCloudLock()
19 BuildCloudLock(const AfterBuildAction &buildAction, const BeforeFinalize &finalize, std::shared_ptr<CloudLocker> &locker) BuildCloudLock() argument
H A Dcloud_locker.h26 std::shared_ptr<CloudLocker> &locker);
/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/
H A Dability_list.cpp38 AbilityLockGuard locker(abilityListMutex_); in Add()
53 AbilityLockGuard locker(abilityListMutex_); in Get()
73 AbilityLockGuard locker(abilityListMutex_); in Get()
88 AbilityLockGuard locker(abilityListMutex_); in GetByTaskId()
103 AbilityLockGuard locker(abilityListMutex_); in Erase()
118 AbilityLockGuard locker(abilityListMutex_); in GetAbilityList()
130 AbilityLockGuard locker(abilityListMutex_); in Size()
136 AbilityLockGuard locker(abilityListMutex_); in MoveToTop()
148 AbilityLockGuard locker(abilityListMutex_); in PopAbility()
154 AbilityLockGuard locker(abilityListMutex in GetTopAbility()
[all...]
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/
H A Dcast_timer.cpp35 std::unique_lock<std::mutex> locker(threadMutex_); in Start()
41 std::unique_lock<std::mutex> locker(mutex_); in Start()
42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
59 std::unique_lock<std::mutex> locker(threadMutex_); in Stop()
62 std::unique_lock<std::mutex> locker(mutex_); in Stop()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/
H A Dcast_timer.cpp35 std::unique_lock<std::mutex> locker(threadMutex_); in Start()
41 std::unique_lock<std::mutex> locker(mutex_); in Start()
42 cond_.wait_for(locker, std::chrono::milliseconds(interval), [this] { return exit_.load(); }); in Start()
59 std::unique_lock<std::mutex> locker(threadMutex_); in Stop()
62 std::unique_lock<std::mutex> locker(mutex_); in Stop()
/foundation/distributedhardware/device_manager/utils/src/timer/lite/
H A Ddm_timer.cpp41 std::unique_lock<std::mutex> locker(timerStateMutex_); in ~DmTimer()
42 stopTimerCondition_.wait(locker, [this] { return static_cast<bool>(!timerState_); }); in ~DmTimer()
56 std::lock_guard<std::mutex> locker(timerMutex_); in StartTimer()
68 std::unique_lock<std::mutex> locker(timerStateMutex_); in StartTimer()
69 runTimerCondition_.wait(locker, [this] { return static_cast<bool>(timerState_); }); in StartTimer()
82 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteTimer()
94 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteAll()
111 std::unique_lock<std::mutex> locker(timerStateMutex_); in TimerRunning()
141 std::unique_lock<std::mutex> locker(timerStateMutex_); in TimerRunning()
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/src/
H A Dvsync_distributor.cpp122 std::unique_lock<std::mutex> locker(mutex_); in RequestNextVSync()
144 std::unique_lock<std::mutex> locker(mutex_); in GetReceiveFd()
161 std::unique_lock<std::mutex> locker(mutex_); in PostEvent()
206 std::unique_lock<std::mutex> locker(mutex_); in SetVSyncRate()
235 std::unique_lock<std::mutex> locker(mutex_); in Destroy()
243 std::unique_lock<std::mutex> locker(mutex_); in SetUiDvsyncSwitch()
263 std::unique_lock<std::mutex> locker(mutex_); in SetNativeDVSyncSwitch()
283 std::unique_lock<std::mutex> locker(mutex_); in SetUiDvsyncConfig()
323 std::unique_lock<std::mutex> locker(mutex_); in ~VSyncDistributor()
328 std::unique_lock<std::mutex> locker(mutex in ~VSyncDistributor()
403 WaitForVsyncOrRequest(std::unique_lock<std::mutex> &locker) WaitForVsyncOrRequest() argument
446 WaitForVsyncOrTimeOut(std::unique_lock<std::mutex> &locker) WaitForVsyncOrTimeOut() argument
698 SendConnectionsToVSyncWindow(int64_t now, int64_t period, uint32_t refreshRate, VSyncMode vsyncMode, std::unique_lock<std::mutex> &locker) SendConnectionsToVSyncWindow() argument
[all...]
H A Dvsync_controller.cpp43 std::lock_guard<std::mutex> locker(offsetMutex_); in SetEnable()
70 std::lock_guard<std::mutex> locker(callbackMutex_); in SetCallback()
85 std::lock_guard<std::mutex> locker(offsetMutex_); in SetPhaseOffset()
96 std::lock_guard<std::mutex> locker(callbackMutex_); in OnVSyncEvent()
106 std::lock_guard<std::mutex> locker(offsetMutex_); in OnPhaseOffsetChanged()
115 std::lock_guard<std::mutex> locker(callbackMutex_); in OnConnsRefreshRateChanged()
H A Dvsync_receiver.cpp55 std::lock_guard<std::mutex> locker(fdMutex_); in ReadFdInternal()
91 std::lock_guard<std::mutex> locker(mtx_); in HandleVsyncCallbacks()
144 std::lock_guard<std::mutex> locker(fdMutex_); in CloseFd()
163 std::lock_guard<std::mutex> locker(initMutex_); in Init()
234 std::lock_guard<std::mutex> locker(initMutex_); in RequestNextVSync()
250 std::lock_guard<std::mutex> locker(initMutex_); in RequestNextVSyncWithMultiCallback()
266 std::lock_guard<std::mutex> locker(initMutex_); in SetVSyncRate()
292 std::lock_guard<std::mutex> locker(initMutex_); in GetVSyncPeriodAndLastTimeStamp()
322 std::lock_guard<std::mutex> locker(initMutex_); in CloseVsyncReceiverFd()
336 std::lock_guard<std::mutex> locker(initMutex in Destroy()
[all...]
H A Dvsync_generator.cpp132 std::unique_lock<std::mutex> locker(mutex_); in ~VSyncGenerator()
149 std::unique_lock<std::mutex> locker(mutex_); in ListenerVsyncEventCB()
186 std::unique_lock<std::mutex> locker(mutex_); in ThreadLoop()
197 con_.wait(locker); in ThreadLoop()
206 con_.wait(locker); in ThreadLoop()
214 locker.unlock(); in ThreadLoop()
537 std::lock_guard<std::mutex> locker(mutex_); in UpdateMode()
557 std::lock_guard<std::mutex> locker(mutex_); in AddListener()
654 std::lock_guard<std::mutex> locker(mutex_); in ChangeGeneratorRefreshRateModel()
715 std::lock_guard<std::mutex> locker(mutex in GetVSyncPulse()
[all...]
/foundation/graphic/graphic_2d/interfaces/inner_api/composer/
H A Dvsync_receiver.h51 std::lock_guard<std::mutex> locker(mtx_); in SetCallback()
58 std::lock_guard<std::mutex> locker(mtx_); in SetName()
63 std::lock_guard<std::mutex> locker(mtx_); in SetRNVFlag()
68 std::lock_guard<std::mutex> locker(mtx_); in GetRNVFlag()
74 std::lock_guard<std::mutex> locker(mtx_); in GetPeriod()
80 std::lock_guard<std::mutex> locker(mtx_); in GetTimeStamp()
86 std::lock_guard<std::mutex> locker(mtx_); in GetPeriodShared()
92 std::lock_guard<std::mutex> locker(mtx_); in GetTimeStampShared()
98 std::lock_guard<std::mutex> locker(mtx_); in AddCallback()
/foundation/communication/netmanager_ext/services/netfirewallmanager/src/
H A Dnetfirewall_policy_manager.cpp99 std::unique_lock<std::shared_mutex> locker(setPolicyMutex_); in SetCurrentUserFirewallPolicy()
144 std::lock_guard<std::shared_mutex> locker(setPolicyMutex_); in ClearCurrentFirewallPolicy()
172 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in IsPolicyCacheInvalid()
178 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in IsPolicyCacheOpen()
184 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in GetPolicyCacheInInternal()
193 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in GetPolicyCacheOutInternal()
202 std::unique_lock<std::shared_mutex> locker(setPolicyMutex_); in RebuildFirewallPolicyCache()
H A Dnetfirewall_rule_native_helper.cpp51 std::lock_guard<std::mutex> locker(callNetSysController_); in SetFirewallDefaultAction()
63 std::lock_guard<std::mutex> locker(callNetSysController_); in ClearFirewallRules()
111 std::lock_guard<std::mutex> locker(callNetSysController_); in SetFirewallRulesInner()
123 std::lock_guard<std::mutex> locker(callNetSysController_); in SetCurrentUserId()
H A Dnetfirewall_intercept_recorder.cpp60 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in GetInterceptRecords()
73 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in SetCurrentUserId()
79 std::shared_lock<std::shared_mutex> locker(setRecordMutex_); in GetRecordCacheSize()
85 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in PutRecordCache()
93 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in SyncRecordCache()
H A Dnetfirewall_rule_manager.cpp59 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in AddNetFirewallRule()
101 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in AddDefaultNetFirewallRule()
112 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in UpdateNetFirewallRule()
139 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in DeleteNetFirewallRule()
168 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in DeleteNetFirewallRuleByUserId()
183 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in DeleteNetFirewallRuleByAppId()
252 std::shared_lock<std::shared_mutex> locker(setFirewallRuleMutex_); in GetNetFirewallRules()
275 std::shared_lock<std::shared_mutex> locker(setFirewallRuleMutex_); in GetNetFirewallRule()
524 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in OpenOrCloseNativeFirewall()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnetsys_network.cpp29 std::lock_guard locker(mutex_); in ClearInterfaces()
36 std::lock_guard locker(mutex_); in ExistInterface()
/foundation/CastEngine/castengine_wifi_display/services/event/
H A Devent_manager.cpp72 std::unique_lock<std::mutex> locker(mutex_); in AddListener()
97 std::unique_lock<std::mutex> locker(mutex_); in DrainAllListeners()
108 std::unique_lock<std::mutex> locker(mutex_); in PushEvent()
147 std::unique_lock<std::mutex> locker(mutex_); in ProcessEvent()
150 hasEvent_.wait(locker); in ProcessEvent()
/foundation/communication/netmanager_base/services/common/include/
H A Dffrt_timer.h64 std::lock_guard<ffrt::mutex> locker(mutex_); in Start()
78 std::unique_lock<ffrt::mutex> locker(mutex_); in Stop()
79 timerCond_.wait(locker, [this] { return stopStatus_ == true; }); in Stop()
/foundation/distributedhardware/device_manager/utils/src/timer/
H A Ddm_timer.cpp53 std::lock_guard<std::mutex> locker(timerMutex_); in StartTimer()
72 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteTimer()
91 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteAll()
/foundation/ability/ability_runtime/services/abilitymgr/src/data_ability/
H A Ddata_ability_manager.cpp73 std::lock_guard<ffrt::mutex> locker(mutex_); in Acquire()
129 std::lock_guard<ffrt::mutex> locker(mutex_); in Release()
183 std::lock_guard<ffrt::mutex> locker(mutex_); in ContainsDataAbility()
201 std::lock_guard<ffrt::mutex> locker(mutex_); in AttachAbilityThread()
251 std::lock_guard<ffrt::mutex> locker(mutex_); in AbilityTransitionDone()
298 std::lock_guard<ffrt::mutex> locker(mutex_); in OnAbilityDied()
335 std::lock_guard<ffrt::mutex> locker(mutex_); in OnAppStateChanged()
378 std::lock_guard<ffrt::mutex> locker(mutex_); in GetAbilityRecordById()
399 std::lock_guard<ffrt::mutex> locker(mutex_); in GetAbilityRecordByToken()
427 std::lock_guard<ffrt::mutex> locker(mutex in GetAbilityRecordByScheduler()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/systemtest/
H A DnativeVsync_requestMultiCB_test.cpp31 std::unique_lock<std::mutex> locker(g_mutex); in OnVSync()
52 std::unique_lock<std::mutex> locker(g_mutex); in TestMultiTimes()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dpicture_manager_thread.cpp60 unique_lock<mutex> locker(runningMutex_); in Start()
119 unique_lock<mutex> locker(threadMutex_); in Run()
120 condition_.wait_for(locker, std::chrono::seconds(1)); // 实际1S扫描一次 in Run()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/
H A Ddns_quality_diag.cpp141 std::unique_lock<std::mutex> locker(resultListenersMutex_); in RegisterResultListener()
143 locker.unlock(); in RegisterResultListener()
159 std::lock_guard<std::mutex> locker(resultListenersMutex_); in UnregisterResultListener()
243 std::unique_lock<std::mutex> locker(resultListenersMutex_); in send_dns_report()
253 locker.unlock(); in send_dns_report()
/foundation/CastEngine/castengine_wifi_display/services/mediachannel/
H A Dbuffer_dispatcher.cpp85 std::unique_lock<std::mutex> locker(mutex_); in RequestRead()
92 notifyAudio_.wait(locker, [=]() { return nonBlockAudio_ || type != MEDIA_TYPE_AUDIO; }); in RequestRead()
97 notifyVideo_.wait(locker, [=]() { return nonBlockVideo_ || type != MEDIA_TYPE_VIDEO; }); in RequestRead()
102 notifyData_.wait(locker, [=]() { return dataReady_ || type != MEDIA_TYPE_AV; }); in RequestRead()
451 std::unique_lock<std::shared_mutex> locker(bufferMutex_); in BufferDispatcher()
494 std::unique_lock<std::shared_mutex> locker(bufferMutex_); in SetBufferCapacity()
507 std::unique_lock<std::mutex> locker(idleMutex_); in ReleaseIdleBuffer()
542 std::unique_lock<std::shared_mutex> locker(bufferMutex_); in FlushBuffer()
665 std::lock_guard<std::mutex> locker(notifyMutex_); in AttachReceiver()
756 std::lock_guard<std::mutex> locker(notifyMutex in DetachReceiver()
[all...]
/foundation/distributedhardware/device_manager/services/implementation/src/dependency/commonevent/
H A Ddm_common_event_manager.cpp51 std::lock_guard<std::mutex> locker(evenSubscriberMutex_); in SubscribeServiceEvent()
95 std::lock_guard<std::mutex> locker(evenSubscriberMutex_); in UnsubscribeServiceEvent()

Completed in 13 milliseconds

123