diff options
| author | Tim O'Shea <tim.oshea753@gmail.com> | 2014-12-30 18:42:48 +0100 |
|---|---|---|
| committer | Tim O'Shea <tim.oshea753@gmail.com> | 2014-12-30 18:42:48 +0100 |
| commit | 18944a9a761eb7c2256e4ad450b943f09664c410 (patch) | |
| tree | b9a6a5313a1a15e3f9a8f80c4b5998c35aadb8ce /gr-zeromq/lib/req_msg_source_impl.h | |
| parent | 29bd7ae09383372afddcbab22fcd99b2333e4c1e (diff) | |
zmq: rep/req msg blocks now working
Diffstat (limited to 'gr-zeromq/lib/req_msg_source_impl.h')
| -rw-r--r-- | gr-zeromq/lib/req_msg_source_impl.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/gr-zeromq/lib/req_msg_source_impl.h b/gr-zeromq/lib/req_msg_source_impl.h index 635fa45b62..3a691743b5 100644 --- a/gr-zeromq/lib/req_msg_source_impl.h +++ b/gr-zeromq/lib/req_msg_source_impl.h @@ -35,11 +35,16 @@ namespace gr { int d_timeout; zmq::context_t *d_context; zmq::socket_t *d_socket; + void readloop(); + boost::thread *d_thread; public: req_msg_source_impl(char *address, int timeout); ~req_msg_source_impl(); + bool start(); + bool stop(); + bool d_finished; int work(int noutput_items, gr_vector_const_void_star &input_items, gr_vector_void_star &output_items); |