diff --git a/internal/nodes/client_conn.go b/internal/nodes/client_conn.go index d35d723..7fe09cf 100644 --- a/internal/nodes/client_conn.go +++ b/internal/nodes/client_conn.go @@ -119,7 +119,7 @@ func (this *ClientConn) Read(b []byte) (n int, err error) { // 关闭连接 if err == io.EOF { - _ = this.rawConn.Close() + _ = this.Close() } return @@ -167,7 +167,7 @@ func (this *ClientConn) Write(b []byte) (n int, err error) { _ = conn.SetLinger(0) } - _ = this.rawConn.Close() + _ = this.Close() } return