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

Bounded the loop waiting for all events to be logged and print a warning

Browse Source 
if not all are logged 10 minutes after all pods are started #6637
This commit is contained in:
Robert Rati 2015-04-20 12:59:30 -04:00
parent 93d1040fcd
commit 23c5b7714e
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
test/e2e/density.go
View File

@ -269,11 +269,13 @@ var _ = Describe("Density", func() {
ns = "e2e-density" + nameStr ns = "e2e-density" + nameStr
RCName = "my-hostname-density" + nameStr RCName = "my-hostname-density" + nameStr
RunRC(c, RCName, ns, "gcr.io/google_containers/pause:go", totalPods) RunRC(c, RCName, ns, "gcr.io/google_containers/pause:go", totalPods)
By("waiting for all events to be recorded")
By("Waiting for all events to be recorded")
last := -1 last := -1
current := 0 current := 0
var events *api.EventList var events *api.EventList
for last < current { timeout := 10 * time.Minute
for start := time.Now(); last < current && time.Since(start) < timeout; time.Sleep(10 * time.Second) {
e, err := c.Events(ns).List( e, err := c.Events(ns).List(
labels.Everything(), labels.Everything(),
fields.Set{ fields.Set{
@ -284,12 +286,14 @@ var _ = Describe("Density", func() {
last = current last = current
current = len(e.Items) current = len(e.Items)
events = e events = e
time.Sleep(10 * time.Second) }
if current != last {
Logf("Warning: Not all events were recorded after waiting %.2f minutes", timeout.Minutes())
} }
Logf("Found %d events", current) Logf("Found %d events", current)
// Verify no pods were killed or failed to start // Verify there were no pod killings or failures
By("verifying no pods were killed or failed to start") By("Verifying there were no pod killings or failures")
for _, e := range events.Items { for _, e := range events.Items {
for _, s := range []string{"kill", "fail"} { for _, s := range []string{"kill", "fail"} {
Expect(e.Reason).NotTo(ContainSubstring(s), "event:' %s', reason: '%s', message: '%s', field path: '%s'", e, e.ObjectMeta.Name, e.Message, e.InvolvedObject.FieldPath) Expect(e.Reason).NotTo(ContainSubstring(s), "event:' %s', reason: '%s', message: '%s', field path: '%s'", e, e.ObjectMeta.Name, e.Message, e.InvolvedObject.FieldPath)