diff --git a/pkg/scheduler/internal/queue/scheduling_queue.go b/pkg/scheduler/internal/queue/scheduling_queue.go index b969e3b3eac..2426702a83f 100644 --- a/pkg/scheduler/internal/queue/scheduling_queue.go +++ b/pkg/scheduler/internal/queue/scheduling_queue.go @@ -393,7 +393,7 @@ func (p *PriorityQueue) flushBackoffQCompleted() { } } -// flushUnschedulableQLeftover moves pod which stays in unschedulableQ longer than the durationStayUnschedulableQ +// flushUnschedulableQLeftover moves pod which stays in unschedulableQ longer than the unschedulableQTimeInterval // to activeQ. func (p *PriorityQueue) flushUnschedulableQLeftover() { p.lock.Lock() @@ -537,8 +537,8 @@ func (p *PriorityQueue) AssignedPodUpdated(pod *v1.Pod) { p.lock.Unlock() } -// MoveAllToActiveOrBackoffQueue moves all pods from unschedulableQ to activeQ. This -// function adds all pods and then signals the condition variable to ensure that +// MoveAllToActiveOrBackoffQueue moves all pods from unschedulableQ to activeQ or backoffQ. +// This function adds all pods and then signals the condition variable to ensure that // if Pop() is waiting for an item, it receives it after all the pods are in the // queue and the head is the highest priority pod. func (p *PriorityQueue) MoveAllToActiveOrBackoffQueue(event string) {