commit d8b6849254925e372a274a739331692648213493
author Jonathan Hart <jono@onlab.us> Thu May 25 15:46:23 2017 -0700
committer Jonathan Hart <jono@onlab.us> Thu Jun 01 21:11:42 2017 +0000
tree ae3f609bccfef7b24234d901d873f6709dbcfe06
parent 948ac4bbb8d713ad63fecc00582727e4021a62d9

Clear peers map on FPM app deactivation

Change-Id: I18be5a599b91dbb6375d27aa6fe4120fffd93ae4

apps/routing/fpm/src/main/java/org/onosproject/routing/fpm/FpmManager.java

diff --git a/apps/routing/fpm/src/main/java/org/onosproject/routing/fpm/FpmManager.java b/apps/routing/fpm/src/main/java/org/onosproject/routing/fpm/FpmManager.java
index 4f7e488..cd1ed78 100644
--- a/apps/routing/fpm/src/main/java/org/onosproject/routing/fpm/FpmManager.java
+++ b/apps/routing/fpm/src/main/java/org/onosproject/routing/fpm/FpmManager.java
@@ -42,6 +42,7 @@
 import org.onosproject.cfg.ComponentConfigService;
 import org.onosproject.cluster.ClusterService;
 import org.onosproject.cluster.NodeId;
+import org.onosproject.core.CoreService;
 import org.onosproject.incubator.net.routing.Route;
 import org.onosproject.incubator.net.routing.RouteAdminService;
 import org.onosproject.routing.fpm.protocol.FpmHeader;
@@ -81,6 +82,10 @@
     private final Logger log = LoggerFactory.getLogger(getClass());
 
     private static final int FPM_PORT = 2620;
+    private static final String APP_NAME = "org.onosproject.fpm";
+
+    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+    protected CoreService coreService;
 
     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
     protected ComponentConfigService componentConfigService;
@@ -126,6 +131,9 @@
 
         modified(context);
         startServer();
+
+        coreService.registerApplication(APP_NAME, peers::destroy);
+
         log.info("Started");
     }
 
@@ -326,6 +334,10 @@
             }
 
             peers.compute(peer, (p, infos) -> {
+                if (infos == null) {
+                    return null;
+                }
+
                 infos.stream()
                         .filter(i -> i.connectedTo().equals(clusterService.getLocalNode().id()))
                         .findAny()