diff options
| author | Johnathan Corgan <johnathan@corganlabs.com> | 2017-04-06 21:25:51 -0700 |
|---|---|---|
| committer | Johnathan Corgan <johnathan@corganlabs.com> | 2017-04-06 21:25:51 -0700 |
| commit | ca38efec194f7d4e437a294838268a2ccdf609e9 (patch) | |
| tree | 74237271f5ff456f69dcbf608b4d65543d16064e /gr-zeromq/python/zeromq/qa_zeromq_reqrep.py | |
| parent | 83526c6c7c16c483f42bee4d4602c2b9f88258cc (diff) | |
| parent | 42fa660d84398b0b06908948e2064b711d72da3f (diff) | |
Merge branch 'next' into python3
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_reqrep.py')
| -rw-r--r-- | gr-zeromq/python/zeromq/qa_zeromq_reqrep.py | 20 |
1 files changed, 13 insertions, 7 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py b/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py index 664e156528..9fccbf300d 100644 --- a/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py @@ -30,10 +30,12 @@ import time class qa_zeromq_reqrep (gr_unittest.TestCase): def setUp (self): - self.tb = gr.top_block () + self.send_tb = gr.top_block() + self.recv_tb = gr.top_block() def tearDown (self): - self.tb = None + self.send_tb = None + self.recv_tb = None def test_001 (self): vlen = 10 @@ -42,12 +44,16 @@ class qa_zeromq_reqrep (gr_unittest.TestCase): zeromq_rep_sink = zeromq.rep_sink(gr.sizeof_float, vlen, "tcp://127.0.0.1:5558", 0) zeromq_req_source = zeromq.req_source(gr.sizeof_float, vlen, "tcp://127.0.0.1:5558", 0) sink = blocks.vector_sink_f(vlen) - self.tb.connect(src, zeromq_rep_sink) - self.tb.connect(zeromq_req_source, sink) - self.tb.start() + self.send_tb.connect(src, zeromq_rep_sink) + self.recv_tb.connect(zeromq_req_source, sink) + self.recv_tb.start() time.sleep(0.25) - self.tb.stop() - self.tb.wait() + self.send_tb.start() + time.sleep(0.25) + self.recv_tb.stop() + self.send_tb.stop() + self.recv_tb.wait() + self.send_tb.wait() self.assertFloatTuplesAlmostEqual(sink.data(), src_data) if __name__ == '__main__': |