From 8417efc63039b8f8387157d54522d79e26f47c85 Mon Sep 17 00:00:00 2001 From: Vivia Nikolaidou Date: Thu, 29 Jun 2023 17:20:27 +0300 Subject: [PATCH] togglerecord: Error out if main stream buffer has no valid running time We cannot continue with this buffer, because we cannot calculate the time when the recording stopped or started. We also cannot safely drop it, because that might break the stream, especially if it's encoded. Therefore, we return an element error. Part-of: --- utils/togglerecord/src/togglerecord/imp.rs | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/utils/togglerecord/src/togglerecord/imp.rs b/utils/togglerecord/src/togglerecord/imp.rs index 74fdaba0..ee6fea71 100644 --- a/utils/togglerecord/src/togglerecord/imp.rs +++ b/utils/togglerecord/src/togglerecord/imp.rs @@ -444,6 +444,17 @@ impl ToggleRecord { let current_running_time = state.in_segment.to_running_time(dts_or_pts); let current_running_time_end = state.in_segment.to_running_time(dts_or_pts_end); + let (current_running_time, current_running_time_end) = state + .in_segment + .clip(current_running_time, current_running_time_end) + .ok_or_else(|| { + gst::element_imp_error!( + self, + gst::StreamError::Format, + ["Received a buffer in the main stream without a valid running time"] + ); + gst::FlowError::Error + })?; state.current_running_time = current_running_time .opt_max(state.current_running_time) @@ -452,9 +463,6 @@ impl ToggleRecord { .opt_max(state.current_running_time_end) .or(current_running_time_end); - // FIXME we should probably return if either current_running_time or current_running_time_end - // are None at this point - // Wake up everybody, we advanced a bit // Important: They will only be able to advance once we're done with this // function or waiting for them to catch up below, otherwise they might