Lines Matching refs:in_thread_queue
3658 av_thread_message_queue_set_err_recv(f->in_thread_queue, ret);
3664 av_thread_message_queue_set_err_recv(f->in_thread_queue, AVERROR(ENOMEM));
3668 ret = av_thread_message_queue_send(f->in_thread_queue, &queue_pkt, flags);
3671 ret = av_thread_message_queue_send(f->in_thread_queue, &queue_pkt, flags);
3683 av_thread_message_queue_set_err_recv(f->in_thread_queue, ret);
3696 if (!f || !f->in_thread_queue)
3698 av_thread_message_queue_set_err_send(f->in_thread_queue, AVERROR_EOF);
3699 while (av_thread_message_queue_recv(f->in_thread_queue, &pkt, 0) >= 0)
3704 av_thread_message_queue_free(&f->in_thread_queue);
3728 ret = av_thread_message_queue_alloc(&f->in_thread_queue,
3735 av_thread_message_queue_free(&f->in_thread_queue);
3756 return av_thread_message_queue_recv(f->in_thread_queue, pkt,