diff options
author | Jan Alexander Steffens (heftig) <jan.steffens@ltnglobal.com> | 2023-10-25 01:32:41 +0300 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2023-11-10 18:47:41 +0300 |
commit | f565875b6cce646febb25a43c5d900c9e062c244 (patch) | |
tree | c9c057ad2fe811924098507f5b4673a840dab436 | |
parent | 873b91d7d542cb440b5a5b91a6781ae2c13cf2db (diff) |
livesync: Simplify num_duplicate counting
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1387>
-rw-r--r-- | utils/livesync/src/livesync/imp.rs | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/utils/livesync/src/livesync/imp.rs b/utils/livesync/src/livesync/imp.rs index 76924a17..b107fcf3 100644 --- a/utils/livesync/src/livesync/imp.rs +++ b/utils/livesync/src/livesync/imp.rs @@ -987,7 +987,9 @@ impl LiveSync { } fn src_loop(&self) { - let Err(mut err) = self.src_loop_inner() else { + let mut err = if let Err(err) = self.src_loop_inner() { + err + } else { return; }; @@ -1129,7 +1131,6 @@ impl LiveSync { } }; - let duplicate; let mut caps = None; let mut segment = None; @@ -1143,7 +1144,9 @@ impl LiveSync { caps = state.pending_caps.take(); segment = state.pending_segment.take(); - duplicate = lateness != BufferLateness::OnTime; + if lateness != BufferLateness::OnTime { + state.num_duplicate += 1; + } } None => { // Work around borrow checker @@ -1182,7 +1185,7 @@ impl LiveSync { state.out_buffer.as_ref().unwrap(), state.out_segment.as_ref().unwrap(), ); - duplicate = true; + state.num_duplicate += 1; } } @@ -1227,9 +1230,6 @@ impl LiveSync { } state.num_out += 1; - if duplicate { - state.num_duplicate += 1; - } drop(state); |