| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
| D | PointerTrackerQueueTests.java | 74 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/ |
| 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/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/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/ |
| D | Player.java | 87 private List<QueueItem> mQueue; field in Player
200 if (mQueue == null || mQueue.isEmpty()) { in saveState()
205 playlist.songs = new Song[mQueue.size()]; in saveState()
208 for (QueueItem item : mQueue) { in saveState()
220 playlist.currentQueueId = mQueue.get(mCurrentQueueIdx).getQueueId(); in saveState()
265 mQueue = queue; in maybeRebuildQueue()
303 mSession.setQueue(mQueue); in updateSessionQueueState()
327 mQueue = new ArrayList<>(queue); in startPlayback()
329 QueueItem current = mQueue.get(mCurrentQueueIdx); in startPlayback()
355 if (mQueue == null) { in postMediaNotification()
[all …]
|
| D | DataModel.java | 85 private List<QueueItem> mQueue = new ArrayList<>(); field in DataModel
146 return mQueue; in getQueue()
202 mQueue.clear(); in onQueryByKey()
233 .setQueue(mQueue); in onQueryByKey()
316 private List<QueueItem> mQueue; field in DataModel.QueryTask
328 mQueue = builder.mQueue; in QueryTask()
371 if (mQueue != null) { in doInBackground()
372 mQueue.add(new QueueItem(description, idx)); in doInBackground()
409 private List<QueueItem> mQueue; field in DataModel.QueryTask.Builder
462 mQueue = queue; in setQueue()
|
| /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/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| D | SampleQueue.java | 25 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/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/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/Nfc/nci/jni/ |
| D | DataQueue.cpp | 52 while (mQueue.empty() == false) { in ~DataQueue()
53 tHeader* header = mQueue.front(); in ~DataQueue()
54 mQueue.pop_front(); in ~DataQueue()
62 bool retval = mQueue.empty(); in isEmpty()
91 mQueue.push_back(header); in enqueue()
117 tHeader* header = mQueue.front(); in dequeue()
127 mQueue.pop_front(); in dequeue()
|
| D | DataQueue.h | 96 Queue mQueue; variable
|
| /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/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/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/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/Car/Media/src/com/android/car/media/ |
| D | PlaybackFragment.java | 70 private RecyclerView mQueue; field in PlaybackFragment
269 mQueue = view.findViewById(R.id.queue_list); in onCreateView()
409 mQueue.addItemDecoration(new QueueTopItemDecoration(decorationHeight, decorationPosition)); in initQueue()
411 mQueue.setVerticalFadingEdgeEnabled( in initQueue()
423 mQueue.setAdapter(mQueueAdapter); in initQueue()
424 mQueue.setLayoutManager(new LinearLayoutManager(getContext())); in initQueue()
429 mQueue.setItemAnimator(mItemAnimator); in initQueue()
481 ViewUtils.showViewAnimated(mQueue, mFadeDuration); in toggleQueueVisibility()
484 ViewUtils.hideViewAnimated(mQueue, mFadeDuration); in toggleQueueVisibility()
|
| /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/modules/NetworkStack/src/android/net/util/ |
| D | FdEventsReader.java | 75 private final MessageQueue mQueue; field in FdEventsReader
91 mQueue = mHandler.getLooper().getQueue(); in FdEventsReader()
194 mQueue.addOnFileDescriptorEventListener( in createAndRegisterFd()
255 mQueue.removeOnFileDescriptorEventListener(mFd); in unregisterAndDestroyFd()
|
| /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()
|