/frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
H A D | AwaitableCompletionListener.java | 33 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 D | AwaitableErrorListener.java | 31 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 D | Handler.java | 124 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 D | Looper.java | 59 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 D | NuPlayerStreamListener.cpp | 63 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 D | NuPlayerStreamListener.h | 65 List<QueueEntry> mQueue; member in struct:android::NuPlayer::NuPlayerStreamListener
|
/frameworks/base/media/libstagefright/ |
H A D | TimedEventQueue.cpp | 84 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 D | SurfaceMediaSource.cpp | 67 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 D | AwesomePlayer.cpp | 219 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 D | TabletTicker.java | 73 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 D | AnimationThread.java | 70 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 D | ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } 54 List<sp<ABuffer> > mQueue; member in struct:android::ARTPSource
|
H A D | ARTPSource.cpp | 107 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 D | AudioPlaybackHandler.java | 46 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 D | ATSParser.cpp | 115 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 D | MPEG2PSExtractor.cpp | 62 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 D | SurfaceTexture.cpp | 239 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 D | OMX.cpp | 74 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 D | TimedEventQueue.h | 112 List<QueueItem> mQueue; member in struct:android::TimedEventQueue
|
H A D | SimpleSoftOMXComponent.h | 52 List<BufferInfo *> mQueue; member in struct:android::SimpleSoftOMXComponent::PortInfo
|
/frameworks/base/media/libstagefright/timedtext/ |
H A D | TimedTextPlayer.h | 77 TimedEventQueue *mQueue; member in class:android::TimedTextPlayer
|
H A D | TimedTextPlayer.cpp | 71 mQueue(queue), 280 mQueue->postEventWithDelay(mTextEvent, delayUs < 0 ? 10000 : delayUs); 284 mQueue->cancelEvent(mTextEvent->eventID());
|
/frameworks/media/libvideoeditor/lvpp/ |
H A D | PreviewPlayerBase.cpp | 207 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 D | PreviewPlayer.cpp | 122 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 D | SurfaceTexture.h | 245 // 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
|