Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 119) sorted by relevance

12345

/frameworks/base/services/tests/servicestests/src/com/android/server/textclassifier/
DFixedSizeQueueTest.java30 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/
DBlockingQueue_test.cpp33 BlockingQueue<int> queue(capacity); in TEST() local
44 BlockingQueue<int> queue(capacity); in TEST() local
59 BlockingQueue<int> queue(capacity); in TEST() local
71 BlockingQueue<int> queue(capacity); in TEST() local
83 BlockingQueue<int> queue(capacity); in TEST() local
100 BlockingQueue<int> queue(capacity); in TEST() local
125 BlockingQueue<int> queue(capacity); in TEST() local
DTestInputListener.cpp120 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertCalled() local
140 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertNotCalled() local
153 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in notify() local
/frameworks/base/apct-tests/perftests/core/src/android/libcore/
DReferencePerfTest.java44 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/
DLayerUpdateQueueTests.cpp28 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/core/jni/
Dandroid_graphics_BLASTBufferQueue.cpp89 sp<BLASTBufferQueue> queue = new BLASTBufferQueue(name.c_str(), updateDestinationFrame); in nativeCreate() local
95 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeDestroy() local
101 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetSurface() local
128 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeSyncNextTransaction() local
149 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeStopContinuousSyncTransaction() local
155 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeUpdate() local
161 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeMergeWithNextTransaction() local
167 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetLastAcquiredFrameNum() local
172 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeApplyPendingTransactions() local
177 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeIsSameSurfaceControl() local
[all …]
Dandroid_view_InputQueue.cpp205 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
240 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendMotionEvent() local
/frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/
DASensorManager.cpp161 sp<ASensorEventQueue> queue = in createEventQueue() local
188 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()
DALooper.cpp33 void ALooper::signalSensorEvents(wp<ASensorEventQueue> queue) { in signalSensorEvents()
76 for (auto& queue : mReadyQueues) { in pollOnce() local
94 void ALooper::invalidateSensorQueue(wp<ASensorEventQueue> queue) { in invalidateSensorQueue()
/frameworks/base/native/android/
Dsensor.cpp123 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()
Dinput.cpp311 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper()
318 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper()
323 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents()
328 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent()
336 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent()
342 void AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled) { in AInputQueue_finishEvent()
/frameworks/base/core/proto/android/os/
Dlooper.proto31 optional MessageQueueProto queue = 3; field
/frameworks/av/media/libstagefright/rtsp/
DAAVCAssembler.cpp58 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()
DAHEVCAssembler.cpp67 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()
DAMPEG2TSAssembler.cpp55 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
/frameworks/native/vulkan/libvulkan/
Dapi.h68 inline DeviceData& GetData(VkQueue queue) { in GetData()
/frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/common/
DSyncTransactionQueue.java70 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/bufferpool/2.0/
DBufferStatus.cpp62 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/
DLoaderTestCase.java57 final ArrayBlockingQueue<T> queue = new ArrayBlockingQueue<T>(1); in getLoaderResultSynchronously() local
/frameworks/base/libs/hwui/thread/
DThreadBase.h39 WorkQueue& queue() { return mQueue; } in queue() function
/frameworks/av/media/codec2/components/base/
DSimpleC2Component.cpp625 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in queue_nb() local
653 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in flush_sm() local
683 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in drain_nb() local
727 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in stop() local
748 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in reset() local
782 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in finish() local
807 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in cloneAndSend() local
831 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue() local
933 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue() local
/frameworks/av/media/bufferpool/1.0/
DBufferStatus.cpp49 std::unique_ptr<BufferStatusQueue> queue = in open() local
95 std::unique_ptr<BufferStatusQueue> queue = in BufferStatusChannel() local
/frameworks/base/core/java/android/view/
DInputQueue.java151 void onInputQueueCreated(InputQueue queue); in onInputQueueCreated()
157 void onInputQueueDestroyed(InputQueue queue); in onInputQueueDestroyed()
/frameworks/av/media/libstagefright/
DMediaCodecSource.cpp151 Mutexed<Queue>::Locked queue(mQueue); in readBuffer() local
192 Mutexed<Queue>::Locked queue(mQueue); in stop() local
209 Mutexed<Queue>::Locked queue(mQueue); in pause() local
214 Mutexed<Queue>::Locked queue(mQueue); in resume() local
238 Mutexed<Queue>::Locked queue(mQueue); in onMessageReceived() local
286 Mutexed<Queue>::Locked queue(mQueue); in onMessageReceived() local
/frameworks/base/media/java/android/media/session/
DISessionControllerCallback.aidl34 void onQueueChanged(in ParceledListSlice queue); in onQueueChanged()

12345