| /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
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 RegisterPublishCallback() local
119 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterPublishCallback() local
136 std::lock_guard<std::mutex> autoLock(lock_); in RegisterAuthenticateCallback() local
150 std::lock_guard<std::mutex> autoLock(lock_); in UnRegisterAuthenticateCallback() 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 | 79 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAdapter() local
126 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAggregator() local
138 std::lock_guard<std::mutex> autoLock(communicatorLock_); in GetLocalIdentity() local
205 std::lock_guard<std::mutex> autoLock(timersLock_); in ModifyTimer() local
223 std::lock_guard<std::mutex> autoLock(timersLock_); in RemoveTimer() local
242 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleTask() local
254 std::lock_guard<std::mutex> autoLock(taskLock_); in ScheduleQueuedTask() local
265 std::lock_guard<std::mutex> autoLock(taskLock_); in ShrinkMemory() local
274 std::lock_guard<std::mutex> autoLock(timeTickMonitorLock_); in RegisterTimeChangedLister() local
290 std::lock_guard<std::mutex> autoLock(loopLock_); in PrepareLoop() local
[all …]
|
| D | auto_launch.cpp | 45 std::lock_guard<std::mutex> autoLock(communicatorLock_); in SetCommunicatorAggregator() local
79 std::lock_guard<std::mutex> autoLock(communicatorLock_); in ~AutoLaunch() local
90 std::unique_lock<std::mutex> autoLock(dataLock_); in ~AutoLaunch() local
126 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
226 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
232 std::lock_guard<std::mutex> autoLock(dataLock_); in GetKVConnectionInEnable() local
340 std::lock_guard<std::mutex> autoLock(dataLock_); in ObserverFunc() local
368 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
101 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportProcessInfo() local
113 std::lock_guard<std::mutex> autoLock(frameMsgIntfMutex_); in ReportCgroupChange() local
125 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
|
| /foundation/communication/dsoftbus/core/frame/standard/client_manager/src/ |
| D | softbus_client_info_manager.cpp | 36 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusAddService() local
51 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in SoftbusRemoveService() local
65 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxy() local
76 std::lock_guard<std::recursive_mutex> autoLock(clientObjectMapLock_); in GetSoftbusClientProxyMap() local
84 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/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/ability/dmsfwk/services/base/src/ |
| D | dtbschedmgr_device_info_storage.cpp | 155 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in RegisterUuidNetworkIdMap() local
168 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in UnregisterUuidNetworkIdMap() local
176 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceIdSet() local
207 lock_guard<mutex> autoLock(deviceLock_); in ClearAllDevices() local
213 lock_guard<mutex> autoLock(deviceLock_); in GetDeviceInfoById() local
228 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetUuidByNetworkId() local
249 std::lock_guard<std::mutex> autoLock(uuidNetworkIdLock_); in GetNetworkIdByUuid() local
279 lock_guard<mutex> autoLock(deviceLock_); in DeviceOnlineNotify() local
311 lock_guard<mutex> autoLock(deviceLock_); in DeviceOfflineNotify() local
|
| /foundation/distributedhardware/device_manager/services/implementation/src/discovery/ |
| D | dm_discovery_manager.cpp | 55 std::lock_guard<std::mutex> autoLock(locks_); in CheckDiscoveryQueue() local
85 std::lock_guard<std::mutex> autoLock(locks_); in StartDeviceDiscovery() local
103 std::lock_guard<std::mutex> autoLock(locks_); in StopDeviceDiscovery() local
121 std::lock_guard<std::mutex> autoLock(locks_); in OnDeviceFound() local
150 std::lock_guard<std::mutex> autoLock(locks_); in OnDiscoverySuccess() local
162 std::lock_guard<std::mutex> autoLock(locks_); in HandleDiscoveryTimeout() local
|
| /foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/ |
| D | plugin_mgr.cpp | 94 std::lock_guard<std::mutex> autoLock(pluginMutex_); in LoadPlugin() local
166 std::lock_guard<std::mutex> autoLock(disablePluginsMutex_); in RemoveDisablePluginHandler() local
191 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in DispatchResource() local
233 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in SubscribeResource() local
243 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in UnSubscribeResource() local
288 std::lock_guard<std::mutex> autoLock(pluginMutex_); in DumpInfoFromPlugin() local
320 std::lock_guard<std::mutex> autoLock(pluginMutex_); in DumpPluginInfoAppend() local
343 std::lock_guard<std::mutex> autoLock(resTypeMutex_); in ClearResource() local
367 std::lock_guard<std::mutex> autoLock(disablePluginsMutex_); in RepairPlugin() local
387 std::lock_guard<std::mutex> autoLock(pluginMutex_); in deliverResourceToPlugin() local
[all …]
|
| /foundation/deviceprofile/device_info_manager/services/core/src/dbstorage/ |
| D | device_profile_storage_manager.cpp | 87 std::lock_guard<std::mutex> autoLock(serviceLock_); in Init() local
153 std::unique_lock<std::mutex> autoLock(serviceLock_); in PutDeviceProfile() local
204 std::unique_lock<std::mutex> autoLock(serviceLock_); in GetDeviceProfile() local
220 std::unique_lock<std::mutex> autoLock(serviceLock_); in SetServiceType() local
255 std::unique_lock<std::mutex> autoLock(serviceLock_); in DeleteDeviceProfile() local
290 std::unique_lock<std::mutex> autoLock(serviceLock_); in RemoveUnBoundDeviceProfile() local
360 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
373 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncStart() local
385 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySyncCompleted() local
400 std::lock_guard<std::mutex> autoLock(profileSyncLock_); in NotifySubscriberDied() local
[all …]
|
| /foundation/deviceprofile/device_info_manager/services/core/src/devicemanager/ |
| D | dp_device_manager.cpp | 104 std::lock_guard<std::mutex> autoLock(deviceLock_); in OnNodeOnline() local
119 std::lock_guard<std::mutex> autoLock(deviceLock_); in OnNodeOffline() local
218 std::lock_guard<std::mutex> autoLock(deviceLock_); in RecoverDevicesIfNeeded() local
234 std::lock_guard<std::mutex> autoLock(deviceLock_); in AddLocalDeviceIds() local
253 std::lock_guard<std::mutex> autoLock(deviceLock_); in AddDeviceIds() local
273 std::lock_guard<std::mutex> autoLock(deviceLock_); in RemoveDeviceIds() local
286 std::lock_guard<std::mutex> autoLock(deviceLock_); in RemoveDeviceIdsByUdid() local
340 std::lock_guard<std::mutex> autoLock(deviceLock_); in TransformDeviceId() local
354 std::lock_guard<std::mutex> autoLock(deviceLock_); in GetDeviceIdList() local
363 std::lock_guard<std::mutex> autoLock(deviceLock_); in GetDeviceList() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/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 | remote_executor.cpp | 60 std::lock_guard<std::mutex> autoLock(innerSourceLock_); in Initialize() local
170 std::lock_guard<std::mutex> autoLock(msgQueueLock_); in ReceiveRemoteExecutorRequest() local
184 std::lock_guard<std::mutex> autoLock(msgQueueLock_); in ReceiveRemoteExecutorRequest() local
392 std::lock_guard<std::mutex> autoLock(taskLock_); in RemoteQueryInner() local
426 std::lock_guard<std::mutex> autoLock(taskLock_); in TryExecuteTaskInLock() local
455 std::lock_guard<std::mutex> autoLock(taskLock_); in DoRollBack() local
622 std::lock_guard<std::mutex> autoLock(timeoutLock_); in StartTimer() local
631 std::lock_guard<std::mutex> autoLock(timeoutLock_); in RemoveTimer() local
662 std::lock_guard<std::mutex> autoLock(timeoutLock_); in DoTimeout() local
704 std::lock_guard<std::mutex> autoLock(taskLock_); in ClearTaskInfo() 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
175 std::lock_guard<std::mutex> autoLock(sessionMutex_); in OpenSessionCallback() local
244 std::lock_guard<std::mutex> autoLock(sessionMutex_); in GetSessionListener() local
248 std::lock_guard<std::mutex> autoLock(listenerMutex_); in GetSessionListener() local
268 std::lock_guard<std::mutex> autoLock(listenerMutex_); in GetSessionListenerOnSessionOpened() local
|
| /foundation/distributedhardware/distributed_screen/common/src/ |
| D | dscreen_sa_process_state.cpp | 39 std::lock_guard<std::mutex> autoLock(g_saProcessState); in SetSinkProcessExit() local
53 std::lock_guard<std::mutex> autoLock(g_saProcessState); in SetSourceProcessExit() local
|
| /foundation/distributedhardware/distributed_camera/common/src/utils/ |
| D | dcamera_sa_process_state.cpp | 37 std::lock_guard<std::mutex> autoLock(g_saProcessState); in SetSinkProcessExit() local
50 std::lock_guard<std::mutex> autoLock(g_saProcessState); in SetSourceProcessExit() local
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| D | distributed_sched_mission_manager.cpp | 98 std::lock_guard<std::mutex> autoLock(remoteDmsLock_); in GetRemoteDms() local
125 std::lock_guard<std::mutex> autoLock(remoteDmsLock_); in GetRemoteDms() local
270 std::lock_guard<std::mutex> autoLock(remoteDmsLock_); in DeviceOfflineNotify() local
328 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in RegisterMissionListener() local
351 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in StartSyncRemoteMissions() local
370 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in StartSyncRemoteMissions() local
410 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in UnRegisterMissionListener() local
434 std::lock_guard<std::mutex> autoLock(listenDeviceLock_); in CleanMissionResources() local
502 std::lock_guard<std::mutex> autoLock(remoteSyncDeviceLock_); in StartSyncMissionsFromRemote() local
527 std::lock_guard<std::mutex> autoLock(remoteSyncDeviceLock_); in StopSyncMissionsFromRemote() local
[all …]
|
| /foundation/distributedhardware/device_manager/interfaces/kits/js/src/ |
| D | dm_native_event.cpp | 42 std::lock_guard<std::mutex> autoLock(lock_); in On() local
59 std::lock_guard<std::mutex> autoLock(lock_); in Off() local
82 std::lock_guard<std::mutex> autoLock(lock_); in OnEvent() local
|