fix getting service backends in dual-stack clusters (#2323)

kubeovn · Feb 13, 2023 · fe42367 · fe42367
1 parent 33e6e41
commit fe42367
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/controller/endpoint.go b/pkg/controller/endpoint.go
@@ -237,7 +237,9 @@ func getServicePortBackends(endpoints *v1.Endpoints, pods []*v1.Pod, servicePort
 
 		for _, address := range subset.Addresses {
 			if address.TargetRef == nil || address.TargetRef.Kind != "Pod" {
-				backends = append(backends, util.JoinHostPort(address.IP, targetPort))
+				if util.CheckProtocol(address.IP) == protocol {
+					backends = append(backends, util.JoinHostPort(address.IP, targetPort))
+				}
 				continue
 			}
 
@@ -257,7 +259,7 @@ func getServicePortBackends(endpoints *v1.Endpoints, pods []*v1.Pod, servicePort
 					break
 				}
 			}
-			if ip == "" {
+			if ip == "" && util.CheckProtocol(address.IP) == protocol {
 				ip = address.IP
 			}
 			if ip != "" {