From c38c9808b1b0f4d949c1d70610085e0ad5cfaf35 Mon Sep 17 00:00:00 2001 From: Suchi Raman Date: Wed, 2 Oct 2013 15:26:49 -0400 Subject: [PATCH] Add rate-based tracking of flow. Signed-off-by: Suchi Raman --- .../affinity/analytics/internal/AnalyticsManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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> flows = this.affinityManager.getAllFlowsByHost(al); @@ -263,8 +264,8 @@ public class AnalyticsManager implements IReadServiceListener, IAnalyticsManager @Override public void nodeFlowStatisticsUpdated(Node node, List flowStatsList) { - Set allHosts = this.hostTracker.getAllHosts(); + for (FlowOnNode f : flowStatsList) { Host srcHost = getSourceHostFromFlow(f.getFlow(), allHosts); Host dstHost = getDestinationHostFromFlow(f.getFlow(), allHosts); -- 2.36.6