diff --git a/vendor/k8s.io/kubernetes/pkg/controller/resourcequota/resource_quota_controller.go b/vendor/k8s.io/kubernetes/pkg/controller/resourcequota/resource_quota_controller.go index 2d864fd3ab62..7855d75f55fb 100644 --- a/vendor/k8s.io/kubernetes/pkg/controller/resourcequota/resource_quota_controller.go +++ b/vendor/k8s.io/kubernetes/pkg/controller/resourcequota/resource_quota_controller.go @@ -240,15 +240,13 @@ func (rq *ResourceQuotaController) addQuota(obj interface{}) { // worker runs a worker thread that just dequeues items, processes them, and marks them done. func (rq *ResourceQuotaController) worker(queue workqueue.RateLimitingInterface) func() { workFunc := func() bool { - - rq.workerLock.RLock() - defer rq.workerLock.RUnlock() - key, quit := queue.Get() if quit { return true } defer queue.Done(key) + rq.workerLock.RLock() + defer rq.workerLock.RUnlock() err := rq.syncHandler(key.(string)) if err == nil { queue.Forget(key)