diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-03-23 13:20:01 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-03-23 13:20:01 +0100 |
| commit | 8048e2e242c6029337bfe6cc056d2830b127044b (patch) | |
| tree | 95870f30bde4b11184291326e0589ad2913a9714 | |
| parent | b03564a7d59d3bf15b9b8f9f2ae8bb6d8d35d955 (diff) | |
| download | dabmod-8048e2e242c6029337bfe6cc056d2830b127044b.tar.gz dabmod-8048e2e242c6029337bfe6cc056d2830b127044b.tar.bz2 dabmod-8048e2e242c6029337bfe6cc056d2830b127044b.zip | |
Make sure the ZMQ input thread dies on Stop()
| -rw-r--r-- | src/InputZeroMQReader.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp index 4b55434..afb6b7d 100644 --- a/src/InputZeroMQReader.cpp +++ b/src/InputZeroMQReader.cpp @@ -147,6 +147,7 @@ void InputZeroMQWorker::Start(struct InputZeroMQThreadData* workerdata) void InputZeroMQWorker::Stop() { running = false; + zmqcontext.close(); recv_thread.join(); } |