#! /bin/bash
-if python2.7 waf-1.9.3 --help &> /dev/null ; then
- python2.7 waf-1.9.3 $@
- exit $?
-elif python3 waf-1.9.3 --help &> /dev/null ; then
- python3 waf-1.9.3 $@
- exit $?
+waf=waf-1.9.3
+p2=${PYTHON:-${PYTHON2:-python2.7}}
+p3=${PYTHON3:-python3}
+
+
+# try Pythons which can load waf
+
+if $p2 $waf --help &> /dev/null; then
+ $p2 $waf $@
+elif $p3 $waf --help &> /dev/null; then
+ $p3 $waf $@
+
+# waf can't be loaded, print the error with available Python
+
+elif which $p2 &> /dev/null; then
+ $p2 $waf $@
+elif which $p3 &> /dev/null; then
+ $p3 $waf $@
+
+# no Python available
+
else
- echo Required Python versions at least 2.7 or 3
+ echo Required Python 2.7 or 3
exit 1
fi
#! /bin/bash
export WAFLOCK=.lock-wafbuild_dpdk
-if python2.7 waf-1.9.3 --help &> /dev/null ; then
- python2.7 waf-1.9.3 $@
- exit $?
-elif python3 waf-1.9.3 --help &> /dev/null ; then
- python3 waf-1.9.3 $@
- exit $?
+waf=waf-1.9.3
+p2=${PYTHON:-${PYTHON2:-python2.7}}
+p3=${PYTHON3:-python3}
+
+
+# try Pythons which can load waf
+
+if $p2 $waf --help &> /dev/null; then
+ $p2 $waf $@
+elif $p3 $waf --help &> /dev/null; then
+ $p3 $waf $@
+
+# waf can't be loaded, print the error with available Python
+
+elif which $p2 &> /dev/null; then
+ $p2 $waf $@
+elif which $p3 &> /dev/null; then
+ $p3 $waf $@
+
+# no Python available
+
else
- echo Required Python versions at least 2.7 or 3
+ echo Required Python 2.7 or 3
exit 1
fi
--- /dev/null
+###############################################################
+#### TRex benchmark configuration file ####
+###############################################################
+
+### stateful ###
+
+test_jumbo:
+ multiplier : 2.8
+ cores : 1
+ bw_per_core : 67.030
+
+
+test_routing_imix:
+ multiplier : 1
+ cores : 1
+ bw_per_core : 3.979
+
+
+test_routing_imix_64:
+ multiplier : 50
+ cores : 1
+ bw_per_core : .681
+
+
+test_static_routing_imix_asymmetric:
+ multiplier : 0.8
+ cores : 1
+ bw_per_core : 13.742
+
+
+
+### stateless ###
+
+test_CPU_benchmark:
+ profiles:
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 64}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 64, stream_count: 10}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 64, stream_count: 100}
+ cpu_util : 1
+ bw_per_core : 1
+
+# causes queue full
+# - name : stl/udp_for_benchmarks.py
+# kwargs : {packet_len: 64, stream_count: 1000}
+# cpu_util : 1
+# bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 128}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 256}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 512}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 1500}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 4000}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 9000}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 9000, stream_count: 10}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_for_benchmarks.py
+ kwargs : {packet_len: 9000, stream_count: 100}
+ cpu_util : 1
+ bw_per_core : 1
+
+# not enough memory + queue full if memory increase
+# - name : stl/udp_for_benchmarks.py
+# kwargs : {packet_len: 9000, stream_count: 1000}
+# cpu_util : 1
+# bw_per_core : 1
+
+ - name : stl/imix.py
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 64}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 128}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 256}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 512}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 1500}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 4000}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_1pkt_tuple_gen.py
+ kwargs : {packet_len: 9000}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/pcap.py
+ kwargs : {ipg_usec: 2, loop_count: 0}
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/udp_rand_len_9k.py
+ cpu_util : 1
+ bw_per_core : 1
+
+ - name : stl/hlt/hlt_udp_rand_len_9k.py
+ cpu_util : 1
+ bw_per_core : 1
+
+
--- /dev/null
+################################################################
+#### TRex nightly test configuration file ####
+################################################################
+
+
+### TRex configuration:
+# hostname - can be DNS name or IP for the TRex machine for ssh to the box
+# is_dual - should the TRex inject with -p ?
+# version_path - path to the TRex version and executable
+# cores - how many cores should be used
+# latency - rate of latency packets injected by the TRex
+# modes - list of modes (tagging) of this setup (loopback, virtual etc.)
+# * loopback - Trex works via loopback. Router and TFTP configurations may be skipped.
+# * VM - Virtual OS (accept low CPU utilization in tests, latency can get spikes)
+# * virt_nics - NICs are virtual (VMXNET3 etc.)
+
+### Router configuration:
+# hostname - the router hostname as apears in ______# cli prefix
+# ip_address - the router's ip that can be used to communicate with
+# image - the desired imaged wished to be loaded as the router's running config
+# line_password - router password when access via Telent
+# en_password - router password when changing to "enable" mode
+# interfaces - an array of client-server pairs, representing the interfaces configurations of the router
+# configurations - an array of configurations that could possibly loaded into the router during the test.
+# The "clean" configuration is a mandatory configuration the router will load with to run the basic test bench
+
+### TFTP configuration:
+# hostname - the tftp hostname
+# ip_address - the tftp's ip address
+# images_path - the tftp's relative path in which the router's images are located
+
+### Test_misc configuration:
+# expected_bw - the "golden" bandwidth (in Gbps) results planned on receiving from the test
+
+trex:
+ hostname : csi-trex-24
+ cores : 1
+ modes : [VM, virt_nics, loopback]
+
def begin (self):
- if self.pkg and self.kill_running and not CTRexScenario.is_copied:
+ client = CTRexScenario.trex
+ if self.pkg and not CTRexScenario.is_copied:
+ if client.master_daemon.is_trex_daemon_running() and client.get_trex_cmds() and not self.kill_running:
+ print("Can't update TRex, it's running")
+ sys.exit(-1)
print('Updating TRex to %s' % self.pkg)
- if not CTRexScenario.trex.master_daemon.update_trex(self.pkg):
+ if not client.master_daemon.update_trex(self.pkg):
print('Failed updating TRex')
sys.exit(-1)
else:
return
if not self.no_daemon:
print('Restarting TRex daemon server')
- res = CTRexScenario.trex.restart_trex_daemon()
+ res = client.restart_trex_daemon()
if not res:
print('Could not restart TRex daemon server')
sys.exit(-1)
print('Restarted.')
if self.kill_running:
- CTRexScenario.trex.kill_all_trexes()
+ client.kill_all_trexes()
else:
- if CTRexScenario.trex.get_trex_cmds():
+ if client.get_trex_cmds():
print('TRex is already running')
sys.exit(-1)
if 'virt_nics' in self.modes and cores > 1:
raise Exception('Number of cores should be 1 with virtual NICs')
if not self.no_daemon:
- CTRexScenario.trex.start_stateless(c = cores)
+ client.start_stateless(c = cores)
CTRexScenario.stl_trex = STLClient(username = 'TRexRegression',
server = self.configuration.trex['trex_name'],
verbose_level = self.json_verbose)
.. code-block:: python
- :caption: Example 1: Minimal example of client interacting with the TRex server
+
+ # Example 1: Minimal example of client interacting with the TRex server
c = STLClient()
.. code-block:: python
- :caption: Example 2: Client can execute other functions while the TRex server is generating traffic
+
+ # Example 2: Client can execute other functions while the TRex server is generating traffic
c = STLClient()
.. code-block:: python
- :caption: Example 3: Console-like API interface
+
+ # Example 3: Console-like API interface
def simple ():
.. code-block:: python
- :caption: Example 5: pin cores to ports
+
+ # Example 5: pin cores to ports
c = STLClient()
--------------------
.. code-block:: python
- :caption: FE Example1
+
+ # FE Example1
base_pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)
.. code-block:: python
- :caption: FE Example2
+
+ # FE Example2
#range of source mac-addr
.. code-block:: python
- :caption: STLProfile Example1
+
+ # STLProfile Example1
size = self.fsize - 4; # no FCS
.. code-block:: python
- :caption: STLProfile Example2
+
+ # STLProfile Example2
class STLS1(object):
\r
def setup_custom_logger(name, log_path = None):\r
# first make sure path availabe\r
+ prepare_dir(log_path)\r
logging.basicConfig(level = logging.INFO, \r
format = '%(asctime)s %(name)-10s %(module)-20s %(levelname)-8s %(message)s',\r
datefmt = '%m-%d %H:%M')\r
the ASYNC port
.. code-block:: python
- :caption: Example
+ # Example
# connect to local TRex server
c = STLClient()
The following example splits the generated traffic by "ip_src" variable.
.. code-block:: python
- :caption: Split by
+ # Split by
# TCP SYN
base_pkt = Ether()/IP(dst="48.0.0.1")/TCP(dport=80,flags="S")
Possible values: "inc", "dec", "random"
.. code-block:: python
- :caption: Example1
+ # Example1
# input
STLVmFlowVar(min_value=0, max_value=3, size=1,op="inc")
in could be string in case of scapy packet. format IP[:[id]]
.. code-block:: python
- :caption: Example2
+
+ # Example2
pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)
How to write the variable to the the packet. True=big-endian, False=little-endian
.. code-block:: python
- :caption: Example3
+
+ # Example3
pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)
="0.0.0.10", port_min=1025, port_max=65535, limit_flows=100000, flags=0
.. code-block:: python
- :caption: Example5
+
+ # Example5
def create_stream (self):
# pkt
.. code-block:: python
- :caption: Example6
-
- # packet is scapy
- STLPktBuilder( pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)/(10*'x') )
+ # Example6
+
+ # packet is scapy
+ STLPktBuilder( pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)/(10*'x') )
- # packet is taken from pcap file relative to python
- STLPktBuilder( pkt ="stl/yaml/udp_64B_no_crc.pcap")
+ # packet is taken from pcap file relative to python
+ STLPktBuilder( pkt ="stl/yaml/udp_64B_no_crc.pcap")
- # packet is taken from pcap file relative to profile file
- STLPktBuilder( pkt ="stl/yaml/udp_64B_no_crc.pcap",
- path_relative_to_profile = True )
+ # packet is taken from pcap file relative to profile file
+ STLPktBuilder( pkt ="stl/yaml/udp_64B_no_crc.pcap",
+ path_relative_to_profile = True )
- vm = STLScVmRaw( [ STLVmTupleGen ( ip_min="16.0.0.1", ip_max="16.0.0.2",
- port_min=1025, port_max=65535,
- name="tuple"), # define tuple gen
+ vm = STLScVmRaw( [ STLVmTupleGen ( ip_min="16.0.0.1", ip_max="16.0.0.2",
+ port_min=1025, port_max=65535,
+ name="tuple"), # define tuple gen
- STLVmWrFlowVar (fv_name="tuple.ip", pkt_offset= "IP.src" ), # write ip to packet IP.src
- STLVmFixIpv4(offset = "IP"), # fix checksum
- STLVmWrFlowVar (fv_name="tuple.port", pkt_offset= "UDP.sport" ) #write udp.port
- ]
- )
+ STLVmWrFlowVar (fv_name="tuple.ip", pkt_offset= "IP.src" ), # write ip to packet IP.src
+ STLVmFixIpv4(offset = "IP"), # fix checksum
+ STLVmWrFlowVar (fv_name="tuple.port", pkt_offset= "UDP.sport" ) #write udp.port
+ ]
+ )
- 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'
+ 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'
- STLPktBuilder(pkt = base_pkt/pad, vm= vm)
+ STLPktBuilder(pkt = base_pkt/pad, vm= vm)
:parameters:
Link interface percent (0-100). Example: 10 is 10% of the port link setup
.. code-block:: python
- :caption: STLTXMode Example
- mode = STLTXCont(pps = 10)
+ # STLTXMode Example
- mode = STLTXCont(bps_L1 = 10000000) #10mbps L1
+ mode = STLTXCont(pps = 10)
- mode = STLTXCont(bps_L2 = 10000000) #10mbps L2
+ mode = STLTXCont(bps_L1 = 10000000) #10mbps L1
- mode = STLTXCont(percentage = 10) #10%
+ mode = STLTXCont(bps_L2 = 10000000) #10mbps L2
+
+ mode = STLTXCont(percentage = 10) #10%
"""
see :class:`trex_stl_lib.trex_stl_streams.STLTXMode` for rate
.. code-block:: python
- :caption: STLTXCont Example
- mode = STLTXCont(pps = 10)
+ # STLTXCont Example
+
+ mode = STLTXCont(pps = 10)
"""
super(STLTXCont, self).__init__(**kwargs)
see :class:`trex_stl_lib.trex_stl_streams.STLTXMode` for rate
.. code-block:: python
- :caption: STLTXSingleBurst Example
- mode = STLTXSingleBurst( pps = 10, total_pkts = 1)
+ # STLTXSingleBurst Example
+
+ mode = STLTXSingleBurst( pps = 10, total_pkts = 1)
"""
see :class:`trex_stl_lib.trex_stl_streams.STLTXMode` for rate
.. code-block:: python
- :caption: STLTXMultiBurst Example
- mode = STLTXMultiBurst(pps = 10, pkts_per_burst = 1,count 10, ibg=10.0)
+ # STLTXMultiBurst Example
+
+ mode = STLTXMultiBurst(pps = 10, pkts_per_burst = 1,count 10, ibg=10.0)
"""
""" Define per stream basic stats
.. code-block:: python
- :caption: STLFlowStats Example
+
+ # STLFlowStats Example
flow_stats = STLFlowStats(pg_id = 7)
""" Define per stream basic stats + latency, jitter, packet reorder/loss
.. code-block:: python
- :caption: STLFlowLatencyStats Example
+
+ # STLFlowLatencyStats Example
flow_stats = STLFlowLatencyStats(pg_id = 7)
""" One stream object. Includes mode, Field Engine mode packet template and Rx stats
.. code-block:: python
- :caption: STLStream Example
+
+ # STLStream Example
base_pkt = Ether()/IP(src="16.0.0.1",dst="48.0.0.1")/UDP(dport=12,sport=1025)
""" Describe a list of streams
.. code-block:: python
- :caption: STLProfile Example
- profile = STLProfile( [ STLStream( isg = 10.0, # star in delay
+ # STLProfile Example
+
+ profile = STLProfile( [ STLStream( isg = 10.0, # star in delay
name ='S0',
packet = STLPktBuilder(pkt = base_pkt/pad),
mode = STLTXSingleBurst( pps = 10, total_pkts = self.burst_size),
def confirm(msg, default = False):
if not os.isatty(1):
return default
- termios.tcflush(sys.stdin, termios.TCIOFLUSH)
+ termios.tcflush(sys.stdin, termios.TCIFLUSH)
try:
return strtobool(raw_input(msg))
except KeyboardInterrupt:
def read_line(msg = '', default = ''):
if not os.isatty(1):
return default
- termios.tcflush(sys.stdin, termios.TCIOFLUSH)
+ termios.tcflush(sys.stdin, termios.TCIFLUSH)
try:
return raw_input(msg).strip()
except KeyboardInterrupt:
'rte_i40e_pmd': 'i40e',
'rte_em_pmd': 'e1000',
'rte_vmxnet3_pmd': 'vmxnet3',
- 'rte_virtio_pmd': 'virtio',
+ 'rte_virtio_pmd': 'virtio-pci',
'rte_enic_pmd': 'enic',
}
for pci, info in dpdk_nic_bind.get_info_from_trex(dpdk_interfaces).items():
Code Review / trex.git / commitdiff