github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Improve density test to log unscheduled pods

pull/6/head
Wojciech Tyczynski 2015-03-26 17:00:12 +01:00
parent 8183a4805e
commit 13feb77288
1 changed files with 22 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
test/e2e/density.go
View File

@ -27,6 +27,7 @@ import (
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
"github.com/GoogleCloudPlatform/kubernetes/pkg/util/wait"
"github.com/golang/glog"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
@ -105,7 +106,7 @@ func RunRC(c *client.Client, name string, ns, image string, replicas int) {
current = len(pods.Items)
failCount := 5
for same < failCount && current < replicas {
Logf("Controller %s: Found %d pods out of %d", name, current, replicas)
glog.Infof("Controller %s: Found %d pods out of %d", name, current, replicas)
if last < current {
same = 0
} else if last == current {
@ -115,7 +116,7 @@ func RunRC(c *client.Client, name string, ns, image string, replicas int) {
}
if same >= failCount {
Logf("No pods submitted for the last %d checks", failCount)
glog.Infof("No pods submitted for the last %d checks", failCount)
}
last = current
@ -125,32 +126,39 @@ func RunRC(c *client.Client, name string, ns, image string, replicas int) {
current = len(pods.Items)
}
Expect(current).To(Equal(replicas))
Logf("Controller %s: Found %d pods out of %d", name, current, replicas)
glog.Infof("Controller %s: Found %d pods out of %d", name, current, replicas)
By("Waiting for each pod to be running")
same = 0
last = 0
failCount = 6
unknown := 0
pending := 0
failCount = 10
current = 0
for same < failCount && current < replicas {
current = 0
pending = 0
unknown = 0
waiting := 0
pending := 0
unknown := 0
time.Sleep(10 * time.Second)
for _, pod := range pods.Items {
p, err := c.Pods(ns).Get(pod.Name)
Expect(err).NotTo(HaveOccurred())
currentPods, listErr := c.Pods(ns).List(label)
Expect(listErr).NotTo(HaveOccurred())
if len(currentPods.Items) != len(pods.Items) {
Failf("Number of reported pods changed: %d vs %d", len(currentPods.Items), len(pods.Items))
}
for _, p := range currentPods.Items {
if p.Status.Phase == api.PodRunning {
current++
} else if p.Status.Phase == api.PodPending {
pending++
if p.Status.Host == "" {
waiting++
} else {
pending++
}
} else if p.Status.Phase == api.PodUnknown {
unknown++
}
}
Logf("Pod States: %d running, %d pending, %d unknown ", current, pending, unknown)
glog.Infof("Pod States: %d running, %d pending, %d waiting, %d unknown ", current, pending, waiting, unknown)
if last < current {
same = 0
} else if last == current {
@ -159,7 +167,7 @@ func RunRC(c *client.Client, name string, ns, image string, replicas int) {
Failf("Number of running pods dropped from %d to %d", last, current)
}
if same >= failCount {
Logf("No pods started for the last %d checks", failCount)
glog.Infof("No pods started for the last %d checks", failCount)
}
last = current
}