sched: Optimize anti-affinity node label check

utam0k · utam0k · commit eb7733e92a3b · 2025-06-03T20:23:10.000+09:00
Signed-off-by: utam0k &lt;k0ma@utam0k.jp&gt;
diff --git a/pkg/scheduler/framework/plugins/interpodaffinity/filtering.go b/pkg/scheduler/framework/plugins/interpodaffinity/filtering.go
@@ -351,12 +351,13 @@ func getPreFilterState(cycleState fwk.CycleState) (*preFilterState, error) {
 // terms indicated by the existing pods.
 func satisfyExistingPodsAntiAffinity(state *preFilterState, nodeInfo *framework.NodeInfo) bool {
 	if len(state.existingAntiAffinityCounts) > 0 {
-		// Iterate over topology pairs to get any of the pods being affected by
-		// the scheduled pod anti-affinity terms
-		for topologyKey, topologyValue := range nodeInfo.Node().Labels {
-			tp := topologyPair{key: topologyKey, value: topologyValue}
-			if state.existingAntiAffinityCounts[tp] > 0 {
-				return false
+		// Check if this node matches any anti-affinity topology pairs.
+		nodeLabels := nodeInfo.Node().Labels
+		for tp, count := range state.existingAntiAffinityCounts {
+			if count > 0 {
+				if nodeValue, ok := nodeLabels[tp.key]; ok && nodeValue == tp.value {
+					return false
+				}
 			}
 		}
 	}
