commit 74bcd92c75961a2820a2f5231b573f55af563058
author Thomas Vachuska <tom@onlab.us> Tue Jun 02 13:08:57 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Tue Jun 02 20:17:57 2015 +0000
tree ed3a86fc2c61c63b71681e7c32ac35141aa53bcd
parent a98bf9395ec5e2a193daa966b914a86f8f5ab11c

Added STC shutdown scenario.

Change-Id: I48b882c872f69fdd84fe2fd057163e68ffb58012

providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java

diff --git a/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java b/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java
index 56d41ff..586365a 100644
--- a/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java
+++ b/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java
@@ -141,8 +141,8 @@
     public void deactivate() {
         providerRegistry.unregister(this);
         controller.removeListener(listener);
+        collectors.values().forEach(PortStatsCollector::stop);
         providerService = null;
-
         LOG.info("Stopped");
     }
 
@@ -165,6 +165,7 @@
         if (sw == null || !sw.isConnected()) {
             LOG.error("Failed to probe device {} on sw={}", deviceId, sw);
             providerService.deviceDisconnected(deviceId);
+            return;
         } else {
             LOG.trace("Confirmed device {} connection", deviceId);
         }