Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newCPUAccumulator (0.13 sec)

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

    			fakeTopoMultiSocketDualSocketPerNumaHT,
    			mustParseCPUSet(t, "0-40,42-49,51-68,71-79"),
    			[]int{},
    		},
    	}
    
    	for _, tc := range testCases {
    		t.Run(tc.description, func(t *testing.T) {
    			acc := newCPUAccumulator(tc.topo, tc.availableCPUs, 0)
    			result := acc.freeSockets()
    			sort.Ints(result)
    			if !reflect.DeepEqual(result, tc.expect) {
    				t.Errorf("expected %v to equal %v", result, tc.expect)
    
    			}
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 17:31:37 UTC 2023
    - 22.7K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/cpu_assignment.go

    	// cardinality equal to the total number of CPUs to accumulate.
    	result cpuset.CPUSet
    
    	numaOrSocketsFirst numaOrSocketsFirstFuncs
    }
    
    func newCPUAccumulator(topo *topology.CPUTopology, availableCPUs cpuset.CPUSet, numCPUs int) *cpuAccumulator {
    	acc := &cpuAccumulator{
    		topo:          topo,
    		details:       topo.CPUDetails.KeepOnly(availableCPUs),
    		numCPUsNeeded: numCPUs,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 25 23:56:21 UTC 2024
    - 36.3K bytes
    - Viewed (0)
Back to top