Home
last modified time | relevance | path

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

123456

/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-test/src/
Dmm_qcamera_queue.c34 int mm_camera_queue_init(mm_camera_queue_t *queue, in mm_camera_queue_init() argument
38 if ( NULL == queue ) { in mm_camera_queue_init()
42 pthread_mutex_init(&queue->m_lock, NULL); in mm_camera_queue_init()
43 cam_list_init(&queue->m_head.list); in mm_camera_queue_init()
44 queue->m_size = 0; in mm_camera_queue_init()
45 queue->m_dataFn = data_rel_fn; in mm_camera_queue_init()
46 queue->m_userData = user_data; in mm_camera_queue_init()
51 int mm_qcamera_queue_release(mm_camera_queue_t *queue) in mm_qcamera_queue_release() argument
53 if ( NULL == queue ) { in mm_qcamera_queue_release()
57 mm_qcamera_queue_flush(queue); in mm_qcamera_queue_release()
[all …]
/hardware/libhardware/modules/sensors/tests/
DSensorEventQueue_test.cpp16 bool checkWritableBufferSize(SensorEventQueue* queue, int requested, int expected) { in checkWritableBufferSize() argument
18 int actual = queue->getWritableRegion(requested, &buffer); in checkWritableBufferSize()
26 bool checkSize(SensorEventQueue* queue, int expected) { in checkSize() argument
27 int actual = queue->getSize(); in checkSize()
45 SensorEventQueue* queue = new SensorEventQueue(10); in testSimpleWriteSizeCounts() local
46 if (!checkSize(queue, 0)) return false; in testSimpleWriteSizeCounts()
47 if (!checkWritableBufferSize(queue, 11, 10)) return false; in testSimpleWriteSizeCounts()
48 if (!checkWritableBufferSize(queue, 10, 10)) return false; in testSimpleWriteSizeCounts()
49 if (!checkWritableBufferSize(queue, 9, 9)) return false; in testSimpleWriteSizeCounts()
51 queue->markAsWritten(7); in testSimpleWriteSizeCounts()
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/
Dmm_jpeg_queue.c37 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) in mm_jpeg_queue_init() argument
39 pthread_mutex_init(&queue->lock, NULL); in mm_jpeg_queue_init()
40 cam_list_init(&queue->head.list); in mm_jpeg_queue_init()
41 queue->size = 0; 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() argument
57 pthread_mutex_lock(&queue->lock); in mm_jpeg_queue_enq()
58 cam_list_add_tail_node(&node->list, &queue->head.list); in mm_jpeg_queue_enq()
59 queue->size++; in mm_jpeg_queue_enq()
60 pthread_mutex_unlock(&queue->lock); 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() argument
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/common/
Dcam_queue.h47 static inline int32_t cam_queue_init(cam_queue_t *queue) in cam_queue_init() argument
49 pthread_mutex_init(&queue->lock, NULL); in cam_queue_init()
50 cam_list_init(&queue->head.list); in cam_queue_init()
51 queue->size = 0; in cam_queue_init()
55 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) in cam_queue_enq() argument
66 pthread_mutex_lock(&queue->lock); in cam_queue_enq()
67 cam_list_add_tail_node(&node->list, &queue->head.list); in cam_queue_enq()
68 queue->size++; in cam_queue_enq()
69 pthread_mutex_unlock(&queue->lock); in cam_queue_enq()
74 static inline void *cam_queue_deq(cam_queue_t *queue) in cam_queue_deq() argument
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-interface/src/
Dmm_camera_channel.c89 mm_channel_queue_t * queue, cam_stream_type_t cam_type);
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_t frame_idx);
1482 mm_frame_sync_queue_t *queue = NULL; in mm_channel_reg_frame_sync() local
[all …]
Dmm_camera_muxer.c1856 mm_frame_sync_queue_t *queue, uint8_t matched_only) in mm_camera_muxer_frame_sync_dequeue() argument
1863 pthread_mutex_lock(&queue->que.lock); in mm_camera_muxer_frame_sync_dequeue()
1864 head = &queue->que.head.list; in mm_camera_muxer_frame_sync_dequeue()
1877 queue->que.size--; in mm_camera_muxer_frame_sync_dequeue()
1881 queue->match_cnt--; in mm_camera_muxer_frame_sync_dequeue()
1885 pthread_mutex_unlock(&queue->que.lock); in mm_camera_muxer_frame_sync_dequeue()
1904 mm_frame_sync_queue_t *queue, mm_camera_super_buf_t *buffer, in mm_camera_muxer_do_frame_sync() argument
1919 for (buf_s_idx = 0; buf_s_idx < queue->num_objs; buf_s_idx++) { in mm_camera_muxer_do_frame_sync()
1920 if ((buffer->ch_id == queue->bundled_objs[buf_s_idx]) || in mm_camera_muxer_do_frame_sync()
1921 (buffer->bufs[0]->stream_id == queue->bundled_objs[buf_s_idx])) { in mm_camera_muxer_do_frame_sync()
[all …]
/hardware/google/av/media/codecs/base/
DSimpleC2Component.cpp188 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in queue_nb() local
189 queueWasEmpty = queue->empty(); in queue_nb()
191 queue->push_back(std::move(items->front())); in queue_nb()
216 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in flush_sm() local
217 queue->incGeneration(); in flush_sm()
219 while (!queue->empty()) { in flush_sm()
220 std::unique_ptr<C2Work> work = queue->pop_front(); in flush_sm()
249 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in drain_nb() local
250 queueWasEmpty = queue->empty(); in drain_nb()
251 queue->markDrain(drainMode); in drain_nb()
[all …]
/hardware/qcom/msm8996/kernel-headers/sound/
Dasequencer.h181 unsigned char queue; member
206 unsigned char queue; member
219 struct snd_seq_ev_queue_control queue; member
309 unsigned char queue; member
374 int queue; member
384 int queue; member
395 int queue; member
409 int queue; member
422 int queue; member
439 unsigned char queue; member
[all …]
/hardware/qcom/msm8996/original-kernel-headers/sound/
Dasequencer.h250 unsigned char queue; /* affected queue */ member
276 unsigned char queue; /* schedule queue */ member
289 struct snd_seq_ev_queue_control queue; member
393 unsigned char queue; /* Queue for REMOVE_DEST */ member
472 int queue; /* queue id */ member
488 int queue; /* queue id */ member
500 int queue; /* sequencer queue */ member
516 int queue; /* sequencer queue */ member
529 int queue; /* sequencer queue */ member
547 unsigned char queue; /* input time-stamp queue (optional) */ member
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/inc/
Dmm_jpeg.h482 extern int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue);
483 extern int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue,
485 extern int32_t mm_jpeg_queue_enq_head(mm_jpeg_queue_t* queue,
487 extern mm_jpeg_q_data_t mm_jpeg_queue_deq(mm_jpeg_queue_t* queue);
488 extern int32_t mm_jpeg_queue_deinit(mm_jpeg_queue_t* queue);
489 extern int32_t mm_jpeg_queue_flush(mm_jpeg_queue_t* queue);
490 extern uint32_t mm_jpeg_queue_get_size(mm_jpeg_queue_t* queue);
491 extern mm_jpeg_q_data_t mm_jpeg_queue_peek(mm_jpeg_queue_t* queue);
511 mm_jpeg_queue_t* queue, uint32_t client_hdl);
513 mm_jpeg_queue_t* queue, uint32_t job_id);
[all …]
/hardware/qcom/camera/msm8998/QCamera2/HAL3/
DQCamera3HdrPlusListenerThread.h108 std::queue<uint32_t> mNextCaptureReadyIds;
109 std::queue<PendingResult> mResults;
112 std::queue<std::pair<uint32_t, int64_t>> mShutters;
113 std::queue<PendingPostview> mPostviews;
117 std::queue<CallbackType> mPendingCallbacks;
/hardware/libhardware/tests/hwc/
Dcnativewindow.c87 static CNativeBuffer *get_front(struct CNativeBuffer *queue) { in get_front() argument
88 CNativeBuffer *buf = queue->next; in get_front()
89 if (buf == queue) in get_front()
91 buf->next->prev = queue; in get_front()
92 queue->next = buf->next; in get_front()
97 static void put_front(struct CNativeBuffer *queue, aBuffer *_buf) { in put_front() argument
99 buf->prev = queue; in put_front()
100 buf->next = queue->next; in put_front()
101 queue->next->prev = buf; in put_front()
102 queue->next = buf; in put_front()
[all …]
/hardware/google/pixel/perfstatsd/include/
Dstatstype.h30 void dump(std::priority_queue<StatsData, std::vector<StatsData>, StatsdataCompare> *queue) { in dump() argument
32 std::queue<StatsData> buffer = mBuffer.dump(); in dump()
34 queue->push(buffer.front()); in dump()
Dperfstats_buffer.h70 const std::queue<StatsData> &dump(void);
74 std::queue<StatsData> mStorage;
/hardware/interfaces/graphics/bufferqueue/2.0/
DIGraphicBufferProducer.hal34 * owned by the buffer queue, i.e., they are not owned by the producer or
81 * match the current generation number of the buffer queue previously
83 * match the current generation number of the buffer queue.
94 * Sets the async flag: whether the producer intends to asynchronously queue
99 * for the asynchronous behavior. If it is not enabled, queue/dequeue calls
238 * buffer queue.
258 * detaches it from the buffer queue. This is equivalent to calling
271 * @return buffer Buffer just released from the buffer queue.
284 * Attempts to transfer ownership of a buffer to the buffer queue.
295 * @param buffer Buffer to attach to the buffer queue.
[all …]
/hardware/libhardware/modules/sensors/
Dmultihal.cpp134 SensorEventQueue* queue; member
141 SensorEventQueue* queue = ctx->queue; in writerTask() local
146 if (queue->waitForSpace(&queue_mutex)) { in writerTask()
149 int bufferSize = queue->getWritableRegion(SENSOR_EVENT_QUEUE_CAPACITY, &buffer); in writerTask()
164 queue->markAsWritten(eventsPolled); in writerTask()
225 SensorEventQueue *queue = new SensorEventQueue(SENSOR_EVENT_QUEUE_CAPACITY); in addSubHwDevice() local
226 this->queues.push_back(queue); in addSubHwDevice()
230 taskContext->queue = queue; in addSubHwDevice()
371 SensorEventQueue* queue = this->queues.at(this->nextReadIndex); in poll() local
372 sensors_event_t* event = queue->peek(); in poll()
[all …]
/hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/
DConcurrentQueue.h84 std::queue<T> mQueue;
105 void run(ConcurrentQueue<T>* queue, in run() argument
108 mQueue = queue; in run()
/hardware/interfaces/audio/2.0/
DIStreamIn.hal64 * Data structure passed back to the client via status message queue
88 * -- command queue is used to instruct the reader thread what operation
90 * -- data queue is used for passing audio data from the driver
92 * -- status queue is used for reporting operation status
107 * @return commandMQ a message queue used for passing commands.
108 * @return dataMQ a message queue used for passing audio data in the format
110 * @return statusMQ a message queue used for passing status from the driver
/hardware/interfaces/media/c2/1.0/
DIInputSink.hal34 * to queue to the component.
40 * - `NO_MEMORY` - Not enough memory to queue @p workBundle.
44 queue(WorkBundle workBundle) generates (Status status);
/hardware/interfaces/audio/4.0/
DIStreamIn.hal64 * Data structure passed back to the client via status message queue
94 * -- command queue is used to instruct the reader thread what operation
96 * -- data queue is used for passing audio data from the driver
98 * -- status queue is used for reporting operation status
113 * @return commandMQ a message queue used for passing commands.
114 * @return dataMQ a message queue used for passing audio data in the format
116 * @return statusMQ a message queue used for passing status from the driver
/hardware/interfaces/audio/6.0/
DIStreamIn.hal64 * Data structure passed back to the client via status message queue
94 * -- command queue is used to instruct the reader thread what operation
96 * -- data queue is used for passing audio data from the driver
98 * -- status queue is used for reporting operation status
113 * @return commandMQ a message queue used for passing commands.
114 * @return dataMQ a message queue used for passing audio data in the format
116 * @return statusMQ a message queue used for passing status from the driver
/hardware/interfaces/audio/5.0/
DIStreamIn.hal64 * Data structure passed back to the client via status message queue
94 * -- command queue is used to instruct the reader thread what operation
96 * -- data queue is used for passing audio data from the driver
98 * -- status queue is used for reporting operation status
113 * @return commandMQ a message queue used for passing commands.
114 * @return dataMQ a message queue used for passing audio data in the format
116 * @return statusMQ a message queue used for passing status from the driver
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-test/inc/
Dmm_qcamera_app.h530 extern int mm_camera_queue_init(mm_camera_queue_t *queue,
533 extern int mm_qcamera_queue_release(mm_camera_queue_t *queue);
534 extern int mm_qcamera_queue_isempty(mm_camera_queue_t *queue);
535 extern int mm_qcamera_queue_enqueue(mm_camera_queue_t *queue, void *data);
536 extern void* mm_qcamera_queue_dequeue(mm_camera_queue_t *queue,
538 extern void mm_qcamera_queue_flush(mm_camera_queue_t *queue);
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-interface/inc/
Dmm_camera_muxer.h167 mm_frame_sync_queue_t *queue, mm_camera_super_buf_t *buffer,
170 int32_t mm_muxer_frame_sync_queue_init(mm_frame_sync_queue_t *queue);
171 int32_t mm_muxer_frame_sync_queue_deinit(mm_frame_sync_queue_t *queue);
177 mm_frame_sync_queue_t *queue, uint8_t matched_only);
/hardware/google/pixel/perfstatsd/
Dperfstats_buffer.cpp33 const std::queue<StatsData> &PerfstatsBuffer::dump(void) { in dump()

123456