gibheer/bleve
0
0
Fork 0
Code

fsync rootBolt when persisting snapshot

Browse Source
This commit is contained in:
Marty Schoch 2017-12-13 13:55:06 -05:00
parent f83c9f2a20
commit cd45487cb3
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
index/scorch/persister.go
View File

@ -109,6 +109,13 @@ func (s *Scorch) persistSnapshot(snapshot *IndexSnapshot) error {
if err != nil { if err != nil {
return err return err
} }
// defer fsync of the rootbolt
defer func() {
if err == nil {
err = s.rootBolt.Sync()
}
}()
// defer commit/rollback transaction
defer func() { defer func() {
if err == nil { if err == nil {
err = tx.Commit() err = tx.Commit()