| /cts/tests/tests/media/common/src/android/media/cts/ |
| D | NonBlockingAudioTrack.java | 51 private LinkedList<QueueElement> mQueue = new LinkedList<QueueElement>(); field in NonBlockingAudioTrack
138 mQueue.add(element); in setEndOfStream()
142 if (mQueue.isEmpty()) { in stop()
167 mQueue.clear(); in flush()
173 mQueue.clear(); in release()
181 while (!mQueue.isEmpty()) { in process()
182 QueueElement element = mQueue.peekFirst(); in process()
203 mQueue.removeFirst(); in process()
219 mQueue.removeFirst(); in process()
247 mQueue.add(element); in write()
|
| /cts/tests/media/common/src/android/mediav2/common/cts/ |
| D | ImageSurface.java | 45 private final ArrayDeque<Pair<Image, Exception>> mQueue = new ArrayDeque<>(); field in ImageSurface
70 if (mQueue.size() == reader.getMaxImages()) { in onImageAvailable()
73 releaseImage(mQueue.poll()); in onImageAvailable()
78 mQueue.add(Pair.create(image, null /* Exception */)); in onImageAvailable()
82 mQueue.add(Pair.create(null /* Image */, e)); in onImageAvailable()
93 while (mQueue.size() == 0 && retry > 0) { in getImage()
98 if (mQueue.size() > 0) { in getImage()
99 Pair<Image, Exception> imageResult = mQueue.poll(); in getImage()
158 mQueue.forEach(this::releaseImage); in release()
159 mQueue.clear(); in release()
|
| /cts/tests/inputmethod/util/src/android/view/inputmethod/cts/util/ |
| D | WindowFocusStealer.java | 42 final BlockingQueue<Integer> mQueue = new ArrayBlockingQueue<>(1); field in WindowFocusStealer.MyResultReceiver
50 mQueue.add(resultCode); in onReceiveResult()
56 result = mQueue.poll(timeout, TimeUnit.MILLISECONDS); in waitResult()
|
| /cts/hostsidetests/devicepolicy/app/DeviceAndProfileOwner/src/com/android/cts/deviceandprofileowner/ |
| D | CustomizationRestrictionsTest.java | 87 private BlockingQueue<Integer> mQueue = new ArrayBlockingQueue<Integer>(1); field in CustomizationRestrictionsTest.BlockingBroadcastReceiver
91 assertTrue(mQueue.add(0)); in onReceive()
95 Integer result = mQueue.poll(BROADCAST_TIMEOUT_SEC, TimeUnit.SECONDS); in waitForBroadcast()
|
| /cts/tests/tests/graphics/jni/ |
| D | VulkanPreTransformTestHelpers.h | 42 VkQueue queue() const { return mQueue; } in queue()
51 VkQueue mQueue; variable
|
| D | VulkanTestHelpers.h | 36 VkQueue queue() { return mQueue; } in queue()
53 VkQueue mQueue = VK_NULL_HANDLE; variable
|
| D | VulkanTestHelpers.cpp | 241 vkGetDeviceQueue(mDevice, 0, 0, &mQueue); in init()
248 if (mQueue != VK_NULL_HANDLE) { in ~VkInit()
250 mQueue = VK_NULL_HANDLE; in ~VkInit()
|
| D | VulkanPreTransformTestHelpers.cpp | 118 mQueue(VK_NULL_HANDLE) {} in DeviceInfo()
246 vkGetDeviceQueue(mDevice, mQueueFamilyIndex, 0, &mQueue); in init()
|
| /cts/tests/tests/telephony/current/src/android/telephony/ims/cts/ |
| D | ImsServiceTest.java | 1364 LinkedBlockingQueue<Integer> mQueue = new LinkedBlockingQueue<>(); in testMmTelManagerRegistrationCallback() local
1368 mQueue.offer(imsTransportType); in testMmTelManagerRegistrationCallback()
1373 mQueue.offer(imsTransportType); in testMmTelManagerRegistrationCallback()
1378 mQueue.offer(info.getCode()); in testMmTelManagerRegistrationCallback()
1383 mQueue.offer(imsTransportType); in testMmTelManagerRegistrationCallback()
1384 mQueue.offer(info.getCode()); in testMmTelManagerRegistrationCallback()
1408 assertEquals(ImsReasonInfo.CODE_LOCAL_NOT_REGISTERED, waitForIntResult(mQueue)); in testMmTelManagerRegistrationCallback()
1414 assertEquals(AccessNetworkConstants.TRANSPORT_TYPE_WWAN, waitForIntResult(mQueue)); in testMmTelManagerRegistrationCallback()
1419 assertEquals(AccessNetworkConstants.TRANSPORT_TYPE_WWAN, waitForIntResult(mQueue)); in testMmTelManagerRegistrationCallback()
1426 assertEquals(AccessNetworkConstants.TRANSPORT_TYPE_WLAN, waitForIntResult(mQueue)); in testMmTelManagerRegistrationCallback()
[all …]
|
| /cts/tests/framework/base/windowmanager/src/android/server/wm/window/ |
| D | ScreenRecordingCallbackTests.java | 75 private final BlockingQueue<Integer> mQueue = new LinkedBlockingDeque<>(); field in ScreenRecordingCallbackTests.TestableScreenRecordingCallback
79 mQueue.add(state); in accept()
83 Integer value = mQueue.poll(5L * HW_TIMEOUT_MULTIPLIER, TimeUnit.SECONDS); in getState()
91 return mQueue.isEmpty(); in queueEmpty()
|
| /cts/tests/mediapc/src/android/mediapc/cts/ |
| D | PlaybackFrameDrop.java | 74 private final ArrayList<BufferData> mQueue = new ArrayList<>(); field in PlaybackFrameDrop.OutputHandler
84 if (mQueue.isEmpty()) { in getOutput()
87 output = mQueue.remove(0); in getOutput()
116 mQueue.add(new BufferData(outputCount, bufferIndex, info)); in add()
|
| /cts/tests/camera/src/android/hardware/camera2/cts/ |
| D | ReadoutTimestampTest.java | 226 private final LinkedBlockingQueue<TotalCaptureResult> mQueue = field in ReadoutTimestampTest.ReadoutCaptureCallback
257 mQueue.put(result); in onCaptureCompleted()
266 TotalCaptureResult result = mQueue.poll(timeout, TimeUnit.MILLISECONDS); in getCaptureResult()
|
| D | CaptureResultTest.java | 902 private final LinkedBlockingQueue<Pair<TotalCaptureResult, List<CaptureResult>> > mQueue = field in CaptureResultTest.TotalAndPartialResultListener
925 mQueue.put(new Pair<TotalCaptureResult, List<CaptureResult>>( in onCaptureCompleted()
966 mQueue.poll(timeout, TimeUnit.MILLISECONDS); in getCaptureResultPairs()
|
| /cts/tests/tests/media/bettertogether/src/android/media/bettertogether/cts/ |
| D | MediaSessionTest.java | 314 callback.onQueueChanged(mCallback.mQueue); in testConfigureSession()
321 assertThat(mCallback.mQueue.size()).isEqualTo(queue.size()); in testConfigureSession()
322 assertThat(mCallback.mQueue.get(0).getQueueId()).isEqualTo(TEST_QUEUE_ID); in testConfigureSession()
323 assertThat(mCallback.mQueue.get(0).getDescription().getMediaId()).isEqualTo(TEST_VALUE); in testConfigureSession()
336 callback.onQueueChanged(mCallback.mQueue); in testConfigureSession()
345 assertThat(mCallback.mQueue).isNull(); in testConfigureSession()
1205 private volatile List<QueueItem> mQueue; field in MediaSessionTest.MediaControllerCallback
1223 mQueue = null; in resetLocked()
1251 mQueue = queue; in onQueueChanged()
|
| /cts/tests/tests/telephony/current/src/android/telephony/cts/ |
| D | TelephonyRegistryManagerTest.java | 470 private final LinkedBlockingQueue<Set<Integer>> mQueue; field in TelephonyRegistryManagerTest.SimultaneousCallingListener
473 mQueue = queue; in SimultaneousCallingListener()
479 mQueue.offer(simultaneousCallingSubscriptionIds); in onSimultaneousCellularCallingSubscriptionsChanged()
771 private final LinkedBlockingQueue<Boolean> mQueue; field in TelephonyRegistryManagerTest.CarrierRoamingNtnModeListener
774 mQueue = queue; in CarrierRoamingNtnModeListener()
779 mQueue.offer(active); in onCarrierRoamingNtnModeChanged()
|
| /cts/tests/tests/media/decoder/src/android/media/decoder/cts/ |
| D | ImageReaderDecoderTest.java | 390 private final LinkedBlockingQueue<Pair<Image, Exception>> mQueue = field in ImageReaderDecoderTest.ImageListener
396 mQueue.put(Pair.create(reader.acquireNextImage(), null /* Exception */)); in onImageAvailable()
402 mQueue.put(Pair.create(null /* Image */, e)); in onImageAvailable()
417 Pair<Image,Exception> imageResult = mQueue.poll(timeout, TimeUnit.MILLISECONDS); in getImage()
|
| /cts/hostsidetests/appsecurity/test-apps/EphemeralTestApp/NormalApp/src/com/android/cts/normalapp/ |
| D | ClientTest.java | 649 private final SynchronousQueue<TestResult> mQueue; field in ClientTest.ActivityBroadcastReceiver
651 mQueue = queue; in ActivityBroadcastReceiver()
657 mQueue.offer(intent.getParcelableExtra(TestResult.EXTRA_TEST_RESULT), in onReceive()
|
| /cts/tests/camera/utils/src/android/hardware/camera2/cts/ |
| D | CameraTestUtils.java | 611 private final LinkedBlockingQueue<Image> mQueue = field in CameraTestUtils.SimpleImageReaderListener
658 mQueue.put(imge); in onImageAvailable()
659 if (mAsyncMode && mQueue.size() >= mMaxImages) { in onImageAvailable()
660 Image img = mQueue.poll(); in onImageAvailable()
676 Image image = mQueue.poll(timeout, TimeUnit.MILLISECONDS); in getImage()
686 while (!mQueue.isEmpty()) { in drain()
687 Image image = mQueue.poll(); in drain()
762 if (mQueue.size() < mMaxBuffers) { in onImageAvailable()
766 mQueue.offer(new ImageAndMultiResStreamInfo(image, multiResStreamInfo)); in onImageAvailable()
792 ImageAndMultiResStreamInfo imageAndInfo = mQueue.poll(timeoutMs, in getAnyImageAndInfoAvailable()
[all …]
|
| /cts/hostsidetests/appsecurity/test-apps/EphemeralTestApp/EphemeralApp1/src/com/android/cts/ephemeralapp1/ |
| D | ClientTest.java | 1499 private final SynchronousQueue<TestResult> mQueue; field in ClientTest.ActivityBroadcastReceiver
1501 mQueue = queue; in ActivityBroadcastReceiver()
1507 mQueue.offer(intent.getParcelableExtra(TestResult.EXTRA_TEST_RESULT), in onReceive()
|