diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-02-21 10:49:42 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-02-21 10:49:42 +0100 |
| commit | e8c274301aca0bca1b7d1e6086cf29af4645732e (patch) | |
| tree | 44a000d7fcafb4c495268e3003e8acd8c9ad0926 /src/InputReader.h | |
| parent | a0eda7372e525c3b7d292c042155be19c34856f8 (diff) | |
| download | dabmod-e8c274301aca0bca1b7d1e6086cf29af4645732e.tar.gz dabmod-e8c274301aca0bca1b7d1e6086cf29af4645732e.tar.bz2 dabmod-e8c274301aca0bca1b7d1e6086cf29af4645732e.zip | |
zmq input improvements
Diffstat (limited to 'src/InputReader.h')
| -rw-r--r-- | src/InputReader.h | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/InputReader.h b/src/InputReader.h index ae36899..de8fb78 100644 --- a/src/InputReader.h +++ b/src/InputReader.h @@ -143,15 +143,14 @@ class InputZeroMQWorker { public: InputZeroMQWorker() : - zmqcontext(1), subscriber(zmqcontext, ZMQ_SUB) {} + zmqcontext(1) {} void Start(struct InputZeroMQThreadData* workerdata); void Stop(); private: void RecvProcess(struct InputZeroMQThreadData* workerdata); bool running; - zmq::context_t zmqcontext; - zmq::socket_t subscriber; + zmq::context_t zmqcontext; // is thread-safe boost::thread recv_thread; }; |