| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
| PointerTrackerQueueTests.java | 66 private final PointerTrackerQueue mQueue = new PointerTrackerQueue();
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.add(mElement3)
[all...] |
| /packages/apps/Launcher3/src/com/android/launcher3/ |
| DeferredHandler.java | 36 @Thunk LinkedList<Runnable> mQueue = new LinkedList<>();
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.clear()
[all...] |
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockExecutor.java | 29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>();
35 mQueue.addLast(task);
39 mQueue.clear();
48 return mQueue.size();
52 if (mQueue.isEmpty()) {
55 Runnable command = mQueue.removeFirst();
|
| /frameworks/support/v7/recyclerview/tests/src/android/support/v7/util/ |
| MessageQueueTest.java | 34 MessageThreadUtil.MessageQueue mQueue;
38 mQueue = new MessageThreadUtil.MessageQueue();
44 mQueue.sendMessage(MessageThreadUtil.SyncQueueItem.obtainMessage(
47 MessageThreadUtil.SyncQueueItem msg = mQueue.next();
59 mQueue.sendMessage(obtainMessage(1, 2));
60 mQueue.sendMessage(obtainMessage(3, 4));
61 mQueue.sendMessage(obtainMessage(5, 6));
63 MessageThreadUtil.SyncQueueItem msg = mQueue.next();
67 msg = mQueue.next();
71 msg = mQueue.next()
[all...] |
| /packages/apps/TV/usbtuner/src/com/android/usbtuner/exoplayer/cache/ |
| SampleQueue.java | 28 private final LinkedList<SampleHolder> mQueue = new LinkedList<>();
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.getFirst().timeUs > durationUs
[all...] |
| /packages/apps/Launcher2/src/com/android/launcher2/ |
| DeferredHandler.java | 35 private LinkedList<Pair<Runnable, Integer>> mQueue = new LinkedList<Pair<Runnable, Integer>>();
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.remove(runnable)) {
[all...] |
| /packages/apps/Gallery/src/com/android/camera/ |
| ImageLoader.java | 37 private final ArrayList<WorkItem> mQueue = new ArrayList<WorkItem>();
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/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| SingleThreadNamedTaskExecutor.java | 32 private final LinkedBlockingQueue<NamedTask> mQueue;
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/Camera2/src/com/android/camera/processing/ |
| ProcessingServiceManager.java | 52 private final LinkedList<ProcessingTask> mQueue = new LinkedList<ProcessingTask>();
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()) {
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| OutputPort.java | 39 private FrameQueue mQueue = null;
56 return mQueue == null || mQueue.canPush();
165 return mQueue;
169 mQueue = queue;
180 return mQueue != null;
188 if (mQueue != null) {
189 mQueue.clear();
|
| InputPort.java | 43 private FrameQueue mQueue = null;
178 if (mQueue == null) {
181 Frame frame = mQueue.pullFrame();
197 if (mQueue == null) {
200 return mQueue.peek();
208 return mQueue != null;
216 return mQueue != null && mQueue.canPull();
292 mQueue = queue;
297 return mQueue;
[all...] |
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/ |
| DynamicRingBuffer.java | 62 private final CountableBufferQueue<ImageProxy> mQueue;
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.peekNext()
[all...] |
| /packages/apps/Nfc/nci/jni/ |
| DataQueue.cpp | 55 while (mQueue.empty() == false)
57 tHeader* header = mQueue.front ();
58 mQueue.pop_front ();
68 bool retval = mQueue.empty();
101 mQueue.push_back (header);
130 tHeader* header = mQueue.front ();
142 mQueue.pop_front ();
|
| DataQueue.h | 103 Queue mQueue;
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| ConcurrentBufferQueue.java | 76 * Lock used for mQueue modification and mClosed.
82 private final BlockingQueue<Entry<T>> mQueue;
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.add(nextEntry)
[all...] |
| /frameworks/base/core/java/android/speech/tts/ |
| AudioPlaybackHandler.java | 27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue =
51 mQueue.put(item);
80 return (mQueue.peek() != null) || (mCurrentWorkItem != null);
96 mQueue.clear();
103 Iterator<PlaybackQueueItem> it = mQueue.iterator();
123 item = mQueue.take();
129 // If stop() or stopForApp() are called between mQueue.take()
|
| /cts/tests/tests/media/src/android/media/cts/ |
| NonBlockingAudioTrack.java | 45 private LinkedList<QueueElement> mQueue = new LinkedList<QueueElement>();
116 if (mQueue.isEmpty()) {
133 mQueue.clear();
139 mQueue.clear();
147 while (!mQueue.isEmpty()) {
148 QueueElement element = mQueue.peekFirst();
160 mQueue.removeFirst();
181 mQueue.add(element);
|
| /frameworks/base/core/java/android/os/ |
| Looper.java | 71 final MessageQueue mQueue;
128 final MessageQueue queue = me.mQueue;
194 return myLooper().mQueue;
198 mQueue = new MessageQueue(quitAllowed);
244 mQueue.quit(false);
260 mQueue.quit(true);
278 return mQueue;
289 mQueue.dump(pw, prefix + " ");
|
| Handler.java | 203 mQueue = mLooper.mQueue;
229 mQueue = looper.mQueue;
495 mQueue.removeMessages(this, r, null);
505 mQueue.removeMessages(this, r, token);
605 MessageQueue queue = mQueue;
608 this + " sendMessageAtTime() called with no mQueue");
628 MessageQueue queue = mQueue;
631 this + " sendMessageAtTime() called with no mQueue");
[all...] |
| /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/ |
| ServiceResolveQueue.java | 29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>();
64 if (mQueue.contains(newRequest)) return;
65 mQueue.add(newRequest);
73 mQueue.remove(newRequest);
81 if (mQueue.isEmpty()) return;
82 mCurrentRequest = mQueue.removeFirst();
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
|
| /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/samsung/ |
| ServiceResolveQueue.java | 29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>();
64 if (mQueue.contains(newRequest)) return;
65 mQueue.add(newRequest);
73 mQueue.remove(newRequest);
81 if (mQueue.isEmpty()) return;
82 mCurrentRequest = mQueue.removeFirst();
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
|
| /frameworks/av/media/libmediaplayerservice/nuplayer/ |
| NuPlayerStreamListener.cpp | 63 mQueue.push_back(entry);
84 mQueue.push_back(entry);
107 if (mQueue.empty()) {
113 QueueEntry *entry = &*mQueue.begin();
119 mQueue.erase(mQueue.begin());
130 mQueue.erase(mQueue.begin());
166 mQueue.erase(mQueue.begin())
[all...] |
| /packages/apps/Gallery/src/com/android/camera/gallery/ |
| LruCache.java | 30 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>();
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>();
|
| /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/xerox/ |
| ServiceResolver.java | 102 private final LinkedList<NsdServiceInfo> mQueue = new LinkedList<>();
108 if (mQueue.contains(serviceInfo)) return;
109 mQueue.add(serviceInfo);
116 mQueue.remove(serviceInfo);
124 mQueue.clear();
131 if (mQueue.isEmpty()) return;
132 mCurrentRequest = mQueue.removeFirst();
137 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
|
| /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/ |
| ProviderExecutor.java | 51 private final LinkedBlockingQueue<Runnable> mQueue = new LinkedBlockingQueue<Runnable>();
88 mQueue.add(command);
96 mQueue.add(command);
103 final Runnable command = mQueue.take();
|
