- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 71 for num_nodes (0.43 sec)
-
pkg/scheduler/internal/cache/node_tree.go
// over nodes in a round robin fashion. func (nt *nodeTree) list() ([]string, error) { if len(nt.zones) == 0 { return nil, nil } nodesList := make([]string, 0, nt.numNodes) numExhaustedZones := 0 nodeIndex := 0 for len(nodesList) < nt.numNodes { if numExhaustedZones >= len(nt.zones) { // all zones are exhausted. return nodesList, errors.New("all zones exhausted before reaching count of nodes expected") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
if numaid != nodeWithoutTopology { NUMANodes := []*pluginapi.NUMANode{{ID: numaid}} if pDev, ok := devicePluginMap[devID]; ok && pDev.Topology != nil { if nodes := pDev.Topology.GetNodes(); nodes != nil { NUMANodes = append(NUMANodes, nodes...) } } // ID and Healthy are not relevant here. topology = &pluginapi.TopologyInfo{Nodes: NUMANodes} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
samples/kind-lb/setupkind.sh
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 02 19:08:19 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/policy_test.go
expected: TopologyHint{ NUMANodeAffinity: NewTestBitMask(numaNodes...), Preferred: true, }, }, { name: "HintProvider returns empty non-nil map[string][]TopologyHint", hp: []HintProvider{ &mockHintProvider{ map[string][]TopologyHint{}, }, }, expected: TopologyHint{ NUMANodeAffinity: NewTestBitMask(numaNodes...), Preferred: true, }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:08 UTC 2022 - 34.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
// candidates returned will never be greater than <numNodes>. func (pl *DefaultPreemption) calculateNumCandidates(numNodes int32) int32 { n := (numNodes * pl.args.MinCandidateNodesPercentage) / 100 if n < pl.args.MinCandidateNodesAbsolute { n = pl.args.MinCandidateNodesAbsolute } if n > numNodes { n = numNodes } return n }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/scheduler/internal/cache/node_tree_test.go
expectedNumNodes := int(0) for _, na := range expectedTree { expectedNumNodes += len(na) } if numNodes := nt.numNodes; numNodes != expectedNumNodes { t.Errorf("unexpected nodeTree.numNodes. Expected: %v, Got: %v", expectedNumNodes, numNodes) } if diff := cmp.Diff(expectedTree, nt.tree); diff != "" { t.Errorf("Unexpected node tree (-want, +got):\n%s", diff) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/dumper.go
} // DumpAll writes cached nodes and scheduling queue information to the scheduler logs. func (d *CacheDumper) DumpAll(logger klog.Logger) { d.dumpNodes(logger) d.dumpSchedulingQueue(logger) } // dumpNodes writes NodeInfo to the scheduler logs. func (d *CacheDumper) dumpNodes(logger klog.Logger) { dump := d.cache.Dump() nodeInfos := make([]string, 0, len(dump.Nodes)) for name, nodeInfo := range dump.Nodes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
Topology: &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}}, }, } cpus := []int64{12, 23, 30} memory := []*podresourcesapi.ContainerMemory{ { MemoryType: "memory", Size_: 1073741824, Topology: &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}}, }, { MemoryType: "hugepages-1Gi", Size_: 1073741824,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot_test.go
"gcr.io/200:v1": sets.New("node-0"), }, expected: map[string]*framework.ImageStateSummary{ "gcr.io/10:v1": { Size: int64(10 * mb), NumNodes: 2, }, "gcr.io/200:v1": { Size: int64(200 * mb), NumNodes: 1, }, }, }, { node: &v1.Node{ ObjectMeta: metav1.ObjectMeta{Name: "node-0"}, Status: v1.NodeStatus{}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 12K bytes - Viewed (0)