github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 04:54:54 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #132005 from kei01234kei/handle_context_in_processloop

Browse Source 
Handle context in the process loop
This commit is contained in:
Kubernetes Prow Robot
2025-07-06 17:13:25 -07:00
committed by GitHub
parent 116cfc0c5f 5cca037927
commit 43a30ef17b
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
staging/src/k8s.io/client-go/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.Pop(PopProcessFunc(c.config.Process))
if err != nil {
if errors.Is(err, ErrFIFOClosed) {
return
}
}
}
}