Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for numaNodes (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top