summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2014-01-10 10:04:52 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2014-01-10 10:04:52 +0100
commit3f094996520fbf006a567873bc9da4d1b430345f (patch)
tree6a05a08d1a04fbe24f01c6cde6db72a523f8c74f /src
parent0d681f0f5a23d1ad32206c385b7e4201749abc27 (diff)
downloaddabmod-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.h6
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_;