From: Suchi Raman <suchi.raman@plexxi.com>
Date: Wed, 2 Oct 2013 19:26:49 +0000 (-0400)
Subject: Add rate-based tracking of flow.
X-Git-Tag: jenkins-affinity-bulk-release-prepare-only-1~65
X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=commitdiff_plain;h=c38c9808b1b0f4d949c1d70610085e0ad5cfaf35;p=affinity.git

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 9d88206..2c4086c 100644
--- 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);