- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,500 for cpuset (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)