/cts/common/device-side/util-axt/src/com/android/compatibility/common/util/ |
D | BlockingBroadcastReceiver.java | 68 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/ |
D | BlockingBroadcastReceiver.java | 73 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/ |
D | BaseBroadcastTest.java | 310 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/ |
D | TunerTest.java | 352 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/ |
D | TunerTest.java | 351 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/ |
D | BroadcastResponseStatsTest.java | 2277 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/ |
D | GlobalSearchSessionServiceCtsTestBase.java | 2012 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/ |
D | BlobStoreManagerTest.java | 1902 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/ |
D | ActivityManagerTest.java | 2597 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/ |
D | UsageStatsTest.java | 2810 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()
|