pespin has uploaded this change for review.

View Change

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)

To view, visit change 39903. To unsubscribe, or for help writing mail filters, visit settings.