def __init__(self, port, pci, switch_port=None, vtep_vlan=None, ip=None, tg_gateway_ip=None,
gateway_ip=None, ip_addrs_step=None, tg_gateway_ip_addrs_step=None,
- gateway_ip_addrs_step=None, chain_count=1, flow_count=1, vlan_tagging=False):
+ gateway_ip_addrs_step=None, udp_src_port=None, udp_dst_port=None,
+ chain_count=1, flow_count=1, vlan_tagging=False):
self.chain_count = chain_count
self.flow_count = flow_count
self.dst = None
self.tg_gateway_ip_list = self.expand_ip(self.tg_gateway_ip,
self.tg_gateway_ip_addrs_step,
self.chain_count)
+ self.udp_src_port = udp_src_port
+ self.udp_dst_port = udp_dst_port
def set_mac(self, mac):
if mac is None:
'ip_dst_addr_max': self.dst.ip_list[max_idx],
'ip_dst_count': ip_dst_count,
'ip_addrs_step': self.ip_addrs_step,
+ 'udp_src_port': self.udp_src_port,
+ 'udp_dst_port': self.udp_dst_port,
'mac_discovery_gw': self.gateway_ip_list[chain_idx],
'ip_src_tg_gw': self.tg_gateway_ip_list[chain_idx],
'ip_dst_tg_gw': self.dst.tg_gateway_ip_list[chain_idx],
'gateway_ip_addrs_step': self.gateway_ip_addrs_step,
'tg_gateway_ip': generator_config.tg_gateway_ip_addrs[0],
'tg_gateway_ip_addrs_step': self.tg_gateway_ip_addrs_step,
+ 'udp_src_port': generator_config.udp_src_port,
+ 'udp_dst_port': generator_config.udp_dst_port,
'vlan_tagging': self.vlan_tagging
}
dst_config = {
'gateway_ip_addrs_step': self.gateway_ip_addrs_step,
'tg_gateway_ip': generator_config.tg_gateway_ip_addrs[1],
'tg_gateway_ip_addrs_step': self.tg_gateway_ip_addrs_step,
+ 'udp_src_port': generator_config.udp_src_port,
+ 'udp_dst_port': generator_config.udp_dst_port,
'vlan_tagging': self.vlan_tagging
}
retDict[port]['rx'][key] = int(stats[port]['rx'][key])
except ValueError:
retDict[port]['rx'][key] = 0
- retDict[port]['rx']['avg_delay_usec'] = float(stats[port]['rx']['avg_delay_usec'])
- retDict[port]['rx']['min_delay_usec'] = float(stats[port]['rx']['min_delay_usec'])
- retDict[port]['rx']['max_delay_usec'] = float(stats[port]['rx']['max_delay_usec'])
+ retDict[port]['rx']['avg_delay_usec'] = int(stats[port]['rx']['avg_delay_usec'])
+ retDict[port]['rx']['min_delay_usec'] = int(stats[port]['rx']['min_delay_usec'])
+ retDict[port]['rx']['max_delay_usec'] = int(stats[port]['rx']['max_delay_usec'])
retDict[port]['drop_rate_percent'] = self.__get_dropped_rate(retDict[port])
ports = sorted(retDict.keys())
indicating the rate to send on each interface
right the right side of the range to search as a % of line rate
indicating the rate to send on each interface
- targets a dict of drop rates to search (0.1 = 0.1%), indexed by the DR name or "tag" ('ndr', 'pdr')
+ targets a dict of drop rates to search (0.1 = 0.1%), indexed by the DR name or "tag"
+ ('ndr', 'pdr')
results a dict to store results
'''
if len(targets) == 0:
})
right_targets[tag] = target
else:
+ # initialize to 0 all fields of result for
+ # the worst case scenario of the binary search (if ndr/pdr is not found)
+ if tag not in results:
+ results[tag] = dict.fromkeys(rates, 0)
+ empty_stats = self.__format_output_stats(dict(stats))
+ for key in empty_stats:
+ if isinstance(empty_stats[key], dict):
+ empty_stats[key] = dict.fromkeys(empty_stats[key], 0)
+ else:
+ empty_stats[key] = 0
+ results[tag].update({
+ 'load_percent_per_direction': 0,
+ 'stats': empty_stats,
+ 'timestamp_sec': None
+ })
left_targets[tag] = target
# search lower half