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

Merge pull request #117534 from Mskxn/fix_watcher

Browse Source 
stop watcher when error occurs
This commit is contained in:
Kubernetes Prow Robot 2023-04-27 04:56:14 -07:00 committed by GitHub
commit 041bb9a56c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
staging/src/k8s.io/client-go/tools/watch/informerwatcher_test.go
View File

@ -302,7 +302,7 @@ func TestInformerWatcherDeletedFinalStateUnknown(t *testing.T) {
return retval, nil return retval, nil
}, },
WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
w := watch.NewFake() w := watch.NewRaceFreeFake()
if options.ResourceVersion == "1" { if options.ResourceVersion == "1" {
go func() { go func() {
// Close with a "Gone" error when trying to start a watch from the first list // Close with a "Gone" error when trying to start a watch from the first list
@ -315,6 +315,7 @@ func TestInformerWatcherDeletedFinalStateUnknown(t *testing.T) {
}, },
} }
_, _, w, done := NewIndexerInformerWatcher(lw, &corev1.Secret{}) _, _, w, done := NewIndexerInformerWatcher(lw, &corev1.Secret{})
defer w.Stop()
// Expect secret add // Expect secret add
select { select {