X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=applications%2Fforwardingrules-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fapplications%2Ffrm%2Fimpl%2FDeviceMastershipManager.java;h=ede9d4845b1462eeefa4427f50cc2d1f84768692;hb=refs%2Fchanges%2F97%2F82297%2F29;hp=4194a540239fc9c6a47fd230335d4ef3b2b73ea6;hpb=6b6281680872611d795261dbf232c0131235bd51;p=openflowplugin.git diff --git a/applications/forwardingrules-manager/src/main/java/org/opendaylight/openflowplugin/applications/frm/impl/DeviceMastershipManager.java b/applications/forwardingrules-manager/src/main/java/org/opendaylight/openflowplugin/applications/frm/impl/DeviceMastershipManager.java index 4194a54023..ede9d4845b 100644 --- a/applications/forwardingrules-manager/src/main/java/org/opendaylight/openflowplugin/applications/frm/impl/DeviceMastershipManager.java +++ b/applications/forwardingrules-manager/src/main/java/org/opendaylight/openflowplugin/applications/frm/impl/DeviceMastershipManager.java @@ -134,6 +134,7 @@ public class DeviceMastershipManager implements ClusteredDataTreeChangeListener< if (activeNodes.contains(nodeIdent)) { Set> set = Sets.newHashSet(activeNodes); set.remove(nodeIdent); + reconcliationAgent.flowNodeDisconnected(nodeIdent); activeNodes = Collections.unmodifiableSet(set); setNodeOperationalStatus(nodeIdent, false); }