| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | lib.rs | 243 bluetooth.lock().unwrap().disable(); in dispatch()
247 bluetooth.lock().unwrap().cleanup(); in dispatch()
255 bluetooth_dis.lock().unwrap().initialize(); in dispatch()
259 bluetooth_media.lock().unwrap().dispatch_a2dp_callbacks(a); in dispatch()
263 bluetooth_media.lock().unwrap().dispatch_avrcp_callbacks(av); in dispatch()
267 dispatch_base_callbacks(bluetooth.lock().unwrap().as_mut(), b.clone()); in dispatch()
268 dispatch_base_callbacks(suspend.lock().unwrap().as_mut(), b); in dispatch()
278 let mut bt = bluetooth.lock().unwrap(); in dispatch()
299 dispatch_gatt_client_callbacks(bluetooth_gatt.lock().unwrap().as_mut(), m); in dispatch()
303 dispatch_gatt_server_callbacks(bluetooth_gatt.lock().unwrap().as_mut(), m); in dispatch()
[all …]
|
| D | suspend.rs | 182 let hci_index = self.bt.lock().unwrap().get_hci_index(); in suspend_ready()
203 let bonded_connected = self.bt.lock().unwrap().get_bonded_and_connected_devices(); in get_connected_audio_devices()
204 self.media.lock().unwrap().filter_to_connected_audio_devices_from(&bonded_connected) in get_connected_audio_devices()
226 self.suspend_state.lock().unwrap().suspend_expected = true; in suspend()
228 self.intf.lock().unwrap().set_default_event_mask_except(MASKED_EVENTS_FOR_SUSPEND, 0u64); in suspend()
230 self.bt.lock().unwrap().scan_mode_enter_suspend(); in suspend()
231 self.intf.lock().unwrap().clear_event_filter(); in suspend()
232 self.intf.lock().unwrap().clear_filter_accept_list(); in suspend()
234 self.bt.lock().unwrap().discovery_enter_suspend(); in suspend()
235 self.gatt.lock().unwrap().advertising_enter_suspend(); in suspend()
[all …]
|
| /packages/providers/MediaProvider/tests/src/com/android/providers/media/photopicker/sync/ |
| D | PickerSyncLockManagerTest.java | 46 try (CloseableReentrantLock lock = mSyncLockManager.lock(CLOUD_SYNC_LOCK)) { in testLockIsCloseable() argument
48 assertThat(lock.isHeldByCurrentThread()).isTrue(); in testLockIsCloseable()
49 assertThat(lock.getHoldCount()).isEqualTo(1); in testLockIsCloseable()
51 try (CloseableReentrantLock lockInLock = mSyncLockManager.lock(CLOUD_SYNC_LOCK)) { in testLockIsCloseable()
54 assertThat(lock.isHeldByCurrentThread()).isTrue(); in testLockIsCloseable()
55 assertThat(lock).isEqualTo(lockInLock); in testLockIsCloseable()
56 assertThat(lock.getHoldCount()).isEqualTo(2); in testLockIsCloseable()
60 assertThat(lock.isHeldByCurrentThread()).isTrue(); in testLockIsCloseable()
61 assertThat(lock.getHoldCount()).isEqualTo(1); in testLockIsCloseable()
62 assertThat(lock).isEqualTo(mSyncLockManager.getLock(CLOUD_SYNC_LOCK)); in testLockIsCloseable()
[all …]
|
| /packages/modules/StatsD/statsd/tests/utils/ |
| D | MultiConditionTrigger_test.cpp | 41 mutex lock; in TEST() local
46 MultiConditionTrigger trigger(conditionNames, [&lock, &cv, &triggerCalled] { in TEST()
48 lock_guard lg(lock); in TEST()
67 unique_lock<mutex> unique_lk(lock); in TEST()
82 mutex lock; in TEST() local
86 MultiConditionTrigger trigger({}, [&lock, &cv, &triggerCalled] { in TEST()
88 lock_guard lg(lock); in TEST()
94 unique_lock<mutex> unique_lk(lock); in TEST()
104 mutex lock; in TEST() local
108 MultiConditionTrigger trigger(conditionNames, [&lock, &cv, &triggerCalled] { in TEST()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/service/src/ |
| D | interface_manager.rs | 73 cr.lock().unwrap().set_async_support(Some(( in dispatch()
82 cr.lock().unwrap().set_object_manager_support(Some(conn.clone())); in dispatch()
83 let object_manager = cr.lock().unwrap().object_manager(); in dispatch()
84 cr.lock().unwrap().insert("/", &[object_manager], {}); in dispatch()
93 cr_clone.lock().unwrap().handle_message(msg, conn).unwrap(); in dispatch()
101 &mut cr.lock().unwrap(), in dispatch()
106 &mut cr.lock().unwrap(), in dispatch()
111 &mut cr.lock().unwrap(), in dispatch()
116 &mut cr.lock().unwrap(), in dispatch()
121 &mut cr.lock().unwrap(), in dispatch()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/ |
| D | gatt_service.rs | 52 gatt: Arc::new(Mutex::new(Gatt::new(&btif_clone.lock().unwrap()).unwrap())), in create()
56 me.gatt.lock().unwrap().initialize( in create()
173 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in register_advertiser()
181 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in unregister_advertiser()
189 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in get_own_address()
197 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in set_parameters()
205 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in set_data()
213 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in advertising_enable()
221 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in advertising_disable()
229 let advertiser = &mut self.gatt.lock().unwrap().advertiser; in start_advertising()
[all …]
|
| /packages/modules/Bluetooth/system/gd/storage/ |
| D | storage_module.cc | 84 std::lock_guard<std::recursive_mutex> lock(mutex_); in ~StorageModule() local
103 std::lock_guard<std::recursive_mutex> lock(mutex_); in Modify() local
108 std::lock_guard<std::recursive_mutex> lock(mutex_); in SaveDelayed() local
118 std::lock_guard<std::recursive_mutex> lock(mutex_); in SaveImmediately() local
141 std::lock_guard<std::recursive_mutex> lock(mutex_); in Clear() local
150 std::lock_guard<std::recursive_mutex> lock(mutex_); in Start() local
193 std::lock_guard<std::recursive_mutex> lock(mutex_); in Stop() local
209 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetDeviceByLegacyKey() local
218 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetDeviceByClassicMacAddress() local
227 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetDeviceByLeIdentityAddress() local
[all …]
|
| /packages/modules/Bluetooth/system/gd/os/android/ |
| D | parameter_provider.cc | 41 std::lock_guard<std::mutex> lock(parameter_mutex); in ConfigFilePath() local
50 std::lock_guard<std::mutex> lock(parameter_mutex); in OverrideConfigFilePath() local
56 std::lock_guard<std::mutex> lock(parameter_mutex); in SnoopLogFilePath() local
65 std::lock_guard<std::mutex> lock(parameter_mutex); in OverrideSnoopLogFilePath() local
72 std::lock_guard<std::mutex> lock(parameter_mutex); in SnoozLogFilePath() local
81 std::lock_guard<std::mutex> lock(parameter_mutex); in OverrideSnoozLogFilePath() local
91 std::lock_guard<std::mutex> lock(parameter_mutex); in GetBtKeystoreInterface() local
96 std::lock_guard<std::mutex> lock(parameter_mutex); in SetBtKeystoreInterface() local
101 std::lock_guard<std::mutex> lock(parameter_mutex); in IsCommonCriteriaMode() local
106 std::lock_guard<std::mutex> lock(parameter_mutex); in SetCommonCriteriaMode() local
[all …]
|
| /packages/modules/HealthFitness/apk/src/com/android/healthconnect/controller/utils/ |
| D | FeatureUtils.kt | 51 private val lock = Any() in isSessionTypesEnabled() constant
76 synchronized(lock) { in isSessionTypesEnabled()
82 synchronized(lock) { in isSessionTypesEnabled()
88 synchronized(lock) { in isSessionTypesEnabled()
94 synchronized(lock) { in isSessionTypesEnabled()
100 synchronized(lock) { in isSessionTypesEnabled()
106 synchronized(lock) { in isSessionTypesEnabled()
112 synchronized(lock) { in isSessionTypesEnabled()
118 synchronized(lock) { in isSessionTypesEnabled()
124 synchronized(lock) { in isSessionTypesEnabled()
[all …]
|
| /packages/modules/Connectivity/staticlibs/testutils/hostdevice/com/android/net/module/util/ |
| D | TrackRecord.kt | 56 private val lock = ReentrantLock() constant in com.android.net.module.util.ArrayTrackRecord
57 private val condition = lock.newCondition()
79 override val size get() = lock.withLock { elements.size } in hasNext()
80 override fun contains(element: E) = lock.withLock { elements.contains(element) } in <lambda>()
81 override fun containsAll(elements: Collection<E>) = lock.withLock { in <lambda>()
84 override operator fun get(index: Int) = lock.withLock { elements[index] } in <lambda>()
85 override fun indexOf(element: E): Int = lock.withLock { elements.indexOf(element) } in <lambda>()
86 override fun lastIndexOf(element: E): Int = lock.withLock { elements.lastIndexOf(element) } in <lambda>()
87 override fun isEmpty() = lock.withLock { elements.isEmpty() } in <lambda>()
91 override fun subList(fromIndex: Int, toIndex: Int): List<E> = lock.withLock { in listIterator()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/client/src/ |
| D | callbacks.rs | 83 self.context.lock().unwrap().adapters.entry(hci_interface).or_insert(false); in on_hci_device_changed()
85 self.context.lock().unwrap().adapters.remove(&hci_interface); in on_hci_device_changed()
90 self.context.lock().unwrap().set_adapter_enabled(hci_interface, enabled); in on_hci_enabled_changed()
107 &mut cr.lock().unwrap(), in export_for_rpc()
110 cr.lock().unwrap().insert(self.get_object_id(), &[iface], Arc::new(Mutex::new(self))); in export_for_rpc()
152 self.context.lock().unwrap().adapter_address = Some(addr); in on_address_changed()
165 .lock() in on_device_found()
179 match self.context.lock().unwrap().found_devices.remove(&remote_device.address.to_string()) in on_device_cleared()
189 self.context.lock().unwrap().bonded_devices.remove(&remote_device.address.to_string()); in on_device_cleared()
193 self.context.lock().unwrap().discovering_state = discovering; in on_discovering_changed()
[all …]
|
| D | main.rs | 384 cr.lock().unwrap().set_async_support(Some(( in main()
394 cr_clone.lock().unwrap().handle_message(msg, conn).unwrap(); in main()
419 if !context.lock().unwrap().manager_dbus.is_valid() { in main()
427 context.lock().unwrap().manager_dbus.register_callback(Box::new(BtManagerCallback::new( in main()
436 let default_adapter = context.lock().unwrap().default_adapter; in main()
439 let mut context_locked = context.lock().unwrap(); in main()
533 if context.lock().unwrap().adapter_ready { in handle_client_command()
535 .lock() in handle_client_command()
580 let dbus_connection = context.lock().unwrap().dbus_connection.clone(); in handle_client_command()
581 let dbus_crossroads = context.lock().unwrap().dbus_crossroads.clone(); in handle_client_command()
[all …]
|
| /packages/apps/Launcher3/tests/multivalentTests/src/com/android/launcher3/util/ |
| D | CancellableTaskTest.kt | 39 private val lock = ReentrantLock() constant
81 lock.lock() in run_and_cancel_cancelTaskAndCallback()
82 Executors.UI_HELPER_EXECUTOR.submit { lock.lock() } in run_and_cancel_cancelTaskAndCallback()
87 lock.unlock() // unblock task on UI_HELPER_EXECUTOR in run_and_cancel_cancelTaskAndCallback()
98 lock.lock() in run_and_cancel_cancelCallback()
99 Executors.VIEW_PREINFLATION_EXECUTOR.submit { lock.lock() } in run_and_cancel_cancelCallback()
106 lock.unlock() // unblock callback on VIEW_PREINFLATION_EXECUTOR in run_and_cancel_cancelCallback()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/appsearch/ |
| D | AppSearchConsentWorker.java | 159 READ_WRITE_LOCK.readLock().lock(); in getConsent()
176 READ_WRITE_LOCK.writeLock().lock(); in setConsent()
200 READ_WRITE_LOCK.readLock().lock(); in getAppsWithConsent()
218 READ_WRITE_LOCK.writeLock().lock(); in clearAppsWithConsent()
235 READ_WRITE_LOCK.writeLock().lock(); in addAppWithConsent()
285 READ_WRITE_LOCK.readLock().lock(); in removeAppWithConsent()
314 READ_WRITE_LOCK.readLock().lock(); in wasNotificationDisplayed()
325 READ_WRITE_LOCK.readLock().lock(); in wasGaUxNotificationDisplayed()
339 READ_WRITE_LOCK.writeLock().lock(); in recordNotificationDisplayed()
357 READ_WRITE_LOCK.writeLock().lock(); in recordGaUxNotificationDisplayed()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.1/stats/ |
| D | CameraUsageStats.cpp | 80 AutoMutex lock(mMutex); in framesReceived() local
85 AutoMutex lock(mMutex); in framesReceived() local
92 AutoMutex lock(mMutex); in framesReturned() local
97 AutoMutex lock(mMutex); in framesReturned() local
104 AutoMutex lock(mMutex); in framesIgnored() local
109 AutoMutex lock(mMutex); in framesSkippedToSync() local
114 AutoMutex lock(mMutex); in eventsReceived() local
119 AutoMutex lock(mMutex); in updateNumClients() local
126 AutoMutex lock(mMutex); in getTimeCreated() local
131 AutoMutex lock(mMutex); in getFramesReceived() local
[all …]
|
| /packages/services/Car/cpp/evs/manager/aidl/stats/src/ |
| D | CameraUsageStats.cpp | 75 AutoMutex lock(mMutex); in framesReceived() local
80 AutoMutex lock(mMutex); in framesReceived() local
87 AutoMutex lock(mMutex); in framesReturned() local
92 AutoMutex lock(mMutex); in framesReturned() local
99 AutoMutex lock(mMutex); in framesIgnored() local
104 AutoMutex lock(mMutex); in framesSkippedToSync() local
109 AutoMutex lock(mMutex); in eventsReceived() local
114 AutoMutex lock(mMutex); in updateNumClients() local
121 AutoMutex lock(mMutex); in getTimeCreated() local
126 AutoMutex lock(mMutex); in getFramesReceived() local
[all …]
|
| /packages/modules/HealthFitness/service/java/com/android/server/healthconnect/ |
| D | HealthConnectDeviceConfigManager.java | 304 mLock.readLock().lock(); in isExerciseRouteFeatureEnabled()
314 mLock.readLock().lock(); in isExerciseRoutesReadAllFeatureEnabled()
331 mLock.readLock().lock(); in isSessionDatatypeFeatureEnabled()
344 mLock.readLock().lock(); in getMigrationStateInProgressCount()
357 mLock.readLock().lock(); in getMigrationStateAllowedCount()
367 mLock.readLock().lock(); in getMaxStartMigrationCalls()
380 mLock.readLock().lock(); in getIdleStateTimeoutPeriod()
390 mLock.readLock().lock(); in getNonIdleStateTimeoutPeriod()
403 mLock.readLock().lock(); in getInProgressStateTimeoutPeriod()
413 mLock.readLock().lock(); in getExecutionTimeBuffer()
[all …]
|
| /packages/services/Telephony/tests/src/com/android/ |
| D | TelephonyTestBase.java | 77 final CountDownLatch lock = new CountDownLatch(1); in waitForExecutorAction() local
79 lock.countDown(); in waitForExecutorAction()
81 while (lock.getCount() > 0) { in waitForExecutorAction()
83 return lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForExecutorAction()
92 final CountDownLatch lock = new CountDownLatch(1); in waitForHandlerAction() local
93 h.post(lock::countDown); in waitForHandlerAction()
94 while (lock.getCount() > 0) { in waitForHandlerAction()
96 lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForHandlerAction()
104 final CountDownLatch lock = new CountDownLatch(1); in waitForHandlerActionDelayed() local
105 h.postDelayed(lock::countDown, delayMs); in waitForHandlerActionDelayed()
[all …]
|
| /packages/services/Car/cpp/evs/support_library/ |
| D | StreamHandler.cpp | 54 unique_lock<mutex> lock(mLock); in shutdown() local
56 mSignal.wait(lock, [this]() { return !mRunning; }); in shutdown()
65 lock_guard<mutex> lock(mLock); in startStream() local
82 lock_guard<mutex> lock(mLock); in newDisplayFrameAvailable() local
87 lock_guard<mutex> lock(mLock); in getNewDisplayFrame() local
111 lock_guard<mutex> lock(mLock); in doneWithFrame() local
134 lock_guard<mutex> lock(mLock); in deliverFrame() local
186 lock_guard<mutex> lock(mLock); in attachRenderCallback() local
198 lock_guard<mutex> lock(mLock); in detachRenderCallback() local
212 lock_guard<std::shared_mutex> lock(mAnalyzerLock); in attachAnalyzeCallback() local
[all …]
|
| /packages/modules/StatsD/statsd/src/config/ |
| D | ConfigManager.cpp | 64 lock_guard<mutex> lock(mMutex); in AddListener() local
71 lock_guard <mutex> lock(mMutex); in UpdateConfig() local
117 lock_guard<mutex> lock(mMutex); in SetConfigReceiver() local
122 lock_guard<mutex> lock(mMutex); in RemoveConfigReceiver() local
128 lock_guard<mutex> lock(mMutex); in RemoveConfigReceiver() local
137 lock_guard<mutex> lock(mMutex); in SetActiveConfigsChangedReceiver() local
142 lock_guard<mutex> lock(mMutex); in RemoveActiveConfigsChangedReceiver() local
148 lock_guard<mutex> lock(mMutex); in RemoveActiveConfigsChangedReceiver() local
159 lock_guard<mutex> lock(mMutex); in SetRestrictedMetricsChangedReceiver() local
167 lock_guard<mutex> lock(mMutex); in RemoveRestrictedMetricsChangedReceiver() local
[all …]
|
| /packages/services/Car/cpp/evs/manager/aidl/src/ |
| D | HalCamera.cpp | 95 auto current = client.lock(); in disownVirtualCamera()
117 std::shared_ptr<VirtualCamera> virtCam = client.lock(); in changeFramesInFlight()
142 std::lock_guard lock(mFrameMutex); in changeFramesInFlight() local
167 std::shared_ptr<VirtualCamera> virtCam = client.lock(); in changeFramesInFlight()
186 std::lock_guard lock(mFrameMutex); in changeFramesInFlight() local
210 std::lock_guard<std::mutex> lock(mFrameMutex); in requestNewFrame() local
216 std::lock_guard lock(mFrameMutex); in clientStreamStarting() local
240 std::lock_guard<std::mutex> lock(mFrameMutex); in clientStreamEnding() local
248 return r.client.lock().get() == client; in clientStreamEnding()
256 std::shared_ptr<VirtualCamera> virtCam = client.lock(); in clientStreamEnding()
[all …]
|
| D | VirtualCamera.cpp | 65 std::lock_guard lock(mMutex); in doneWithFrame() local
120 auto pHwCamera = mHalCamera.begin()->second.lock(); in forcePrimaryClient()
140 auto pHwCamera = mHalCamera.begin()->second.lock(); in getCameraInfo()
159 auto pHwCamera = mHalCamera.begin()->second.lock(); in getExtendedInfo()
177 auto pHwCamera = mHalCamera.begin()->second.lock(); in getIntParameter()
196 auto pHwCamera = mHalCamera.begin()->second.lock(); in getIntParameterRange()
215 auto pHwCamera = mHalCamera.begin()->second.lock(); in getParameterList()
233 auto pHwCamera = device->second.lock(); in getPhysicalCameraInfo()
252 auto pHwCamera = mHalCamera.begin()->second.lock(); in importExternalBuffers()
275 auto pHwCamera = mHalCamera.begin()->second.lock(); in pauseVideoStream()
[all …]
|
| /packages/modules/Connectivity/framework/src/android/net/ |
| D | DnsResolver.java | 203 final Object lock = new Object(); in rawQuery() local
213 synchronized (lock) { in rawQuery()
214 registerFDListener(executor, queryfd, callback, cancellationSignal, lock); in rawQuery()
216 addCancellationSignal(cancellationSignal, queryfd, lock); in rawQuery()
244 final Object lock = new Object(); in rawQuery() local
253 synchronized (lock) { in rawQuery()
254 registerFDListener(executor, queryfd, callback, cancellationSignal, lock); in rawQuery()
256 addCancellationSignal(cancellationSignal, queryfd, lock); in rawQuery()
352 final Object lock = new Object(); in query() local
409 synchronized (lock) { in query()
[all …]
|
| /packages/apps/ManagedProvisioning/studio-dev/StubGenerator/src/main/java/com/android/development/ |
| D | ProgressBar.java | 9 private final Object lock = new Object(); field in ProgressBar
22 synchronized (lock) { in update()
27 lock.notify(); in update()
34 synchronized (lock) { in finish()
35 lock.notify(); in finish()
44 synchronized (lock) { in loop()
48 lock.wait(); in loop()
|
| /packages/modules/DnsResolver/tests/unsolicited_listener/ |
| D | unsolicited_event_listener.cpp | 38 std::lock_guard lock(mMutex); in onDnsHealthEvent() local
46 std::lock_guard lock(mMutex); in onNat64PrefixEvent() local
61 std::lock_guard lock(mMutex); in onPrivateDnsValidationEvent() local
72 std::unique_lock lock(mMutex); in waitForPrivateDnsValidation() local
73 return mCv.wait_for(lock, kEventTimeoutMs, [&]() REQUIRES(mMutex) { in waitForPrivateDnsValidation()
90 std::unique_lock lock(mMutex); in waitForNat64Prefix() local
93 if (mCv.wait_for(lock, timeout, [&]() REQUIRES(mMutex) { in waitForNat64Prefix()
108 std::unique_lock lock(mMutex); in popDnsHealthResult() local
111 if (!mCv.wait_for(lock, kEventTimeoutMs, in popDnsHealthResult()
|