diff options
| author | Martin Braun <martin@gnuradio.org> | 2021-02-15 13:07:21 +0100 |
|---|---|---|
| committer | Martin Braun <martin@gnuradio.org> | 2021-02-15 05:36:51 -0800 |
| commit | e774111ea47e5bd3dccc14d3cf4ea18da2c45e96 (patch) | |
| tree | 223fb971c27708ead92e3b8a7db75d4eb28593dc | |
| parent | 24e5a34d5b275b63c0d1a075a475288ab76ba133 (diff) | |
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 <martin@gnuradio.org>
| -rw-r--r-- | gr-zeromq/python/zeromq/qa_zeromq_req_msg_source.py | 6 | ||||
| -rw-r--r-- | gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py | 6 |
2 files changed, 8 insertions, 4 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_req_msg_source.py b/gr-zeromq/python/zeromq/qa_zeromq_req_msg_source.py index 61759c289b..5e03d352ad 100644 --- a/gr-zeromq/python/zeromq/qa_zeromq_req_msg_source.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_req_msg_source.py @@ -60,8 +60,10 @@ class qa_zeromq_req_msg_source(gr_unittest.TestCase): """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))) diff --git a/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py b/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py index 3c98396087..10e7d5da84 100644 --- a/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_sub_msg_source.py @@ -48,8 +48,10 @@ class qa_zeromq_sub_msg_source(gr_unittest.TestCase): """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))) |