From 96dde2d3377eafdd983a90e4b4694dd894539426 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Fran=C3=A7ois=20Laignel?= <francois@centricular.com>
Date: Wed, 16 Jul 2025 12:24:15 +0200
Subject: [PATCH] ts-inter: fix racy test

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/2380>
---
 generic/threadshare/tests/inter.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/generic/threadshare/tests/inter.rs b/generic/threadshare/tests/inter.rs
index 76f5faae0..acfb79973 100644
--- a/generic/threadshare/tests/inter.rs
+++ b/generic/threadshare/tests/inter.rs
@@ -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");