Lines Matching defs:queue
34 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue)
36 pthread_mutex_init(&queue->lock, NULL);
37 cam_list_init(&queue->head.list);
38 queue->size = 0;
42 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, void* data)
54 pthread_mutex_lock(&queue->lock);
55 cam_list_add_tail_node(&node->list, &queue->head.list);
56 queue->size++;
57 pthread_mutex_unlock(&queue->lock);
63 void* mm_jpeg_queue_deq(mm_jpeg_queue_t* queue)
70 pthread_mutex_lock(&queue->lock);
71 head = &queue->head.list;
76 queue->size--;
78 pthread_mutex_unlock(&queue->lock);
88 uint32_t mm_jpeg_queue_get_size(mm_jpeg_queue_t* queue)
92 pthread_mutex_lock(&queue->lock);
93 size = queue->size;
94 pthread_mutex_unlock(&queue->lock);
100 int32_t mm_jpeg_queue_deinit(mm_jpeg_queue_t* queue)
102 mm_jpeg_queue_flush(queue);
103 pthread_mutex_destroy(&queue->lock);
107 int32_t mm_jpeg_queue_flush(mm_jpeg_queue_t* queue)
114 pthread_mutex_lock(&queue->lock);
115 head = &queue->head.list;
121 queue->size--;
131 queue->size = 0;
132 pthread_mutex_unlock(&queue->lock);
136 void* mm_jpeg_queue_peek(mm_jpeg_queue_t* queue)
143 pthread_mutex_lock(&queue->lock);
144 head = &queue->head.list;
149 pthread_mutex_unlock(&queue->lock);