| /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/services/inputflinger/tests/ |
| D | BlockingQueue_test.cpp | 34 BlockingQueue<int> queue(capacity); in TEST() local
53 BlockingQueue<int> queue(capacity); in TEST() local
68 BlockingQueue<int> queue(capacity); in TEST() local
80 BlockingQueue<int> queue(capacity); in TEST() local
92 BlockingQueue<int> queue(capacity); in TEST() local
109 BlockingQueue<int> queue(capacity); in TEST() local
134 BlockingQueue<int> queue(capacity); in TEST() local
151 BlockingQueue<int> queue; in TEST() local
|
| 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 | 137 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertCalled() local
159 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertNotCalled() local
174 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in addToQueue() 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/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
151 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeStopContinuousSyncTransaction() local
156 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeClearSyncTransaction() local
162 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeUpdate() local
168 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeMergeWithNextTransaction() local
174 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetLastAcquiredFrameNum() local
179 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/services/tests/mockingservicestests/src/com/android/server/am/ |
| D | BroadcastQueueModernImplTest.java | 186 private static void assertOrphan(BroadcastProcessQueue queue) { in assertOrphan()
255 private void enqueueOrReplaceBroadcast(BroadcastProcessQueue queue, in enqueueOrReplaceBroadcast()
260 private void enqueueOrReplaceBroadcast(BroadcastProcessQueue queue, in enqueueOrReplaceBroadcast()
391 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Empty() local
404 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Normal_Deferrable() local
431 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Normal() local
457 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Foreground() local
492 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Ordered() local
517 BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, in testRunnableAt_Huge() local
538 final BroadcastProcessQueue queue = new BroadcastProcessQueue(mConstants, PACKAGE_GREEN, in testRunnableAt_uidForeground() local
[all …]
|
| /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/base/services/core/java/com/android/server/am/ |
| D | BroadcastQueueModernImpl.java | 361 private void updateRunnableList(@NonNull BroadcastProcessQueue queue) { in updateRunnableList()
439 BroadcastProcessQueue queue = mRunnableHead; in updateRunningListLocked() local
576 private void reEnqueueActiveBroadcast(@NonNull BroadcastProcessQueue queue) { in reEnqueueActiveBroadcast()
594 final BroadcastProcessQueue queue = getProcessQueue(app); in onApplicationAttachedLocked() local
647 final BroadcastProcessQueue queue = getProcessQueue(app); in onApplicationCleanupLocked() local
694 final BroadcastProcessQueue queue = getProcessQueue(app); in getPreferredSchedulingGroupLocked() local
723 final BroadcastProcessQueue queue = getOrCreateProcessQueue( in enqueueBroadcastLocked() local
869 private boolean scheduleReceiverColdLocked(@NonNull BroadcastProcessQueue queue) { in scheduleReceiverColdLocked()
936 private boolean scheduleReceiverWarmLocked(@NonNull BroadcastProcessQueue queue) in scheduleReceiverWarmLocked()
977 private String shouldSkipReceiver(@NonNull BroadcastProcessQueue queue, in shouldSkipReceiver()
[all …]
|
| D | BroadcastProcessQueue.java | 323 final ArrayDeque<SomeArgs> queue = getQueueForBroadcast(record); in replaceBroadcast() local
337 private BroadcastRecord replaceBroadcastInQueue(@NonNull ArrayDeque<SomeArgs> queue, in replaceBroadcastInQueue()
407 private boolean forEachMatchingBroadcastInQueue(@NonNull ArrayDeque<SomeArgs> queue, in forEachMatchingBroadcastInQueue()
771 final ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in removeNextBroadcast() local
826 private static boolean isQueueEmpty(@Nullable ArrayDeque<SomeArgs> queue) { in isQueueEmpty()
881 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcast() local
887 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcastRecord() local
973 private boolean isDispatchedInQueue(@NonNull ArrayDeque<SomeArgs> queue, in isDispatchedInQueue()
1267 private void assertHealthLocked(@NonNull ArrayDeque<SomeArgs> queue) { in assertHealthLocked()
|
| /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 | 317 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper()
324 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper()
329 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents()
334 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent()
342 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent()
348 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/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/native/vulkan/libvulkan/ |
| D | api.h | 68 inline DeviceData& GetData(VkQueue queue) { in GetData()
|
| /frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/common/ |
| D | SyncTransactionQueue.java | 70 public void queue(WindowContainerTransaction wct) { in queue() method in SyncTransactionQueue
88 public void queue(LegacyTransitions.ILegacyTransition transition, in queue() method in SyncTransactionQueue
|
| /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/test-runner/src/android/test/ |
| D | LoaderTestCase.java | 57 final ArrayBlockingQueue<T> queue = new ArrayBlockingQueue<T>(1); in getLoaderResultSynchronously() local
|
| /frameworks/base/libs/hwui/thread/ |
| D | ThreadBase.h | 39 WorkQueue& queue() { return mQueue; } in queue() function
|
| /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
|