github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-14 14:23:37 +00:00
Code Issues Projects Releases Wiki Activity

kubelet: improve allocated resources checkpointing

Browse Source 
changed calls to set allocation from container level to pod level on status manager.
This commit is contained in:
Filipe Xavier 2025-01-07 09:20:36 -03:00
parent a499facee6
commit 8e872978e8
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/kubelet/kubelet.go
View File

@ -2922,7 +2922,7 @@ func (kl *Kubelet) handlePodResourcesResize(pod *v1.Pod, podStatus *kubecontaine
if fit { if fit {
// Update pod resource allocation checkpoint // Update pod resource allocation checkpoint
if err := kl.statusManager.SetPodAllocation(pod); err != nil { if err := kl.statusManager.SetPodAllocation(pod); err != nil {
return nil, err klog.ErrorS(err, "SetPodAllocation failed", "pod", klog.KObj(pod))
} }
for i, container := range pod.Spec.Containers { for i, container := range pod.Spec.Containers {
if !apiequality.Semantic.DeepEqual(container.Resources, allocatedPod.Spec.Containers[i].Resources) { if !apiequality.Semantic.DeepEqual(container.Resources, allocatedPod.Spec.Containers[i].Resources) {

12
pkg/kubelet/status/status_manager.go
View File

@ -296,13 +296,17 @@ func (m *manager) GetPodResizeStatus(podUID types.UID) v1.PodResizeStatus {
func (m *manager) SetPodAllocation(pod *v1.Pod) error { func (m *manager) SetPodAllocation(pod *v1.Pod) error {
m.podStatusesLock.RLock() m.podStatusesLock.RLock()
defer m.podStatusesLock.RUnlock() defer m.podStatusesLock.RUnlock()
podUID := string(pod.UID)
podAlloc := state.PodResourceAllocation{}
podAlloc[podUID] = make(map[string]v1.ResourceRequirements)
for _, container := range pod.Spec.Containers { for _, container := range pod.Spec.Containers {
alloc := *container.Resources.DeepCopy() alloc := *container.Resources.DeepCopy()
if err := m.state.SetContainerResourceAllocation(string(pod.UID), container.Name, alloc); err != nil { podAlloc[podUID][container.Name] = alloc
return err
}
} }
return nil
return m.state.SetPodResourceAllocation(podUID, podAlloc)
} }
// SetPodResizeStatus checkpoints the last resizing decision for the pod. // SetPodResizeStatus checkpoints the last resizing decision for the pod.