diff --git a/pkg/controller/resourceclaim/controller.go b/pkg/controller/resourceclaim/controller.go index 148ad7d57db..b3497a94abc 100644 --- a/pkg/controller/resourceclaim/controller.go +++ b/pkg/controller/resourceclaim/controller.go @@ -392,8 +392,8 @@ func (ec *Controller) Run(ctx context.Context, workers int) { defer ec.queue.ShutDown() logger := klog.FromContext(ctx) - logger.Info("Starting ephemeral volume controller") - defer logger.Info("Shutting down ephemeral volume controller") + logger.Info("Starting resource claim controller") + defer logger.Info("Shutting down resource claim controller") eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) eventBroadcaster.StartLogging(klog.Infof) @@ -401,7 +401,7 @@ func (ec *Controller) Run(ctx context.Context, workers int) { ec.recorder = eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "resource_claim"}) defer eventBroadcaster.Shutdown() - if !cache.WaitForNamedCacheSync("ephemeral", ctx.Done(), ec.podSynced, ec.claimsSynced) { + if !cache.WaitForNamedCacheSync("resource_claim", ctx.Done(), ec.podSynced, ec.podSchedulingSynced, ec.claimsSynced, ec.templatesSynced) { return } diff --git a/pkg/controller/resourceclaim/controller_test.go b/pkg/controller/resourceclaim/controller_test.go index 59e913cffeb..28d5debe155 100644 --- a/pkg/controller/resourceclaim/controller_test.go +++ b/pkg/controller/resourceclaim/controller_test.go @@ -35,7 +35,6 @@ import ( "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" k8stesting "k8s.io/client-go/testing" - "k8s.io/client-go/tools/cache" "k8s.io/component-base/metrics/testutil" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/controller" @@ -520,14 +519,13 @@ func TestSyncHandler(t *testing.T) { } // Ensure informers are up-to-date. - go informerFactory.Start(ctx.Done()) + informerFactory.Start(ctx.Done()) stopInformers := func() { cancel() informerFactory.Shutdown() } defer stopInformers() informerFactory.WaitForCacheSync(ctx.Done()) - cache.WaitForCacheSync(ctx.Done(), podInformer.Informer().HasSynced, claimInformer.Informer().HasSynced, templateInformer.Informer().HasSynced) // Add claims that only exist in the mutation cache. for _, claim := range tc.claimsInCache {