autobatch: don't forget to flush on delete

ipfs · Apr 13, 2019 · 534082e · 534082e
1 parent f0357db
commit 534082e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/autobatch/autobatch.go b/autobatch/autobatch.go
@@ -36,6 +36,9 @@ func NewAutoBatching(d ds.Batching, size int) *Datastore {
 // Delete deletes a key/value
 func (d *Datastore) Delete(k ds.Key) error {
 	d.buffer[k] = op{delete: true}
+	if len(d.buffer) > d.maxBufferEntries {
+		return d.Flush()
+	}
 	return nil
 }