Home
last modified time | relevance | path

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

12

/cts/tests/tests/telephony/current/src/android/telephony/cts/
DTelephonyRegistryManagerTest.java58 LinkedBlockingQueue<Pair<Integer, String>> queue = new LinkedBlockingQueue<>(1); in testNotifyCallStateChangedForAllSubscriptions() local
62 queue.offer(Pair.create(state, number)); in testNotifyCallStateChangedForAllSubscriptions()
68 queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChangedForAllSubscriptions()
75 Pair<Integer, String> result = queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChangedForAllSubscriptions()
86 LinkedBlockingQueue<Pair<Integer, String>> queue = new LinkedBlockingQueue<>(1); in testNotifyCallStateChanged() local
90 queue.offer(Pair.create(state, number)); in testNotifyCallStateChanged()
97 queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChanged()
106 Pair<Integer, String> result = queue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testNotifyCallStateChanged()
117 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(1); in testNotifyServiceStateChanged() local
121 queue.offer(ss); in testNotifyServiceStateChanged()
[all …]
/cts/tests/tests/telecom/src/android/telecom/cts/
DTelecomManagerTest.java38 LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue(1); in testGetCurrentTtyMode() local
40 queue.put(mTelecomManager.getCurrentTtyMode())); in testGetCurrentTtyMode()
42 int currentTtyMode = queue.poll(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in testGetCurrentTtyMode()
59 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testIsInEmergencyCall_noOngoingEmergencyCall() local
61 queue.put(mTelecomManager.isInEmergencyCall())); in testIsInEmergencyCall_noOngoingEmergencyCall()
63 boolean isInEmergencyCall = queue.poll(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in testIsInEmergencyCall_noOngoingEmergencyCall()
92 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testIsInEmergencyCall_ongoingEmergencyCall() local
94 queue.put(mTelecomManager.isInEmergencyCall())); in testIsInEmergencyCall_ongoingEmergencyCall()
96 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()
DCarModeInCallServiceTest.java394 final LinkedBlockingQueue<ICtsCarModeInCallServiceControl> queue = in getControlBinder() local
399 queue.offer(android.telecom.cts.carmodetestapp in getControlBinder()
405 queue.offer(null); in getControlBinder()
411 return queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in getControlBinder()
DIncomingCallTest.java144 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in testRingOnIncomingCall() local
154 if (isPlayingRingtone && queue.isEmpty()) { in testRingOnIncomingCall()
155 queue.add(isPlayingRingtone); in testRingOnIncomingCall()
165 Boolean ringing = queue.poll(WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, TimeUnit.MILLISECONDS); in testRingOnIncomingCall()
DThirdPartyCallScreeningServiceTest.java558 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in addRoleHolder() local
564 queue.put(successful); in addRoleHolder()
569 boolean result = queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in addRoleHolder()
577 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue(1); in removeRoleHolder() local
583 queue.put(successful); in removeRoleHolder()
588 boolean result = queue.poll(ASYNC_TIMEOUT, TimeUnit.MILLISECONDS); in removeRoleHolder()
DConferenceTest.java94 LinkedBlockingQueue<Connection> queue = new LinkedBlockingQueue(1); in testConferenceCreate() local
96 queue.put(mConferenceObject.getPrimaryConnection())); in testConferenceCreate()
98 Connection primaryConnection = queue.poll(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in testConferenceCreate()
/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/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.java87 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in listenForCellInfo() local
95 queue.offer(cis); in listenForCellInfo()
102 return queue.poll(LISTENER_TIMEOUT, TimeUnit.MILLISECONDS); in listenForCellInfo()
111 LinkedBlockingQueue<CellLocation> queue = new LinkedBlockingQueue<>(); in listenForCellLocation() local
119 queue.offer(cellLocation); in listenForCellLocation()
126 return queue.poll(LISTENER_TIMEOUT, TimeUnit.MILLISECONDS); in listenForCellLocation()
135 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(); in listenForServiceState() local
143 queue.offer(ss); in listenForServiceState()
150 ServiceState ss = queue.poll(LISTENER_TIMEOUT, TimeUnit.MILLISECONDS); in listenForServiceState()
/cts/hostsidetests/telephony/devicetest/src/android/telephony/device/cts/
DTelephonyTest.java79 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testListenerRegistrationWithChangeEnabled() local
83 queue.offer(true); in testListenerRegistrationWithChangeEnabled()
102 Boolean result = queue.poll(TEST_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in testListenerRegistrationWithChangeEnabled()
115 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in testListenerRegistrationWithChangeDisabled() local
119 queue.offer(true); in testListenerRegistrationWithChangeDisabled()
128 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/apps/CtsVerifier/src/com/android/cts/verifier/usb/device/
DUsbDeviceTestActivity.java473 receiveZero.queue(zeroBuffer, 1); in receiveZeroSizeRequestLegacy()
545 boolean wasQueued = receive.queue(bufferReceivedSliced, size); in echoUsbRequestLegacy()
547 wasQueued = sent.queue(bufferSentSliced, size); in echoUsbRequestLegacy()
610 receiveZero.queue(zeroBuffer); in receiveZeroSizeRequest()
684 boolean wasQueued = receive.queue(bufferReceivedSliced); in echoUsbRequest()
686 wasQueued = sent.queue(bufferSentSliced); in echoUsbRequest()
777 boolean wasQueued = receive.queue(bufferReceived, totalSize); in echoLargeUsbRequestLegacy()
779 wasQueued = sent.queue(bufferSent, totalSize); in echoLargeUsbRequestLegacy()
832 reqQueued.queue(buffer);
864 boolean isQueued = sent.queue(buffer, 0);
[all …]
/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/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/autofillservice/src/android/autofillservice/cts/
DGridActivity.java140 final BlockingQueue<String> queue = new LinkedBlockingQueue<>(1); in getText() local
141 onCell(row, column, (c) -> Helper.offer(queue, c.getText().toString(), timeoutMs)); in getText()
142 final String text = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in getText()
/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/tests/telephony/current/src/android/telephony/ims/cts/
DRcsUceAdapterTest.java142 LinkedBlockingQueue<Uri> queue = new LinkedBlockingQueue<>(1); in testGetAndSetUceSetting() local
143 registerUceObserver(queue::offer); in testGetAndSetUceSetting()
148 Uri result = queue.poll(ImsUtils.TEST_TIMEOUT_MS, TimeUnit.MILLISECONDS); in testGetAndSetUceSetting()
DImsServiceConnector.java249 LinkedBlockingQueue<Boolean> queue = new LinkedBlockingQueue<>(1); in setDefaultSmsApp() local
254 Runnable::run, queue::offer)); in setDefaultSmsApp()
255 result = queue.poll(ImsUtils.TEST_TIMEOUT_MS, TimeUnit.MILLISECONDS); in setDefaultSmsApp()
/cts/tests/tests/media/src/android/media/cts/
DMediaSessionTest.java195 List<QueueItem> queue = new ArrayList<>(); in testConfigureSession() local
198 queue.add(item); in testConfigureSession()
199 mSession.setQueue(queue); in testConfigureSession()
210 assertEquals(queue.size(), mCallback.mQueue.size()); in testConfigureSession()
215 assertEquals(queue.size(), controller.getQueue().size()); in testConfigureSession()
662 public void onQueueChanged(List<QueueItem> queue) { in onQueueChanged() argument
665 mQueue = queue; in onQueueChanged()
/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/media/libaudiojni/
DAndroid.bp19 "appendix-b-1-1-buffer-queue.cpp",
/cts/tests/tests/graphics/jni/
DVulkanPreTransformTestHelpers.h43 VkQueue queue() const { return mQueue; } in queue() function
DVulkanTestHelpers.h36 VkQueue queue() { return mQueue; } in queue() function

12