diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-10-29 23:18:01 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-10-29 23:18:01 -0700 |
| commit | 57e441d67be69311b2428d88dd41b5791ee51f99 (patch) | |
| tree | 4c4ee8950272c6da7f83e24054fad2f707773f5a | |
| parent | d4f755347e4874cf0a2fd13480580f348b86a465 (diff) | |
| download | seaweedfs-57e441d67be69311b2428d88dd41b5791ee51f99.tar.xz seaweedfs-57e441d67be69311b2428d88dd41b5791ee51f99.zip | |
fix compaction logic
| -rw-r--r-- | weed/storage/volume_vacuum.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/storage/volume_vacuum.go b/weed/storage/volume_vacuum.go index 73314f022..0e5130572 100644 --- a/weed/storage/volume_vacuum.go +++ b/weed/storage/volume_vacuum.go @@ -23,7 +23,7 @@ func (v *Volume) garbageLevel() float64 { func (v *Volume) Compact(preallocate int64, compactionBytePerSecond int64) error { - if v.MemoryMapMaxSizeMb > 0 { //it makes no sense to compact in memory + if v.MemoryMapMaxSizeMb == 0 { //it makes no sense to compact in memory glog.V(3).Infof("Compacting volume %d ...", v.Id) //no need to lock for copy on write //v.accessLock.Lock() @@ -46,7 +46,7 @@ func (v *Volume) Compact(preallocate int64, compactionBytePerSecond int64) error func (v *Volume) Compact2() error { - if v.MemoryMapMaxSizeMb > 0 { //it makes no sense to compact in memory + if v.MemoryMapMaxSizeMb == 0 { //it makes no sense to compact in memory glog.V(3).Infof("Compact2 volume %d ...", v.Id) v.isCompacting = true @@ -63,7 +63,7 @@ func (v *Volume) Compact2() error { } func (v *Volume) CommitCompact() error { - if v.MemoryMapMaxSizeMb > 0 { //it makes no sense to compact in memory + if v.MemoryMapMaxSizeMb == 0 { //it makes no sense to compact in memory glog.V(0).Infof("Committing volume %d vacuuming...", v.Id) v.isCompacting = true |