Home
last modified time | relevance | path

Searched refs:mQueue (Results 1 – 25 of 40) sorted by relevance

12

/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/
DPointerTrackerQueueTests.java74 private final PointerTrackerQueue mQueue = new PointerTrackerQueue(); field in PointerTrackerQueueTests
78 assertEquals(0, mQueue.size()); in testEmpty()
79 assertEquals("[]", mQueue.toString()); in testEmpty()
84 mQueue.add(mElement1); in testAdd()
85 assertEquals(1, mQueue.size()); in testAdd()
86 assertEquals("[1]", mQueue.toString()); in testAdd()
87 mQueue.add(mElement2); in testAdd()
88 assertEquals(2, mQueue.size()); in testAdd()
89 assertEquals("[1 2]", mQueue.toString()); in testAdd()
90 mQueue.add(mElement3); in testAdd()
[all …]
/packages/apps/Gallery/src/com/android/camera/
DImageLoader.java37 private final ArrayList<WorkItem> mQueue = new ArrayList<WorkItem>(); field in ImageLoader
54 synchronized (mQueue) { in getBitmap()
56 mQueue.add(w); in getBitmap()
57 mQueue.notifyAll(); in getBitmap()
62 synchronized (mQueue) { in cancel()
65 mQueue.remove(index); in cancel()
75 for (int i = 0; i < mQueue.size(); i++) { in findItem()
76 if (mQueue.get(i).mImage == image) { in findItem()
85 synchronized (mQueue) { in clearQueue()
86 int n = mQueue.size(); in clearQueue()
[all …]
/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/
DDynamicRingBuffer.java62 private final CountableBufferQueue<ImageProxy> mQueue; field in DynamicRingBuffer
75 mQueue = new CountableBufferQueue<>(mQueueSize, new ImageCloser()); in DynamicRingBuffer()
103 mQueue.discardNext(); in update()
107 mQueue.update(new TicketImageProxy(image, ticket)); in update()
127 mQueue.close(); in close()
132 return mQueue.getNext(); in getNext()
138 return mQueue.getNext(timeout, unit); in getNext()
143 return mQueue.peekNext(); in peekNext()
148 mQueue.discardNext(); in discardNext()
153 return mQueue.isClosed(); in isClosed()
[all …]
/packages/apps/Camera2/src/com/android/camera/async/
DConcurrentBufferQueue.java82 private final BlockingQueue<Entry<T>> mQueue; field in ConcurrentBufferQueue
96 mQueue = new LinkedBlockingQueue<>(); in ConcurrentBufferQueue()
120 mQueue.drainTo(remainingElements); in close()
130 while (mQueue.peek() == null) { in close()
131 mQueue.add(makeClosingMarker()); in close()
148 mQueue.add(makeEntry(element)); in update()
160 mQueue.add(nextEntry); in doWithNextEntry()
169 Entry<T> nextEntry = mQueue.take(); in getNext()
176 Entry<T> nextEntry = mQueue.poll(timeout, unit); in getNext()
185 Entry<T> nextEntry = mQueue.peek(); in peekNext()
[all …]
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/
DSampleQueue.java25 private final LinkedList<SampleHolder> mQueue = new LinkedList<>(); field in SampleQueue
34 mQueue.offer(sample); in queueSample()
39 SampleHolder sampleFromQueue = mQueue.poll(); in dequeueSample()
55 while (!mQueue.isEmpty()) { in clear()
56 mSamplePool.releaseSample(mQueue.poll()); in clear()
66 return !mQueue.isEmpty() && mQueue.getLast().timeUs - mQueue.getFirst().timeUs > durationUs; in isDurationGreaterThan()
70 return mQueue.isEmpty(); in isEmpty()
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/
DSampleQueue.java26 private final LinkedList<DecoderInputBuffer> mQueue = new LinkedList<>(); field in SampleQueue
35 mQueue.offer(sample); in queueSample()
40 DecoderInputBuffer sampleFromQueue = mQueue.poll(); in dequeueSample()
58 while (!mQueue.isEmpty()) { in clear()
59 mInputBufferPool.releaseSample(mQueue.poll()); in clear()
69 return !mQueue.isEmpty() && mQueue.getLast().timeUs - mQueue.getFirst().timeUs > durationUs; in isDurationGreaterThan()
73 return mQueue.isEmpty(); in isEmpty()
/packages/modules/StatsD/statsd/src/logd/
DLogEventQueue.cpp32 if (mQueue.empty()) { in waitPop()
33 mCondition.wait(lock, [this] { return !this->mQueue.empty(); }); in waitPop()
36 unique_ptr<LogEvent> item = std::move(mQueue.front()); in waitPop()
37 mQueue.pop(); in waitPop()
46 if (mQueue.size() < mQueueLimit) { in push()
47 mQueue.push(std::move(item)); in push()
51 result.oldestTimestampNs = mQueue.front()->GetElapsedTimestampNs(); in push()
54 result.size = mQueue.size(); in push()
/packages/apps/Settings/tests/robotests/src/com/android/settings/testutils/
DFakeTimer.java27 private final PriorityQueue<ScheduledTimerTask> mQueue = new PriorityQueue<>(); field in FakeTimer
34 mQueue.clear(); in cancel()
39 mQueue.offer(new ScheduledTimerTask(System.currentTimeMillis() + delay, task)); in schedule()
46 if (mQueue.size() > 0) { in runOneTask()
47 mQueue.poll().mTask.run(); in runOneTask()
55 while (mQueue.size() > 0) { in runAllTasks()
56 mQueue.poll().mTask.run(); in runAllTasks()
64 return mQueue.size(); in numOfPendingTasks()
/packages/apps/Camera2/src/com/android/camera/processing/
DProcessingServiceManager.java52 private final LinkedList<ProcessingTask> mQueue = new LinkedList<ProcessingTask>(); field in ProcessingServiceManager
79 mQueue.add(task); in enqueueTask()
80 Log.d(TAG, "Task added. Queue size now: " + mQueue.size()); in enqueueTask()
96 if (!mQueue.isEmpty() && !mHoldProcessing) { in popNextSession()
97 Log.d(TAG, "Popping a session. Remaining: " + (mQueue.size() - 1)); in popNextSession()
98 return mQueue.remove(); in popNextSession()
111 return mServiceRunning || !mQueue.isEmpty(); in isRunningOrHasItems()
137 Log.d(TAG, "Resume processing. Queue size: " + mQueue.size()); in resumeProcessing()
140 if (!mQueue.isEmpty()) { in resumeProcessing()
/packages/apps/Launcher3/quickstep/src/com/android/quickstep/util/
DTaskKeyByLastActiveTimeCache.java44 private final PriorityQueue<Task.TaskKey> mQueue; field in TaskKeyByLastActiveTimeCache
48 mQueue = new PriorityQueue<>(Comparator.comparingLong(t -> t.lastActiveTime)); in TaskKeyByLastActiveTimeCache()
58 mQueue.clear(); in evictAll()
74 mQueue.remove(entry.mKey); in remove()
83 Iterator<Task.TaskKey> iterator = mQueue.iterator(); in removeAll()
118 mQueue.remove(entry.mKey); in put()
123 mQueue.add(key); in put()
151 while (mQueue.size() > maxSize && !mQueue.isEmpty()) { in removeExcessIfNeeded()
152 Task.TaskKey key = mQueue.poll(); in removeExcessIfNeeded()
175 return mQueue; in getQueue()
/packages/modules/DnsResolver/
DLockedQueue.h35 mQueue.push_front(std::move(item)); in push()
41 mQueue.swap(other); in swap()
46 std::deque<T> mQueue GUARDED_BY(mLock);
56 mQueue.push_back(std::move(record)); in push()
57 if (mQueue.size() > mCapacity) { in push()
58 mQueue.pop_front(); in push()
64 return mQueue; in copy()
70 std::deque<T> mQueue GUARDED_BY(mLock);
/packages/apps/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/
DPlayer.java90 private List<QueueItem> mQueue; field in Player
206 if (mQueue == null || mQueue.isEmpty()) { in saveState()
211 playlist.songs = new Song[mQueue.size()]; in saveState()
214 for (QueueItem item : mQueue) { in saveState()
226 playlist.currentQueueId = mQueue.get(mCurrentQueueIdx).getQueueId(); in saveState()
291 mQueue = queue; in maybeRebuildQueue()
333 mSession.setQueue(mQueue); in updateSessionQueueState()
357 mQueue = new ArrayList<>(queue); in startPlayback()
359 QueueItem current = mQueue.get(mCurrentQueueIdx); in startPlayback()
385 if (mQueue == null) { in postMediaNotification()
[all …]
DDataModel.java85 private List<QueueItem> mQueue = new ArrayList<>(); field in DataModel
146 return mQueue; in getQueue()
202 mQueue.clear(); in onQueryByKey()
232 .setQueue(mQueue); in onQueryByKey()
315 private List<QueueItem> mQueue; field in DataModel.QueryTask
327 mQueue = builder.mQueue; in QueryTask()
370 if (mQueue != null) { in doInBackground()
371 mQueue.add(new QueueItem(description, idx)); in doInBackground()
408 private List<QueueItem> mQueue; field in DataModel.QueryTask.Builder
461 mQueue = queue; in setQueue()
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/
DMockExecutor.java29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>(); field in MockExecutor
35 mQueue.addLast(task); in execute()
39 mQueue.clear(); in cancelPendingTasks()
48 return mQueue.size(); in countPendingTasks()
52 if (mQueue.isEmpty()) { in runNext()
55 Runnable command = mQueue.removeFirst(); in runNext()
/packages/apps/Nfc/nci/jni/
DDataQueue.cpp51 while (mQueue.empty() == false) { in ~DataQueue()
52 tHeader* header = mQueue.front(); in ~DataQueue()
53 mQueue.pop_front(); in ~DataQueue()
61 bool retval = mQueue.empty(); in isEmpty()
90 mQueue.push_back(header); in enqueue()
116 tHeader* header = mQueue.front(); in dequeue()
126 mQueue.pop_front(); in dequeue()
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
DSingleThreadNamedTaskExecutor.kt25 private val mQueue: LinkedBlockingQueue<NamedTask> constant
30 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size.toString() + " tasks: " + mWorker.name) in cancelPendingTasks()
34 mQueue.clear() in cancelPendingTasks()
40 mQueue.clear() in close()
47 mQueue.add(task) in execute()
65 mQueue.take() in loop()
95 mQueue = LinkedBlockingQueue<NamedTask>()
/packages/apps/Gallery/src/com/android/camera/gallery/
DImageListUber.java39 private final PriorityQueue<MergeSlot> mQueue; field in ImageListUber
55 mQueue = new PriorityQueue<MergeSlot>(4, in ImageListUber()
63 mQueue.clear(); in ImageListUber()
67 if (slot.next()) mQueue.add(slot); in ImageListUber()
136 if (slot.next()) mQueue.add(slot); in getImageAt()
139 if (slot.next()) mQueue.add(slot); in getImageAt()
144 MergeSlot slot = mQueue.poll(); in nextMergeSlot()
234 if (slot.next()) mQueue.add(slot); in getImageIndex()
237 if (slot.next()) mQueue.add(slot); in getImageIndex()
DLruCache.java30 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); field in LruCache
53 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
56 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
64 key, new Entry<K, V>(key, value, mQueue)); in put()
79 mQueue = new ReferenceQueue<V>(); in clear()
/packages/modules/Bluetooth/framework/tests/bumble/src/android/bluetooth/
DStreamObserverSpliterator.java29 private BlockingQueue<Object> mQueue = new LinkedBlockingQueue<>(); field in StreamObserverSpliterator
62 Object item = mQueue.take(); in tryAdvance()
83 mQueue.add(value); in onNext()
88 mQueue.add(t); in onError()
93 mQueue.add(COMPLETED_INDICATOR); in onCompleted()
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/
DLruCache.java34 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); field in LruCache
57 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
60 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
73 key, new Entry<K, V>(key, value, mQueue)); in put()
88 mQueue = new ReferenceQueue<V>(); in clear()
/packages/apps/Calendar/src/com/android/calendar/
DEventLoader.kt153 var mQueue: LinkedBlockingQueue<LoadRequest> variable
157 mQueue.put(ShutdownRequest()) in shutdown()
172 var request: LoadRequest = mQueue.take() in run()
176 while (!mQueue.isEmpty()) { in run()
181 request = mQueue.take() in run()
194 mQueue = queue
/packages/apps/Gallery2/src/com/android/gallery3d/util/
DIdentityCache.java29 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); field in IdentityCache
44 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
47 entry = (Entry<K, V>) mQueue.poll(); in cleanUpWeakMap()
54 key, new Entry<K, V>(key, value, mQueue)); in put()
/packages/apps/DocumentsUI/src/com/android/documentsui/
DProviderExecutor.java51 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()
/packages/apps/Nfc/testutils/src/com/android/nfc/emulator/
DPollingLoopEmulatorActivity.java54 private Queue<PollingFrame> mQueue = new ArrayDeque<PollingFrame>(); field in PollingLoopEmulatorActivity
86 mQueue = new ArrayDeque<PollingFrame>(); in onResume()
178 if (mQueue.size() == mCapacity) { in processPollingFrame()
181 mQueue.add(frame); in processPollingFrame()
210 PollingFrame frame = mQueue.poll(); in removeFirstElement()
/packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/utils/
DFdEventsReader.java81 private final MessageQueue mQueue; field in FdEventsReader
97 mQueue = mHandler.getLooper().getQueue(); in FdEventsReader()
200 mQueue.addOnFileDescriptorEventListener( in createAndRegisterFd()
261 mQueue.removeOnFileDescriptorEventListener(mFd); in unregisterAndDestroyFd()

12