Home
last modified time | relevance | path

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

123

/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/modules/StatsD/statsd/tests/log_event/
DLogEventQueue_test.cpp51 LogEventQueue queue(50); in TEST() local
53 std::thread writer([&queue, timeBaseNs] { in TEST()
56 bool success = queue.push(makeLogEvent(timeBaseNs + i * 1000), &oldestEventNs); in TEST()
62 std::thread reader([&queue, timeBaseNs] { in TEST()
64 auto event = queue.waitPop(); in TEST()
76 LogEventQueue queue(50); in TEST() local
78 std::thread writer([&queue, timeBaseNs] { in TEST()
82 bool success = queue.push(makeLogEvent(timeBaseNs + i * 1000), &oldestEventNs); in TEST()
95 std::thread reader([&queue, timeBaseNs] { in TEST()
98 auto event = queue.waitPop(); in TEST()
/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/audio_util/
DMediaPlayerWrapper.java95 mCurrentData.queue = Util.toMetadataList(mContext, getQueue()); in MediaPlayerWrapper()
134 return mCurrentData.queue; in getCurrentQueue()
218 List<MediaSession.QueueItem> queue = getQueue(); in isMetadataSynced() local
219 if (queue != null && getActiveQueueID() != -1) { in isMetadataSynced()
223 for (MediaSession.QueueItem item : queue) { in isMetadataSynced()
473 public void onQueueChanged(@Nullable List<MediaSession.QueueItem> queue) { in onQueueChanged() argument
482 if (!Objects.equals(queue, getQueue())) { in onQueueChanged()
486 List<Metadata> current_queue = Util.toMetadataList(mContext, queue); in onQueueChanged()
487 if (current_queue.equals(mCurrentData.queue)) { in onQueueChanged()
561 sb.append(" Queue: size=" + mCurrentData.queue.size() + "\n"); in toString()
[all …]
DMediaPlayerList.java292 final List<Metadata> queue = player.getCurrentQueue(); in getCurrentMediaId() local
298 || queue.size() == 0) { in getCurrentMediaId()
559 List<Metadata> queue = new ArrayList<Metadata>(); in removeMediaPlayer() local
560 queue.add(Util.empty_data()); in removeMediaPlayer()
564 queue in removeMediaPlayer()
641 if (data.queue.size() == 0) { in sendMediaUpdate()
643 data.queue.add(data.metadata); in sendMediaUpdate()
718 List<Metadata> queue = new ArrayList<Metadata>(); in updateMediaForAudioPlayback() local
719 queue.add(Util.empty_data()); in updateMediaForAudioPlayback()
723 queue in updateMediaForAudioPlayback()
/packages/modules/adb/
Dadb_utils.h70 std::vector<T> queue; variable
76 queue.push_back(t); in Push()
87 cv.wait(lock, [this]() { return !queue.empty(); }); in PopAll()
88 popped = std::move(queue); in PopAll()
89 queue.clear(); in PopAll()
/packages/apps/Bluetooth/src/com/android/bluetooth/audio_util/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.java140 List<MediaSessionCompat.QueueItem> queue = Collections.singletonList(queueItem); in testGetSanitizedQueue() local
145 mCapturedCallback.getValue().onQueueChanged(queue); in testGetSanitizedQueue()
173 List<MediaSessionCompat.QueueItem> queue = Collections.emptyList(); in testGetHasQueue_empty() local
180 mCapturedCallback.getValue().onQueueChanged(queue); in testGetHasQueue_empty()
188 List<MediaSessionCompat.QueueItem> queue = in testGetHasQueue_true() local
194 mCapturedCallback.getValue().onQueueChanged(queue); in testGetHasQueue_true()
/packages/apps/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/
DPlayer.java256 List<QueueItem> queue = new ArrayList<>(); in maybeRebuildQueue() local
268 foundIdx = queue.size(); in maybeRebuildQueue()
279 queue.add(new QueueItem(description, song.queueId)); in maybeRebuildQueue()
282 if (queue.isEmpty()) { in maybeRebuildQueue()
286 mQueue = queue; in maybeRebuildQueue()
336 List<QueueItem> queue = mDataModel.getQueue(); in startPlayback() local
339 for (QueueItem item : queue) { in startPlayback()
352 mQueue = new ArrayList<>(queue); in startPlayback()
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/audio_util/
DMediaPlayerWrapperTest.java279 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testNoQueueMediaUpdates()
297 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testNoQueueMediaUpdates()
347 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testDataOnUpdateNoQueue()
404 Assert.assertEquals("Returned Queue isn't null", data.queue.size(), 0); in testNullQueue()
464 Assert.assertEquals("Returned Queue isn't empty", data.queue.size(), 0); in testPlaybackStateUpdateSpam()
587 data.queue, in testMetadataSync()
637 data.queue, in testMetadataSyncFail()
717 data.queue, in testMetadataSyncFuzz()
/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/
DTestUtils.java208 public static Intent waitForIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForIntent() argument
210 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForIntent()
227 public static Intent waitForNoIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForNoIntent() argument
229 Intent intent = queue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForNoIntent()
/packages/apps/Bluetooth/src/com/android/bluetooth/avrcp/
DAvrcpTargetService.java92 boolean queue = !Objects.equals(mCurrentData.queue, data.queue); in run()
96 + " state=" + state + " queue=" + queue); in run()
100 mNativeInterface.sendMediaUpdate(metadata, state, queue); in run()
DAvrcpNativeInterface.java176 void sendMediaUpdate(boolean metadata, boolean playStatus, boolean queue) { in sendMediaUpdate() argument
179 + " queue=" + queue); in sendMediaUpdate()
180 sendMediaUpdateNative(metadata, playStatus, queue); in sendMediaUpdate()
/packages/providers/MediaProvider/src/com/android/providers/media/util/
DIsoInterface.java263 final Queue<Box> queue = new ArrayDeque<>(mRoots); in IsoInterface() local
264 while (!queue.isEmpty()) { in IsoInterface()
265 final Box box = queue.poll(); in IsoInterface()
268 queue.addAll(box.children); in IsoInterface()
/packages/apps/Car/tests/TestMediaApp/src/com/android/car/media/testmediaapp/
DTmaBrowser.java193 TmaMediaItem queue = mLibrary.getRoot(LEAF_CHILDREN); in onLoadChildren() local
194 if (queue != null) { in onLoadChildren()
195 mSession.setQueue(queue.buildQueue()); in onLoadChildren()
196 mPlayer.prepareMediaItem(queue.getPlayableByIndex(0)); in onLoadChildren()
DTmaMediaItem.java189 List<QueueItem> queue = new ArrayList<>(count); in buildQueue() local
192 queue.add(new QueueItem(child.buildDescription(), i)); in buildQueue()
194 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/modules/DnsResolver/tests/unsolicited_listener/
Dunsolicited_event_listener.h72 std::queue<int> emptyQueue; in reset()
100 std::queue<int> mDnsHealthResultRecords GUARDED_BY(mMutex);
/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()

123