Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,500 for cpuset (0.14 sec)

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

    func (d CPUDetails) KeepOnly(cpus cpuset.CPUSet) CPUDetails {
    	result := CPUDetails{}
    	for cpu, info := range d {
    		if cpus.Contains(cpu) {
    			result[cpu] = info
    		}
    	}
    	return result
    }
    
    // NUMANodes returns all of the NUMANode IDs associated with the CPUs in this
    // CPUDetails.
    func (d CPUDetails) NUMANodes() cpuset.CPUSet {
    	var numaNodeIDs []int
    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/topology/topology_test.go

    		0: {},
    		1: {},
    		2: {},
    	}
    
    	tests := []struct {
    		name string
    		cpus cpuset.CPUSet
    		want CPUDetails
    	}{{
    		name: "cpus is in CPUDetails.",
    		cpus: cpuset.New(0, 1),
    		want: map[int]CPUInfo{
    			0: {},
    			1: {},
    		},
    	}, {
    		name: "cpus is not in CPUDetails.",
    		cpus: cpuset.New(3),
    		want: CPUDetails{},
    	}}
    
    	for _, tt := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 31.7K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/affinity_linux.go

    // CPU affinity functions
    
    package unix
    
    import (
    	"math/bits"
    	"unsafe"
    )
    
    const cpuSetSize = _CPU_SETSIZE / _NCPUBITS
    
    // CPUSet represents a CPU affinity mask.
    type CPUSet [cpuSetSize]cpuMask
    
    func schedAffinity(trap uintptr, pid int, set *CPUSet) error {
    	_, _, e := RawSyscall(trap, uintptr(pid), uintptr(unsafe.Sizeof(*set)), uintptr(unsafe.Pointer(set)))
    	if e != 0 {
    		return errnoErr(e)
    	}
    	return nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Feb 19 21:26:10 UTC 2020
    - 1.9K bytes
    - Viewed (0)
  4. src/runtime/testdata/testprog/numcpu_freebsd.go

    		return fmt.Errorf("could not check against an empty CPU list")
    	}
    
    	cListString := cpuSetRE.FindString(listString)
    	if len(cListString) == 0 {
    		return fmt.Errorf("invalid cpuset output '%s'", listString)
    	}
    	// Launch FreeBSDNumCPUHelper() with specified CPUs list.
    	cmd := exec.Command("cpuset", "-l", cListString, os.Args[0], "FreeBSDNumCPUHelper")
    	cmdline := strings.Join(cmd.Args, " ")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 30 20:09:46 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/state/state_test.go

    limitations under the License.
    */
    
    package state
    
    import (
    	"reflect"
    	"testing"
    
    	"k8s.io/utils/cpuset"
    )
    
    func TestClone(t *testing.T) {
    	expect := ContainerCPUAssignments{
    		"pod": map[string]cpuset.CPUSet{
    			"container1": cpuset.New(4, 5, 6),
    			"container2": cpuset.New(1, 2, 3),
    		},
    	}
    	actual := expect.Clone()
    	if &expect == &actual || !reflect.DeepEqual(expect, actual) {
    		t.Fail()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 935 bytes
    - Viewed (0)
  6. pkg/kubelet/cm/cpumanager/cpu_manager.go

    	// GetAllocatableCPUs returns the total set of CPUs available for allocation.
    	GetAllocatableCPUs() cpuset.CPUSet
    
    	// GetCPUAffinity returns cpuset which includes cpus from shared pools
    	// as well as exclusively allocated cpus
    	GetCPUAffinity(podUID, containerName string) cpuset.CPUSet
    }
    
    type manager struct {
    	sync.Mutex
    	policy Policy
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/policy_none.go

    func (p *nonePolicy) GetAllocatableCPUs(m state.State) cpuset.CPUSet {
    	return cpuset.New()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/cpumanager/policy_none_test.go

    	}
    
    	policy := &nonePolicy{}
    
    	st := &mockState{
    		assignments:   state.ContainerCPUAssignments{},
    		defaultCPUSet: cpuset.New(cpuIDs...),
    	}
    
    	cpus := policy.GetAllocatableCPUs(st)
    	if cpus.Size() != 0 {
    		t.Errorf("NonePolicy GetAllocatableCPUs() error. expected empty set, returned: %v", cpus)
    	}
    }
    
    func TestNonePolicyOptions(t *testing.T) {
    	var err error
    
    	_, err = NewNonePolicy(nil)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/cpumanager/policy.go

    	// among this and other resource controllers.
    	GetPodTopologyHints(s state.State, pod *v1.Pod) map[string][]topologymanager.TopologyHint
    	// GetAllocatableCPUs returns the total set of CPUs available for allocation.
    	GetAllocatableCPUs(m state.State) cpuset.CPUSet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/cpumanager/cpu_assignment.go

    // the least amount of free CPUs to the one with the highest amount of free CPUs (i.e. in ascending
    // order of free CPUs). For any NUMA node, the cores are selected from the ones in the socket with
    // the least amount of free CPUs to the one with the highest amount of free CPUs.
    func takeByTopologyNUMAPacked(topo *topology.CPUTopology, availableCPUs cpuset.CPUSet, numCPUs int) (cpuset.CPUSet, error) {
    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