From ab56227709e999fe2d585d861a01185a192d7fff Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Mon, 15 Nov 2021 16:16:07 +0100
Subject: Common ba7f317

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

diff --git a/contrib/Socket.cpp b/contrib/Socket.cpp
index c876f32..7ff6b5e 100644
--- a/contrib/Socket.cpp
+++ b/contrib/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