From 6d115ae55eae2445e4e9c0e5fe7968828704a769 Mon Sep 17 00:00:00 2001 From: Nicolas Brignone Date: Sat, 11 Apr 2020 12:42:50 -0300 Subject: [PATCH] Sleeping before port forwarding. command is crashing without this, not sure yet what is the resource that it is not ready yet. --- pkg/smoke/tcp_echo/tcp_echo.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/smoke/tcp_echo/tcp_echo.go b/pkg/smoke/tcp_echo/tcp_echo.go index af04123..49a9eca 100644 --- a/pkg/smoke/tcp_echo/tcp_echo.go +++ b/pkg/smoke/tcp_echo/tcp_echo.go @@ -108,13 +108,13 @@ func (r *SmokeTestRunner) RunTests() { fmt.Printf("Public service ClusterIp = %q\n", publicService.Spec.ClusterIP) fmt.Printf("Private service ClusterIp = %q\n", privateService.Spec.ClusterIP) + time.Sleep(20 * time.Second) + r.Pub1Cluster.KubectlExecAsync("port-forward service/tcp-go-echo 9090:9090") r.Priv1Cluster.KubectlExecAsync("port-forward service/tcp-go-echo 9091:9090") - time.Sleep(2 * time.Second) //give time to port forwarding to start + time.Sleep(20 * time.Second) //give time to port forwarding to start - //sendReceive(publicService.Spec.ClusterIP + ":9090") - //sendReceive(privateService.Spec.ClusterIP + ":9090") sendReceive("127.0.0.1:9090") sendReceive("127.0.0.1:9091") }