From 454d443b72dad5956f2acb71413ed0b6f1098c26 Mon Sep 17 00:00:00 2001 From: Markus Lehtonen Date: Fri, 26 Jul 2024 10:29:15 +0300 Subject: [PATCH] nfd-gc: check that node informer cache sync succeeded --- pkg/nfd-gc/nfd-gc.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/pkg/nfd-gc/nfd-gc.go b/pkg/nfd-gc/nfd-gc.go index fd0e7f4a91..a092aa1b03 100644 --- a/pkg/nfd-gc/nfd-gc.go +++ b/pkg/nfd-gc/nfd-gc.go @@ -18,6 +18,7 @@ package nfdgarbagecollector import ( "context" + "fmt" "time" topologyclientset "github.com/k8stopologyawareschedwg/noderesourcetopology-api/pkg/generated/clientset/versioned" @@ -208,7 +209,15 @@ func (n *nfdGarbageCollector) startNodeInformer() error { // start informers n.factory.Start(n.stopChan) - n.factory.WaitForCacheSync(n.stopChan) + + start := time.Now() + ret := n.factory.WaitForCacheSync(n.stopChan) + for res, ok := range ret { + if !ok { + return fmt.Errorf("node informer cache failed to sync (%s)", res) + } + } + klog.InfoS("node informer cache synced", "duration", time.Since(start)) return nil }