scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-05 16:15:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #89 from benbjohnson/buffered-import

Browse source 
Add buffered snapshot writer
This commit is contained in:
tgruben 2016-06-10 10:00:43 -05:00 • committed by GitHub
commit aaea7a16f9
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
fragment.go
View file

@ -2,6 +2,7 @@ package pilosa
import (
"archive/tar"
"bufio"
"bytes"
"crypto/sha1"
"encoding/binary"
@ -906,8 +907,11 @@ func (f *Fragment) snapshot() error {
defer file.Close()
// Write storage to snapshot.
if _, err := f.storage.WriteTo(file); err != nil {
bw := bufio.NewWriter(file)
if _, err := f.storage.WriteTo(bw); err != nil {
return fmt.Errorf("snapshot write to: %s", err)
} else if err := bw.Flush(); err != nil {
return fmt.Errorf("flush: %s", err)
}
// Close current storage.