diff options
| author | Johannes Schmitz <schmitz@ti.rwth-aachen.de> | 2014-05-09 16:35:50 +0200 |
|---|---|---|
| committer | Johannes Schmitz <schmitz@ti.rwth-aachen.de> | 2014-05-09 16:35:50 +0200 |
| commit | aef0f4f3d525da300fa8c5b10b81ff8eee953b93 (patch) | |
| tree | 061d40862ca44cefc7cd9ebdf7425826f73914b9 | |
| parent | 49466c73743d1acf70a3e2d24e6dbc2a954f7271 (diff) | |
zeromq: Add qa code
| -rwxr-xr-x | gr-zeromq/python/zeromq/qa_zeromq_pub.py | 52 |
1 files changed, 52 insertions, 0 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_pub.py b/gr-zeromq/python/zeromq/qa_zeromq_pub.py new file mode 100755 index 0000000000..77297509b2 --- /dev/null +++ b/gr-zeromq/python/zeromq/qa_zeromq_pub.py @@ -0,0 +1,52 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- +# +# Copyright 202013 Free Software Foundation, Inc. +# +# This file is part of GNU Radio +# +# GNU Radio is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; either version 3, or (at your option) +# any later version. +# +# GNU Radio is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with GNU Radio; see the file COPYING. If not, write to +# the Free Software Foundation, Inc., 51 Franklin Street, +# Boston, MA 02110-1301, USA. +# + +from gnuradio import gr, gr_unittest +from gnuradio import blocks, zeromq +from gnuradio import eng_notation + +class qa_zeromq_pub (gr_unittest.TestCase): + + def setUp (self): + self.tb = gr.top_block () + + def tearDown (self): + self.tb = None + + def test_001_t (self): + print "test_001_t" + src_data = [1,2,3,4,5,6,7,8,9,0]*100 + src = blocks.vector_source_f(src_data, False, 1) + zeromq_pub_sink = zeromq.pub_sink(gr.sizeof_float, 10 , "tcp://127.0.0.1:5555") + self.tb.connect(src, zeromq_pub_sink) + self.probe_manager = zeromq.probe_manager() + self.probe_manager.add_socket("tcp://127.0.0.1:5555", 'float32', self.recv_data) + self.tb.run () + self.assertEqual(self.rx_data, src_data) + + def recv_data (self, data): + self.rx_data = data + + +if __name__ == '__main__': + gr_unittest.run(qa_zeromq_pub, "qa_zeromq_pub.xml") |