Skip to content

Commit fa0830a

Browse files
nervghalexey-igrychev
authored andcommitted
fix(buildah,host-cleanup): do requested changes
Signed-off-by: Alexandr Zaytsev <alexandr.zaytsev@flant.com>
1 parent a64d4ff commit fa0830a

3 files changed

Lines changed: 27 additions & 26 deletions

File tree

pkg/host_cleaning/cleanup_report.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,22 +7,22 @@ import (
77

88
type cleanupReport prune.Report
99

10-
func newCleanupReport(size int) cleanupReport {
10+
func newCleanupReport() cleanupReport {
1111
return cleanupReport{
12-
ItemsDeleted: make([]string, 0, size),
12+
ItemsDeleted: []string{},
1313
SpaceReclaimed: 0,
1414
}
1515
}
1616

1717
func mapPruneReportToCleanupReport(report prune.Report) cleanupReport {
18-
cr := newCleanupReport(0)
18+
cr := newCleanupReport()
1919
cr.SpaceReclaimed = report.SpaceReclaimed
2020
cr.ItemsDeleted = append(cr.ItemsDeleted, report.ItemsDeleted...)
2121
return cr
2222
}
2323

2424
func mapImageListToCleanupReport(list image.ImagesList) cleanupReport {
25-
report := newCleanupReport(0)
25+
report := newCleanupReport()
2626
report.ItemsDeleted = make([]string, 0, len(list))
2727
for _, img := range list {
2828
report.ItemsDeleted = append(report.ItemsDeleted, img.ID)

pkg/host_cleaning/local_backend_cleaner.go

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -475,7 +475,7 @@ func (cleaner *LocalBackendCleaner) pruneImages(ctx context.Context, options Run
475475
if options.DryRun {
476476
list, err := cleaner.backend.Images(ctx, buildImagesOptions(filters.ToPairs()...))
477477
if err != nil {
478-
return newCleanupReport(0), err
478+
return newCleanupReport(), err
479479
}
480480
return mapImageListToCleanupReport(list), nil
481481
}
@@ -485,9 +485,9 @@ func (cleaner *LocalBackendCleaner) pruneImages(ctx context.Context, options Run
485485
case errors.Is(err, container_backend.ErrImageUsedByContainer),
486486
errors.Is(err, container_backend.ErrPruneIsAlreadyRunning):
487487
logboek.Context(ctx).Info().LogF("NOTE: Ignore image pruning: %s\n", err.Error())
488-
return newCleanupReport(0), nil
488+
return newCleanupReport(), nil
489489
case err != nil:
490-
return newCleanupReport(0), err
490+
return newCleanupReport(), err
491491
}
492492

493493
return mapPruneReportToCleanupReport(report), err
@@ -498,17 +498,17 @@ func (cleaner *LocalBackendCleaner) pruneVolumes(ctx context.Context, options Ru
498498
if options.DryRun {
499499
// NOTE: Buildah does not give us a way to precalculate pruned size.
500500
// NOTE: Docker does not give us a way to precalculate pruned size.
501-
return newCleanupReport(0), errOptionDryRunNotSupported
501+
return newCleanupReport(), errOptionDryRunNotSupported
502502
}
503503

504504
report, err := cleaner.backend.PruneVolumes(ctx, prune.Options{})
505505

506506
switch {
507507
case errors.Is(err, container_backend.ErrPruneIsAlreadyRunning):
508508
logboek.Context(ctx).Info().LogF("NOTE: Ignore volume pruning: %s\n", err.Error())
509-
return newCleanupReport(0), nil
509+
return newCleanupReport(), nil
510510
case err != nil:
511-
return newCleanupReport(0), err
511+
return newCleanupReport(), err
512512
}
513513

514514
return mapPruneReportToCleanupReport(report), err
@@ -517,10 +517,11 @@ func (cleaner *LocalBackendCleaner) pruneVolumes(ctx context.Context, options Ru
517517
func (cleaner *LocalBackendCleaner) cleanupWerfContainers(ctx context.Context, options RunGCOptions, vu volumeutils.VolumeUsage) (cleanupReport, error) {
518518
containers, err := werfContainersByContainersOptions(ctx, cleaner.backend, buildContainersOptions())
519519
if err != nil {
520-
return newCleanupReport(0), fmt.Errorf("cannot get build containers: %w", err)
520+
return newCleanupReport(), fmt.Errorf("cannot get build containers: %w", err)
521521
}
522522

523-
report := newCleanupReport(len(containers))
523+
report := newCleanupReport()
524+
report.ItemsDeleted = make([]string, 0, len(containers))
524525

525526
for _, container := range containers {
526527
containerName := werfContainerName(container)
@@ -531,7 +532,7 @@ func (cleaner *LocalBackendCleaner) cleanupWerfContainers(ctx context.Context, o
531532
}
532533

533534
if ok, err := cleaner.isLocked(container_backend.ContainerLockName(containerName)); err != nil {
534-
return newCleanupReport(0), fmt.Errorf("checking lock %q: %w", container_backend.ContainerLockName(containerName), err)
535+
return newCleanupReport(), fmt.Errorf("checking lock %q: %w", container_backend.ContainerLockName(containerName), err)
535536
} else if ok {
536537
continue
537538
}
@@ -569,10 +570,10 @@ func (cleaner *LocalBackendCleaner) cleanupWerfContainers(ctx context.Context, o
569570
func (cleaner *LocalBackendCleaner) cleanupWerfImages(ctx context.Context, options RunGCOptions, vu volumeutils.VolumeUsage, targetVolumeUsagePercentage float64) (cleanupReport, error) {
570571
images, err := cleaner.werfImages(ctx)
571572
if err != nil {
572-
return newCleanupReport(0), err
573+
return newCleanupReport(), err
573574
}
574575

575-
report := newCleanupReport(0)
576+
report := newCleanupReport()
576577

577578
tVu := targetVolumeUsagePercentage
578579

pkg/host_cleaning/local_backend_cleaner_test.go

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ var _ = Describe("LocalBackendCleaner", func() {
127127

128128
report, err := cleaner.pruneImages(ctx, RunGCOptions{})
129129
Expect(err).To(Equal(err0))
130-
Expect(report).To(Equal(newCleanupReport(0)))
130+
Expect(report).To(Equal(newCleanupReport()))
131131
})
132132
It("should return err=nil and empty report if opts.DryRun=false calling backend.PruneImages() which returns pruneErr=ErrImageUsedByContainer", func(ctx context.Context) {
133133
ctx = logging.WithLogger(ctx)
@@ -136,7 +136,7 @@ var _ = Describe("LocalBackendCleaner", func() {
136136

137137
report, err := cleaner.pruneImages(ctx, RunGCOptions{})
138138
Expect(err).To(Succeed())
139-
Expect(report).To(Equal(newCleanupReport(0)))
139+
Expect(report).To(Equal(newCleanupReport()))
140140
})
141141
It("should return err=nil and empty report if opts.DryRun=false calling backend.PruneImages() which returns pruneErr=ErrPruneIsAlreadyRunning", func(ctx context.Context) {
142142
ctx = logging.WithLogger(ctx)
@@ -145,7 +145,7 @@ var _ = Describe("LocalBackendCleaner", func() {
145145

146146
report, err := cleaner.pruneImages(ctx, RunGCOptions{})
147147
Expect(err).To(Succeed())
148-
Expect(report).To(Equal(newCleanupReport(0)))
148+
Expect(report).To(Equal(newCleanupReport()))
149149
})
150150
It("should return err=nil and full report if opts.DryRun=false calling backend.PruneImages() which returns pruneErr=nil", func(ctx SpecContext) {
151151
pruneReport := prune.Report{
@@ -165,7 +165,7 @@ var _ = Describe("LocalBackendCleaner", func() {
165165
DryRun: true,
166166
})
167167
Expect(errors.Is(err, errOptionDryRunNotSupported)).To(BeTrue())
168-
Expect(report).To(Equal(newCleanupReport(0)))
168+
Expect(report).To(Equal(newCleanupReport()))
169169
})
170170
It("should return err=nil and empty report if opts.DryRun=false calling backend.PruneVolumes() which returns returns pruneErr=ErrPruneIsAlreadyRunning", func(ctx context.Context) {
171171
ctx = logging.WithLogger(ctx)
@@ -174,15 +174,15 @@ var _ = Describe("LocalBackendCleaner", func() {
174174

175175
report, err := cleaner.pruneVolumes(ctx, RunGCOptions{})
176176
Expect(err).To(Succeed())
177-
Expect(report).To(Equal(newCleanupReport(0)))
177+
Expect(report).To(Equal(newCleanupReport()))
178178
})
179179
It("should return err=some_err and empty report if opts.DryRun=false calling backend.PruneVolumes() which returns returns pruneErr=err", func(ctx SpecContext) {
180180
err0 := errors.New("some_err")
181181
backend.EXPECT().PruneVolumes(ctx, prune.Options{}).Return(prune.Report{}, err0)
182182

183183
report, err := cleaner.pruneVolumes(ctx, RunGCOptions{})
184184
Expect(err).To(Equal(err0))
185-
Expect(report).To(Equal(newCleanupReport(0)))
185+
Expect(report).To(Equal(newCleanupReport()))
186186
})
187187
It("should return err=nil and full report if opts.DryRun=false calling backend.PruneVolumes() which returns pruneErr=nil", func(ctx SpecContext) {
188188
pruneReport := prune.Report{
@@ -234,7 +234,7 @@ var _ = Describe("LocalBackendCleaner", func() {
234234
},
235235
true,
236236
container_backend.ErrCannotRemovePausedContainer,
237-
newCleanupReport(0),
237+
newCleanupReport(),
238238
),
239239
Entry(
240240
"should not return err if backend.Rm() returns 'container is running' error",
@@ -245,7 +245,7 @@ var _ = Describe("LocalBackendCleaner", func() {
245245
},
246246
true,
247247
container_backend.ErrCannotRemoveRunningContainer,
248-
newCleanupReport(0),
248+
newCleanupReport(),
249249
),
250250
Entry(
251251
"should not call backend.Rm() if lock was not acquired",
@@ -256,7 +256,7 @@ var _ = Describe("LocalBackendCleaner", func() {
256256
},
257257
false,
258258
nil,
259-
newCleanupReport(0),
259+
newCleanupReport(),
260260
),
261261
Entry(
262262
"should return full report in dry run mode if lock was acquired",
@@ -285,7 +285,7 @@ var _ = Describe("LocalBackendCleaner", func() {
285285
},
286286
false,
287287
nil,
288-
newCleanupReport(0),
288+
newCleanupReport(),
289289
),
290290
)
291291

@@ -399,7 +399,7 @@ var _ = Describe("LocalBackendCleaner", func() {
399399
TotalBytes: 1000,
400400
},
401401
[]string{},
402-
newCleanupReport(0),
402+
newCleanupReport(),
403403
),
404404
)
405405

0 commit comments

Comments
 (0)