commit 849e1bbdb98f6b6c0ab633ca8b7f206ca42362fe
author pier <pier@opennetworking.org> Wed Mar 04 14:36:41 2020 +0100
committer pier <pier@opennetworking.org> Thu Mar 26 22:10:06 2020 +0100
tree 425e50322477e644cc1fcda75cbb0d37238f1b0d
parent ec6f9294d40d5e18da319655347aadf1f593b309

Fixes invalidate nextid

Change-Id: I475899566fcd2a51dd7d0e672ede6e65e25c8f78

apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java

diff --git a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
index e46c1d8..8c4968a 100644
--- a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
+++ b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
@@ -1240,7 +1240,8 @@
                 (objective, error) -> {
                     log.warn("Failed to add {} on {}/{}, vlan {}: {}",
                             mcastIp, deviceId, port.toLong(), assignedVlan, error);
-                    srManager.invalidateNextObj(objective.id());
+                    // Schedule the removal using directly the key
+                    mcastWorker.execute(() -> mcastNextObjStore.remove(mcastStoreKey));
                 });
             ForwardingObjective fwdObj = mcastUtils.fwdObjBuilder(mcastIp, assignedVlan,
                                                           newNextObj.id()).add(context);