aboutsummaryrefslogtreecommitdiff
path: root/go/storage/volume.go
diff options
context:
space:
mode:
Diffstat (limited to 'go/storage/volume.go')
-rw-r--r--go/storage/volume.go28
1 files changed, 0 insertions, 28 deletions
diff --git a/go/storage/volume.go b/go/storage/volume.go
index 9ec112c57..bfdac8edf 100644
--- a/go/storage/volume.go
+++ b/go/storage/volume.go
@@ -281,34 +281,6 @@ func (v *Volume) read(n *Needle) (int, error) {
return -1, errors.New("Not Found")
}
-func (v *Volume) garbageLevel() float64 {
- return float64(v.nm.DeletedSize()) / float64(v.ContentSize())
-}
-
-func (v *Volume) Compact() error {
- v.accessLock.Lock()
- defer v.accessLock.Unlock()
-
- filePath := v.FileName()
- glog.V(3).Infof("creating copies for volume %d ...", v.Id)
- return v.copyDataAndGenerateIndexFile(filePath+".cpd", filePath+".cpx")
-}
-func (v *Volume) commitCompact() error {
- v.accessLock.Lock()
- defer v.accessLock.Unlock()
- _ = v.dataFile.Close()
- var e error
- if e = os.Rename(v.FileName()+".cpd", v.FileName()+".dat"); e != nil {
- return e
- }
- if e = os.Rename(v.FileName()+".cpx", v.FileName()+".idx"); e != nil {
- return e
- }
- if e = v.load(true, false); e != nil {
- return e
- }
- return nil
-}
func (v *Volume) freeze() error {
if v.readOnly {
return nil