From 4b4c20be7cad9e950ad2a58c2c2e971814b2b78b Mon Sep 17 00:00:00 2001 From: Ted Yu Date: Sat, 6 Apr 2019 13:48:49 -0700 Subject: [PATCH] Use read lock for PendingPods --- pkg/scheduler/internal/queue/scheduling_queue.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/scheduler/internal/queue/scheduling_queue.go b/pkg/scheduler/internal/queue/scheduling_queue.go index edd3d721530..4b442808a06 100644 --- a/pkg/scheduler/internal/queue/scheduling_queue.go +++ b/pkg/scheduler/internal/queue/scheduling_queue.go @@ -702,8 +702,8 @@ func (p *PriorityQueue) NominatedPodsForNode(nodeName string) []*v1.Pod { // PendingPods returns all the pending pods in the queue. This function is // used for debugging purposes in the scheduler cache dumper and comparer. func (p *PriorityQueue) PendingPods() []*v1.Pod { - p.lock.Lock() - defer p.lock.Unlock() + p.lock.RLock() + defer p.lock.RUnlock() result := []*v1.Pod{} for _, pInfo := range p.activeQ.List() { result = append(result, pInfo.(*podInfo).pod)