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

Merge pull request #20042 from thockin/logs-for-19665

Browse Source 
slightly better logs in service e2e
This commit is contained in:
Zach Loafman 2016-01-23 07:33:11 -08:00
commit c3fc36ee95
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
test/e2e/service.go
View File

@ -1405,7 +1405,7 @@ func verifyServeHostnameServiceUp(c *client.Client, ns, host string, expectedPod
// Loop a bunch of times - the proxy is randomized, so we want a good // Loop a bunch of times - the proxy is randomized, so we want a good
// chance of hitting each backend at least once. // chance of hitting each backend at least once.
command := fmt.Sprintf( command := fmt.Sprintf(
"for i in $(seq 1 %d); do wget -q -T 1 -O - http://%s:%d || true; echo; done", "for i in $(seq 1 %d); do wget -q -T 1 -O - http://%s:%d 2>&1 || true; echo; done",
50*len(expectedPods), serviceIP, servicePort) 50*len(expectedPods), serviceIP, servicePort)
commands := []func() string{ commands := []func() string{
@ -1435,26 +1435,21 @@ func verifyServeHostnameServiceUp(c *client.Client, ns, host string, expectedPod
By(fmt.Sprintf("verifying service has %d reachable backends", len(expectedPods))) By(fmt.Sprintf("verifying service has %d reachable backends", len(expectedPods)))
for _, cmdFunc := range commands { for _, cmdFunc := range commands {
passed := false passed := false
pods := []string{} gotPods := []string{}
// Retry cmdFunc for a while // Retry cmdFunc for a while
for start := time.Now(); time.Since(start) < time.Minute; time.Sleep(5 * time.Second) { for start := time.Now(); time.Since(start) < time.Minute; time.Sleep(5 * time.Second) {
pods = strings.Split(strings.TrimSpace(cmdFunc()), "\n") pods := strings.Split(strings.TrimSpace(cmdFunc()), "\n")
// Uniq pods before the sort because inserting them into a set // Uniq pods before the sort because inserting them into a set
// (which is implemented using dicts) can re-order them. // (which is implemented using dicts) can re-order them.
uniquePods := sets.String{} gotPods := sets.NewString(pods...).List()
for _, name := range pods { if api.Semantic.DeepEqual(gotPods, expectedPods) {
uniquePods.Insert(name)
}
sortedPods := uniquePods.List()
sort.StringSlice(sortedPods).Sort()
if api.Semantic.DeepEqual(sortedPods, expectedPods) {
passed = true passed = true
break break
} }
Logf("Waiting for expected pods for %s: %v, got: %v", serviceIP, expectedPods, sortedPods) Logf("Waiting for expected pods for %s: %v, got: %v", serviceIP, expectedPods, gotPods)
} }
if !passed { if !passed {
return fmt.Errorf("service verification failed for:\n %s, expected to retrieve pods %v, only retrieved %v", serviceIP, expectedPods, pods) return fmt.Errorf("service verification failed for: %s, expected %v, got %v", serviceIP, expectedPods, gotPods)
} }
} }
return nil return nil