mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-09-27 14:30:27 +00:00
Code Issues Projects Releases Wiki Activity

livesync: Simplify num_duplicate counting

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1387>
This commit is contained in:
Jan Alexander Steffens (heftig) 2023-10-25 00:32:41 +02:00 committed by Sebastian Dröge
parent 873b91d7d5
commit f565875b6c
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
utils/livesync/src/livesync/imp.rs
View file

@ -987,7 +987,9 @@ impl LiveSync {
} }
fn src_loop(&self) { 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; return;
}; };
@ -1129,7 +1131,6 @@ impl LiveSync {
} }
}; };
let duplicate;
let mut caps = None; let mut caps = None;
let mut segment = None; let mut segment = None;
@ -1143,7 +1144,9 @@ impl LiveSync {
caps = state.pending_caps.take(); caps = state.pending_caps.take();
segment = state.pending_segment.take(); segment = state.pending_segment.take();
duplicate = lateness != BufferLateness::OnTime; if lateness != BufferLateness::OnTime {
state.num_duplicate += 1;
}
} }
None => { None => {
// Work around borrow checker // Work around borrow checker
@ -1182,7 +1185,7 @@ impl LiveSync {
state.out_buffer.as_ref().unwrap(), state.out_buffer.as_ref().unwrap(),
state.out_segment.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; state.num_out += 1;
if duplicate {
state.num_duplicate += 1;
}
drop(state); drop(state);