/packages/apps/Nfc/nci/jni/ |
H A D | DataQueue.h | 103 Queue mQueue; member in class:DataQueue
|
/packages/apps/Gallery2/src/com/android/gallery3d/util/ |
H A D | IdentityCache.java | 29 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); field in class:IdentityCache 44 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 47 entry = (Entry<K, V>) mQueue.poll(); 54 key, new Entry<K, V>(key, value, mQueue)); 68 mQueue = new ReferenceQueue<V>();
|
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
H A D | MockExecutor.java | 29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>(); field in class:MockExecutor 35 mQueue.addLast(task); 39 mQueue.clear(); 48 return mQueue.size(); 52 if (mQueue.isEmpty()) { 55 Runnable command = mQueue.removeFirst();
|
/packages/apps/Gallery/src/com/android/camera/gallery/ |
H A D | LruCache.java | 30 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); field in class:LruCache 53 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 56 entry = (Entry<K, V>) mQueue.poll(); 64 key, new Entry<K, V>(key, value, mQueue)); 79 mQueue = new ReferenceQueue<V>();
|
H A D | ImageListUber.java | 39 private final PriorityQueue<MergeSlot> mQueue; field in class:ImageListUber 55 mQueue = new PriorityQueue<MergeSlot>(4, 63 mQueue.clear(); 67 if (slot.next()) mQueue.add(slot); 136 if (slot.next()) mQueue.add(slot); 139 if (slot.next()) mQueue.add(slot); 144 MergeSlot slot = mQueue.poll(); 234 if (slot.next()) mQueue.add(slot); 237 if (slot.next()) mQueue.add(slot);
|
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
H A D | LruCache.java | 34 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); field in class:LruCache 57 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 60 entry = (Entry<K, V>) mQueue.poll(); 73 key, new Entry<K, V>(key, value, mQueue)); 88 mQueue = new ReferenceQueue<V>();
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
H A D | SingleThreadNamedTaskExecutor.java | 32 private final LinkedBlockingQueue<NamedTask> mQueue; field in class:SingleThreadNamedTaskExecutor 37 mQueue = new LinkedBlockingQueue<NamedTask>(); 43 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size() + " tasks: " + mWorker.getName()); 47 mQueue.clear(); 53 mQueue.clear(); 60 mQueue.add(task); 78 task = mQueue.take();
|
/packages/apps/TV/usbtuner/src/com/android/usbtuner/exoplayer/cache/ |
H A D | SampleQueue.java | 28 private final LinkedList<SampleHolder> mQueue = new LinkedList<>(); field in class:SampleQueue 36 mQueue.offer(sample); 40 SampleHolder sampleFromQueue = mQueue.poll(); 55 while (!mQueue.isEmpty()) { 56 mSamplePool.releaseSample(mQueue.poll()); 61 if (mQueue.isEmpty()) { 64 return mQueue.getLast().timeUs; 68 if (mQueue.isEmpty()) { 71 return mQueue.getLast().timeUs - mQueue [all...] |
/packages/apps/Camera2/src/com/android/camera/processing/ |
H A D | ProcessingServiceManager.java | 52 private final LinkedList<ProcessingTask> mQueue = new LinkedList<ProcessingTask>(); field in class:ProcessingServiceManager 79 mQueue.add(task); 80 Log.d(TAG, "Task added. Queue size now: " + mQueue.size()); 96 if (!mQueue.isEmpty() && !mHoldProcessing) { 97 Log.d(TAG, "Popping a session. Remaining: " + (mQueue.size() - 1)); 98 return mQueue.remove(); 111 return mServiceRunning || !mQueue.isEmpty(); 137 Log.d(TAG, "Resume processing. Queue size: " + mQueue.size()); 140 if (!mQueue.isEmpty()) {
|
/packages/apps/Launcher2/src/com/android/launcher2/ |
H A D | DeferredHandler.java | 35 private LinkedList<Pair<Runnable, Integer>> mQueue = new LinkedList<Pair<Runnable, Integer>>(); field in class:DeferredHandler 43 synchronized (mQueue) { 44 if (mQueue.size() == 0) { 47 p = mQueue.removeFirst(); 51 synchronized (mQueue) { 82 synchronized (mQueue) { 83 mQueue.add(new Pair<Runnable, Integer>(runnable, type)); 84 if (mQueue.size() == 1) { 99 synchronized (mQueue) { 100 while (mQueue [all...] |
/packages/apps/Launcher3/src/com/android/launcher3/ |
H A D | DeferredHandler.java | 36 @Thunk LinkedList<Runnable> mQueue = new LinkedList<>(); field in class:DeferredHandler 43 synchronized (mQueue) { 44 if (mQueue.size() == 0) { 47 r = mQueue.removeFirst(); 50 synchronized (mQueue) { 78 synchronized (mQueue) { 79 mQueue.add(runnable); 80 if (mQueue.size() == 1) { 92 synchronized (mQueue) { 93 mQueue [all...] |
/packages/apps/Calendar/src/com/android/calendar/ |
H A D | EventLoader.java | 161 LinkedBlockingQueue<LoadRequest> mQueue; field in class:EventLoader.LoaderThread 165 mQueue = queue; 171 mQueue.put(new ShutdownRequest()); 186 LoadRequest request = mQueue.take(); 190 while (!mQueue.isEmpty()) { 195 request = mQueue.take();
|
/packages/apps/Camera2/src/com/android/camera/async/ |
H A D | ConcurrentBufferQueue.java | 76 * Lock used for mQueue modification and mClosed. 82 private final BlockingQueue<Entry<T>> mQueue; field in class:ConcurrentBufferQueue 96 mQueue = new LinkedBlockingQueue<>(); 120 mQueue.drainTo(remainingElements); 125 // mQueue, the call to peek() from this thread will see a value. 130 while (mQueue.peek() == null) { 131 mQueue.add(makeClosingMarker()); 148 mQueue.add(makeEntry(element)); 159 // in which a thread reaches the mQueue.take() call after close(). 160 mQueue [all...] |
/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/ |
H A D | DynamicRingBuffer.java | 62 private final CountableBufferQueue<ImageProxy> mQueue; field in class:DynamicRingBuffer 75 mQueue = new CountableBufferQueue<>(mQueueSize, new ImageCloser()); 90 // mQueue. However, for a brief moment, we acquire a ticket from 91 // mTicketPool, but have yet added it to mQueue. During this period, 103 mQueue.discardNext(); 107 mQueue.update(new TicketImageProxy(image, ticket)); 127 mQueue.close(); 132 return mQueue.getNext(); 138 return mQueue.getNext(timeout, unit); 143 return mQueue [all...] |
/packages/apps/Gallery/src/com/android/camera/ |
H A D | ImageLoader.java | 37 private final ArrayList<WorkItem> mQueue = new ArrayList<WorkItem>(); field in class:ImageLoader 54 synchronized (mQueue) { 56 mQueue.add(w); 57 mQueue.notifyAll(); 62 synchronized (mQueue) { 65 mQueue.remove(index); 73 // The caller should hold mQueue lock. 75 for (int i = 0; i < mQueue.size(); i++) { 76 if (mQueue.get(i).mImage == image) { 85 synchronized (mQueue) { [all...] |
/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
H A D | PointerTrackerQueueTests.java | 66 private final PointerTrackerQueue mQueue = new PointerTrackerQueue(); field in class:PointerTrackerQueueTests 69 assertEquals(0, mQueue.size()); 70 assertEquals("[]", mQueue.toString()); 74 mQueue.add(mElement1); 75 assertEquals(1, mQueue.size()); 76 assertEquals("[1]", mQueue.toString()); 77 mQueue.add(mElement2); 78 assertEquals(2, mQueue.size()); 79 assertEquals("[1 2]", mQueue.toString()); 80 mQueue [all...] |
/packages/services/Car/car-ui-provider/src/android/car/ui/provider/ |
H A D | DrawerController.java | 481 private final Queue<Animation> mQueue = new LinkedList<>(); field in class:DrawerController.ViewAnimationController 516 Animation nextAnimation = mQueue.poll(); 569 mQueue.clear(); 578 if (mQueue.contains(animation)) { 582 mQueue.add(animation);
|
/packages/apps/Camera2/src/com/android/camera/ |
H A D | PhotoModule.java | 1061 private final Vector<NamedEntity> mQueue; field in class:PhotoModule.NamedImages 1064 mQueue = new Vector<NamedEntity>(); 1071 mQueue.add(r); 1075 synchronized (mQueue) { 1076 if (!mQueue.isEmpty()) { 1077 return mQueue.remove(0);
|
/packages/apps/LegacyCamera/src/com/android/camera/ |
H A D | Camera.java | 875 private ArrayList<SaveRequest> mQueue; field in class:Camera.ImageSaver 882 mQueue = new ArrayList<SaveRequest>(); 901 while (mQueue.size() >= QUEUE_LIMIT) { 908 mQueue.add(r); 919 if (mQueue.isEmpty()) { 933 r = mQueue.get(0); 938 mQueue.remove(0); 947 while (!mQueue.isEmpty()) { 1004 needThumbnail = (mQueue.size() <= 1);
|