Lines Matching refs:queue
37 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue)
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)
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_t data)
80 head = &queue->head.list;
83 pthread_mutex_lock(&queue->lock);
85 queue->size++;
86 pthread_mutex_unlock(&queue->lock);
91 mm_jpeg_q_data_t mm_jpeg_queue_deq(mm_jpeg_queue_t* queue)
100 pthread_mutex_lock(&queue->lock);
101 head = &queue->head.list;
106 queue->size--;
108 pthread_mutex_unlock(&queue->lock);
118 uint32_t mm_jpeg_queue_get_size(mm_jpeg_queue_t* queue)
122 pthread_mutex_lock(&queue->lock);
123 size = queue->size;
124 pthread_mutex_unlock(&queue->lock);
130 int32_t mm_jpeg_queue_deinit(mm_jpeg_queue_t* queue)
132 mm_jpeg_queue_flush(queue);
133 pthread_mutex_destroy(&queue->lock);
137 int32_t mm_jpeg_queue_flush(mm_jpeg_queue_t* queue)
143 pthread_mutex_lock(&queue->lock);
144 head = &queue->head.list;
150 queue->size--;
160 queue->size = 0;
161 pthread_mutex_unlock(&queue->lock);
165 mm_jpeg_q_data_t mm_jpeg_queue_peek(mm_jpeg_queue_t* queue)
174 pthread_mutex_lock(&queue->lock);
175 head = &queue->head.list;
180 pthread_mutex_unlock(&queue->lock);
