diff options
| author | 1992414357@qq.com <1992414357@qq.com> | 2025-06-09 17:17:39 +0800 |
|---|---|---|
| committer | 1992414357@qq.com <1992414357@qq.com> | 2025-06-09 17:17:39 +0800 |
| commit | e5cbc548a7d8ba62a76421057d6b281a9277646f (patch) | |
| tree | 0b82088c52c1adb1d3e8fc3d33e045f494b73706 /core/src/service | |
| parent | 0d8761e5f907d173c40a2a44f3a1d8d8ce5a2f6e (diff) | |
.
Diffstat (limited to 'core/src/service')
| -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; } } |