diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index 8f682ac10e4..f4131a72a35 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -1238,12 +1238,10 @@ func (kl *Kubelet) StartGarbageCollection() { } }, ContainerGCPeriod, wait.NeverStop) - stopChan := make(chan struct{}) - defer close(stopChan) // when the high threshold is set to 100, stub the image GC manager if kl.kubeletConfiguration.ImageGCHighThresholdPercent == 100 { glog.V(2).Infof("ImageGCHighThresholdPercent is set 100, Disable image GC") - go func() { stopChan <- struct{}{} }() + return } prevImageGCFailed := false @@ -1266,7 +1264,7 @@ func (kl *Kubelet) StartGarbageCollection() { glog.V(vLevel).Infof("Image garbage collection succeeded") } - }, ImageGCPeriod, stopChan) + }, ImageGCPeriod, wait.NeverStop) } // initializeModules will initialize internal modules that do not require the container runtime to be up.