mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
update comments of some funs in scheduling_queue
This commit is contained in:
parent
82c7c86998
commit
02e217759e
@ -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.
|
// to activeQ.
|
||||||
func (p *PriorityQueue) flushUnschedulableQLeftover() {
|
func (p *PriorityQueue) flushUnschedulableQLeftover() {
|
||||||
p.lock.Lock()
|
p.lock.Lock()
|
||||||
@ -537,8 +537,8 @@ func (p *PriorityQueue) AssignedPodUpdated(pod *v1.Pod) {
|
|||||||
p.lock.Unlock()
|
p.lock.Unlock()
|
||||||
}
|
}
|
||||||
|
|
||||||
// MoveAllToActiveOrBackoffQueue moves all pods from unschedulableQ to activeQ. This
|
// MoveAllToActiveOrBackoffQueue moves all pods from unschedulableQ to activeQ or backoffQ.
|
||||||
// function adds all pods and then signals the condition variable to ensure that
|
// 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
|
// 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.
|
// queue and the head is the highest priority pod.
|
||||||
func (p *PriorityQueue) MoveAllToActiveOrBackoffQueue(event string) {
|
func (p *PriorityQueue) MoveAllToActiveOrBackoffQueue(event string) {
|
||||||
|
Loading…
Reference in New Issue
Block a user