Searched refs:blockingQueue (Results 1 – 4 of 4) sorted by relevance
| /aosp12/system/chre/util/tests/ |
| H A D | blocking_queue_test.cc | 27 FixedSizeBlockingQueue<int, 16> blockingQueue; in TEST() local
28 ASSERT_TRUE(blockingQueue.empty()); in TEST()
32 FixedSizeBlockingQueue<int, 16> blockingQueue; in TEST() local
34 ASSERT_TRUE(blockingQueue.push(0x1337)); in TEST()
35 ASSERT_TRUE(blockingQueue.push(0xcafe)); in TEST()
37 ASSERT_EQ(blockingQueue.pop(), 0x1337); in TEST()
38 ASSERT_EQ(blockingQueue.pop(), 0xcafe); in TEST()
46 FixedSizeBlockingQueue<UniquePtr<int>, 16> blockingQueue; in TEST() local
48 ASSERT_TRUE(blockingQueue.push(std::move(ptr))); in TEST()
50 ASSERT_EQ(*(blockingQueue.pop()), kVal); in TEST()
|
| /aosp12/packages/modules/Connectivity/tests/cts/hostside/app/src/com/android/cts/net/hostside/ |
| H A D | NetworkPolicyTestUtils.java | 227 BlockingQueue<Integer> blockingQueue = new LinkedBlockingQueue<>(); in setWifiMeteredStatus() local
229 blockingQueue, Integer.MAX_VALUE)); in setWifiMeteredStatus()
230 Integer resultCode = blockingQueue.poll(TIMEOUT_CHANGE_METEREDNESS_MS, in setWifiMeteredStatus()
242 blockingQueue = new LinkedBlockingQueue<>(); in setWifiMeteredStatus()
244 blockingQueue, Integer.MAX_VALUE)); in setWifiMeteredStatus()
245 resultCode = blockingQueue.poll(TIMEOUT_CHANGE_METEREDNESS_MS, in setWifiMeteredStatus()
273 private static ActionListener createActionListener(BlockingQueue<Integer> blockingQueue, in createActionListener() argument
278 blockingQueue.offer(successCode); in createActionListener()
283 blockingQueue.offer(reason); in createActionListener()
|
| /aosp12/frameworks/base/core/tests/coretests/src/android/os/ |
| H A D | BinderWorkSourceNestedService.java | 52 BlockingQueue<IBinderWorkSourceService> blockingQueue =
56 blockingQueue.add(IBinderWorkSourceService.Stub.asInterface(service));
70 service = blockingQueue.poll(30, TimeUnit.SECONDS);
|
| /aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/adb/ |
| H A D | AdbDebuggingManagerTestActivity.java | 137 public Configurator setBlockingQueue(BlockingQueue blockingQueue) { in setBlockingQueue() argument
138 sBlockingQueue = blockingQueue; in setBlockingQueue()
|