summaryrefslogtreecommitdiffstats
path: root/scripts/stl/udp_1pkt_src_ip_split_latency.py
diff options
context:
space:
mode:
authorIdo Barnea <ibarnea@cisco.com>2016-05-17 12:16:36 +0300
committerIdo Barnea <ibarnea@cisco.com>2016-05-18 19:23:48 +0300
commitf8d4267c09469019a275e522e0d2493720b5f9a1 (patch)
tree04bf92d3bfc03a02ae68c9d921b77e516302ccdf /scripts/stl/udp_1pkt_src_ip_split_latency.py
parent3e024d8bdcebdd3100851f28b5724a2ecbfc923a (diff)
more error counter
Diffstat (limited to 'scripts/stl/udp_1pkt_src_ip_split_latency.py')
-rw-r--r--scripts/stl/udp_1pkt_src_ip_split_latency.py50
1 files changed, 50 insertions, 0 deletions
diff --git a/scripts/stl/udp_1pkt_src_ip_split_latency.py b/scripts/stl/udp_1pkt_src_ip_split_latency.py
new file mode 100644
index 00000000..c874b38d
--- /dev/null
+++ b/scripts/stl/udp_1pkt_src_ip_split_latency.py
@@ -0,0 +1,50 @@
+from trex_stl_lib.api import *
+
+
+# split the range of IP to cores
+#
+class STLS1(object):
+
+ def __init__ (self):
+ self.fsize =64;
+
+ def create_stream (self, dir):
+ # create a base packet and pad it to size
+ size = self.fsize - 4; # no FCS
+
+ base_pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)
+
+ pad = max(0, size - len(base_pkt)) * 'x'
+
+ vm = STLScVmRaw( [ STLVmFlowVar ( "ip_src", min_value="10.0.0.1",
+ max_value="10.0.0.255", size=4, step=1,op="inc"),
+ STLVmWrFlowVar (fv_name="ip_src", pkt_offset= "IP.src" ), # write ip to packet IP.src
+ STLVmFixIpv4(offset = "IP") # fix checksum
+ ]
+ ,split_by_field = "ip_src" # split to cores base on the tuple generator
+ ,cache_size =255 # the cache size
+ );
+
+ pkt = STLPktBuilder(pkt = base_pkt/pad,
+ vm = vm)
+ stream = [STLStream(packet = pkt,
+ mode = STLTXCont(percentage=80)),
+ STLStream(packet = STLPktBuilder(pkt = "yaml/udp_64B_no_crc.pcap", path_relative_to_profile = True), # path relative to pwd
+ mode = STLTXCont(pps=1000),
+ flow_stats = STLFlowLatencyStats(pg_id = 12+dir))
+
+ ]
+ #print(stream.to_code())
+ return stream
+
+
+ def get_streams (self, direction = 0, **kwargs):
+ return self.create_stream(dir=direction)
+
+
+# dynamic load - used for trex console or simulator
+def register():
+ return STLS1()
+
+
+