Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for allocateCPUs (0.23 sec)

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

    		s.SetDefaultCPUSet(s.GetDefaultCPUSet().Union(toRelease))
    	}
    	return nil
    }
    
    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)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/policy_static_test.go

    			continue
    		}
    
    		cset, err := policy.allocateCPUs(st, tc.numRequested, tc.socketMask, cpuset.New())
    		if err != nil {
    			t.Errorf("StaticPolicy allocateCPUs() error (%v). expected CPUSet %v not error %v",
    				tc.description, tc.expCSet, err)
    			continue
    		}
    
    		if !reflect.DeepEqual(tc.expCSet, cset) {
    			t.Errorf("StaticPolicy allocateCPUs() error (%v). expected CPUSet %v but got %v",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 40.8K bytes
    - Viewed (0)
Back to top