github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-30 22:35:10 +00:00
Code Issues Projects Releases Wiki Activity

handle context in process loop

Browse Source 
Kubernetes-commit: f67d30b3529ea970dd5fd069eaddfc7f61d74169
This commit is contained in:
Keisuke Ishigami 2025-05-29 00:34:43 +09:00 committed by Kubernetes Publisher
parent 660181394a
commit 03728c1ebe
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tools/cache/controller.go vendored
View File

@ -204,13 +204,15 @@ func (c *controller) LastSyncResourceVersion() string {
// concurrently.
func (c *controller) processLoop(ctx context.Context) {
for {
// TODO: Plumb through the ctx so that this can
// actually exit when the controller is stopped. Or just give up on this stuff
// ever being stoppable.
_, err := c.config.Queue.Pop(PopProcessFunc(c.config.Process))
if err != nil {
if err == ErrFIFOClosed {
return
select {
case <-ctx.Done():
return
default:
_, err := c.config.Queue.Pop(PopProcessFunc(c.config.Process))
if err != nil {
if err == ErrFIFOClosed {
return
}
}
}
}