d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

dedup in updatePodStatus (#830)

Browse Source 
Co-authored-by: Brian Goff <cpuguy83@gmail.com>
This commit is contained in:
Weidong Cai
2020-06-16 05:35:14 +08:00
committed by GitHub
parent 05fc1a43be
commit 2398504d08
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
node/pod.go
View File

@@ -209,6 +209,9 @@ func (pc *PodController) updatePodStatus(ctx context.Context, podFromKubernetes
kPod.Lock() kPod.Lock()
podFromProvider := kPod.lastPodStatusReceivedFromProvider.DeepCopy() podFromProvider := kPod.lastPodStatusReceivedFromProvider.DeepCopy()
kPod.Unlock() kPod.Unlock()
if cmp.Equal(podFromKubernetes.Status, podFromProvider.Status) {
return nil
}
// We need to do this because the other parts of the pod can be updated elsewhere. Since we're only updating // We need to do this because the other parts of the pod can be updated elsewhere. Since we're only updating
// the pod status, and we should be the sole writers of the pod status, we can blind overwrite it. Therefore // the pod status, and we should be the sole writers of the pod status, we can blind overwrite it. Therefore
// we need to copy the pod and set ResourceVersion to 0. // we need to copy the pod and set ResourceVersion to 0.