#
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):
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
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:
- 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."""