commit 4ac9f9b8a4ef5eaa4720c1b43862c243ff722b56
author Jian Li <pyguni@gmail.com> Mon May 18 17:48:48 2020 +0900
committer Jian Li <pyguni@gmail.com> Mon May 18 18:41:18 2020 +0900
tree fd1a88aa2d61edcf61acd0475c3b8f7f653839ca
parent 5908b5642a41e5755adcf7ec10f3d4f2c0ea2657

Fix: only reply ARP request from external router

Change-Id: Ieed4f49c0ae607d2318ab6cfafea19d62a87c344

apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java

diff --git a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
index 6e9d71b..5b5e8a7 100644
--- a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
+++ b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackRoutingFloatingIpHandler.java
@@ -507,15 +507,17 @@
                 GW_COMMON_TABLE,
                 install);
 
-        setArpRule(floatingIp, instPort.macAddress(), selectedGatewayNode, install);
+        setArpRule(floatingIp, instPort.macAddress(), externalPeerRouter, selectedGatewayNode, install);
     }
 
     private void setArpRule(NetFloatingIP floatingIp, MacAddress targetMac,
+                            ExternalPeerRouter externalPeerRouter,
                             OpenstackNode gateway, boolean install) {
-        if (ARP_BROADCAST_MODE.equals(getArpMode())) {
+        if (ARP_BROADCAST_MODE.equals(getArpMode()) && externalPeerRouter.ipAddress() != null) {
             TrafficSelector selector = DefaultTrafficSelector.builder()
                     .matchInPort(gateway.uplinkPortNum())
                     .matchEthType(EthType.EtherType.ARP.ethType().toShort())
+                    .matchArpSpa(Ip4Address.valueOf(externalPeerRouter.ipAddress().toString()))
                     .matchArpOp(ARP.OP_REQUEST)
                     .matchArpTpa(Ip4Address.valueOf(floatingIp.getFloatingIpAddress()))
                     .build();