Commit 36740719 authored by PingWang's avatar PingWang

exec gofmt -s

parent b9736703
......@@ -140,6 +140,7 @@ func findNodesThatFit(pod *api.Pod, nodeNameToInfo map[string]*schedulercache.No
filtered := []api.Node{}
failedPredicateMap := FailedPredicateMap{}
//wp:#25606
if len(predicateFuncs) == 0 {
filtered = nodes.Items
} else {
......@@ -148,7 +149,7 @@ func findNodesThatFit(pod *api.Pod, nodeNameToInfo map[string]*schedulercache.No
checkNode := func(i int) {
nodeName := nodes.Items[i].Name
fits, failedPredicate, err := podFitsOnNode(pod, nodeNameToInfo[nodeName], predicateFuncs)
predicateResultLock.Lock()
defer predicateResultLock.Unlock()
if err != nil {
......@@ -173,6 +174,24 @@ func findNodesThatFit(pod *api.Pod, nodeNameToInfo map[string]*schedulercache.No
if err != nil {
return api.NodeList{}, FailedPredicateMap{}, err
}
//add the extender failed info to failedPredicateMap wp:#25797
for _, filteredNode := range filtered {
nodeIn := false
for _, exNode := range filteredList.Items {
if filteredNode.Name == exNode.Name {
nodeIn = true
break
}
}
if !nodeIn {
if re, ok := extender.(*HTTPExtender); ok {
failedPredicateMap[filteredNode.Name] = fmt.Sprintf("%s, %s", re.extenderURL, re.filterVerb)
} else {
failedPredicateMap[filteredNode.Name] = "extender failed"
}
}
}
filtered = filteredList.Items
if len(filtered) == 0 {
break
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment