From 83c326437ed83c4373f1bbc1d5224ffa13fb70d6 Mon Sep 17 00:00:00 2001 From: Julian Rother Date: Wed, 18 Jul 2018 01:50:18 +0200 Subject: [PATCH] Fixes for live_forward --- live_forward.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/live_forward.c b/live_forward.c index f3fe35a..a017e83 100644 --- a/live_forward.c +++ b/live_forward.c @@ -52,6 +52,7 @@ int main(int argc, char *argv[]) mux->streams[i]->codecpar->codec_tag = 0; mux->streams[i]->time_base = demux->streams[i]->time_base; } + avio_open(&mux->pb, dest, AVIO_FLAG_WRITE); muxopts = 0; parse_dict(&muxopts, jlookup(argv[4], "options")); if ((err = avformat_write_header(mux, &muxopts)) < 0) @@ -60,7 +61,7 @@ int main(int argc, char *argv[]) while (!canceled && !av_read_frame(demux, &pkt)) { if (!checktime(30)) - canceled = ping_job(jobid, "running", 0); + canceled = ping_job(jobid, "running", "{\"log\": \"%s\"}", jescape(get_avlogbuf())); if (pkt.stream_index >= demux->nb_streams || idxmap[pkt.stream_index] == -1) continue; @@ -79,6 +80,7 @@ int main(int argc, char *argv[]) av_interleaved_write_frame(mux, 0); if (err = av_write_trailer(mux)) job_failed("Error writing trailer", av_err2str(err)); + avio_closep(&mux->pb); ping_job(jobid, "finished", "{%s, \"log\": \"%s\"}", jescape(get_avlogbuf())); return 0; } -- 2.24.1