summaryrefslogtreecommitdiff
path: root/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
diff options
context:
space:
mode:
authorTom Rondeau <tom@trondeau.com>2014-05-16 14:02:06 -0400
committerTom Rondeau <tom@trondeau.com>2014-05-16 14:02:06 -0400
commitf4a0034532eefbeeaa6fd0d05f305463f106e50b (patch)
treec7cc6a9f80805c61273f6ecb5020214e692609f3 /gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
parent844867c749198e9d39d5196f214b1be77d0001a4 (diff)
zeromq: updates to qa code to wait for completion and pass.
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_reqrep.py')
-rwxr-xr-xgr-zeromq/python/zeromq/qa_zeromq_reqrep.py8
1 files changed, 6 insertions, 2 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py b/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
index 337f28588e..3329add1be 100755
--- a/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
+++ b/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
@@ -24,6 +24,7 @@
from gnuradio import gr, gr_unittest
from gnuradio import blocks, zeromq
from gnuradio import eng_notation
+import time
class qa_zeromq_reqrep (gr_unittest.TestCase):
@@ -42,8 +43,11 @@ class qa_zeromq_reqrep (gr_unittest.TestCase):
sink = blocks.vector_sink_f(vlen)
self.tb.connect(src, zeromq_rep_sink)
self.tb.connect(zeromq_req_source, sink)
- self.tb.run ()
- self.assertEqual(sink.data(), src_data)
+ self.tb.start()
+ time.sleep(0.25)
+ self.tb.stop()
+ self.tb.wait()
+ self.assertFloatTuplesAlmostEqual(sink.data(), src_data)
if __name__ == '__main__':
gr_unittest.run(qa_zeromq_reqrep)