Unified · Split
| @@ -368,8 +368,9 @@ static int thread_start(Demuxer *d) · 367 unmodified lines | |||
| 368 | if (d->thread_queue_size <= 0) | 368 | if (d->thread_queue_size <= 0) |
| 369 | d->thread_queue_size = (nb_input_files > 1 ? 8 : 1); | 369 | d->thread_queue_size = (nb_input_files > 1 ? 8 : 1); |
| 370 | 370 | ||
| 371 | if (f->ctx->pb ? !f->ctx->pb->seekable : | 371 | if (nb_input_files > 1 && |
| 372 | strcmp(f->ctx->iformat->name, "lavfi")) | 372 | (f->ctx->pb ? !f->ctx->pb->seekable : |
| 373 | strcmp(f->ctx->iformat->name, "lavfi"))) | ||
| 373 | d->non_blocking = 1; | 374 | d->non_blocking = 1; |
| 374 | ret = av_thread_message_queue_alloc(&d->in_thread_queue, | 375 | ret = av_thread_message_queue_alloc(&d->in_thread_queue, |
| 375 | d->thread_queue_size, sizeof(DemuxMsg)); | 376 | d->thread_queue_size, sizeof(DemuxMsg)); |