github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 22:40:35 +00:00
Code Issues Projects Releases Wiki Activity

make OnPodSandboxReady async to work correctly with on-demand per-pod relist

Browse Source
This commit is contained in:
Priyanka Saggu
2026-03-16 10:55:52 +05:30
parent 410efb048f
commit 7b71b3a165
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
pkg/kubelet/kubelet.go
View File

@@ -3514,26 +3514,29 @@ func (kl *Kubelet) OnPodSandboxReady(ctx context.Context, pod *v1.Pod) error {
logger := klog.FromContext(ctx)
logger.V(3).Info("OnPodSandboxReady callback invoked", "pod", klog.KObj(pod), "podUID", pod.UID)
existingStatus, ok := kl.statusManager.GetPodStatus(pod.UID)
if !ok {
existingStatus = pod.Status
}
// update the status asynchronously to avoid blocking the SyncPod flow
go func() {
existingStatus, ok := kl.statusManager.GetPodStatus(pod.UID)
if !ok {
existingStatus = pod.Status
}
cachedStatus := existingStatus.DeepCopy()
cachedStatus := existingStatus.DeepCopy()
readySandboxCondition := v1.PodCondition{
Type: v1.PodReadyToStartContainers,
Status: v1.ConditionTrue,
ObservedGeneration: podutil.CalculatePodConditionObservedGeneration(cachedStatus, pod.Generation, v1.PodReadyToStartContainers),
}
readySandboxCondition := v1.PodCondition{
Type: v1.PodReadyToStartContainers,
Status: v1.ConditionTrue,
ObservedGeneration: podutil.CalculatePodConditionObservedGeneration(cachedStatus, pod.Generation, v1.PodReadyToStartContainers),
}
cachedStatus.Conditions = utilpod.ReplaceOrAppendPodCondition(cachedStatus.Conditions, &readySandboxCondition)
cachedStatus.Conditions = utilpod.ReplaceOrAppendPodCondition(cachedStatus.Conditions, &readySandboxCondition)
kl.statusManager.SetPodStatus(logger, pod, *cachedStatus)
kl.statusManager.SetPodStatus(logger, pod, *cachedStatus)
logger.V(3).Info("Successfully updated PodReadyToStartContainers condition after sandbox creation",
"pod", klog.KObj(pod),
"podUID", pod.UID)
logger.V(3).Info("Successfully updated PodReadyToStartContainers condition after sandbox creation",
"pod", klog.KObj(pod),
"podUID", pod.UID)
}()
return nil
}