X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fforwardingrulesmanager%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fforwardingrulesmanager%2Finternal%2FForwardingRulesManager.java;h=cade2666883c66b4f8ca3e838b9b60524903ce88;hp=eea28364ac9cc4e5db00c76a67dee5e9873a918c;hb=e72ae0ab1513e382e141f70dc544efdd782e439d;hpb=ae4ac1b0039b308777c5907c01e22824b34f5413 diff --git a/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java b/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java index eea28364ac..cade266688 100644 --- a/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java +++ b/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java @@ -897,10 +897,11 @@ public class ForwardingRulesManager implements IForwardingRulesManager, PortGrou log.warn(logMsg, groupName); return new Status(StatusCode.NOTACCEPTABLE, msg); } - int toBeRemoved = groupFlows.get(groupName).size(); + int toBeRemoved = 0; String error = ""; if (groupFlows.containsKey(groupName)) { List list = new ArrayList(groupFlows.get(groupName)); + toBeRemoved = list.size(); for (FlowEntryInstall entry : list) { Status status = this.removeEntry(entry.getOriginal(), false); if (status.isSuccess()) { @@ -1914,7 +1915,7 @@ public class ForwardingRulesManager implements IForwardingRulesManager, PortGrou log.info("Forwarding mode for node {} set to {}", node, (proactive ? "proactive" : "reactive")); for (FlowConfig fc : defaultConfigs) { - Status status = (proactive) ? addStaticFlowInternal(fc, true) : removeStaticFlow(fc); + Status status = (proactive) ? addStaticFlowInternal(fc, false) : removeStaticFlow(fc); if (status.isSuccess()) { log.info("{} Proactive Static flow: {}", (proactive ? "Installed" : "Removed"), fc.getName()); } else {