diff options
| author | Chris Lu <chris.lu@gmail.com> | 2013-09-28 22:18:52 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2013-09-28 22:18:52 -0700 |
| commit | 3f5f8657d28d98eaecb53dacb0228d29f705f24b (patch) | |
| tree | 8cc3d43c0f05d727d7791a6a3b0b9ef9f3143716 /go/storage | |
| parent | 738e52832973abe73775586709a35f075290fc40 (diff) | |
| download | seaweedfs-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.go | 2 | ||||
| -rw-r--r-- | go/storage/volume.go | 2 |
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() |
