fallbackswitch: Log affected pad when scheduling buffer waiting for it

This commit is contained in:
Sebastian Dröge 2022-04-13 14:06:49 +03:00 committed by Sebastian Dröge
parent d73bce2985
commit 0ca0d485a0

View file

@ -334,6 +334,7 @@ impl SinkState {
fn schedule_clock( fn schedule_clock(
&mut self, &mut self,
element: &super::FallbackSwitch, element: &super::FallbackSwitch,
pad: &super::FallbackSwitchSinkPad,
running_time: Option<gst::ClockTime>, running_time: Option<gst::ClockTime>,
extra_time: gst::ClockTime, extra_time: gst::ClockTime,
) -> Option<gst::SingleShotClockId> { ) -> Option<gst::SingleShotClockId> {
@ -350,7 +351,7 @@ impl SinkState {
if wait_until < now { if wait_until < now {
debug!( debug!(
CAT, CAT,
obj: element, obj: pad,
"Skipping buffer wait until {} - clock already {}", "Skipping buffer wait until {} - clock already {}",
wait_until, wait_until,
now now
@ -360,7 +361,7 @@ impl SinkState {
debug!( debug!(
CAT, CAT,
obj: element, obj: pad,
"Scheduling buffer wait until {} = {} + extra {} + base time {}", "Scheduling buffer wait until {} = {} + extra {} + base time {}",
wait_until, wait_until,
running_time, running_time,
@ -637,6 +638,7 @@ impl FallbackSwitch {
let output_clockid = if is_active { let output_clockid = if is_active {
pad_state.schedule_clock( pad_state.schedule_clock(
element, element,
pad,
start_running_time, start_running_time,
state.upstream_latency + settings.latency, state.upstream_latency + settings.latency,
) )
@ -666,6 +668,7 @@ impl FallbackSwitch {
} else { } else {
pad_state.schedule_clock( pad_state.schedule_clock(
element, element,
pad,
end_running_time, end_running_time,
state.upstream_latency + settings.timeout + settings.latency, state.upstream_latency + settings.timeout + settings.latency,
) )