Handle modulator restart with file input

1 files changed, 13 insertions, 5 deletions

diff --git a/src/DabMod.cpp b/src/DabMod.cpp
index 01125b2..3ed5e40 100644
--- a/src/DabMod.cpp
+++ b/src/DabMod.cpp
@@ -783,20 +783,28 @@ int launch_modulator(int argc, char* argv[])
                 run_again = false;
                 ret = 1;
                 break;
-#if defined(HAVE_ZEROMQ)
             case MOD_AGAIN:
                 etiLog.level(warn) << "Restart modulator.";
-                running = true;
-                if (inputTransport == "zeromq") {
+                run_again = false;
+                if (inputTransport == "file") {
+                    if (inputFileReader.Open(inputName, loop) == -1) {
+                        etiLog.level(error) << "Unable to open input file!";
+                        ret = 1;
+                    }
+                    else {
+                        run_again = true;
+                    }
+                }
+                else if (inputTransport == "zeromq") {
+#if defined(HAVE_ZEROMQ)
                     run_again = true;
-
                     // Create a new input reader
                     inputZeroMQReader = make_shared<InputZeroMQReader>();
                     inputZeroMQReader->Open(inputName, inputMaxFramesQueued);
                     m.inputReader = inputZeroMQReader.get();
+#endif
                 }
                 break;
-#endif
             case MOD_NORMAL_END:
             default:
                 etiLog.level(info) << "modulator stopped.";