diff options
| author | Chris Lu <chris.lu@gmail.com> | 2016-05-09 10:04:21 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2016-05-09 10:04:21 -0700 |
| commit | 766512c47523f65b345331bb632bd6a864890fec (patch) | |
| tree | 592da5bee6cf39c2762abbb7655fa56cff101730 /go | |
| parent | 3626ec5cf7ccc08a2771a600644655e0ff83e925 (diff) | |
| download | seaweedfs-766512c47523f65b345331bb632bd6a864890fec.tar.xz seaweedfs-766512c47523f65b345331bb632bd6a864890fec.zip | |
close current needle map when switching
Diffstat (limited to 'go')
| -rw-r--r-- | go/storage/volume_vacuum.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/go/storage/volume_vacuum.go b/go/storage/volume_vacuum.go index 7377afdc9..5ba8d575c 100644 --- a/go/storage/volume_vacuum.go +++ b/go/storage/volume_vacuum.go @@ -28,6 +28,7 @@ func (v *Volume) commitCompact() error { v.dataFileAccessLock.Lock() defer v.dataFileAccessLock.Unlock() glog.V(3).Infof("Got Committing lock...") + v.nm.Close() _ = v.dataFile.Close() var e error if e = os.Rename(v.FileName()+".cpd", v.FileName()+".dat"); e != nil { |