From 20e7c628347ec0e4a6469b53b98b5309c74a47f0 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Sat, 2 Oct 2021 18:13:24 +0200
Subject: Common ba7f317: Improve EDI TCP receive

---
 lib/Socket.cpp | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'lib/Socket.cpp')

diff --git a/lib/Socket.cpp b/lib/Socket.cpp
index c876f32..7ff6b5e 100644
--- a/lib/Socket.cpp
+++ b/lib/Socket.cpp
@@ -936,10 +936,12 @@ void TCPReceiveServer::process()
                 sock.close();
                 // TODO replace fprintf
                 fprintf(stderr, "TCP Receiver restarted after error: %s\n", e.what());
+                m_queue.push(make_shared<TCPReceiveMessageDisconnected>());
             }
 
             if (num_timeouts > max_num_timeouts) {
                 sock.close();
+                m_queue.push(make_shared<TCPReceiveMessageDisconnected>());
             }
         }
     }
-- 
cgit v1.2.3