| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| D | single_ver_relational_sync_task_context.cpp | 31 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
|
| D | single_ver_kv_sync_task_context.cpp | 29 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/ |
| D | device_manager_notify.cpp | 34 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_source/src/ |
| D | dcamera_source_handler_ipc.cpp | 44 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in Init() local
57 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in UnInit() local
73 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in GetSourceLocalCamSrv() local
98 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in GetSourceLocalCamSrv() local
111 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in DeleteSourceLocalCamSrv() local
128 std::lock_guard<std::mutex> autoLock(sourceLocalCamSrvLock_); in OnSourceLocalCamSrvDied() local
|
| /foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/camera_sink/src/ |
| D | dcamera_sink_handler_ipc.cpp | 44 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in Init() local
57 std::lock_guard<std::mutex> autoLock(initCamSrvLock_); in UnInit() local
73 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in GetSinkLocalCamSrv() local
98 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in GetSinkLocalCamSrv() local
111 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in DeleteSinkLocalCamSrv() local
128 std::lock_guard<std::mutex> autoLock(sinkLocalCamSrvLock_); in OnSinkLocalCamSrvDied() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | runtime_context_impl.cpp | 81 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAdapter() local
128 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAggregator() local
140 std::lock_guard<std::mutex> autoLock(communicatorLock_); in GetLocalIdentity() local
213 std::lock_guard<std::mutex> autoLock(timersLock_); in ModifyTimer() local
232 std::lock_guard<std::mutex> autoLock(timersLock_); in RemoveTimer() local
254 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleTask() local
269 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleQueuedTask() local
280 std::lock_guard<std::mutex> autoLock(taskLock_); in ShrinkMemory() local
289 std::lock_guard<std::mutex> autoLock(timeTickMonitorLock_); in RegisterTimeChangedLister() local
306 std::lock_guard<std::mutex> autoLock(loopLock_); in PrepareLoop() local
[all …]
|
| D | auto_launch.cpp | 43 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAggregator() local
77 std::lock_guard<std::mutex> autoLock(communicatorLock_); in ~AutoLaunch() local
88 std::unique_lock<std::mutex> autoLock(dataLock_); in ~AutoLaunch() local
124 std::lock_guard<std::mutex> autoLock(dataLock_); in EnableKvStoreAutoLaunchParmCheck() local
178 std::lock_guard<std::mutex> autoLock(dataLock_); in EnableKvStoreAutoLaunch() local
202 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
224 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
230 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
338 std::lock_guard<std::mutex> autoLock(dataLock_); in ObserverFunc() local
366 std::lock_guard<std::mutex> autoLock(dataLock_); in ObserverFunc() local
[all …]
|
| /foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/ |
| D | dcamera_source_service_ipc.cpp | 43 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/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcameramgr/ |
| D | dcamera_sink_service_ipc.cpp | 43 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/resourceschedule/frame_aware_sched/interfaces/innerkits/frameintf/ |
| D | frame_msg_intf.cpp | 33 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in Init() local
64 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportWindowFocus() local
76 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportRenderThread() local
89 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportAppInfo() local
102 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportProcessInfo() local
114 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportCgroupChange() local
128 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in Stop() local
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
| D | dms_callback_task.cpp | 39 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
|
| D | distributed_sched_continuation.cpp | 54 std::lock_guard<std::mutex> autoLock(continuationLock_); in PushAbilityToken() local
78 std::lock_guard<std::mutex> autoLock(continuationLock_); in PopAbilityToken() local
94 std::lock_guard<std::mutex> autoLock(continuationLock_); in GenerateSessionId() local
122 std::lock_guard<std::mutex> autoLock(continuationLock_); in IsFreeInstall() local
133 std::lock_guard<std::mutex> autoLock(continuationLock_); in IsInContinuationProgress() local
144 std::lock_guard<std::mutex> autoLock(continuationLock_); in GetTargetDevice() local
167 std::lock_guard<std::mutex> autoLock(continuationLock_); in PushCallback() local
183 std::lock_guard<std::mutex> autoLock(continuationLock_); in PopCallback() local
250 std::lock_guard<std::mutex> autoLock(continuationLock_); in SetCleanMissionFlag() local
256 std::lock_guard<std::mutex> autoLock(continuationLock_); in IsCleanMission() local
|
| D | dtbschedmgr_device_info_storage.cpp | 149 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
185 lock_guard<mutex> autoLock(deviceLock_); in UpdateDeviceInfoStorage() local
216 lock_guard<mutex> autoLock(deviceLock_); in ClearAllDevices() local
222 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceInfoById() local
237 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetUuidByNetworkId() local
258 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetNetworkIdByUuid() local
285 lock_guard<mutex> autoLock(deviceLock_); in DeviceOnlineNotify() local
313 lock_guard<mutex> autoLock(deviceLock_); in DeviceOfflineNotify() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| D | cloud_syncer.cpp | 101 std::lock_guard<std::mutex> autoLock(contextLock_); in Close() local
119 std::lock_guard<std::mutex> autoLock(queueLock_); in Close() local
164 std::lock_guard<std::mutex> autoLock(queueLock_); in DoSyncIfNeed() local
187 std::lock_guard<std::mutex> autoLock(queueLock_); in DoSync() local
196 std::lock_guard<std::mutex> autoLock(contextLock_); in DoSync() local
225 std::lock_guard<std::mutex> autoLock(contextLock_); in DoUploadInNeed() local
264 std::lock_guard<std::mutex> autoLock(contextLock_); in DoSyncInner() local
288 std::lock_guard<std::mutex> autoLock(queueLock_); in DoFinished() local
294 std::lock_guard<std::mutex> autoLock(contextLock_); in DoFinished() local
312 std::lock_guard<std::mutex> autoLock(queueLock_); in DoFinished() local
[all …]
|
| /foundation/systemabilitymgr/samgr/services/samgr/native/source/collect/ |
| D | common_event_collect.cpp | 73 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in Init() local
78 std::lock_guard<std::mutex> autoLock(commomEventLock_); in Init() local
103 std::lock_guard<std::mutex> autoLock(commomEventLock_); in AddSkillsEvent() local
112 std::lock_guard<std::mutex> autoLock(commonEventSubscriberLock_); in CreateCommonEventSubscriber() local
149 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in SaveAction() local
173 std::lock_guard<std::mutex> autoLock(commonEventStateLock_); in CheckCondition() local
188 std::lock_guard<std::mutex> autoLock(extraDataLock_); in SaveOnDemandReasonExtraData() local
206 std::lock_guard<std::mutex> autoLock(extraDataLock_); in RemoveOnDemandReasonExtraData() local
213 std::lock_guard<std::mutex> autoLock(extraDataLock_); in GetOnDemandReasonExtraData() local
225 std::lock_guard<std::mutex> autoLock(commomEventLock_); in AddCollectEvent() local
|
| D | device_timed_collect.cpp | 39 lock_guard<mutex> autoLock(taskLock_); in Init() local
74 lock_guard<mutex> autoLock(taskLock_); in PostLoopTaskLocked() local
83 lock_guard<mutex> autoLock(taskLock_); in OnStart() local
109 std::lock_guard<std::mutex> autoLock(taskLock_); in AddCollectEvent() local
|
| /foundation/communication/dsoftbus/core/frame/standard/client_manager/src/ |
| D | softbus_client_info_manager.cpp | 42 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusAddService() local
63 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusRemoveService() local
78 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxy() local
89 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxy() local
105 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxyMap() local
113 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusClientIsExist() local
|
| /foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/ |
| D | dcamera_stream_data_process.cpp | 87 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/systemabilitymgr/samgr/services/lsamgr/src/ |
| D | local_abilitys.cpp | 31 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/ |
| D | ipc_server_listenermgr.cpp | 32 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/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| D | virtual_cloud_syncer.cpp | 60 std::lock_guard<std::mutex> autoLock(contextLock_); in Notify() local
65 std::lock_guard<std::mutex> autoLock(queueLock_); in Notify() local
68 std::lock_guard<std::mutex> autoLock(contextLock_); in Notify() local
74 std::lock_guard<std::mutex> autoLock(queueLock_); in GetQueueCount() local
86 std::lock_guard<std::mutex> autoLock(queueLock_); in SetCurrentTaskInfo() local
|
| /foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/ |
| D | plugin_mgr.cpp | 91 std::lock_guard<std::mutex> autoLock(dispatcherHandlerMutex_); in Init() local
119 std::lock_guard<std::mutex> autoLock(pluginMutex_); in LoadPlugin() local
198 std::lock_guard<std::mutex> autoLock(dispatcherHandlerMutex_); in GetRunner() local
212 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in GetPluginListByResType() local
251 std::lock_guard<std::mutex> autoLock(dispatcherHandlerMutex_); in DispatchResource() local
266 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in SubscribeResource() local
276 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in UnSubscribeResource() local
321 std::lock_guard<std::mutex> autoLock(pluginMutex_); in DumpInfoFromPlugin() local
353 std::lock_guard<std::mutex> autoLock(pluginMutex_); in DumpPluginInfoAppend() local
378 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in ClearResource() local
[all …]
|
| /foundation/distributedhardware/device_manager/services/implementation/src/discovery/ |
| D | dm_discovery_manager.cpp | 57 std::lock_guard<std::mutex> autoLock(locks_); in CheckDiscoveryQueue() local
88 std::lock_guard<std::mutex> autoLock(locks_); in StartDeviceDiscovery() local
108 std::lock_guard<std::mutex> autoLock(locks_); in StartDeviceDiscovery() local
126 std::lock_guard<std::mutex> autoLock(locks_); in StopDeviceDiscovery() local
144 std::lock_guard<std::mutex> autoLock(locks_); in OnDeviceFound() local
207 std::lock_guard<std::mutex> autoLock(locks_); in OnDeviceFound() local
239 std::lock_guard<std::mutex> autoLock(locks_); in OnDiscoveryFailed() local
256 std::lock_guard<std::mutex> autoLock(locks_); in OnDiscoverySuccess() local
269 std::lock_guard<std::mutex> autoLock(locks_); in HandleDiscoveryTimeout() local
|
| /foundation/deviceprofile/device_info_manager/services/core/src/dbstorage/ |
| D | device_profile_storage_manager.cpp | 86 std::lock_guard<std::mutex> autoLock(serviceLock_); in Init() local
152 std::unique_lock<std::mutex> autoLock(serviceLock_); in PutDeviceProfile() local
203 std::unique_lock<std::mutex> autoLock(serviceLock_); in GetDeviceProfile() local
219 std::unique_lock<std::mutex> autoLock(serviceLock_); in SetServiceType() local
254 std::unique_lock<std::mutex> autoLock(serviceLock_); in DeleteDeviceProfile() local
289 std::unique_lock<std::mutex> autoLock(serviceLock_); in RemoveUnBoundDeviceProfile() local
369 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
382 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
394 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncCompleted() local
409 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySubscriberDied() local
[all …]
|
| /foundation/systemabilitymgr/safwk/services/safwk/src/ |
| D | system_ability.cpp | 92 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Publish() local
105 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in CancelIdle() local
165 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Start() local
178 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Start() local
188 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Idle() local
197 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Idle() local
208 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Active() local
217 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Active() local
227 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Stop() local
238 std::lock_guard<std::recursive_mutex> autoLock(abilityLock); in Stop() local
[all …]
|