- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetCPUSet (0.12 sec)
-
pkg/kubelet/cm/cpumanager/state/state_mem.go
func NewMemoryState() State { klog.InfoS("Initialized new in-memory state store") return &stateMemory{ assignments: ContainerCPUAssignments{}, defaultCPUSet: cpuset.New(), } } func (s *stateMemory) GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) { s.RLock() defer s.RUnlock() res, ok := s.assignments[podUID][containerName] return res.Clone(), ok }
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
if err != nil { klog.ErrorS(err, "Failed to save checkpoint") return err } return nil } // GetCPUSet returns current CPU set func (sc *stateCheckpoint) GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) { sc.mux.RLock() defer sc.mux.RUnlock() res, ok := sc.cache.GetCPUSet(podUID, containerName) return res, ok } // GetDefaultCPUSet returns default CPU set
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_checkpoint_test.go
for container, set := range tc.assignments[pod] { state.SetCPUSet(pod, container, set) if cpus, _ := state.GetCPUSet(pod, container); !cpus.Equals(set) { t.Fatalf("state inconsistent, got %q instead of %q", set, cpus) } state.Delete(pod, container) if _, ok := state.GetCPUSet(pod, container); ok { t.Fatal("deleted container still existing in state") } } } }) }
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
for container, cset := range as[pod] { 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 }
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/policy_static.go
return SMTAlignmentError{ RequestedCPUs: numCPUs, CpusPerCore: CPUsPerCore, AvailablePhysicalCPUs: availablePhysicalCPUs, } } } if cpuset, ok := s.GetCPUSet(string(pod.UID), container.Name); ok { p.updateCPUsToReuse(pod, container, cpuset) klog.InfoS("Static policy: container already present in state, skipping", "pod", klog.KObj(pod), "containerName", container.Name) return nil
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/cpu_manager.go
return err } return nil } func (m *manager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { m.Lock() defer m.Unlock() if cset, exists := m.state.GetCPUSet(string(pod.UID), container.Name); exists { m.lastUpdateState.SetCPUSet(string(pod.UID), container.Name, cset) } m.containerMap.Add(string(pod.UID), container.Name, containerID) }
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/cpu_manager_test.go
} func (s *mockState) GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) { res, ok := s.assignments[podUID][containerName] 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0)