Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 605) sorted by relevance

12345678910>>...25

/aosp12/system/bt/osi/test/
H A Dfixed_queue_test.cc55 fixed_queue_t* queue; in TEST_F() local
58 queue = fixed_queue_new(0); in TEST_F()
59 EXPECT_TRUE(queue != NULL); in TEST_F()
63 queue = fixed_queue_new(1); in TEST_F()
64 EXPECT_TRUE(queue != NULL); in TEST_F()
69 EXPECT_TRUE(queue != NULL); in TEST_F()
74 EXPECT_TRUE(queue != NULL); in TEST_F()
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
[all …]
/aosp12/system/bt/osi/src/
H A Dfixed_queue.cc69 if (!queue) return; in fixed_queue_free()
81 delete queue->mutex; in fixed_queue_free()
82 osi_free(queue); in fixed_queue_free()
86 if (!queue) return; in fixed_queue_flush()
111 CHECK(queue != NULL); in fixed_queue_capacity()
117 CHECK(queue != NULL); in fixed_queue_enqueue()
183 return list_is_empty(queue->list) ? NULL : list_front(queue->list); in fixed_queue_try_peek_first()
190 return list_is_empty(queue->list) ? NULL : list_back(queue->list); in fixed_queue_try_peek_last()
219 return queue->list; in fixed_queue_get_list()
244 reactor_register(reactor, fixed_queue_get_dequeue_fd(queue), queue, in fixed_queue_register_dequeue()
[all …]
/aosp12/system/bt/common/
H A Dleaky_bonded_queue_unittest.cc57 queue->Enqueue(item1); in TEST()
59 queue->Enqueue(item2); in TEST()
61 queue->Enqueue(item3); in TEST()
64 queue->Enqueue(item4); in TEST()
82 delete queue; in TEST()
116 delete queue; in TEST()
156 delete queue; in TEST()
184 queue->Clear(); in TEST()
185 delete queue; in TEST()
213 delete queue; in TEST()
[all …]
/aosp12/hardware/libhardware/modules/sensors/tests/
H A DSensorEventQueue_test.cpp51 queue->markAsWritten(7); in testSimpleWriteSizeCounts()
57 queue->markAsWritten(3); in testSimpleWriteSizeCounts()
68 queue->markAsWritten(9); in testWrappingWriteSizeCounts()
72 queue->dequeue(); in testWrappingWriteSizeCounts()
73 queue->dequeue(); in testWrappingWriteSizeCounts()
95 SensorEventQueue* queue; member
106 SensorEventQueue* queue = ctx->queue; in fullQueueWriterTask() local
145 SensorEventQueue* queue = ctx->queue; in fullQueueReaderTask() local
154 queue->dequeue(); in fullQueueReaderTask()
171 readerCtx.queue = queue; in testFullQueueIo()
[all …]
/aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-test/src/
H A Dmm_qcamera_queue.c38 if ( NULL == queue ) { in mm_camera_queue_init()
44 queue->m_size = 0; in mm_camera_queue_init()
53 if ( NULL == queue ) { in mm_qcamera_queue_release()
65 if ( NULL == queue ) { in mm_qcamera_queue_isempty()
81 if ( NULL == queue ) { in mm_qcamera_queue_enqueue()
97 queue->m_size++; in mm_qcamera_queue_enqueue()
105 if ( NULL == queue ) { in mm_qcamera_queue_dequeue()
124 queue->m_size--; in mm_qcamera_queue_dequeue()
154 queue->m_size--; in mm_qcamera_queue_flush()
158 queue->m_dataFn(node->data, queue->m_userData); in mm_qcamera_queue_flush()
[all …]
/aosp12/art/runtime/base/
H A Dmessage_queue_test.cc52 TestMessageQueue queue; in TEST_F() local
71 TestMessageQueue queue; in TEST_F() local
102 TestMessageQueue queue; in TEST_F() local
109 queue.SetTimeout(500); in TEST_F()
120 queue.SwitchReceive( in TEST_F()
159 TestMessageQueue queue; in TEST_F() local
166 queue.SetTimeout(500); in TEST_F()
176 TestMessageQueue queue; in TEST_F() local
183 queue.SetTimeout(500); in TEST_F()
187 queue.SwitchReceive( in TEST_F()
[all …]
/aosp12/hardware/samsung/nfc/halimpl/osi/
H A Dosi_memory.cc139 if (!queue || queue->state != OSI_ALLOCATED) { in OSI_queue_put()
144 if (queue->head == queue->tail) { in OSI_queue_put()
147 queue->queue[queue->head++] = p_data; in OSI_queue_put()
148 if (queue->head >= OSI_QUEUE_SIZE) queue->head = 0; in OSI_queue_put()
154 ret = (queue->head) - (queue->tail); in OSI_queue_put()
166 if (!queue || queue->state != OSI_ALLOCATED) { in queue_get()
178 if (queue->tail + 1 == queue->head) { in queue_get()
186 if (queue->tail >= OSI_QUEUE_SIZE) queue->tail = 0; in queue_get()
187 data = queue->queue[queue->tail]; in queue_get()
207 if (!queue || queue->state != OSI_ALLOCATED) { in OSI_queue_get_wait()
[all …]
/aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/textclassifier/
H A DFixedSizeQueueTest.java33 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 …]
/aosp12/frameworks/native/services/inputflinger/tests/
H A DBlockingQueue_test.cpp35 ASSERT_TRUE(queue.push(1)); in TEST()
36 ASSERT_EQ(queue.pop(), 1); in TEST()
73 queue.push(1); in TEST()
74 queue.push(2); in TEST()
75 queue.clear(); in TEST()
76 queue.push(3); in TEST()
85 queue.push(1); in TEST()
86 queue.push(2); in TEST()
87 queue.push(3); in TEST()
88 queue.push(4); in TEST()
[all …]
/aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/
H A Dmm_jpeg_queue.c41 queue->size = 0; in mm_jpeg_queue_init()
59 queue->size++; in mm_jpeg_queue_enq()
80 head = &queue->head.list; in mm_jpeg_queue_enq_head()
85 queue->size++; in mm_jpeg_queue_enq_head()
101 head = &queue->head.list; in mm_jpeg_queue_deq()
106 queue->size--; in mm_jpeg_queue_deq()
123 size = queue->size; in mm_jpeg_queue_get_size()
144 head = &queue->head.list; in mm_jpeg_queue_flush()
150 queue->size--; in mm_jpeg_queue_flush()
160 queue->size = 0; in mm_jpeg_queue_flush()
[all …]
/aosp12/frameworks/base/libs/hwui/tests/unit/
H A DLayerUpdateQueueTests.cpp28 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 …]
/aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/common/
H A Dcam_queue.h50 cam_list_init(&queue->head.list); in cam_queue_init()
51 queue->size = 0; in cam_queue_init()
66 pthread_mutex_lock(&queue->lock); in cam_queue_enq()
68 queue->size++; in cam_queue_enq()
81 pthread_mutex_lock(&queue->lock); in cam_queue_deq()
82 head = &queue->head.list; in cam_queue_deq()
87 queue->size--; in cam_queue_deq()
106 head = &queue->head.list; in cam_queue_flush()
113 queue->size--; in cam_queue_flush()
124 queue->size = 0; in cam_queue_flush()
[all …]
/aosp12/system/bt/osi/include/
H A Dfixed_queue.h53 bool fixed_queue_is_empty(fixed_queue_t* queue);
57 size_t fixed_queue_length(fixed_queue_t* queue);
61 size_t fixed_queue_capacity(fixed_queue_t* queue);
66 void fixed_queue_enqueue(fixed_queue_t* queue, void* data);
71 void* fixed_queue_dequeue(fixed_queue_t* queue);
82 void* fixed_queue_try_dequeue(fixed_queue_t* queue);
87 void* fixed_queue_try_peek_first(fixed_queue_t* queue);
92 void* fixed_queue_try_peek_last(fixed_queue_t* queue);
108 list_t* fixed_queue_get_list(fixed_queue_t* queue);
115 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue);
[all …]
/aosp12/frameworks/base/libs/hwui/renderthread/
H A DRenderProxy.cpp116 mRenderThread.queue().post( in setLightAlpha()
198 thread.queue().post([&thread]() { in purgeCaches()
213 mRenderThread.queue().runSync([]() {}); in fence()
231 mRenderThread.queue().runSync([&]() { in dumpProfileInfo()
247 mRenderThread.queue().runSync([=]() { in resetProfileInfo()
309 mRenderThread.queue().post( in setPictureCapturedCallback()
315 mRenderThread.queue().post( in setASurfaceTransactionCallback()
321 mRenderThread.queue().post( in setPrepareSurfaceControlForWebviewCallback()
384 renderThread->queue().post(task); in prepareToDraw()
395 return thread.queue().runSync( in copyHWBitmapInto()
[all …]
/aosp12/art/runtime/gc/
H A Dreference_queue_test.cc36 ReferenceQueue queue(&lock); in TEST_F() local
37 ASSERT_TRUE(queue.IsEmpty()); in TEST_F()
38 ASSERT_EQ(queue.GetLength(), 0U); in TEST_F()
48 ASSERT_TRUE(!queue.IsEmpty()); in TEST_F()
51 ASSERT_TRUE(!queue.IsEmpty()); in TEST_F()
57 ASSERT_TRUE(!queue.IsEmpty()); in TEST_F()
61 ASSERT_TRUE(queue.IsEmpty()); in TEST_F()
70 ReferenceQueue queue(&lock); in TEST_F() local
72 queue.Dump(oss); in TEST_F()
89 queue.Dump(oss); in TEST_F()
[all …]
/aosp12/frameworks/av/media/libstagefright/rtsp/
H A DAAVCAssembler.cpp59 List<sp<ABuffer>> *queue = source->queue(); in addNack() local
118 List<sp<ABuffer> > *queue = source->queue(); in addNALUnit() local
121 if (queue->empty()) { in addNALUnit()
258 queue->erase(queue->begin()); in addNALUnit()
267 queue->erase(queue->begin()); in addNALUnit()
276 queue->erase(queue->begin()); in addNALUnit()
283 queue->erase(queue->begin()); in addNALUnit()
290 queue->erase(queue->begin()); in addNALUnit()
428 queue->erase(queue->begin()); in addFragmentedNALUnit()
438 queue->erase(queue->begin()); in addFragmentedNALUnit()
[all …]
H A DAHEVCAssembler.cpp68 List<sp<ABuffer>> *queue = source->queue(); in addNack() local
128 List<sp<ABuffer> > *queue = source->queue(); in addNALUnit() local
131 if (queue->empty()) { in addNALUnit()
268 queue->erase(queue->begin()); in addNALUnit()
277 queue->erase(queue->begin()); in addNALUnit()
286 queue->erase(queue->begin()); in addNALUnit()
293 queue->erase(queue->begin()); in addNALUnit()
300 queue->erase(queue->begin()); in addNALUnit()
442 queue->erase(queue->begin()); in addFragmentedNALUnit()
452 queue->erase(queue->begin()); in addFragmentedNALUnit()
[all …]
H A DAH263Assembler.cpp54 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
56 if (queue->empty()) { in addPacket()
62 while (it != queue->end()) { in addPacket()
67 it = queue->erase(it); in addPacket()
70 if (queue->empty()) { in addPacket()
75 sp<ABuffer> buffer = *queue->begin(); in addPacket()
99 queue->erase(queue->begin()); in addPacket()
113 queue->erase(queue->begin()); in addPacket()
121 queue->erase(queue->begin()); in addPacket()
129 queue->erase(queue->begin()); in addPacket()
[all …]
H A DAMPEG2TSAssembler.cpp55 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
57 if (queue->empty()) { in addPacket()
62 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
63 while (it != queue->end()) { in addPacket()
68 it = queue->erase(it); in addPacket()
71 if (queue->empty()) { in addPacket()
76 sp<ABuffer> buffer = *queue->begin(); in addPacket()
90 queue->erase(queue->begin()); in addPacket()
102 queue->erase(queue->begin()); in addPacket()
H A DAAMRAssembler.cpp103 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
105 if (queue->empty()) { in addPacket()
111 while (it != queue->end()) { in addPacket()
116 it = queue->erase(it); in addPacket()
119 if (queue->empty()) { in addPacket()
124 sp<ABuffer> buffer = *queue->begin(); in addPacket()
138 queue->erase(queue->begin()); in addPacket()
155 queue->erase(queue->begin()); in addPacket()
169 queue->erase(queue->begin()); in addPacket()
196 queue->erase(queue->begin()); in addPacket()
[all …]
/aosp12/system/bt/gd/os/linux_generic/
H A Dqueue_unittest.cc693 queue->RegisterEnqueue( in TEST_F()
704 queue->RegisterDequeue( in TEST_F()
723 delete queue; in TEST_F()
765 queue.RegisterEnqueue( in TEST_F()
788 queue.RegisterEnqueue( in TEST_F()
810 queue->RegisterEnqueue( in RegisterEnqueueAndDelete()
812 delete queue; in RegisterEnqueueAndDelete()
821 … common::Bind([](Queue<std::string>* queue) { queue->TryDequeue(); }, common::Unretained(queue))); in RegisterDequeueAndDelete() argument
822 delete queue; in RegisterDequeueAndDelete()
859 std::queue<int> queue_;
[all …]
/aosp12/frameworks/base/core/jni/
H A Dandroid_graphics_BLASTBufferQueue.cpp72 sp<BLASTBufferQueue> queue = new BLASTBufferQueue(name.c_str()); in nativeCreate() local
73 queue->incStrong((void*)nativeCreate); in nativeCreate()
74 return reinterpret_cast<jlong>(queue.get()); in nativeCreate()
80 sp<BLASTBufferQueue> queue = in nativeCreateAndUpdate() local
83 queue->incStrong((void*)nativeCreate); in nativeCreateAndUpdate()
84 return reinterpret_cast<jlong>(queue.get()); in nativeCreateAndUpdate()
89 queue->decStrong((void*)nativeCreate); in nativeDestroy()
102 queue->setNextTransaction(transaction); in nativeSetNextTransaction()
117 queue->mergeWithNextTransaction(transaction, framenumber); in nativeMergeWithNextTransaction()
125 queue->setTransactionCompleteCallback(frameNumber, nullptr); in nativeSetTransactionCompleteCallback()
[all …]
/aosp12/frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/
H A DASensorManager.cpp161 sp<ASensorEventQueue> queue = in createEventQueue() local
182 queue->incStrong(NULL /* id */); in createEventQueue()
185 return queue.get(); in createEventQueue()
191 queue->invalidate(); in destroyEventQueue()
193 queue->decStrong(NULL /* id */); in destroyEventQueue()
194 queue = NULL; in destroyEventQueue()
271 queue = NULL; in ASensorManager_destroyEventQueue()
305 ASensorEventQueue* queue, in ASensorEventQueue_registerSensor() argument
311 return queue->registerSensor( in ASensorEventQueue_registerSensor()
330 ASensorEventQueue* queue, in ASensorEventQueue_setEventRate() argument
[all …]
/aosp12/frameworks/av/media/codec2/components/base/
H A DSimpleC2Component.cpp270 queue->incGeneration(); in flush_sm()
272 while (!queue->empty()) { in flush_sm()
280 queue->pending().erase(queue->pending().begin()); in flush_sm()
344 queue->clear(); in stop()
345 queue->pending().clear(); in stop()
365 queue->clear(); in reset()
366 queue->pending().clear(); in reset()
448 if (queue->empty()) { in processQueue()
554 queue.unlock(); in processQueue()
563 queue.unlock(); in processQueue()
[all …]
/aosp12/frameworks/base/native/android/
H A Dsensor.cpp58 if (queue == nullptr) { \
113 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
115 if (queue != 0) { in ASensorManager_createEventQueue()
117 queue->looper = looper; in ASensorManager_createEventQueue()
118 queue->requestAdditionalInfo = false; in ASensorManager_createEventQueue()
119 queue->incStrong(manager); in ASensorManager_createEventQueue()
121 return static_cast<ASensorEventQueue*>(queue.get()); in ASensorManager_createEventQueue()
218 return static_cast<SensorEventQueue*>(queue)->enableSensor( in ASensorEventQueue_registerSensor()
252 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue) { in ASensorEventQueue_hasEvents() argument
256 pfd.fd = static_cast<SensorEventQueue*>(queue)->getFd(); in ASensorEventQueue_hasEvents()
[all …]

12345678910>>...25