diff options
Diffstat (limited to 'weed/storage')
| -rw-r--r-- | weed/storage/store_vacuum.go | 38 |
1 files changed, 8 insertions, 30 deletions
diff --git a/weed/storage/store_vacuum.go b/weed/storage/store_vacuum.go index 3ada1f49c..cc0521491 100644 --- a/weed/storage/store_vacuum.go +++ b/weed/storage/store_vacuum.go @@ -2,51 +2,29 @@ package storage import ( "fmt" - "strconv" - "github.com/chrislusf/seaweedfs/weed/glog" ) -func (s *Store) CheckCompactVolume(volumeIdString string, garbageThresholdString string) (error, bool) { - vid, err := NewVolumeId(volumeIdString) - if err != nil { - return fmt.Errorf("Volume Id %s is not a valid unsigned integer", volumeIdString), false - } - garbageThreshold, e := strconv.ParseFloat(garbageThresholdString, 32) - if e != nil { - return fmt.Errorf("garbageThreshold %s is not a valid float number", garbageThresholdString), false - } - if v := s.findVolume(vid); v != nil { - glog.V(3).Infoln(vid, "garbage level is", v.garbageLevel()) - return nil, garbageThreshold < v.garbageLevel() +func (s *Store) CheckCompactVolume(volumeId VolumeId) (float64, error) { + if v := s.findVolume(volumeId); v != nil { + glog.V(3).Infof("volumd %d garbage level: %f", volumeId, v.garbageLevel()) + return v.garbageLevel(), nil } - return fmt.Errorf("volume id %d is not found during check compact", vid), false + return 0, fmt.Errorf("volume id %d is not found during check compact", volumeId) } -func (s *Store) CompactVolume(volumeIdString string, preallocate int64) error { - vid, err := NewVolumeId(volumeIdString) - if err != nil { - return fmt.Errorf("Volume Id %s is not a valid unsigned integer", volumeIdString) - } +func (s *Store) CompactVolume(vid VolumeId, preallocate int64) error { if v := s.findVolume(vid); v != nil { return v.Compact(preallocate) } return fmt.Errorf("volume id %d is not found during compact", vid) } -func (s *Store) CommitCompactVolume(volumeIdString string) error { - vid, err := NewVolumeId(volumeIdString) - if err != nil { - return fmt.Errorf("Volume Id %s is not a valid unsigned integer", volumeIdString) - } +func (s *Store) CommitCompactVolume(vid VolumeId) error { if v := s.findVolume(vid); v != nil { return v.commitCompact() } return fmt.Errorf("volume id %d is not found during commit compact", vid) } -func (s *Store) CommitCleanupVolume(volumeIdString string) error { - vid, err := NewVolumeId(volumeIdString) - if err != nil { - return fmt.Errorf("Volume Id %s is not a valid unsigned integer", volumeIdString) - } +func (s *Store) CommitCleanupVolume(vid VolumeId) error { if v := s.findVolume(vid); v != nil { return v.cleanupCompact() } |
