Signed-off-by: Suchi Raman <suchi.raman@plexxi.com>
}
public double getBitRateOnAffinityLink(AffinityLink al) {
}
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);
double maxDuration = 0;
int totalBytes = 0;
List<Entry<Host, Host>> flows = this.affinityManager.getAllFlowsByHost(al);
@Override
public void nodeFlowStatisticsUpdated(Node node, List<FlowOnNode> flowStatsList) {
@Override
public void nodeFlowStatisticsUpdated(Node node, List<FlowOnNode> flowStatsList) {
Set<HostNodeConnector> allHosts = this.hostTracker.getAllHosts();
Set<HostNodeConnector> allHosts = this.hostTracker.getAllHosts();
for (FlowOnNode f : flowStatsList) {
Host srcHost = getSourceHostFromFlow(f.getFlow(), allHosts);
Host dstHost = getDestinationHostFromFlow(f.getFlow(), allHosts);
for (FlowOnNode f : flowStatsList) {
Host srcHost = getSourceHostFromFlow(f.getFlow(), allHosts);
Host dstHost = getDestinationHostFromFlow(f.getFlow(), allHosts);