summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAndrej Rode <mail@andrejro.de>2018-06-17 14:23:42 +0200
committerMarcus Müller <marcus@hostalia.de>2018-08-25 14:12:56 +0200
commit35f76a9c487e1dabe74b03e874c90349b816aeff (patch)
tree2985c6224bfca3faf4351d293f2a3bd373dee972
parent3043b54b846efec5f32d4226991fd980b518ef41 (diff)
digital: qa_packet_format fix conditionals to wait for messages
-rw-r--r--gr-digital/python/digital/qa_packet_format.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/gr-digital/python/digital/qa_packet_format.py b/gr-digital/python/digital/qa_packet_format.py
index 6b2e9e958e..cf8cf3c8cf 100644
--- a/gr-digital/python/digital/qa_packet_format.py
+++ b/gr-digital/python/digital/qa_packet_format.py
@@ -57,7 +57,7 @@ class test_packet_format_fb(gr_unittest.TestCase):
formatter.to_basic_block()._post(port, msg)
self.tb.start()
- while (snk_hdr.num_messages() < 1) and (snk_pld.num_messages() < 1):
+ while (snk_hdr.num_messages() < 1) or (snk_pld.num_messages() < 1):
time.sleep(0.1)
self.tb.stop()
@@ -109,7 +109,7 @@ class test_packet_format_fb(gr_unittest.TestCase):
self.tb.msg_connect(parser_4bps, 'info', snk_hdr_4bps, 'store')
self.tb.start()
- while (snk_hdr_1bps.num_messages() < 1) and (snk_hdr_4bps.num_messages() < 1):
+ while (snk_hdr_1bps.num_messages() < 1) or (snk_hdr_4bps.num_messages() < 1):
time.sleep(0.1)
self.tb.stop()
self.tb.wait()
@@ -151,7 +151,7 @@ class test_packet_format_fb(gr_unittest.TestCase):
formatter.to_basic_block()._post(port, msg)
self.tb.start()
- while (snk_hdr.num_messages() < 1) and (snk_pld.num_messages() < 1):
+ while (snk_hdr.num_messages() < 1) or (snk_pld.num_messages() < 1):
time.sleep(0.1)
self.tb.stop()
self.tb.wait()