diff options
Diffstat (limited to 'gr-zeromq/lib/rep_msg_sink_impl.h')
| -rw-r--r-- | gr-zeromq/lib/rep_msg_sink_impl.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/gr-zeromq/lib/rep_msg_sink_impl.h b/gr-zeromq/lib/rep_msg_sink_impl.h index 40d7969472..25bd0e87a0 100644 --- a/gr-zeromq/lib/rep_msg_sink_impl.h +++ b/gr-zeromq/lib/rep_msg_sink_impl.h @@ -35,6 +35,9 @@ namespace gr { int d_timeout; zmq::context_t *d_context; zmq::socket_t *d_socket; + boost::thread *d_thread; + bool d_finished; + void readloop(); public: rep_msg_sink_impl(char *address, int timeout); @@ -43,7 +46,8 @@ namespace gr { int work(int noutput_items, gr_vector_const_void_star &input_items, gr_vector_void_star &output_items); - void handler(pmt::pmt_t msg); + bool start(); + bool stop(); }; } // namespace zeromq |