Lines Matching defs:queue
49 int32_t mm_camera_queue_init(mm_camera_queue_t* queue)
51 pthread_mutex_init(&queue->lock, NULL);
52 cam_list_init(&queue->head.list);
53 queue->size = 0;
57 int32_t mm_camera_queue_enq(mm_camera_queue_t* queue, void* data)
69 pthread_mutex_lock(&queue->lock);
70 cam_list_add_tail_node(&node->list, &queue->head.list);
71 queue->size++;
72 pthread_mutex_unlock(&queue->lock);
78 void* mm_camera_queue_deq(mm_camera_queue_t* queue)
85 pthread_mutex_lock(&queue->lock);
86 head = &queue->head.list;
91 queue->size--;
93 pthread_mutex_unlock(&queue->lock);
103 int32_t mm_camera_queue_deinit(mm_camera_queue_t* queue)
105 mm_camera_queue_flush(queue);
106 pthread_mutex_destroy(&queue->lock);
110 int32_t mm_camera_queue_flush(mm_camera_queue_t* queue)
117 pthread_mutex_lock(&queue->lock);
118 head = &queue->head.list;
124 queue->size--;
135 queue->size = 0;
136 pthread_mutex_unlock(&queue->lock);
159 /* we got notified about new cmd avail in cmd queue */