Skip to content

Commit e855753

Browse files
authored
Merge pull request kubernetes#126848 from carlory/ref-124136
Fix hotloop once the watch closes
2 parents 3ffc177 + 231d9af commit e855753

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

test/integration/volume/persistent_volumes_test.go

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1068,7 +1068,16 @@ func TestPersistentVolumeProvisionMultiPVCs(t *testing.T) {
10681068
}
10691069
for {
10701070
select {
1071-
case event := <-w.ResultChan():
1071+
case event, ok := <-w.ResultChan():
1072+
if !ok {
1073+
klog.Info("Event watch channel closed")
1074+
w, err = testClient.EventsV1().Events(ns.Name).Watch(tCtx, metav1.ListOptions{})
1075+
if err != nil {
1076+
klog.ErrorS(err, "Failed to restart event watch")
1077+
return
1078+
}
1079+
continue
1080+
}
10721081
reportToArtifacts(t.Name()+"-events.text", event.Object)
10731082
case <-tCtx.Done():
10741083
w.Stop()

0 commit comments

Comments
 (0)