diff --git a/pkg/relay/relay.go b/pkg/relay/relay.go index ded126c..ba168b0 100644 --- a/pkg/relay/relay.go +++ b/pkg/relay/relay.go @@ -48,7 +48,7 @@ func (r *Relay) ListenAndServe() error { if err != nil { return err } - go func(c *net.TCPConn) { + go func() { defer c.Close() r.ConnFunc(c.RemoteAddr()) rc, err := r.HyClient.DialTCP(r.Remote) @@ -59,6 +59,6 @@ func (r *Relay) ListenAndServe() error { defer rc.Close() err = utils.PipePairWithTimeout(c, rc, r.Timeout) r.ErrorFunc(c.RemoteAddr(), err) - }(c) + }() } } diff --git a/pkg/socks5/server.go b/pkg/socks5/server.go index 6b8925f..202c903 100644 --- a/pkg/socks5/server.go +++ b/pkg/socks5/server.go @@ -124,7 +124,7 @@ func (s *Server) ListenAndServe() error { if err != nil { return err } - go func(c *net.TCPConn) { + go func() { defer c.Close() if s.TCPTimeout != 0 { if err := c.SetDeadline(time.Now().Add(s.TCPTimeout)); err != nil { @@ -139,7 +139,7 @@ func (s *Server) ListenAndServe() error { return } _ = s.handle(c, r) - }(c) + }() } }