diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-08-15 20:06:27 +0200 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-08-15 20:06:27 +0200 |
| commit | a45009f0063a98260c835786901dbd00ec5e9705 (patch) | |
| tree | 0bede8886e805b1c06b89dcb401e6ded3e6ab19a /src/InputReader.h | |
| parent | 1e01627b0653c76e215a9d8f5e9fffe510e247a6 (diff) | |
| download | dabmod-a45009f0063a98260c835786901dbd00ec5e9705.tar.gz dabmod-a45009f0063a98260c835786901dbd00ec5e9705.tar.bz2 dabmod-a45009f0063a98260c835786901dbd00ec5e9705.zip | |
Move running flag out of workerdata
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() |