- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 701 for cpuset (0.1 sec)
-
pkg/kubelet/cm/cpumanager/state/state.go
ret[pod][container] = cset } } return ret } // Reader interface used to read current cpu/pod assignment state type Reader interface { GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) GetDefaultCPUSet() cpuset.CPUSet GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet GetCPUAssignments() ContainerCPUAssignments } type writer interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/fake_cpu_manager.go
func (m *fakeManager) GetExclusiveCPUs(podUID, containerName string) cpuset.CPUSet { klog.InfoS("GetExclusiveCPUs", "podUID", podUID, "containerName", containerName) return cpuset.CPUSet{} } func (m *fakeManager) GetAllocatableCPUs() cpuset.CPUSet { klog.InfoS("Get Allocatable CPUs") return cpuset.CPUSet{} } func (m *fakeManager) GetCPUAffinity(podUID, containerName string) cpuset.CPUSet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_mem.go
s.assignments[podUID] = make(map[string]cpuset.CPUSet) } s.assignments[podUID][containerName] = cset klog.InfoS("Updated desired CPUSet", "podUID", podUID, "containerName", containerName, "cpuSet", cset) } func (s *stateMemory) SetDefaultCPUSet(cset cpuset.CPUSet) { s.Lock() defer s.Unlock() s.defaultCPUSet = cset klog.InfoS("Updated default CPUSet", "cpuSet", cset) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_checkpoint.go
sc.mux.Lock() defer sc.mux.Unlock() sc.cache.SetCPUSet(podUID, containerName, cset) err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err) } } // SetDefaultCPUSet sets default CPU set func (sc *stateCheckpoint) SetDefaultCPUSet(cset cpuset.CPUSet) { sc.mux.Lock() defer sc.mux.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 7.9K bytes - Viewed (0) -
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) -
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/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)