diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-02-04 10:38:12 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-02-04 10:38:12 -0800 |
| commit | 08e47025427bf2764cf06853e169398ee84b7b09 (patch) | |
| tree | 3e87aac1690cd444c9b2d820bdfd70864cc8a4a3 | |
| parent | 3a35632d586a9a12115ff7204db6e2b8ee855e15 (diff) | |
| download | seaweedfs-08e47025427bf2764cf06853e169398ee84b7b09.tar.xz seaweedfs-08e47025427bf2764cf06853e169398ee84b7b09.zip | |
sync before closing index file
merge from https://github.com/stlpmo-jn/seaweedfs/commit/0181f87d9142852f981541cb05689df9fc9ef6a0
| -rw-r--r-- | weed/storage/needle_map_memory.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/storage/needle_map_memory.go b/weed/storage/needle_map_memory.go index 37dee7889..84197912f 100644 --- a/weed/storage/needle_map_memory.go +++ b/weed/storage/needle_map_memory.go @@ -64,6 +64,10 @@ func (nm *NeedleMap) Delete(key NeedleId, offset Offset) error { return nm.appendToIndexFile(key, offset, TombstoneFileSize) } func (nm *NeedleMap) Close() { + indexFileName := nm.indexFile.Name() + if err := nm.indexFile.Sync(); err != nil { + glog.Warningf("sync file %s failed, %v", indexFileName, err) + } _ = nm.indexFile.Close() } func (nm *NeedleMap) Destroy() error { |