Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for numaAffinity1 (0.17 sec)

  1. pkg/kubelet/cm/memorymanager/policy_static.go

    }
    
    func isNUMAAffinitiesEqual(numaAffinity1, numaAffinity2 []int) bool {
    	bitMask1, err := bitmask.NewBitMask(numaAffinity1...)
    	if err != nil {
    		klog.ErrorS(err, "failed to create bit mask", "numaAffinity1", numaAffinity1)
    		return false
    	}
    
    	bitMask2, err := bitmask.NewBitMask(numaAffinity2...)
    	if err != nil {
    		klog.ErrorS(err, "failed to create bit mask", "numaAffinity2", numaAffinity2)
    		return false
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/memorymanager/policy_static_test.go

    					"container1": {
    						{
    							NUMAAffinity: []int{0, 1},
    							Type:         v1.ResourceMemory,
    							Size:         768 * mb,
    						},
    						{
    							NUMAAffinity: []int{0, 1},
    							Type:         hugepages1Gi,
    							Size:         gb,
    						},
    					},
    				},
    				"pod2": map[string][]state.Block{
    					"container2": {
    						{
    							NUMAAffinity: []int{0, 1},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 05:49:15 UTC 2023
    - 100.4K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/policy_static.go

    func (p *staticPolicy) allocateCPUs(s state.State, numCPUs int, numaAffinity bitmask.BitMask, reusableCPUs cpuset.CPUSet) (cpuset.CPUSet, error) {
    	klog.InfoS("AllocateCPUs", "numCPUs", numCPUs, "socket", numaAffinity)
    
    	allocatableCPUs := p.GetAvailableCPUs(s).Union(reusableCPUs)
    
    	// If there are aligned CPUs in numaAffinity, attempt to take those first.
    	result := cpuset.New()
    	if numaAffinity != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/topologymanager/topology_manager.go

    	// the TopologyManager supports on the underlying machine.
    	//
    	// At present, having more than this number of NUMA Nodes will result in a
    	// state explosion when trying to enumerate possible NUMAAffinity masks and
    	// generate hints for them. As such, if more NUMA Nodes than this are
    	// present on a machine and the TopologyManager is enabled, an error will
    	// be returned and the TopologyManager will not be loaded.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 15 12:43:16 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/memorymanager/memory_manager.go

    	// Get NUMA node affinity of blocks assigned to the container during Allocate()
    	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 (1)
  6. pkg/kubelet/cm/container_manager_linux.go

    			MemoryType: string(b.Type),
    			Size_:      b.Size,
    			Topology: &podresourcesapi.TopologyInfo{
    				Nodes: []*podresourcesapi.NUMANode{},
    			},
    		}
    
    		for _, numaNodeID := range b.NUMAAffinity {
    			containerMemory.Topology.Nodes = append(containerMemory.Topology.Nodes, &podresourcesapi.NUMANode{ID: int64(numaNodeID)})
    		}
    
    		containerMemories = append(containerMemories, &containerMemory)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
Back to top