stopping forwarder when remote dialer is closed

rancher · Jan 28, 2025 · 57577ba · 57577ba
1 parent 7550820
commit 57577ba
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/proxyclient/client.go b/proxyclient/client.go
@@ -148,6 +148,7 @@ func (c *ProxyClient) Run(ctx context.Context) {
 
 				if err := remotedialer.ClientConnect(ctx, c.serverUrl, headers, c.dialer, onConnectAuth, onConnect); err != nil {
 					logrus.Errorf("remotedialer.ClientConnect error: %s", err.Error())
+					c.forwarder.Stop()
 					time.Sleep(retryTimeout)
 				}
 			}