| /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...] |
