Quick fix for UDP_STREAM

Signed-off-by: Joe Talerico (rook) <[email protected]>
cloud-bulldozer · Oct 17, 2022 · 181a35b · 181a35b
1 parent b4f56c2
commit 181a35b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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).