github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/{storage,mergeset}: sync filenames inside part when finalizing the part

Browse source 
Fixes https://github.com/VictoriaMetrics/VictoriaMetrics/issues/63
This commit is contained in:
Aliaksandr Valialkin 2019-06-11 21:46:21 +03:00
parent 3437c30180
commit b491045a4b
2 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/mergeset/block_stream_writer.go
View file

@ -151,6 +151,12 @@ func (bsw *blockStreamWriter) MustClose() {
bsw.itemsWriter.MustClose() bsw.itemsWriter.MustClose()
bsw.lensWriter.MustClose() bsw.lensWriter.MustClose()
// Sync bsw.path contents to make sure it doesn't disappear
// after system crash or power loss.
if bsw.path != "" {
fs.SyncPath(bsw.path)
}
bsw.reset() bsw.reset()
} }

6
lib/storage/block_stream_writer.go
View file

@ -146,6 +146,12 @@ func (bsw *blockStreamWriter) MustClose() {
bsw.indexWriter.MustClose() bsw.indexWriter.MustClose()
bsw.metaindexWriter.MustClose() bsw.metaindexWriter.MustClose()
// Sync bsw.path contents to make sure it doesn't disappear
// after system crash or power loss.
if bsw.path != "" {
fs.SyncPath(bsw.path)
}
bsw.reset() bsw.reset()
} }