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-06-23 00:20:34 +00:00
Code Issues Projects Releases Wiki Activity

jitterbuffer: fix packet_spacing calculation

Browse source 
When encountering an unexpected gap in received seqnums, ips_pts
and ips_rtptime must be reset to avoid calculating a potentially
invalid packet spacing the next time sequential packets are
received.
This commit is contained in:
Mathieu Duponchelle 2019-09-11 19:25:30 +02:00
parent 7d88c014f8
commit ec56fee368
1 changed files with 18 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
gst-plugin-threadshare/src/jitterbuffer.rs
View file

@ -315,6 +315,14 @@ impl JitterBuffer {
} else {
state.packet_spacing = new_packet_spacing;
}
gst_debug!(
self.cat,
"new packet spacing {}, old packet spacing {} combined to {}",
new_packet_spacing,
old_packet_spacing,
state.packet_spacing
);
}
state.ips_rtptime = rtptime;
state.ips_pts = pts;
@ -520,13 +528,17 @@ impl JitterBuffer {
let gap = gst_rtp::compare_seqnum(state.last_in_seqnum as u16, seq);
if gap == 1 {
self.calculate_packet_spacing(state, rtptime, pts);
} else if (gap != -1 && gap < -(max_misorder as i32)) || (gap >= max_dropout as i32) {
let reset = self.handle_big_gap_buffer(state, element, buffer, pt);
if reset {
return self.reset(state, pad, element);
} else {
return Ok(gst::FlowSuccess::Ok);
} else {
if (gap != -1 && gap < -(max_misorder as i32)) || (gap >= max_dropout as i32) {
let reset = self.handle_big_gap_buffer(state, element, buffer, pt);
if reset {
return self.reset(state, pad, element);
} else {
return Ok(gst::FlowSuccess::Ok);
}
}
state.ips_pts = gst::CLOCK_TIME_NONE;
state.ips_rtptime = 0;
}
state.gap_packets.as_mut().unwrap().clear();