autobatch: fix flush on close

f0357dbc · Steven Allen · 301890e7 · f0357dbc
Commit f0357dbc authored Apr 12, 2019 by Steven Allen
Hide whitespace changes
Inline Side-by-side

Showing with 9 additions and 1 deletion

autobatch/autobatch.go autobatch/autobatch.go +9 -1

No files found.
--- a/autobatch/autobatch.go
+++ b/autobatch/autobatch.go
@@ -128,5 +128,13 @@ func (d *Datastore) DiskUsage() (uint64, error) {
 }

 func (d *Datastore) Close() error {
-	return d.child.Close()
+	err1 := d.Flush()
+	err2 := d.child.Close()
+	if err1 != nil {
+		return err1
+	}
+	if err2 != nil {
+		return err2
+	}
+	return nil
 }