diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2021-11-15 16:16:35 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2021-11-15 16:16:35 +0100 |
| commit | 1897c5abaf8837002bda6d618d38627a878e996f (patch) | |
| tree | d29a12f7677aac87564c0c557c2aed479e219323 | |
| parent | 2b368315f9a63e54aa6bda20390c53b2d9bd3069 (diff) | |
| download | ODR-SourceCompanion-1897c5abaf8837002bda6d618d38627a878e996f.tar.gz ODR-SourceCompanion-1897c5abaf8837002bda6d618d38627a878e996f.tar.bz2 ODR-SourceCompanion-1897c5abaf8837002bda6d618d38627a878e996f.zip | |
Common ba7f317
| -rw-r--r-- | lib/Socket.cpp | 2 |
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>()); } } } |