- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for tpCounts (0.09 sec)
-
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) -
pkg/volume/util/fsquota/common/quota_common_linux_impl.go
func runXFSQuotaCommand(mountpoint string, command string) (string, error) { tmpMounts, err := os.CreateTemp("", "mounts") if err != nil { return "", fmt.Errorf("cannot create temporary mount file: %v", err) } tmpMountsFileName := tmpMounts.Name() defer tmpMounts.Close() defer os.Remove(tmpMountsFileName) mounts, err := os.Open(MountsFile) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 9.1K bytes - Viewed (0) -
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)