metrics: don't hang in injection_queue_depth_multi_thread test

Darksonn · Sep 23, 2024 · 345e5a4 · 345e5a4
1 parent 8ef5163
commit 345e5a4
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/tokio/tests/rt_metrics.rs b/tokio/tests/rt_metrics.rs
@@ -83,12 +83,21 @@ fn injection_queue_depth_multi_thread() {
 
     barrier1.wait();
 
+    let mut fail: Option<String> = None;
     for i in 0..10 {
-        assert_eq!(i, metrics.injection_queue_depth());
+        let depth = metrics.injection_queue_depth();
+        if i != depth {
+            fail = Some(format!("{i} is not equal to {depth}"));
+            break;
+        }
         rt.spawn(async {});
     }
 
     barrier2.wait();
+
+    if let Some(fail) = fail {
+        panic!("{fail}");
+    }
 }
 
 fn current_thread() -> Runtime {