diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-02-22 21:39:56 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-02-22 21:39:56 +0100 |
| commit | 87b708657a78cac4690ba81967e5ca03d7faab09 (patch) | |
| tree | 029f6bdc0cc65d9a1ad2849624e947a9404b94b8 /src/InputZeroMQReader.cpp | |
| parent | 1ada0901a8fa687576fa4953044fd43bc6c06f8a (diff) | |
| download | dabmod-87b708657a78cac4690ba81967e5ca03d7faab09.tar.gz dabmod-87b708657a78cac4690ba81967e5ca03d7faab09.tar.bz2 dabmod-87b708657a78cac4690ba81967e5ca03d7faab09.zip | |
Restart full modulator on ZeroMQ input overrun
Diffstat (limited to 'src/InputZeroMQReader.cpp')
| -rw-r--r-- | src/InputZeroMQReader.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp index 5fab447..7ac7d41 100644 --- a/src/InputZeroMQReader.cpp +++ b/src/InputZeroMQReader.cpp @@ -64,7 +64,14 @@ struct zmq_dab_message_t int InputZeroMQReader::Open(const std::string& uri, unsigned max_queued_frames) { - uri_ = uri; + // The URL might start with zmq+tcp:// + if (uri.substr(0, 4) == "zmq+") { + uri_ = uri.substr(4); + } + else { + uri_ = uri; + } + workerdata_.uri = uri; workerdata_.max_queued_frames = max_queued_frames; // launch receiver thread |