Code Review
/
nfvbench.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
nfvbenchvm: add option to use local nfvbench code
[nfvbench.git]
/
nfvbench
/
stats_manager.py
diff --git
a/nfvbench/stats_manager.py
b/nfvbench/stats_manager.py
index
a1fb497
..
6fa98bd
100644
(file)
--- a/
nfvbench/stats_manager.py
+++ b/
nfvbench/stats_manager.py
@@
-15,9
+15,9
@@
#
import time
#
import time
-from log import LOG
-from packet_stats import PacketPathStatsManager
-from stats_collector import IntervalCollector
+from
.
log import LOG
+from
.
packet_stats import PacketPathStatsManager
+from
.
stats_collector import IntervalCollector
class StatsManager(object):
class StatsManager(object):
@@
-35,7
+35,7
@@
class StatsManager(object):
if self.config.single_run:
pps_list = []
self.traffic_client.insert_interface_stats(pps_list)
if self.config.single_run:
pps_list = []
self.traffic_client.insert_interface_stats(pps_list)
- self.pps_mgr = PacketPathStatsManager(pps_list)
+ self.pps_mgr = PacketPathStatsManager(
self.config,
pps_list)
else:
self.pps_mgr = None
self.worker = None
else:
self.pps_mgr = None
self.worker = None
@@
-73,9
+73,9
@@
class StatsManager(object):
def _update_interface_stats(self, diff=False):
"""Update interface stats for both the traffic generator and the worker."""
def _update_interface_stats(self, diff=False):
"""Update interface stats for both the traffic generator and the worker."""
- self.traffic_client.update_interface_stats(diff
=True
)
+ self.traffic_client.update_interface_stats(diff)
if self.worker:
if self.worker:
- self.worker.update_interface_stats(diff
=True
)
+ self.worker.update_interface_stats(diff)
def run_fixed_rate(self):
"""Run a fixed rate and analyze results."""
def run_fixed_rate(self):
"""Run a fixed rate and analyze results."""