diff options
Diffstat (limited to 'src/InputReader.h')
| -rw-r--r-- | src/InputReader.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/InputReader.h b/src/InputReader.h index b8c4fae..d2b5d8c 100644 --- a/src/InputReader.h +++ b/src/InputReader.h @@ -150,8 +150,6 @@ struct InputZeroMQThreadData ThreadsafeQueue<std::shared_ptr<std::vector<uint8_t> > > *in_messages; std::string uri; unsigned max_queued_frames; - - bool running; }; class InputZeroMQWorker @@ -164,10 +162,13 @@ class InputZeroMQWorker void Start(struct InputZeroMQThreadData* workerdata); void Stop(); + + bool is_running(void) { return running; } private: + bool running; + void RecvProcess(struct InputZeroMQThreadData* workerdata); - bool running; zmq::context_t zmqcontext; // is thread-safe boost::thread recv_thread; @@ -186,7 +187,6 @@ class InputZeroMQReader : public InputReader InputZeroMQReader() { workerdata_.in_messages = &in_messages_; - workerdata_.running = false; } ~InputZeroMQReader() |