aboutsummaryrefslogtreecommitdiff
path: root/go/storage/store_vacuum.go
diff options
context:
space:
mode:
Diffstat (limited to 'go/storage/store_vacuum.go')
-rw-r--r--go/storage/store_vacuum.go44
1 files changed, 0 insertions, 44 deletions
diff --git a/go/storage/store_vacuum.go b/go/storage/store_vacuum.go
deleted file mode 100644
index 52343c898..000000000
--- a/go/storage/store_vacuum.go
+++ /dev/null
@@ -1,44 +0,0 @@
-package storage
-
-import (
- "fmt"
- "strconv"
-
- "github.com/chrislusf/seaweedfs/go/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()
- }
- return fmt.Errorf("volume id %d is not found during check compact", vid), false
-}
-func (s *Store) CompactVolume(volumeIdString string) error {
- vid, err := NewVolumeId(volumeIdString)
- if err != nil {
- return fmt.Errorf("Volume Id %s is not a valid unsigned integer", volumeIdString)
- }
- if v := s.findVolume(vid); v != nil {
- return v.Compact()
- }
- 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)
- }
- if v := s.findVolume(vid); v != nil {
- return v.commitCompact()
- }
- return fmt.Errorf("volume id %d is not found during commit compact", vid)
-}