aboutsummaryrefslogtreecommitdiff
path: root/go/storage
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2013-09-28 22:18:52 -0700
committerChris Lu <chris.lu@gmail.com>2013-09-28 22:18:52 -0700
commit3f5f8657d28d98eaecb53dacb0228d29f705f24b (patch)
tree8cc3d43c0f05d727d7791a6a3b0b9ef9f3143716 /go/storage
parent738e52832973abe73775586709a35f075290fc40 (diff)
downloadseaweedfs-3f5f8657d28d98eaecb53dacb0228d29f705f24b.tar.xz
seaweedfs-3f5f8657d28d98eaecb53dacb0228d29f705f24b.zip
add a command to force compaction of a volume, removing deleted files
Diffstat (limited to 'go/storage')
-rw-r--r--go/storage/store.go2
-rw-r--r--go/storage/volume.go2
2 files changed, 2 insertions, 2 deletions
diff --git a/go/storage/store.go b/go/storage/store.go
index bea3bd34f..e5dc92bf6 100644
--- a/go/storage/store.go
+++ b/go/storage/store.go
@@ -126,7 +126,7 @@ func (s *Store) CompactVolume(volumeIdString string) error {
return fmt.Errorf("Volume Id %s is not a valid unsigned integer!", volumeIdString)
}
if v := s.findVolume(vid); v != nil {
- return v.compact()
+ return v.Compact()
}
return fmt.Errorf("volume id %s is not found during compact!", vid)
}
diff --git a/go/storage/volume.go b/go/storage/volume.go
index 2466113c5..7eb3ea7e6 100644
--- a/go/storage/volume.go
+++ b/go/storage/volume.go
@@ -256,7 +256,7 @@ func (v *Volume) garbageLevel() float64 {
return float64(v.nm.DeletedSize()) / float64(v.ContentSize())
}
-func (v *Volume) compact() error {
+func (v *Volume) Compact() error {
v.accessLock.Lock()
defer v.accessLock.Unlock()