Home
last modified time | relevance | path

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

/aosp12/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/common/
H A DBlockingBroadcastReceiver.java48 private final BlockingQueue<Intent> mBlockingQueue; field in BlockingBroadcastReceiver
55 mBlockingQueue = new ArrayBlockingQueue<>(1); in BlockingBroadcastReceiver()
61 mBlockingQueue.add(intent); in onReceive()
75 return mBlockingQueue.poll(DEFAULT_TIMEOUT_SECONDS, TimeUnit.SECONDS); in awaitForBroadcast()
88 return mBlockingQueue.poll(timeoutMillis, TimeUnit.MILLISECONDS); in awaitForBroadcast()
/aosp12/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/provisioning/
H A DProvisioningControllerBaseTest.java96 private BlockingQueue<AbstractProvisioningTask> mBlockingQueue field in ProvisioningControllerBaseTest.FakeTaskHandler
100 return mBlockingQueue.poll(10, TimeUnit.SECONDS); in getLastTask()
105 assertTrue(mBlockingQueue.add((AbstractProvisioningTask) msg.obj)); in handleMessage()
/aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/adb/
H A DAdbDebuggingManagerTest.java87 private BlockingQueue<TestResult> mBlockingQueue; field in AdbDebuggingManagerTest
108 mBlockingQueue = new ArrayBlockingQueue<>(1); in setUp()
944 .setBlockingQueue(mBlockingQueue); in runAdbTest()
952 TestResult activityResult = mBlockingQueue.poll(TIMEOUT, TIMEOUT_TIME_UNIT); in runAdbTest()
962 TestResult threadResult = mBlockingQueue.poll(TIMEOUT, TIMEOUT_TIME_UNIT); in runAdbTest()
1059 mBlockingQueue.put(result); in sendResponse()