Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for NUMANodes (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. pkg/kubelet/cm/devicemanager/manager.go

    	klog.V(2).InfoS("Creating Device Plugin manager", "path", socketPath)
    
    	var numaNodes []int
    	for _, node := range topology {
    		numaNodes = append(numaNodes, node.Id)
    	}
    
    	manager := &ManagerImpl{
    		endpoints: make(map[string]endpointInfo),
    
    		allDevices:            NewResourceDeviceInstances(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
Back to top