github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 03:11:40 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #89863 from aojea/closewait

Browse Source 
e2e TCP CLOSE test wait until pod is ready
This commit is contained in:
Kubernetes Prow Robot 2020-04-05 07:37:46 -07:00 committed by GitHub
commit 4fc998157a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/network/kube_proxy.go
View File

@ -208,9 +208,12 @@ var _ = SIGDescribe("Network", func() {
serverNodeInfo.nodeIP,
kubeProxyE2eImage))
fr.PodClient().CreateSync(serverPodSpec)
defer fr.PodClient().DeleteSync(serverPodSpec.Name, metav1.DeleteOptions{}, framework.DefaultPodDeletionTimeout)
// The server should be listening before spawning the client pod
<-time.After(time.Duration(2) * time.Second)
if readyErr := e2epod.WaitForPodsReady(fr.ClientSet, fr.Namespace.Name, serverPodSpec.Name, 0); readyErr != nil {
framework.Failf("error waiting for server pod %s to be ready: %w", serverPodSpec.Name, readyErr)
}
// Connect to the server and leak the connection
ginkgo.By(fmt.Sprintf(
"Launching a client connection on node %v (node ip: %v, image: %v)",
@ -218,6 +221,7 @@ var _ = SIGDescribe("Network", func() {
clientNodeInfo.nodeIP,
kubeProxyE2eImage))
fr.PodClient().CreateSync(clientPodSpec)
defer fr.PodClient().DeleteSync(clientPodSpec.Name, metav1.DeleteOptions{}, framework.DefaultPodDeletionTimeout)
ginkgo.By("Checking /proc/net/nf_conntrack for the timeout")
// These must be synchronized from the default values set in