Skip to content

Commit df69a52

Browse files
authored
Merge pull request kubernetes#126335 from kannon92/split-filesystem-fix
[KEP-4191]: Move container fs check so that we only check if system is split
2 parents 696ad19 + 3e642ae commit df69a52

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

pkg/kubelet/stats/cadvisor_stats_provider.go

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -267,10 +267,6 @@ func (p *cadvisorStatsProvider) ImageFsStats(ctx context.Context) (imageFsRet *s
267267
}
268268
return imageFs, imageFs, nil
269269
}
270-
containerFsInfo, err := p.cadvisor.ContainerFsInfo()
271-
if err != nil {
272-
return nil, nil, fmt.Errorf("failed to get container fs info: %v", err)
273-
}
274270
imageStats, err := p.imageService.ImageFsInfo(ctx)
275271
if err != nil || imageStats == nil {
276272
return nil, nil, fmt.Errorf("failed to get image stats: %v", err)
@@ -296,10 +292,17 @@ func (p *cadvisorStatsProvider) ImageFsStats(ctx context.Context) (imageFsRet *s
296292
Inodes: imageFsInfo.Inodes,
297293
InodesUsed: imageFsInodesUsed,
298294
}
295+
// We rely on cadvisor to have the crio-containers label for split filesystem case.
296+
// We return to avoid checking ContainerFsInfo.
299297
if !splitFileSystem {
300298
return fsStats, fsStats, nil
301299
}
302300

301+
containerFsInfo, err := p.cadvisor.ContainerFsInfo()
302+
if err != nil {
303+
return nil, nil, fmt.Errorf("failed to get container fs info: %w", err)
304+
}
305+
303306
containerFs := imageStats.ContainerFilesystems[0]
304307
var containerFsInodesUsed *uint64
305308
if containerFsInfo.Inodes != nil && containerFsInfo.InodesFree != nil {

pkg/kubelet/stats/cadvisor_stats_provider_test.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -569,7 +569,6 @@ func TestCadvisorImagesFsStats(t *testing.T) {
569569
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true)
570570

571571
mockCadvisor.EXPECT().ImagesFsInfo().Return(imageFsInfo, nil)
572-
mockCadvisor.EXPECT().ContainerFsInfo().Return(imageFsInfo, nil)
573572
mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil)
574573

575574
provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider())

0 commit comments

Comments
 (0)