| /system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/ |
| D | handler_manager.cpp | 72 std::lock_guard<std::mutex> lock(lock_); in AddHandler()
83 std::lock_guard<std::mutex> lock(lock_); in StartHandler()
113 std::lock_guard<std::mutex> lock(lock_); in DeleteHandler()
151 std::lock_guard<std::mutex> lock(lock_); in RunThread()
187 std::lock_guard<std::mutex> lock(lock_); in InitiateMerge()
197 bool SnapshotHandlerManager::StartMerge(std::lock_guard<std::mutex>* proof_of_lock, in StartMerge()
241 std::lock_guard<std::mutex> lock(lock_); in MonitorMerge()
263 std::lock_guard<std::mutex> lock(lock_); in GetMergeStatus()
274 std::lock_guard<std::mutex> lock(lock_); in GetMergePercentage()
305 std::lock_guard<std::mutex> lock(lock_); in GetVerificationStatus()
[all …]
|
| D | snapuserd_transitions.cpp | 170 std::lock_guard<std::mutex> lock(lock_); in MonitorMerge()
179 std::lock_guard<std::mutex> lock(lock_); in InitiateMerge()
249 std::lock_guard<std::mutex> lock(lock_); in ReadAheadIOCompleted()
290 std::lock_guard<std::mutex> lock(lock_); in NotifyRAForMergeReady()
303 std::lock_guard<std::mutex> lock(lock_); in MergeFailed()
312 std::lock_guard<std::mutex> lock(lock_); in MergeCompleted()
338 std::lock_guard<std::mutex> lock(lock_); in NotifyIOTerminated()
346 std::lock_guard<std::mutex> lock(lock_); in IsIOTerminated()
353 std::lock_guard<std::mutex> lock(lock_); in ReadAheadIOFailed()
390 std::lock_guard<std::mutex> lock(lock_); in MarkMergeComplete()
[all …]
|
| /system/core/init/ |
| D | action_manager.cpp | 44 auto lock = std::lock_guard{event_queue_lock_}; in QueueEventTrigger()
49 auto lock = std::lock_guard{event_queue_lock_}; in QueuePropertyChange()
58 auto lock = std::lock_guard{event_queue_lock_}; in QueueBuiltinAction()
69 auto lock = std::lock_guard{event_queue_lock_}; in ExecuteOneCommand()
112 auto lock = std::lock_guard{event_queue_lock_}; in HasMoreCommands()
123 auto lock = std::lock_guard{event_queue_lock_}; in ClearQueue()
|
| /system/chre/host/hal_generic/aidl/ |
| D | event_logger.cc | 48 std::lock_guard<std::mutex> lock(mQueuesMutex); in logNanoappLoad()
59 std::lock_guard<std::mutex> lock(mQueuesMutex); in logNanoappUnload()
68 std::lock_guard<std::mutex> lock(mQueuesMutex); in logContextHubRestart()
74 std::lock_guard<std::mutex> lock(mQueuesMutex); in logMessageToNanoapp()
85 std::lock_guard<std::mutex> lock(mQueuesMutex); in logMessageFromNanoapp()
94 std::lock_guard<std::mutex> lock(mQueuesMutex); in logMessageFromNanoapp()
106 std::lock_guard<std::mutex> lock(mQueuesMutex); in dump()
|
| D | generic_context_hub_aidl.cc | 144 std::lock_guard<std::mutex> lock(mTestModeMutex); in loadNanoapp()
156 std::lock_guard<std::mutex> lock(mTestModeMutex); in unloadNanoapp()
264 std::lock_guard<std::mutex> lock(mCallbackMutex); in registerCallback()
310 std::lock_guard<std::mutex> lock(mConnectedHostEndpointsMutex); in onHostEndpointConnected()
335 std::lock_guard<std::mutex> lock(mConnectedHostEndpointsMutex); in onHostEndpointDisconnected()
355 std::lock_guard<std::mutex> lock(mCallbackMutex); in onNanoappMessage()
413 std::lock_guard<std::mutex> lock(mQueryNanoappsInternalMutex); in onNanoappListResponse()
420 std::lock_guard<std::mutex> lock(mCallbackMutex); in onNanoappListResponse()
433 std::lock_guard<std::mutex> callbackLock(mCallbackMutex); in onTransactionResult()
441 std::lock_guard<std::mutex> lock(mCallbackMutex); in onContextHubRestarted()
[all …]
|
| /system/logging/logd/ |
| D | LogBufferTest.h | 56 auto lock = std::lock_guard{*mutex_}; in Write()
105 auto lock = std::lock_guard{logd_lock};
124 auto lock = std::lock_guard{mutex_}; in TestReaderThread()
144 auto lock = std::lock_guard{mutex_}; in WaitForMessages()
153 auto lock = std::lock_guard{mutex_}; in read_log_messages()
170 auto lock = std::lock_guard{logd_lock}; in ReadLogMessagesNonBlockingThread()
178 auto lock = std::lock_guard{logd_lock}; in ReleaseAndJoinReaders()
187 auto lock = std::lock_guard{logd_lock}; in ReleaseAndJoinReaders()
|
| D | SimpleLogBuffer.cpp | 39 auto lock = std::lock_guard{logd_lock}; in Init()
98 auto lock = std::lock_guard{logd_lock}; in Log()
185 auto lock = std::lock_guard{logd_lock}; in Clear()
197 auto lock = std::lock_guard{logd_lock}; in Clear()
202 auto lock = std::lock_guard{logd_lock}; in Clear()
211 auto lock = std::lock_guard{logd_lock}; in Clear()
217 auto lock = std::lock_guard{logd_lock}; in GetSize()
229 auto lock = std::lock_guard{logd_lock}; in SetSize()
|
| /system/chre/chpp/test/ |
| D | fake_link.cpp | 32 std::lock_guard<std::mutex> lock(mMutex); in appendTxPacket()
39 std::lock_guard<std::mutex> lock(mMutex); in getTxPacketCount()
57 std::lock_guard<std::mutex> lock(mMutex); in popTxPacket()
65 std::lock_guard<std::mutex> lock(mMutex); in reset()
|
| /system/netd/server/ |
| D | EventReporter.cpp | 24 std::lock_guard lock(mEventMutex); in getNetdEventListener()
42 std::lock_guard lock(mUnsolicitedMutex); in getNetdUnsolicitedEventListenerMap()
48 std::lock_guard lock(mUnsolicitedMutex); in registerUnsolEventListener()
76 std::lock_guard lock(mUnsolicitedMutex); in unregisterUnsolEventListener()
|
| D | TcpSocketMonitor.cpp | 105 std::lock_guard guard(mLock); in dump()
158 std::lock_guard guard(mLock); in setPollingInterval()
168 std::lock_guard guard(mLock); in resumePolling()
181 std::lock_guard guard(mLock); in suspendPolling()
193 std::lock_guard guard(mLock); in poll()
260 std::lock_guard guard(mLock); in waitForNextPoll()
274 std::lock_guard guard(mLock); in isRunning()
321 std::lock_guard guard(mLock); in TcpSocketMonitor()
337 std::lock_guard guard(mLock); in ~TcpSocketMonitor()
|
| /system/chre/platform/linux/task_util/ |
| D | task_manager.cc | 44 std::lock_guard<std::mutex> lock(mMutex); in addTask()
65 std::lock_guard<std::mutex> lock(mMutex); in cancelTask()
88 std::lock_guard<std::mutex> lock(mMutex); in flushTasks()
96 std::lock_guard<std::mutex> lock(mMutex); in flushAndStop()
148 std::lock_guard<std::mutex> lock(mMutex); in run()
|
| D | task.cc | 45 std::lock_guard lock(mExecutionMutex); in operator =()
56 std::lock_guard lock(mExecutionMutex); in cancel()
64 std::lock_guard lock(mExecutionMutex); in execute()
|
| /system/media/audio_utils/include/audio_utils/ |
| D | CommandThread.h | 55 std::lock_guard lg(mMutex); in add()
66 std::lock_guard lg(mMutex); in dump()
77 std::lock_guard lg(mMutex); in quit()
88 std::lock_guard lg(mMutex); in size()
|
| /system/gsid/ |
| D | gsi_service.cpp | 144 std::lock_guard<std::mutex> guard(lock_); in openInstall()
166 std::lock_guard<std::mutex> guard(lock_); in closeInstall()
201 std::lock_guard<std::mutex> guard(lock_); in createPartition()
242 std::lock_guard<std::mutex> guard(lock_); in closePartition()
259 std::lock_guard<std::mutex> guard(lock_); in commitGsiChunkFromStream()
271 std::lock_guard<std::mutex> guard(progress_lock_); in StartAsyncOperation()
280 std::lock_guard<std::mutex> guard(progress_lock_); in UpdateProgress()
292 std::lock_guard<std::mutex> guard(progress_lock_); in getInstallProgress()
303 std::lock_guard<std::mutex> guard(lock_); in commitGsiChunkFromAshmem()
327 std::lock_guard<std::mutex> guard(lock_); in enableGsiAsync()
[all …]
|
| /system/chre/host/hal_generic/common/ |
| D | hal_client_manager.cc | 149 const std::lock_guard<std::mutex> lock(mLock); in getClientId()
160 const std::lock_guard<std::mutex> lock(mLock); in getCallback()
172 const std::lock_guard<std::mutex> lock(mLock); in registerCallback()
215 const std::lock_guard<std::mutex> lock(mLock); in handleClientDeath()
246 const std::lock_guard<std::mutex> lock(mLock); in registerPendingLoadTransaction()
263 const std::lock_guard<std::mutex> lock(mLock); in getNextFragmentedLoadRequest()
282 const std::lock_guard<std::mutex> lock(mLock); in registerPendingUnloadTransaction()
347 const std::lock_guard<std::mutex> lock(mLock); in registerEndpointId()
374 const std::lock_guard<std::mutex> lock(mLock); in removeEndpointId()
400 const std::lock_guard<std::mutex> lock(mLock); in getCallbackForEndpoint()
[all …]
|
| /system/libhidl/transport/token/1.0/utils/ |
| D | HybridInterface.cpp | 35 std::lock_guard<std::mutex> lock(gTokenManagerLock); in serviceDied()
79 std::lock_guard<std::mutex> lock(gTokenManagerLock); in retrieveHalInterface()
94 std::lock_guard<std::mutex> lock(gTokenManagerLock); in createHalToken()
108 std::lock_guard<std::mutex> lock(gTokenManagerLock); in deleteHalToken()
|
| /system/media/audio_utils/ |
| D | MelAggregator.cpp | 169 std::lock_guard _l(mLock); in aggregateAndAddNewMelRecord()
239 std::lock_guard _l(mLock); in reset()
251 std::lock_guard _l(mLock); in getCachedMelRecordsSize()
257 std::lock_guard _l(mLock); in foreachCachedMel()
264 std::lock_guard _l(mLock); in getCsd()
269 std::lock_guard _l(mLock); in getCsdRecordsSize()
275 std::lock_guard _l(mLock); in foreachCsd()
|
| /system/core/libstats/bootstrap/ |
| D | BootstrapClientInternal.cpp | 31 std::lock_guard<std::mutex> lock(mLock); in getServiceNonBlocking()
40 std::lock_guard<std::mutex> lock(mLock); in binderDied()
|
| /system/core/libmodprobe/ |
| D | libmodprobe_ext.cpp | 57 std::lock_guard guard(module_loaded_lock_); in Insmod()
67 std::lock_guard guard(module_loaded_lock_); in Insmod()
81 std::lock_guard guard(module_loaded_lock_); in Rmmod()
|
| /system/chre/host/common/ |
| D | socket_server.cc | 69 std::lock_guard<std::mutex> lock(mClientsMutex); in run()
84 std::lock_guard<std::mutex> lock(mClientsMutex); in sendToAllClients()
106 std::lock_guard<std::mutex> lock(mClientsMutex); in sendToClientById()
156 std::lock_guard<std::mutex> lock(mClientsMutex); in acceptClientConnection()
190 std::lock_guard<std::mutex> lock(mClientsMutex); in disconnectClient()
|
| D | hal_client.cc | 76 std::lock_guard<std::shared_mutex> lockGuard{mConnectionLock}; in initConnection()
137 std::lock_guard<std::shared_mutex> lockGuard(halClient->mConnectionLock); in onHalDisconnected()
215 std::lock_guard<std::shared_mutex> lockGuard( in tryReconnectEndpoints()
237 std::lock_guard<std::mutex> lock(mBackgroundConnectionFuturesLock); in ~HalClient()
|
| /system/apex/apexd/ |
| D | apex_database.h | 121 std::lock_guard lock(mounted_apexes_mutex_); in AddMountedApex()
129 std::lock_guard lock(mounted_apexes_mutex_);
151 std::lock_guard lock(mounted_apexes_mutex_); in DoIfLatest()
167 std::lock_guard lock(mounted_apexes_mutex_);
185 std::lock_guard lock(mounted_apexes_mutex_);
214 std::lock_guard lock(mounted_apexes_mutex_); in Reset()
|
| /system/chre/platform/linux/ |
| D | pal_ble.cc | 68 std::lock_guard<std::mutex> lock(gBatchMutex); in flush()
89 std::lock_guard<std::mutex> lock(gBatchMutex); in sendAdReportEvents()
112 std::lock_guard<std::mutex> lock(gBatchMutex); in startScan()
156 std::lock_guard<std::mutex> lock(gBatchMutex); in chrePalBleStartScan()
215 std::lock_guard<std::mutex> lock(gBatchMutex); in chrePalBleApiClose()
|
| /system/media/audio_utils/tests/ |
| D | audio_mutex_tests.cpp | 152 audio_utils::lock_guard l(mutex1()); in value1()
169 audio_utils::lock_guard l(mutex2()); in combo12_l()
198 audio_utils::lock_guard l1(mutex1()); in combo123()
199 audio_utils::lock_guard l2(mutex2()); in combo123()
200 audio_utils::lock_guard l3(mutex3()); in combo123()
208 audio_utils::lock_guard l2(mutex2()); in combo123()
209 audio_utils::lock_guard l1(mutex1()); // 2 is acquired before 1. in combo123()
210 audio_utils::lock_guard l3(mutex3()); in combo123()
235 audio_utils::lock_guard(c.mutex1()); in TEST()
241 audio_utils::lock_guard l(c.mutex1()); in TEST()
[all …]
|
| /system/chre/host/common/pigweed/ |
| D | hal_rpc_client.cc | 52 std::lock_guard lock(mNanoappMutex); in hasService()
107 std::lock_guard lock(mHubInfoMutex); in init()
205 std::lock_guard lock(mClient->mHubInfoMutex); in handleHubInfoResponse()
215 std::lock_guard lock(mClient->mNanoappMutex); in handleNanoappListResponse()
|