Lock access and update to Kubelet pods.

duda · Mar 13, 2015 · 0e48531 · 0e48531
1 parent 203f37a
commit 0e48531
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go
@@ -1618,6 +1618,8 @@ func (kl *Kubelet) syncLoop(updates <-chan PodUpdate, handler SyncHandler) {
 // Updated the Kubelet's internal pods with those provided by the update.
 // Records new and updated pods in newPods and updatedPods.
 func (kl *Kubelet) updatePods(u PodUpdate, podSyncTypes map[types.UID]metrics.SyncPodType) {
+	kl.podLock.Lock()
+	defer kl.podLock.Unlock()
 	switch u.Op {
 	case SET:
 		glog.V(3).Infof("SET: Containers changed")