Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for numaAffinity1 (0.16 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/memorymanager/memory_manager_test.go

    					"fakeContainer1": {
    						{
    							NUMAAffinity: []int{0},
    							Type:         v1.ResourceMemory,
    							Size:         1 * gb,
    						},
    						{
    							NUMAAffinity: []int{0},
    							Type:         hugepages1Gi,
    							Size:         1 * gb,
    						},
    					},
    					"fakeContainer2": {
    						{
    							NUMAAffinity: []int{0},
    							Type:         v1.ResourceMemory,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 05 13:01:40 UTC 2023
    - 70.2K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/state/state_checkpoint_test.go

    				"entries":{"pod":{"container1":[{"numaAffinity":[0],"type":"memory","size":512}]}},
    				"checksum": 4215593881
    			}`,
    			"",
    			&stateMemory{
    				assignments: ContainerMemoryAssignments{
    					"pod": map[string][]Block{
    						"container1": {
    							{
    								NUMAAffinity: []int{0},
    								Type:         v1.ResourceMemory,
    								Size:         512,
    							},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 30 03:35:26 UTC 2022
    - 10.6K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/memorymanager/state/state.go

    			}
    		}
    	}
    	return clone
    }
    
    // Block is a data structure used to represent a certain amount of memory
    type Block struct {
    	// NUMAAffinity contains the string that represents NUMA affinity bitmask
    	NUMAAffinity []int           `json:"numaAffinity"`
    	Type         v1.ResourceName `json:"type"`
    	Size         uint64          `json:"size"`
    }
    
    // ContainerMemoryAssignments stores memory assignments of containers
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 08 23:10:00 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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 (0)
  9. 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