| /aosp14/frameworks/base/services/tests/servicestests/src/com/android/server/textclassifier/ |
| H A D | FixedSizeQueueTest.java | 33 queue.add(1); in add_belowMaxCapacity()
43 queue.add(1); in add_exceedMaxCapacity()
44 queue.add(2); in add_exceedMaxCapacity()
45 queue.add(3); in add_exceedMaxCapacity()
56 queue.add(1); in poll()
66 queue.add(1); in remove()
76 queue.add(1); in remove_noSuchElement()
92 queue.add(1); in isEmpty_false()
103 queue.add(1); in onEntryEvicted()
104 queue.add(2); in onEntryEvicted()
[all …]
|
| /aosp14/frameworks/base/libs/hwui/tests/unit/ |
| H A D | LayerUpdateQueueTests.cpp | 28 LayerUpdateQueue queue; in TEST() local
29 EXPECT_TRUE(queue.entries().empty()); in TEST()
44 LayerUpdateQueue queue; in TEST() local
49 EXPECT_EQ(3u, queue.entries().size()); in TEST()
62 LayerUpdateQueue queue; in TEST() local
66 EXPECT_EQ(1u, queue.entries().size()); in TEST()
75 LayerUpdateQueue queue; in TEST() local
76 queue.enqueueLayerWithDamage(a.get(), Rect(100, 100)); in TEST()
78 EXPECT_FALSE(queue.entries().empty()); in TEST()
80 queue.clear(); in TEST()
[all …]
|
| H A D | ThreadBaseTests.cpp | 39 static WorkQueue& queue() { in queue() function
40 return thread().queue(); in queue()
45 queue().post([&ran]() { ran = true; }); in TEST()
57 queue().postDelayed(100_us, [&]() { ranAtPromise.set_value(clock::now()); }); in TEST()
67 auto result = queue().runSync([&otherTid]() -> auto { in TEST()
80 auto otherTid = queue().async([]() -> auto { return gettid(); }); in TEST()
81 auto otherPid = queue().async([]() -> auto { return getpid(); }); in TEST()
82 auto result = queue().async([]() -> auto { return 42; }); in TEST()
132 queue().runSync([c = std::move(counter)](){}); in TEST()
141 return queue().runSync([t = test]()->int { return t->getStrongCount(); }); in lifecycleTestHelper()
[all …]
|
| /aosp14/frameworks/base/services/core/java/com/android/server/am/ |
| H A D | BroadcastQueueModernImpl.java | 397 if (queue.isEmpty() && !queue.isActive() && !queue.isProcessWarm()) { in updateRunnableList()
398 removeProcessQueue(queue.processName, queue.uid); in updateRunnableList()
653 if (queue != null && queue.app == app) { in onApplicationCleanupLocked()
695 if ((queue != null) && getRunningIndexOf(queue) >= 0) { in getPreferredSchedulingGroupLocked()
1027 queue.lastCpuDelayTime = queue.app.getCpuDelayTime(); in dispatchReceivers()
1199 if ((queue == null) || !queue.isActive()) { in finishReceiverLocked()
1325 queue.runningOomAdjusted = queue.isPendingManifest() in promoteToRunningLocked()
1783 checkState(queue.isActive(), "isActive " + queue); in assertHealthLocked() local
1864 if (queue == null || queue.app == null || queue.app.getPid() != app.getPid()) { in refreshProcessQueueLocked()
1867 setQueueProcess(queue, queue.app); in refreshProcessQueueLocked()
[all …]
|
| H A D | BroadcastProcessQueue.java | 411 final Iterator<SomeArgs> it = queue.iterator(); in forEachMatchingBroadcastInQueue()
772 if (queue == mPendingUrgent) { in removeNextBroadcast()
774 } else if (queue == mPending) { in removeNextBroadcast()
777 } else if (queue == mPendingOffload) { in removeNextBroadcast()
781 return !isQueueEmpty(queue) ? queue.removeFirst() : null; in removeNextBroadcast()
827 return (queue == null || queue.isEmpty()); in isQueueEmpty()
881 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcast() local
882 return !isQueueEmpty(queue) ? queue.peekFirst() : null; in peekNextBroadcast()
888 return !isQueueEmpty(queue) ? (BroadcastRecord) queue.peekFirst().arg1 : null; in peekNextBroadcastRecord()
975 final Iterator<SomeArgs> it = queue.iterator(); in isDispatchedInQueue()
[all …]
|
| H A D | BroadcastLoopers.java | 78 final MessageQueue queue = looper.getQueue(); in waitForIdle()
79 queue.addIdleHandler(() -> { in waitForIdle()
110 final MessageQueue queue = looper.getQueue(); in waitForCondition() local
111 if (queue.isIdle()) { in waitForCondition()
|
| H A D | BroadcastQueue.md | 37 Each per-process queue has the concept of a _runnable at_ timestamp when it's
51 Each per-process queue represents a single remote `ApplicationThread`, and we
61 into a _running_ state. We choose the next per-process queue to promote based
83 * A per-process queue that has a delayed _runnable at_ policy applied can risk
85 `BroadcastConstants.MAX_PENDING_BROADCASTS` bypassing any delays when the queue
87 * A per-process queue that has a large number of pending broadcasts can risk
93 by maintaining a separate `mPendingUrgent` queue of urgent events, which we
94 prefer to dispatch before the normal `mPending` queue.
|
| /aosp14/frameworks/base/services/tests/mockingservicestests/src/com/android/server/am/ |
| H A D | BroadcastQueueModernImplTest.java | 507 queue.invalidateRunnableAt(); in testRunnableAt_Ordered()
526 queue.invalidateRunnableAt(); in testRunnableAt_Huge()
531 queue.invalidateRunnableAt(); in testRunnableAt_Huge()
760 assertTrue(queue.isEmpty()); in testMakeActiveNextPending()
1006 verifyPendingRecords(queue, in testDeliveryGroupPolicy_mostRecent()
1017 verifyPendingRecords(queue, in testDeliveryGroupPolicy_mostRecent()
1027 verifyPendingRecords(queue, in testDeliveryGroupPolicy_mostRecent()
1290 verifyPendingRecords(queue, in testDeliveryGroupPolicy_matchingFilter()
1301 verifyPendingRecords(queue, in testDeliveryGroupPolicy_matchingFilter()
1311 verifyPendingRecords(queue, in testDeliveryGroupPolicy_matchingFilter()
[all …]
|
| /aosp14/frameworks/base/libs/hwui/renderthread/ |
| H A D | RenderProxy.cpp | 138 mRenderThread.queue().post( in setLightAlpha()
246 thread.queue().post([&thread]() { in purgeCaches()
287 mRenderThread.queue().runSync([&]() { in dumpProfileInfo()
303 mRenderThread.queue().runSync([=]() { in resetProfileInfo()
319 thread.queue().runSync([&]() { in dumpGraphicsMemory()
374 mRenderThread.queue().post( in setPictureCapturedCallback()
380 mRenderThread.queue().post( in setASurfaceTransactionCallback()
386 mRenderThread.queue().post( in setPrepareSurfaceControlForWebviewCallback()
451 renderThread->queue().post(task); in prepareToDraw()
462 return thread.queue().runSync( in copyHWBitmapInto()
[all …]
|
| /aosp14/frameworks/base/core/jni/ |
| H A D | android_graphics_BLASTBufferQueue.cpp | 94 queue->incStrong((void*)nativeCreate); in nativeCreate()
95 return reinterpret_cast<jlong>(queue.get()); in nativeCreate()
99 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeDestroy() local
100 queue->decStrong((void*)nativeCreate); in nativeDestroy()
139 return queue->syncNextTransaction( in nativeSyncNextTransaction()
152 queue->stopContinuousSyncTransaction(); in nativeStopContinuousSyncTransaction()
157 queue->clearSyncTransaction(); in nativeClearSyncTransaction()
175 return queue->getLastAcquiredFrameNum(); in nativeGetLastAcquiredFrameNum()
180 queue->applyPendingTransactions(frameNum); in nativeApplyPendingTransactions()
192 queue->setTransactionHangCallback(nullptr); in nativeSetTransactionHangCallback()
[all …]
|
| H A D | android_view_InputQueue.cpp | 206 if (!queue.get()) { in nativeInit()
210 queue->incStrong(&gInputQueueClassInfo); in nativeInit()
211 return reinterpret_cast<jlong>(queue.get()); in nativeInit()
215 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeDispose() local
216 queue->detachLooper(); in nativeDispose()
217 queue->decStrong(&gInputQueueClassInfo); in nativeDispose()
222 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendKeyEvent() local
223 KeyEvent* event = queue->createKeyEvent(); in nativeSendKeyEvent()
230 queue->enqueueEvent(event); in nativeSendKeyEvent()
241 MotionEvent* event = queue->createMotionEvent(); in nativeSendMotionEvent()
[all …]
|
| /aosp14/frameworks/base/native/android/ |
| H A D | sensor.cpp | 58 if (queue == nullptr) { \
123 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
125 if (queue != 0) { in ASensorManager_createEventQueue()
127 queue->looper = looper; in ASensorManager_createEventQueue()
128 queue->requestAdditionalInfo = false; in ASensorManager_createEventQueue()
129 queue->incStrong(manager); in ASensorManager_createEventQueue()
131 return static_cast<ASensorEventQueue*>(queue.get()); in ASensorManager_createEventQueue()
228 return static_cast<SensorEventQueue*>(queue)->enableSensor( in ASensorEventQueue_registerSensor()
262 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue) { in ASensorEventQueue_hasEvents() argument
266 pfd.fd = static_cast<SensorEventQueue*>(queue)->getFd(); in ASensorEventQueue_hasEvents()
[all …]
|
| H A D | input.cpp | 317 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper() argument
319 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_attachLooper()
324 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper() argument
325 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_detachLooper()
329 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents() argument
330 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_hasEvents()
334 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent() argument
335 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_getEvent()
342 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent() argument
343 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_preDispatchEvent()
[all …]
|
| /aosp14/frameworks/base/apct-tests/perftests/core/src/android/libcore/ |
| H A D | ReferencePerfTest.java | 44 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAlloc() local
47 new PhantomReference(mObject, queue); in timeAlloc()
54 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAllocAndEnqueue() local
57 (new PhantomReference<Object>(mObject, queue)).enqueue(); in timeAllocAndEnqueue()
64 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAllocEnqueueAndPoll() local
67 (new PhantomReference<Object>(mObject, queue)).enqueue(); in timeAllocEnqueueAndPoll()
68 queue.poll(); in timeAllocEnqueueAndPoll()
75 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAllocEnqueueAndRemove() local
78 (new PhantomReference<Object>(mObject, queue)).enqueue(); in timeAllocEnqueueAndRemove()
80 queue.remove(); in timeAllocEnqueueAndRemove()
|
| /aosp14/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| H A D | FrameQueue.java | 38 public void attachQueue(FrameQueue queue) { in attachQueue() argument
39 mAttachedQueues.add(queue); in attachQueue()
51 private void buildQueueImpl(FrameQueue queue) { in buildQueueImpl() argument
52 QueueImpl queueImpl = queue.new SingleFrameQueueImpl(); in buildQueueImpl()
53 queue.mQueueImpl = queueImpl; in buildQueueImpl()
58 for (FrameQueue queue : mAttachedQueues) { in buildType()
59 result = FrameType.merge(result, queue.mType); in buildType()
|
| /aosp14/system/core/storaged/ |
| H A D | storaged_diskstats.cpp | 44 << " q: " << perf->queue; in log_debug_disk_perf()
170 perf.queue = (stats->io_in_queue + (stats->io_ticks >> 1)) / in get_disk_perf()
218 mMean.queue = (uint32_t)mStats.queue.get_mean(); in update_mean()
228 mStd.queue = (uint32_t)mStats.queue.get_std(); in update_std()
237 mStats.queue.add(perf->queue); in add()
245 mStats.queue.evict(perf->queue); in evict()
250 return ((double)perf->queue >= (double)mMean.queue + mSigma * (double)mStd.queue) && in detect()
|
| /aosp14/frameworks/base/services/tests/servicestests/src/com/android/server/pm/ |
| H A D | UserManagerServiceIdRecyclingTest.java | 98 LinkedHashSet<Integer> queue = new LinkedHashSet<>(); in testUserCreateRecycleIdsOverflow() local
102 assertTrue("Returned id should not be recent. Id=" + userId + ". Recents=" + queue, in testUserCreateRecycleIdsOverflow()
103 queue.add(userId)); in testUserCreateRecycleIdsOverflow()
104 if (queue.size() > UserManagerService.MAX_RECENTLY_REMOVED_IDS_SIZE) { in testUserCreateRecycleIdsOverflow()
105 queue.remove(queue.iterator().next()); in testUserCreateRecycleIdsOverflow()
|
| /aosp14/frameworks/base/core/java/android/hardware/ |
| H A D | SystemSensorManager.java | 268 if (queue == null) { in registerListenerImpl()
276 queue.dispose(); in registerListenerImpl()
297 if (queue != null) { in unregisterListenerImpl()
304 if (result && !queue.hasSensors()) { in unregisterListenerImpl()
306 queue.dispose(); in unregisterListenerImpl()
329 if (queue == null) { in requestTriggerSensorImpl()
336 queue.dispose(); in requestTriggerSensorImpl()
356 if (queue != null) { in cancelTriggerSensorImpl()
365 queue.dispose(); in cancelTriggerSensorImpl()
378 if (queue == null) { in flushImpl()
[all …]
|
| /aosp14/system/core/debuggerd/tombstoned/ |
| H A D | tombstoned.cpp | 129 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */, in for_tombstones() local
132 return &queue; in for_tombstones()
136 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */, in for_anrs() local
139 return &queue; in for_anrs()
433 CrashQueue* queue = CrashQueue::for_crash(crash); in crash_completed() local
456 CrashArtifactPaths paths = queue->get_next_artifact_paths(); in crash_completed()
458 if (rename_tombstone_fd(crash->output.text.fd, queue->dir_fd(), paths.text)) { in crash_completed()
473 rename_tombstone_fd(crash->output.proto->fd, queue->dir_fd(), *paths.proto); in crash_completed()
494 CrashQueue* queue = CrashQueue::for_crash(crash); in crash_completed_cb() local
496 queue->on_crash_completed(); in crash_completed_cb()
[all …]
|
| /aosp14/frameworks/base/libs/WindowManager/Shell/tests/unittest/src/com/android/wm/shell/common/ |
| H A D | LaunchAdjacentControllerTest.kt | 68 verify(syncQueue, never()).queue(any())
108 verify(syncQueue, never()).queue(any())
118 verify(syncQueue).queue(any())
133 verify(syncQueue, never()).queue(any())
144 verify(syncQueue).queue(any())
149 verify(syncQueue, atLeastOnce()).queue(arg.capture())
|
| /aosp14/frameworks/base/services/accessibility/java/com/android/server/accessibility/magnification/ |
| H A D | MagnificationGestureHandler.java | 154 private static void storeEventInto(Queue<MotionEvent> queue, MotionEvent event) { in storeEventInto() argument
155 queue.add(MotionEvent.obtain(event)); in storeEventInto()
157 while (!queue.isEmpty() && (event.getEventTime() - queue.peek().getEventTime() > 5000)) { in storeEventInto()
158 queue.remove().recycle(); in storeEventInto()
|
| /aosp14/frameworks/base/test-runner/src/android/test/ |
| H A D | LoaderTestCase.java | 57 final ArrayBlockingQueue<T> queue = new ArrayBlockingQueue<T>(1); in getLoaderResultSynchronously() local
70 queue.add(data); in getLoaderResultSynchronously()
92 result = queue.take(); in getLoaderResultSynchronously()
|
| /aosp14/frameworks/base/core/java/android/app/ |
| H A D | NativeActivity.java | 91 private native long loadNativeCode(String path, String funcname, MessageQueue queue, in loadNativeCode() argument
287 public void onInputQueueCreated(InputQueue queue) { in onInputQueueCreated() argument
289 mCurInputQueue = queue; in onInputQueueCreated()
290 onInputQueueCreatedNative(mNativeHandle, queue.getNativePtr()); in onInputQueueCreated()
294 public void onInputQueueDestroyed(InputQueue queue) { in onInputQueueDestroyed() argument
296 onInputQueueDestroyedNative(mNativeHandle, queue.getNativePtr()); in onInputQueueDestroyed()
|
| /aosp14/frameworks/base/core/java/android/os/ |
| H A D | Handler.java | 728 MessageQueue queue = mQueue; in sendMessageAtTime() local
729 if (queue == null) { in sendMessageAtTime()
735 return enqueueMessage(queue, msg, uptimeMillis); in sendMessageAtTime()
751 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue() local
752 if (queue == null) { in sendMessageAtFrontOfQueue()
758 return enqueueMessage(queue, msg, 0); in sendMessageAtFrontOfQueue()
778 private boolean enqueueMessage(@NonNull MessageQueue queue, @NonNull Message msg, in enqueueMessage() argument
786 return queue.enqueueMessage(msg, uptimeMillis); in enqueueMessage()
|
| /aosp14/frameworks/base/libs/hwui/hwui/ |
| H A D | AnimatedImageThread.cpp | 39 return queue().async([drawable]() { return drawable->decodeNextFrame(); }); in decodeNextFrame()
44 return queue().async([drawable]() { return drawable->reset(); }); in reset()
|