github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-31 23:00:26 +00:00
Code Issues Projects Releases Wiki Activity

reset listenersStarted

Browse Source 
for correctness. technically shouldnt be an issue since restarting a stopped processor is not supported

Kubernetes-commit: 3a81341cfa6f7e2ca1b9bfc195c567dcdfaa4dea
This commit is contained in:
Alexander Zielenski 2022-08-08 14:19:37 -07:00 committed by Kubernetes Publisher
parent 449817f7b5
commit 0f4a6cf319
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tools/cache/shared_informer.go vendored
View File

@ -754,6 +754,10 @@ func (p *sharedProcessor) run(stopCh <-chan struct{}) {
// Wipe out list of listeners since they are now closed // Wipe out list of listeners since they are now closed
// (processorListener cannot be re-used) // (processorListener cannot be re-used)
p.listeners = nil p.listeners = nil
// Reset to false since there are nil listeners, also to block new listeners
// that are added from being run now that the processor was stopped
p.listenersStarted = false
}() }()
p.wg.Wait() // Wait for all .pop() and .run() to stop p.wg.Wait() // Wait for all .pop() and .run() to stop