commit | d89db46e2fac6243bedd59565f8124da82038db5 | [log] [tgz] |
---|---|---|
author | Jian Li <pyguni@gmail.com> | Fri Feb 08 18:21:57 2019 +0900 |
committer | Jian Li <pyguni@gmail.com> | Wed Mar 06 05:28:38 2019 +0000 |
tree | e4b69aa2758ff0b42718465a50bc3b6c8f7244a5 | |
parent | 4aa1764d35718368ea53ebb31560718dc7c6fe58 [diff] [blame] |
Add Kubernetes API server invocation proxy handler Change-Id: Iadcbe4c2969e36e1f7bf10caff4926c5662d0df6
diff --git a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sSwitchingArpHandler.java b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sSwitchingArpHandler.java index 90ad174..1bf2150 100644 --- a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sSwitchingArpHandler.java +++ b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sSwitchingArpHandler.java
@@ -90,6 +90,8 @@ private final Logger log = LoggerFactory.getLogger(getClass()); + private static final String API_SERVER_CLUSTER_IP = "10.96.0.1"; + @Reference(cardinality = ReferenceCardinality.MANDATORY) protected CoreService coreService; @@ -212,7 +214,7 @@ .filter(n -> n.gatewayIp().equals(targetIp)) .count(); - if (gwIpCnt > 0) { + if (gwIpCnt > 0 || targetIp.equals(IpAddress.valueOf(API_SERVER_CLUSTER_IP))) { replyMac = gwMacAddress; }