Searched refs:mQueue (Results 1 - 25 of 43) sorted by path

12

/frameworks/av/media/libmediaplayerservice/nuplayer/
H A DNuPlayerStreamListener.cpp63 mQueue.push_back(entry);
84 mQueue.push_back(entry);
107 if (mQueue.empty()) {
113 QueueEntry *entry = &*mQueue.begin();
119 mQueue.erase(mQueue.begin());
130 mQueue.erase(mQueue.begin());
166 mQueue.erase(mQueue
[all...]
H A DNuPlayerStreamListener.h65 List<QueueEntry> mQueue; member in struct:android::NuPlayer::NuPlayerStreamListener
/frameworks/av/media/libstagefright/
H A DMediaCodecSource.cpp94 Mutexed<Queue> mQueue; member in struct:android::MediaCodecSource::Puller
145 Mutexed<Queue>::Locked queue(mQueue);
184 Mutexed<Queue>::Locked queue(mQueue);
207 Mutexed<Queue>::Locked queue(mQueue);
212 Mutexed<Queue>::Locked queue(mQueue);
235 Mutexed<Queue>::Locked queue(mQueue);
269 Mutexed<Queue>::Locked queue(mQueue);
/frameworks/av/media/libstagefright/include/
H A DSimpleSoftOMXComponent.h52 List<BufferInfo *> mQueue; member in struct:android::SimpleSoftOMXComponent::PortInfo
/frameworks/av/media/libstagefright/mpeg2ts/
H A DATSParser.cpp162 ElementaryStreamQueue *mQueue; member in struct:android::ATSParser::Stream
172 // Feed the payload into mQueue and if a packet is identified, queue it
598 mQueue(NULL) {
601 mQueue = new ElementaryStreamQueue(
607 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC);
611 mQueue = new ElementaryStreamQueue(
617 mQueue = new ElementaryStreamQueue(
622 mQueue = new ElementaryStreamQueue(
628 mQueue = new ElementaryStreamQueue(
633 mQueue
[all...]
H A DMPEG2PSExtractor.cpp64 ElementaryStreamQueue *mQueue; member in struct:android::MPEG2PSExtractor::Track
595 mQueue(NULL) {
626 mQueue = new ElementaryStreamQueue(mode);
633 delete mQueue;
634 mQueue = NULL;
687 if (mQueue == NULL) {
698 status_t err = mQueue->appendData(data, size, timeUs);
705 while ((accessUnit = mQueue->dequeueAccessUnit()) != NULL) {
707 sp<MetaData> meta = mQueue->getFormat();
715 } else if (mQueue
[all...]
/frameworks/av/media/libstagefright/omx/
H A DOMX.cpp86 std::list<omx_message> mQueue; member in struct:android::OMX::CallbackDispatcher
124 mQueue.push_back(msg);
144 while (!mDone && mQueue.empty()) {
152 messages.swap(mQueue);
H A DSimpleSoftOMXComponent.cpp382 port->mQueue.push_back(buffer);
510 port->mQueue.clear();
567 port->mQueue.clear();
682 return mPorts.editItemAt(portIndex).mQueue;
/frameworks/av/media/libstagefright/rtsp/
H A DARTPSource.cpp110 mQueue.push_back(buffer);
154 List<sp<ABuffer> >::iterator it = mQueue.begin();
155 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) {
159 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) {
164 mQueue.insert(it, buffer);
H A DARTPSource.h44 List<sp<ABuffer> > *queue() { return &mQueue; }
54 List<sp<ABuffer> > mQueue; member in struct:android::ARTPSource
/frameworks/base/core/java/android/os/
H A DHandler.java203 mQueue = mLooper.mQueue;
229 mQueue = looper.mQueue;
495 mQueue.removeMessages(this, r, null);
505 mQueue.removeMessages(this, r, token);
605 MessageQueue queue = mQueue;
608 this + " sendMessageAtTime() called with no mQueue");
628 MessageQueue queue = mQueue;
631 this + " sendMessageAtTime() called with no mQueue");
755 final MessageQueue mQueue; field in class:Handler
[all...]
H A DLooper.java71 final MessageQueue mQueue; field in class:Looper
128 final MessageQueue queue = me.mQueue;
194 return myLooper().mQueue;
198 mQueue = new MessageQueue(quitAllowed);
244 mQueue.quit(false);
260 mQueue.quit(true);
278 return mQueue;
289 mQueue.dump(pw, prefix + " ");
H A DStrictMode.java1668 MessageQueue mq = looper.mQueue;
/frameworks/base/core/java/android/speech/tts/
H A DAudioPlaybackHandler.java27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue = field in class:AudioPlaybackHandler
51 mQueue.put(item);
80 return (mQueue.peek() != null) || (mCurrentWorkItem != null);
96 mQueue.clear();
103 Iterator<PlaybackQueueItem> it = mQueue.iterator();
123 item = mQueue.take();
129 // If stop() or stopForApp() are called between mQueue.take()
/frameworks/base/libs/hwui/renderthread/
H A DRenderThread.cpp322 mQueue.queue(task);
344 mQueue.queueAtFront(task);
355 mQueue.remove(task);
377 RenderTask* next = mQueue.peek();
384 next = mQueue.next();
H A DRenderThread.h127 TaskQueue mQueue; member in class:android::uirenderer::renderthread::RenderThread
135 // both mQueue *and* mDisplayEventReceiver have been drained off all
/frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/helpers/
H A DCameraTestUtils.java271 private final LinkedBlockingQueue<Image> mQueue = field in class:CameraTestUtils.SimpleImageReaderListener
314 mQueue.put(reader.acquireNextImage());
315 if (mAsyncMode && mQueue.size() >= mMaxImages) {
316 Image img = mQueue.poll();
332 Image image = mQueue.poll(timeout, TimeUnit.MILLISECONDS);
342 while (!mQueue.isEmpty()) {
343 Image image = mQueue.poll();
380 private final LinkedBlockingQueue<TotalCaptureResult> mQueue = field in class:CameraTestUtils.SimpleCaptureCallback
406 mQueue.put(result);
442 result = mQueue
[all...]
/frameworks/base/packages/DocumentsUI/src/com/android/documentsui/
H A DProviderExecutor.java51 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>(); field in class:ProviderExecutor
88 mQueue.add(command);
96 mQueue.add(command);
103 final Runnable command = mQueue.take();
/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/
H A DServiceResolveQueue.java29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>(); field in class:ServiceResolveQueue
64 if (mQueue.contains(newRequest)) return;
65 mQueue.add(newRequest);
73 mQueue.remove(newRequest);
81 if (mQueue.isEmpty()) return;
82 mCurrentRequest = mQueue.removeFirst();
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/samsung/
H A DServiceResolveQueue.java29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>(); field in class:ServiceResolveQueue
64 if (mQueue.contains(newRequest)) return;
65 mQueue.add(newRequest);
73 mQueue.remove(newRequest);
81 if (mQueue.isEmpty()) return;
82 mCurrentRequest = mQueue.removeFirst();
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/xerox/
H A DServiceResolver.java102 private final LinkedList<NsdServiceInfo> mQueue = new LinkedList<>(); field in class:ServiceResolver
108 if (mQueue.contains(serviceInfo)) return;
109 mQueue.add(serviceInfo);
116 mQueue.remove(serviceInfo);
124 mQueue.clear();
131 if (mQueue.isEmpty()) return;
132 mCurrentRequest = mQueue.removeFirst();
137 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
/frameworks/base/packages/Shell/tests/src/com/android/shell/
H A DActionSendMultipleConsumerActivity.java90 private final BlockingQueue<Bundle> mQueue = new SynchronousQueue<>(); field in class:ActionSendMultipleConsumerActivity.CustomActionSendMultipleListener
98 mQueue.put(intent.getExtras());
118 bundle = mQueue.poll(2 * TIMEOUT, TimeUnit.SECONDS);
/frameworks/base/packages/SystemUI/src/com/android/systemui/recents/model/
H A DRecentsTaskLoader.java50 ConcurrentLinkedQueue<Task> mQueue = new ConcurrentLinkedQueue<Task>(); field in class:TaskResourceLoadQueue
54 if (!mQueue.contains(t)) {
55 mQueue.add(t);
67 return mQueue.poll();
72 mQueue.remove(t);
77 mQueue.clear();
82 return mQueue.isEmpty();
/frameworks/base/services/backup/java/com/android/server/backup/
H A DBackupManagerService.java2651 ArrayList<BackupRequest> mQueue; field in class:BackupManagerService.PerformBackupTask
2743 mQueue = (ArrayList<BackupRequest>) mOriginalQueue.clone();
2749 for (int i = 0; i < mQueue.size(); i++) {
2750 if (PACKAGE_MANAGER_SENTINEL.equals(mQueue.get(i).packageName)) {
2754 mQueue.remove(i);
2759 if (DEBUG) Slog.v(TAG, "Beginning backup of " + mQueue.size() + " targets");
2830 addBackupTrace("invoke q=" + mQueue.size());
2834 if (mQueue.isEmpty()) {
2841 BackupRequest request = mQueue.get(0);
2842 mQueue
9073 HashSet<String> mQueue; field in class:BackupManagerService.PerformInitializeTask
[all...]
/frameworks/base/services/core/java/com/android/server/media/
H A DMediaSessionRecord.java107 private ParceledListSlice mQueue; field in class:MediaSessionRecord
452 + (mQueue == null ? 0 : mQueue.getList().size()));
536 cb.onQueueChanged(mQueue);
806 mQueue = queue;
1303 return mQueue;

Completed in 736 milliseconds

12