Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for CPUsInCores (0.14 sec)

  1. pkg/kubelet/cm/cpumanager/topology/topology.go

    			if info.NUMANodeID == id {
    				cpuIDs = append(cpuIDs, cpu)
    			}
    		}
    	}
    	return cpuset.New(cpuIDs...)
    }
    
    // CPUsInCores returns all of the logical CPU IDs associated with the given
    // core IDs in this CPUDetails.
    func (d CPUDetails) CPUsInCores(ids ...int) cpuset.CPUSet {
    	var cpuIDs []int
    	for _, id := range ids {
    		for cpu, info := range d {
    			if info.CoreID == id {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/cpu_assignment.go

    func (n *numaFirst) sortAvailableCores() []int {
    	var result []int
    	for _, socket := range n.acc.sortAvailableSockets() {
    		cores := n.acc.details.CoresInSockets(socket).UnsortedList()
    		n.acc.sort(cores, n.acc.details.CPUsInCores)
    		result = append(result, cores...)
    	}
    	return result
    }
    
    // If sockets are higher in the memory hierarchy than NUMA nodes, then we take
    // from the set of sockets as the first level.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 25 23:56:21 UTC 2024
    - 36.3K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/topology/topology_test.go

    		ids:  []int{3},
    		want: cpuset.New(),
    	}}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			got := details.CPUsInCores(tt.ids...)
    			if !reflect.DeepEqual(got, tt.want) {
    				t.Errorf("CPUsInCores() = %v, want %v", got, tt.want)
    			}
    		})
    	}
    }
    
    func TestCPUCoreID(t *testing.T) {
    	topoDualSocketHT := &CPUTopology{
    		NumCPUs:    12,
    		NumSockets: 2,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 31.7K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/policy_static.go

    		if err != nil {
    			return nil, fmt.Errorf("[cpumanager] unable to build the reserved physical CPUs from the reserved set: %w", err)
    		}
    		reservedPhysicalCPUs = reservedPhysicalCPUs.Union(topology.CPUDetails.CPUsInCores(core))
    	}
    
    	klog.InfoS("Reserved CPUs not available for exclusive assignment", "reservedSize", reserved.Size(), "reserved", reserved, "reservedPhysicalCPUs", reservedPhysicalCPUs)
    	policy.reservedCPUs = reserved
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
Back to top