| /frameworks/base/core/java/android/os/ |
| D | Looper.java | 60 final MessageQueue mQueue; field in Looper
116 final MessageQueue queue = me.mQueue; in loop()
185 return myLooper().mQueue; in myQueue()
189 mQueue = new MessageQueue(quitAllowed); in Looper()
200 mQueue.quit(); in quit()
227 return mQueue.enqueueSyncBarrier(SystemClock.uptimeMillis()); in postSyncBarrier()
242 mQueue.removeSyncBarrier(token); in removeSyncBarrier()
254 return mQueue; in getQueue()
262 pw.println("mQueue=" + ((mQueue != null) ? mQueue : "(null")); in dump()
263 if (mQueue != null) { in dump()
[all …]
|
| D | Handler.java | 124 mQueue = mLooper.mQueue; in Handler()
148 mQueue = mLooper.mQueue; in Handler()
157 mQueue = looper.mQueue; in Handler()
167 mQueue = looper.mQueue; in Handler()
359 mQueue.removeMessages(this, r, null); in removeCallbacks()
369 mQueue.removeMessages(this, r, token); in removeCallbacks()
470 MessageQueue queue = mQueue; in sendMessageAtTime()
498 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue()
516 mQueue.removeMessages(this, what, null); in removeMessages()
525 mQueue.removeMessages(this, what, object); in removeMessages()
[all …]
|
| /frameworks/av/media/libstagefright/ |
| D | TimedEventQueue.cpp | 78 mQueue.clear(); in stop()
106 List<QueueItem>::iterator it = mQueue.begin(); in postTimedEvent()
107 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) { in postTimedEvent()
115 if (it == mQueue.begin()) { in postTimedEvent()
119 mQueue.insert(it, item); in postTimedEvent()
159 List<QueueItem>::iterator it = mQueue.begin(); in cancelEvents()
160 while (it != mQueue.end()) { in cancelEvents()
166 if (it == mQueue.begin()) { in cancelEvents()
173 it = mQueue.erase(it); in cancelEvents()
213 while (mQueue.empty()) { in threadEntry()
[all …]
|
| D | AwesomePlayer.cpp | 220 mQueue.stop(); in ~AwesomePlayer()
229 mQueue.cancelEvent(mVideoEvent->eventID()); in cancelPlayerEvents()
231 mQueue.cancelEvent(mVideoLagEvent->eventID()); in cancelPlayerEvents()
235 mQueue.cancelEvent(mStreamDoneEvent->eventID()); in cancelPlayerEvents()
237 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID()); in cancelPlayerEvents()
240 mQueue.cancelEvent(mBufferingEvent->eventID()); in cancelPlayerEvents()
1831 mQueue.postEventWithDelay(mVideoEvent, delayUs < 0 ? 10000 : delayUs); in postVideoEvent_l()
1841 mQueue.postEvent(mStreamDoneEvent); in postStreamDoneEvent_l()
1849 mQueue.postEventWithDelay(mBufferingEvent, 1000000ll); in postBufferingEvent_l()
1857 mQueue.postEventWithDelay(mVideoLagEvent, 1000000ll); in postVideoLagEvent_l()
[all …]
|
| /frameworks/av/media/libmediaplayerservice/nuplayer/ |
| D | NuPlayerStreamListener.cpp | 63 mQueue.push_back(entry); in queueBuffer()
84 mQueue.push_back(entry); in issueCommand()
107 if (mQueue.empty()) { in read()
113 QueueEntry *entry = &*mQueue.begin(); in read()
119 mQueue.erase(mQueue.begin()); in read()
130 mQueue.erase(mQueue.begin()); in read()
157 mQueue.erase(mQueue.begin()); in read()
|
| D | NuPlayerStreamListener.h | 65 List<QueueEntry> mQueue; member
|
| /frameworks/base/core/java/android/speech/tts/ |
| D | AudioPlaybackHandler.java | 27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue = field in AudioPlaybackHandler
51 mQueue.put(item); in enqueue()
80 return (mQueue.peek() != null) || (mCurrentWorkItem != null); in isSpeaking()
96 mQueue.clear(); in removeAllMessages()
103 Iterator<PlaybackQueueItem> it = mQueue.iterator(); in removeWorkItemsFor()
123 item = mQueue.take(); in run()
|
| /frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
| D | AwaitableCompletionListener.java | 33 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); field in AwaitableCompletionListener
38 mQueue.put(new Object()); in onCompletion()
49 if (mQueue.poll(timeout, unit) == null) { in awaitOneCallback()
55 if (mQueue.peek() != null) { in assertNoMoreCallbacks()
|
| D | AwaitableErrorListener.java | 31 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); field in AwaitableErrorListener
46 mQueue.put(new Object()); in addAnObjectToTheQueue()
57 if (mQueue.poll(timeout, unit) == null) { in awaitOneCallback()
63 if (mQueue.peek() != null) { in assertNoMoreCallbacks()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/tablet/ |
| D | TabletTicker.java | 73 private StatusBarNotification[] mQueue = new StatusBarNotification[QUEUE_LENGTH]; field in TabletTicker
94 + " mQueuePos=" + mQueuePos + " mQueue=" + Arrays.toString(mQueue)); in add()
101 mQueue[mQueuePos] = notification; in add()
130 mQueue[i] = mQueue[i+1]; in remove()
133 mQueue[QUEUE_LENGTH-1] = null; in remove()
148 mQueue[i] = null; in halt()
197 mCurrentNotification = mQueue[0]; in dequeue()
199 Slog.d(TAG, "dequeue mQueuePos=" + mQueuePos + " mQueue=" + Arrays.toString(mQueue)); in dequeue()
204 mQueue[i] = mQueue[i+1]; in dequeue()
207 mQueue[N] = null; in dequeue()
|
| /frameworks/native/libs/gui/ |
| D | BufferQueue.cpp | 227 mQueue.clear(); in setBufferCount()
265 value = (mQueue.size() >= 2); in query()
347 if (!mQueue.isEmpty() && numberOfBuffersNeedsToChange) { in dequeueBuffer()
594 mQueue.push_back(buf); in queueBuffer()
601 if (mQueue.empty()) { in queueBuffer()
602 mQueue.push_back(buf); in queueBuffer()
609 Fifo::iterator front(mQueue.begin()); in queueBuffer()
641 mQueue.size()); in queueBuffer()
643 ATRACE_INT(mConsumerName.string(), mQueue.size()); in queueBuffer()
705 mQueue.size()); in connect()
[all …]
|
| /frameworks/native/services/surfaceflinger/ |
| D | MessageQueue.cpp | 54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); in signalRefresh()
60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); in signalInvalidate()
68 mQueue.mFlinger->onMessageReceived(message.what); in handleMessage()
72 mQueue.mFlinger->onMessageReceived(message.what); in handleMessage()
|
| D | MessageQueue.h | 68 MessageQueue& mQueue; variable
71 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } in Handler()
|
| /frameworks/support/volley/src/com/android/volley/ |
| D | NetworkDispatcher.java | 32 private final BlockingQueue<Request> mQueue; field in NetworkDispatcher
54 mQueue = queue; in NetworkDispatcher()
75 request = mQueue.take(); in run()
|
| /frameworks/av/media/libstagefright/mpeg2ts/ |
| D | ATSParser.cpp | 123 ElementaryStreamQueue *mQueue; member
433 mQueue(NULL) { in Stream()
436 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::H264); in Stream()
439 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC); in Stream()
443 mQueue = new ElementaryStreamQueue( in Stream()
449 mQueue = new ElementaryStreamQueue( in Stream()
454 mQueue = new ElementaryStreamQueue( in Stream()
464 if (mQueue != NULL) { in Stream()
471 delete mQueue; in ~Stream()
472 mQueue = NULL; in ~Stream()
[all …]
|
| D | MPEG2PSExtractor.cpp | 62 ElementaryStreamQueue *mQueue; member
538 mQueue(NULL) { in Track()
569 mQueue = new ElementaryStreamQueue(mode); in Track()
576 delete mQueue; in ~Track()
577 mQueue = NULL; in ~Track()
630 if (mQueue == NULL) { in appendPESData()
641 status_t err = mQueue->appendData(data, size, timeUs); in appendPESData()
648 while ((accessUnit = mQueue->dequeueAccessUnit()) != NULL) { in appendPESData()
650 sp<MetaData> meta = mQueue->getFormat(); in appendPESData()
658 } else if (mQueue->getFormat() != NULL) { in appendPESData()
|
| /frameworks/av/media/libstagefright/rtsp/ |
| D | ARTPSource.cpp | 107 mQueue.push_back(buffer); in queuePacket()
144 List<sp<ABuffer> >::iterator it = mQueue.begin(); in queuePacket()
145 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) { in queuePacket()
149 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) { in queuePacket()
154 mQueue.insert(it, buffer); in queuePacket()
|
| D | ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } in queue()
54 List<sp<ABuffer> > mQueue; member
|
| /frameworks/base/tools/layoutlib/bridge/src/android/animation/ |
| D | AnimationThread.java | 70 private Queue<MessageBundle> mQueue = new PriorityQueue<MessageBundle>(); field in AnimationThread
119 MessageBundle bundle = mQueue.poll(); in run()
162 } while (mListener.isCanceled() == false && mQueue.size() > 0); in run()
|
| /frameworks/av/media/libstagefright/omx/ |
| D | OMX.cpp | 74 List<omx_message> mQueue; member
112 mQueue.push_back(msg); in post()
130 while (!mDone && mQueue.empty()) { in loop()
138 msg = *mQueue.begin(); in loop()
139 mQueue.erase(mQueue.begin()); in loop()
|
| D | SimpleSoftOMXComponent.cpp | 374 port->mQueue.push_back(buffer); in onMessageReceived()
479 port->mQueue.clear(); in onPortEnable()
528 port->mQueue.clear(); in onPortFlush()
636 return mPorts.editItemAt(portIndex).mQueue; in getPortQueue()
|
| /frameworks/av/libvideoeditor/lvpp/ |
| D | PreviewPlayer.cpp | 139 mQueue.stop(); in ~PreviewPlayer()
154 mQueue.cancelEvent(mVideoEvent->eventID()); in cancelPlayerEvents_l()
156 mQueue.cancelEvent(mStreamDoneEvent->eventID()); in cancelPlayerEvents_l()
158 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID()); in cancelPlayerEvents_l()
160 mQueue.cancelEvent(mVideoLagEvent->eventID()); in cancelPlayerEvents_l()
163 mQueue.cancelEvent(mProgressCbEvent->eventID()); in cancelPlayerEvents_l()
1146 mQueue.start(); in prepareAsync_l()
1154 mQueue.postEvent(mAsyncPrepareEvent); in prepareAsync_l()
1344 mQueue.postEvent(mProgressCbEvent); in postProgressCallbackEvent_l()
1369 mQueue.postEvent(mOverlayUpdateEvent); in postOverlayUpdateEvent_l()
[all …]
|
| /frameworks/av/media/libaah_rtp/ |
| D | aah_tx_player.cpp | 109 mQueue.stop(); in ~AAH_TXPlayer()
117 mQueue.cancelEvent(mBufferingEvent->eventID()); in cancelPlayerEvents()
120 mQueue.cancelEvent(mPumpAudioEvent->eventID()); in cancelPlayerEvents()
237 mQueue.start(); in prepareAsync_l()
245 mQueue.postEvent(mAsyncPrepareEvent); in prepareAsync_l()
893 mQueue.postEventWithDelay(mBufferingEvent, 1000000ll); in postBufferingEvent_l()
901 mQueue.postEventWithDelay(mPumpAudioEvent, delayUs < 0 ? 10000 : delayUs); in postPumpAudioEvent_l()
|
| /frameworks/native/opengl/libs/EGL/ |
| D | eglApi.cpp | 738 thread->mQueue.push_back(sync); in queueSync()
741 ATRACE_INT("GPU Frames Outstanding", thread->mQueue.size()); in queueSync()
753 while (mQueue.isEmpty()) { in threadLoop()
756 sync = mQueue[0]; in threadLoop()
773 mQueue.removeAt(0); in threadLoop()
775 ATRACE_INT("GPU Frames Outstanding", mQueue.size()); in threadLoop()
782 Vector<EGLSyncKHR> mQueue; member in FrameCompletionThread
|
| /frameworks/av/media/libstagefright/include/ |
| D | TimedEventQueue.h | 112 List<QueueItem> mQueue; member
|