pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/upf-benchmark/+/39903?usp=email )

Change subject: tunend: trex: Make amount of pkts per flow configurable ......................................................................

tunend: trex: Make amount of pkts per flow configurable

Change-Id: I72ca5c7fd15949936b208b23259b79881325fc43 --- M testsuites/gtplab-sysmo2025/tunend/trex/run.sh M testsuites/gtplab-sysmo2025/tunend/trex/udp_simple.py 2 files changed, 12 insertions(+), 5 deletions(-)

git pull ssh://gerrit.osmocom.org:29418/upf-benchmark refs/changes/03/39903/1

diff --git a/testsuites/gtplab-sysmo2025/tunend/trex/run.sh b/testsuites/gtplab-sysmo2025/tunend/trex/run.sh index 0bc0b73..18c2bbe 100755 --- a/testsuites/gtplab-sysmo2025/tunend/trex/run.sh +++ b/testsuites/gtplab-sysmo2025/tunend/trex/run.sh @@ -11,7 +11,7 @@ echo "To start the test, run: >" echo "tunnel --type gtpu;" echo "tunnels_topo load -f ${SCRIPT_DIR}/gtpu_topo.py -t num-streams=${NUM_STREAMS},num-addrs=${NUM_ADDRS};" -echo "start -f ${SCRIPT_DIR}/udp_simple.py -m 50000 -d 600 -t num-streams=${NUM_STREAMS},num-addrs=${NUM_ADDRS},dir=ul;" +echo "start -f ${SCRIPT_DIR}/udp_simple.py -m 50000 -d 600 -t num-streams=${NUM_STREAMS},num-addrs=${NUM_ADDRS},num-pkts=1,dir=ul;" echo "" printf "Once the test finished, run: >\ntunnel --type gtpu --off;\n stats\n" set -x diff --git a/testsuites/gtplab-sysmo2025/tunend/trex/udp_simple.py b/testsuites/gtplab-sysmo2025/tunend/trex/udp_simple.py index 106edbc..31d4370 100644 --- a/testsuites/gtplab-sysmo2025/tunend/trex/udp_simple.py +++ b/testsuites/gtplab-sysmo2025/tunend/trex/udp_simple.py @@ -56,6 +56,10 @@ type=int, default=1, help="The number of src IP addresses.") + parser.add_argument('--num-pkts', + type=int, + default=1, + help="The number of Packets to transmit per flow.") parser.add_argument('--dir', type=str, default='ul', @@ -64,23 +68,26 @@ args = parser.parse_args(tunables) self.num_streams = args.num_streams self.num_addrs = args.num_addrs + self.num_pkts = args.num_pkts do_ul = "ul" in args.dir.lower() do_dl = "dl" in args.dir.lower()

# client commands prog_c = ASTFProgram(stream=False, udp_mtu=1400, addon='latency') if do_ul: - prog_c.send_msg(ul_pkt) + for _ in range(self.num_pkts): + prog_c.send_msg(ul_pkt) if do_dl: prog_c.set_keepalive_msg(10000) - prog_c.recv_msg(1) + prog_c.recv_msg(self.num_pkts)

prog_s = ASTFProgram(stream=False, udp_mtu=1400, addon='latency') if do_ul: prog_s.set_keepalive_msg(10000) - prog_s.recv_msg(1) + prog_s.recv_msg(self.num_pkts) if do_dl: - prog_s.send_msg(dl_pkt) + for _ in range(self.num_pkts): + prog_s.send_msg(dl_pkt)

# Not really used, but must be passed to ASTFProfile: default_ip_gen = self.create_ip_gen(prog_c, prog_s, 0)