gibheer/bleve
0
0
Fork 0
Code

firestorm close kvwriter sooner

Browse Source
This commit is contained in:
Steve Yen 2016-01-10 09:58:24 -08:00
parent d533b326f6
commit bff95eef70
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
index/firestorm/firestorm.go
View File

@ -346,6 +346,7 @@ func (f *Firestorm) Batch(batch *index.Batch) (err error) {
}
indexStart := time.Now()
// start a writer for this batch
var kvwriter store.KVWriter
kvwriter, err = f.store.Writer()
@ -362,10 +363,12 @@ func (f *Firestorm) Batch(batch *index.Batch) (err error) {
}
f.compensator.MutateBatch(inflightItems, lastDocNumber)
err = kvwriter.Close()
f.lookuper.NotifyBatch(inflightItems)
f.dictUpdater.NotifyBatch(dictionaryDeltas)
err = kvwriter.Close()
atomic.AddUint64(&f.stats.indexTime, uint64(time.Since(indexStart)))
if err == nil {