/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 | Looper.java | 60 final MessageQueue mQueue; field in class:Looper 115 final MessageQueue queue = me.mQueue; 184 return myLooper().mQueue; 188 mQueue = new MessageQueue(quitAllowed); 217 mQueue.quit(false); 233 mQueue.quit(true); 260 return mQueue.enqueueSyncBarrier(SystemClock.uptimeMillis()); 275 mQueue.removeSyncBarrier(token); 287 return mQueue; 297 return mQueue [all...] |
H A D | Handler.java | 203 mQueue = mLooper.mQueue; 229 mQueue = looper.mQueue; 479 mQueue.removeMessages(this, r, null); 489 mQueue.removeMessages(this, r, token); 588 MessageQueue queue = mQueue; 591 this + " sendMessageAtTime() called with no mQueue"); 611 MessageQueue queue = mQueue; 614 this + " sendMessageAtTime() called with no mQueue"); 736 final MessageQueue mQueue; field in class:Handler [all...] |
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
H A D | OutputPort.java | 39 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 D | InputPort.java | 43 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 D | FrameManager.java | 161 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/base/core/java/android/speech/tts/ |
H A D | AudioPlaybackHandler.java | 27 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/libstagefright/ |
H A D | TimedEventQueue.cpp | 94 mQueue.clear(); 122 List<QueueItem>::iterator it = mQueue.begin(); 123 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) { 132 if (it == mQueue.begin()) { 140 mQueue.insert(it, item); 180 List<QueueItem>::iterator it = mQueue.begin(); 181 while (it != mQueue.end()) { 187 if (it == mQueue.begin()) { 197 it = mQueue.erase(it); 229 while (mQueue [all...] |
/frameworks/av/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/packages/DocumentsUI/src/com/android/documentsui/ |
H A D | ProviderExecutor.java | 54 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/native/services/surfaceflinger/ |
H A D | MessageQueue.cpp | 54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); 60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); 66 mQueue.mLooper->sendMessage(this, Message(MessageQueue::TRANSACTION)); 74 mQueue.mFlinger->onMessageReceived(message.what); 78 mQueue.mFlinger->onMessageReceived(message.what); 82 mQueue.mFlinger->onMessageReceived(message.what);
|
H A D | MessageQueue.h | 69 MessageQueue& mQueue; member in class:android::MessageQueue::Handler 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
|
/frameworks/volley/src/com/android/volley/ |
H A D | NetworkDispatcher.java | 36 private final BlockingQueue<Request> mQueue; field in class:NetworkDispatcher 58 mQueue = queue; 80 request = mQueue.take();
|
/frameworks/av/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 | 110 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/av/media/libstagefright/include/ |
H A D | TimedEventQueue.h | 63 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 D | SimpleSoftOMXComponent.h | 52 List<BufferInfo *> mQueue; member in struct:android::SimpleSoftOMXComponent::PortInfo
|
/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 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 D | BufferQueue.cpp | 219 value = (mQueue.size() >= 2); 570 if (mQueue.empty()) { 573 mQueue.push_back(item); 578 Fifo::iterator front(mQueue.begin()); 590 mQueue.push_back(item); 599 mQueue.size()); 601 ATRACE_INT(mConsumerName.string(), mQueue.size()); 669 if (mQueue.size() > (size_t) maxBufferCount) { 671 ST_LOGV("queue size is %d, waiting", mQueue.size()); 683 output->inflate(mDefaultWidth, mDefaultHeight, mTransformHint, mQueue [all...] |
/frameworks/av/media/libstagefright/mpeg2ts/ |
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...] |
H A D | ATSParser.cpp | 136 ElementaryStreamQueue *mQueue; member in struct:android::ATSParser::Stream 476 mQueue(NULL) { 479 mQueue = new ElementaryStreamQueue( 485 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC); 489 mQueue = new ElementaryStreamQueue( 495 mQueue = new ElementaryStreamQueue( 500 mQueue = new ElementaryStreamQueue( 505 mQueue = new ElementaryStreamQueue( 515 if (mQueue != NULL) { 522 delete mQueue; [all...] |
/frameworks/av/libvideoeditor/lvpp/ |
H A D | PreviewPlayer.cpp | 139 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/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());
|