koordlet: fix by adding lock during podmap update (#1838)

Signed-off-by: xujihui1985 <[email protected]>
koordinator-sh · Jan 15, 2024 · c70f410 · c70f410
1 parent acb6926
commit c70f410
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/koordlet/statesinformer/impl/states_pods.go b/pkg/koordlet/statesinformer/impl/states_pods.go
@@ -162,7 +162,10 @@ func (s *podsInformer) syncPods() error {
 		// record pod container metrics
 		recordPodResourceMetrics(podMeta)
 	}
+	s.podRWMutex.Lock()
 	s.podMap = newPodMap
+	s.podRWMutex.Unlock()
+
 	s.podHasSynced.Store(true)
 	s.podUpdatedTime = time.Now()
 	klog.V(4).Infof("get pods success, len %d, time %s", len(s.podMap), s.podUpdatedTime.String())