| /foundation/distributedhardware/devicemanager/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
76 std::lock_guard<std::mutex> autoLock(lock_); in RegisterDiscoveryCallback() local
89 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterDiscoveryCallback() local
106 std::lock_guard<std::mutex> autoLock(lock_); in RegisterAuthenticateCallback() local
120 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterAuthenticateCallback() local
135 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterPackageCallback() local
145 std::lock_guard<std::mutex> autoLock(lock_); in RegisterVerifyAuthenticationCallback() local
[all …]
|
| /foundation/distributedhardware/distributedcamera/interfaces/inner_kits/native_cpp/camera_source/src/ |
| D | dcamera_source_handler_ipc.cpp | 43 std::lock_guard<std::mutex> autoLock(initDmsLock_); in Init() local
58 std::lock_guard<std::mutex> autoLock(initDmsLock_); in UnInit() local
76 std::lock_guard<std::mutex> autoLock(sourceLocalDmsLock_); in GetSourceLocalDHMS() local
101 std::lock_guard<std::mutex> autoLock(sourceLocalDmsLock_); in GetSourceLocalDHMS() local
114 std::lock_guard<std::mutex> autoLock(sourceLocalDmsLock_); in DeleteSourceLocalDhms() local
146 std::lock_guard<std::mutex> autoLock(sourceLocalDmsLock_); in OnSourceLocalDmsDied() local
|
| /foundation/distributedhardware/distributedcamera/interfaces/inner_kits/native_cpp/camera_sink/src/ |
| D | dcamera_sink_handler_ipc.cpp | 43 std::lock_guard<std::mutex> autoLock(initDmsLock_); in Init() local
58 std::lock_guard<std::mutex> autoLock(initDmsLock_); in UnInit() local
76 std::lock_guard<std::mutex> autoLock(sinkLocalDmsLock_); in GetSinkLocalDHMS() local
101 std::lock_guard<std::mutex> autoLock(sinkLocalDmsLock_); in GetSinkLocalDHMS() local
114 std::lock_guard<std::mutex> autoLock(sinkLocalDmsLock_); in DeleteSinkLocalDhms() local
146 std::lock_guard<std::mutex> autoLock(sinkLocalDmsLock_); in OnSinkLocalDmsDied() local
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/common/src/ |
| D | runtime_context_impl.cpp | 76 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAdapter() local
123 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAggregator() local
135 std::lock_guard<std::mutex> autoLock(communicatorLock_); in GetLocalIdentity() local
202 std::lock_guard<std::mutex> autoLock(timersLock_); in ModifyTimer() local
220 std::lock_guard<std::mutex> autoLock(timersLock_); in RemoveTimer() local
239 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleTask() local
251 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleQueuedTask() local
262 std::lock_guard<std::mutex> autoLock(taskLock_); in ShrinkMemory() local
271 std::lock_guard<std::mutex> autoLock(timeTickMonitorLock_); in RegisterTimeChangedLister() local
286 std::lock_guard<std::mutex> autoLock(loopLock_); in PrepareLoop() local
[all …]
|
| D | auto_launch.cpp | 42 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
180 std::lock_guard<std::mutex> autoLock(dataLock_); in EnableKvStoreAutoLaunch() local
204 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
209 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
224 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
228 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
234 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
[all …]
|
| /foundation/distributedhardware/distributedcamera/services/cameraservice/sourceservice/src/distributedcameramgr/ |
| D | dcamera_source_service_ipc.cpp | 43 std::lock_guard<std::mutex> autoLock(initDmsLock_); in Init() local
58 std::lock_guard<std::mutex> autoLock(initDmsLock_); in UnInit() local
80 std::lock_guard<std::mutex> autoLock(sinkRemoteDmsLock_); in GetSinkRemoteDHMS() local
110 std::lock_guard<std::mutex> autoLock(sinkRemoteDmsLock_); in GetSinkRemoteDHMS() local
124 std::lock_guard<std::mutex> autoLock(sinkRemoteDmsLock_); in DeleteSinkRemoteDhms() local
140 std::lock_guard<std::mutex> autoLock(sinkRemoteDmsLock_); in ClearSinkRemoteDhms() local
174 std::lock_guard<std::mutex> autoLock(sinkRemoteDmsLock_); in OnSinkRemoteDmsDied() local
|
| /foundation/distributedhardware/distributedcamera/services/cameraservice/sinkservice/src/distributedcameramgr/ |
| D | dcamera_sink_service_ipc.cpp | 43 std::lock_guard<std::mutex> autoLock(initDmsLock_); in Init() local
58 std::lock_guard<std::mutex> autoLock(initDmsLock_); in UnInit() local
80 std::lock_guard<std::mutex> autoLock(sourceRemoteDmsLock_); in GetSourceRemoteDHMS() local
110 std::lock_guard<std::mutex> autoLock(sourceRemoteDmsLock_); in GetSourceRemoteDHMS() local
124 std::lock_guard<std::mutex> autoLock(sourceRemoteDmsLock_); in DeleteSourceRemoteDhms() local
140 std::lock_guard<std::mutex> autoLock(sourceRemoteDmsLock_); in ClearSourceRemoteDhms() local
174 std::lock_guard<std::mutex> autoLock(sourceRemoteDmsLock_); in OnSourceRemoteDmsDied() local
|
| /foundation/communication/dsoftbus/core/frame/standard/client_manager/src/ |
| D | softbus_client_info_manager.cpp | 35 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusAddService() local
47 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusRemoveService() local
61 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxy() local
72 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxyMap() local
80 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusClientIsExist() 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
65 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportAppInfo() local
77 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportWindowFocus() local
89 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportProcessInfo() local
101 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in Stop() local
|
| /foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/ |
| D | plugin_mgr.cpp | 143 std::lock_guard<std::mutex> autoLock(pluginMutex_); in LoadPlugin() local
176 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in DispatchResource() local
191 std::lock_guard<std::mutex> autoLock(dispatcherHandlerMutex_); in DispatchResource() local
205 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in SubscribeResource() local
215 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in UnSubscribeResource() local
230 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in ClearResource() local
236 std::lock_guard<std::mutex> autoLock(pluginMutex_); in deliverResourceToPlugin() local
270 std::lock_guard<std::mutex> autoLock(pluginMutex_); in UnLoadPlugin() local
289 std::lock_guard<std::mutex> autoLock(dispatcherHandlerMutex_); in OnDestroy() local
|
| D | res_sched_mgr.cpp | 42 std::lock_guard<std::mutex> autoLock(mainHandlerMutex_); in Stop() local
55 std::lock_guard<std::mutex> autoLock(mainHandlerMutex_); in ReportData() local
|
| /foundation/distributedschedule/dmsfwk/services/dtbschedmgr/src/ |
| D | dtbschedmgr_device_info_storage.cpp | 146 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in RegisterUuidNetworkIdMap() local
155 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in UnregisterUuidNetworkIdMap() local
163 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceIdSet() local
194 lock_guard<mutex> autoLock(deviceLock_); in ClearAllDevices() local
200 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceInfoById() local
215 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetUuidByNetworkId() local
236 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetNetworkIdByUuid() local
269 lock_guard<mutex> autoLock(deviceLock_); in DeviceOnlineNotify() local
298 lock_guard<mutex> autoLock(deviceLock_); in DeviceOfflineNotify() 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 IsInContinuationProgress() local
150 std::lock_guard<std::mutex> autoLock(continuationLock_); in PushCallback() local
162 std::lock_guard<std::mutex> autoLock(continuationLock_); in PopCallback() local
|
| /foundation/distributedhardware/devicemanager/services/devicemanagerservice/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/deviceprofile/device_profile_core/services/core/src/dbstorage/ |
| D | device_profile_storage_manager.cpp | 79 std::lock_guard<std::mutex> autoLock(serviceLock_); in Init() local
144 std::unique_lock<std::mutex> autoLock(serviceLock_); in PutDeviceProfile() local
193 std::unique_lock<std::mutex> autoLock(serviceLock_); in GetDeviceProfile() local
209 std::unique_lock<std::mutex> autoLock(serviceLock_); in SetServiceType() local
243 std::unique_lock<std::mutex> autoLock(serviceLock_); in DeleteDeviceProfile() local
320 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
333 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
344 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncCompleted() local
359 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySubscriberDied() local
407 std::unique_lock<std::mutex> autoLock(serviceLock_); in FlushProfileItems() local
[all …]
|
| D | online_sync_table.cpp | 64 std::lock_guard<std::mutex> autoLock(tableLock_); in RegisterSyncCallback() local
72 std::lock_guard<std::mutex> autoLock(tableLock_); in UnRegisterSyncCallback() local
141 std::lock_guard<std::mutex> autoLock(tableLock_); in NotifySyncCompleted() local
|
| /foundation/distributedschedule/dmsfwk/services/dtbschedmgr/src/mission/ |
| D | distributed_sched_mission_manager.cpp | 107 std::lock_guard<std::mutex> autoLock(remoteDmsLock_); in GetRemoteDms() local
134 std::lock_guard<std::mutex> autoLock(remoteDmsLock_); in GetRemoteDms() local
317 std::lock_guard<std::mutex> autoLock(remoteDmsLock_); in DeviceOfflineNotify() local
326 std::lock_guard<std::mutex> autoLock(osdSwitchLock_); in DeviceOfflineNotify() local
342 std::lock_guard<std::mutex> autoLock(osdSwitchLock_); in UpdateConnCapSupportOsd() local
417 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in RegisterMissionListener() local
445 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in StartSyncRemoteMissions() local
464 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in StartSyncRemoteMissions() local
508 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in UnRegisterMissionListener() local
532 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in CleanMissionResources() local
[all …]
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/syncer/src/ |
| D | single_ver_relational_sync_task_context.cpp | 57 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in SetRelationalSyncStrategy() local
63 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in GetSyncStrategy() local
82 std::lock_guard<std::mutex> autoLock(syncStrategyMutex_); in SchemaChange() local
|
| D | query_sync_water_mark_helper.cpp | 52 std::lock_guard<std::mutex> autoLock(lruLock_); in Put() local
59 std::lock_guard<std::mutex> autoLock(lruLock_); in Get() local
69 std::lock_guard<std::mutex> autoLock(lruLock_); in RemoveWithPrefixKey() local
146 std::lock_guard<std::mutex> autoLock(deleteSyncLock_); in LoadDeleteSyncDataToCache() local
183 std::lock_guard<std::mutex> autoLock(queryWaterMarkLock_); in GetQueryWaterMark() local
192 std::lock_guard<std::mutex> autoLock(queryWaterMarkLock_); in SetRecvQueryWaterMark() local
201 std::lock_guard<std::mutex> autoLock(queryWaterMarkLock_); in SetLastQueryTime() local
229 std::lock_guard<std::mutex> autoLock(queryWaterMarkLock_); in SetSendQueryWaterMark() local
351 std::lock_guard<std::mutex> autoLock(queryWaterMarkLock_); in GetHashQuerySyncDeviceId() local
375 std::lock_guard<std::mutex> autoLock(deleteSyncLock_); in SetSendDeleteSyncWaterMark() local
[all …]
|
| /foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/ |
| D | session_service_impl.cpp | 56 std::lock_guard<std::mutex> autoLock(listenerMutex_); in CreateSessionServer() local
71 std::lock_guard<std::mutex> autoLock(listenerMutex_); in RemoveSessionServer() local
96 std::lock_guard<std::mutex> autoLock(sessionMutex_); in OpenSession() local
118 std::lock_guard<std::mutex> autoLock(sessionMutex_); in CloseSession() local
159 std::lock_guard<std::mutex> autoLock(sessionMutex_); in CreatNewSession() local
195 std::lock_guard<std::mutex> autoLock(sessionMutex_); in OpenSessionCallback() local
264 std::lock_guard<std::mutex> autoLock(sessionMutex_); in GetSessionListener() local
268 std::lock_guard<std::mutex> autoLock(listenerMutex_); in GetSessionListener() local
288 std::lock_guard<std::mutex> autoLock(listenerMutex_); in GetSessionListenerOnSessionOpened() local
|
| /foundation/deviceprofile/device_profile_core/services/core/src/devicemanager/ |
| D | device_manager.cpp | 100 std::lock_guard<std::mutex> autoLock(deviceLock_); in OnNodeOnline() local
115 std::lock_guard<std::mutex> autoLock(deviceLock_); in OnNodeOffline() local
180 std::lock_guard<std::mutex> autoLock(deviceLock_); in RecoverDevicesIfNeeded() local
197 std::lock_guard<std::mutex> autoLock(deviceLock_); in AddLocalDeviceIds() local
214 std::lock_guard<std::mutex> autoLock(deviceLock_); in AddDeviceIds() local
221 std::lock_guard<std::mutex> autoLock(deviceLock_); in RemoveDeviceIds() local
298 std::lock_guard<std::mutex> autoLock(deviceLock_); in TransformDeviceId() local
312 std::lock_guard<std::mutex> autoLock(deviceLock_); in GetDeviceIdList() local
321 std::lock_guard<std::mutex> autoLock(deviceLock_); in GetDeviceList() local
|
| /foundation/distributedhardware/devicemanager/interfaces/inner_kits/native_cpp/src/ipc/standard/ |
| D | ipc_client_manager.cpp | 75 std::lock_guard<std::mutex> autoLock(lock_); in Init() local
117 std::lock_guard<std::mutex> autoLock(lock_); in UnInit() local
160 std::lock_guard<std::mutex> autoLock(lock_); in IsInit() local
|
| /foundation/multimedia/medialibrary_standard/frameworks/innerkitsimpl/medialibrary_data_ability/src/ |
| D | medialibrary_device.cpp | 82 lock_guard<mutex> autoLock(deviceLock_); in OnDeviceOnline() local
106 lock_guard<mutex> autoLock(deviceLock_); in OnDeviceOffline() local
138 lock_guard<mutex> autoLock(deviceLock_); in ClearAllDevices() local
190 lock_guard<mutex> autoLock(deviceLock_); in InitDeviceRdbStore() local
215 lock_guard<mutex> autoLock(deviceLock_); in UpdateDevicieSyncStatus() local
231 lock_guard<mutex> autoLock(deviceLock_); in GetDevicieSyncStatus() local
|
| /foundation/distributedschedule/samgr/services/samgr/native/source/ |
| D | system_ability_manager.cpp | 82 std::lock_guard<std::mutex> autoLock(instanceLock); in GetInstance() local
109 lock_guard<mutex> autoLock(saProfileMapLock_); in InitSaProfile() local
123 lock_guard<mutex> autoLock(saProfileMapLock_); in GetSaProfile() local
239 lock_guard<recursive_mutex> autoLock(listenerMapLock_); in FindSystemAbilityNotify() local
264 lock_guard<recursive_mutex> autoLock(onDemandLock_); in StartOnDemandAbility() local
298 lock_guard<recursive_mutex> autoLock(onDemandLock_); in AddOnDemandSystemAbilityInfo() local
348 lock_guard<recursive_mutex> autoLock(onDemandLock_); in CheckSystemAbility() local
448 lock_guard<recursive_mutex> autoLock(listenerMapLock_); in SubscribeSystemAbility() local
514 lock_guard<recursive_mutex> autoLock(listenerMapLock_); in UnSubscribeSystemAbility() local
524 lock_guard<recursive_mutex> autoLock(listenerMapLock_); in UnSubscribeSystemAbility() local
[all …]
|
| /foundation/deviceprofile/device_profile_core/services/core/src/subscribemanager/ |
| D | profile_sync_handler.cpp | 45 std::lock_guard<std::mutex> autoLock(notifierLock_); in SyncCompleted() local
54 std::lock_guard<std::mutex> autoLock(notifierLock_); in NotifySyncCompleted() local
|