From 8c39648ec6890adc4132d0bfbaeb506eef5a4245 Mon Sep 17 00:00:00 2001
From: sakridge <sakridge@gmail.com>
Date: Thu, 19 May 2022 10:54:39 -0600
Subject: [PATCH] Give some tolerance to recv_mmsg test (#25299)

---
 streamer/tests/recvmmsg.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/streamer/tests/recvmmsg.rs b/streamer/tests/recvmmsg.rs
index 7fa18739df..ffda66c6cf 100644
--- a/streamer/tests/recvmmsg.rs
+++ b/streamer/tests/recvmmsg.rs
@@ -18,6 +18,7 @@ pub fn test_recv_mmsg_batch_size() {
     let sent = TEST_BATCH_SIZE;
 
     let mut elapsed_in_max_batch = 0;
+    let mut num_max_batches = 0;
     (0..1000).for_each(|_| {
         for _ in 0..sent {
             let data = [0; PACKET_DATA_SIZE];
@@ -27,8 +28,11 @@ pub fn test_recv_mmsg_batch_size() {
         let now = Instant::now();
         let recv = recv_mmsg(&reader, &mut packets[..]).unwrap();
         elapsed_in_max_batch += now.elapsed().as_nanos();
-        assert_eq!(TEST_BATCH_SIZE, recv);
+        if recv == TEST_BATCH_SIZE {
+            num_max_batches += 1;
+        }
     });
+    assert!(num_max_batches > 990);
 
     let mut elapsed_in_small_batch = 0;
     (0..1000).for_each(|_| {