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-22 11:30:59 +00:00
Code Issues Projects Releases Wiki Activity

fmp4mux: Let test consume remaining buffers after EOS

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1914>
This commit is contained in:
Jochen Henneberg 2024-11-13 08:16:10 +01:00
parent b95f39f4bf
commit 580e06a002
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
mux/fmp4/tests/tests.rs
View file

@ -2757,8 +2757,10 @@ fn test_caps_change_at_gop_boundary_multi_stream() {
assert_eq!(h1.upstream_events_in_queue(), 2); assert_eq!(h1.upstream_events_in_queue(), 2);
assert_eq!(h2.upstream_events_in_queue(), 1); assert_eq!(h2.upstream_events_in_queue(), 1);
h1.crank_single_clock_wait().unwrap();
h1.push_event(gst::event::Eos::new()); h1.push_event(gst::event::Eos::new());
h2.push_event(gst::event::Eos::new()); h2.push_event(gst::event::Eos::new());
test_caps_changed_verify(&mut h1, 1 + 1 + 8, true, false);
assert_eq!(h1.buffers_in_queue(), 0); assert_eq!(h1.buffers_in_queue(), 0);
} }
@ -2800,7 +2802,7 @@ fn test_caps_change_at_gop_boundary_chunked_multi_stream() {
h2.set_src_caps(caps2); h2.set_src_caps(caps2);
h2.play(); h2.play();
for i in 0..21 { for i in 0..19 {
// caps change on 10th and 20th buffer // caps change on 10th and 20th buffer
if let Some(caps) = match i { if let Some(caps) = match i {
10 => Some( 10 => Some(
@ -2903,8 +2905,11 @@ fn test_caps_change_at_gop_boundary_chunked_multi_stream() {
// The first chunk of the new fragment // The first chunk of the new fragment
test_caps_changed_verify(&mut h1, 1 + 1 + 8 + 9, true, false); test_caps_changed_verify(&mut h1, 1 + 1 + 8 + 9, true, false);
h1.crank_single_clock_wait().unwrap();
h1.push_event(gst::event::Eos::new()); h1.push_event(gst::event::Eos::new());
h2.push_event(gst::event::Eos::new()); h2.push_event(gst::event::Eos::new());
// The final chunk from EOS
test_caps_changed_verify(&mut h1, 1 + 1 + 1, false, true);
assert_eq!(h1.buffers_in_queue(), 0); assert_eq!(h1.buffers_in_queue(), 0);
} }