diff options
Diffstat (limited to 'gr-zeromq/python/zeromq/qa_zeromq_pushpull.py')
| -rwxr-xr-x | gr-zeromq/python/zeromq/qa_zeromq_pushpull.py | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py b/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py index 72c024e6a2..86b85d9c1d 100755 --- a/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py +++ b/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py @@ -1,7 +1,6 @@ #!/usr/bin/env python -# -*- coding: utf-8 -*- # -# Copyright 202013 Free Software Foundation, Inc. +# Copyright 2014 Free Software Foundation, Inc. # # This file is part of GNU Radio # @@ -21,9 +20,7 @@ # Boston, MA 02110-1301, USA. # -from gnuradio import gr, gr_unittest -from gnuradio import blocks, zeromq -from gnuradio import eng_notation +from gnuradio import gr, gr_unittest, blocks, zeromq class qa_zeromq_pushpull (gr_unittest.TestCase): @@ -35,12 +32,10 @@ class qa_zeromq_pushpull (gr_unittest.TestCase): def test_001_t (self): src_data = [1,2,3,4,5,6,7,8,9]*100 - print src_data src = blocks.vector_source_c(src_data, False, 1) - zeromq_push_sink = zeromq.push_sink(gr.sizeof_gr_complex, 1, "tcp://*:5555", True) - zeromq_pull_source = zeromq.pull_source(gr.sizeof_gr_complex, 1, "tcp://localhost:5555", 0.1) + zeromq_push_sink = zeromq.push_sink(gr.sizeof_gr_complex, 1, "tcp://127.0.0.1:5555", True) + zeromq_pull_source = zeromq.pull_source(gr.sizeof_gr_complex, 1, "tcp://127.0.0.1:5555", 0.1) sink = blocks.vector_sink_c() -# print sink.data self.tb.connect(src, zeromq_push_sink) self.tb.connect(zeromq_pull_source, sink) self.tb.run () |