opendaylight/statisticsmanager/src/main/java/org/opendaylight/controller/statisticsmanager/StatisticsManager.java

   1
   2 /*
   3  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
   4  *
   5  * This program and the accompanying materials are made available under the
   6  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   7  * and is available at http://www.eclipse.org/legal/epl-v10.html
   8  */
   9
  10 package org.opendaylight.controller.statisticsmanager;
  11
  12 import java.util.ArrayList;
  13 import java.util.HashMap;
  14 import java.util.List;
  15 import java.util.Map;
  16
  17 import org.opendaylight.controller.forwardingrulesmanager.FlowEntry;
  18 import org.opendaylight.controller.sal.core.Node;
  19 import org.opendaylight.controller.sal.core.NodeConnector;
  20 import org.opendaylight.controller.sal.flowprogrammer.Flow;
  21 import org.opendaylight.controller.sal.reader.FlowOnNode;
  22 import org.opendaylight.controller.sal.reader.IReadService;
  23 import org.opendaylight.controller.sal.reader.NodeConnectorStatistics;
  24 import org.opendaylight.controller.sal.reader.NodeDescription;
  25 import org.slf4j.Logger;
  26 import org.slf4j.LoggerFactory;
  27
  28 /**
  29  * The class which implements the methods for retrieving
  30  * the network nodes statistics.
  31  */
  32 public class StatisticsManager implements IStatisticsManager {
  33     private static final Logger log = LoggerFactory
  34             .getLogger(StatisticsManager.class);
  35     private IReadService reader;
  36
  37     public StatisticsManager() {
  38
  39     }
  40
  41     /**
  42      * Function called by the dependency manager when all the required
  43      * dependencies are satisfied
  44      *
  45      */
  46     void init() {
  47         log.debug("INIT called!");
  48     }
  49
  50     /**
  51      * Function called by the dependency manager when at least one
  52      * dependency become unsatisfied or when the component is shutting
  53      * down because for example bundle is being stopped.
  54      *
  55      */
  56     void destroy() {
  57         log.debug("DESTROY called!");
  58     }
  59
  60     /**
  61      * Function called by dependency manager after "init ()" is called
  62      * and after the services provided by the class are registered in
  63      * the service registry
  64      *
  65      */
  66     void start() {
  67         log.debug("START called!");
  68     }
  69
  70     /**
  71      * Function called by the dependency manager before the services
  72      * exported by the component are unregistered, this will be
  73      * followed by a "destroy ()" calls
  74      *
  75      */
  76     void stop() {
  77         log.debug("STOP called!");
  78     }
  79
  80     public void setReaderService(IReadService service) {
  81         log.debug("Got inventory service set request {}", service);
  82         this.reader = service;
  83     }
  84
  85     public void unsetReaderService(IReadService service) {
  86         log.debug("Got a service UNset request");
  87         this.reader = null;
  88     }
  89
  90     @Override
  91     public List<FlowOnNode> getFlows(Node node) {
  92         return reader.readAllFlows(node);
  93     }
  94
  95     @Override
  96     public Map<Node, List<FlowOnNode>> getFlowStatisticsForFlowList(
  97             List<FlowEntry> flowList) {
  98         Map<Node, List<FlowOnNode>> map = new HashMap<Node, List<FlowOnNode>>();
  99         if (flowList != null) {
 100             for (FlowEntry entry : flowList) {
 101                 Node node = entry.getNode();
 102                 Flow flow = entry.getFlow();
 103                 List<FlowOnNode> list = (map.containsKey(node)) ? map.get(node)
 104                         : new ArrayList<FlowOnNode>();
 105                 list.add(reader.readFlow(node, flow));
 106                 map.put(node, list);
 107             }
 108         }
 109         return map;
 110     }
 111
 112     @Override
 113     public int getFlowsNumber(Node node) {
 114         return reader.readAllFlows(node).size();
 115     }
 116
 117     @Override
 118     public NodeDescription getNodeDescription(Node node) {
 119         return reader.readDescription(node);
 120     }
 121
 122     @Override
 123     public NodeConnectorStatistics getNodeConnectorStatistics(
 124             NodeConnector nodeConnector) {
 125         return reader.readNodeConnector(nodeConnector);
 126     }
 127
 128     @Override
 129     public List<NodeConnectorStatistics> getNodeConnectorStatistics(Node node) {
 130         return reader.readNodeConnectors(node);
 131     }
 132 }