Searched defs:queue (Results 1 - 25 of 46) sorted by relevance

12

/hardware/intel/common/wrs_omxil_core/utils/inc/
H A Dqueue.h2 * queue.h, queue
28 struct queue { struct
34 void __queue_init(struct queue *queue);
35 struct queue *queue_alloc(void);
37 inline void __queue_free(struct queue *queue);
39 void queue_free_all(struct queue *queue);
[all...]
/hardware/qcom/camera/msm8998/QCamera2/stack/common/
H A Dcam_queue.h47 static inline int32_t cam_queue_init(cam_queue_t *queue) argument
49 pthread_mutex_init(&queue->lock, NULL);
50 cam_list_init(&queue->head.list);
51 queue->size = 0;
55 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) argument
66 pthread_mutex_lock(&queue->lock);
67 cam_list_add_tail_node(&node->list, &queue->head.list);
68 queue->size++;
69 pthread_mutex_unlock(&queue->lock);
74 static inline void *cam_queue_deq(cam_queue_t *queue) argument
99 cam_queue_flush(cam_queue_t *queue) argument
129 cam_queue_deinit(cam_queue_t *queue) argument
[all...]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-test/src/
H A Dmm_qcamera_queue.c34 int mm_camera_queue_init(mm_camera_queue_t *queue, argument
38 if ( NULL == queue ) {
42 pthread_mutex_init(&queue->m_lock, NULL);
43 cam_list_init(&queue->m_head.list);
44 queue->m_size = 0;
45 queue->m_dataFn = data_rel_fn;
46 queue->m_userData = user_data;
51 int mm_qcamera_queue_release(mm_camera_queue_t *queue) argument
53 if ( NULL == queue ) {
57 mm_qcamera_queue_flush(queue);
63 mm_qcamera_queue_isempty(mm_camera_queue_t *queue) argument
79 mm_qcamera_queue_enqueue(mm_camera_queue_t *queue, void *data) argument
103 mm_qcamera_queue_dequeue(mm_camera_queue_t *queue, int bFromHead) argument
136 mm_qcamera_queue_flush(mm_camera_queue_t *queue) argument
[all...]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/
H A Dmm_jpeg_queue.c37 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) argument
39 pthread_mutex_init(&queue->lock, NULL);
40 cam_list_init(&queue->head.list);
41 queue->size = 0;
45 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, mm_jpeg_q_data_t data) argument
57 pthread_mutex_lock(&queue->lock);
58 cam_list_add_tail_node(&node->list, &queue->head.list);
59 queue->size++;
60 pthread_mutex_unlock(&queue->lock);
66 int32_t mm_jpeg_queue_enq_head(mm_jpeg_queue_t* queue, mm_jpeg_q_data_ argument
91 mm_jpeg_queue_deq(mm_jpeg_queue_t* queue) argument
118 mm_jpeg_queue_get_size(mm_jpeg_queue_t* queue) argument
130 mm_jpeg_queue_deinit(mm_jpeg_queue_t* queue) argument
137 mm_jpeg_queue_flush(mm_jpeg_queue_t* queue) argument
165 mm_jpeg_queue_peek(mm_jpeg_queue_t* queue) argument
[all...]
/hardware/intel/common/wrs_omxil_core/utils/src/
H A Dqueue.c2 * queue.c, queue
21 #include <queue.h>
23 inline void __queue_init(struct queue *queue) argument
25 queue->head = NULL;
26 queue->tail = NULL;
27 queue->length = 0;
30 struct queue *queue_alloc(void)
32 struct queue *queu local
41 __queue_free(struct queue *queue) argument
46 queue_free_all(struct queue *queue) argument
54 __queue_push_head(struct queue *queue, struct list *entry) argument
63 queue_push_head(struct queue *queue, void *data) argument
79 __queue_push_tail(struct queue *queue, struct list *entry) argument
93 queue_push_tail(struct queue *queue, void *data) argument
111 __queue_pop_head(struct queue *queue) argument
126 queue_pop_head(struct queue *queue) argument
140 __queue_pop_tail(struct queue *queue) argument
155 queue_pop_tail(struct queue *queue) argument
169 __queue_peek_head(struct queue *queue) argument
174 __queue_peek_tail(struct queue *queue) argument
179 queue_peek_head(struct queue *queue) argument
191 queue_peek_tail(struct queue *queue) argument
203 queue_length(struct queue *queue) argument
[all...]
/hardware/qcom/msm8960/kernel-headers/linux/
H A Dmsm_adsp.h26 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8960/original-kernel-headers/linux/
H A Dmsm_adsp.h26 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8994/kernel-headers/linux/
H A Dmsm_adsp.h26 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8994/original-kernel-headers/linux/
H A Dmsm_adsp.h25 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8996/kernel-headers/linux/
H A Dmsm_adsp.h26 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8996/original-kernel-headers/linux/
H A Dmsm_adsp.h25 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8998/kernel-headers/linux/
H A Dmsm_adsp.h26 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8998/original-kernel-headers/linux/
H A Dmsm_adsp.h25 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8x84/kernel-headers/linux/
H A Dmsm_adsp.h26 uint16_t queue; member in struct:adsp_command_t
/hardware/qcom/msm8x84/original-kernel-headers/linux/
H A Dmsm_adsp.h25 uint16_t queue; member in struct:adsp_command_t
/hardware/google/av/codec2/vndk/bufferpool/
H A DBufferStatus.cpp48 std::unique_ptr<BufferStatusQueue> queue = local
50 if (!queue || queue->isValid() == false) {
54 *fmqDescPtr = queue->getDesc();
57 std::make_pair(id, std::move(queue)));
94 std::unique_ptr<BufferStatusQueue> queue = local
96 if (!queue || queue->isValid() == false) {
101 mBufferStatusQueue = std::move(queue);
/hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/
H A DConcurrentQueue.h20 #include <queue>
63 /* Deactivates the queue, thus no one can push items to it, also
84 std::queue<T> mQueue;
105 void run(ConcurrentQueue<T>* queue, argument
108 mQueue = queue;
/hardware/libhardware/modules/sensors/tests/
H A DSensorEventQueue_test.cpp16 bool checkWritableBufferSize(SensorEventQueue* queue, int requested, int expected) { argument
18 int actual = queue->getWritableRegion(requested, &buffer);
26 bool checkSize(SensorEventQueue* queue, int expected) { argument
27 int actual = queue->getSize();
29 printf("Expected queue size was %d; actual was %d\n", expected, actual);
45 SensorEventQueue* queue = new SensorEventQueue(10); local
46 if (!checkSize(queue, 0)) return false;
47 if (!checkWritableBufferSize(queue, 11, 10)) return false;
48 if (!checkWritableBufferSize(queue, 10, 10)) return false;
49 if (!checkWritableBufferSize(queue,
67 SensorEventQueue* queue = new SensorEventQueue(10); local
95 SensorEventQueue* queue; member in struct:TaskContext
106 SensorEventQueue* queue = ctx->queue; local
145 SensorEventQueue* queue = ctx->queue; local
167 SensorEventQueue* queue = new SensorEventQueue(FULL_QUEUE_CAPACITY); local
[all...]
/hardware/google/av/codec2/hidl/1.0/utils/
H A DComponent.cpp200 Return<Status> Component::queue(const WorkBundle& workBundle) { function in class:hardware::google::media::c2::V1_0::utils::Component
201 ALOGV("queue -- converting input");
206 ALOGV("queue -- corrupted");
209 ALOGV("queue -- calling");
/hardware/libhardware/tests/hwc/
H A Dcnativewindow.c87 static CNativeBuffer *get_front(struct CNativeBuffer *queue) { argument
88 CNativeBuffer *buf = queue->next;
89 if (buf == queue)
91 buf->next->prev = queue;
92 queue->next = buf->next;
97 static void put_front(struct CNativeBuffer *queue, aBuffer *_buf) { argument
99 buf->prev = queue;
100 buf->next = queue->next;
101 queue->next->prev = buf;
102 queue
105 put_back(struct CNativeBuffer *queue, aBuffer *_buf) argument
[all...]
/hardware/google/av/codec2/hidl/client/
H A Dclient.cpp368 // release input buffers potentially held by the component from queue
839 c2_status_t Codec2Client::Component::queue( function in class:android::Codec2Client::Component
852 ALOGI("duplicate input index %llu in queue", (long long)inputIndex);
864 ALOGE("queue -- bad input.");
867 Return<Status> transStatus = base()->queue(workBundle);
869 ALOGE("queue -- transaction failed.");
875 ALOGE("queue -- call failed. "
/hardware/libhardware/modules/sensors/
H A Dmultihal.cpp134 SensorEventQueue* queue; member in struct:TaskContext
141 SensorEventQueue* queue = ctx->queue; local
146 if (queue->waitForSpace(&queue_mutex)) {
149 int bufferSize = queue->getWritableRegion(SENSOR_EVENT_QUEUE_CAPACITY, &buffer);
164 queue->markAsWritten(eventsPolled);
225 SensorEventQueue *queue = new SensorEventQueue(SENSOR_EVENT_QUEUE_CAPACITY); local
226 this->queues.push_back(queue);
230 taskContext->queue = queue;
371 SensorEventQueue* queue = this->queues.at(this->nextReadIndex); local
[all...]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-interface/src/
H A Dmm_camera_channel.c89 mm_channel_queue_t * queue, cam_stream_type_t cam_type);
124 /* channel super queue functions */
125 int32_t mm_channel_superbuf_queue_init(mm_channel_queue_t * queue);
126 int32_t mm_channel_superbuf_queue_deinit(mm_channel_queue_t * queue);
128 mm_channel_queue_t * queue,
131 mm_channel_queue_t * queue, mm_channel_t *ch_obj);
133 mm_channel_queue_t *queue);
135 mm_channel_queue_t *queue);
140 mm_channel_queue_t * queue);
156 mm_channel_queue_t * queue, uint32_
1482 mm_frame_sync_queue_t *queue = NULL; local
2694 mm_channel_superbuf_queue_init(mm_channel_queue_t * queue) argument
2711 mm_channel_superbuf_queue_deinit(mm_channel_queue_t * queue) argument
2760 mm_channel_validate_super_buf(mm_channel_t* ch_obj, mm_channel_queue_t *queue, mm_camera_buf_info_t *buf_info) argument
2809 mm_channel_handle_metadata( mm_channel_t* ch_obj, mm_channel_queue_t * queue, mm_camera_buf_info_t *buf_info) argument
3069 mm_channel_superbuf_comp_and_enqueue( mm_channel_t* ch_obj, mm_channel_queue_t *queue, mm_camera_buf_info_t *buf_info) argument
3371 mm_channel_superbuf_dequeue_internal( mm_channel_queue_t * queue, uint8_t matched_only, mm_channel_t *ch_obj) argument
3425 mm_channel_superbuf_dequeue_frame_internal( mm_channel_queue_t *queue, uint32_t frame_idx) argument
3475 mm_channel_superbuf_dequeue( mm_channel_queue_t * queue, mm_channel_t *ch_obj) argument
3501 mm_channel_superbuf_bufdone_overflow(mm_channel_t* my_obj, mm_channel_queue_t * queue) argument
3547 mm_channel_superbuf_skip(mm_channel_t* my_obj, mm_channel_queue_t * queue) argument
3630 mm_channel_superbuf_flush(mm_channel_t* my_obj, mm_channel_queue_t * queue, cam_stream_type_t cam_type) argument
3714 mm_channel_superbuf_flush_matched(mm_channel_t* my_obj, mm_channel_queue_t * queue) argument
[all...]
H A Dmm_camera_muxer.c1322 * frames from superbuf queue
1354 * frames from superbuf queue
1397 * DESCRIPTION: flush out all frames in the superbuf queue
1848 * DESCRIPTION: dequeue object from frame sync queue
1851 * @queue: ptr to queue to dequeue object
1853 * RETURN : ptr to a node from superbuf queue
1856 mm_frame_sync_queue_t *queue, uint8_t matched_only)
1863 pthread_mutex_lock(&queue->que.lock);
1864 head = &queue
1855 mm_camera_muxer_frame_sync_dequeue( mm_frame_sync_queue_t *queue, uint8_t matched_only) argument
1903 mm_camera_muxer_do_frame_sync( mm_frame_sync_queue_t *queue, mm_camera_super_buf_t *buffer, mm_frame_sync_queue_node_t *dispatch_buf) argument
2159 mm_muxer_frame_sync_queue_init(mm_frame_sync_queue_t *queue) argument
2182 mm_muxer_frame_sync_queue_deinit(mm_frame_sync_queue_t *queue) argument
2201 mm_camera_muxer_frame_sync_flush(mm_frame_sync_queue_t *queue) argument
[all...]
H A Dmm_camera_stream.c1151 mm_frame_sync_queue_t *queue = NULL; local
1155 queue = &frame_sync->superbuf_queue;
1156 queue->num_objs = 0;
1157 memset(&queue->bundled_objs, 0, sizeof(queue->bundled_objs));
1158 queue->bundled_objs[queue->num_objs] = my_obj->my_hdl;
1159 queue->num_objs++;
1160 queue->bundled_objs[queue
[all...]

Completed in 612 milliseconds

12