Home
last modified time | relevance | path

Searched defs:autoLock (Results 1 – 25 of 147) sorted by relevance

123456

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
Ddb_status_adapter.cpp34 std::lock_guard<std::mutex> autoLock(handleMutex_); in SetDBInfoHandle() local
53 std::lock_guard<std::mutex> autoLock(supportMutex_); in IsSupport() local
58 std::lock_guard<std::mutex> autoLock(supportMutex_); in IsSupport() local
73 std::lock_guard<std::mutex> autoLock(localInfoMutex_); in GetLocalDBInfos() local
86 std::lock_guard<std::mutex> autoLock(callbackMutex_); in SetDBStatusChangeCallback() local
98 std::lock_guard<std::mutex> autoLock(remoteInfoMutex_); in SetDBStatusChangeCallback() local
104 std::lock_guard<std::mutex> autoLock(localInfoMutex_); in SetDBStatusChangeCallback() local
138 std::lock_guard<std::mutex> autoLock(callbackMutex_); in NotifyDBInfos() local
157 std::lock_guard<std::mutex> autoLock(supportMutex_); in TargetOffline() local
183 std::lock_guard<std::mutex> autoLock(supportMutex_); in SetRemoteOptimizeCommunication() local
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
Dsingle_ver_relational_sync_task_context.cpp31 std::lock_guard<std::mutex> autoLock(querySyncIdMutex_); in GetQuerySyncId() local
37 std::lock_guard<std::mutex> autoLock(deleteSyncIdMutex_); in GetDeleteSyncId() local
44 std::lock_guard<std::mutex> autoLock(querySyncIdMutex_); in Clear() local
48 std::lock_guard<std::mutex> autoLock(deleteSyncIdMutex_); in Clear() local
60 std::lock_guard<std::mutex> autoLock(queryMutex_); in CopyTargetData() local
66 std::lock_guard<std::mutex> autoLock(querySyncIdMutex_); in CopyTargetData() local
70 std::lock_guard<std::mutex> autoLock(deleteSyncIdMutex_); in CopyTargetData() local
77 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in SetRelationalSyncStrategy() local
84 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in GetSchemaSyncStatus() local
Dsingle_ver_kv_sync_task_context.cpp29 std::lock_guard<std::mutex> autoLock(queryMutex_); in GetQuerySyncId() local
40 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in SetSyncStrategy() local
50 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in GetSchemaSyncStatus() local
/foundation/distributedhardware/device_manager/interfaces/inner_kits/native_cpp/src/notify/
Ddevice_manager_notify.cpp34 std::lock_guard<std::mutex> autoLock(lock_); in RegisterDeathRecipientCallback() local
44 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterDeathRecipientCallback() local
55 std::lock_guard<std::mutex> autoLock(lock_); in RegisterDeviceStateCallback() local
65 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterDeviceStateCallback() local
75 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterDeviceStatusCallback() local
86 std::lock_guard<std::mutex> autoLock(lock_); in RegisterDeviceStatusCallback() local
97 std::lock_guard<std::mutex> autoLock(lock_); in RegisterDiscoveryCallback() local
110 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterDiscoveryCallback() local
127 std::lock_guard<std::mutex> autoLock(lock_); in RegisterPublishCallback() local
140 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterPublishCallback() local
[all …]
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/camera_sink/src/
Ddcamera_sink_handler_ipc.cpp45 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in Init() local
58 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in UnInit() local
74 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in GetSinkLocalCamSrv() local
99 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in GetSinkLocalCamSrv() local
112 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in DeleteSinkLocalCamSrv() local
129 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in OnSinkLocalCamSrvDied() local
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/camera_source/src/
Ddcamera_source_handler_ipc.cpp45 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in Init() local
58 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in UnInit() local
74 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in GetSourceLocalCamSrv() local
99 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in GetSourceLocalCamSrv() local
112 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in DeleteSourceLocalCamSrv() local
129 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in OnSourceLocalCamSrvDied() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
Druntime_context_impl.cpp89 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAdapter() local
137 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAggregator() local
149 std::lock_guard<std::mutex> autoLock(communicatorLock_); in GetLocalIdentity() local
222 std::lock_guard<std::mutex> autoLock(timersLock_); in ModifyTimer() local
241 std::lock_guard<std::mutex> autoLock(timersLock_); in RemoveTimer() local
263 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleTask() local
287 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleQueuedTask() local
307 std::lock_guard<std::mutex> autoLock(taskLock_); in ShrinkMemory() local
316 std::lock_guard<std::mutex> autoLock(timeTickMonitorLock_); in RegisterTimeChangedLister() local
333 std::lock_guard<std::mutex> autoLock(loopLock_); in PrepareLoop() local
[all …]
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcameramgr/
Ddcamera_sink_service_ipc.cpp43 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in Init() local
56 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in UnInit() local
76 std::lock_guard<std::mutex> autoLock(sourceRemoteCamSrvLock_); in GetSourceRemoteCamSrv() local
106 std::lock_guard<std::mutex> autoLock(sourceRemoteCamSrvLock_); in GetSourceRemoteCamSrv() local
120 std::lock_guard<std::mutex> autoLock(sourceRemoteCamSrvLock_); in DeleteSourceRemoteCamSrv() local
136 std::lock_guard<std::mutex> autoLock(sourceRemoteCamSrvLock_); in ClearSourceRemoteCamSrv() local
155 std::lock_guard<std::mutex> autoLock(sourceRemoteCamSrvLock_); in OnSourceRemoteCamSrvDied() local
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/
Ddcamera_source_service_ipc.cpp43 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in Init() local
56 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in UnInit() local
76 std::lock_guard<std::mutex> autoLock(sinkRemoteCamSrvLock_); in GetSinkRemoteCamSrv() local
106 std::lock_guard<std::mutex> autoLock(sinkRemoteCamSrvLock_); in GetSinkRemoteCamSrv() local
120 std::lock_guard<std::mutex> autoLock(sinkRemoteCamSrvLock_); in DeleteSinkRemoteCamSrv() local
136 std::lock_guard<std::mutex> autoLock(sinkRemoteCamSrvLock_); in ClearSinkRemoteCamSrv() local
155 std::lock_guard<std::mutex> autoLock(sinkRemoteCamSrvLock_); in OnSinkRemoteCamSrvDied() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
Dcloud_syncer.cpp109 std::lock_guard<std::mutex> autoLock(dataLock_); in Close() local
128 std::lock_guard<std::mutex> autoLock(dataLock_); in Close() local
197 std::lock_guard<std::mutex> autoLock(dataLock_); in DoSync() local
204 std::lock_guard<std::mutex> autoLock(dataLock_); in DoSync() local
220 std::lock_guard<std::mutex> autoLock(dataLock_); in DoSync() local
253 std::lock_guard<std::mutex> autoLock(dataLock_); in DoUploadInNeed() local
273 std::lock_guard<std::mutex> autoLock(dataLock_); in DoUploadInNeed() local
304 std::lock_guard<std::mutex> autoLock(dataLock_); in DoFinished() local
314 std::lock_guard<std::mutex> autoLock(dataLock_); in DoFinished() local
382 std::lock_guard<std::mutex> autoLock(dataLock_); in IsDataContainAssets() local
[all …]
Dprocess_notifier.cpp35 std::lock_guard<std::mutex> autoLock(processMutex_); in Init() local
52 std::lock_guard<std::mutex> autoLock(processMutex_); in UpdateProcess() local
76 std::lock_guard<std::mutex> autoLock(processMutex_); in NotifyProcess() local
123 std::lock_guard<std::mutex> autoLock(processMutex_); in GetUploadBatchIndex() local
132 std::lock_guard<std::mutex> autoLock(processMutex_); in GetLastUploadSuccessCount() local
144 std::lock_guard<std::mutex> autoLock(processMutex_); in GetDownloadInfoByTableName() local
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
Ddms_callback_task.cpp39 std::lock_guard<std::mutex> autoLock(taskMutex_); in GenerateTaskId() local
68 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in PushCallback() local
94 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in PopCallback() local
111 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in PopContinuationMissionMap() local
124 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in GetContinuaionMissionId() local
141 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in SetContinuationMissionMap() local
156 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in GetLaunchType() local
169 std::lock_guard<std::mutex> autoLock(callbackMapMutex_); in NotifyDeviceOffline() local
Ddistributed_sched_continuation.cpp57 std::lock_guard<std::mutex> autoLock(continuationLock_); in PushAbilityToken() local
81 std::lock_guard<std::mutex> autoLock(continuationLock_); in PopAbilityToken() local
97 std::lock_guard<std::mutex> autoLock(continuationLock_); in GenerateSessionId() local
125 std::lock_guard<std::mutex> autoLock(continuationLock_); in IsFreeInstall() local
136 std::lock_guard<std::mutex> autoLock(continuationLock_); in IsInContinuationProgress() local
147 std::lock_guard<std::mutex> autoLock(continuationLock_); in GetTargetDevice() local
167 std::lock_guard<std::mutex> autoLock(continuationLock_); in PushCallback() local
195 std::lock_guard<std::mutex> autoLock(continuationLock_); in PushCallback() local
211 std::lock_guard<std::mutex> autoLock(continuationLock_); in GetCallback() local
217 std::lock_guard<std::mutex> autoLock(continuationLock_); in CleanupCallback() local
[all …]
Ddtbschedmgr_device_info_storage.cpp149 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in RegisterUuidNetworkIdMap() local
162 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in UnregisterUuidNetworkIdMap() local
170 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceIdSet() local
186 lock_guard<mutex> autoLock(deviceLock_); in UpdateDeviceInfoStorage() local
239 lock_guard<mutex> autoLock(deviceLock_); in ClearAllDevices() local
245 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceInfoById() local
260 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetUuidByNetworkId() local
291 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetNetworkIdByUuid() local
318 lock_guard<mutex> autoLock(deviceLock_); in DeviceOnlineNotify() local
346 lock_guard<mutex> autoLock(deviceLock_); in DeviceOfflineNotify() local
/foundation/systemabilitymgr/samgr/services/samgr/native/source/collect/
Dcommon_event_collect.cpp84 std::lock_guard<std::mutex> autoLock(commomEventLock_); in InitCommonEventState() local
95 std::lock_guard<std::mutex> autoLock(commomEventLock_); in InitCommonEventState() local
99 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in InitCommonEventState() local
110 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in Init() local
116 std::lock_guard<std::mutex> autoLock(commomEventLock_); in Init() local
140 std::lock_guard<std::mutex> autoLock(commomEventLock_); in AddSkillsEvent() local
155 std::lock_guard<std::mutex> autoLock(commomEventLock_); in CleanFailedEventLocked() local
161 std::lock_guard<std::mutex> autoLock(commonEventSubscriberLock_); in CreateCommonEventSubscriber() local
215 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in SaveAction() local
241 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in CheckCondition() local
[all …]
Ddevice_timed_collect.cpp137 lock_guard<mutex> autoLock(persitenceLoopEventSetLock_); in SaveTimedEvent() local
140 lock_guard<mutex> autoLock(nonPersitenceLoopEventSetLock_); in SaveTimedEvent() local
167 lock_guard<mutex> autoLock(nonPersitenceLoopEventSetLock_); in PostNonPersistenceLoopTaskLocked() local
202 lock_guard<mutex> autoLock(nonPersitenceLoopEventSetLock_); in PostNonPersistenceLoopTasks() local
211 lock_guard<mutex> autoLock(persitenceLoopEventSetLock_); in PostPersistenceLoopTasks() local
267 std::lock_guard<std::mutex> autoLock(persitenceTimedEventSetLock_); in AddCollectEvent() local
272 std::lock_guard<std::mutex> autoLock(nonPersitenceTimedEventSetLock); in AddCollectEvent() local
285 std::lock_guard<std::mutex> autoLock(nonPersitenceLoopEventSetLock_); in AddCollectEvent() local
313 std::lock_guard<std::mutex> autoLock(nonPersitenceLoopEventSetLock_); in RemoveNonPersistenceLoopTask() local
323 std::lock_guard<std::mutex> autoLock(persitenceLoopEventSetLock_); in RemovePersistenceLoopTask() local
/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/
Dplugin_mgr.cpp88 std::lock_guard<ffrt::mutex> autoLock(dispatcherHandlerMutex_); in Init() local
125 std::lock_guard<ffrt::mutex> autoLock(pluginMutex_); in LoadPlugin() local
127 std::lock_guard<std::mutex> autoLock(pluginMutex_); in LoadPlugin() local
212 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in GetPluginListByResType() local
252 std::lock_guard<ffrt::mutex> autoLock(dispatcherHandlerMutex_); in DispatchResource() local
254 std::lock_guard<std::mutex> autoLock(dispatcherHandlerMutex_); in DispatchResource() local
277 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in SubscribeResource() local
287 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in UnSubscribeResource() local
333 std::lock_guard<ffrt::mutex> autoLock(pluginMutex_); in DumpInfoFromPlugin() local
369 std::lock_guard<ffrt::mutex> autoLock(pluginMutex_); in DumpPluginInfoAppend() local
[all …]
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/
Ddcamera_stream_data_process.cpp87 std::lock_guard<std::mutex> autoLock(producerMutex_); in ReleaseStreams() local
117 std::lock_guard<std::mutex> autoLock(producerMutex_); in StartCapture() local
147 std::lock_guard<std::mutex> autoLock(producerMutex_); in StopCapture() local
180 std::lock_guard<std::mutex> autoLock(producerMutex_); in GetProducerSize() local
188 std::lock_guard<std::mutex> autoLock(producerMutex_); in FeedStreamToSnapShot() local
198 std::lock_guard<std::mutex> autoLock(pipelineMutex_); in FeedStreamToContinue() local
216 std::lock_guard<std::mutex> autoLock(producerMutex_); in OnProcessedVideoBuffer() local
231 std::lock_guard<std::mutex> autoLock(pipelineMutex_); in CreatePipeline() local
254 std::lock_guard<std::mutex> autoLock(pipelineMutex_); in DestroyPipeline() local
/foundation/communication/dsoftbus/core/frame/standard/client_manager/src/
Dsoftbus_client_info_manager.cpp43 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusAddService() local
63 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusRemoveService() local
79 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxy() local
90 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxy() local
104 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxyMap() local
112 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusClientIsExist() local
/foundation/resourceschedule/frame_aware_sched/interfaces/innerkits/frameintf/
Dframe_msg_intf.cpp41 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in Init() local
68 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in ReportWindowFocus() local
80 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in ReportRenderThread() local
93 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in ReportAppInfo() local
106 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in ReportProcessInfo() local
118 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in ReportCgroupChange() local
132 std::lock_guard<ffrt::mutex> autoLock(frameMsgIntfMutex_); in ReportContinuousTask() local
/foundation/systemabilitymgr/samgr/services/lsamgr/src/
Dlocal_abilitys.cpp31 std::lock_guard<std::mutex> autoLock(localSALock_); in AddAbility() local
37 std::lock_guard<std::mutex> autoLock(localSALock_); in GetAbility() local
48 std::lock_guard<std::mutex> autoLock(localSALock_); in RemoveAbility() local
/foundation/distributedhardware/device_manager/services/service/src/ipc/lite/
Dipc_server_listenermgr.cpp32 std::lock_guard<std::mutex> autoLock(lock_); in RegisterListener() local
43 std::lock_guard<std::mutex> autoLock(lock_); in GetListenerByPkgName() local
55 std::lock_guard<std::mutex> autoLock(lock_); in UnregisterListener() local
/foundation/distributedhardware/device_manager/services/implementation/src/discovery/
Ddm_discovery_manager.cpp58 std::lock_guard<std::mutex> autoLock(locks_); in CheckDiscoveryQueue() local
89 std::lock_guard<std::mutex> autoLock(locks_); in StartDeviceDiscovery() local
109 std::lock_guard<std::mutex> autoLock(locks_); in StartDeviceDiscovery() local
127 std::lock_guard<std::mutex> autoLock(locks_); in StopDeviceDiscovery() local
145 std::lock_guard<std::mutex> autoLock(locks_); in OnDeviceFound() local
208 std::lock_guard<std::mutex> autoLock(locks_); in OnDeviceFound() local
240 std::lock_guard<std::mutex> autoLock(locks_); in OnDiscoveryFailed() local
257 std::lock_guard<std::mutex> autoLock(locks_); in OnDiscoverySuccess() local
270 std::lock_guard<std::mutex> autoLock(locks_); in HandleDiscoveryTimeout() local
/foundation/deviceprofile/device_info_manager/old/services/core/src/dbstorage/
Ddevice_profile_storage_manager.cpp90 std::lock_guard<std::mutex> autoLock(serviceLock_); in Init() local
157 std::unique_lock<std::mutex> autoLock(serviceLock_); in PutDeviceProfile() local
223 std::unique_lock<std::mutex> autoLock(serviceLock_); in GetDeviceProfile() local
251 std::unique_lock<std::mutex> autoLock(serviceLock_); in SetServiceType() local
286 std::unique_lock<std::mutex> autoLock(serviceLock_); in DeleteDeviceProfile() local
334 std::unique_lock<std::mutex> autoLock(serviceLock_); in RemoveUnBoundDeviceProfile() local
425 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
438 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
450 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncCompleted() local
465 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySubscriberDied() local
[all …]
/foundation/systemabilitymgr/safwk/services/safwk/src/
Dsystem_ability.cpp92 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Publish() local
105 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in CancelIdle() local
166 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Start() local
179 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Start() local
189 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Idle() local
198 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Idle() local
209 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Active() local
218 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Active() local
228 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Stop() local
239 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Stop() local
[all …]

123456