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

12

/frameworks/base/core/java/android/os/
H A DLooper.java60 final MessageQueue mQueue; field in class:Looper
116 final MessageQueue queue = me.mQueue;
185 return myLooper().mQueue;
189 mQueue = new MessageQueue(quitAllowed);
200 mQueue.quit();
227 return mQueue.enqueueSyncBarrier(SystemClock.uptimeMillis());
242 mQueue.removeSyncBarrier(token);
254 return mQueue;
262 pw.println("mQueue=" + ((mQueue !
[all...]
H A DHandler.java200 mQueue = mLooper.mQueue;
226 mQueue = looper.mQueue;
471 mQueue.removeMessages(this, r, null);
481 mQueue.removeMessages(this, r, token);
580 MessageQueue queue = mQueue;
583 this + " sendMessageAtTime() called with no mQueue");
603 MessageQueue queue = mQueue;
606 this + " sendMessageAtTime() called with no mQueue");
728 final MessageQueue mQueue; field in class:Handler
[all...]
/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/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/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());
157 mQueue.erase(mQueue
[all...]
H A DNuPlayerStreamListener.h65 List<QueueEntry> mQueue; member in struct:android::NuPlayer::NuPlayerStreamListener
/frameworks/av/media/libstagefright/
H A DTimedEventQueue.cpp79 mQueue.clear();
107 List<QueueItem>::iterator it = mQueue.begin();
108 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) {
116 if (it == mQueue.begin()) {
120 mQueue.insert(it, item);
160 List<QueueItem>::iterator it = mQueue.begin();
161 while (it != mQueue.end()) {
167 if (it == mQueue.begin()) {
174 it = mQueue.erase(it);
206 while (mQueue
[all...]
H A DAwesomePlayer.cpp221 mQueue.stop();
230 mQueue.cancelEvent(mVideoEvent->eventID());
232 mQueue.cancelEvent(mVideoLagEvent->eventID());
236 mQueue.cancelEvent(mStreamDoneEvent->eventID());
238 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID());
241 mQueue.cancelEvent(mBufferingEvent->eventID());
1846 mQueue.postEventWithDelay(mVideoEvent, delayUs < 0 ? 10000 : delayUs);
1856 mQueue.postEvent(mStreamDoneEvent);
1864 mQueue.postEventWithDelay(mBufferingEvent, 1000000ll);
1872 mQueue
[all...]
/frameworks/support/volley/src/com/android/volley/
H A DNetworkDispatcher.java34 private final BlockingQueue<Request> mQueue; field in class:NetworkDispatcher
56 mQueue = queue;
78 request = mQueue.take();
/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
95 + " mQueuePos=" + mQueuePos + " mQueue=" + Arrays.toString(mQueue));
102 mQueue[mQueuePos] = notification;
131 mQueue[i] = mQueue[i+1];
134 mQueue[QUEUE_LENGTH-1] = null;
149 mQueue[i] = null;
198 mCurrentNotification = mQueue[0];
200 Slog.d(TAG, "dequeue mQueuePos=" + mQueuePos + " mQueue
[all...]
/frameworks/native/services/surfaceflinger/
H A DMessageQueue.cpp54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH));
60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE));
68 mQueue.mFlinger->onMessageReceived(message.what);
72 mQueue.mFlinger->onMessageReceived(message.what);
H A DMessageQueue.h68 MessageQueue& mQueue; member in class:android::MessageQueue::Handler
71 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
/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
H A DARTPSource.cpp110 mQueue.push_back(buffer);
147 List<sp<ABuffer> >::iterator it = mQueue.begin();
148 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) {
152 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) {
157 mQueue.insert(it, buffer);
/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/libs/gui/
H A DBufferQueue.cpp223 value = (mQueue.size() >= 2);
533 mQueue.push_back(buf);
540 if (mQueue.empty()) {
541 mQueue.push_back(buf);
548 Fifo::iterator front(mQueue.begin());
581 mQueue.size());
583 ATRACE_INT(mConsumerName.string(), mQueue.size());
647 mQueue.size());
719 Fifo::const_iterator i(mQueue.begin());
720 while (i != mQueue
[all...]
/frameworks/av/media/libstagefright/mpeg2ts/
H A DATSParser.cpp136 ElementaryStreamQueue *mQueue; member in struct:android::ATSParser::Stream
464 mQueue(NULL) {
467 mQueue = new ElementaryStreamQueue(
473 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC);
477 mQueue = new ElementaryStreamQueue(
483 mQueue = new ElementaryStreamQueue(
488 mQueue = new ElementaryStreamQueue(
493 mQueue = new ElementaryStreamQueue(
503 if (mQueue != NULL) {
510 delete 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/av/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());
H A DSimpleSoftOMXComponent.cpp374 port->mQueue.push_back(buffer);
479 port->mQueue.clear();
528 port->mQueue.clear();
636 return mPorts.editItemAt(portIndex).mQueue;
/frameworks/av/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/av/libvideoeditor/lvpp/
H A DPreviewPlayer.cpp139 mQueue.stop();
154 mQueue.cancelEvent(mVideoEvent->eventID());
156 mQueue.cancelEvent(mStreamDoneEvent->eventID());
158 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID());
160 mQueue.cancelEvent(mVideoLagEvent->eventID());
163 mQueue.cancelEvent(mProgressCbEvent->eventID());
1146 mQueue.start();
1154 mQueue.postEvent(mAsyncPrepareEvent);
1344 mQueue.postEvent(mProgressCbEvent);
1369 mQueue
[all...]
/frameworks/av/services/camera/libcameraservice/
H A DCamera2Device.cpp1397 for (s = mQueue.begin(); s != mQueue.end(); s++) {
1405 mQueue.clear();
1421 mQueue.push_back(entry);
1456 if (stream->mQueue.empty()) {
1461 QueueEntry &entry = *(stream->mQueue.begin());
1466 stream->mQueue.erase(stream->mQueue.begin());

Completed in 293 milliseconds

12