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

---
 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