diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-02-04 10:37:14 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-02-04 10:37:14 -0800 |
| commit | 3a35632d586a9a12115ff7204db6e2b8ee855e15 (patch) | |
| tree | 9c6a80a5cd35eab7bcce019862ed9df2144f9a3f | |
| parent | dc786a63ac658c6b527d3b5a8e426cb9b8969a20 (diff) | |
| download | seaweedfs-3a35632d586a9a12115ff7204db6e2b8ee855e15.tar.xz seaweedfs-3a35632d586a9a12115ff7204db6e2b8ee855e15.zip | |
sync before closing file
merge changes from https://github.com/stlpmo-jn/seaweedfs/commit/1747fc2d523a42af6cade446c56317d840bd2c67
| -rw-r--r-- | weed/storage/needle_map_leveldb.go | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/weed/storage/needle_map_leveldb.go b/weed/storage/needle_map_leveldb.go index ef8571e83..3bb258559 100644 --- a/weed/storage/needle_map_leveldb.go +++ b/weed/storage/needle_map_leveldb.go @@ -128,8 +128,17 @@ func (m *LevelDbNeedleMap) Delete(key NeedleId, offset Offset) error { } func (m *LevelDbNeedleMap) Close() { - m.indexFile.Close() - m.db.Close() + indexFileName := m.indexFile.Name() + if err := m.indexFile.Sync(); err != nil { + glog.Warningf("sync file %s failed: %v", indexFileName, err) + } + if err := m.indexFile.Close(); err != nil { + glog.Warningf("close index file %s failed: %v", indexFileName, err) + } + + if err := m.db.Close(); err != nil { + glog.Warningf("close levelDB failed: %v", err) + } } func (m *LevelDbNeedleMap) Destroy() error { |