Searched refs:mQueue (Results 1 - 25 of 32) sorted by relevance

12

/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/base/core/java/android/os/
H A DHandler.java124 mQueue = mLooper.mQueue;
148 mQueue = mLooper.mQueue;
157 mQueue = looper.mQueue;
167 mQueue = looper.mQueue;
359 mQueue.removeMessages(this, r, null);
369 mQueue
608 final MessageQueue mQueue; field in class:Handler
[all...]
H A DLooper.java59 final MessageQueue mQueue; field in class:Looper
88 myLooper().mQueue.mQuitAllowed = false;
110 MessageQueue queue = me.mQueue;
193 return myLooper().mQueue;
197 mQueue = new MessageQueue();
207 mQueue.enqueueMessage(msg, 0);
219 return mQueue;
227 pw.println("mQueue=" + ((mQueue != null) ? mQueue
[all...]
/frameworks/base/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());
157 mQueue.erase(mQueue
[all...]
H A DNuPlayerStreamListener.h65 List<QueueEntry> mQueue; member in struct:android::NuPlayer::NuPlayerStreamListener
/frameworks/base/media/libstagefright/
H A DTimedEventQueue.cpp84 mQueue.clear();
112 List<QueueItem>::iterator it = mQueue.begin();
113 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) {
121 if (it == mQueue.begin()) {
125 mQueue.insert(it, item);
165 List<QueueItem>::iterator it = mQueue.begin();
166 while (it != mQueue.end()) {
172 if (it == mQueue.begin()) {
179 it = mQueue.erase(it);
236 while (mQueue
[all...]
H A DSurfaceMediaSource.cpp67 return mQueue.size();
146 mQueue.clear();
217 while (!mQueue.isEmpty()) {
233 // here we're guaranteed that mQueue is empty
499 mQueue.push_back(bufIndex);
501 mNumFramesReceived, bufIndex, mQueue.size(),
505 if (mQueue.empty()) {
506 mQueue.push_back(bufIndex);
508 Fifo::iterator front(mQueue.begin());
547 if (mSynchronousMode || mQueue
[all...]
H A DAwesomePlayer.cpp219 mQueue.stop();
228 mQueue.cancelEvent(mVideoEvent->eventID());
230 mQueue.cancelEvent(mVideoLagEvent->eventID());
234 mQueue.cancelEvent(mStreamDoneEvent->eventID());
236 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID());
239 mQueue.cancelEvent(mBufferingEvent->eventID());
1362 mTextPlayer = new TimedTextPlayer(this, mListener, &mQueue);
1809 mQueue.postEventWithDelay(mVideoEvent, delayUs < 0 ? 10000 : delayUs);
1819 mQueue.postEvent(mStreamDoneEvent);
1827 mQueue
[all...]
/frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/tablet/
H A DTabletTicker.java73 private StatusBarNotification[] mQueue = new StatusBarNotification[QUEUE_LENGTH]; field in class:TabletTicker
94 + " mQueuePos=" + mQueuePos + " mQueue=" + Arrays.toString(mQueue));
101 mQueue[mQueuePos] = notification;
130 mQueue[i] = mQueue[i+1];
133 mQueue[QUEUE_LENGTH-1] = null;
148 mQueue[i] = null;
197 mCurrentNotification = mQueue[0];
199 Slog.d(TAG, "dequeue mQueuePos=" + mQueuePos + " mQueue
[all...]
/frameworks/base/tools/layoutlib/bridge/src/android/animation/
H A DAnimationThread.java70 private Queue<MessageBundle> mQueue = new PriorityQueue<MessageBundle>(); field in class:AnimationThread
91 mQueue.add(new MessageBundle(handler, msg, uptimeMillis));
113 MessageBundle bundle = mQueue.poll();
142 // the next message, so mQueue will have another one.
156 } while (mListener.isCanceled() == false && mQueue.size() > 0);
/frameworks/base/media/libstagefright/rtsp/
H A DARTPSource.h44 List<sp<ABuffer> > *queue() { return &mQueue; }
54 List<sp<ABuffer> > mQueue; member in struct:android::ARTPSource
H A DARTPSource.cpp107 mQueue.push_back(buffer);
144 List<sp<ABuffer> >::iterator it = mQueue.begin();
145 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) {
149 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) {
154 mQueue.insert(it, buffer);
/frameworks/base/core/java/android/speech/tts/
H A DAudioPlaybackHandler.java46 private final PriorityBlockingQueue<ListEntry> mQueue = field in class:AudioPlaybackHandler
96 mQueue.add(new ListEntry(SYNTHESIS_DONE, token, HIGH_PRIORITY));
148 return (mQueue.peek() != null) || (mCurrentParams != null);
157 mQueue.add(new ListEntry(SHUTDOWN, null, HIGH_PRIORITY));
162 mQueue.add(new ListEntry(SYNTHESIS_START, token));
167 mQueue.add(new ListEntry(SYNTHESIS_DATA_AVAILABLE, token));
172 mQueue.add(new ListEntry(SYNTHESIS_DONE, token));
177 mQueue.add(new ListEntry(PLAY_AUDIO, token));
182 mQueue.add(new ListEntry(PLAY_SILENCE, token));
203 entry = mQueue
[all...]
/frameworks/base/media/libstagefright/mpeg2ts/
H A DATSParser.cpp115 ElementaryStreamQueue *mQueue; member in struct:android::ATSParser::Stream
402 mQueue(NULL) {
405 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::H264);
408 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC);
412 mQueue = new ElementaryStreamQueue(
418 mQueue = new ElementaryStreamQueue(
423 mQueue = new ElementaryStreamQueue(
433 if (mQueue != NULL) {
440 delete mQueue;
441 mQueue
[all...]
H A DMPEG2PSExtractor.cpp62 ElementaryStreamQueue *mQueue; member in struct:android::MPEG2PSExtractor::Track
538 mQueue(NULL) {
569 mQueue = new ElementaryStreamQueue(mode);
576 delete mQueue;
577 mQueue = NULL;
630 if (mQueue == NULL) {
641 status_t err = mQueue->appendData(data, size, timeUs);
648 while ((accessUnit = mQueue->dequeueAccessUnit()) != NULL) {
650 sp<MetaData> meta = mQueue->getFormat();
658 } else if (mQueue
[all...]
/frameworks/base/libs/gui/
H A DSurfaceTexture.cpp239 mQueue.clear();
324 if (!mQueue.isEmpty() && numberOfBuffersNeedsToChange) {
333 // here we're guaranteed that mQueue is empty
569 mQueue.push_back(buf);
576 if (mQueue.empty()) {
577 mQueue.push_back(buf);
584 Fifo::iterator front(mQueue.begin());
760 if (!mQueue.empty()) {
761 Fifo::iterator front(mQueue.begin());
839 mQueue
[all...]
/frameworks/base/media/libstagefright/omx/
H A DOMX.cpp74 List<omx_message> mQueue; member in struct:android::OMX::CallbackDispatcher
112 mQueue.push_back(msg);
130 while (!mDone && mQueue.empty()) {
138 msg = *mQueue.begin();
139 mQueue.erase(mQueue.begin());
/frameworks/base/media/libstagefright/include/
H A DTimedEventQueue.h112 List<QueueItem> mQueue; member in struct:android::TimedEventQueue
H A DSimpleSoftOMXComponent.h52 List<BufferInfo *> mQueue; member in struct:android::SimpleSoftOMXComponent::PortInfo
/frameworks/base/media/libstagefright/timedtext/
H A DTimedTextPlayer.h77 TimedEventQueue *mQueue; member in class:android::TimedTextPlayer
H A DTimedTextPlayer.cpp71 mQueue(queue),
280 mQueue->postEventWithDelay(mTextEvent, delayUs < 0 ? 10000 : delayUs);
284 mQueue->cancelEvent(mTextEvent->eventID());
/frameworks/media/libvideoeditor/lvpp/
H A DPreviewPlayerBase.cpp207 mQueue.stop();
216 mQueue.cancelEvent(mVideoEvent->eventID());
218 mQueue.cancelEvent(mStreamDoneEvent->eventID());
220 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID());
222 mQueue.cancelEvent(mVideoLagEvent->eventID());
226 mQueue.cancelEvent(mBufferingEvent->eventID());
1538 mQueue.postEventWithDelay(mVideoEvent, delayUs < 0 ? 10000 : delayUs);
1548 mQueue.postEvent(mStreamDoneEvent);
1556 mQueue.postEventWithDelay(mBufferingEvent, 1000000ll);
1564 mQueue
[all...]
H A DPreviewPlayer.cpp122 mQueue.stop();
133 mQueue.cancelEvent(mVideoEvent->eventID());
135 mQueue.cancelEvent(mStreamDoneEvent->eventID());
137 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID());
140 mQueue.cancelEvent(mProgressCbEvent->eventID());
1146 mQueue.start();
1154 mQueue.postEvent(mAsyncPrepareEvent);
1355 mQueue.postEvent(mProgressCbEvent);
1381 mQueue.postEvent(mOverlayUpdateEvent);
/frameworks/base/include/gui/
H A DSurfaceTexture.h245 // and EGLImage) for all slots except the head of mQueue
472 // mQueue is a FIFO of queued buffers used in synchronous mode
474 Fifo mQueue; member in class:android::SurfaceTexture

Completed in 522 milliseconds

12