Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 45) sorted by relevance

12

/cts/tests/tests/telephony/current/src/android/telephony/cts/
DTelephonyRegistryManagerTest.java63 LinkedBlockingQueue<Pair<Integer, String>> queue = new LinkedBlockingQueue<>(1); in testNotifyCallStateChangedForAllSubscriptions() local
67 queue.offer(Pair.create(state, number)); in testNotifyCallStateChangedForAllSubscriptions()
73 queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChangedForAllSubscriptions()
80 Pair<Integer, String> result = queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChangedForAllSubscriptions()
90 LinkedBlockingQueue<Pair<Integer, String>> queue = new LinkedBlockingQueue<>(1); in testNotifyCallStateChanged() local
94 queue.offer(Pair.create(state, number)); in testNotifyCallStateChanged()
101 queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChanged()
111 Pair<Integer, String> result = queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChanged()
121 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(1); in testNotifyServiceStateChanged() local
125 queue.offer(ss); in testNotifyServiceStateChanged()
[all …]
DCarrierConfigManagerTest.java328 BlockingQueue<Boolean> queue = new ArrayBlockingQueue<Boolean>(5); in testExtraRebroadcastOnUnlock() local
333 queue.add(new Boolean(true)); in testExtraRebroadcastOnUnlock()
352 Boolean broadcastReceived = queue.poll(BROADCAST_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testExtraRebroadcastOnUnlock()
/cts/tests/signature/tests/src/android/signature/cts/tests/
DLineSpliteratorTestBase.java80 List<Spliterator<Integer>> queue = new LinkedList<>(); in testSplit() local
81 queue.add(createSpliterator(getRepetitions(1000), CONVERTER)); in testSplit()
89 assertTrue(!queue.isEmpty()); in testSplit()
92 Spliterator<Integer> split = queue.get(0).trySplit(); in testSplit()
94 queue.add(1, split); in testSplit()
100 if (!queue.get(0).tryAdvance(createVerifier(i))) { in testSplit()
101 queue.remove(0); in testSplit()
106 while (!queue.isEmpty()) { in testSplit()
107 Spliterator<Integer> first = queue.remove(0); in testSplit()
/cts/tests/tests/telephony/current/LocationAccessingApp/src/android/telephony/cts/locationaccessingapp/
DCtsLocationAccessService.java103 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in listenForCellInfo() local
111 queue.offer(cis); in listenForCellInfo()
118 return queue.poll(LISTENER_TIMEOUT, TimeUnit.MILLISECONDS); in listenForCellInfo()
127 LinkedBlockingQueue<CellLocation> queue = new LinkedBlockingQueue<>(); in listenForCellLocation() local
135 queue.offer(cellLocation); in listenForCellLocation()
142 return queue.poll(LISTENER_TIMEOUT, TimeUnit.MILLISECONDS); in listenForCellLocation()
151 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(); in listenForServiceState() local
159 queue.offer(ss); in listenForServiceState()
166 ServiceState ss = queue.poll(LISTENER_TIMEOUT, TimeUnit.MILLISECONDS); in listenForServiceState()
179 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in requestCellInfoUpdate() local
[all …]
/cts/tests/tests/os/src/android/os/cts/
DMessageQueueTest.java221 MessageQueue queue = Looper.getMainLooper().getQueue(); in testRegisterFileDescriptorCallbackThrowsWhenFdIsNull() local
223 queue.addOnFileDescriptorEventListener(null, 0, in testRegisterFileDescriptorCallbackThrowsWhenFdIsNull()
237 MessageQueue queue = Looper.getMainLooper().getQueue(); in testRegisterFileDescriptorCallbackThrowsWhenCallbackIsNull() local
242 queue.addOnFileDescriptorEventListener(reader.getFileDescriptor(), 0, null); in testRegisterFileDescriptorCallbackThrowsWhenCallbackIsNull()
251 MessageQueue queue = Looper.getMainLooper().getQueue(); in testUnregisterFileDescriptorCallbackThrowsWhenFdIsNull() local
253 queue.removeOnFileDescriptorEventListener(null); in testUnregisterFileDescriptorCallbackThrowsWhenFdIsNull()
262 MessageQueue queue = Looper.getMainLooper().getQueue(); in testUnregisterFileDescriptorCallbackDoesNothingWhenFdNotRegistered() local
266 queue.removeOnFileDescriptorEventListener(reader.getFileDescriptor()); in testUnregisterFileDescriptorCallbackDoesNothingWhenFdNotRegistered()
277 final MessageQueue queue = thread.getLooper().getQueue(); in testFileDescriptorCallbacks() local
363 queue.addOnFileDescriptorEventListener(reader.getFD(), in testFileDescriptorCallbacks()
[all …]
/cts/tests/tests/telecom/src/android/telecom/cts/
DTelecomManagerTest.java49 LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue(1); in testGetCurrentTtyMode() local
51 queue.put(mTelecomManager.getCurrentTtyMode())); in testGetCurrentTtyMode()
53 int currentTtyMode = queue.poll(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in testGetCurrentTtyMode()
132 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testIsInEmergencyCall_noOngoingEmergencyCall() local
134 queue.put(mTelecomManager.isInEmergencyCall())); in testIsInEmergencyCall_noOngoingEmergencyCall()
136 boolean isInEmergencyCall = queue.poll(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in testIsInEmergencyCall_noOngoingEmergencyCall()
165 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testIsInEmergencyCall_ongoingEmergencyCall() local
167 queue.put(mTelecomManager.isInEmergencyCall())); in testIsInEmergencyCall_ongoingEmergencyCall()
169 boolean isInEmergencyCall = queue.poll(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in testIsInEmergencyCall_ongoingEmergencyCall()
DCallRedirectionServiceTest.java254 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in addRoleHolder() local
260 queue.put(successful); in addRoleHolder()
265 boolean result = queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in addRoleHolder()
273 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in removeRoleHolder() local
279 queue.put(successful); in removeRoleHolder()
284 boolean result = queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in removeRoleHolder()
DThirdPartyCallScreeningServiceTest.java561 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in addRoleHolder() local
567 queue.put(successful); in addRoleHolder()
572 boolean result = queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in addRoleHolder()
580 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in removeRoleHolder() local
586 queue.put(successful); in removeRoleHolder()
591 boolean result = queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in removeRoleHolder()
DIncomingCallTest.java146 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testRingOnIncomingCall() local
156 if (isPlayingRingtone && queue.isEmpty()) { in testRingOnIncomingCall()
157 queue.add(isPlayingRingtone); in testRingOnIncomingCall()
167 Boolean ringing = queue.poll(WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, TimeUnit.MILLISECONDS); in testRingOnIncomingCall()
/cts/tests/tests/media/src/android/media/cts/
DMediaSessionTestService.java59 public void onQueueChanged(List<MediaSession.QueueItem> queue) { in testSeriesOfSetQueue_setUp()
60 if (queue != null) { in testSeriesOfSetQueue_setUp()
61 if (numberOfItems.addAndGet(queue.size()) >= expectedTotalNumberOfItems) { in testSeriesOfSetQueue_setUp()
90 public void onQueueChanged(List<MediaSession.QueueItem> queue) { in testSetQueue_setUp()
91 if (queue != null && queue.size() == expectedQueueSize) { in testSetQueue_setUp()
DMediaSessionTest.java234 List<QueueItem> queue = new ArrayList<>(); in testConfigureSession() local
237 queue.add(item); in testConfigureSession()
238 mSession.setQueue(queue); in testConfigureSession()
249 assertEquals(queue.size(), mCallback.mQueue.size()); in testConfigureSession()
254 assertEquals(queue.size(), controller.getQueue().size()); in testConfigureSession()
914 List<QueueItem> queue = new ArrayList<>(); in testSeriesOfSetQueue() local
918 queue.add(new QueueItem(description, id)); in testSeriesOfSetQueue()
928 mSession.setQueue(queue); in testSeriesOfSetQueue()
937 List<QueueItem> queue = new ArrayList<>(); in testSetQueueWithLargeNumberOfItems() local
941 queue.add(new QueueItem(description, id)); in testSetQueueWithLargeNumberOfItems()
[all …]
DMediaCodecBlockModelTest.java365 request.queue(); in onInputSlot()
776 final LinkedBlockingQueue<SlotEvent> queue = new LinkedBlockingQueue<>(); in runEncodeShortVideo() local
780 queue.offer(new SlotEvent(true, index)); in runEncodeShortVideo()
786 queue.offer(new SlotEvent(false, index)); in runEncodeShortVideo()
809 event = queue.take(); in runEncodeShortVideo()
858 .queue(); in runEncodeShortVideo()
905 final LinkedBlockingQueue<SlotEvent> queue = new LinkedBlockingQueue<>(); in runComponentWithLinearInput() local
909 queue.offer(new SlotEvent(true, index)); in runComponentWithLinearInput()
915 queue.offer(new SlotEvent(false, index)); in runComponentWithLinearInput()
953 event = queue.take(); in runComponentWithLinearInput()
/cts/hostsidetests/telephony/devicetest/src/android/telephony/device/cts/
DTelephonyTest.java80 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testListenerRegistrationWithChangeEnabled() local
84 queue.offer(true); in testListenerRegistrationWithChangeEnabled()
103 Boolean result = queue.poll(TEST_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testListenerRegistrationWithChangeEnabled()
116 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testListenerRegistrationWithChangeDisabled() local
120 queue.offer(true); in testListenerRegistrationWithChangeDisabled()
129 Boolean result = queue.poll(TEST_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testListenerRegistrationWithChangeDisabled()
/cts/tests/inputmethod/src/android/view/inputmethod/cts/util/
DWindowFocusStealer.java104 final BlockingQueue<IWindowFocusStealer> queue = new ArrayBlockingQueue<>(1); in connect() local
108 queue.add(IWindowFocusStealer.Stub.asInterface(service)); in connect()
121 focusStealer = queue.poll(timeout, TimeUnit.MILLISECONDS); in connect()
/cts/hostsidetests/devicepolicy/app/CorpOwnedManagedProfile/src/com/android/cts/comp/
DBindDeviceAdminServiceGoodSetupTest.java182 final LinkedBlockingQueue<IInterface> queue = new LinkedBlockingQueue<>(); in assertCrossProfileCall() local
191 queue.add(NOT_IN_MAIN_THREAD_POISON_PILL); in assertCrossProfileCall()
194 queue.add(ICrossUserService.Stub.asInterface(service)); in assertCrossProfileCall()
204 IInterface service = queue.poll(5, TimeUnit.SECONDS); in assertCrossProfileCall()
/cts/apps/CtsVerifier/src/com/android/cts/verifier/usb/device/
DUsbDeviceTestActivity.java477 receiveZero.queue(zeroBuffer, 1); in receiveZeroSizeRequestLegacy()
549 boolean wasQueued = receive.queue(bufferReceivedSliced, size); in echoUsbRequestLegacy()
551 wasQueued = sent.queue(bufferSentSliced, size); in echoUsbRequestLegacy()
614 receiveZero.queue(zeroBuffer); in receiveZeroSizeRequest()
688 boolean wasQueued = receive.queue(bufferReceivedSliced); in echoUsbRequest()
690 wasQueued = sent.queue(bufferSentSliced); in echoUsbRequest()
781 boolean wasQueued = receive.queue(bufferReceived, totalSize); in echoLargeUsbRequestLegacy()
783 wasQueued = sent.queue(bufferSent, totalSize); in echoLargeUsbRequestLegacy()
836 reqQueued.queue(buffer);
868 boolean isQueued = sent.queue(buffer, 0);
[all …]
/cts/libs/deviceutillegacy/src/android/webkit/cts/
DWebkitUtils.java173 public static <T> T waitForNextQueueElement(BlockingQueue<T> queue) { in waitForNextQueueElement() argument
175 T value = queue.poll(TEST_TIMEOUT_MS, TimeUnit.MILLISECONDS); in waitForNextQueueElement()
/cts/tests/tests/webkit/src/android/webkit/cts/
DPostMessageTest.java181 final BlockingQueue<String> queue = new ArrayBlockingQueue<>(messageCount); in testMessageChannel() local
189 queue.add(message.getData()); in testMessageChannel()
200 WebkitUtils.waitForNextQueueElement(queue)); in testMessageChannel()
/cts/tests/autofillservice/src/android/autofillservice/cts/activities/
DGridActivity.java144 final BlockingQueue<String> queue = new LinkedBlockingQueue<>(1); in getText() local
145 onCell(row, column, (c) -> Helper.offer(queue, c.getText().toString(), timeoutMs)); in getText()
146 final String text = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in getText()
/cts/hostsidetests/devicepolicy/app/ManagedProfile/src/com/android/cts/managedprofile/
DPhoneAccountTest.java165 final LinkedBlockingQueue<Intent> queue = new LinkedBlockingQueue<>(1); in testIncomingMissedCall() local
169 queue.offer(intent); in testIncomingMissedCall()
173 Intent intent = queue.poll(10, TimeUnit.SECONDS); in testIncomingMissedCall()
/cts/hostsidetests/incident/src/com/android/server/cts/
DActivityManagerIncidentTest.java69 for (BroadcastQueueProto queue : dump.getBroadcastQueueList()) { in testDumpBroadcasts()
70 for (BroadcastRecordProto record : queue.getHistoricalBroadcastsList()) { in testDumpBroadcasts()
76 for (BroadcastSummary summary : queue.getHistoricalBroadcastsSummaryList()) { in testDumpBroadcasts()
/cts/tests/tests/telephony/current/src/android/telephony/ims/cts/
DImsServiceConnector.java319 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in setDefaultSmsApp() local
326 Runnable::run, queue::offer)); in setDefaultSmsApp()
332 Runnable::run, queue::offer)); in setDefaultSmsApp()
334 result = queue.poll(ImsUtils.TEST_TIMEOUT_MS, TimeUnit.MILLISECONDS); in setDefaultSmsApp()
/cts/tests/tests/graphics/jni/
DVulkanPreTransformTestHelpers.h42 VkQueue queue() const { return mQueue; } in queue() function
/cts/tests/tests/media/libaudiojni/
DAndroid.bp23 "appendix-b-1-1-buffer-queue.cpp",
/cts/tests/translation/src/android/translation/cts/
DCtsTranslationService.java309 private static <T> boolean offer(BlockingQueue<T> queue, T obj, long timeoutMs) { in offer() argument
312 offered = queue.offer(obj, timeoutMs, TimeUnit.MILLISECONDS); in offer()

12