apps/kubevpn
1
0
Fork 0
mirror of https://github.com/kubenetworks/kubevpn.git synced 2025-10-16 20:30:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: single connection broken will not redo port-forward

Browse Source
This commit is contained in:
fengcaiwen
2023-08-14 19:23:31 +08:00
committed by naison
parent ff2fcf939f
commit b0e2e0e2b9
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/handler/connect.go
View File

@@ -212,8 +212,10 @@ func (c *ConnectOptions) portForward(ctx context.Context, portPair string) error
podName := podList[0].GetName() podName := podList[0].GetName()
// if port-forward occurs error, check pod is deleted or not, speed up fail // if port-forward occurs error, check pod is deleted or not, speed up fail
runtime.ErrorHandlers = []func(error){func(err error) { runtime.ErrorHandlers = []func(error){func(err error) {
if !strings.Contains(err.Error(), "an error occurred forwarding") {
log.Debugf("port-forward occurs error, err: %v, retrying", err) log.Debugf("port-forward occurs error, err: %v, retrying", err)
cancelFunc() cancelFunc()
}
}} }}
// try to detect pod is delete event, if pod is deleted, needs to redo port-forward // try to detect pod is delete event, if pod is deleted, needs to redo port-forward
go checkPodStatus(childCtx, cancelFunc, podName, podInterface) go checkPodStatus(childCtx, cancelFunc, podName, podInterface)