github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 03:41:45 +00:00
Code Issues Projects Releases Wiki Activity

test: e2e: fix race in pods test

Browse Source
This commit is contained in:
Seth Jennings 2020-10-02 14:11:21 -05:00
parent 112dbd5586
commit b7c74338e8
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/node/pods.go
View File

@ -263,6 +263,7 @@ var _ = SIGDescribe("Pods Extended", func() {
start := time.Now()
created := podClient.Create(pod)
ch := make(chan []watch.Event)
waitForWatch := make(chan struct{})
go func() {
defer ginkgo.GinkgoRecover()
defer close(ch)
@ -275,6 +276,7 @@ var _ = SIGDescribe("Pods Extended", func() {
return
}
defer w.Stop()
close(waitForWatch)
events := []watch.Event{
{Type: watch.Added, Object: created},
}
@ -291,6 +293,10 @@ var _ = SIGDescribe("Pods Extended", func() {
ch <- events
}()
select {
case <-ch: // in case the goroutine above exits before establishing the watch
case <-waitForWatch: // when the watch is established
}
t := time.Duration(rand.Intn(delay)) * time.Millisecond
time.Sleep(t)
err := podClient.Delete(context.TODO(), pod.Name, metav1.DeleteOptions{})