MD-SAL Statistics Manager - Implement request and notifications and minor modificatio...

[controller.git] / opendaylight / md-sal / statistics-manager / src / main / java / org / opendaylight / controller / md / statistics / manager / StatisticsProvider.java

diff --git a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java
index 5c02b6cea069b5266244189990f54e66cddff67f..5218d051fa2cdb40ec9fa47f58114abf5c334dc6 100644 (file)
--- a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java
+++ b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java
@@ -1,6 +1,12 @@
+/*
+ * Copyright IBM Corporation, 2013.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
 package org.opendaylight.controller.md.statistics.manager;
 
-import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
@@ -17,7 +23,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.
 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupFeaturesInputBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupFeaturesOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.OpendaylightGroupStatisticsService;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetAllMeterConfigStatisticsInputBuilder;
@@ -52,8 +58,8 @@ public class StatisticsProvider implements AutoCloseable {
     
     //Local caching of stats
     
-    private final ConcurrentMap<NodeRef,NodeStatistics> statisticsCache = 
-            new ConcurrentHashMap<NodeRef,NodeStatistics>();
+    private final ConcurrentMap<NodeId,NodeStatistics> statisticsCache = 
+            new ConcurrentHashMap<NodeId,NodeStatistics>();
     
     public DataProviderService getDataService() {
       return this.dps;
@@ -94,12 +100,13 @@ public class StatisticsProvider implements AutoCloseable {
             public void run() {
                 while(true){
                     try {
+                        spLogger.info("Statistics requester thread started with timer interval : {}",5000);
+                        
                         statsRequestSender();
                         
                         Thread.sleep(5000);
                     }catch (Exception e){
-                        spLogger.error("Exception occurred while sending stats request : {}",e.getMessage());
-                        e.printStackTrace();
+                        spLogger.error("Exception occurred while sending stats request : {}",e);
                     }
                 }
             }
@@ -116,93 +123,96 @@ public class StatisticsProvider implements AutoCloseable {
     private void statsRequestSender(){
         
         //Need to call API to receive all the nodes connected to controller.
-        
-        List<NodeRef> targetNodes = new ArrayList<NodeRef>();
-        
-        for (NodeRef targetNode : targetNodes){
-            
-            sendAllGroupStatisticsRequest(targetNode);
-            
-            sendAllMeterStatisticsRequest(targetNode);
+        List<Node> targetNodes = getAllConnectedNodes();
 
-            //We need to add check, so see if groups/meters are supported
-            //by the target node.
-            sendGroupDescriptionRequest(targetNode);
-            
-            sendGroupFeaturesRequest(targetNode);
-            
-            sendMeterConfigStatisticsRequest(targetNode);
+        for (Node targetNode : targetNodes){
+            spLogger.info("Send request for stats collection to node : {})",targetNode.getId());
             
-            sendMeterFeaturesRequest(targetNode);
+            //We need to add check, so see if groups/meters are supported
+            //by the target node. Below check doesn't look good.
+            if(targetNode.getId().getValue().contains("openflow:")){
+                sendAllGroupStatisticsRequest(targetNode);
+                
+                sendAllMeterStatisticsRequest(targetNode);
+                
+                sendGroupDescriptionRequest(targetNode);
+                
+                sendGroupFeaturesRequest(targetNode);
+                
+                sendMeterConfigStatisticsRequest(targetNode);
+                
+                sendMeterFeaturesRequest(targetNode);
+            }
         }
     }
     
-    private void sendAllGroupStatisticsRequest(NodeRef targetNode){
+    private void sendAllGroupStatisticsRequest(Node targetNode){
         
-        GetAllGroupStatisticsInputBuilder input = new GetAllGroupStatisticsInputBuilder();
+        final GetAllGroupStatisticsInputBuilder input = new GetAllGroupStatisticsInputBuilder();
         
-        input.setNode(targetNode);
+        input.setId(targetNode.getId());
 
         Future<RpcResult<GetAllGroupStatisticsOutput>> response = 
                 groupStatsService.getAllGroupStatistics(input.build());
     }
     
-    private void sendGroupDescriptionRequest(NodeRef targetNode){
-        GetGroupDescriptionInputBuilder input = new GetGroupDescriptionInputBuilder();
+    private void sendGroupDescriptionRequest(Node targetNode){
+        final GetGroupDescriptionInputBuilder input = new GetGroupDescriptionInputBuilder();
         
-        input.setNode(targetNode);
+        input.setId(targetNode.getId());
         
         Future<RpcResult<GetGroupDescriptionOutput>> response = 
                 groupStatsService.getGroupDescription(input.build());
     }
     
-    private void sendGroupFeaturesRequest(NodeRef targetNode){
+    private void sendGroupFeaturesRequest(Node targetNode){
         
         GetGroupFeaturesInputBuilder input = new GetGroupFeaturesInputBuilder();
         
-        input.setNode(targetNode);
+        input.setId(targetNode.getId());
         
         Future<RpcResult<GetGroupFeaturesOutput>> response = 
                 groupStatsService.getGroupFeatures(input.build());
     }
     
-    private void sendAllMeterStatisticsRequest(NodeRef targenetNode){
+    private void sendAllMeterStatisticsRequest(Node targetNode){
         
         GetAllMeterStatisticsInputBuilder input = new GetAllMeterStatisticsInputBuilder();
         
-        input.setNode(targenetNode);
+        input.setId(targetNode.getId());
         
         Future<RpcResult<GetAllMeterStatisticsOutput>> response = 
                 meterStatsService.getAllMeterStatistics(input.build());
     }
     
-    private void sendMeterConfigStatisticsRequest(NodeRef targetNode){
+    private void sendMeterConfigStatisticsRequest(Node targetNode){
         
         GetAllMeterConfigStatisticsInputBuilder input = new GetAllMeterConfigStatisticsInputBuilder();
         
-        input.setNode(targetNode);
+        input.setId(targetNode.getId());
         
         Future<RpcResult<GetAllMeterConfigStatisticsOutput>> response = 
                 meterStatsService.getAllMeterConfigStatistics(input.build());
         
     }
-    private void sendMeterFeaturesRequest(NodeRef targetNode){
+    private void sendMeterFeaturesRequest(Node targetNode){
      
         GetMeterFeaturesInputBuilder input = new GetMeterFeaturesInputBuilder();
         
-        input.setNode(targetNode);
+        input.setId(targetNode.getId());
         
         Future<RpcResult<GetMeterFeaturesOutput>> response = 
                 meterStatsService.getMeterFeatures(input.build());
     }
     
-    public ConcurrentMap<NodeRef, NodeStatistics> getStatisticsCache() {
+    public ConcurrentMap<NodeId, NodeStatistics> getStatisticsCache() {
         return statisticsCache;
     }
     
     private List<Node> getAllConnectedNodes(){
         
         Nodes nodes = (Nodes) dps.readOperationalData(nodesIdentifier);
+        spLogger.info("Number of connected nodes : {}",nodes.getNode().size());
         return nodes.getNode();
     }