2014-05-20 02:18:39 +00:00
|
|
|
package storage
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
2016-06-03 01:09:14 +00:00
|
|
|
"github.com/chrislusf/seaweedfs/weed/glog"
|
2014-05-20 02:18:39 +00:00
|
|
|
)
|
|
|
|
|
2018-10-15 06:12:43 +00:00
|
|
|
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
|
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
|
|
|
}
|
2018-10-15 06:12:43 +00:00
|
|
|
func (s *Store) CompactVolume(vid VolumeId, preallocate int64) error {
|
2014-05-20 02:18:39 +00:00
|
|
|
if v := s.findVolume(vid); v != nil {
|
2017-08-30 06:59:53 +00:00
|
|
|
return v.Compact(preallocate)
|
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
|
|
|
}
|
2018-10-15 06:12:43 +00:00
|
|
|
func (s *Store) CommitCompactVolume(vid VolumeId) error {
|
2014-05-20 02:18:39 +00:00
|
|
|
if v := s.findVolume(vid); v != nil {
|
|
|
|
return v.commitCompact()
|
|
|
|
}
|
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
|
|
|
}
|
2018-10-15 06:12:43 +00:00
|
|
|
func (s *Store) CommitCleanupVolume(vid VolumeId) error {
|
2017-08-30 06:59:53 +00:00
|
|
|
if v := s.findVolume(vid); v != nil {
|
|
|
|
return v.cleanupCompact()
|
|
|
|
}
|
|
|
|
return fmt.Errorf("volume id %d is not found during cleaning up", vid)
|
|
|
|
}
|