commit | 55511c47648f45fffc5d38561b27bfaf0389c8d3 | [log] [tgz] |
---|---|---|
author | Jian Li <pyguni@gmail.com> | Fri Sep 04 16:34:49 2020 +0900 |
committer | Jian Li <pyguni@gmail.com> | Sat Sep 05 04:45:37 2020 +0000 |
tree | 63505e737521419e09b99d8831d29a4c561970e7 | |
parent | b1218443984d0c7f7cad902716611c2f9c38618d [diff] |
Fix: only receive host events initiated by openstack provider Change-Id: I14803c6d668547bb498a18bc855b40d6c0e7ac02
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