diff options
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_pushpull.py')
| -rwxr-xr-x | gr-zeromq/python/zeromq/qa_zeromq_pushpull.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py b/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py index dd4cb44ae6..56f0cb616b 100755 --- a/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py @@ -31,12 +31,12 @@ class qa_zeromq_pushpull (gr_unittest.TestCase): self.tb = None def test_001 (self): - print "test_001" - src_data = [1,2,3,4,5,6,7,8,9,0]*100 - src = blocks.vector_source_c(src_data, False, 1) - zeromq_push_sink = zeromq.push_sink(gr.sizeof_gr_complex, 10, "tcp://127.0.0.1:5555") - zeromq_pull_source = zeromq.pull_source(gr.sizeof_gr_complex, 10, "tcp://127.0.0.1:5555", 0) - sink = blocks.vector_sink_c() + vlen = 10 + src_data = range(vlen)*100 + src = blocks.vector_source_f(src_data, False, vlen) + zeromq_push_sink = zeromq.push_sink(gr.sizeof_float, vlen, "tcp://127.0.0.1:5555") + zeromq_pull_source = zeromq.pull_source(gr.sizeof_float, vlen, "tcp://127.0.0.1:5555", 0) + sink = blocks.vector_sink_f(vlen) self.tb.connect(src, zeromq_push_sink) self.tb.connect(zeromq_pull_source, sink) self.tb.run () |