static int av_thread_message_queue_recv_locked(AVThreadMessageQueue *mq,

                                               void *msg,

                                               unsigned flags)

{

    while (!mq->err_recv && av_fifo_size(mq->fifo) < mq->elsize) {

        if ((flags & AV_THREAD_MESSAGE_NONBLOCK))

            return AVERROR(EAGAIN);

        pthread_cond_wait(&mq->cond, &mq->lock);

    }

    if (av_fifo_size(mq->fifo) < mq->elsize)

        return mq->err_recv;

    av_fifo_generic_read(mq->fifo, msg, mq->elsize, NULL);

    pthread_cond_signal(&mq->cond);

    return 0;

}

static int av_thread_message_queue_recv_locked(AVThreadMessageQueue *mq,

                                               void *msg,

                                               unsigned flags)

{

    while (!mq->err_recv && av_fifo_size(mq->fifo) < mq->elsize) {

        if ((flags & AV_THREAD_MESSAGE_NONBLOCK))

            return AVERROR(EAGAIN);

        pthread_cond_wait(&mq->cond, &mq->lock);

    }

    if (av_fifo_size(mq->fifo) < mq->elsize)

        return mq->err_recv;

    av_fifo_generic_read(mq->fifo, msg, mq->elsize, NULL);

    pthread_cond_signal(&mq->cond);

    return 0;

}

        pthread_cond_wait(&mq->cond, &mq->lock);     pthread_cond_signal(&mq->cond);         pthread_cond_wait(&mq->cond, &mq->lock);     pthread_cond_signal(&mq->cond);
static int FUNC_0(AVThreadMessageQueue *VAR_0,

                                               void *VAR_1,

                                               unsigned VAR_2)

{

    while (!VAR_0->err_recv && av_fifo_size(VAR_0->fifo) < VAR_0->elsize) {

        if ((VAR_2 & AV_THREAD_MESSAGE_NONBLOCK))

            return AVERROR(EAGAIN);

        pthread_cond_wait(&VAR_0->cond, &VAR_0->lock);

    }

    if (av_fifo_size(VAR_0->fifo) < VAR_0->elsize)

        return VAR_0->err_recv;

    av_fifo_generic_read(VAR_0->fifo, VAR_1, VAR_0->elsize, NULL);

    pthread_cond_signal(&VAR_0->cond);

    return 0;

}

static int FUNC_0(AVThreadMessageQueue *VAR_0,
void *VAR_1,
unsigned VAR_2)
{ while (!VAR_0->err_recv && av_fifo_size(VAR_0->fifo) < VAR_0->elsize) { if ((VAR_2 & AV_THREAD_MESSAGE_NONBLOCK))
return AVERROR(EAGAIN); pthread_cond_wait(&VAR_0->cond, &VAR_0->lock); } if (av_fifo_size(VAR_0->fifo) < VAR_0->elsize)
return VAR_0->err_recv; av_fifo_generic_read(VAR_0->fifo, VAR_1, VAR_0->elsize, NULL); pthread_cond_signal(&VAR_0->cond); return 0; }