Home
last modified time | relevance | path

Searched refs:locker (Results 1 – 25 of 53) sorted by relevance

123

/ohos5.0/base/update/sys_installer/services/module_update/service/src/
H A Dmodule_update_queue.cpp31 std::unique_lock<std::mutex> locker(mtx_); in Stop() local
40 std::unique_lock<std::mutex> locker(mtx_); in Put() local
44 notFull_.wait(locker); in Put()
46 std::unique_lock<std::mutex> locker(mtx_); in Put() local
56 std::unique_lock<std::mutex> locker(mtx_); in Pop() local
60 notEmpty_.wait(locker); in Pop()
62 std::unique_lock<std::mutex> locker(mtx_); in Pop() local
72 std::unique_lock<std::mutex> locker(mtx_); in IsEmpty() local
78 std::unique_lock<std::mutex> locker(mtx_); in IsFull() local
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/src/
H A Dvsync_distributor.cpp144 std::unique_lock<std::mutex> locker(mutex_); in GetReceiveFd() local
208 std::unique_lock<std::mutex> locker(mutex_); in SetVSyncRate() local
237 std::unique_lock<std::mutex> locker(mutex_); in Destroy() local
345 std::lock_guard<std::mutex> locker(mutex_); in AddConnection() local
375 std::lock_guard<std::mutex> locker(mutex_); in RemoveConnection() local
418 con_.wait(locker); in WaitForVsyncOrRequest()
438 con_.wait(locker); in WaitForVsyncOrRequest()
729 locker.unlock(); in SendConnectionsToVSyncWindow()
731 locker.lock(); in SendConnectionsToVSyncWindow()
948 dvsync_->RNVWait(locker); in RequestNextVSync()
[all …]
H A Dvsync_receiver.cpp55 std::lock_guard<std::mutex> locker(cbMutex_); in OnShutdown() local
63 std::lock_guard<std::mutex> locker(fdMutex_); in ReadFdInternal() local
99 std::lock_guard<std::mutex> locker(mtx_); in HandleVsyncCallbacks() local
157 std::lock_guard<std::mutex> locker(cbMutex_); in RegisterFdShutDownCallback() local
175 std::lock_guard<std::mutex> locker(initMutex_); in Init() local
221 std::lock_guard<std::mutex> locker(initMutex_); in ~VSyncReceiver() local
248 std::lock_guard<std::mutex> locker(initMutex_); in RequestNextVSync() local
264 std::lock_guard<std::mutex> locker(initMutex_); in RequestNextVSyncWithMultiCallback() local
280 std::lock_guard<std::mutex> locker(initMutex_); in SetVSyncRate() local
306 std::lock_guard<std::mutex> locker(initMutex_); in GetVSyncPeriodAndLastTimeStamp() local
[all …]
H A Dvsync_controller.cpp43 std::lock_guard<std::mutex> locker(offsetMutex_); in SetEnable() local
70 std::lock_guard<std::mutex> locker(callbackMutex_); in SetCallback() local
85 std::lock_guard<std::mutex> locker(offsetMutex_); in SetPhaseOffset() local
95 std::lock_guard<std::mutex> locker(callbackMutex_); in OnVSyncEvent() local
105 std::lock_guard<std::mutex> locker(offsetMutex_); in OnPhaseOffsetChanged() local
114 std::lock_guard<std::mutex> locker(callbackMutex_); in OnConnsRefreshRateChanged() local
H A Dvsync_generator.cpp195 con_.wait(locker); in ThreadLoop()
204 con_.wait(locker); in ThreadLoop()
213 locker.unlock(); in ThreadLoop()
533 std::lock_guard<std::mutex> locker(mutex_); in UpdateMode() local
553 std::lock_guard<std::mutex> locker(mutex_); in AddListener() local
643 std::lock_guard<std::mutex> locker(mutex_); in ChangeGeneratorRefreshRateModel() local
704 std::lock_guard<std::mutex> locker(mutex_); in GetVSyncPulse() local
711 std::lock_guard<std::mutex> locker(mutex_); in SetVSyncMode() local
718 std::lock_guard<std::mutex> locker(mutex_); in GetVSyncMode() local
724 std::lock_guard<std::mutex> locker(mutex_); in SetVSyncPhaseByPulseNum() local
[all …]
/ohos5.0/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/
H A Dability_list.cpp38 AbilityLockGuard locker(abilityListMutex_); in Add() local
53 AbilityLockGuard locker(abilityListMutex_); in Get() local
73 AbilityLockGuard locker(abilityListMutex_); in Get() local
88 AbilityLockGuard locker(abilityListMutex_); in GetByTaskId() local
103 AbilityLockGuard locker(abilityListMutex_); in Erase() local
118 AbilityLockGuard locker(abilityListMutex_); in GetAbilityList() local
130 AbilityLockGuard locker(abilityListMutex_); in Size() local
136 AbilityLockGuard locker(abilityListMutex_); in MoveToTop() local
148 AbilityLockGuard locker(abilityListMutex_); in PopAbility() local
154 AbilityLockGuard locker(abilityListMutex_); in GetTopAbility() local
[all …]
/ohos5.0/foundation/communication/netmanager_ext/services/netfirewallmanager/src/
H A Dnetfirewall_policy_manager.cpp41 std::lock_guard<std::shared_mutex> locker(setPolicyMutex_); in SetCurrentUserId() local
53 std::lock_guard<std::shared_mutex> locker(setPolicyMutex_); in SetNetFirewallPolicy() local
73 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in GetNetFirewallPolicy() local
89 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in IsFirewallStatusChange() local
97 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in IsFirewallActionChange() local
105 std::lock_guard<std::shared_mutex> locker(setPolicyMutex_); in SetCurrentUserFirewallPolicy() local
122 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in IsNetFirewallOpen() local
140 std::lock_guard<std::shared_mutex> locker(setPolicyMutex_); in ClearFirewallPolicy() local
157 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in GetFirewallPolicyInAction() local
165 std::shared_lock<std::shared_mutex> locker(setPolicyMutex_); in GetFirewallPolicyOutAction() local
H A Dnetfirewall_intercept_recorder.cpp60 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in GetInterceptRecords() local
73 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in SetCurrentUserId() local
79 std::shared_lock<std::shared_mutex> locker(setRecordMutex_); in GetRecordCacheSize() local
85 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in PutRecordCache() local
93 std::lock_guard<std::shared_mutex> locker(setRecordMutex_); in SyncRecordCache() local
H A Dnetfirewall_rule_native_helper.cpp51 std::lock_guard<std::mutex> locker(callNetSysController_); in SetFirewallDefaultAction() local
63 std::lock_guard<std::mutex> locker(callNetSysController_); in ClearFirewallRules() local
111 std::lock_guard<std::mutex> locker(callNetSysController_); in SetFirewallRulesInner() local
123 std::lock_guard<std::mutex> locker(callNetSysController_); in SetCurrentUserId() local
H A Dnetfirewall_rule_manager.cpp59 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in AddNetFirewallRule() local
101 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in AddDefaultNetFirewallRule() local
112 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in UpdateNetFirewallRule() local
139 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in DeleteNetFirewallRule() local
168 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in DeleteNetFirewallRuleByUserId() local
183 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in DeleteNetFirewallRuleByAppId() local
252 std::shared_lock<std::shared_mutex> locker(setFirewallRuleMutex_); in GetNetFirewallRules() local
275 std::shared_lock<std::shared_mutex> locker(setFirewallRuleMutex_); in GetNetFirewallRule() local
524 std::lock_guard<std::shared_mutex> locker(setFirewallRuleMutex_); in OpenOrCloseNativeFirewall() local
/ohos5.0/foundation/distributedhardware/device_manager/utils/src/timer/lite/
H A Ddm_timer.cpp42 std::unique_lock<std::mutex> locker(timerStateMutex_); in ~DmTimer() local
43 stopTimerCondition_.wait(locker, [this] { return static_cast<bool>(!timerState_); }); in ~DmTimer()
57 std::lock_guard<std::mutex> locker(timerMutex_); in StartTimer() local
69 std::unique_lock<std::mutex> locker(timerStateMutex_); in StartTimer() local
70 runTimerCondition_.wait(locker, [this] { return static_cast<bool>(timerState_); }); in StartTimer()
83 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteTimer() local
95 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteAll() local
112 std::unique_lock<std::mutex> locker(timerStateMutex_); in TimerRunning() local
142 std::unique_lock<std::mutex> locker(timerStateMutex_); in TimerRunning() local
/ohos5.0/foundation/graphic/graphic_2d/interfaces/inner_api/composer/
H A Dvsync_receiver.h52 std::lock_guard<std::mutex> locker(mtx_); in SetCallback()
59 std::lock_guard<std::mutex> locker(mtx_); in SetName()
64 std::lock_guard<std::mutex> locker(mtx_); in SetRNVFlag()
69 std::lock_guard<std::mutex> locker(mtx_); in GetRNVFlag()
75 std::lock_guard<std::mutex> locker(mtx_); in GetPeriod()
81 std::lock_guard<std::mutex> locker(mtx_); in GetTimeStamp()
87 std::lock_guard<std::mutex> locker(mtx_); in GetPeriodShared()
93 std::lock_guard<std::mutex> locker(mtx_); in GetTimeStampShared()
99 std::lock_guard<std::mutex> locker(mtx_); in AddCallback()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_locker.cpp20 std::shared_ptr<CloudLocker> &locker) in BuildCloudLock() argument
22 locker = std::make_shared<CloudLocker>(); in BuildCloudLock()
25 locker = nullptr; in BuildCloudLock()
27 locker->finalize_ = finalize; in BuildCloudLock()
/ohos5.0/base/telephony/call_manager/utils/include/
H A Dtimer.h62 std::lock_guard<std::mutex> locker(mutex_); in start()
77 std::unique_lock<std::mutex> locker(mutex_); in stop()
78 timerCond_.wait(locker, [this] { return stopStatus_ == true; }); in stop()
87 std::lock_guard<std::mutex> locker(mutex_); in ThreadExit()
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Ddata_ability_manager.cpp73 std::lock_guard<ffrt::mutex> locker(mutex_); in Acquire() local
129 std::lock_guard<ffrt::mutex> locker(mutex_); in Release() local
183 std::lock_guard<ffrt::mutex> locker(mutex_); in ContainsDataAbility() local
201 std::lock_guard<ffrt::mutex> locker(mutex_); in AttachAbilityThread() local
251 std::lock_guard<ffrt::mutex> locker(mutex_); in AbilityTransitionDone() local
335 std::lock_guard<ffrt::mutex> locker(mutex_); in OnAppStateChanged() local
378 std::lock_guard<ffrt::mutex> locker(mutex_); in GetAbilityRecordById() local
399 std::lock_guard<ffrt::mutex> locker(mutex_); in GetAbilityRecordByToken() local
427 std::lock_guard<ffrt::mutex> locker(mutex_); in GetAbilityRecordByScheduler() local
443 std::lock_guard<ffrt::mutex> locker(mutex_); in Dump() local
[all …]
/ohos5.0/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()
/ohos5.0/foundation/distributedhardware/device_manager/utils/src/timer/
H A Ddm_timer.cpp53 std::lock_guard<std::mutex> locker(timerMutex_); in StartTimer() local
72 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteTimer() local
91 std::lock_guard<std::mutex> locker(timerMutex_); in DeleteAll() local
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnetsys_network.cpp29 std::lock_guard locker(mutex_); in ClearInterfaces() local
36 std::lock_guard locker(mutex_); in ExistInterface() local
/ohos5.0/base/powermgr/thermal_manager/services/native/src/thermal_action/
H A Dthermal_timer.cpp126 std::lock_guard<std::mutex> locker(mutex_); in Start() local
153 std::unique_lock<std::mutex> locker(mutex_); in Stop() local
154 expiredCond_.wait(locker, [this] { in Stop()
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/
H A Ddns_quality_diag.cpp141 std::unique_lock<std::mutex> locker(resultListenersMutex_); in RegisterResultListener() local
143 locker.unlock(); in RegisterResultListener()
159 std::lock_guard<std::mutex> locker(resultListenersMutex_); in UnregisterResultListener() local
243 std::unique_lock<std::mutex> locker(resultListenersMutex_); in send_dns_report() local
253 locker.unlock(); in send_dns_report()
/ohos5.0/foundation/communication/netmanager_base/services/netconnmanager/src/
H A Dnet_conn_service.cpp457 locker.unlock(); in RegisterNetSupplierAsync()
614 locker.unlock(); in UnregisterNetSupplierAsync()
626 locker.unlock(); in UnregisterNetSupplierAsync()
826 locker.unlock(); in UpdateNetLinkInfoAsync()
2095 std::lock_guard<std::mutex> locker(mutex_); in OnInterfaceAddressUpdated() local
2110 std::lock_guard<std::mutex> locker(mutex_); in OnInterfaceAddressRemoved() local
2123 std::lock_guard<std::mutex> locker(mutex_); in OnInterfaceAdded() local
2136 std::lock_guard<std::mutex> locker(mutex_); in OnInterfaceRemoved() local
2149 std::lock_guard<std::mutex> locker(mutex_); in OnInterfaceChanged() local
2162 std::lock_guard<std::mutex> locker(mutex_); in OnInterfaceLinkStateChanged() local
[all …]
/ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dpicture_manager_thread.cpp60 unique_lock<mutex> locker(runningMutex_); in Start() local
119 unique_lock<mutex> locker(threadMutex_); in Run() local
120 condition_.wait_for(locker, std::chrono::seconds(1)); // 实际1S扫描一次 in Run()
/ohos5.0/foundation/distributedhardware/device_manager/services/implementation/src/dependency/hichain/
H A Dmine_hichain_connector.cpp66 std::unique_lock<std::mutex> locker(g_createGroupMutex); in onFinish() local
80 std::unique_lock<std::mutex> locker(g_createGroupMutex); in onError() local
183 std::unique_lock<std::mutex> locker(g_createGroupMutex); in CreateGroup() local
184 if (g_createGroupNotify.wait_for(locker, timeout, [] { return g_mineCreateGroupFlag; })) { in CreateGroup()
/ohos5.0/foundation/communication/netmanager_ext/services/vpnmanager/src/
H A Dnetworkvpn_service.cpp149 std::unique_lock<std::mutex> locker(netVpnMutex_); in GetDumpMessage() local
202 std::unique_lock<std::mutex> locker(netVpnMutex_); in Prepare() local
532 std::unique_lock<std::mutex> locker(netVpnMutex_); in SetUpVpn() local
592 std::unique_lock<std::mutex> locker(netVpnMutex_); in DestroyVpn() local
631 std::unique_lock<std::mutex> locker(netVpnMutex_); in AddSysVpnConfig() local
662 std::unique_lock<std::mutex> locker(netVpnMutex_); in DeleteSysVpnConfig() local
689 std::unique_lock<std::mutex> locker(netVpnMutex_); in GetSysVpnConfigList() local
720 std::unique_lock<std::mutex> locker(netVpnMutex_); in GetSysVpnConfig() local
749 std::unique_lock<std::mutex> locker(netVpnMutex_); in GetConnectedSysVpnConfig() local
902 std::lock_guard<std::mutex> locker(netVpnMutex_); in OnNetSysRestart() local
[all …]
/ohos5.0/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() local
94 std::lock_guard<std::mutex> locker(evenSubscriberMutex_); in UnsubscribeServiceEvent() local

123