Lines Matching refs:fifo
27 AVFifoBuffer *fifo; member
67 if (!(rmq->fifo = av_fifo_alloc(elsize * nelem))) { in av_thread_message_queue_alloc()
96 av_fifo_freep(&(*mq)->fifo); in av_thread_message_queue_free()
110 ret = av_fifo_size(mq->fifo); in av_thread_message_queue_nb_elems()
124 while (!mq->err_send && av_fifo_space(mq->fifo) < mq->elsize) { in av_thread_message_queue_send_locked()
131 av_fifo_generic_write(mq->fifo, msg, mq->elsize, NULL); in av_thread_message_queue_send_locked()
141 while (!mq->err_recv && av_fifo_size(mq->fifo) < mq->elsize) { in av_thread_message_queue_recv_locked()
146 if (av_fifo_size(mq->fifo) < mq->elsize) in av_thread_message_queue_recv_locked()
148 av_fifo_generic_read(mq->fifo, msg, mq->elsize, NULL); in av_thread_message_queue_recv_locked()
225 used = av_fifo_size(mq->fifo); in av_thread_message_flush()
228 av_fifo_generic_peek_at(mq->fifo, mq, off, mq->elsize, free_func_wrap); in av_thread_message_flush()
229 av_fifo_drain(mq->fifo, used); in av_thread_message_flush()