summaryrefslogtreecommitdiff
path: root/gr-zeromq/lib/req_msg_source_impl.h
diff options
context:
space:
mode:
Diffstat (limited to 'gr-zeromq/lib/req_msg_source_impl.h')
-rw-r--r--gr-zeromq/lib/req_msg_source_impl.h5
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);