zeromq: qa: Increase timeout for msg source tests

The chosen timeout of 100ms was too short for some cases. Increase to
max 2000ms, but check every 200ms.

Signed-off-by: Martin Braun <[email protected]>

Author: mbr0wn

gr-zeromq/python/zeromq/qa_zeromq_req_msg_source.py

@@ -60,8 +60,10 @@ def test_valid_pmt(self):
         """Test receiving of valid PMT messages"""
         msg = pmt.to_pmt('test_valid_pmt')
         self.send_messages([msg])
-
-        time.sleep(0.1)
+        for _ in range(10):
+            if self.message_debug.num_messages() > 0:
+                break
+            time.sleep(0.2)
         self.assertEqual(1, self.message_debug.num_messages())
         self.assertTrue(pmt.equal(msg, self.message_debug.get_message(0)))
 

gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py

@@ -48,8 +48,10 @@ def test_valid_pmt(self):
         """Test receiving of valid PMT messages"""
         msg = pmt.to_pmt('test_valid_pmt')
         self.zmq_sock.send(pmt.serialize_str(msg))
-
-        time.sleep(0.1)
+        for _ in range(10):
+            if self.message_debug.num_messages() > 0:
+                break
+            time.sleep(0.2)
         self.assertEqual(1, self.message_debug.num_messages())
         self.assertTrue(pmt.equal(msg, self.message_debug.get_message(0)))