diff --git a/pkg/client/cache/delta_fifo.go b/pkg/client/cache/delta_fifo.go index 5a7f4a90f62..c374e2ee356 100644 --- a/pkg/client/cache/delta_fifo.go +++ b/pkg/client/cache/delta_fifo.go @@ -496,8 +496,8 @@ func (f *DeltaFIFO) Replace(list []interface{}, resourceVersion string) error { // Resync will send a sync event for each item func (f *DeltaFIFO) Resync() error { - f.lock.RLock() - defer f.lock.RUnlock() + f.lock.Lock() + defer f.lock.Unlock() for _, k := range f.knownObjects.ListKeys() { obj, exists, err := f.knownObjects.GetByKey(k) if err != nil {