fix

hsyan2008 · Jun 18, 2021 · ff98b0a · ff98b0a
1 parent 62e410e
commit ff98b0a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/ssh/forward.go b/ssh/forward.go
@@ -59,9 +59,13 @@ func NewForward(httpCtx *hfw.HTTPContext, t ForwardType, sshConfig SSHConfig, fi
 		err = l.Bind(fi)
 		if err != nil {
 			l.c.Close()
+			return
 		}
+		l.httpCtx.Infof("Bind %s forward to %s success, start to accept", l.lister.Addr().String(), fi.Addr)
+		l.Accept()
 	} else {
 		l.c.Close()
+		return
 	}
 
 	return
@@ -90,10 +94,6 @@ func (l *Forward) Bind(fi *ForwardIni) (err error) {
 		} else if l.t == REMOTE {
 			l.lister, err = l.c.Listen(l.fi.Bind)
 		}
-		if err == nil {
-			l.httpCtx.Infof("Bind %s forward to %s success, start to accept", l.lister.Addr().String(), fi.Addr)
-			go l.Accept()
-		}
 	} else {
 		return errors.New("Err ForwardIni")
 	}