X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fstatisticsmanager%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fstatisticsmanager%2Finternal%2FStatisticsManager.java;h=5cd47f2f20a48cbf75774055267d0f2f90f6b751;hb=94d0d20b41d64bb6696c2a573ec367fcfddc44e9;hp=92ed44efbbde51e80046048f3d4afe9e1a4de56f;hpb=6e9d5f469bf492778360a7400861e1d839737f87;p=controller.git

diff --git a/opendaylight/statisticsmanager/implementation/src/main/java/org/opendaylight/controller/statisticsmanager/internal/StatisticsManager.java b/opendaylight/statisticsmanager/implementation/src/main/java/org/opendaylight/controller/statisticsmanager/internal/StatisticsManager.java
index 92ed44efbb..5cd47f2f20 100644
--- a/opendaylight/statisticsmanager/implementation/src/main/java/org/opendaylight/controller/statisticsmanager/internal/StatisticsManager.java
+++ b/opendaylight/statisticsmanager/implementation/src/main/java/org/opendaylight/controller/statisticsmanager/internal/StatisticsManager.java
@@ -101,7 +101,6 @@ public class StatisticsManager implements IStatisticsManager, IReadServiceListen
         triggers = new ConcurrentHashMap<Integer, Node>();
     }
 
-    @SuppressWarnings("deprecation")
     private void allocateCaches() {
         if (clusterContainerService == null) {
             nonClusterObjectCreate();
@@ -126,7 +125,7 @@ public class StatisticsManager implements IStatisticsManager, IReadServiceListen
             log.debug("Skipping statistics cache creation - already present");
         }
     }
-    @SuppressWarnings({ "unchecked", "deprecation" })
+    @SuppressWarnings({ "unchecked" })
     private void retrieveCaches() {
         ConcurrentMap<?, ?> map;
 
@@ -426,7 +425,7 @@ public class StatisticsManager implements IStatisticsManager, IReadServiceListen
     @Override
     public List<NodeConnectorStatistics> getNodeConnectorStatistics(Node node) {
         if (node == null){
-            return null;
+            return Collections.emptyList();
         }
 
         List<NodeConnectorStatistics> statList = new ArrayList<NodeConnectorStatistics>();
@@ -456,7 +455,7 @@ public class StatisticsManager implements IStatisticsManager, IReadServiceListen
     @Override
     public List<NodeTableStatistics> getNodeTableStatistics(Node node){
         if (node == null){
-            return null;
+            return Collections.emptyList();
         }
         List<NodeTableStatistics> statList = new ArrayList<NodeTableStatistics>();
         List<NodeTableStatistics> cachedList = tableStatistics.get(node);
@@ -468,11 +467,8 @@ public class StatisticsManager implements IStatisticsManager, IReadServiceListen
 
     @Override
     public void nodeFlowStatisticsUpdated(Node node, List<FlowOnNode> flowStatsList) {
-        List<FlowOnNode> currentStat = this.flowStatistics.get(node);
-        // Update cache only if changed to avoid unnecessary cache sync operations
-        if (! flowStatsList.equals(currentStat)){
-            this.flowStatistics.put(node, flowStatsList);
-        }
+        // No equality check because duration fields change constantly
+        this.flowStatistics.put(node, flowStatsList);
     }
 
     @Override