| /packages/modules/StatsD/statsd/tests/utils/ |
| D | MultiConditionTrigger_test.cpp | 39 mutex lock; in TEST() local
44 MultiConditionTrigger trigger(conditionNames, [&lock, &cv, &triggerCalled] { in TEST()
46 lock_guard lg(lock); in TEST()
65 unique_lock<mutex> unique_lk(lock); in TEST()
80 mutex lock; in TEST() local
84 MultiConditionTrigger trigger({}, [&lock, &cv, &triggerCalled] { in TEST()
86 lock_guard lg(lock); in TEST()
92 unique_lock<mutex> unique_lk(lock); in TEST()
102 mutex lock; in TEST() local
106 MultiConditionTrigger trigger(conditionNames, [&lock, &cv, &triggerCalled] { in TEST()
[all …]
|
| /packages/modules/StatsD/statsd/src/guardrail/ |
| D | StatsdStats.cpp | 145 lock_guard<std::mutex> lock(mLock); in noteConfigReceived() local
183 lock_guard<std::mutex> lock(mLock); in noteConfigRemoved() local
195 lock_guard<std::mutex> lock(mLock); in noteConfigReset() local
201 lock_guard<std::mutex> lock(mLock); in noteLogLost() local
213 lock_guard<std::mutex> lock(mLock); in noteBroadcastSent() local
230 lock_guard<std::mutex> lock(mLock); in noteActiveStatusChanged() local
249 lock_guard<std::mutex> lock(mLock); in noteActivationBroadcastGuardrailHit() local
262 lock_guard<std::mutex> lock(mLock); in noteEventQueueOverflow() local
278 lock_guard<std::mutex> lock(mLock); in noteDataDropped() local
298 lock_guard<std::mutex> lock(mLock); in noteMetricsReportSent() local
[all …]
|
| /packages/services/Telephony/tests/src/com/android/ |
| D | TelephonyTestBase.java | 63 final CountDownLatch lock = new CountDownLatch(1); in waitForExecutorAction() local
65 lock.countDown(); in waitForExecutorAction()
67 while (lock.getCount() > 0) { in waitForExecutorAction()
69 return lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForExecutorAction()
78 final CountDownLatch lock = new CountDownLatch(1); in waitForHandlerAction() local
79 h.post(lock::countDown); in waitForHandlerAction()
80 while (lock.getCount() > 0) { in waitForHandlerAction()
82 lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForHandlerAction()
90 final CountDownLatch lock = new CountDownLatch(1); in waitForHandlerActionDelayed() local
91 h.postDelayed(lock::countDown, delayMs); in waitForHandlerActionDelayed()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.1/stats/ |
| D | CameraUsageStats.cpp | 85 AutoMutex lock(mMutex); in framesReceived() local
92 AutoMutex lock(mMutex); in framesReceived() local
100 AutoMutex lock(mMutex); in framesReturned() local
107 AutoMutex lock(mMutex); in framesReturned() local
115 AutoMutex lock(mMutex); in framesIgnored() local
121 AutoMutex lock(mMutex); in framesSkippedToSync() local
127 AutoMutex lock(mMutex); in eventsReceived() local
133 AutoMutex lock(mMutex); in updateNumClients() local
141 AutoMutex lock(mMutex); in getTimeCreated() local
147 AutoMutex lock(mMutex); in getFramesReceived() local
[all …]
|
| D | StatsCollector.cpp | 74 AutoMutex lock(mMutex); in handleMessage() local
95 Mutex::Autolock lock(mMutex); in handleMessage() local
108 AutoMutex lock(mMutex); in handleCollectionEvent() local
179 AutoMutex lock(mMutex); in startCollection() local
198 AutoMutex lock(mMutex); in startCollection() local
225 AutoMutex lock(mMutex); in startCollection() local
242 AutoMutex lock(mMutex); in stopCollection() local
283 AutoMutex lock(mMutex); in startCustomCollection() local
319 Mutex::Autolock lock(mMutex); in stopCustomCollection() local
387 AutoMutex lock(mMutex); in registerClientToMonitor() local
[all …]
|
| /packages/services/Car/cpp/evs/support_library/ |
| D | StreamHandler.cpp | 58 unique_lock<mutex> lock(mLock); in shutdown() local
60 mSignal.wait(lock, [this]() { return !mRunning; }); in shutdown()
70 lock_guard<mutex> lock(mLock); in startStream() local
88 lock_guard<mutex> lock(mLock); in newDisplayFrameAvailable() local
94 lock_guard<mutex> lock(mLock); in getNewDisplayFrame() local
119 lock_guard<mutex> lock(mLock); in doneWithFrame() local
144 lock_guard <mutex> lock(mLock); in deliverFrame() local
197 lock_guard<mutex> lock(mLock); in attachRenderCallback() local
209 lock_guard<mutex> lock(mLock); in detachRenderCallback() local
223 lock_guard<std::shared_mutex> lock(mAnalyzerLock); in attachAnalyzeCallback() local
[all …]
|
| /packages/modules/Connectivity/framework/src/android/net/ |
| D | DnsResolver.java | 194 final Object lock = new Object(); in rawQuery() local
204 synchronized (lock) { in rawQuery()
205 registerFDListener(executor, queryfd, callback, cancellationSignal, lock); in rawQuery()
207 addCancellationSignal(cancellationSignal, queryfd, lock); in rawQuery()
235 final Object lock = new Object(); in rawQuery() local
244 synchronized (lock) { in rawQuery()
245 registerFDListener(executor, queryfd, callback, cancellationSignal, lock); in rawQuery()
247 addCancellationSignal(cancellationSignal, queryfd, lock); in rawQuery()
343 final Object lock = new Object(); in query() local
400 synchronized (lock) { in query()
[all …]
|
| /packages/apps/Bluetooth/jni/ |
| D | com_android_bluetooth_hfp.cpp | 85 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in ConnectionStateCallback() local
100 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in AudioStateCallback() local
113 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in VoiceRecognitionCallback() local
128 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in AnswerCallCallback() local
143 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in HangupCallCallback() local
159 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in VolumeControlCallback() local
174 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in DialCallCallback() local
198 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in DtmfCmdCallback() local
215 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in NoiseReductionCallback() local
231 std::shared_lock<std::shared_timed_mutex> lock(callbacks_mutex); in WbsCallback() local
[all …]
|
| /packages/modules/StatsD/statsd/src/metrics/ |
| D | MetricProducer.h | 174 std::lock_guard<std::mutex> lock(mMutex); in onConfigUpdated()
187 std::lock_guard<std::mutex> lock(mMutex); in notifyAppUpgrade()
200 std::lock_guard<std::mutex> lock(mMutex); in onStatsdInitCompleted()
205 std::lock_guard<std::mutex> lock(mMutex); in onMatchedLogEvent()
210 std::lock_guard<std::mutex> lock(mMutex); in onConditionChanged()
215 std::lock_guard<std::mutex> lock(mMutex); in onSlicedConditionMayChange()
220 std::lock_guard<std::mutex> lock(mMutex); in isConditionSliced()
236 std::lock_guard<std::mutex> lock(mMutex); in onDumpReport()
258 std::lock_guard<std::mutex> lock(mMutex); in clearPastBuckets()
263 std::lock_guard<std::mutex> lock(mMutex); in prepareFirstBucket()
[all …]
|
| /packages/modules/adb/ |
| D | transport.cpp | 155 std::lock_guard<std::mutex> lock(reconnect_mutex_); in Stop() local
162 std::lock_guard<std::mutex> lock(reconnect_mutex_); in Stop() local
173 std::lock_guard<std::mutex> lock(reconnect_mutex_); in TrackTransport() local
191 std::unique_lock<std::mutex> lock(reconnect_mutex_); in Run() local
199 reconnect_cv_.wait_until(lock, reconnect_queue_.begin()->reconnect_time); in Run()
201 reconnect_cv_.wait(lock); in Run()
244 std::lock_guard<std::mutex> lock(reconnect_mutex_); in Run() local
290 std::lock_guard<std::mutex> lock(mutex_); in Start() local
301 std::unique_lock<std::mutex> lock(mutex_); in Start() local
303 cv_.wait(lock, [this]() REQUIRES(mutex_) { in Start()
[all …]
|
| /packages/modules/Wifi/service/java/com/android/server/wifi/ |
| D | WifiLockManager.java | 274 for (WifiLock lock : mWifiLocks) { in createMergedWorkSource()
275 mergedWS.add(lock.getWorkSource()); in createMergedWorkSource()
413 for (WifiLock lock : mWifiLocks) { in setBlameHiPerfLocks()
414 if (lock.mMode == WifiManager.WIFI_MODE_FULL_HIGH_PERF) { in setBlameHiPerfLocks()
415 setBlameHiPerfWs(lock.getWorkSource(), shouldBlame); in setBlameHiPerfLocks()
515 private synchronized boolean addLock(WifiLock lock) { in addLock() argument
517 Log.d(TAG, "addLock: " + lock); in addLock()
520 if (findLockByBinder(lock.getBinder()) != null) { in addLock()
527 mWifiLocks.add(lock); in addLock()
529 switch(lock.mMode) { in addLock()
[all …]
|
| /packages/services/Car/service/src/com/android/car/ |
| D | CarDiagnosticService.java | 91 mDiagnosticLock.lock(); in init()
140 mDiagnosticLock.lock(); in release()
160 mDiagnosticLock.lock(); in processDiagnosticData()
209 mDiagnosticLock.lock(); in registerOrUpdateDiagnosticListener()
263 mDiagnosticLock.lock(); in registerOrUpdateDiagnosticListener()
320 mDiagnosticLock.lock(); in unregisterDiagnosticListener()
426 mLiveFrameDiagnosticRecord.lock(); in getLatestLiveFrame()
434 mFreezeFrameDiagnosticRecords.lock(); in getFreezeFrameTimestamps()
443 mFreezeFrameDiagnosticRecords.lock(); in getFreezeFrame()
459 mFreezeFrameDiagnosticRecords.lock(); in clearFreezeFrames()
[all …]
|
| /packages/modules/StatsD/statsd/src/config/ |
| D | ConfigManager.cpp | 68 lock_guard<mutex> lock(thiz->mMutex); in configReceiverDied() local
102 lock_guard<mutex> lock(thiz->mMutex); in activeConfigChangedReceiverDied() local
135 lock_guard<mutex> lock(mMutex); in AddListener() local
142 lock_guard <mutex> lock(mMutex); in UpdateConfig() local
190 lock_guard<mutex> lock(mMutex); in SetConfigReceiver() local
197 lock_guard<mutex> lock(mMutex); in RemoveConfigReceiver() local
204 lock_guard<mutex> lock(mMutex); in SetActiveConfigsChangedReceiver() local
212 lock_guard<mutex> lock(mMutex); in RemoveActiveConfigsChangedReceiver() local
219 lock_guard <mutex> lock(mMutex); in RemoveConfig() local
251 lock_guard <mutex> lock(mMutex); in RemoveConfigs() local
[all …]
|
| /packages/services/Car/cpp/evs/sampleDriver/ |
| D | ConfigManager.h | 133 unique_lock<mutex> lock(mConfigLock); in getSystemInfo()
134 mConfigCond.wait(lock, [this] { return mIsReady; }); in getSystemInfo()
147 unique_lock<mutex> lock(mConfigLock); in getCameraIdList()
148 mConfigCond.wait(lock, [this] { return mIsReady; }); in getCameraIdList()
167 unique_lock<mutex> lock(mConfigLock); in getCameraGroupIdList()
168 mConfigCond.wait(lock, [this] { return mIsReady; }); in getCameraGroupIdList()
185 unique_lock<mutex> lock(mConfigLock); in getCameraGroupInfo()
186 mConfigCond.wait(lock, [this] { return mIsReady; }); in getCameraGroupInfo()
203 unique_lock<mutex> lock(mConfigLock); in getCameraInfo()
204 mConfigCond.wait(lock, [this] { return mIsReady; }); in getCameraInfo()
|
| /packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| D | TelecomTestCase.java | 58 final CountDownLatch lock = new CountDownLatch(1); in waitForHandlerAction() local
59 h.post(lock::countDown); in waitForHandlerAction()
60 while (lock.getCount() > 0) { in waitForHandlerAction()
62 lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForHandlerAction()
70 final CountDownLatch lock = new CountDownLatch(1); in waitForHandlerActionDelayed() local
71 h.postDelayed(lock::countDown, delayMs); in waitForHandlerActionDelayed()
72 while (lock.getCount() > 0) { in waitForHandlerActionDelayed()
74 lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForHandlerActionDelayed()
|
| /packages/services/Car/cpp/evs/apps/default/ |
| D | StreamHandler.cpp | 115 std::unique_lock<std::mutex> lock(mLock); in startStream() local
144 std::unique_lock<std::mutex> lock(mLock); in blockingStopStream() local
146 mSignal.wait(lock, [this]() { return !mRunning; }); in blockingStopStream()
152 std::unique_lock<std::mutex> lock(mLock); in isRunning() local
158 std::unique_lock<std::mutex> lock(mLock); in newFrameAvailable() local
164 std::unique_lock<std::mutex> lock(mLock); in getNewFrame() local
185 std::unique_lock<std::mutex> lock(mLock); in doneWithFrame() local
221 std::unique_lock <std::mutex> lock(mLock); in deliverFrame_1_1() local
253 lock.unlock(); in deliverFrame_1_1()
265 std::lock_guard<std::mutex> lock(mLock); in notify() local
|
| /packages/services/Car/service/jni/evs/ |
| D | StreamHandler.cpp | 81 std::lock_guard<std::mutex> lock(mLock); in startStream() local
105 std::lock_guard<std::mutex> lock(mLock); in asyncStopStream() local
138 std::lock_guard<std::mutex> lock(mLock); in blockingStopStream() local
144 std::unique_lock<std::mutex> lock(mLock); in blockingStopStream() local
146 if (!mCondition.wait_for(lock, 1s, [this]() { return !mRunning; })) { in blockingStopStream()
154 std::lock_guard<std::mutex> lock(mLock); in isRunning() local
160 std::lock_guard<std::mutex> lock(mLock); in doneWithFrame() local
204 std::lock_guard<std::mutex> lock(mLock); in deliverFrame_1_1() local
214 std::lock_guard<std::mutex> lock(mLock); in deliverFrame_1_1() local
235 std::lock_guard<std::mutex> lock(mLock); in notify() local
|
| /packages/modules/DnsResolver/tests/unsolicited_listener/ |
| D | unsolicited_event_listener.cpp | 39 std::lock_guard lock(mMutex); in onDnsHealthEvent() local
46 std::lock_guard lock(mMutex); in onNat64PrefixEvent() local
60 std::lock_guard lock(mMutex); in onPrivateDnsValidationEvent() local
72 std::unique_lock lock(mMutex); in waitForPrivateDnsValidation() local
78 } while (mCv.wait_until(lock, now + kEventTimeoutMs) != std::cv_status::timeout); in waitForPrivateDnsValidation()
97 std::lock_guard lock(mMutex); in waitForNat64Prefix() local
116 std::lock_guard lock(mMutex); in popDnsHealthResult() local
122 std::lock_guard lock(mMutex); in popDnsHealthResult() local
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ticketpool/ |
| D | ReservableTicketPool.java | 90 mLock.lock(); in close()
158 mLock.lock(); in updateCurrentTicketCount()
192 mLock.lock(); in tryAcquire()
217 mLock.lock(); in reserveCapacity()
247 mLock.lock(); in releaseCapacity()
277 mLock.lock(); in releaseAllCapacity()
302 mLock.lock(); in acquireParentTickets()
337 mLock.lock(); in tryAcquireAtomically()
356 mLock.lock(); in releaseWaitersOnTicketAvailability()
377 mLock.lock(); in abortWaitersOnCapacityDecrease()
|
| /packages/apps/TV/jni/ |
| D | mutex.h | 29 int lock() { in lock() function
43 Autolock(Mutex &mutex) : lock(&mutex) { in Autolock()
44 lock->lock(); in Autolock()
47 lock->unlock(); in ~Autolock()
50 Mutex *lock;
|
| /packages/services/Car/cpp/watchdog/server/src/ |
| D | WatchdogProcessService.cpp | 148 Mutex::Autolock lock(mMutex); in registerWatchdogServiceHelper() local
159 Mutex::Autolock lock(mMutex); in registerClient() local
164 Mutex::Autolock lock(mMutex); in unregisterClient() local
175 Mutex::Autolock lock(mMutex); in registerCarWatchdogService() local
185 Mutex::Autolock lock(mMutex); in unregisterCarWatchdogService() local
192 Mutex::Autolock lock(mMutex); in registerMonitor() local
210 Mutex::Autolock lock(mMutex); in unregisterMonitor() local
228 Mutex::Autolock lock(mMutex); in tellClientAlive() local
237 Mutex::Autolock lock(mMutex); in tellCarWatchdogServiceAlive() local
260 Mutex::Autolock lock(mMutex); in tellDumpFinished() local
[all …]
|
| /packages/modules/StatsD/statsd/src/ |
| D | StatsLogProcessor.cpp | 135 std::lock_guard<std::mutex> lock(mMetricsMutex); in onPeriodicAlarmFired() local
372 std::lock_guard<std::mutex> lock(mMetricsMutex); in resetConfigs() local
389 std::lock_guard<std::mutex> lock(mMetricsMutex); in OnLogEvent() local
510 std::lock_guard<std::mutex> lock(mMetricsMutex); in GetActiveConfigs() local
525 std::lock_guard<std::mutex> lock(mMetricsMutex); in OnConfigUpdated() local
565 std::lock_guard<std::mutex> lock(mMetricsMutex); in GetMetricsSize() local
575 std::lock_guard<std::mutex> lock(mMetricsMutex); in dumpStates() local
597 std::lock_guard<std::mutex> lock(mMetricsMutex); in onDumpReport() local
749 std::lock_guard<std::mutex> lock(mMetricsMutex); in OnConfigRemoved() local
845 std::lock_guard<std::mutex> lock(mMetricsMutex); in SaveActiveConfigsToDisk() local
[all …]
|
| /packages/modules/DnsResolver/tests/dns_metrics_listener/ |
| D | dns_metrics_listener.cpp | 49 std::lock_guard lock(mMutex); in onNat64PrefixEvent() local
59 std::lock_guard lock(mMutex); in onPrivateDnsValidationEvent() local
72 std::lock_guard lock(mMutex); in onDnsEvent() local
84 std::lock_guard lock(mMutex); in waitForNat64Prefix() local
100 std::unique_lock lock(mMutex); in waitForPrivateDnsValidation() local
106 } while (mCv.wait_until(lock, now + kEventTimeoutMs) != std::cv_status::timeout); in waitForPrivateDnsValidation()
126 std::lock_guard lock(mMutex); in popDnsEvent() local
132 std::lock_guard lock(mMutex); in popDnsEvent() local
|
| /packages/apps/Camera2/src/com/android/camera/device/ |
| D | SingleDeviceStateMachine.java | 118 mLock.lock(); in requestOpen()
135 mLock.lock(); in requestClose()
153 mLock.lock(); in setRequest()
184 mLock.lock(); in onDeviceOpened()
201 mLock.lock(); in onDeviceOpenException()
216 mLock.lock(); in onDeviceOpenException()
233 mLock.lock(); in onDeviceClosed()
250 mLock.lock(); in onDeviceClosingException()
362 mLock.lock(); in shutdown()
|
| /packages/services/Car/cpp/computepipe/runner/graph/ |
| D | StreamSetObserver.cpp | 40 std::lock_guard lock(mStopObservationLock); in startObservingStream() local
63 std::lock_guard lock(mStopObservationLock); in startObservingStream() local
99 std::lock_guard lock(mStopObservationLock); in startObservingStream() local
114 std::lock_guard lock(mStopObservationLock); in stopObservingStream() local
131 std::lock_guard lock(mLock); in startObservingStreams() local
157 std::unique_lock lock(mLock); in stopObservingStreams() local
175 mStoppedCv.wait(lock, [this]() -> bool { return mStopped; }); in stopObservingStreams()
180 std::lock_guard lock(mLock); in reportStreamClosed() local
|