diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2021-10-02 18:13:24 +0200 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2021-10-02 18:13:24 +0200 |
| commit | 20e7c628347ec0e4a6469b53b98b5309c74a47f0 (patch) | |
| tree | 3ee868b8535029ba055801954aec2ec2b22c3ea3 /lib/Socket.cpp | |
| parent | 37b60a6aab4abb47bb052db6fb1b49fe277e4bdc (diff) | |
| download | dabmux-20e7c628347ec0e4a6469b53b98b5309c74a47f0.tar.gz dabmux-20e7c628347ec0e4a6469b53b98b5309c74a47f0.tar.bz2 dabmux-20e7c628347ec0e4a6469b53b98b5309c74a47f0.zip | |
Common ba7f317: Improve EDI TCP receive
Diffstat (limited to 'lib/Socket.cpp')
| -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>()); } } } |