From 0ca0d485a0560c712611023e2efc7c55c11d7727 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sebastian=20Dr=C3=B6ge?= Date: Wed, 13 Apr 2022 14:06:49 +0300 Subject: [PATCH] fallbackswitch: Log affected pad when scheduling buffer waiting for it --- utils/fallbackswitch/src/fallbackswitch/imp.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/utils/fallbackswitch/src/fallbackswitch/imp.rs b/utils/fallbackswitch/src/fallbackswitch/imp.rs index 6ba81f01..4253b5c4 100644 --- a/utils/fallbackswitch/src/fallbackswitch/imp.rs +++ b/utils/fallbackswitch/src/fallbackswitch/imp.rs @@ -334,6 +334,7 @@ impl SinkState { fn schedule_clock( &mut self, element: &super::FallbackSwitch, + pad: &super::FallbackSwitchSinkPad, running_time: Option, extra_time: gst::ClockTime, ) -> Option { @@ -350,7 +351,7 @@ impl SinkState { if wait_until < now { debug!( CAT, - obj: element, + obj: pad, "Skipping buffer wait until {} - clock already {}", wait_until, now @@ -360,7 +361,7 @@ impl SinkState { debug!( CAT, - obj: element, + obj: pad, "Scheduling buffer wait until {} = {} + extra {} + base time {}", wait_until, running_time, @@ -637,6 +638,7 @@ impl FallbackSwitch { let output_clockid = if is_active { pad_state.schedule_clock( element, + pad, start_running_time, state.upstream_latency + settings.latency, ) @@ -666,6 +668,7 @@ impl FallbackSwitch { } else { pad_state.schedule_clock( element, + pad, end_running_time, state.upstream_latency + settings.timeout + settings.latency, )