start ssh forward only once (#49)

annetutil · Apr 10, 2024 · 10697ff · 10697ff
1 parent 9df4b87
commit 10697ff
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/streamer/ssh/ssh.go b/pkg/streamer/ssh/ssh.go
@@ -686,6 +686,9 @@ func (m *Streamer) WithCloseSessionCallback(fn func(*ssh.Session) error) {
 }
 
 func (m *Streamer) startForwarding(sess *ssh.Session) error {
+	if m.forwardAgent != nil {
+		return nil
+	}
 	keyring := agent.NewKeyring()
 
 	privKeysRaw := m.credentials.GetPrivateKeys()