Lines Matching refs:queue
43 static inline int32_t cam_queue_init(cam_queue_t *queue) in cam_queue_init() argument
45 pthread_mutex_init(&queue->lock, NULL); in cam_queue_init()
46 cam_list_init(&queue->head.list); in cam_queue_init()
47 queue->size = 0; in cam_queue_init()
51 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) in cam_queue_enq() argument
62 pthread_mutex_lock(&queue->lock); in cam_queue_enq()
63 cam_list_add_tail_node(&node->list, &queue->head.list); in cam_queue_enq()
64 queue->size++; in cam_queue_enq()
65 pthread_mutex_unlock(&queue->lock); in cam_queue_enq()
70 static inline void *cam_queue_deq(cam_queue_t *queue) in cam_queue_deq() argument
77 pthread_mutex_lock(&queue->lock); in cam_queue_deq()
78 head = &queue->head.list; in cam_queue_deq()
83 queue->size--; in cam_queue_deq()
85 pthread_mutex_unlock(&queue->lock); in cam_queue_deq()
95 static inline int32_t cam_queue_flush(cam_queue_t *queue) in cam_queue_flush() argument
101 pthread_mutex_lock(&queue->lock); in cam_queue_flush()
102 head = &queue->head.list; in cam_queue_flush()
109 queue->size--; in cam_queue_flush()
120 queue->size = 0; in cam_queue_flush()
121 pthread_mutex_unlock(&queue->lock); in cam_queue_flush()
125 static inline int32_t cam_queue_deinit(cam_queue_t *queue) in cam_queue_deinit() argument
127 cam_queue_flush(queue); in cam_queue_deinit()
128 pthread_mutex_destroy(&queue->lock); in cam_queue_deinit()