/frameworks/av/media/libstagefright/include/ |
TimedEventQueue.h | 63 PMDeathRecipient(TimedEventQueue *queue) : mQueue(queue) {} 73 TimedEventQueue *mQueue; 131 List<QueueItem> mQueue;
|
SimpleSoftOMXComponent.h | 52 List<BufferInfo *> mQueue;
|
/frameworks/volley/src/com/android/volley/ |
NetworkDispatcher.java | 36 private final BlockingQueue<Request> mQueue; 58 mQueue = queue; 80 request = mQueue.take();
|
/packages/apps/Gallery/src/com/android/camera/gallery/ |
ImageListUber.java | 39 private final PriorityQueue<MergeSlot> mQueue; 55 mQueue = new PriorityQueue<MergeSlot>(4, 63 mQueue.clear(); 67 if (slot.next()) mQueue.add(slot); 136 if (slot.next()) mQueue.add(slot); 139 if (slot.next()) mQueue.add(slot); 144 MergeSlot slot = mQueue.poll(); 234 if (slot.next()) mQueue.add(slot); 237 if (slot.next()) mQueue.add(slot);
|
/frameworks/av/media/libstagefright/rtsp/ |
ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } 54 List<sp<ABuffer> > mQueue;
|
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/native/services/surfaceflinger/ |
MessageQueue.h | 69 MessageQueue& mQueue; 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
|
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
FrameManager.java | 161 private PriorityQueue<Backing> mQueue; 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/tools/layoutlib/bridge/src/android/animation/ |
AnimationThread.java | 70 private Queue<MessageBundle> mQueue = new PriorityQueue<MessageBundle>(); 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/ |
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.size()) [all...] |
/frameworks/av/media/libmediaplayerservice/nuplayer/ |
NuPlayerStreamListener.h | 65 List<QueueEntry> mQueue;
|
/packages/apps/Calendar/src/com/android/calendar/ |
EventLoader.java | 161 LinkedBlockingQueue<LoadRequest> mQueue; 165 mQueue = queue; 171 mQueue.put(new ShutdownRequest()); 186 LoadRequest request = mQueue.take(); 190 while (!mQueue.isEmpty()) { 195 request = mQueue.take();
|
/packages/services/Telephony/src/com/android/phone/ |
CallHandlerServiceProxy.java | 71 private List<QueueParams> mQueue; // Guarded by mServiceAndQueueLock 438 if (mQueue != null) { 439 mQueue.clear(); 524 if (mQueue == null) { 525 mQueue = Lists.newArrayList(); 527 return mQueue; 548 if (mQueue != null) { 549 for (QueueParams params : mQueue) { 565 mQueue.clear(); 566 mQueue = null [all...] |
/frameworks/av/media/libstagefright/mpeg2ts/ |
MPEG2PSExtractor.cpp | 62 ElementaryStreamQueue *mQueue; 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->getFormat() != NULL) [all...] |
ATSParser.cpp | 136 ElementaryStreamQueue *mQueue; 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/ |
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()); [all...] |
/frameworks/av/media/libstagefright/omx/ |
OMX.cpp | 74 List<omx_message> mQueue; 112 mQueue.push_back(msg); 130 while (!mDone && mQueue.empty()) { 138 msg = *mQueue.begin(); 139 mQueue.erase(mQueue.begin());
|
SimpleSoftOMXComponent.cpp | 374 port->mQueue.push_back(buffer); 483 port->mQueue.clear(); 532 port->mQueue.clear(); 644 return mPorts.editItemAt(portIndex).mQueue;
|
/cts/tests/tests/hardware/src/android/hardware/camera2/cts/ |
CameraCaptureResultTest.java | 216 LinkedBlockingQueue<CaptureResult> mQueue = new LinkedBlockingQueue<CaptureResult>(); 227 mQueue.put(result); 245 CaptureResult result = mQueue.poll(timeout, TimeUnit.MILLISECONDS);
|
/frameworks/av/media/libstagefright/ |
AwesomePlayer.cpp | 235 mQueue.stop(); 244 mQueue.cancelEvent(mVideoEvent->eventID()); 246 mQueue.cancelEvent(mVideoLagEvent->eventID()); 250 mQueue.cancelEvent(mAudioTearDownEvent->eventID()); 255 mQueue.cancelEvent(mStreamDoneEvent->eventID()); 257 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID()); 260 mQueue.cancelEvent(mBufferingEvent->eventID()); 1067 mQueue.cancelEvent(mAudioTearDownEvent->eventID()); [all...] |
/frameworks/native/include/gui/ |
BufferQueue.h | 527 // mQueue is a FIFO of queued buffers used in synchronous mode 529 Fifo mQueue;
|
/packages/apps/VideoEditor/src/com/android/videoeditor/ |
VideoEditorActivity.java | [all...] |
/frameworks/native/opengl/libs/EGL/ |
eglApi.cpp | [all...] |
/frameworks/webview/chromium/java/com/android/webview/chromium/ |
WebViewChromium.java | 91 mQueue = new ConcurrentLinkedQueue<Runnable>(); 95 mQueue.add(task); 107 if (mQueue == null || mQueue.isEmpty()) { 111 Runnable task = mQueue.poll(); 114 task = mQueue.poll(); 118 private Queue<Runnable> mQueue; [all...] |
/packages/apps/LegacyCamera/src/com/android/camera/ |
Camera.java | [all...] |