commit e23cd861cbfc2df22957ab4fede22a502e42ecd7
author pier <pier@opennetworking.org> Wed Mar 04 14:36:41 2020 +0100
committer pier <pier@opennetworking.org> Thu Mar 26 22:05:41 2020 +0100
tree daead789c45ad2f668afb1ad8b1b507ce446f42f
parent 9e02ab7abd420d08828f5f770a788506541e5f0d

Fixes invalidate nextid

Change-Id: I475899566fcd2a51dd7d0e672ede6e65e25c8f78

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

diff --git a/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java b/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
index e46c1d8..8c4968a 100644
--- a/app/src/main/java/org/onosproject/segmentrouting/mcast/McastHandler.java
+++ b/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);