From 79f474920af304273577882e19acdf21ac24a2cf Mon Sep 17 00:00:00 2001 From: Boshi LIAN Date: Tue, 20 Aug 2019 17:44:37 -0700 Subject: [PATCH] prevent var from being overwritten --- sshpiperd/sshpiperd.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/sshpiperd/sshpiperd.go b/sshpiperd/sshpiperd.go index 04425f2a..b906de00 100644 --- a/sshpiperd/sshpiperd.go +++ b/sshpiperd/sshpiperd.go @@ -172,14 +172,15 @@ func startPiper(config *piperdConfig, logger *log.Logger) error { logger.Printf("sshpiperd started") for { - c, err := listener.Accept() + conn, err := listener.Accept() if err != nil { logger.Printf("failed to accept connection: %v", err) continue } - logger.Printf("connection accepted: %v", c.RemoteAddr()) - go func() { + logger.Printf("connection accepted: %v", conn.RemoteAddr()) + + go func(c net.Conn) { p, err := ssh.NewSSHPiperConn(c, piper) if err != nil { @@ -201,6 +202,6 @@ func startPiper(config *piperdConfig, logger *log.Logger) error { err = p.Wait() logger.Printf("connection from %v closed reason: %v", c.RemoteAddr(), err) - }() + }(conn) } }