- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetDefaultCPUSet (0.18 sec)
-
pkg/kubelet/cm/cpumanager/state/state_checkpoint.go
defer sc.mux.RUnlock() res, ok := sc.cache.GetCPUSet(podUID, containerName) return res, ok } // GetDefaultCPUSet returns default CPU set func (sc *stateCheckpoint) GetDefaultCPUSet() cpuset.CPUSet { sc.mux.RLock() defer sc.mux.RUnlock() return sc.cache.GetDefaultCPUSet() } // GetCPUSetOrDefault returns current CPU set, or default one if it wasn't changed
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/state/state_mem.go
return res.Clone(), ok } func (s *stateMemory) GetDefaultCPUSet() cpuset.CPUSet { s.RLock() defer s.RUnlock() return s.defaultCPUSet.Clone() } func (s *stateMemory) GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet { if res, ok := s.GetCPUSet(podUID, containerName); ok { return res } return s.GetDefaultCPUSet() }
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_test.go
} } } }) } } func AssertStateEqual(t *testing.T, sf State, sm State) { cpusetSf := sf.GetDefaultCPUSet() cpusetSm := sm.GetDefaultCPUSet() if !cpusetSf.Equals(cpusetSm) { t.Errorf("State CPUSet mismatch. Have %v, want %v", cpusetSf, cpusetSm) } cpuassignmentSf := sf.GetCPUAssignments()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 10.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state.go
} } 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/cpu_manager_test.go
return res.Clone(), ok } func (s *mockState) GetDefaultCPUSet() cpuset.CPUSet { return s.defaultCPUSet.Clone() } func (s *mockState) GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet { if res, ok := s.GetCPUSet(podUID, containerName); ok { return res } return s.GetDefaultCPUSet() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
func (p *staticPolicy) GetAvailableCPUs(s state.State) cpuset.CPUSet { return s.GetDefaultCPUSet().Difference(p.reservedCPUs) } func (p *staticPolicy) GetAvailablePhysicalCPUs(s state.State) cpuset.CPUSet { return s.GetDefaultCPUSet().Difference(p.reservedPhysicalCPUs) } func (p *staticPolicy) updateCPUsToReuse(pod *v1.Pod, container *v1.Container, cset cpuset.CPUSet) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
t.Errorf("StaticPolicy Start() error. expected cpuid %d to be present in defaultCPUSet", cpuid) } } } if !st.GetDefaultCPUSet().Equals(testCase.expCSet) { t.Errorf("State CPUSet is different than expected. Have %q wants: %q", st.GetDefaultCPUSet(), testCase.expCSet) } }) } } func TestStaticPolicyAdd(t *testing.T) { var largeTopoCPUids []int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0)