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-09-01 17:23:48 +00:00
Code Issues Projects Releases Wiki Activity

ts-inter: fix racy test

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/2380>
This commit is contained in:
François Laignel 2025-07-16 12:24:15 +02:00
parent 716ac58a20
commit 96dde2d337
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
generic/threadshare/tests/inter.rs
View file

@ -429,13 +429,13 @@ fn one_to_many_up_first() {
});
pipe_down_1.set_state(gst::State::Null).unwrap();
// pipe_down_1 was set to stop after 20 buffers
assert_eq!(samples_1.load(Ordering::SeqCst), 20);
// pipe_down_1 was set to stop after 20 buffers (but more might have go through before we stopped)
assert!(samples_1.load(Ordering::SeqCst) >= 20);
// Waiting for pipe_down_2 to handle its buffers too
futures::executor::block_on(n_buf_rx_2).unwrap();
pipe_down_2.set_state(gst::State::Null).unwrap();
assert_eq!(samples_2.load(Ordering::SeqCst), 20);
assert!(samples_2.load(Ordering::SeqCst) >= 20);
pipe_up.set_state(gst::State::Null).unwrap();
println!("up null");