From 3e69c5a9b8ce72ec81b9e853e32d19302a1564c3 Mon Sep 17 00:00:00 2001 From: Daniel Smith Date: Wed, 17 Aug 2016 17:34:49 -0700 Subject: [PATCH] queueActionLocked requires write lock --- pkg/client/cache/delta_fifo.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 {