| /aosp14/frameworks/base/services/tests/mockingservicestests/src/com/android/server/ |
| H A D | CircularQueueTest.java | 34 mQueue = new CircularQueue<>(LIMIT); in testQueueInsertionAndDeletion()
35 mQueue.put(1, "A"); in testQueueInsertionAndDeletion()
37 mQueue.removeElement(1); in testQueueInsertionAndDeletion()
38 assertNull(mQueue.getElement(1)); in testQueueInsertionAndDeletion()
43 mQueue = new CircularQueue<>(LIMIT); in testQueueLimit()
44 mQueue.put(1, "A"); in testQueueLimit()
45 mQueue.put(2, "B"); in testQueueLimit()
47 assertNull(mQueue.getElement(1)); in testQueueLimit()
57 mQueue.put(1, "A"); in testQueueElements()
58 mQueue.put(2, "B"); in testQueueElements()
[all …]
|
| /aosp14/frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/common/ |
| H A D | SyncTransactionQueue.java | 54 synchronized (mQueue) {
76 synchronized (mQueue) { in queue()
78 mQueue.add(cb); in queue()
79 if (mQueue.size() == 1) { in queue()
95 synchronized (mQueue) { in queue()
97 mQueue.add(cb); in queue()
98 if (mQueue.size() == 1) { in queue()
114 synchronized (mQueue) { in queueIfWaiting()
115 if (mQueue.isEmpty()) { in queueIfWaiting()
121 mQueue.add(cb); in queueIfWaiting()
[all …]
|
| /aosp14/frameworks/base/services/tests/servicestests/src/com/android/server/timezonedetector/location/ |
| H A D | TestThreadingDomain.java | 65 private ArrayList<QueuedRunnable> mQueue = new ArrayList<>(); field in TestThreadingDomain
94 mQueue.add(new QueuedRunnable(r, token, mCurrentTimeMillis + delayMillis)); in postDelayed()
95 mQueue.sort(QueuedRunnable.COMPARATOR); in postDelayed()
100 mQueue.removeIf(runnable -> runnable.token != null && runnable.token == token); in removeQueuedRunnables()
104 mQueue.clear(); in removeAllQueuedRunnables()
118 assertEquals(expectedLength, mQueue.size()); in assertQueueLength()
130 assertTrue(mQueue.isEmpty()); in assertQueueEmpty()
134 assertFalse(mQueue.isEmpty()); in getNextQueueItemDelayMillis()
135 return mQueue.get(0).executionTimeMillis - mCurrentTimeMillis; in getNextQueueItemDelayMillis()
139 assertFalse(mQueue.isEmpty()); in executeNext()
[all …]
|
| /aosp14/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| H A D | InputPort.java | 43 private FrameQueue mQueue = null; field in InputPort
178 if (mQueue == null) { in pullFrame()
181 Frame frame = mQueue.pullFrame(); in pullFrame()
197 if (mQueue == null) { in peek()
200 return mQueue.peek(); in peek()
208 return mQueue != null; in isConnected()
216 return mQueue != null && mQueue.canPull(); in hasFrame()
292 mQueue = queue; in setQueue()
297 return mQueue; in getQueue()
301 if (mQueue != null) { in clear()
[all …]
|
| H A D | OutputPort.java | 39 private FrameQueue mQueue = null; field in OutputPort
56 return mQueue == null || mQueue.canPush(); in isAvailable()
165 return mQueue; in getQueue()
169 mQueue = queue; in setQueue()
180 return mQueue != null; in isOpen()
188 if (mQueue != null) { in clear()
189 mQueue.clear(); in clear()
|
| H A D | FrameManager.java | 161 private PriorityQueue<Backing> mQueue; field in FrameManager.PriorityBackingCache
164 mQueue = new PriorityQueue<Backing>(4, new Comparator<Backing>() { in PriorityBackingCache()
174 for (Backing backing : mQueue) { in fetchBacking()
181 mQueue.remove(backing); in fetchBacking()
195 mQueue.add(backing); in cacheBacking()
203 mQueue.clear(); in clear()
224 Backing dropped = mQueue.poll(); in reserve()
|
| /aosp14/frameworks/base/services/core/jni/BroadcastRadio/ |
| H A D | NativeCallbackThread.cpp | 57 if (mQueue.empty()) { in threadLoop()
61 if (mQueue.empty()) continue; in threadLoop()
64 task = mQueue.front(); in threadLoop()
65 mQueue.pop(); in threadLoop()
81 ALOGD_IF(!mQueue.empty(), "Skipped execution of %zu tasks", mQueue.size()); in threadLoop()
93 mQueue.push(task); in enqueue()
|
| /aosp14/frameworks/base/core/java/android/os/ |
| H A D | Handler.java | 230 mQueue = mLooper.mQueue; in Handler()
264 mQueue = looper.mQueue; in Handler()
621 mQueue.removeMessages(this, r, null); in removeCallbacks()
630 mQueue.removeMessages(this, r, token); in removeCallbacks()
728 MessageQueue queue = mQueue; in sendMessageAtTime()
751 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue()
802 mQueue.removeMessages(this, what, null); in removeMessages()
861 return mQueue.hasMessages(this); in hasMessagesOrCallbacks()
887 return mQueue.hasMessages(this, r, null); in hasCallbacks()
927 synchronized (mQueue) { in getIMessenger()
[all …]
|
| H A D | Looper.java | 78 final MessageQueue mQueue; field in Looper
162 Message msg = me.mQueue.next(); // might block in loopOnce()
327 return myLooper().mQueue; in myQueue()
331 mQueue = new MessageQueue(quitAllowed); in Looper()
387 mQueue.quit(false); in quit()
403 mQueue.quit(true); in quitSafely()
421 return mQueue; in getQueue()
432 mQueue.dump(pw, prefix + " ", null); in dump()
445 mQueue.dump(pw, prefix + " ", handler); in dump()
453 if (mQueue != null) { in dumpDebug()
[all …]
|
| H A D | TestLooperManager.java | 35 private final MessageQueue mQueue; field in TestLooperManager
53 mQueue = mLooper.getQueue(); in TestLooperManager()
63 return mQueue; in getMessageQueue()
91 return mQueue.next(); in next()
156 return mQueue.hasMessages(h, what, object); in hasMessages()
168 return mQueue.hasMessages(h, r, object); in hasMessages()
|
| /aosp14/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/ |
| H A D | ServiceResolveQueue.java | 29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>(); field in ServiceResolveQueue
64 if (mQueue.contains(newRequest)) return; in queueRequest()
65 mQueue.add(newRequest); in queueRequest()
73 mQueue.remove(newRequest); in removeRequest()
81 if (mQueue.isEmpty()) return; in makeNextRequest()
82 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
|
| /aosp14/frameworks/base/core/java/android/speech/tts/ |
| H A D | AudioPlaybackHandler.java | 27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue = field in AudioPlaybackHandler
51 mQueue.put(item); in enqueue()
80 return (mQueue.peek() != null) || (mCurrentWorkItem != null); in isSpeaking()
96 mQueue.clear(); in removeAllMessages()
103 Iterator<PlaybackQueueItem> it = mQueue.iterator(); in removeWorkItemsFor()
124 item = mQueue.take(); in run()
|
| /aosp14/frameworks/base/libs/hwui/thread/ |
| H A D | ThreadBase.h | 37 , mQueue([this]() { mLooper->wake(); }, mLock) {} in ThreadBase()
39 WorkQueue& queue() { return mQueue; } in queue()
57 nextWakeup = mQueue.nextWakeup(lock); in waitForWork()
68 void processQueue() { mQueue.process(); } in processQueue()
83 WorkQueue mQueue;
|
| /aosp14/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/xerox/ |
| H A D | ServiceResolver.java | 105 private final LinkedList<NsdServiceInfo> mQueue = new LinkedList<>(); field in ServiceResolver
111 if (mQueue.contains(serviceInfo)) return; in queueRequest()
112 mQueue.add(serviceInfo); in queueRequest()
119 mQueue.remove(serviceInfo); in removeRequest()
127 mQueue.clear(); in clearRequests()
134 if (mQueue.isEmpty()) return; in makeNextRequest()
135 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
140 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
|
| /aosp14/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/ |
| H A D | BlockingQueueIntentReceiver.java | 27 private final BlockingQueue<Intent> mQueue = new ArrayBlockingQueue<Intent>(1); field in BlockingQueueIntentReceiver
31 mQueue.add(intent); in onReceive()
35 return mQueue.poll(10, TimeUnit.SECONDS); in waitForIntent()
39 return mQueue.poll(3, TimeUnit.SECONDS); in waitForIntentShortDelay()
|
| /aosp14/frameworks/base/core/tests/utiltests/src/com/android/internal/util/ |
| H A D | PersistentServiceConnectionTest.java | 196 private final Queue<Runnable> mQueue = new ArrayDeque<>(); field in PersistentServiceConnectionTest.FakeExecutor
200 mQueue.add(command); in execute()
204 while (!mQueue.isEmpty()) { in runAll()
205 mQueue.remove().run(); in runAll()
210 while (!mQueue.isEmpty()) { in clearAll()
211 mQueue.remove(); in clearAll()
|
| H A D | ObservableServiceConnectionTest.java | 207 private final Queue<Runnable> mQueue = new ArrayDeque<>(); field in ObservableServiceConnectionTest.FakeExecutor
211 mQueue.add(command); in execute()
215 while (!mQueue.isEmpty()) { in runAll()
216 mQueue.remove().run(); in runAll()
221 while (!mQueue.isEmpty()) { in clearAll()
222 mQueue.remove(); in clearAll()
|
| /aosp14/frameworks/base/tests/ActivityManagerPerfTests/tests/src/com/android/frameworks/perftests/am/util/ |
| H A D | TimeReceiver.java | 36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>(); field in TimeReceiver
56 mQueue.add(new ReceivedMessage(type, timeNs)); in addTimeForTypeToQueue()
88 message = mQueue.poll(endTimeNs - curTimeNs, TimeUnit.NANOSECONDS); in getReceivedTimeNs()
108 mQueue.clear(); in clear()
|
| /aosp14/frameworks/base/services/tests/mockingservicestests/src/com/android/server/am/ |
| H A D | BroadcastQueueTest.java | 172 private BroadcastQueue mQueue; field in BroadcastQueueTest
700 mQueue.enqueueBroadcastLocked(r);
710 mQueue.waitForIdle(LOG_WRITER_INFO);
826 mQueue.dumpToDropBoxLocked(TAG);
831 assertNotNull(mQueue.toString());
2019 assertTrue(mQueue.isIdleLocked());
2027 assertFalse(mQueue.isIdleLocked());
2036 assertFalse(mQueue.isIdleLocked());
2043 mQueue.waitForBarrier(LOG_WRITER_INFO);
2046 mQueue.waitForIdle(LOG_WRITER_INFO);
[all …]
|
| /aosp14/frameworks/base/services/robotests/src/com/android/server/testing/shadows/ |
| H A D | ShadowKeyValueBackupTask.java | 54 private List<String> mQueue; field in ShadowKeyValueBackupTask
72 mQueue = queue; in __constructor__()
83 return mQueue; in getQueue()
|
| /aosp14/frameworks/base/tests/OneMedia/src/com/android/onemedia/ |
| H A D | PlayerSession.java | 48 protected ArrayList<MediaSession.QueueItem> mQueue; field in PlayerSession
64 mQueue = new ArrayList<MediaSession.QueueItem>(); in PlayerSession()
121 mQueue.clear(); in setIcon()
122 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11)); in setIcon()
132 mSession.setQueue(mUseQueue ? mQueue : null); in updateMetadata()
155 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11)); in initMetadata()
|
| /aosp14/frameworks/base/packages/Shell/tests/src/com/android/shell/ |
| H A D | ActionSendMultipleConsumerActivity.java | 90 private final BlockingQueue<Bundle> mQueue = new SynchronousQueue<>(); field in ActionSendMultipleConsumerActivity.CustomActionSendMultipleListener
98 mQueue.put(intent.getExtras()); in CustomActionSendMultipleListener()
118 bundle = mQueue.poll(2 * TIMEOUT, TimeUnit.SECONDS); in getExtras()
|
| /aosp14/frameworks/base/services/core/java/com/android/server/pm/ |
| H A D | ParallelPackageParser.java | 46 private final BlockingQueue<ParseResult> mQueue = new ArrayBlockingQueue<>(QUEUE_CAPACITY); field in ParallelPackageParser
88 return mQueue.take(); in take()
114 mQueue.put(pr); in submit()
|
| /aosp14/frameworks/base/core/java/com/android/internal/infra/ |
| H A D | ServiceConnector.java | 254 private final @NonNull Queue<Job<I, ?>> mQueue = this; field in ServiceConnector.Impl
456 } else if (!mQueue.offer(job)) { in enqueueJobThread()
500 while ((job = mQueue.poll()) != null) { in processQueue()
528 if (mUnfinishedJobs.isEmpty() && mQueue.isEmpty()) { in maybeScheduleUnbindTimeout()
602 while ((job = mQueue.poll()) != null) { in cancelPendingJobs()
690 if (!mQueue.isEmpty()) { in toString()
691 sb.append(", ").append(mQueue.size()).append(" pending job(s)"); in toString()
711 .append("Pending jobs: ").append(String.valueOf(mQueue.size())).println(); in dump()
713 for (Job<I, ?> pendingJob : mQueue) { in dump()
774 boolean wasRemoved = mQueue.remove(this); in cancel()
|
| /aosp14/frameworks/base/services/backup/java/com/android/server/backup/internal/ |
| H A D | PerformInitializeTask.java | 54 private final String[] mQueue; field in PerformInitializeTask
83 mQueue = transportNames; in PerformInitializeTask()
112 List<TransportConnection> transportClientsToDisposeOf = new ArrayList<>(mQueue.length); in run()
115 for (String transportName : mQueue) { in run()
|