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

fix kubelet image gc

Browse Source 
Signed-off-by: lixd <xueduan.li@gmail.com>
This commit is contained in:
lixd 2023-07-28 17:42:07 +08:00
parent f9f00da6bc
commit bad0593a68
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/kubelet/images/image_gc_manager.go
View File

@ -100,9 +100,6 @@ type realImageGCManager struct {
// Reference to this node. // Reference to this node.
nodeRef *v1.ObjectReference nodeRef *v1.ObjectReference
// Track initialization
initialized bool
// imageCache is the cache of latest image list. // imageCache is the cache of latest image list.
imageCache imageCache imageCache imageCache
@ -176,7 +173,6 @@ func NewImageGCManager(runtime container.Runtime, statsProvider StatsProvider, r
statsProvider: statsProvider, statsProvider: statsProvider,
recorder: recorder, recorder: recorder,
nodeRef: nodeRef, nodeRef: nodeRef,
initialized: false,
tracer: tracer, tracer: tracer,
} }
@ -186,16 +182,9 @@ func NewImageGCManager(runtime container.Runtime, statsProvider StatsProvider, r
func (im *realImageGCManager) Start() { func (im *realImageGCManager) Start() {
ctx := context.Background() ctx := context.Background()
go wait.Until(func() { go wait.Until(func() {
// Initial detection make detected time "unknown" in the past. _, err := im.detectImages(ctx, time.Now())
var ts time.Time
if im.initialized {
ts = time.Now()
}
_, err := im.detectImages(ctx, ts)
if err != nil { if err != nil {
klog.InfoS("Failed to monitor images", "err", err) klog.InfoS("Failed to monitor images", "err", err)
} else {
im.initialized = true
} }
}, 5*time.Minute, wait.NeverStop) }, 5*time.Minute, wait.NeverStop)