| /aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/textclassifier/ |
| H A 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
|
| /aosp12/system/bt/osi/src/ |
| H A D | fixed_queue.cc | 96 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
103 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
110 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
116 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
130 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
162 void* fixed_queue_try_dequeue(fixed_queue_t* queue) { in fixed_queue_try_dequeue()
179 void* fixed_queue_try_peek_first(fixed_queue_t* queue) { in fixed_queue_try_peek_first()
186 void* fixed_queue_try_peek_last(fixed_queue_t* queue) { in fixed_queue_try_peek_last()
213 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
222 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
[all …]
|
| /aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/ |
| H A D | mm_jpeg_queue.c | 37 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) in mm_jpeg_queue_init()
45 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, mm_jpeg_q_data_t data) in mm_jpeg_queue_enq()
66 int32_t mm_jpeg_queue_enq_head(mm_jpeg_queue_t* queue, mm_jpeg_q_data_t data) in mm_jpeg_queue_enq_head()
91 mm_jpeg_q_data_t mm_jpeg_queue_deq(mm_jpeg_queue_t* queue) in mm_jpeg_queue_deq()
118 uint32_t mm_jpeg_queue_get_size(mm_jpeg_queue_t* queue) in mm_jpeg_queue_get_size()
130 int32_t mm_jpeg_queue_deinit(mm_jpeg_queue_t* queue) in mm_jpeg_queue_deinit()
137 int32_t mm_jpeg_queue_flush(mm_jpeg_queue_t* queue) in mm_jpeg_queue_flush()
165 mm_jpeg_q_data_t mm_jpeg_queue_peek(mm_jpeg_queue_t* queue) in mm_jpeg_queue_peek()
|
| /aosp12/system/bt/osi/test/ |
| H A D | fixed_queue_test.cc | 40 static void fixed_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in fixed_queue_ready()
55 fixed_queue_t* queue; in TEST_F() local
83 fixed_queue_t* queue; in TEST_F() local
125 fixed_queue_t* queue; in TEST_F() local
147 fixed_queue_t* queue; in TEST_F() local
169 fixed_queue_t* queue; in TEST_F() local
197 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
234 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
264 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
295 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
[all …]
|
| /aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-test/src/ |
| H A D | mm_qcamera_queue.c | 34 int mm_camera_queue_init(mm_camera_queue_t *queue, in mm_camera_queue_init()
51 int mm_qcamera_queue_release(mm_camera_queue_t *queue) in mm_qcamera_queue_release()
63 int mm_qcamera_queue_isempty(mm_camera_queue_t *queue) in mm_qcamera_queue_isempty()
79 int mm_qcamera_queue_enqueue(mm_camera_queue_t *queue, void *data) in mm_qcamera_queue_enqueue()
103 void* mm_qcamera_queue_dequeue(mm_camera_queue_t *queue, int bFromHead) in mm_qcamera_queue_dequeue()
136 void mm_qcamera_queue_flush(mm_camera_queue_t *queue) in mm_qcamera_queue_flush()
|
| /aosp12/hardware/libhardware/modules/sensors/tests/ |
| H A D | SensorEventQueue_test.cpp | 16 bool checkWritableBufferSize(SensorEventQueue* queue, int requested, int expected) { in checkWritableBufferSize()
26 bool checkSize(SensorEventQueue* queue, int expected) { in checkSize()
45 SensorEventQueue* queue = new SensorEventQueue(10); in testSimpleWriteSizeCounts() local
67 SensorEventQueue* queue = new SensorEventQueue(10); in testWrappingWriteSizeCounts() local
95 SensorEventQueue* queue; member
106 SensorEventQueue* queue = ctx->queue; in fullQueueWriterTask() local
145 SensorEventQueue* queue = ctx->queue; in fullQueueReaderTask() local
167 SensorEventQueue* queue = new SensorEventQueue(FULL_QUEUE_CAPACITY); in testFullQueueIo() local
|
| /aosp12/frameworks/native/services/inputflinger/tests/ |
| H A D | BlockingQueue_test.cpp | 33 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
|
| H A D | TestInputListener.cpp | 113 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertCalled() local
133 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in assertNotCalled() local
146 std::vector<NotifyArgsType>& queue = std::get<std::vector<NotifyArgsType>>(mQueues); in notify() local
|
| /aosp12/system/bt/gd/os/linux_generic/ |
| H A D | queue_unittest.cc | 204 Queue<std::string> queue(kQueueSize); in TEST_F() local
228 Queue<std::string> queue(kQueueSize); in TEST_F() local
246 Queue<std::string> queue(kQueueSize); in TEST_F() local
280 Queue<std::string> queue(kQueueSize); in TEST_F() local
313 Queue<std::string> queue(kQueueSize); in TEST_F() local
346 Queue<std::string> queue(kQueueSize); in TEST_F() local
382 Queue<std::string> queue(kQueueSize); in TEST_F() local
411 Queue<std::string> queue(kQueueSize); in TEST_F() local
742 Queue<std::string> queue(10); in TEST_F() local
762 Queue<std::string> queue(10); in TEST_F() local
[all …]
|
| /aosp12/hardware/samsung/nfc/halimpl/osi/ |
| H A D | osi_memory.cc | 134 int OSI_queue_put(tOSI_QUEUE_HANDLER queue, void* p_data) { in OSI_queue_put()
163 void* queue_get(tOSI_QUEUE_HANDLER queue) { in queue_get()
192 void* OSI_queue_get(tOSI_QUEUE_HANDLER queue) { in OSI_queue_get()
202 void* OSI_queue_get_wait(tOSI_QUEUE_HANDLER queue) { in OSI_queue_get_wait()
231 tOSI_QUEUE_HANDLER queue = NULL; in OSI_queue_get_handler() local
|
| /aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/common/ |
| H A D | cam_queue.h | 47 static inline int32_t cam_queue_init(cam_queue_t *queue) in cam_queue_init()
55 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) in cam_queue_enq()
74 static inline void *cam_queue_deq(cam_queue_t *queue) in cam_queue_deq()
99 static inline int32_t cam_queue_flush(cam_queue_t *queue) in cam_queue_flush()
129 static inline int32_t cam_queue_deinit(cam_queue_t *queue) in cam_queue_deinit()
|
| /aosp12/frameworks/base/core/jni/ |
| H A D | android_graphics_BLASTBufferQueue.cpp | 72 sp<BLASTBufferQueue> queue = new BLASTBufferQueue(name.c_str()); in nativeCreate() local
80 sp<BLASTBufferQueue> queue = in nativeCreateAndUpdate() local
88 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeDestroy() local
94 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetSurface() local
100 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeSetNextTransaction() local
107 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeUpdate() local
115 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeMergeWithNextTransaction() local
123 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeSetTransactionCompleteCallback() local
136 sp<BLASTBufferQueue> queue = reinterpret_cast<BLASTBufferQueue*>(ptr); in nativeGetLastAcquiredFrameNum() local
|
| /aosp12/frameworks/base/libs/hwui/tests/unit/ |
| H A 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
|
| /aosp12/system/bt/common/ |
| H A D | leaky_bonded_queue_unittest.cc | 54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
90 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
124 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
164 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
193 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
218 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
227 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(1); in TEST() local
237 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
|
| /aosp12/frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/ |
| H A D | ASensorManager.cpp | 161 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()
|
| H A D | ALooper.cpp | 33 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()
|
| /aosp12/frameworks/base/native/android/ |
| H A D | sensor.cpp | 113 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
124 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue) { in ASensorManager_destroyEventQueue()
209 int ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor, in ASensorEventQueue_registerSensor()
223 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) { in ASensorEventQueue_enableSensor()
231 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) { in ASensorEventQueue_disableSensor()
239 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) { in ASensorEventQueue_setEventRate()
252 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue) { in ASensorEventQueue_hasEvents()
271 ssize_t ASensorEventQueue_getEvents(ASensorEventQueue* queue, ASensorEvent* events, size_t count) { in ASensorEventQueue_getEvents()
287 int ASensorEventQueue_requestAdditionalInfoEvents(ASensorEventQueue* queue, bool enable) { in ASensorEventQueue_requestAdditionalInfoEvents()
|
| /aosp12/art/runtime/base/ |
| H A D | message_queue_test.cc | 52 TestMessageQueue queue; in TEST_F() local
71 TestMessageQueue queue; in TEST_F() local
102 TestMessageQueue queue; in TEST_F() local
159 TestMessageQueue queue; in TEST_F() local
176 TestMessageQueue queue; in TEST_F() local
200 TestMessageQueue queue; in TEST_F() local
216 TestMessageQueue queue; in TEST_F() local
|
| /aosp12/system/bt/gd/l2cap/fuzz/ |
| H A D | channel_fuzz_controller.cc | 27 EnqueueType* queue = reinterpret_cast<EnqueueType*>(chan->GetQueueUpEnd()); in ChannelFuzzController() local
32 EnqueueType* queue = reinterpret_cast<EnqueueType*>(chan->GetQueueUpEnd()); in ChannelFuzzController() local
|
| /aosp12/frameworks/av/media/codec2/components/base/ |
| H A D | SimpleC2Component.cpp | 241 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in queue_nb() local
269 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in flush_sm() local
299 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in drain_nb() local
343 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in stop() local
364 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in reset() local
398 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in finish() local
423 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in cloneAndSend() local
447 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue() local
549 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue() local
|
| /aosp12/system/bt/gd/os/ |
| H A D | queue_benchmark.cc | 59 …explicit TestEnqueueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestEnqueueEnd()
109 …explicit TestDequeueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestDequeueEnd()
143 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
177 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
|
| /aosp12/packages/apps/Car/libs/car-media-common/tests/robotests/src/com/android/car/media/common/playback/ |
| H A D | PlaybackViewModelTest.java | 140 List<MediaSessionCompat.QueueItem> queue = Collections.singletonList(queueItem); in testGetSanitizedQueue() local
173 List<MediaSessionCompat.QueueItem> queue = Collections.emptyList(); in testGetHasQueue_empty() local
188 List<MediaSessionCompat.QueueItem> queue = in testGetHasQueue_true() local
|
| /aosp12/system/bt/test/stub/ |
| H A D | osi.cc | 304 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
316 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
320 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd()
324 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
328 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
332 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
349 void fixed_queue_unregister_dequeue(fixed_queue_t* queue) { in fixed_queue_unregister_dequeue()
352 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
356 void* fixed_queue_try_dequeue(fixed_queue_t* queue) { in fixed_queue_try_dequeue()
360 void* fixed_queue_try_peek_first(fixed_queue_t* queue) { in fixed_queue_try_peek_first()
[all …]
|
| /aosp12/art/test/004-NativeAllocations/src-art/ |
| H A D | Main.java | 43 public static PhantomReference allocPhantom(ReferenceQueue<Object> queue) { in allocPhantom()
54 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in checkRegisterNativeAllocation() local
|
| /aosp12/art/runtime/gc/ |
| H A D | reference_queue_test.cc | 36 ReferenceQueue queue(&lock); in TEST_F() local
70 ReferenceQueue queue(&lock); in TEST_F() local
|