From 00e31ce565aa48222fe0bd05ca245c5e0ea6d3ba Mon Sep 17 00:00:00 2001 From: Yuan Chen Date: Thu, 22 Jul 2021 20:39:00 -0700 Subject: [PATCH] Fix incorrect comments in scheduler_queue.go --- pkg/scheduler/internal/queue/scheduling_queue.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/scheduler/internal/queue/scheduling_queue.go b/pkg/scheduler/internal/queue/scheduling_queue.go index b0bac0a128b..33a6ca68c32 100644 --- a/pkg/scheduler/internal/queue/scheduling_queue.go +++ b/pkg/scheduler/internal/queue/scheduling_queue.go @@ -48,8 +48,8 @@ import ( ) const ( - // If the pod stays in unschedulableQ longer than the unschedulableQTimeInterval, - // the pod will be moved from unschedulableQ to activeQ. + // If a pod stays in unschedulableQ longer than unschedulableQTimeInterval, + // the pod will be moved from unschedulableQ to backoffQ or activeQ. unschedulableQTimeInterval = 60 * time.Second queueClosed = "scheduling queue is closed" @@ -434,8 +434,8 @@ func (p *PriorityQueue) flushBackoffQCompleted() { } } -// flushUnschedulableQLeftover moves pod which stays in unschedulableQ longer than the unschedulableQTimeInterval -// to activeQ. +// flushUnschedulableQLeftover moves pods which stay in unschedulableQ longer than unschedulableQTimeInterval +// to backoffQ or activeQ. func (p *PriorityQueue) flushUnschedulableQLeftover() { p.lock.Lock() defer p.lock.Unlock()