From 0bdd2960707a8abb5d9e435d1313aec4cf264ab1 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Tue, 6 Mar 2018 09:31:43 +0100
Subject: Implement TCP input auto-reconnect

---
 src/DabMod.cpp | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'src/DabMod.cpp')

diff --git a/src/DabMod.cpp b/src/DabMod.cpp
index 90751f6..80dc6b4 100644
--- a/src/DabMod.cpp
+++ b/src/DabMod.cpp
@@ -528,8 +528,12 @@ static run_modulator_state_t run_modulator(modulator_data& m)
                      */
                 }
 #endif // defined(HAVE_ZEROMQ)
-                // No need to handle the TCP input in a special way to get SIGINT working,
-                // because recv() will return with EINTR.
+                else if (dynamic_pointer_cast<InputTcpReader>(m.inputReader)) {
+                    /* Same as for ZeroMQ */
+                }
+                else {
+                    throw logic_error("Unhandled framesize==0!");
+                }
             }
             else {
                 etiLog.level(error) << "Input read error.";
-- 
cgit v1.2.3