- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for NUMANodes (0.17 sec)
-
pkg/kubelet/cm/topologymanager/numa_info.go
type NUMAInfo struct { Nodes []int NUMADistances NUMADistances } func NewNUMAInfo(topology []cadvisorapi.Node, opts PolicyOptions) (*NUMAInfo, error) { var numaNodes []int distances := map[int][]uint64{} for _, node := range topology { numaNodes = append(numaNodes, node.Id) var nodeDistance []uint64 if opts.PreferClosestNUMA { nodeDistance = node.Distances if nodeDistance == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:14 UTC 2022 - 2.7K bytes - Viewed (0) -
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, ",") }
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/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/kubelet/cm/memorymanager/memory_manager.go
numaNodes := sets.New[int]() for _, block := range m.state.GetMemoryBlocks(string(pod.UID), container.Name) { for _, nodeID := range block.NUMAAffinity { // avoid nodes duplication when hugepages and memory blocks pinned to the same NUMA node numaNodes.Insert(nodeID) } } if numaNodes.Len() == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (0) -
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/cpumanager/topology/topology.go
result := CPUDetails{} for cpu, info := range d { if cpus.Contains(cpu) { result[cpu] = info } } return result } // NUMANodes returns all of the NUMANode IDs associated with the CPUs in this // CPUDetails. func (d CPUDetails) NUMANodes() cpuset.CPUSet { var numaNodeIDs []int for _, info := range d { numaNodeIDs = append(numaNodeIDs, info.NUMANodeID) } return cpuset.New(numaNodeIDs...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 7.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/cpumanager/topology/topology_test.go
3: {NUMANodeID: 1}, }, want: cpuset.New(0, 1), }} for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { got := tt.details.NUMANodes() if !reflect.DeepEqual(got, tt.want) { t.Errorf("NUMANodes() = %v, want %v", got, tt.want) } }) } } func TestCPUDetailsNUMANodesInSockets(t *testing.T) { var details1 CPUDetails details1 = map[int]CPUInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 31.7K 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)