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

kubelet syncloop should stop if/when updates chan closes

Browse Source
This commit is contained in:
Tobi Knaup 2015-04-08 14:45:16 -07:00
parent c4cbc9bc46
commit 3efff6d4e8
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/kubelet/kubelet.go
View File

@ -1632,7 +1632,10 @@ func (kl *Kubelet) syncLoop(updates <-chan PodUpdate, handler SyncHandler) {
unsyncedPod := false unsyncedPod := false
podSyncTypes := make(map[types.UID]metrics.SyncPodType) podSyncTypes := make(map[types.UID]metrics.SyncPodType)
select { select {
case u := <-updates: case u, ok := <-updates:
if !ok {
return
}
kl.podManager.UpdatePods(u, podSyncTypes) kl.podManager.UpdatePods(u, podSyncTypes)
unsyncedPod = true unsyncedPod = true
case <-time.After(kl.resyncInterval): case <-time.After(kl.resyncInterval):