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-12-29 13:30:34 +00:00
Code Issues Projects Releases Wiki Activity

fallbackswitch: Use DTS if existing or otherwise PTS for timestamp tracking

Browse source
This commit is contained in:
Sebastian Dröge 2019-09-18 14:31:29 +03:00 committed by Sebastian Dröge
parent 50ee0c1a1d
commit a6812d852f
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
gst-plugin-fallbackswitch/src/fallbackswitch.rs
View file

@ -161,7 +161,7 @@ impl FallbackSwitch {
}
drop(active_sinkpad);
state.last_sinkpad_time = segment.to_running_time(buffer.get_pts());
state.last_sinkpad_time = segment.to_running_time(buffer.get_dts_or_pts());
// Drop all older buffers from the fallback sinkpad
if let Some(fallback_sinkpad) = fallback_sinkpad {
@ -175,7 +175,7 @@ impl FallbackSwitch {
})?;
while let Some(fallback_buffer) = fallback_sinkpad.peek_buffer() {
let fallback_pts = fallback_buffer.get_pts();
let fallback_pts = fallback_buffer.get_dts_or_pts();
if fallback_pts.is_none()
|| fallback_segment.to_running_time(fallback_pts) <= state.last_sinkpad_time
{
@ -232,7 +232,7 @@ impl FallbackSwitch {
gst_error!(self.cat, obj: agg, "Only TIME segments supported");
gst::FlowError::Error
})?;
let running_time = fallback_segment.to_running_time(buffer.get_pts());
let running_time = fallback_segment.to_running_time(buffer.get_dts_or_pts());
{
// FIXME: This will not work correctly for negative DTS
@ -649,7 +649,7 @@ impl AggregatorImpl for FallbackSwitch {
}
};
let running_time = segment.to_running_time(buffer.get_pts());
let running_time = segment.to_running_time(buffer.get_dts_or_pts());
gst_debug!(
self.cat,
obj: agg,