commit b73a95a24682de1eceb94abaf518fef623321f76
author Jian Li <pyguni@gmail.com> Fri Sep 04 16:34:49 2020 +0900
committer Jian Li <pyguni@gmail.com> Fri Sep 04 16:35:33 2020 +0900
tree 930597f3793318aa183cfaf32f8e9bdd07e36ba1
parent c2242bdafa6145e76241f81cb8396291b331f925

Fix: only receive host events initiated by openstack provider

Change-Id: I14803c6d668547bb498a18bc855b40d6c0e7ac02

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

diff --git a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/InstancePortManager.java b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/InstancePortManager.java
index ba90b7e..4e1d1b8 100644
--- a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/InstancePortManager.java
+++ b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/InstancePortManager.java
@@ -80,6 +80,7 @@
 
     protected final Logger log = getLogger(getClass());
 
+    private static final String OPENSTACK_PROVIDER = "sona:org.onosproject.openstacknetworking";
     private static final String MSG_INSTANCE_PORT = "Instance port %s %s";
     private static final String MSG_CREATED = "created";
     private static final String MSG_UPDATED = "updated";
@@ -302,9 +303,12 @@
                 return false;
             }
 
+            boolean isProvider =
+                    OPENSTACK_PROVIDER.equals(event.subject().providerId().id());
+
             // do not allow to proceed without leadership
             NodeId leader = leadershipService.getLeader(appId.name());
-            return Objects.equals(localNodeId, leader);
+            return Objects.equals(localNodeId, leader) && isProvider;
         }
 
         @Override