github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 10:51:29 +00:00
Code Issues Projects Releases Wiki Activity

e2e conntrack invalid test should wait pod are running

Browse Source
This commit is contained in:
Antonio Ojea 2021-02-18 15:46:07 +01:00
parent f760c21cd1
commit 60109a1632
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")
}) })
}) })