Searched defs:mQueue (Results 1 - 25 of 30) sorted by relevance

12

/frameworks/av/media/libstagefright/rtsp/
H A DARTPSource.h44 List<sp<ABuffer> > *queue() { return &mQueue; }
54 List<sp<ABuffer> > mQueue; member in struct:android::ARTPSource
/frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/
H A DAwaitableCompletionListener.java33 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); field in class:AwaitableCompletionListener
38 mQueue.put(new Object());
49 if (mQueue.poll(timeout, unit) == null) {
55 if (mQueue.peek() != null) {
H A DAwaitableErrorListener.java31 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); field in class:AwaitableErrorListener
46 mQueue.put(new Object());
57 if (mQueue.poll(timeout, unit) == null) {
63 if (mQueue.peek() != null) {
/frameworks/av/media/libmediaplayerservice/nuplayer/
H A DNuPlayerStreamListener.h65 List<QueueEntry> mQueue; member in struct:android::NuPlayer::NuPlayerStreamListener
/frameworks/base/packages/DocumentsUI/src/com/android/documentsui/
H A DProviderExecutor.java54 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>(); field in class:ProviderExecutor
91 mQueue.add(command);
99 mQueue.add(command);
106 final Runnable command = mQueue.take();
/frameworks/volley/src/com/android/volley/
H A DNetworkDispatcher.java36 private final BlockingQueue<Request<?>> mQueue; field in class:NetworkDispatcher
58 mQueue = queue;
88 request = mQueue.take();
/frameworks/av/media/libstagefright/include/
H A DSimpleSoftOMXComponent.h52 List<BufferInfo *> mQueue; member in struct:android::SimpleSoftOMXComponent::PortInfo
H A DTimedEventQueue.h63 PMDeathRecipient(TimedEventQueue *queue) : mQueue(queue) {}
73 TimedEventQueue *mQueue; member in class:android::TimedEventQueue::PMDeathRecipient
131 List<QueueItem> mQueue; member in struct:android::TimedEventQueue
H A DAwesomePlayer.h152 TimedEventQueue mQueue; member in struct:android::AwesomePlayer
/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.h119 TaskQueue mQueue; member in class:android::uirenderer::renderthread::RenderThread
125 // both mQueue *and* mDisplayEventReceiver have been drained off all
/frameworks/base/tools/layoutlib/bridge/src/android/animation/
H A DAnimationThread.java70 private Queue<MessageBundle> mQueue = new PriorityQueue<MessageBundle>(); field in class:AnimationThread
96 mQueue.add(new MessageBundle(handler, msg, uptimeMillis));
119 MessageBundle bundle = mQueue.poll();
148 // the next message, so mQueue will have another one.
162 } while (mListener.isCanceled() == false && mQueue.size() > 0);
/frameworks/native/services/surfaceflinger/
H A DMessageQueue.h69 MessageQueue& mQueue; member in class:android::MessageQueue::Handler
72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
/frameworks/base/core/java/android/os/
H A DLooper.java59 final MessageQueue mQueue; field in class:Looper
114 final MessageQueue queue = me.mQueue;
183 return myLooper().mQueue;
187 mQueue = new MessageQueue(quitAllowed);
216 mQueue.quit(false);
232 mQueue.quit(true);
259 return mQueue.enqueueSyncBarrier(SystemClock.uptimeMillis());
274 mQueue.removeSyncBarrier(token);
286 return mQueue;
296 return mQueue
[all...]
H A DHandler.java203 mQueue = mLooper.mQueue;
229 mQueue = looper.mQueue;
483 mQueue.removeMessages(this, r, null);
493 mQueue.removeMessages(this, r, token);
593 MessageQueue queue = mQueue;
596 this + " sendMessageAtTime() called with no mQueue");
616 MessageQueue queue = mQueue;
619 this + " sendMessageAtTime() called with no mQueue");
742 final MessageQueue mQueue; field in class:Handler
[all...]
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
H A DOutputPort.java39 private FrameQueue mQueue = null; field in class:OutputPort
56 return mQueue == null || mQueue.canPush();
165 return mQueue;
169 mQueue = queue;
180 return mQueue != null;
188 if (mQueue != null) {
189 mQueue.clear();
H A DInputPort.java43 private FrameQueue mQueue = null; field in class:InputPort
178 if (mQueue == null) {
181 Frame frame = mQueue.pullFrame();
197 if (mQueue == null) {
200 return mQueue.peek();
208 return mQueue != null;
216 return mQueue != null && mQueue.canPull();
292 mQueue = queue;
297 return mQueue;
[all...]
H A DFrameManager.java161 private PriorityQueue<Backing> mQueue; field in class:FrameManager.PriorityBackingCache
164 mQueue = new PriorityQueue<Backing>(4, new Comparator<Backing>() {
174 for (Backing backing : mQueue) {
181 mQueue.remove(backing);
195 mQueue.add(backing);
203 mQueue.clear();
224 Backing dropped = mQueue.poll();
/frameworks/native/include/gui/
H A DBufferQueueCore.h177 // mQueue is a FIFO of queued buffers used in synchronous mode.
178 Fifo mQueue; member in class:android::BufferQueueCore
/frameworks/av/services/camera/libcameraservice/device2/
H A DCamera2Device.h324 List<QueueEntry> mQueue; member in class:android::Camera2Device::ReprocessStreamAdapter
/frameworks/base/tests/OneMedia/src/com/android/onemedia/
H A DPlayerSession.java48 protected ArrayList<MediaSession.QueueItem> mQueue; field in class:PlayerSession
64 mQueue = new ArrayList<MediaSession.QueueItem>();
121 mQueue.clear();
122 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11));
132 mSession.setQueue(mUseQueue ? mQueue : null);
155 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11));
/frameworks/av/media/libstagefright/mpeg2ts/
H A DMPEG2PSExtractor.cpp64 ElementaryStreamQueue *mQueue; member in struct:android::MPEG2PSExtractor::Track
541 mQueue(NULL) {
572 mQueue = new ElementaryStreamQueue(mode);
579 delete mQueue;
580 mQueue = NULL;
633 if (mQueue == NULL) {
644 status_t err = mQueue->appendData(data, size, timeUs);
651 while ((accessUnit = mQueue->dequeueAccessUnit()) != NULL) {
653 sp<MetaData> meta = mQueue->getFormat();
661 } else if (mQueue
[all...]
H A DATSParser.cpp142 ElementaryStreamQueue *mQueue; member in struct:android::ATSParser::Stream
497 mQueue(NULL) {
500 mQueue = new ElementaryStreamQueue(
506 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC);
510 mQueue = new ElementaryStreamQueue(
516 mQueue = new ElementaryStreamQueue(
521 mQueue = new ElementaryStreamQueue(
527 mQueue = new ElementaryStreamQueue(
537 if (mQueue != NULL) {
544 delete mQueue;
[all...]
/frameworks/av/media/libstagefright/omx/
H A DOMX.cpp76 List<omx_message> mQueue; member in struct:android::OMX::CallbackDispatcher
114 mQueue.push_back(msg);
132 while (!mDone && mQueue.empty()) {
140 msg = *mQueue.begin();
141 mQueue.erase(mQueue.begin());
/frameworks/base/packages/SystemUI/src/com/android/systemui/recents/model/
H A DRecentsTaskLoader.java47 ConcurrentLinkedQueue<Task> mQueue = new ConcurrentLinkedQueue<Task>(); field in class:TaskResourceLoadQueue
52 if (!mQueue.contains(t)) {
53 mQueue.add(t);
63 if (!mQueue.contains(t)) {
64 mQueue.add(t);
76 return mQueue.poll();
81 mQueue.remove(t);
86 mQueue.clear();
91 return mQueue.isEmpty();

Completed in 7661 milliseconds

12