github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-21 18:11:22 +00:00
Code Issues Projects Releases Wiki Activity

got rid of ClusterEventReg with generating ClusterEvent objects on the fly

Browse Source
This commit is contained in:
Alexander Minbaev
2021-03-16 17:08:19 -05:00
parent 46563b0abe
commit 8325c6b0da
5 changed files with 120 additions and 119 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/scheduler/eventhandlers.go
View File

@@ -119,8 +119,8 @@ func (sched *Scheduler) updateNodeInCache(oldObj, newObj interface{}) {
nodeInfo := sched.SchedulerCache.UpdateNode(oldNode, newNode)
// Only requeue unschedulable pods if the node became more schedulable.
if event := nodeSchedulingPropertiesChange(newNode, oldNode); event != "" {
sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(event, preCheckForNode(nodeInfo))
if event := nodeSchedulingPropertiesChange(newNode, oldNode); event != nil {
sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(*event, preCheckForNode(nodeInfo))
}
}
@@ -412,24 +412,24 @@ func addAllEventHandlers(
)
}
func nodeSchedulingPropertiesChange(newNode *v1.Node, oldNode *v1.Node) string {
func nodeSchedulingPropertiesChange(newNode *v1.Node, oldNode *v1.Node) *framework.ClusterEvent {
if nodeSpecUnschedulableChanged(newNode, oldNode) {
return queue.NodeSpecUnschedulableChange
return &queue.NodeSpecUnschedulableChange
}
if nodeAllocatableChanged(newNode, oldNode) {
return queue.NodeAllocatableChange
return &queue.NodeAllocatableChange
}
if nodeLabelsChanged(newNode, oldNode) {
return queue.NodeLabelChange
return &queue.NodeLabelChange
}
if nodeTaintsChanged(newNode, oldNode) {
return queue.NodeTaintChange
return &queue.NodeTaintChange
}
if nodeConditionsChanged(newNode, oldNode) {
return queue.NodeConditionChange
return &queue.NodeConditionChange
}
return ""
return nil
}
func nodeAllocatableChanged(newNode *v1.Node, oldNode *v1.Node) bool {