| /frameworks/base/services/tests/servicestests/src/com/android/server/textclassifier/ |
| D | FixedSizeQueueTest.java | 30 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(1, /* onEntryEvictedListener= */ null); in add_belowMaxCapacity() local
41 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(2, /* onEntryEvictedListener= */ null); in add_exceedMaxCapacity() local
54 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(1, /* onEntryEvictedListener= */ null); in poll() local
64 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(1, /* onEntryEvictedListener= */ null); in remove() local
74 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(1, /* onEntryEvictedListener= */ null); in remove_noSuchElement() local
83 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(1, /* onEntryEvictedListener= */ null); in isEmpty_true() local
90 FixedSizeQueue<Integer> queue = new FixedSizeQueue<>(1, /* onEntryEvictedListener= */ null); in isEmpty_false() local
100 FixedSizeQueue<Integer> queue = in onEntryEvicted() local
|
| /frameworks/native/libs/input/tests/ |
| D | BlockingQueue_test.cpp | 33 BlockingQueue<int> queue(capacity); in TEST() local
52 BlockingQueue<int> queue(capacity); in TEST() local
67 BlockingQueue<int> queue(capacity); in TEST() local
79 BlockingQueue<int> queue(capacity); in TEST() local
91 BlockingQueue<int> queue(capacity); in TEST() local
108 BlockingQueue<int> queue(capacity); in TEST() local
133 BlockingQueue<int> queue(capacity); in TEST() local
150 BlockingQueue<int> queue; in TEST() local
|
| /frameworks/base/services/core/java/com/android/server/am/ |
| D | BroadcastQueueModernImpl.java | 405 private void updateRunnableList(@NonNull BroadcastProcessQueue queue) { in updateRunnableList()
484 BroadcastProcessQueue queue = mRunnableHead; in updateRunningListLocked() local
635 private void finishOrReEnqueueActiveBroadcast(@NonNull BroadcastProcessQueue queue) { in finishOrReEnqueueActiveBroadcast()
661 final BroadcastProcessQueue queue = getProcessQueue(app); in onApplicationAttachedLocked() local
721 final BroadcastProcessQueue queue = getProcessQueue(app); in onApplicationCleanupLocked() local
773 final BroadcastProcessQueue queue = getProcessQueue(app); in getPreferredSchedulingGroupLocked() local
787 final BroadcastProcessQueue queue = getOrCreateProcessQueue( in enqueueBroadcastLocked() local
827 final BroadcastProcessQueue queue = getOrCreateProcessQueue( in enqueueBroadcastLocked() local
980 private boolean scheduleReceiverColdLocked(@NonNull BroadcastProcessQueue queue) { in scheduleReceiverColdLocked()
1054 private boolean scheduleReceiverWarmLocked(@NonNull BroadcastProcessQueue queue) in scheduleReceiverWarmLocked()
[all …]
|
| D | BroadcastProcessQueue.java | 372 final ArrayDeque<SomeArgs> queue = getQueueForBroadcast(record); in replaceBroadcast() local
386 private BroadcastRecord replaceBroadcastInQueue(@NonNull ArrayDeque<SomeArgs> queue, in replaceBroadcastInQueue()
472 private boolean forEachMatchingBroadcastInQueue(@NonNull ArrayDeque<SomeArgs> queue, in forEachMatchingBroadcastInQueue()
858 final ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in removeNextBroadcast() local
913 private static boolean isQueueEmpty(@Nullable ArrayDeque<SomeArgs> queue) { in isQueueEmpty()
968 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcast() local
974 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcastRecord() local
1060 private boolean isDispatchedInQueue(@NonNull ArrayDeque<SomeArgs> queue, in isDispatchedInQueue()
1367 private void assertHealthLocked(@NonNull ArrayDeque<SomeArgs> queue) { in assertHealthLocked()
|
| /frameworks/base/core/jni/ |
| D | android_graphics_BLASTBufferQueue.cpp | 93 sp<BLASTBufferQueue> queue = new BLASTBufferQueue(name.c_str(), updateDestinationFrame); in nativeCreate() local
99 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeDestroy() local
105 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetSurface() local
134 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeSyncNextTransaction() local
154 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeStopContinuousSyncTransaction() local
159 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeClearSyncTransaction() local
165 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeUpdate() local
171 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeMergeWithNextTransaction() local
177 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetLastAcquiredFrameNum() local
182 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeApplyPendingTransactions() local
[all …]
|
| D | android_view_InputQueue.cpp | 205 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); in nativeInit() local
215 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeDispose() local
222 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendKeyEvent() local
235 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendMotionEvent() local
|
| /frameworks/base/apct-tests/perftests/core/src/android/libcore/ |
| D | ReferencePerfTest.java | 44 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAlloc() local
54 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAllocAndEnqueue() local
64 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAllocEnqueueAndPoll() local
75 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in timeAllocEnqueueAndRemove() local
|
| /frameworks/base/libs/hwui/tests/unit/ |
| D | LayerUpdateQueueTests.cpp | 28 LayerUpdateQueue queue; in TEST() local
44 LayerUpdateQueue queue; in TEST() local
62 LayerUpdateQueue queue; in TEST() local
75 LayerUpdateQueue queue; in TEST() local
|
| /frameworks/native/services/inputflinger/tests/ |
| D | SyncQueue_test.cpp | 28 SyncQueue<int> queue; in TEST() local
42 SyncQueue<int> queue; in TEST() local
56 SyncQueue<int> queue(capacity); in TEST() local
66 SyncQueue<int> queue; in TEST() local
|
| D | TestInputListener.cpp | 149 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertCalled() local
171 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertNotCalled() local
186 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in addToQueue() local
|
| /frameworks/base/services/tests/mockingservicestests/src/com/android/server/am/ |
| D | BroadcastQueueModernImplTest.java | 156 private static void assertOrphan(BroadcastProcessQueue queue) { in assertOrphan()
220 private void enqueueOrReplaceBroadcast(BroadcastProcessQueue queue, in enqueueOrReplaceBroadcast()
225 private void enqueueOrReplaceBroadcast(BroadcastProcessQueue queue, in enqueueOrReplaceBroadcast()
356 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Empty() local
369 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Normal_Deferrable() local
397 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Normal() local
424 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Foreground() local
459 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Ordered() local
484 BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Huge() local
507 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, PACKAGE_GREEN, in testRunnableAt_uidForeground() local
[all …]
|
| /frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/ |
| D | ASensorManager.cpp | 160 std::shared_ptr<ASensorEventQueue> queue = in createEventQueue() local
182 void ASensorManager::destroyEventQueue(ASensorEventQueue *queue) { in destroyEventQueue()
266 ASensorManager* manager, ASensorEventQueue* queue) { in ASensorManager_destroyEventQueue()
305 ASensorEventQueue* queue, in ASensorEventQueue_registerSensor()
316 ASensorEventQueue* queue, ASensor const* sensor) { in ASensorEventQueue_enableSensor()
323 ASensorEventQueue* queue, ASensor const* sensor) { in ASensorEventQueue_disableSensor()
330 ASensorEventQueue* queue, in ASensorEventQueue_setEventRate()
337 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue) { in ASensorEventQueue_hasEvents()
343 ASensorEventQueue* queue, ASensorEvent* events, size_t count) { in ASensorEventQueue_getEvents()
349 int ASensorEventQueue_requestAdditionalInfoEvents(ASensorEventQueue* queue, bool enable) { in ASensorEventQueue_requestAdditionalInfoEvents()
|
| D | ALooper.cpp | 31 void ALooper::signalSensorEvents(const std::shared_ptr<ASensorEventQueue>& queue) { in signalSensorEvents()
74 for (auto& queue : mReadyQueues) { in pollOnce() local
92 void ALooper::invalidateSensorQueue(const std::shared_ptr<ASensorEventQueue>& queue) { in invalidateSensorQueue()
|
| /frameworks/base/native/android/ |
| D | sensor.cpp | 123 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
134 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue) { in ASensorManager_destroyEventQueue()
219 int ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor, in ASensorEventQueue_registerSensor()
233 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) { in ASensorEventQueue_enableSensor()
241 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) { in ASensorEventQueue_disableSensor()
249 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) { in ASensorEventQueue_setEventRate()
262 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue) { in ASensorEventQueue_hasEvents()
281 ssize_t ASensorEventQueue_getEvents(ASensorEventQueue* queue, ASensorEvent* events, size_t count) { in ASensorEventQueue_getEvents()
297 int ASensorEventQueue_requestAdditionalInfoEvents(ASensorEventQueue* queue, bool enable) { in ASensorEventQueue_requestAdditionalInfoEvents()
|
| D | input.cpp | 337 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper()
344 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper()
349 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents()
354 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent()
362 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent()
368 void AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled) { in AInputQueue_finishEvent()
|
| /frameworks/opt/telephony/tests/telephonytests/src/com/android/internal/telephony/ims/ |
| D | ImsTestBase.java | 139 MessageQueue queue = looper.getLooper().getQueue(); in getLongestDelay() local
158 MessageQueue queue = looper.getLooper().getQueue(); in messagesExist() local
199 MessageQueue queue = looper.getLooper().getQueue(); in moveTimeForward() local
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/policy/ |
| D | AvalancheController.kt | 368 val queue = ArrayList<String>() constant
377 val queue = ArrayList<String>() constant
386 val queue = ArrayList<String>() constant
|
| /frameworks/base/core/java/android/app/admin/ |
| D | PolicySizeVerifier.java | 67 Queue<PersistableBundle> queue = new ArrayDeque<>(); in enforceMaxStringLength() local
92 Queue<Bundle> queue = new ArrayDeque<>(); in enforceMaxBundleFieldsLength() local
|
| /frameworks/base/core/proto/android/os/ |
| D | looper.proto | 31 optional MessageQueueProto queue = 3; field
|
| /frameworks/av/media/libstagefright/rtsp/ |
| D | AAVCAssembler.cpp | 58 List<sp<ABuffer>> *queue = source->queue(); in addNack() local
117 List<sp<ABuffer> > *queue = source->queue(); in addNALUnit() local
410 ARTPAssembler::AssemblyStatus AAVCAssembler::addFragmentedNALUnit( in addFragmentedNALUnit()
617 int32_t AAVCAssembler::pickStartSeq(const Queue *queue, in pickStartSeq()
645 int32_t AAVCAssembler::deleteUnitUnderSeq(Queue *queue, uint32_t seq) { in deleteUnitUnderSeq()
|
| D | AHEVCAssembler.cpp | 67 List<sp<ABuffer>> *queue = source->queue(); in addNack() local
127 List<sp<ABuffer> > *queue = source->queue(); in addNALUnit() local
410 ARTPAssembler::AssemblyStatus AHEVCAssembler::addFragmentedNALUnit( in addFragmentedNALUnit()
620 int32_t AHEVCAssembler::pickStartSeq(const Queue *queue, in pickStartSeq()
648 int32_t AHEVCAssembler::deleteUnitUnderSeq(Queue *queue, uint32_t seq) { in deleteUnitUnderSeq()
|
| /frameworks/av/media/module/bufferpool/2.0/ |
| D | BufferStatus.cpp | 62 std::unique_ptr<BufferStatusQueue> queue = in open() local
108 std::unique_ptr<BufferStatusQueue> queue = in BufferStatusChannel() local
223 std::unique_ptr<BufferInvalidationQueue> queue = in BufferInvalidationListener() local
|
| /frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/common/ |
| D | SyncTransactionQueue.java | 73 public void queue(WindowContainerTransaction wct) { in queue() method in SyncTransactionQueue
91 public void queue(LegacyTransitions.ILegacyTransition transition, in queue() method in SyncTransactionQueue
|
| /frameworks/native/vulkan/libvulkan/ |
| D | api.h | 68 inline DeviceData& GetData(VkQueue queue) { in GetData()
|
| /frameworks/av/media/module/bufferpool/1.0/ |
| D | BufferStatus.cpp | 49 std::unique_ptr<BufferStatusQueue> queue = in open() local
95 std::unique_ptr<BufferStatusQueue> queue = in BufferStatusChannel() local
|