From 181a35b47a29511827f6bc8f3ecdf715f628d3b1 Mon Sep 17 00:00:00 2001
From: "Joe Talerico (rook)" <joe.talerico@gmail.com>
Date: Mon, 17 Oct 2022 18:54:20 -0400
Subject: [PATCH] Quick fix for UDP_STREAM

Signed-off-by: Joe Talerico (rook) <joe.talerico@gmail.com>
---
 netperf/netperf.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/netperf/netperf.go b/netperf/netperf.go
index e39e7eff..750dcbb6 100644
--- a/netperf/netperf.go
+++ b/netperf/netperf.go
@@ -336,7 +336,7 @@ func Run(c *kubernetes.Clientset, rc rest.Config, nc Config, client apiv1.PodLis
 	pod := client.Items[0]
 	fmt.Printf("🔥 Client (%s,%s) starting netperf against server : %s\n", pod.Name, pod.Status.PodIP, serverIP)
 	ShowConfig(nc)
-	cmd := []string{"/usr/local/bin/netperf", "-H", serverIP, "-l", fmt.Sprintf("%d", nc.Duration), "-t", nc.Profile, "--", "-m", fmt.Sprintf("%d", nc.MessageSize), "-P", fmt.Sprintf("0,%d", ServerDataPort)}
+	cmd := []string{"/usr/local/bin/netperf", "-H", serverIP, "-l", fmt.Sprintf("%d", nc.Duration), "-t", nc.Profile, "--", "-m", fmt.Sprintf("%d", nc.MessageSize), "-P", fmt.Sprintf("0,%d", ServerDataPort), "-R", "1"}
 	req := c.CoreV1().RESTClient().
 		Post().
 		Namespace(pod.Namespace).