mirror/kopia
1
0 Fork 0
mirror of https://github.com/kopia/kopia.git synced 2026-10-21 05:34:42 -04:00
Code Issues Packages Projects Releases Wiki Activity

cli: renamed content gc subcommand to blob gc

Browse Source
This commit is contained in:
Jarek Kowalski committed 2019-09-10 21:08:16 -07:00
1 parent 6170ffb117
commit 8a1ce0a353
1 file changed
+7 -7
Download Patch File Download Diff File Expand all files Collapse all files
cli/command_content_gc.go → cli/command_blob_gc.go
+7 -7
View File
@@ -11,16 +11,16 @@ import (
)
var (
contentGarbageCollectCommand = contentCommands.Command("gc", "Garbage-collect unused blobs")
contentGarbageCollectCommandDelete = contentGarbageCollectCommand.Flag("delete", "Whether to delete unused blobs").String()
contentGarbageCollectParallel = contentGarbageCollectCommand.Flag("parallel", "Number of parallel blob scans").Int()
blobGarbageCollectCommand = blobCommands.Command("gc", "Garbage-collect unused blobs")
blobGarbageCollectCommandDelete = blobGarbageCollectCommand.Flag("delete", "Whether to delete unused blobs").String()
blobGarbageCollectParallel = blobGarbageCollectCommand.Flag("parallel", "Number of parallel blob scans").Int()
)
func runContentGarbageCollectCommand(ctx context.Context, rep *repo.Repository) error {
func runBlobGarbageCollectCommand(ctx context.Context, rep *repo.Repository) error {
var mu sync.Mutex
var unused []blob.Metadata
if err := rep.Content.IterateUnreferencedBlobs(ctx, *contentGarbageCollectParallel, func(bm blob.Metadata) error {
if err := rep.Content.IterateUnreferencedBlobs(ctx, *blobGarbageCollectParallel, func(bm blob.Metadata) error {
mu.Lock()
unused = append(unused, bm)
mu.Unlock()
@@ -34,7 +34,7 @@ func runContentGarbageCollectCommand(ctx context.Context, rep *repo.Repository)
return nil
}
if *contentGarbageCollectCommandDelete != "yes" {
if *blobGarbageCollectCommandDelete != "yes" {
var totalBytes int64
for _, u := range unused {
totalBytes += u.Length
@@ -55,5 +55,5 @@ func runContentGarbageCollectCommand(ctx context.Context, rep *repo.Repository)
}
func init() {
contentGarbageCollectCommand.Action(repositoryAction(runContentGarbageCollectCommand))
blobGarbageCollectCommand.Action(repositoryAction(runBlobGarbageCollectCommand))
}