| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
| D | PointerTrackerQueueTests.java | 66 private final PointerTrackerQueue mQueue = new PointerTrackerQueue(); field in PointerTrackerQueueTests
69 assertEquals(0, mQueue.size()); in testEmpty()
70 assertEquals("[]", mQueue.toString()); in testEmpty()
74 mQueue.add(mElement1); in testAdd()
75 assertEquals(1, mQueue.size()); in testAdd()
76 assertEquals("[1]", mQueue.toString()); in testAdd()
77 mQueue.add(mElement2); in testAdd()
78 assertEquals(2, mQueue.size()); in testAdd()
79 assertEquals("[1 2]", mQueue.toString()); in testAdd()
80 mQueue.add(mElement3); in testAdd()
[all …]
|
| /packages/apps/Launcher2/src/com/android/launcher2/ |
| D | DeferredHandler.java | 35 private LinkedList<Pair<Runnable, Integer>> mQueue = new LinkedList<Pair<Runnable, Integer>>(); field in DeferredHandler
43 synchronized (mQueue) { in handleMessage()
44 if (mQueue.size() == 0) { in handleMessage()
47 p = mQueue.removeFirst(); in handleMessage()
51 synchronized (mQueue) { in handleMessage()
82 synchronized (mQueue) { in post()
83 mQueue.add(new Pair<Runnable, Integer>(runnable, type)); in post()
84 if (mQueue.size() == 1) { in post()
99 synchronized (mQueue) { in cancelRunnable()
100 while (mQueue.remove(runnable)) { } in cancelRunnable()
[all …]
|
| /packages/apps/Gallery/src/com/android/camera/ |
| D | ImageLoader.java | 37 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/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/ |
| D | Player.java | 87 private List<QueueItem> mQueue; field in Player
195 if (mQueue == null || mQueue.isEmpty()) { in saveState()
200 playlist.songs = new Song[mQueue.size()]; in saveState()
203 for (QueueItem item : mQueue) { in saveState()
215 playlist.currentQueueId = mQueue.get(mCurrentQueueIdx).getQueueId(); in saveState()
260 mQueue = queue; in maybeRebuildQueue()
298 mSession.setQueue(mQueue); in updateSessionQueueState()
322 mQueue = new ArrayList<>(queue); in startPlayback()
324 QueueItem current = mQueue.get(mCurrentQueueIdx); in startPlayback()
350 if (mQueue == null) { in postMediaNotification()
[all …]
|
| D | DataModel.java | 87 private List<QueueItem> mQueue = new ArrayList<>(); field in DataModel
150 return mQueue; in getQueue()
206 mQueue.clear(); in onQueryByKey()
237 .setQueue(mQueue); in onQueryByKey()
320 private List<QueueItem> mQueue; field in DataModel.QueryTask
332 mQueue = builder.mQueue; in QueryTask()
375 if (mQueue != null) { in doInBackground()
376 mQueue.add(new QueueItem(description, idx)); in doInBackground()
413 private List<QueueItem> mQueue; field in DataModel.QueryTask.Builder
466 mQueue = queue; in setQueue()
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/ |
| D | DynamicRingBuffer.java | 62 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/ |
| D | ConcurrentBufferQueue.java | 82 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/src/com/android/tv/tuner/exoplayer/buffer/ |
| D | SampleQueue.java | 28 private final LinkedList<SampleHolder> mQueue = new LinkedList<>(); field in SampleQueue
37 mQueue.offer(sample); in queueSample()
42 SampleHolder sampleFromQueue = mQueue.poll(); in dequeueSample()
58 while (!mQueue.isEmpty()) { in clear()
59 mSamplePool.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/apps/Camera2/src/com/android/camera/processing/ |
| D | ProcessingServiceManager.java | 52 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/Gallery/src/com/android/camera/gallery/ |
| D | ImageListUber.java | 39 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()
|
| D | LruCache.java | 30 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/apps/Nfc/nci/jni/ |
| D | DataQueue.cpp | 54 while (mQueue.empty() == false) in ~DataQueue()
56 tHeader* header = mQueue.front (); in ~DataQueue()
57 mQueue.pop_front (); in ~DataQueue()
67 bool retval = mQueue.empty(); in isEmpty()
100 mQueue.push_back (header); in enqueue()
129 tHeader* header = mQueue.front (); in dequeue()
141 mQueue.pop_front (); in dequeue()
|
| D | DataQueue.h | 103 Queue mQueue; variable
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| D | SingleThreadNamedTaskExecutor.java | 32 private final LinkedBlockingQueue<NamedTask> mQueue; field in SingleThreadNamedTaskExecutor
37 mQueue = new LinkedBlockingQueue<NamedTask>(); in SingleThreadNamedTaskExecutor()
43 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size() + " tasks: " + mWorker.getName()); in cancelPendingTasks()
47 mQueue.clear(); in cancelPendingTasks()
53 mQueue.clear(); in close()
60 mQueue.add(task); in execute()
78 task = mQueue.take(); in loop()
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| D | MockExecutor.java | 29 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/Calendar/src/com/android/calendar/ |
| D | EventLoader.java | 161 LinkedBlockingQueue<LoadRequest> mQueue; field in EventLoader.LoaderThread
165 mQueue = queue; in LoaderThread()
171 mQueue.put(new ShutdownRequest()); in shutdown()
186 LoadRequest request = mQueue.take(); in run()
190 while (!mQueue.isEmpty()) { in run()
195 request = mQueue.take(); in run()
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
| D | LruCache.java | 34 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/services/Car/tests/InstrumentClusterRendererSample/src/com/android/car/cluster/sample/ |
| D | ClusterView.java | 65 private final PriorityQueue<CardView> mQueue = new PriorityQueue<>(8); field in ClusterView
286 mQueue.remove(card); in removeCard()
288 CardView cardToShow = mQueue.peek(); in removeCard()
323 boolean cardExisted = mQueue.remove(card); in enqueueCard()
324 mQueue.offer(card); in enqueueCard()
326 CardView activeCard = mQueue.peek(); in enqueueCard()
460 mQueue.remove(card); in removeCardInternal()
638 + mQueue.size()); in dumpCardsToLog()
|
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| D | IdentityCache.java | 29 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/ |
| 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()
|
| /packages/apps/LegacyCamera/src/com/android/camera/ |
| D | Camera.java | 875 private ArrayList<SaveRequest> mQueue; field in Camera.ImageSaver
882 mQueue = new ArrayList<SaveRequest>(); in ImageSaver()
901 while (mQueue.size() >= QUEUE_LIMIT) { in addImage()
908 mQueue.add(r); in addImage()
919 if (mQueue.isEmpty()) { in run()
933 r = mQueue.get(0); in run()
938 mQueue.remove(0); in run()
947 while (!mQueue.isEmpty()) { in waitDone()
1004 needThumbnail = (mQueue.size() <= 1); in storeImage()
|
| /packages/apps/Camera2/src/com/android/camera/ |
| D | PhotoModule.java | 1061 private final Vector<NamedEntity> mQueue; field in PhotoModule.NamedImages
1064 mQueue = new Vector<NamedEntity>(); in NamedImages()
1071 mQueue.add(r); in nameNewImage()
1075 synchronized (mQueue) { in getNextNameEntity()
1076 if (!mQueue.isEmpty()) { in getNextNameEntity()
1077 return mQueue.remove(0); in getNextNameEntity()
|