diff options
| author | Camilo Solano <solano@ti.rwth-aachen.de> | 2014-05-13 12:53:23 +0200 |
|---|---|---|
| committer | Camilo Solano <solano@ti.rwth-aachen.de> | 2014-05-13 12:53:23 +0200 |
| commit | 9970854f8938fcc015608dc163442467427cb9a6 (patch) | |
| tree | 31390248ae3252291b15fcb1a3a2819eaa5ce2c6 /gr-zeromq/examples/python | |
| parent | 746737b4a9fc74bf4e86debdf35e67b8238da8b9 (diff) | |
Add sub_source block and fix pub_sink
Diffstat (limited to 'gr-zeromq/examples/python')
| -rwxr-xr-x | gr-zeromq/examples/python/client.py | 3 | ||||
| -rwxr-xr-x | gr-zeromq/examples/python/server.py | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/gr-zeromq/examples/python/client.py b/gr-zeromq/examples/python/client.py index 3d55cc9a98..7663f9a056 100755 --- a/gr-zeromq/examples/python/client.py +++ b/gr-zeromq/examples/python/client.py @@ -50,8 +50,9 @@ class top_block(gr.top_block): source_adr = "tcp://"+self.options.servername+":5555" # blocks - self.zmq_source = zeromq.req_source(gr.sizeof_float, 1, source_adr) + #self.zmq_source = zeromq.req_source(gr.sizeof_float, 1, source_adr) #self.zmq_source = zeromq.pull_source(gr.sizeof_float, 1, source_adr) + self.zmq_source = zeromq.sub_source(gr.sizeof_float, 1, source_adr) #self.zmq_probe = zeromq.push_sink(gr.sizeof_float,probe_adr) self.zmq_probe = zeromq.pub_sink(gr.sizeof_float,probe_adr) diff --git a/gr-zeromq/examples/python/server.py b/gr-zeromq/examples/python/server.py index 28b732ed3e..358b66c568 100755 --- a/gr-zeromq/examples/python/server.py +++ b/gr-zeromq/examples/python/server.py @@ -56,7 +56,8 @@ class top_block(gr.top_block): self.gr_sig_source = analog.sig_source_f(samp_rate, analog.GR_SIN_WAVE , 1000, 1, 0) self.throttle = blocks.throttle(gr.sizeof_float, samp_rate) self.mult = blocks.multiply_const_ff(1) - self.zmq_sink = zeromq.rep_sink(gr.sizeof_float, 1, sink_adr) + #self.zmq_sink = zeromq.rep_sink(gr.sizeof_float, 1, sink_adr) + self.zmq_sink = zeromq.pub_sink(gr.sizeof_float, 1, sink_adr) #self.zmq_sink = zeromq.push_sink(gr.sizeof_float, 1, sink_adr) #self.zmq_probe = zeromq.push_sink(gr.sizeof_float, probe_adr) self.zmq_probe = zeromq.pub_sink(gr.sizeof_float, probe_adr) |