diff options
author | Anton Khirnov <anton@khirnov.net> | 2022-03-22 17:56:30 +0100 |
---|---|---|
committer | Anton Khirnov <anton@khirnov.net> | 2022-08-08 16:20:58 +0200 |
commit | de9fb9fba7f6a7002ade2fe8c306a85fbf83e97d (patch) | |
tree | cf7475abb80aa4fcc628fff362aaab62d20d1df2 | |
parent | aae9de0cb2887e6e0bbfda6ffdf85ab77d3390f0 (diff) |
fftools/ffmpeg_demux: factorize signalling end of demuxing
-rw-r--r-- | fftools/ffmpeg_demux.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/fftools/ffmpeg_demux.c b/fftools/ffmpeg_demux.c index d03210d9e6..d7dde1028f 100644 --- a/fftools/ffmpeg_demux.c +++ b/fftools/ffmpeg_demux.c @@ -18,6 +18,7 @@ #include "ffmpeg.h" +#include "libavutil/avassert.h" #include "libavutil/error.h" #include "libavutil/time.h" #include "libavutil/timestamp.h" @@ -142,7 +143,6 @@ static void *input_thread(void *arg) /* fallthrough to the error path */ } - av_thread_message_queue_set_err_recv(f->in_thread_queue, ret); break; } @@ -162,7 +162,7 @@ static void *input_thread(void *arg) msg.pkt = av_packet_alloc(); if (!msg.pkt) { av_packet_unref(pkt); - av_thread_message_queue_set_err_recv(f->in_thread_queue, AVERROR(ENOMEM)); + ret = AVERROR(ENOMEM); break; } av_packet_move_ref(msg.pkt, pkt); @@ -181,11 +181,13 @@ static void *input_thread(void *arg) "Unable to send packet to main thread: %s\n", av_err2str(ret)); av_packet_free(&msg.pkt); - av_thread_message_queue_set_err_recv(f->in_thread_queue, ret); break; } } + av_assert0(ret < 0); + av_thread_message_queue_set_err_recv(f->in_thread_queue, ret); + return NULL; } |