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

Merge pull request #99201 from aojea/conninvalid

Browse Source 
e2e conntrack invalid test should wait pod are running
This commit is contained in:
Kubernetes Prow Robot 2021-02-18 10:03:12 -08:00 committed by GitHub
commit 473af0b8d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
test/e2e/network/conntrack.go
View File

@ -331,12 +331,7 @@ var _ = SIGDescribe("Conntrack", func() {
}, },
}, },
} }
_, err := fr.ClientSet.CoreV1().Pods(fr.Namespace.Name).Create(context.TODO(), serverPod, metav1.CreateOptions{}) fr.PodClient().CreateSync(serverPod)
framework.ExpectNoError(err)
err = e2epod.WaitForPodsRunningReady(fr.ClientSet, fr.Namespace.Name, 1, 0, framework.PodReadyBeforeTimeout, map[string]string{})
framework.ExpectNoError(err)
ginkgo.By("Server pod created on node " + serverNodeInfo.name) ginkgo.By("Server pod created on node " + serverNodeInfo.name)
svc := &v1.Service{ svc := &v1.Service{
@ -353,7 +348,7 @@ var _ = SIGDescribe("Conntrack", func() {
}, },
}, },
} }
_, err = fr.ClientSet.CoreV1().Services(fr.Namespace.Name).Create(context.TODO(), svc, metav1.CreateOptions{}) _, err := fr.ClientSet.CoreV1().Services(fr.Namespace.Name).Create(context.TODO(), svc, metav1.CreateOptions{})
framework.ExpectNoError(err) framework.ExpectNoError(err)
ginkgo.By("Server service created") ginkgo.By("Server service created")
@ -376,9 +371,8 @@ var _ = SIGDescribe("Conntrack", func() {
RestartPolicy: v1.RestartPolicyNever, RestartPolicy: v1.RestartPolicyNever,
}, },
} }
_, err = fr.ClientSet.CoreV1().Pods(fr.Namespace.Name).Create(context.TODO(), pod, metav1.CreateOptions{})
framework.ExpectNoError(err)
fr.PodClient().CreateSync(pod)
ginkgo.By("Client pod created") ginkgo.By("Client pod created")
// The client will open connections against the server // The client will open connections against the server
@ -397,9 +391,10 @@ var _ = SIGDescribe("Conntrack", func() {
logs, err := e2epod.GetPodLogs(cs, ns, "boom-server", "boom-server") logs, err := e2epod.GetPodLogs(cs, ns, "boom-server", "boom-server")
framework.ExpectNoError(err) framework.ExpectNoError(err)
if !strings.Contains(string(logs), "connection established") { if !strings.Contains(string(logs), "connection established") {
framework.Logf("boom-server pod logs: %s", logs)
framework.Failf("Boom server pod did not sent any bad packet to the client") framework.Failf("Boom server pod did not sent any bad packet to the client")
} }
framework.Logf("boom-server pod logs: %s", logs) framework.Logf("boom-server pod logs: %s", logs)
framework.Logf("boom-server did not receive any RST packet") framework.Logf("boom-server OK: did not receive any RST packet")
}) })
}) })