seaweedfs/weed/storage/store_vacuum.go

35 lines
1.1 KiB
Go
Raw Normal View History

2014-05-20 02:18:39 +00:00
package storage
import (
"fmt"
2019-04-19 04:43:36 +00:00
"github.com/chrislusf/seaweedfs/weed/glog"
2019-04-19 04:43:36 +00:00
"github.com/chrislusf/seaweedfs/weed/storage/needle"
2014-05-20 02:18:39 +00:00
)
2019-04-19 04:43:36 +00:00
func (s *Store) CheckCompactVolume(volumeId needle.VolumeId) (float64, error) {
2018-10-15 06:12:43 +00:00
if v := s.findVolume(volumeId); v != nil {
glog.V(3).Infof("volumd %d garbage level: %f", volumeId, v.garbageLevel())
return v.garbageLevel(), nil
2014-05-20 02:18:39 +00:00
}
2018-10-15 06:12:43 +00:00
return 0, fmt.Errorf("volume id %d is not found during check compact", volumeId)
2014-05-20 02:18:39 +00:00
}
func (s *Store) CompactVolume(vid needle.VolumeId, preallocate int64, compactionBytePerSecond int64) error {
2014-05-20 02:18:39 +00:00
if v := s.findVolume(vid); v != nil {
return v.Compact2(preallocate, compactionBytePerSecond)
2014-05-20 02:18:39 +00:00
}
2015-03-10 07:20:31 +00:00
return fmt.Errorf("volume id %d is not found during compact", vid)
2014-05-20 02:18:39 +00:00
}
2019-04-19 04:43:36 +00:00
func (s *Store) CommitCompactVolume(vid needle.VolumeId) error {
2014-05-20 02:18:39 +00:00
if v := s.findVolume(vid); v != nil {
2019-03-25 16:16:12 +00:00
return v.CommitCompact()
2014-05-20 02:18:39 +00:00
}
2015-03-10 07:20:31 +00:00
return fmt.Errorf("volume id %d is not found during commit compact", vid)
2014-05-20 02:18:39 +00:00
}
2019-04-19 04:43:36 +00:00
func (s *Store) CommitCleanupVolume(vid needle.VolumeId) error {
if v := s.findVolume(vid); v != nil {
return v.cleanupCompact()
}
return fmt.Errorf("volume id %d is not found during cleaning up", vid)
}