diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-10 13:31:23 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-10 13:31:23 -0700 |
| commit | 43e626157956db8687ec5001171a5b2e1ffaae08 (patch) | |
| tree | 88561391a647f190806e338d08ac1f88f6b92e5a | |
| parent | d214cefc2e9ad7c6a4c60cbbd934f164aa91663e (diff) | |
| download | seaweedfs-43e626157956db8687ec5001171a5b2e1ffaae08.tar.xz seaweedfs-43e626157956db8687ec5001171a5b2e1ffaae08.zip | |
volume: fix memory leak
| -rw-r--r-- | weed/storage/volume_vacuum.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/storage/volume_vacuum.go b/weed/storage/volume_vacuum.go index 185484477..c8be1d9f5 100644 --- a/weed/storage/volume_vacuum.go +++ b/weed/storage/volume_vacuum.go @@ -342,6 +342,7 @@ func (v *Volume) copyDataAndGenerateIndexFile(dstName, idxName string, prealloca defer dst.Close() nm := needle_map.NewMemDb() + defer nm.Close() scanner := &VolumeFileScanner4Vacuum{ v: v, @@ -370,7 +371,9 @@ func copyDataBasedOnIndexFile(srcDatName, srcIdxName, dstDatName, datIdxName str defer dstDatBackend.Close() oldNm := needle_map.NewMemDb() + defer oldNm.Close() newNm := needle_map.NewMemDb() + defer newNm.Close() if err = oldNm.LoadFromIdx(srcIdxName); err != nil { return } |