Add rate-based tracking of flow.

Signed-off-by: Suchi Raman <suchi.raman@plexxi.com>

diff --git a/analytics/implementation/src/main/java/org/opendaylight/affinity/analytics/internal/AnalyticsManager.java b/analytics/implementation/src/main/java/org/opendaylight/affinity/analytics/internal/AnalyticsManager.java
index 9d8820672fedd7f1ea6f97b1c87efa6c1aaf9f1c..2c4086cfc3272aa302db3f53b08c6a81e755b51d 100644 (file)
--- a/analytics/implementation/src/main/java/org/opendaylight/affinity/analytics/internal/AnalyticsManager.java
+++ b/analytics/implementation/src/main/java/org/opendaylight/affinity/analytics/internal/AnalyticsManager.java
@@ -227,6 +227,7 @@ public class AnalyticsManager implements IReadServiceListener, IAnalyticsManager
     }
 
     public double getBitRateOnAffinityLink(AffinityLink al) {
+        // Returns bit rate in *bits-per-second*
         double maxDuration = 0;
         int totalBytes = 0;
         List<Entry<Host, Host>> flows = this.affinityManager.getAllFlowsByHost(al);
@@ -263,8 +264,8 @@ public class AnalyticsManager implements IReadServiceListener, IAnalyticsManager
 
     @Override
     public void nodeFlowStatisticsUpdated(Node node, List<FlowOnNode> flowStatsList) {
-
         Set<HostNodeConnector> allHosts = this.hostTracker.getAllHosts();
+
         for (FlowOnNode f : flowStatsList) {
             Host srcHost = getSourceHostFromFlow(f.getFlow(), allHosts);
             Host dstHost = getDestinationHostFromFlow(f.getFlow(), allHosts);