diff --git a/internal/nodes/client_conn.go b/internal/nodes/client_conn.go index 9916aac..288aaea 100644 --- a/internal/nodes/client_conn.go +++ b/internal/nodes/client_conn.go @@ -150,6 +150,8 @@ func (this *ClientConn) Write(b []byte) (n int, err error) { if ok { _ = conn.SetLinger(0) } + + _ = this.rawConn.Close() } return