From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from ffbox0-bg.mplayerhq.hu (ffbox0-bg.ffmpeg.org [79.124.17.100]) by master.gitmailbox.com (Postfix) with ESMTP id BABE34821A for ; Wed, 13 Dec 2023 19:31:10 +0000 (UTC) Received: from [127.0.1.1] (localhost [127.0.0.1]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTP id F34B668D109; Wed, 13 Dec 2023 21:30:33 +0200 (EET) Received: from mail1.khirnov.net (quelana.khirnov.net [94.230.150.81]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTPS id 910B468D07D for ; Wed, 13 Dec 2023 21:30:28 +0200 (EET) Received: from localhost (mail1.khirnov.net [IPv6:::1]) by mail1.khirnov.net (Postfix) with ESMTP id 068071BA4 for ; Wed, 13 Dec 2023 20:30:24 +0100 (CET) Received: from mail1.khirnov.net ([IPv6:::1]) by localhost (mail1.khirnov.net [IPv6:::1]) (amavis, port 10024) with ESMTP id X6otFlTXAtu8 for ; Wed, 13 Dec 2023 20:30:23 +0100 (CET) Received: from libav.khirnov.net (libav.khirnov.net [IPv6:2a00:c500:561:201::7]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature RSA-PSS (2048 bits) server-digest SHA256 client-signature RSA-PSS (2048 bits) client-digest SHA256) (Client CN "libav.khirnov.net", Issuer "smtp.khirnov.net SMTP CA" (verified OK)) by mail1.khirnov.net (Postfix) with ESMTPS id 71B8E1CAE for ; Wed, 13 Dec 2023 20:30:21 +0100 (CET) Received: from libav.khirnov.net (libav.khirnov.net [IPv6:::1]) by libav.khirnov.net (Postfix) with ESMTP id 864053A07CC for ; Wed, 13 Dec 2023 20:30:14 +0100 (CET) From: Anton Khirnov To: ffmpeg-devel@ffmpeg.org Date: Wed, 13 Dec 2023 20:30:06 +0100 Message-ID: <20231213193007.17471-11-anton@khirnov.net> X-Mailer: git-send-email 2.42.0 In-Reply-To: <20231213193007.17471-1-anton@khirnov.net> References: <20231213193007.17471-1-anton@khirnov.net> MIME-Version: 1.0 Subject: [FFmpeg-devel] [PATCH 11/12] fftools/ffmpeg: update the reported timestamp at the end X-BeenThere: ffmpeg-devel@ffmpeg.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: FFmpeg development discussions and patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Reply-To: FFmpeg development discussions and patches Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit Errors-To: ffmpeg-devel-bounces@ffmpeg.org Sender: "ffmpeg-devel" Archived-At: List-Archive: List-Post: Reported-by: microchip --- fftools/ffmpeg.c | 2 +- fftools/ffmpeg_sched.c | 13 ++++++++----- fftools/ffmpeg_sched.h | 2 +- 3 files changed, 10 insertions(+), 7 deletions(-) diff --git a/fftools/ffmpeg.c b/fftools/ffmpeg.c index 8077248254..4c706eb46a 100644 --- a/fftools/ffmpeg.c +++ b/fftools/ffmpeg.c @@ -926,7 +926,7 @@ static int transcode(Scheduler *sch) print_report(0, timer_start, cur_time, transcode_ts); } - ret = sch_stop(sch); + ret = sch_stop(sch, &transcode_ts); /* write the trailer if needed */ for (i = 0; i < nb_output_files; i++) { diff --git a/fftools/ffmpeg_sched.c b/fftools/ffmpeg_sched.c index ab14d6233e..b1c7db776e 100644 --- a/fftools/ffmpeg_sched.c +++ b/fftools/ffmpeg_sched.c @@ -423,7 +423,7 @@ static void task_init(Scheduler *sch, SchTask *task, enum SchedulerNodeType type task->func_arg = func_arg; } -static int64_t trailing_dts(const Scheduler *sch) +static int64_t trailing_dts(const Scheduler *sch, int count_finished) { int64_t min_dts = INT64_MAX; @@ -433,7 +433,7 @@ static int64_t trailing_dts(const Scheduler *sch) for (unsigned j = 0; j < mux->nb_streams; j++) { const SchMuxStream *ms = &mux->streams[j]; - if (ms->source_finished) + if (ms->source_finished && !count_finished) continue; if (ms->last_dts == AV_NOPTS_VALUE) return AV_NOPTS_VALUE; @@ -445,7 +445,7 @@ static int64_t trailing_dts(const Scheduler *sch) return min_dts == INT64_MAX ? AV_NOPTS_VALUE : min_dts; } -int sch_stop(Scheduler *sch) +int sch_stop(Scheduler *sch, int64_t *finish_ts) { int ret = 0, err; @@ -492,6 +492,9 @@ int sch_stop(Scheduler *sch) ret = err_merge(ret, err); } + if (finish_ts) + *finish_ts = trailing_dts(sch, 1); + return ret; } @@ -502,7 +505,7 @@ void sch_free(Scheduler **psch) if (!sch) return; - sch_stop(sch); + sch_stop(sch, NULL); for (unsigned i = 0; i < sch->nb_demux; i++) { SchDemux *d = &sch->demux[i]; @@ -1194,7 +1197,7 @@ static void schedule_update_locked(Scheduler *sch) if (atomic_load(&sch->terminate)) return; - dts = trailing_dts(sch); + dts = trailing_dts(sch, 0); atomic_store(&sch->last_dts, dts); diff --git a/fftools/ffmpeg_sched.h b/fftools/ffmpeg_sched.h index 94bbd30e98..b167d8d158 100644 --- a/fftools/ffmpeg_sched.h +++ b/fftools/ffmpeg_sched.h @@ -127,7 +127,7 @@ Scheduler *sch_alloc(void); void sch_free(Scheduler **sch); int sch_start(Scheduler *sch); -int sch_stop(Scheduler *sch); +int sch_stop(Scheduler *sch, int64_t *finish_ts); /** * Wait until transcoding terminates or the specified timeout elapses. -- 2.42.0 _______________________________________________ ffmpeg-devel mailing list ffmpeg-devel@ffmpeg.org https://ffmpeg.org/mailman/listinfo/ffmpeg-devel To unsubscribe, visit link above, or email ffmpeg-devel-request@ffmpeg.org with subject "unsubscribe".