Close outside Serve(c)

proxy/socks5/server.go

@@ -185,7 +185,6 @@ func (self *Server) handleConnect(c net.Conn, req Request) error {
 }
 
 func (self *Server) Serve(c net.Conn) error {
-	defer c.Close()
 	if err := self.exchangeMetadata(c); err != nil {
 		return err
 	}

relayer/intrinsic.go

@@ -137,6 +137,7 @@ func (self *IntrinsicRelayer) ServeAsLocalRelayer(c net.Conn) {
 		UDPAddr: self.udpAddr,
 		Dial:    context.Dial,
 	}
+	defer c.Close()
 	s.Serve(c)
 }
 

relayer/socks5.go

@@ -60,6 +60,7 @@ func (self *SocksRelayer) ServeAsEndRelayer(red net.Conn) {
 		core.RunSimpleSwitch(core.NewPort(red, CreateProtocol(self.RelayProtocol)),
 			core.NewPort(blue[0], nil))
 	}()
+	defer blue[1].Close()
 	server := &socks5.Server{}
 	server.Serve(blue[1])
 }

s5/main.go

@@ -61,6 +61,7 @@ func main() {
 			return
 		}
 		go func(c net.Conn) {
+			defer c.Close()
 			s := socks5.Server{
 				UDPAddr: udpAddr,
 			}