[FFmpeg-devel] [PATCH 10/12] fftools/ffmpeg_sched: move trailing_dts() higher up
Anton Khirnov
anton at khirnov.net
Wed Dec 13 21:30:05 EET 2023
Will be useful in following commit.
---
fftools/ffmpeg_sched.c | 44 +++++++++++++++++++++---------------------
1 file changed, 22 insertions(+), 22 deletions(-)
diff --git a/fftools/ffmpeg_sched.c b/fftools/ffmpeg_sched.c
index 69f8c0c3c0..ab14d6233e 100644
--- a/fftools/ffmpeg_sched.c
+++ b/fftools/ffmpeg_sched.c
@@ -423,6 +423,28 @@ static void task_init(Scheduler *sch, SchTask *task, enum SchedulerNodeType type
task->func_arg = func_arg;
}
+static int64_t trailing_dts(const Scheduler *sch)
+{
+ int64_t min_dts = INT64_MAX;
+
+ for (unsigned i = 0; i < sch->nb_mux; i++) {
+ const SchMux *mux = &sch->mux[i];
+
+ for (unsigned j = 0; j < mux->nb_streams; j++) {
+ const SchMuxStream *ms = &mux->streams[j];
+
+ if (ms->source_finished)
+ continue;
+ if (ms->last_dts == AV_NOPTS_VALUE)
+ return AV_NOPTS_VALUE;
+
+ min_dts = FFMIN(min_dts, ms->last_dts);
+ }
+ }
+
+ return min_dts == INT64_MAX ? AV_NOPTS_VALUE : min_dts;
+}
+
int sch_stop(Scheduler *sch)
{
int ret = 0, err;
@@ -1162,28 +1184,6 @@ int sch_mux_sub_heartbeat_add(Scheduler *sch, unsigned mux_idx, unsigned stream_
return 0;
}
-static int64_t trailing_dts(const Scheduler *sch)
-{
- int64_t min_dts = INT64_MAX;
-
- for (unsigned i = 0; i < sch->nb_mux; i++) {
- const SchMux *mux = &sch->mux[i];
-
- for (unsigned j = 0; j < mux->nb_streams; j++) {
- const SchMuxStream *ms = &mux->streams[j];
-
- if (ms->source_finished)
- continue;
- if (ms->last_dts == AV_NOPTS_VALUE)
- return AV_NOPTS_VALUE;
-
- min_dts = FFMIN(min_dts, ms->last_dts);
- }
- }
-
- return min_dts == INT64_MAX ? AV_NOPTS_VALUE : min_dts;
-}
-
static void schedule_update_locked(Scheduler *sch)
{
int64_t dts;
--
2.42.0
More information about the ffmpeg-devel
mailing list