summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rwxr-xr-xgr-zeromq/python/zeromq/qa_zeromq_pub.py5
-rwxr-xr-xgr-zeromq/python/zeromq/qa_zeromq_pushpull.py4
-rwxr-xr-xgr-zeromq/python/zeromq/qa_zeromq_reqrep.py4
3 files changed, 7 insertions, 6 deletions
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_pub.py b/gr-zeromq/python/zeromq/qa_zeromq_pub.py
index 77297509b2..e71c01a665 100755
--- a/gr-zeromq/python/zeromq/qa_zeromq_pub.py
+++ b/gr-zeromq/python/zeromq/qa_zeromq_pub.py
@@ -33,8 +33,8 @@ class qa_zeromq_pub (gr_unittest.TestCase):
def tearDown (self):
self.tb = None
- def test_001_t (self):
- print "test_001_t"
+ def test_001 (self):
+ print "test_001"
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")
@@ -42,6 +42,7 @@ class qa_zeromq_pub (gr_unittest.TestCase):
self.probe_manager = zeromq.probe_manager()
self.probe_manager.add_socket("tcp://127.0.0.1:5555", 'float32', self.recv_data)
self.tb.run ()
+ print self.rx_data
self.assertEqual(self.rx_data, src_data)
def recv_data (self, data):
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py b/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py
index 457c524771..1dfcab1b00 100755
--- a/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py
+++ b/gr-zeromq/python/zeromq/qa_zeromq_pushpull.py
@@ -30,8 +30,8 @@ class qa_zeromq_pushpull (gr_unittest.TestCase):
def tearDown (self):
self.tb = None
- def test_001_t (self):
- print "test_001_t"
+ 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")
diff --git a/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py b/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
index e2c14eb71a..afb1fbc54e 100755
--- a/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
+++ b/gr-zeromq/python/zeromq/qa_zeromq_reqrep.py
@@ -33,8 +33,8 @@ class qa_zeromq_reqrep (gr_unittest.TestCase):
def tearDown (self):
self.tb = None
- def test_001_t (self):
- print "test_001_t"
+ 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_rep_sink = zeromq.rep_sink(gr.sizeof_gr_complex, 10, "tcp://127.0.0.1:5555", 0)