|
@@ -251,6 +251,8 @@ func (g *genericScheduler) Schedule(pod *v1.Pod, nodeLister algorithm.NodeLister
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ klog.Infof("Selecting Socket")
|
|
|
|
+
|
|
priorityList, err := PrioritizeNodes(pod, g.nodeInfoSnapshot.NodeInfoMap, metaPrioritiesInterface, socketPrioritizers, filteredNodes, g.extenders)
|
|
priorityList, err := PrioritizeNodes(pod, g.nodeInfoSnapshot.NodeInfoMap, metaPrioritiesInterface, socketPrioritizers, filteredNodes, g.extenders)
|
|
//end-custom
|
|
//end-custom
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -265,7 +267,6 @@ func (g *genericScheduler) Schedule(pod *v1.Pod, nodeLister algorithm.NodeLister
|
|
// ------------------START-CUSTOM-----------------------
|
|
// ------------------START-CUSTOM-----------------------
|
|
// -----------------------------------------------------
|
|
// -----------------------------------------------------
|
|
//trace.Step("Selecting socket")
|
|
//trace.Step("Selecting socket")
|
|
- klog.Infof("Selecting Socket")
|
|
|
|
hosts, err := g.selectHostOnWinningSocket(priorityList)
|
|
hosts, err := g.selectHostOnWinningSocket(priorityList)
|
|
|
|
|
|
//declare a subset of the snapshot of all available nodes
|
|
//declare a subset of the snapshot of all available nodes
|