| /frameworks/support/v7/recyclerview/tests/src/android/support/v7/util/ |
| D | MessageQueueTest.java | 34 MessageThreadUtil.MessageQueue mQueue; field in MessageQueueTest
38 mQueue = new MessageThreadUtil.MessageQueue(); in setUp()
44 mQueue.sendMessage(MessageThreadUtil.SyncQueueItem.obtainMessage( in allArguments()
47 MessageThreadUtil.SyncQueueItem msg = mQueue.next(); in allArguments()
59 mQueue.sendMessage(obtainMessage(1, 2)); in sendInOrder()
60 mQueue.sendMessage(obtainMessage(3, 4)); in sendInOrder()
61 mQueue.sendMessage(obtainMessage(5, 6)); in sendInOrder()
63 MessageThreadUtil.SyncQueueItem msg = mQueue.next(); in sendInOrder()
67 msg = mQueue.next(); in sendInOrder()
71 msg = mQueue.next(); in sendInOrder()
[all …]
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| D | InputPort.java | 43 private FrameQueue mQueue = null; field in InputPort
178 if (mQueue == null) { in pullFrame()
181 Frame frame = mQueue.pullFrame(); in pullFrame()
197 if (mQueue == null) { in peek()
200 return mQueue.peek(); in peek()
208 return mQueue != null; in isConnected()
216 return mQueue != null && mQueue.canPull(); in hasFrame()
292 mQueue = queue; in setQueue()
297 return mQueue; in getQueue()
301 if (mQueue != null) { in clear()
[all …]
|
| D | OutputPort.java | 39 private FrameQueue mQueue = null; field in OutputPort
56 return mQueue == null || mQueue.canPush(); in isAvailable()
165 return mQueue; in getQueue()
169 mQueue = queue; in setQueue()
180 return mQueue != null; in isOpen()
188 if (mQueue != null) { in clear()
189 mQueue.clear(); in clear()
|
| D | FrameManager.java | 161 private PriorityQueue<Backing> mQueue; field in FrameManager.PriorityBackingCache
164 mQueue = new PriorityQueue<Backing>(4, new Comparator<Backing>() { in PriorityBackingCache()
174 for (Backing backing : mQueue) { in fetchBacking()
181 mQueue.remove(backing); in fetchBacking()
195 mQueue.add(backing); in cacheBacking()
203 mQueue.clear(); in clear()
224 Backing dropped = mQueue.poll(); in reserve()
|
| /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()
166 mQueue.erase(mQueue.begin()); in read()
|
| /frameworks/base/core/java/android/os/ |
| D | Handler.java | 203 mQueue = mLooper.mQueue; in Handler()
229 mQueue = looper.mQueue; in Handler()
495 mQueue.removeMessages(this, r, null); in removeCallbacks()
505 mQueue.removeMessages(this, r, token); in removeCallbacks()
605 MessageQueue queue = mQueue; in sendMessageAtTime()
628 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue()
651 mQueue.removeMessages(this, what, null); in removeMessages()
660 mQueue.removeMessages(this, what, object); in removeMessages()
669 mQueue.removeCallbacksAndMessages(this, token); in removeCallbacksAndMessages()
677 return mQueue.hasMessages(this, what, null); in hasMessages()
[all …]
|
| D | Looper.java | 71 final MessageQueue mQueue; field in Looper
128 final MessageQueue queue = me.mQueue; in loop()
194 return myLooper().mQueue; in myQueue()
198 mQueue = new MessageQueue(quitAllowed); in Looper()
244 mQueue.quit(false); in quit()
260 mQueue.quit(true); in quitSafely()
278 return mQueue; in getQueue()
289 mQueue.dump(pw, prefix + " "); in dump()
|
| /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/ |
| D | ServiceResolveQueue.java | 29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>(); field in ServiceResolveQueue
64 if (mQueue.contains(newRequest)) return; in queueRequest()
65 mQueue.add(newRequest); in queueRequest()
73 mQueue.remove(newRequest); in removeRequest()
81 if (mQueue.isEmpty()) return; in makeNextRequest()
82 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
|
| /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/samsung/ |
| D | ServiceResolveQueue.java | 29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>(); field in ServiceResolveQueue
64 if (mQueue.contains(newRequest)) return; in queueRequest()
65 mQueue.add(newRequest); in queueRequest()
73 mQueue.remove(newRequest); in removeRequest()
81 if (mQueue.isEmpty()) return; in makeNextRequest()
82 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
|
| /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/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/xerox/ |
| D | ServiceResolver.java | 102 private final LinkedList<NsdServiceInfo> mQueue = new LinkedList<>(); field in ServiceResolver
108 if (mQueue.contains(serviceInfo)) return; in queueRequest()
109 mQueue.add(serviceInfo); in queueRequest()
116 mQueue.remove(serviceInfo); in removeRequest()
124 mQueue.clear(); in clearRequests()
131 if (mQueue.isEmpty()) return; in makeNextRequest()
132 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
137 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
|
| /frameworks/support/v7/recyclerview/src/android/support/v7/util/ |
| D | MessageThreadUtil.java | 32 final MessageQueue mQueue = new MessageQueue(); in getMainThreadProxy()
55 mQueue.sendMessage(msg); in getMainThreadProxy()
62 SyncQueueItem msg = mQueue.next(); in getMainThreadProxy()
78 msg = mQueue.next(); in getMainThreadProxy()
88 final MessageQueue mQueue = new MessageQueue(); in getBackgroundProxy()
120 mQueue.sendMessage(msg); in getBackgroundProxy()
125 mQueue.sendMessageAtFrontOfQueue(msg); in getBackgroundProxy()
139 SyncQueueItem msg = mQueue.next(); in getBackgroundProxy()
145 mQueue.removeMessages(REFRESH); in getBackgroundProxy()
149 mQueue.removeMessages(UPDATE_RANGE); in getBackgroundProxy()
[all …]
|
| /frameworks/native/libs/gui/ |
| D | BufferQueueConsumer.cpp | 79 if (mCore->mQueue.empty() && !sharedBufferAvailable) { in acquireBuffer()
83 BufferQueueCore::Fifo::iterator front(mCore->mQueue.begin()); in acquireBuffer()
90 if (expectedPresent != 0 && !mCore->mQueue.empty()) { in acquireBuffer()
111 while (mCore->mQueue.size() > 1 && !mCore->mQueue[0].mIsAutoTimestamp) { in acquireBuffer()
112 const BufferItem& bufferItem(mCore->mQueue[1]); in acquireBuffer()
145 desiredPresent, expectedPresent, mCore->mQueue.size()); in acquireBuffer()
169 mCore->mQueue.erase(front); in acquireBuffer()
170 front = mCore->mQueue.begin(); in acquireBuffer()
198 if (sharedBufferAvailable && mCore->mQueue.empty()) { in acquireBuffer()
240 if (mCore->mQueue.empty()) { in acquireBuffer()
[all …]
|
| /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/ |
| D | ProviderExecutor.java | 51 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>(); field in ProviderExecutor
88 mQueue.add(command);
96 mQueue.add(command); in execute()
103 final Runnable command = mQueue.take(); in run()
|
| /frameworks/native/services/surfaceflinger/ |
| D | MessageQueue.cpp | 54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); in dispatchRefresh()
60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); in dispatchInvalidate()
68 mQueue.mFlinger->onMessageReceived(message.what); in handleMessage()
72 mQueue.mFlinger->onMessageReceived(message.what); in handleMessage()
|
| D | MessageQueue.h | 69 MessageQueue& mQueue; variable
72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } in Handler()
|
| /frameworks/av/media/libstagefright/mpeg2ts/ |
| D | ATSParser.cpp | 162 ElementaryStreamQueue *mQueue; member
598 mQueue(NULL) { in Stream()
601 mQueue = new ElementaryStreamQueue( in Stream()
607 mQueue = new ElementaryStreamQueue(ElementaryStreamQueue::AAC); in Stream()
611 mQueue = new ElementaryStreamQueue( in Stream()
617 mQueue = new ElementaryStreamQueue( in Stream()
622 mQueue = new ElementaryStreamQueue( in Stream()
628 mQueue = new ElementaryStreamQueue( in Stream()
633 mQueue = new ElementaryStreamQueue( in Stream()
643 if (mQueue != NULL) { in Stream()
[all …]
|
| D | MPEG2PSExtractor.cpp | 64 ElementaryStreamQueue *mQueue; member
595 mQueue(NULL) { in Track()
626 mQueue = new ElementaryStreamQueue(mode); in Track()
633 delete mQueue; in ~Track()
634 mQueue = NULL; in ~Track()
687 if (mQueue == NULL) { in appendPESData()
698 status_t err = mQueue->appendData(data, size, timeUs); in appendPESData()
705 while ((accessUnit = mQueue->dequeueAccessUnit()) != NULL) { in appendPESData()
707 sp<MetaData> meta = mQueue->getFormat(); in appendPESData()
715 } else if (mQueue->getFormat() != NULL) { in appendPESData()
|
| /frameworks/base/packages/Shell/tests/src/com/android/shell/ |
| D | ActionSendMultipleConsumerActivity.java | 90 private final BlockingQueue<Bundle> mQueue = new SynchronousQueue<>(); field in ActionSendMultipleConsumerActivity.CustomActionSendMultipleListener
98 mQueue.put(intent.getExtras()); in CustomActionSendMultipleListener()
118 bundle = mQueue.poll(2 * TIMEOUT, TimeUnit.SECONDS); in getExtras()
|
| /frameworks/base/tests/OneMedia/src/com/android/onemedia/ |
| D | PlayerSession.java | 48 protected ArrayList<MediaSession.QueueItem> mQueue; field in PlayerSession
64 mQueue = new ArrayList<MediaSession.QueueItem>(); in PlayerSession()
121 mQueue.clear(); in setIcon()
122 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11)); in setIcon()
132 mSession.setQueue(mUseQueue ? mQueue : null); in updateMetadata()
155 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11)); in initMetadata()
|
| /frameworks/av/media/libstagefright/rtsp/ |
| D | ARTPSource.cpp | 110 mQueue.push_back(buffer); in queuePacket()
154 List<sp<ABuffer> >::iterator it = mQueue.begin(); in queuePacket()
155 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) { in queuePacket()
159 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) { in queuePacket()
164 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/volley/src/main/java/com/android/volley/ |
| D | NetworkDispatcher.java | 37 private final BlockingQueue<Request<?>> mQueue; field in NetworkDispatcher
59 mQueue = queue; in NetworkDispatcher()
90 request = mQueue.take(); in run()
|
| /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/base/libs/hwui/renderthread/ |
| D | RenderThread.cpp | 322 mQueue.queue(task); in queue()
344 mQueue.queueAtFront(task); in queueAtFront()
355 mQueue.remove(task); in remove()
377 RenderTask* next = mQueue.peek(); in nextTask()
384 next = mQueue.next(); in nextTask()
|