From ec295c0f2a65fba411968625225d4db24d4cbba4 Mon Sep 17 00:00:00 2001 From: Antonio Ojea Date: Sun, 28 Jun 2020 23:52:37 +0200 Subject: [PATCH] e2e networking: wait for endpoints to be published e2e test wait for the endpoints objects to be created --- test/e2e/framework/network/utils.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/test/e2e/framework/network/utils.go b/test/e2e/framework/network/utils.go index 4182c56d811..c652a9cbe2a 100644 --- a/test/e2e/framework/network/utils.go +++ b/test/e2e/framework/network/utils.go @@ -673,6 +673,13 @@ func (config *NetworkingTestConfig) setup(selector map[string]string) { } else { config.NodeIP = e2enode.FirstAddress(nodeList, v1.NodeInternalIP) } + + ginkgo.By("Waiting for NodePort service to expose endpoint") + err = framework.WaitForServiceEndpointsNum(config.f.ClientSet, config.Namespace, nodePortServiceName, len(config.EndpointPods), time.Second, wait.ForeverTestTimeout) + framework.ExpectNoError(err, "failed to validate endpoints for service %s in namespace: %s", nodePortServiceName, config.Namespace) + ginkgo.By("Waiting for Session Affinity service to expose endpoint") + err = framework.WaitForServiceEndpointsNum(config.f.ClientSet, config.Namespace, sessionAffinityServiceName, len(config.EndpointPods), time.Second, wait.ForeverTestTimeout) + framework.ExpectNoError(err, "failed to validate endpoints for service %s in namespace: %s", sessionAffinityServiceName, config.Namespace) } func (config *NetworkingTestConfig) createNetProxyPods(podName string, selector map[string]string) []*v1.Pod {