github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-14 06:15:45 +00:00
Code Issues Projects Releases Wiki Activity

Fast return when no any matched anti-affinity terms

Browse Source 
When check the incoming pod's anti-affinity rules, there is change to
return early when there is no any matched anti-affinity terms in the
whole cluster.
This commit is contained in:
He Jie Xu 2020-08-10 14:48:26 +08:00
parent 9b78bd5979
commit 75ccb90407
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/scheduler/framework/plugins/interpodaffinity/filtering.go
View File

@ -330,11 +330,13 @@ func satisfyExistingPodsAntiAffinity(state *preFilterState, nodeInfo *framework.
// Checks if the node satisifies the incoming pod's anti-affinity rules. // Checks if the node satisifies the incoming pod's anti-affinity rules.
func satisfyPodAntiAffinity(state *preFilterState, nodeInfo *framework.NodeInfo) bool { func satisfyPodAntiAffinity(state *preFilterState, nodeInfo *framework.NodeInfo) bool {
for _, term := range state.podInfo.RequiredAntiAffinityTerms { if len(state.topologyToMatchedAntiAffinityTerms) > 0 {
if topologyValue, ok := nodeInfo.Node().Labels[term.TopologyKey]; ok { for _, term := range state.podInfo.RequiredAntiAffinityTerms {
tp := topologyPair{key: term.TopologyKey, value: topologyValue} if topologyValue, ok := nodeInfo.Node().Labels[term.TopologyKey]; ok {
if state.topologyToMatchedAntiAffinityTerms[tp] > 0 { tp := topologyPair{key: term.TopologyKey, value: topologyValue}
return false if state.topologyToMatchedAntiAffinityTerms[tp] > 0 {
return false
}
} }
} }
} }