summaryrefslogtreecommitdiff
path: root/gr-zeromq/lib/pull_msg_source_impl.h
diff options
context:
space:
mode:
Diffstat (limited to 'gr-zeromq/lib/pull_msg_source_impl.h')
-rw-r--r--gr-zeromq/lib/pull_msg_source_impl.h9
1 files changed, 4 insertions, 5 deletions
diff --git a/gr-zeromq/lib/pull_msg_source_impl.h b/gr-zeromq/lib/pull_msg_source_impl.h
index 9ff89ef154..6d8791d613 100644
--- a/gr-zeromq/lib/pull_msg_source_impl.h
+++ b/gr-zeromq/lib/pull_msg_source_impl.h
@@ -35,19 +35,18 @@ namespace gr {
int d_timeout; // microseconds, -1 is blocking
zmq::context_t *d_context;
zmq::socket_t *d_socket;
+ boost::thread *d_thread;
+
void readloop();
- boost::thread *d_thread;
public:
+ bool d_finished;
+
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);
};
} // namespace zeromq