diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-01-10 10:04:52 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-01-10 10:04:52 +0100 |
| commit | 3f094996520fbf006a567873bc9da4d1b430345f (patch) | |
| tree | 6a05a08d1a04fbe24f01c6cde6db72a523f8c74f /src | |
| parent | 0d681f0f5a23d1ad32206c385b7e4201749abc27 (diff) | |
| download | dabmod-3f094996520fbf006a567873bc9da4d1b430345f.tar.gz dabmod-3f094996520fbf006a567873bc9da4d1b430345f.tar.bz2 dabmod-3f094996520fbf006a567873bc9da4d1b430345f.zip | |
kill ZMQ thread when InputZeroMQReader is destroyed
Diffstat (limited to 'src')
| -rw-r--r-- | src/InputReader.h | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/InputReader.h b/src/InputReader.h index 8917922..015303d 100644 --- a/src/InputReader.h +++ b/src/InputReader.h @@ -164,6 +164,11 @@ class InputZeroMQReader : public InputReader workerdata_.in_messages = &in_messages_; } + ~InputZeroMQReader() + { + worker_.Stop(); + } + int Open(std::string uri); int GetNextFrame(void* buffer); @@ -171,6 +176,7 @@ class InputZeroMQReader : public InputReader void PrintInfo(); private: + InputZeroMQReader(const InputZeroMQReader& other) {} Logger logger_; std::string uri_; |