Home
last modified time | relevance | path

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

12

/packages/apps/Dialer/java/com/android/voicemail/impl/scheduling/
DTaskQueue.java40 private final Queue<Task> queue = new ArrayDeque<>(); field in TaskQueue
43 List<Bundle> result = new ArrayList<>(queue.size()); in toBundles()
44 for (Task task : queue) { in toBundles()
51 Assert.isTrue(queue.isEmpty()); in fromBundles()
82 queue.add(task); in add()
87 queue.remove(task); in remove()
92 for (Task task : queue) { in getTask()
125 for (Task task : queue) { in getNextTask()
139 queue.clear(); in clear()
143 return queue.size(); in size()
[all …]
DTaskSchedulerJobService.java111 TaskQueue queue = new TaskQueue(); in scheduleJob() local
112 queue.fromBundles(context, existingTasks); in scheduleJob()
115 queue.add(Tasks.createTask(context, pendingTask)); in scheduleJob()
120 pendingTasks = queue.toBundles(); in scheduleJob()
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/
DSimpleSampleBuffer.java91 for (SampleQueue queue : mPlayingSampleQueues) { in getBufferedPositionUs()
92 if (queue == null) { in getBufferedPositionUs()
95 Long lastQueuedSamplePositionUs = queue.getLastQueuedPositionUs(); in getBufferedPositionUs()
113 SampleQueue queue = mPlayingSampleQueues[track]; in readSample() local
114 SoftPreconditions.checkNotNull(queue); in readSample()
115 int result = queue == null ? SampleSource.NOTHING_READ : queue.dequeueSample(sampleHolder); in readSample()
154 for (SampleQueue queue : mPlayingSampleQueues) { in continueBuffering()
155 if (queue == null) { in continueBuffering()
158 if (queue.getLastQueuedPositionUs() == null in continueBuffering()
159 || positionUs > queue.getLastQueuedPositionUs()) { in continueBuffering()
DRecordingSampleBuffer.java213 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample() argument
214 if (queue.getLastQueuedPositionUs() != null in maybeReadSample()
215 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US in maybeReadSample()
216 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) { in maybeReadSample()
226 queue.queueSample(sample); in maybeReadSample()
284 SampleQueue queue = mReadSampleQueues.get(i); in continueBuffering() local
285 maybeReadSample(queue, i); in continueBuffering()
286 if (queue.getLastQueuedPositionUs() == null in continueBuffering()
287 || positionUs > queue.getLastQueuedPositionUs()) { in continueBuffering()
DBufferManager.java312 LinkedList<SampleChunk> queue = mEvictMap.get(key); in add() local
313 if (queue != null) { in add()
315 queue.add(chunk); in add()
320 LinkedList<SampleChunk> queue = mEvictMap.get(key); in poll() local
321 if (queue != null) { in poll()
322 SampleChunk chunk = queue.peek(); in poll()
325 return queue.poll(); in poll()
/packages/apps/Bluetooth/src/com/android/bluetooth/avrcp/
DMediaPlayerWrapper.java103 newWrapper.mCurrentData.queue = Util.toMetadataList(newWrapper.getQueue()); in wrap()
142 return mCurrentData.queue; in getCurrentQueue()
441 public void onQueueChanged(@Nullable List<MediaSession.QueueItem> queue) { in onQueueChanged() argument
450 if (!Objects.equals(queue, getQueue())) { in onQueueChanged()
454 List<Metadata> current_queue = Util.toMetadataList(queue); in onQueueChanged()
455 if (current_queue.equals(mCurrentData.queue)) { in onQueueChanged()
528 sb.append(" Queue: size=" + mCurrentData.queue.size() + "\n"); in toString()
529 for (Metadata data : mCurrentData.queue) { in toString()
DAvrcpTargetService.java72 boolean queue = !Objects.equals(mCurrentData.queue, data.queue); in run()
76 + " state=" + state + " queue=" + queue); in run()
80 mNativeInterface.sendMediaUpdate(metadata, state, queue); in run()
DAvrcpNativeInterface.java156 void sendMediaUpdate(boolean metadata, boolean playStatus, boolean queue) { in sendMediaUpdate() argument
159 + " queue=" + queue); in sendMediaUpdate()
160 sendMediaUpdateNative(metadata, playStatus, queue); in sendMediaUpdate()
DMediaPlayerList.java251 final List<Metadata> queue = player.getCurrentQueue(); in getCurrentMediaId() local
257 || queue.size() == 0) { in getCurrentMediaId()
526 if (data.queue.size() == 0) { in sendMediaUpdate()
528 data.queue.add(data.metadata); in sendMediaUpdate()
/packages/apps/Bluetooth/src/com/android/bluetooth/avrcp/helpers/
DMediaData.java28 public List<Metadata> queue; field in MediaData
35 queue = q; in MediaData()
53 if (!Objects.equals(queue, u.queue)) { in equals()
/packages/apps/Car/libs/car-media-common/tests/robotests/src/com/android/car/media/common/playback/
DPlaybackViewModelTest.java130 List<MediaSessionCompat.QueueItem> queue = Collections.singletonList(queueItem); in testGetSanitizedQueue() local
135 mCapturedCallback.getValue().onQueueChanged(queue); in testGetSanitizedQueue()
163 List<MediaSessionCompat.QueueItem> queue = Collections.emptyList(); in testGetHasQueue_empty() local
170 mCapturedCallback.getValue().onQueueChanged(queue); in testGetHasQueue_empty()
178 List<MediaSessionCompat.QueueItem> queue = in testGetHasQueue_true() local
184 mCapturedCallback.getValue().onQueueChanged(queue); in testGetHasQueue_true()
/packages/apps/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/
DPlayer.java235 List<QueueItem> queue = new ArrayList<>(); in maybeRebuildQueue() local
247 foundIdx = queue.size(); in maybeRebuildQueue()
258 queue.add(new QueueItem(description, song.queueId)); in maybeRebuildQueue()
261 if (queue.isEmpty()) { in maybeRebuildQueue()
265 mQueue = queue; in maybeRebuildQueue()
311 List<QueueItem> queue = mDataModel.getQueue(); in startPlayback() local
314 for (QueueItem item : queue) { in startPlayback()
327 mQueue = new ArrayList<>(queue); in startPlayback()
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/newavrcp/
DMediaPlayerWrapperTest.java242 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testNoQueueMediaUpdates()
260 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testNoQueueMediaUpdates()
310 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testDataOnUpdateNoQueue()
367 Assert.assertEquals("Returned Queue isn't null", data.queue.size(), 0); in testNullQueue()
427 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testPlaybackStateUpdateSpam()
549 data.queue, in testMetadataSync()
599 data.queue, in testMetadataSyncFail()
679 data.queue, in testMetadataSyncFuzz()
/packages/providers/MediaProvider/src/com/android/providers/media/util/
DIsoInterface.java212 final Queue<Box> queue = new LinkedList<>(mRoots); in IsoInterface() local
213 while (!queue.isEmpty()) { in IsoInterface()
214 final Box box = queue.poll(); in IsoInterface()
217 queue.addAll(box.children); in IsoInterface()
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/
DTestUtils.java207 public static Intent waitForIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForIntent() argument
209 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForIntent()
226 public static Intent waitForNoIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForNoIntent() argument
228 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForNoIntent()
/packages/providers/MediaProvider/src/com/android/providers/media/
DRingtoneOverlayService.java105 SynchronousQueue<Uri> queue = new SynchronousQueue<>(); in scanFile() local
117 queue.put(uri); in scanFile()
125 return queue.take(); in scanFile()
/packages/apps/UnifiedEmail/src/com/android/mail/browse/
DMessageAttachmentTile.java139 PriorityQueue<MessageAttachmentTile> queue = new PriorityQueue<MessageAttachmentTile>( in showAndDownloadAttachments() local
143 queue.add(tile); in showAndDownloadAttachments()
150 MessageAttachmentTile tile = queue.remove(); in showAndDownloadAttachments()
/packages/apps/Car/tests/TestMediaApp/src/com/android/car/media/testmediaapp/
DTmaMediaItem.java176 List<QueueItem> queue = new ArrayList<>(count); in buildQueue() local
179 queue.add(new QueueItem(child.buildDescription(), i)); in buildQueue()
181 return queue; in buildQueue()
/packages/apps/Gallery2/src/com/android/gallery3d/util/
DIdentityCache.java37 public Entry(K key, V value, ReferenceQueue<V> queue) { in Entry() argument
38 super(value, queue); in Entry()
/packages/apps/Gallery/src/com/android/camera/gallery/
DLruCache.java45 public Entry(K key, V value, ReferenceQueue<V> queue) { in Entry() argument
46 super(value, queue); in Entry()
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/hid/
DHidDeviceTest.java171 private Intent waitForIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForIntent() argument
173 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForIntent()
193 private void verifyCallback(int timeoutMs, int callbackType, BlockingQueue<Integer> queue) { in verifyCallback() argument
195 Integer lastCallback = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in verifyCallback()
/packages/apps/UnifiedEmail/src/org/apache/commons/io/
DFileCleaningTracker.java242 …cker(String path, FileDeleteStrategy deleteStrategy, Object marker, ReferenceQueue<Object> queue) { in Tracker() argument
243 super(marker, queue); in Tracker()
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/
DLruCache.java49 public Entry(K key, V value, ReferenceQueue<V> queue) { in Entry() argument
50 super(value, queue); in Entry()
/packages/apps/Calendar/src/com/android/calendar/
DEventLoader.java164 public LoaderThread(LinkedBlockingQueue<LoadRequest> queue, EventLoader eventLoader) { in LoaderThread() argument
165 mQueue = queue; in LoaderThread()
/packages/services/Car/tests/carservice_test/src/com/android/car/
DMockedVmsTestBase.java227 private static <T> T receiveWithTimeout(BlockingQueue<T> queue) { in receiveWithTimeout() argument
229 return queue.poll(2L, TimeUnit.SECONDS); in receiveWithTimeout()

12