Lines Matching defs:queue
35 AVThreadMessageQueue *queue;
43 AVThreadMessageQueue *queue;
70 av_log(NULL, AV_LOG_INFO, "sender #%d: flushing the queue\n", wd->id);
71 av_thread_message_flush(wd->queue);
110 /* push the frame in the common queue */
113 ret = av_thread_message_queue_send(wd->queue, &msg, 0);
122 av_thread_message_queue_set_err_recv(wd->queue, ret < 0 ? ret : AVERROR_EOF);
133 av_log(NULL, AV_LOG_INFO, "receiver #%d: flushing the queue, "
135 av_thread_message_queue_nb_elems(rd->queue));
136 av_thread_message_flush(rd->queue);
142 ret = av_thread_message_queue_recv(rd->queue, &msg, 0);
154 av_thread_message_queue_set_err_send(rd->queue, ret < 0 ? ret : AVERROR_EOF);
172 AVThreadMessageQueue *queue = NULL;
208 ret = av_thread_message_queue_alloc(&queue, max_queue_size, sizeof(struct message));
212 av_thread_message_queue_set_free_func(queue, free_frame);
219 td->queue = queue; \
253 av_thread_message_queue_free(&queue);