| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| D | db_status_adapter.cpp | 34 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/ |
| 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_sink/src/ |
| D | dcamera_sink_handler_ipc.cpp | 45 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/ |
| D | dcamera_source_handler_ipc.cpp | 45 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/ |
| D | runtime_context_impl.cpp | 89 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/ |
| 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/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/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| D | cloud_syncer.cpp | 109 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 …]
|
| D | process_notifier.cpp | 35 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/ |
| 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 | 57 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 …]
|
| 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 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/ |
| D | common_event_collect.cpp | 84 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 …]
|
| D | device_timed_collect.cpp | 137 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/ |
| D | plugin_mgr.cpp | 88 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/ |
| 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/communication/dsoftbus/core/frame/standard/client_manager/src/ |
| D | softbus_client_info_manager.cpp | 43 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/ |
| D | frame_msg_intf.cpp | 41 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/ |
| 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/distributedhardware/device_manager/services/implementation/src/discovery/ |
| D | dm_discovery_manager.cpp | 58 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/ |
| D | device_profile_storage_manager.cpp | 90 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/ |
| 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 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 …]
|