X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=nfvbench%2Fchain_workers.py;h=e332d7b26f23f5e6cf72f8d32d08668f55ca584f;hb=refs%2Fchanges%2F36%2F72636%2F1;hp=2e36fb1357fa8ac94a7e0ab3af10dd06eb46f301;hpb=04a7de082bd221eae3c7004f4e0b99dfa4f8be91;p=nfvbench.git diff --git a/nfvbench/chain_workers.py b/nfvbench/chain_workers.py index 2e36fb1..e332d7b 100644 --- a/nfvbench/chain_workers.py +++ b/nfvbench/chain_workers.py @@ -17,37 +17,38 @@ class BasicWorker(object): - def __init__(self, config, clients, specs): - self.config = config - self.clients = clients - self.specs = specs + def __init__(self, stats_manager): + self.stats_manager = stats_manager + self.chain_manager = stats_manager.chain_runner.chain_manager + self.config = stats_manager.config + self.specs = stats_manager.specs - def set_vlan_tag(self, device, vlan): - device.set_vlan_tag(vlan) + def get_compute_nodes_bios(self): + return {} - def set_vlans(self, vlans): - pass + def get_version(self): + return {} def config_interfaces(self): - pass - - def get_data(self): return {} - def get_network_interfaces(self, index): - return [] - - def clear_interfaces(self): + def close(self): pass - def run(self): - return None, None + def insert_interface_stats(self, pps_list): + """Insert interface stats to a list of packet path stats. - def get_compute_nodes_bios(self): - return {} + pps_list: a list of packet path stats instances indexed by chain index - def get_version(self): - return {} + Specialized workers can insert their own interface stats inside each existing packet path + stats for every chain. + """ - def close(self): - pass + def update_interface_stats(self, diff=False): + """Update all interface stats. + + diff: if False, simply refresh the interface stats values with latest values + if True, diff the interface stats with the latest values + Make sure that the interface stats inserted in insert_interface_stats() are updated + with proper values + """