diff options
| author | Tom Rondeau <trondeau@vt.edu> | 2013-03-13 21:16:05 -0400 |
|---|---|---|
| committer | Tom Rondeau <trondeau@vt.edu> | 2013-03-13 21:16:05 -0400 |
| commit | d7c39796926f1e285d36c938c37e93d120638393 (patch) | |
| tree | e453705aa6150439db8c422e5823d5b9ceac508f /gr-blocks/python/qa_udp_source_sink.py | |
| parent | 41c0eb43e2177f3e22f4f72ca8e99d6580944b21 (diff) | |
| parent | 0fb2e888a48c0bd618109c5dd86e570ab93a6ff4 (diff) | |
Merge branch 'master' into next
Diffstat (limited to 'gr-blocks/python/qa_udp_source_sink.py')
| -rw-r--r-- | gr-blocks/python/qa_udp_source_sink.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/gr-blocks/python/qa_udp_source_sink.py b/gr-blocks/python/qa_udp_source_sink.py index bd558b2e25..8c5fa28217 100644 --- a/gr-blocks/python/qa_udp_source_sink.py +++ b/gr-blocks/python/qa_udp_source_sink.py @@ -59,14 +59,14 @@ class test_udp_sink_source(gr_unittest.TestCase): def test_002(self): port = 65500 - n_data = 100000 + n_data = 100 src_data = [float(x) for x in range(n_data)] expected_result = tuple(src_data) src = gr.vector_source_f(src_data, False) - udp_snd = gr.udp_sink(gr.sizeof_float, 'localhost', port) + udp_snd = blocks.udp_sink(gr.sizeof_float, 'localhost', port) self.tb_snd.connect(src, udp_snd) - udp_rcv = gr.udp_source(gr.sizeof_float, 'localhost', port) + udp_rcv = blocks.udp_source(gr.sizeof_float, 'localhost', port) dst = gr.vector_sink_f() self.tb_rcv.connect(udp_rcv, dst) @@ -84,11 +84,11 @@ class test_udp_sink_source(gr_unittest.TestCase): self.assert_(not self.timeout) def test_003(self): - udp_rcv = gr.udp_source( gr.sizeof_float, '0.0.0.0', 0, eof=False ) + udp_rcv = blocks.udp_source(gr.sizeof_float, '0.0.0.0', 0, eof=False) rcv_port = udp_rcv.get_port() - udp_snd = gr.udp_sink( gr.sizeof_float, '127.0.0.1', 65500 ) - udp_snd.connect( 'localhost', rcv_port ) + udp_snd = blocks.udp_sink(gr.sizeof_float, '127.0.0.1', 65500) + udp_snd.connect('localhost', rcv_port) n_data = 16 src_data = [float(x) for x in range(n_data)] @@ -96,8 +96,8 @@ class test_udp_sink_source(gr_unittest.TestCase): src = gr.vector_source_f(src_data) dst = gr.vector_sink_f() - self.tb_snd.connect( src, udp_snd ) - self.tb_rcv.connect( udp_rcv, dst ) + self.tb_snd.connect(src, udp_snd) + self.tb_rcv.connect(udp_rcv, dst) self.tb_rcv.start() self.tb_snd.run() |