p2_dst_start_ip = traffic_options['p2_dst_start_ip']
#p2_dst_end_ip = traffic_options['p2_dst_end_ip']
- base_pkt_a = Ether()/IP(src=p1_src_start_ip, dst=p1_dst_start_ip)
- base_pkt_b = Ether()/IP(src=p2_src_start_ip, dst=p2_dst_start_ip)
+ base_pkt_a = Ether()/IP(src=p1_src_start_ip, dst=p1_dst_start_ip, proto=61)
+ base_pkt_b = Ether()/IP(src=p2_src_start_ip, dst=p2_dst_start_ip, proto=61)
vm1 = CTRexScRaw([STLVmTupleGen(ip_min=p1_src_start_ip, ip_max=p1_src_end_ip,
name="tuple"), # define tuple gen
STLVmFixIpv4(offset="IP"), # fix checksum
]
, split_by_field="tuple") # split to cores base on the tuple generator
-
+
vm2 = CTRexScRaw([STLVmTupleGen(ip_min=p2_src_start_ip, ip_max=p2_src_end_ip,
name="tuple"), # define tuple gen
c.start(ports=[0, 1], mult=rate, duration=duration)
# block until done
- c.wait_on_traffic(ports=[0, 1])
+ c.wait_on_traffic(ports=[0, 1], timeout=(duration+30))
# read the stats after the test
stats = c.get_stats()