Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for tpCounts (0.17 sec)

  1. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    			count := countPodsMatchSelector(nodeInfo.Pods, c.Selector, pod.Namespace)
    			tpCounts[pair] = count
    		}
    		tpCountsByNode[i] = tpCounts
    	}
    	pl.parallelizer.Until(ctx, len(allNodes), processNode, pl.Name())
    
    	for _, tpCounts := range tpCountsByNode {
    		for tp, count := range tpCounts {
    			s.TpPairToMatchNum[tp] += count
    		}
    	}
    	s.TpKeyToDomainsNum = make(map[string]int, len(constraints))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/podtopologyspread/scoring.go

    			// continue to avoid unnecessary calculation.
    			// Per-node counts are also skipped, as they are done during Score.
    			tpCount := state.TopologyPairToPodCounts[pair]
    			if tpCount == nil {
    				continue
    			}
    			count := countPodsMatchSelector(nodeInfo.Pods, c.Selector, pod.Namespace)
    			atomic.AddInt64(tpCount, int64(count))
    		}
    	}
    	pl.parallelizer.Until(ctx, len(allNodes), processAllNode, pl.Name())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
Back to top