diff options
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/service/tcp_network/long_connection.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/core/src/service/tcp_network/long_connection.rs b/core/src/service/tcp_network/long_connection.rs index a08fc6d..1bac6a2 100644 --- a/core/src/service/tcp_network/long_connection.rs +++ b/core/src/service/tcp_network/long_connection.rs @@ -211,6 +211,9 @@ impl PadClientNetwork { } Err(err) => { error!("[TCP Client] [Runtime] Reader encountered an error: {}", err); + entry_mutex!(self.runtime, |guard| { + guard.send(ControlMessage::End, 0, TCPConnection); + }); break; } } |