github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 20:53:33 +00:00
Code Issues Projects Releases Wiki Activity

Improve retry logic in services e2e test.

Browse Source
This commit is contained in:
Quinton Hoole 2015-04-30 10:07:56 -07:00
parent 7ce75689a0
commit f51f6317d2
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
test/e2e/service.go
View File

@ -28,6 +28,7 @@ import (
"github.com/GoogleCloudPlatform/kubernetes/pkg/api/latest" "github.com/GoogleCloudPlatform/kubernetes/pkg/api/latest"
"github.com/GoogleCloudPlatform/kubernetes/pkg/client" "github.com/GoogleCloudPlatform/kubernetes/pkg/client"
"github.com/GoogleCloudPlatform/kubernetes/pkg/util" "github.com/GoogleCloudPlatform/kubernetes/pkg/util"
"github.com/GoogleCloudPlatform/kubernetes/pkg/util/wait"
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
@ -136,7 +137,8 @@ var _ = Describe("Services", func() {
// Try to find results for each expected name. // Try to find results for each expected name.
By("looking for the results for each expected name") By("looking for the results for each expected name")
var failed []string var failed []string
for try := 1; try < 100; try++ {
expectNoError(wait.Poll(time.Second*2, time.Second*60, func() (bool, error) {
failed = []string{} failed = []string{}
for _, name := range namesToResolve { for _, name := range namesToResolve {
_, err := c.Get(). _, err := c.Get().
@ -148,20 +150,20 @@ var _ = Describe("Services", func() {
Do().Raw() Do().Raw()
if err != nil { if err != nil {
failed = append(failed, name) failed = append(failed, name)
fmt.Printf("Lookup using %s for %s failed: %v\n", pod.Name, name, err) Logf("Lookup using %s for %s failed: %v\n", pod.Name, name, err)
} }
} }
if len(failed) == 0 { if len(failed) == 0 {
break return true, nil
} }
fmt.Printf("lookups using %s failed for: %v\n", pod.Name, failed) Logf("Lookups using %s failed for: %v\n", pod.Name, failed)
time.Sleep(10 * time.Second) return false, nil
} }))
Expect(len(failed)).To(Equal(0)) Expect(len(failed)).To(Equal(0))
// TODO: probe from the host, too. // TODO: probe from the host, too.
fmt.Printf("DNS probes using %s succeeded\n", pod.Name) Logf("DNS probes using %s succeeded\n", pod.Name)
}) })
It("should provide RW and RO services", func() { It("should provide RW and RO services", func() {