修复(DedicatedCLBListener): pod已被绑定但状态不是bound时修复下状态

imroc · imroc · commit fa35837dde3d · 2024-08-21T15:54:29.000+08:00
diff --git a/internal/controller/dedicatedclblistener_controller.go b/internal/controller/dedicatedclblistener_controller.go
@@ -327,7 +327,11 @@ func (r *DedicatedCLBListenerReconciler) ensureBackendPod(ctx context.Context, l
 		}
 	}
 	if !needAdd {
-		log.V(6).Info("backend pod already registered", "podIP", pod.Status.PodIP)
+		if lis.Status.State != networkingv1alpha1.DedicatedCLBListenerStateBound { // pod 已被绑定但状态不是bound，更新下状态
+			if err := r.changeState(ctx, lis, networkingv1alpha1.DedicatedCLBListenerStateBound); err != nil {
+				return err
+			}
+		}
 		return nil
 	}
 	r.Recorder.Event(

Original file line number	Diff line number	Diff line change
`@@ -327,7 +327,11 @@ func (r *DedicatedCLBListenerReconciler) ensureBackendPod(ctx context.Context, l`
`327`	`327`	`}`
`328`	`328`	`}`
`329`	`329`	`if !needAdd {`
`330`		`- log.V(6).Info("backend pod already registered", "podIP", pod.Status.PodIP)`
	`330`	`+ if lis.Status.State != networkingv1alpha1.DedicatedCLBListenerStateBound { // pod 已被绑定但状态不是bound，更新下状态`
	`331`	`+ if err := r.changeState(ctx, lis, networkingv1alpha1.DedicatedCLBListenerStateBound); err != nil {`
	`332`	`+ return err`
	`333`	`+ }`
	`334`	`+ }`
`331`	`335`	`return nil`
`332`	`336`	`}`
`333`	`337`	`r.Recorder.Event(`