github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-02 01:39:02 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #103371 from claudiubelu/tests/windows-flakyness

Browse Source 
windows tests: Wait for the network connectivity first
This commit is contained in:
Kubernetes Prow Robot
2021-07-02 12:30:22 -07:00
committed by GitHub
parent a331cf74b7 9accb994df
commit 0bb6d1431c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/windows/hybrid_network.go
View File

@@ -89,12 +89,14 @@ var (
) )
func assertConsistentConnectivity(f *framework.Framework, podName string, os string, cmd []string) { func assertConsistentConnectivity(f *framework.Framework, podName string, os string, cmd []string) {
gomega.Consistently(func() error { connChecker := func() error {
ginkgo.By(fmt.Sprintf("checking connectivity of %s-container in %s", os, podName)) ginkgo.By(fmt.Sprintf("checking connectivity of %s-container in %s", os, podName))
// TODO, we should be retrying this similar to what is done in DialFromNode, in the test/e2e/networking/networking.go tests // TODO, we should be retrying this similar to what is done in DialFromNode, in the test/e2e/networking/networking.go tests
_, _, err := f.ExecCommandInContainerWithFullOutput(podName, os+"-container", cmd...) _, _, err := f.ExecCommandInContainerWithFullOutput(podName, os+"-container", cmd...)
return err return err
}, duration, pollInterval).ShouldNot(gomega.HaveOccurred()) }
gomega.Eventually(connChecker, duration, pollInterval).ShouldNot(gomega.HaveOccurred())
gomega.Consistently(connChecker, duration, pollInterval).ShouldNot(gomega.HaveOccurred())
} }
func linuxCheck(address string, port int) []string { func linuxCheck(address string, port int) []string {