Fix race in monitor test

issuu · Oct 21, 2023 · ca804e3 · ca804e3
1 parent 7651911
commit ca804e3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/zmq/test/zmq_test.ml b/zmq/test/zmq_test.ml
@@ -138,8 +138,9 @@ let test_monitor () =
   end;
   Zmq.Socket.close s1;
   assert_event "m1" m1 "Closed";
-  Zmq.Socket.close s2;
+  assert_event "m1" m1 "Monitor_stopped";
   assert_event "m2" m2 "Disconnect";
+  Zmq.Socket.close s2;
 
   Zmq.Socket.close m2;
   Zmq.Socket.close m1;
@@ -165,7 +166,7 @@ let test_proxy () =
   in
 
   let _thread = Thread.create proxy (pull, pub) in
-  sleep 10;
+  sleep 10; (* Wait until the proxy has been created *)
   let sub =
     let s = Zmq.Socket.create ctx sub in
     Zmq.Socket.connect s pub_endpoint;