Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/sdroege/gst-plugin-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJan Alexander Steffens (heftig) <jan.steffens@ltnglobal.com>2023-10-25 01:32:41 +0300
committerSebastian Dröge <sebastian@centricular.com>2023-11-10 18:47:41 +0300
commitf565875b6cce646febb25a43c5d900c9e062c244 (patch)
treec9c057ad2fe811924098507f5b4673a840dab436
parent873b91d7d542cb440b5a5b91a6781ae2c13cf2db (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.rs14
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);