aboutsummaryrefslogtreecommitdiffstats
path: root/lib/Socket.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Socket.cpp')
-rw-r--r--lib/Socket.cpp2
1 files changed, 2 insertions, 0 deletions
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>());
}
}
}