Home
last modified time | relevance | path

Searched refs:mBlockingQueue (Results 1 – 10 of 10) sorted by relevance

/cts/common/device-side/util-axt/src/com/android/compatibility/common/util/
DBlockingBroadcastReceiver.java68 private final BlockingQueue<Intent> mBlockingQueue; field in BlockingBroadcastReceiver
135 mBlockingQueue = new ArrayBlockingQueue<>(1); in BlockingBroadcastReceiver()
143 if (mBlockingQueue.remainingCapacity() == 0) { in onReceive()
149 mBlockingQueue.add(intent); in onReceive()
215 mReceivedIntent = mBlockingQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); in awaitForBroadcast()
/cts/common/device-side/bedstead/nene/src/main/java/com/android/bedstead/nene/utils/
DBlockingBroadcastReceiver.java73 private final BlockingQueue<Intent> mBlockingQueue; field in BlockingBroadcastReceiver
140 mBlockingQueue = new ArrayBlockingQueue<>(1); in BlockingBroadcastReceiver()
148 if (mBlockingQueue.remainingCapacity() == 0) { in onReceive()
154 mBlockingQueue.add(intent); in onReceive()
221 mReceivedIntent = mBlockingQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); in awaitForBroadcast()
/cts/tests/app/BroadcastsTest/src/android/app/cts/broadcasts/
DBaseBroadcastTest.java310 private final BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in BaseBroadcastTest.TestServiceConnection
319 mBlockingQueue.offer(service); in onServiceConnected()
327 final IBinder service = mBlockingQueue.poll(TIMEOUT_BIND_SERVICE_SEC, in getService()
/cts/tests/tests/tv/src/android/media/tv/tuner/cts/
DTunerTest.java352 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in TunerTest.TestServiceConnection
355 mBlockingQueue.offer(service); in onServiceConnected()
362 mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, TimeUnit.SECONDS); in getService()
368 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in TunerTest.TunerResourceTestServiceConnection
372 mBlockingQueue.offer(service); in onServiceConnected()
380 mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, TimeUnit.SECONDS); in getService()
/cts/tests/tests/tv/tuner/src/android/media/tv/tuner/cts/
DTunerTest.java351 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in TunerTest.TestServiceConnection
354 mBlockingQueue.offer(service); in onServiceConnected()
361 mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, TimeUnit.SECONDS); in getService()
367 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in TunerTest.TunerResourceTestServiceConnection
371 mBlockingQueue.offer(service); in onServiceConnected()
379 mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, TimeUnit.SECONDS); in getService()
/cts/tests/tests/app.usage/BroadcastResponseStats/src/android/app/usage/brs/cts/
DBroadcastResponseStatsTest.java2277 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in BroadcastResponseStatsTest.TestServiceConnection
2285 mBlockingQueue.offer(service); in onServiceConnected()
2292 final IBinder service = mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, in getService()
/cts/tests/appsearch/src/com/android/cts/appsearch/app/
DGlobalSearchSessionServiceCtsTestBase.java2012 private final BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in GlobalSearchSessionServiceCtsTestBase.TestServiceConnection
2022 mBlockingQueue.offer(service); in onServiceConnected()
2031 return mBlockingQueue.poll(TIMEOUT_BIND_SERVICE_SEC, TimeUnit.SECONDS); in getService()
/cts/tests/BlobStore/src/com/android/cts/blob/
DBlobStoreManagerTest.java1902 private final BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in BlobStoreManagerTest.TestServiceConnection
1911 mBlockingQueue.offer(service); in onServiceConnected()
1919 final IBinder service = mBlockingQueue.poll(TIMEOUT_BIND_SERVICE_SEC, in getService()
/cts/tests/app/src/android/app/cts/
DActivityManagerTest.java2597 private final BlockingQueue<Integer> mBlockingQueue = new LinkedBlockingQueue<>();
2603 mBlockingQueue.offer(result);
2612 final Integer result = mBlockingQueue.poll(WAITFOR_MSEC * 2, TimeUnit.MILLISECONDS);
/cts/tests/tests/app.usage/src/android/app/usage/cts/
DUsageStatsTest.java2810 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in UsageStatsTest.TestServiceConnection
2818 mBlockingQueue.offer(service); in onServiceConnected()
2825 final IBinder service = mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, in getService()