distinguish nat ip for central subnet with ecmp and active-standby (#…

…3100)
kubeovn · Aug 3, 2023 · 42e0574 · 42e0574
1 parent a27ce4c
commit 42e0574
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/daemon/gateway.go b/pkg/daemon/gateway.go
@@ -239,7 +239,11 @@ func (c *Controller) getEgressNatIpByNode(nodeName string) (map[string]string, e
 		for _, cidr := range strings.Split(subnet.Spec.CIDRBlock, ",") {
 			for _, gw := range strings.Split(subnet.Spec.GatewayNode, ",") {
 				if strings.Contains(gw, ":") && util.GatewayContains(gw, nodeName) && util.CheckProtocol(cidr) == util.CheckProtocol(strings.Split(gw, ":")[1]) {
-					subnetsNatIp[cidr] = strings.TrimSpace(strings.Split(gw, ":")[1])
+					if subnet.Spec.EnableEcmp {
+						subnetsNatIp[cidr] = strings.TrimSpace(strings.Split(gw, ":")[1])
+					} else if subnet.Status.ActivateGateway == nodeName {
+						subnetsNatIp[cidr] = strings.TrimSpace(strings.Split(gw, ":")[1])
+					}
 					break
 				}
 			}