diff options
| author | Tom Rondeau <trondeau@vt.edu> | 2013-03-13 21:14:41 -0400 |
|---|---|---|
| committer | Tom Rondeau <trondeau@vt.edu> | 2013-03-13 21:14:41 -0400 |
| commit | 0fb2e888a48c0bd618109c5dd86e570ab93a6ff4 (patch) | |
| tree | 57ff2b6ef821dd49410d068eb2b1ce1d5e13004d /gr-blocks/python | |
| parent | 1bacc04f7a8f2f9c868a9934624683c7cefb2300 (diff) | |
blocks: fixing some UDP handling of ports/options; using gr-blocks blocks in QA.
Diffstat (limited to 'gr-blocks/python')
| -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 6ebbf87afc..4ab1430b09 100644 --- a/gr-blocks/python/qa_udp_source_sink.py +++ b/gr-blocks/python/qa_udp_source_sink.py @@ -58,14 +58,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) @@ -83,11 +83,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)] @@ -95,8 +95,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() |