static int init_input_threads(void)

{

    int i, ret;



    if (nb_input_files == 1)

        return 0;



    for (i = 0; i < nb_input_files; i++) {

        InputFile *f = input_files[i];



        if (f->ctx->pb ? !f->ctx->pb->seekable :

            strcmp(f->ctx->iformat->name, "lavfi"))

            f->non_blocking = 1;

        ret = av_thread_message_queue_alloc(&f->in_thread_queue,

                                            8, sizeof(AVPacket));

        if (ret < 0)

            return ret;



        if ((ret = pthread_create(&f->thread, NULL, input_thread, f)))

            return AVERROR(ret);

    }

    return 0;

}

static int init_input_threads(void)

{

    int i, ret;



    if (nb_input_files == 1)

        return 0;



    for (i = 0; i < nb_input_files; i++) {

        InputFile *f = input_files[i];



        if (f->ctx->pb ? !f->ctx->pb->seekable :

            strcmp(f->ctx->iformat->name, "lavfi"))

            f->non_blocking = 1;

        ret = av_thread_message_queue_alloc(&f->in_thread_queue,

                                            8, sizeof(AVPacket));

        if (ret < 0)

            return ret;



        if ((ret = pthread_create(&f->thread, NULL, input_thread, f)))

            return AVERROR(ret);

    }

    return 0;

}

        if ((ret = pthread_create(&f->thread, NULL, input_thread, f)))
static int FUNC_0(void)

{

    int VAR_0, VAR_1;



    if (nb_input_files == 1)

        return 0;



    for (VAR_0 = 0; VAR_0 < nb_input_files; VAR_0++) {

        InputFile *f = input_files[VAR_0];



        if (f->ctx->pb ? !f->ctx->pb->seekable :

            strcmp(f->ctx->iformat->name, "lavfi"))

            f->non_blocking = 1;

        VAR_1 = av_thread_message_queue_alloc(&f->in_thread_queue,

                                            8, sizeof(AVPacket));

        if (VAR_1 < 0)

            return VAR_1;



        if ((VAR_1 = pthread_create(&f->thread, NULL, input_thread, f)))

            return AVERROR(VAR_1);

    }

    return 0;

}

static int FUNC_0(void)
{ int VAR_0, VAR_1; if (nb_input_files == 1)
return 0; for (VAR_0 = 0; VAR_0 < nb_input_files; VAR_0++) { InputFile *f = input_files[VAR_0]; if (f->ctx->pb ? !f->ctx->pb->seekable :
strcmp(f->ctx->iformat->name, "lavfi"))
f->non_blocking = 1; VAR_1 = av_thread_message_queue_alloc(&f->in_thread_queue,
8, sizeof(AVPacket)); if (VAR_1 < 0)
return VAR_1; if ((VAR_1 = pthread_create(&f->thread, NULL, input_thread, f)))
return AVERROR(VAR_1); } return 0; }