diff --git a/staging/src/k8s.io/cloud-provider/controllers/route/route_controller.go b/staging/src/k8s.io/cloud-provider/controllers/route/route_controller.go index 26e2c36d0a0..96cf1a465ee 100644 --- a/staging/src/k8s.io/cloud-provider/controllers/route/route_controller.go +++ b/staging/src/k8s.io/cloud-provider/controllers/route/route_controller.go @@ -104,7 +104,7 @@ func (rc *RouteController) Run(ctx context.Context, syncPeriod time.Duration, co controllerManagerMetrics.ControllerStarted("route") defer controllerManagerMetrics.ControllerStopped("route") - if !cache.WaitForNamedCacheSync("route", ctx.Done(), rc.nodeListerSynced) { + if !cache.WaitForNamedCacheSyncWithContext(ctx, rc.nodeListerSynced) { return } diff --git a/staging/src/k8s.io/cloud-provider/controllers/service/controller.go b/staging/src/k8s.io/cloud-provider/controllers/service/controller.go index 97764cb793c..8a3daa84899 100644 --- a/staging/src/k8s.io/cloud-provider/controllers/service/controller.go +++ b/staging/src/k8s.io/cloud-provider/controllers/service/controller.go @@ -237,7 +237,7 @@ func (c *Controller) Run(ctx context.Context, workers int, controllerManagerMetr controllerManagerMetrics.ControllerStarted("service") defer controllerManagerMetrics.ControllerStopped("service") - if !cache.WaitForNamedCacheSync("service", ctx.Done(), c.serviceListerSynced, c.nodeListerSynced) { + if !cache.WaitForNamedCacheSyncWithContext(ctx, c.serviceListerSynced, c.nodeListerSynced) { return }