Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 47) 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.java225 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample() argument
226 if (queue.getLastQueuedPositionUs() != null in maybeReadSample()
227 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US in maybeReadSample()
228 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) { in maybeReadSample()
238 queue.queueSample(sample); in maybeReadSample()
296 SampleQueue queue = mReadSampleQueues.get(i); in continueBuffering() local
297 maybeReadSample(queue, i); in continueBuffering()
298 if (queue.getLastQueuedPositionUs() == null in continueBuffering()
299 || positionUs > queue.getLastQueuedPositionUs()) { in continueBuffering()
DBufferManager.java315 LinkedList<SampleChunk> queue = mEvictMap.get(key); in add() local
316 if (queue != null) { in add()
318 queue.add(chunk); in add()
323 LinkedList<SampleChunk> queue = mEvictMap.get(key); in poll() local
324 if (queue != null) { in poll()
325 SampleChunk chunk = queue.peek(); in poll()
328 return queue.poll(); in poll()
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/
DMemorySampleBuffer.java86 SampleQueue queue = mPlayingSampleQueues[track]; in readSample() local
87 SoftPreconditions.checkNotNull(queue); in readSample()
88 int result = queue == null ? C.RESULT_NOTHING_READ : queue.dequeueSample(sampleHolder); in readSample()
129 for (SampleQueue queue : mPlayingSampleQueues) { in continueLoading()
130 if (queue == null) { in continueLoading()
133 if (queue.getLastQueuedPositionUs() == null in continueLoading()
134 || positionUs > queue.getLastQueuedPositionUs()) { in continueLoading()
DRecordingSampleBuffer.java225 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample() argument
226 if (queue.getLastQueuedPositionUs() != null in maybeReadSample()
227 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US in maybeReadSample()
228 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) { in maybeReadSample()
238 queue.queueSample(sample); in maybeReadSample()
272 SampleQueue queue = mReadSampleQueues.get(i); in continueLoading() local
273 maybeReadSample(queue, i); in continueLoading()
274 if (queue.getLastQueuedPositionUs() == null in continueLoading()
275 || positionUs > queue.getLastQueuedPositionUs()) { in continueLoading()
DBufferManager.java318 LinkedList<SampleChunk> queue = mEvictMap.get(key); in add() local
319 if (queue != null) { in add()
321 queue.add(chunk); in add()
326 LinkedList<SampleChunk> queue = mEvictMap.get(key); in poll() local
327 if (queue != null) { in poll()
328 SampleChunk chunk = queue.peek(); in poll()
331 return queue.poll(); in poll()
/packages/apps/Bluetooth/src/com/android/bluetooth/avrcp/
DMediaPlayerWrapper.java92 mCurrentData.queue = Util.toMetadataList(getQueue()); in MediaPlayerWrapper()
131 return mCurrentData.queue; in getCurrentQueue()
431 public void onQueueChanged(@Nullable List<MediaSession.QueueItem> queue) { in onQueueChanged() argument
440 if (!Objects.equals(queue, getQueue())) { in onQueueChanged()
444 List<Metadata> current_queue = Util.toMetadataList(queue); in onQueueChanged()
445 if (current_queue.equals(mCurrentData.queue)) { in onQueueChanged()
519 sb.append(" Queue: size=" + mCurrentData.queue.size() + "\n"); in toString()
520 for (Metadata data : mCurrentData.queue) { in toString()
DMediaPlayerList.java275 final List<Metadata> queue = player.getCurrentQueue(); in getCurrentMediaId() local
281 || queue.size() == 0) { in getCurrentMediaId()
522 List<Metadata> queue = new ArrayList<Metadata>(); in removeMediaPlayer() local
523 queue.add(Util.empty_data()); in removeMediaPlayer()
527 queue in removeMediaPlayer()
604 if (data.queue.size() == 0) { in sendMediaUpdate()
606 data.queue.add(data.metadata); in sendMediaUpdate()
681 List<Metadata> queue = new ArrayList<Metadata>(); in updateMediaForAudioPlayback() local
682 queue.add(Util.empty_data()); in updateMediaForAudioPlayback()
686 queue in updateMediaForAudioPlayback()
DAvrcpTargetService.java79 boolean queue = !Objects.equals(mCurrentData.queue, data.queue); in run()
83 + " state=" + state + " queue=" + queue); in run()
87 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()
/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.java127 List<MediaSessionCompat.QueueItem> queue = Collections.singletonList(queueItem); in testGetSanitizedQueue() local
132 mCapturedCallback.getValue().onQueueChanged(queue); in testGetSanitizedQueue()
160 List<MediaSessionCompat.QueueItem> queue = Collections.emptyList(); in testGetHasQueue_empty() local
167 mCapturedCallback.getValue().onQueueChanged(queue); in testGetHasQueue_empty()
175 List<MediaSessionCompat.QueueItem> queue = in testGetHasQueue_true() local
181 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.java244 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testNoQueueMediaUpdates()
262 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testNoQueueMediaUpdates()
312 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testDataOnUpdateNoQueue()
369 Assert.assertEquals("Returned Queue isn't null", data.queue.size(), 0); in testNullQueue()
429 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testPlaybackStateUpdateSpam()
551 data.queue, in testMetadataSync()
601 data.queue, in testMetadataSyncFail()
681 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/apps/Car/tests/TestMediaApp/src/com/android/car/media/testmediaapp/
DTmaBrowser.java171 TmaMediaItem queue = mLibrary.getRoot(LEAF_CHILDREN); in onLoadChildren() local
172 if (queue != null) { in onLoadChildren()
173 mSession.setQueue(queue.buildQueue()); in onLoadChildren()
174 mPlayer.prepareMediaItem(queue.getPlayableByIndex(0)); in onLoadChildren()
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/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/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.java174 private Intent waitForIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForIntent() argument
176 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForIntent()
196 private void verifyCallback(int timeoutMs, int callbackType, BlockingQueue<Integer> queue) { in verifyCallback() argument
198 Integer lastCallback = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in verifyCallback()
/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()

12