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-11-29 06:50:59 +00:00
Code Issues Projects Releases Wiki Activity

fmp4mux: Fix a couple of assertions by handling these cases cleaner

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1071>
This commit is contained in:
Sebastian Dröge 2023-02-01 14:56:03 +02:00
parent 560bdc4cb7
commit ecb26a0b16
1 changed files with 6 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
mux/fmp4/src/fmp4mux/imp.rs
View file

@ -1264,9 +1264,10 @@ impl FMP4Mux {
gst::trace!(
CAT,
obj: stream.sinkpad,
"Draining up to end PTS {} / duration {}",
"Draining from {} up to end PTS {} / duration {}",
chunk_start_pts,
dequeue_end_pts,
dequeue_end_pts - chunk_start_pts
dequeue_end_pts.saturating_sub(chunk_start_pts),
);
while let Some(gop) = stream.queued_gops.back() {
@ -1437,9 +1438,10 @@ impl FMP4Mux {
gst::trace!(
CAT,
obj: stream.sinkpad,
"Draining up to end PTS {} / duration {}",
"Draining from {} up to end PTS {} / duration {}",
chunk_start_pts,
dequeue_end_pts,
dequeue_end_pts - chunk_start_pts
dequeue_end_pts.saturating_sub(chunk_start_pts),
);
while let Some(gop) = stream.queued_gops.back() {
@ -1767,9 +1769,6 @@ impl FMP4Mux {
if all_eos || stream.sinkpad.is_eos() {
// This is handled below generally if nothing was dequeued
} else {
// Otherwise this can only really happen on timeout in live pipelines.
assert!(timeout);
if settings.chunk_duration.is_some() {
gst::warning!(
CAT,
@ -2316,7 +2315,6 @@ impl FMP4Mux {
Err(err) => {
if err == gst_base::AGGREGATOR_FLOW_NEED_DATA {
assert!(!all_eos);
assert!(timeout);
gst::element_imp_warning!(
self,
gst::StreamError::Format,