Home
last modified time | relevance | path

Searched refs:mQueue (Results 1 – 25 of 29) 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/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/
DPlayer.java87 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 …]
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/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/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/Nfc/nci/jni/
DDataQueue.cpp52 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()
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
DSingleThreadNamedTaskExecutor.java32 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/
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/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/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.java161 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/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/modules/DnsResolver/
DDnsQueryLog.cpp63 mQueue.push_back(std::move(record)); in push()
64 if (mQueue.size() > mCapacity) { in push()
65 mQueue.pop_front(); in push()
75 for (const auto& record : mQueue) { in dump()
DLockedQueue.h35 mQueue.push_front(std::move(item)); in push()
41 mQueue.swap(other); in swap()
46 std::deque<T> mQueue GUARDED_BY(mLock);
/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()
/packages/apps/Car/Media/src/com/android/car/media/
DPlaybackFragment.java74 private RecyclerView mQueue; field in PlaybackFragment
239 mQueue.scrollToPosition(mActiveItemPos.intValue()); in updateActiveItem()
353 mQueue = view.findViewById(R.id.queue_list); in onCreateView()
497 mQueue.addItemDecoration(new QueueTopItemDecoration(decorationHeight, decorationPosition)); in initQueue()
499 mQueue.setVerticalFadingEdgeEnabled( in initQueue()
511 mQueue.setAdapter(mQueueAdapter); in initQueue()
516 mQueue.setItemAnimator(mItemAnimator); in initQueue()
/packages/modules/CaptivePortalLogin/src/com/android/captiveportallogin/
DDownloadService.java90 private final Queue<DownloadTask> mQueue = new ArrayDeque<>(1); field in DownloadService
218 synchronized (mQueue) { in onStartCommand()
221 mQueue.add(task); in onStartCommand()
264 synchronized (mQueue) { in run()
265 task = mQueue.poll(); in run()
/packages/apps/LegacyCamera/src/com/android/camera/
DCamera.java875 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/
DPhotoModule.java1061 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()

12