- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for numaNodes (0.14 sec)
-
pkg/kubelet/cm/internal_container_lifecycle_linux.go
containerConfig.Linux.Resources.CpusetCpus = allocatedCPUs.String() } } if i.memoryManager != nil { numaNodes := i.memoryManager.GetMemoryNUMANodes(pod, container) if numaNodes.Len() > 0 { var affinity []string for _, numaNode := range sets.List(numaNodes) { affinity = append(affinity, strconv.Itoa(numaNode)) } containerConfig.Linux.Resources.CpusetMems = strings.Join(affinity, ",") } } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
numaNodes := map[int]bool{} for _, numaNode := range machineInfo.Topology { numaNodes[numaNode.Id] = true } for _, reservation := range reservedMemory { if !numaNodes[int(reservation.NumaNode)] { return nil, fmt.Errorf("the reserved memory configuration references a NUMA node %d that does not exist on this machine", reservation.NumaNode) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/devicemanager/topology_hints.go
// Initialize minAffinitySize to include all NUMA Nodes minAffinitySize := len(m.numaNodes) // Iterate through all combinations of NUMA Nodes and build hints from them. hints := []topologymanager.TopologyHint{} bitmask.IterateBitMasks(m.numaNodes, func(mask bitmask.BitMask) { // First, update minAffinitySize for the current request size. devicesInMask := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K 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) -
pkg/kubelet/cm/memorymanager/policy_static.go
var numaNodes []int for n := range machineState { numaNodes = append(numaNodes, n) } sort.Ints(numaNodes) // Initialize minAffinitySize to include all NUMA Cells. minAffinitySize := len(numaNodes) hints := map[string][]topologymanager.TopologyHint{} bitmask.IterateBitMasks(numaNodes, func(mask bitmask.BitMask) { maskBits := mask.GetBits()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K 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/kubelet/cm/cpumanager/cpu_assignment.go
// Get the total number of NUMA nodes in the system. numNUMANodes := a.topo.CPUDetails.NUMANodes().Size() // Get the total number of NUMA nodes that have CPUs available on them. numNUMANodesAvailable := a.details.NUMANodes().Size() // Get the total number of CPUs in the system. numCPUs := a.topo.CPUDetails.CPUs().Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 25 23:56:21 UTC 2024 - 36.3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
// Initialize minAffinitySize to include all NUMA Nodes. minAffinitySize := p.topology.CPUDetails.NUMANodes().Size() // Iterate through all combinations of numa nodes bitmask and build hints from them. hints := []topologymanager.TopologyHint{} bitmask.IterateBitMasks(p.topology.CPUDetails.NUMANodes().List(), func(mask bitmask.BitMask) { // First, update minAffinitySize for the current request size.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints_test.go
allocatedDevices: make(map[string]sets.Set[string]), podDevices: newPodDevices(), sourcesReady: &sourcesReadyStub{}, activePods: func() []*v1.Pod { return []*v1.Pod{tc.pod} }, numaNodes: []int{0, 1}, } for r := range tc.devices { m.allDevices[r] = make(DeviceInstances) m.healthyDevices[r] = sets.New[string]() for _, d := range tc.devices[r] { m.allDevices[r][d.ID] = d
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 47.5K 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)