diff options
Diffstat (limited to 'gr-zeromq/lib/pull_msg_source_impl.h')
| -rw-r--r-- | gr-zeromq/lib/pull_msg_source_impl.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/gr-zeromq/lib/pull_msg_source_impl.h b/gr-zeromq/lib/pull_msg_source_impl.h index fb9237c408..9ff89ef154 100644 --- a/gr-zeromq/lib/pull_msg_source_impl.h +++ b/gr-zeromq/lib/pull_msg_source_impl.h @@ -35,11 +35,16 @@ namespace gr { int d_timeout; // microseconds, -1 is blocking zmq::context_t *d_context; zmq::socket_t *d_socket; + void readloop(); + boost::thread *d_thread; public: pull_msg_source_impl(char *address, int timeout); ~pull_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); |