diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2018-04-11 15:52:08 +0200 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2018-04-11 15:52:08 +0200 |
| commit | 9a1f5fa40020247ed25fbe553d2ce71fa53d9e95 (patch) | |
| tree | f97a0ee97edb93c646a80b97656b927f4527ce69 /src/DabMod.cpp | |
| parent | 7514a3951bdee4fe71f877e83fc6acf18bc847e5 (diff) | |
| download | dabmod-9a1f5fa40020247ed25fbe553d2ce71fa53d9e95.tar.gz dabmod-9a1f5fa40020247ed25fbe553d2ce71fa53d9e95.tar.bz2 dabmod-9a1f5fa40020247ed25fbe553d2ce71fa53d9e95.zip | |
Add ZMQ input buffer size to RC
Diffstat (limited to 'src/DabMod.cpp')
| -rw-r--r-- | src/DabMod.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/DabMod.cpp b/src/DabMod.cpp index f384e78..0d4a180 100644 --- a/src/DabMod.cpp +++ b/src/DabMod.cpp @@ -383,6 +383,7 @@ int launch_modulator(int argc, char* argv[]) #else auto inputZeroMQReader = make_shared<InputZeroMQReader>(); inputZeroMQReader->Open(mod_settings.inputName, mod_settings.inputMaxFramesQueued); + rcs.enrol(inputZeroMQReader.get()); inputReader = inputZeroMQReader; #endif } @@ -444,11 +445,13 @@ int launch_modulator(int argc, char* argv[]) } } #if defined(HAVE_ZEROMQ) - else if (dynamic_pointer_cast<InputZeroMQReader>(inputReader)) { + else if (auto in_zmq = dynamic_pointer_cast<InputZeroMQReader>(inputReader)) { run_again = true; // Create a new input reader + rcs.remove_controllable(in_zmq.get()); auto inputZeroMQReader = make_shared<InputZeroMQReader>(); inputZeroMQReader->Open(mod_settings.inputName, mod_settings.inputMaxFramesQueued); + rcs.enrol(inputZeroMQReader.get()); inputReader = inputZeroMQReader; } #endif |