diff options
| author | Tim O'Shea <tim.oshea753@gmail.com> | 2014-12-30 18:07:52 +0100 |
|---|---|---|
| committer | Tim O'Shea <tim.oshea753@gmail.com> | 2014-12-30 18:07:52 +0100 |
| commit | 29bd7ae09383372afddcbab22fcd99b2333e4c1e (patch) | |
| tree | 1ba06d071e30e3e8be781ea17dbbc5d53a9d078c /gr-zeromq/lib/pull_msg_source_impl.h | |
| parent | dbf589a17aa159fc2e49e450ff638538cd144aee (diff) | |
zmq: pull_msg_source should be working
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); |