| /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/Launcher3/src/com/android/launcher3/ |
| D | DeferredHandler.java | 36 @Thunk LinkedList<Runnable> mQueue = new LinkedList<>(); field in DeferredHandler
43 synchronized (mQueue) { in handleMessage()
44 if (mQueue.size() == 0) { in handleMessage()
47 r = mQueue.removeFirst(); in handleMessage()
50 synchronized (mQueue) { in handleMessage()
78 synchronized (mQueue) { in post()
79 mQueue.add(runnable); in post()
80 if (mQueue.size() == 1) { in post()
92 synchronized (mQueue) { in cancelAll()
93 mQueue.clear(); in cancelAll()
[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/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/Camera/src/com/android/camera/ |
| D | MediaSaver.java | 45 private ArrayList<SaveRequest> mQueue; field in MediaSaver
55 mQueue = new ArrayList<SaveRequest>(); in MediaSaver()
61 return (mQueue.size() >= SAVE_QUEUE_LIMIT); in queueFull()
77 while (mQueue.size() >= SAVE_QUEUE_LIMIT) { in addImage()
84 mQueue.add(r); in addImage()
95 if (mQueue.isEmpty()) { in run()
110 r = mQueue.remove(0); in run()
117 if (!mQueue.isEmpty()) { in run()
118 Log.e(TAG, "Media saver thread stopped with " + mQueue.size() + " images unsaved"); in run()
119 mQueue.clear(); in run()
|
| D | PhotoModule.java | 1048 private ArrayList<NamedEntity> mQueue; field in PhotoModule.NamedImages
1053 mQueue = new ArrayList<NamedEntity>(); in NamedImages()
1060 mQueue.add(r); in nameNewImage()
1064 if (mQueue.isEmpty()) { in getTitle()
1068 mNamedEntity = mQueue.get(0); in getTitle()
1069 mQueue.remove(0); in getTitle()
|
| /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 | 55 while (mQueue.empty() == false) in ~DataQueue()
57 tHeader* header = mQueue.front (); in ~DataQueue()
58 mQueue.pop_front (); in ~DataQueue()
68 bool retval = mQueue.empty(); in isEmpty()
101 mQueue.push_back (header); in enqueue()
130 tHeader* header = mQueue.front (); in dequeue()
142 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/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/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()
|