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

livesync: Improve formatting

Browse source 
Move some code around to make it a bit more readable. No change in
behavior.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1086>
This commit is contained in:
Jan Alexander Steffens (heftig) 2023-02-09 10:03:46 +01:00 committed by Sebastian Dröge
parent 9d67753fd6
commit fbf50b395d
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -51,15 +51,15 @@ enum Item {
Query(std::ptr::NonNull<gst::QueryRef>, mpsc::SyncSender<bool>), Query(std::ptr::NonNull<gst::QueryRef>, mpsc::SyncSender<bool>),
} }
// SAFETY: Need to be able to pass *mut gst::QueryRef
unsafe impl Send for Item {}
#[derive(Debug, Clone, Copy, PartialEq, Eq)] #[derive(Debug, Clone, Copy, PartialEq, Eq)]
struct Timestamps { struct Timestamps {
start: gst::ClockTime, start: gst::ClockTime,
end: gst::ClockTime, end: gst::ClockTime,
} }
// SAFETY: Need to be able to pass *mut gst::QueryRef
unsafe impl Send for Item {}
#[derive(Debug)] #[derive(Debug)]
pub struct LiveSync { pub struct LiveSync {
state: Mutex<State>, state: Mutex<State>,
@ -614,11 +614,6 @@ impl LiveSync {
state.in_segment = Some(segment.clone()); state.in_segment = Some(segment.clone());
} }
gst::EventView::Gap(_) => {
gst::debug!(CAT, imp: self, "Got gap event");
return true;
}
gst::EventView::Eos(_) => { gst::EventView::Eos(_) => {
let mut state = self.state.lock(); let mut state = self.state.lock();
@ -648,6 +643,11 @@ impl LiveSync {
state.update_fallback_duration(); state.update_fallback_duration();
} }
gst::EventView::Gap(_) => {
gst::debug!(CAT, imp: self, "Got gap event");
return true;
}
_ => {} _ => {}
} }