Searched refs:mBlockingQueue (Results 1 – 4 of 4) sorted by relevance
67 private final BlockingQueue<Intent> mBlockingQueue; field in BlockingBroadcastReceiver126 mBlockingQueue = new ArrayBlockingQueue<>(1); in BlockingBroadcastReceiver()132 if (mBlockingQueue.remainingCapacity() == 0) { in onReceive()138 mBlockingQueue.add(intent); in onReceive()200 mReceivedIntent = mBlockingQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); in awaitForBroadcast()
584 private final BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in GlobalSearchSessionPlatformCtsTest.TestServiceConnection593 mBlockingQueue.offer(service); in onServiceConnected()601 IBinder service = mBlockingQueue.poll(TIMEOUT_BIND_SERVICE_SEC, TimeUnit.SECONDS); in getService()
1802 private BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in UsageStatsTest.TestServiceConnection1805 mBlockingQueue.offer(service); in onServiceConnected()1812 final IBinder service = mBlockingQueue.poll(TIMEOUT_BINDER_SERVICE_SEC, in getService()
1890 private final BlockingQueue<IBinder> mBlockingQueue = new LinkedBlockingQueue<>(); field in BlobStoreManagerTest.TestServiceConnection1899 mBlockingQueue.offer(service); in onServiceConnected()1907 final IBinder service = mBlockingQueue.poll(TIMEOUT_BIND_SERVICE_SEC, in getService()