Merge pull request #87 from ipfs/fix/query-verify-open

fix: verify that the datastore is still open when querying
ipfs · Apr 8, 2020 · 9efc1de · 9efc1de
2 parents adacbc2 + 390ae7d
commit 9efc1de
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/datastore.go b/datastore.go
@@ -342,6 +342,9 @@ func (d *Datastore) Delete(key ds.Key) error {
 func (d *Datastore) Query(q dsq.Query) (dsq.Results, error) {
 	d.closeLk.RLock()
 	defer d.closeLk.RUnlock()
+	if d.closed {
+		return nil, ErrClosed
+	}
 
 	txn := d.newImplicitTransaction(true)
 	// We cannot defer txn.Discard() here, as the txn must remain active while the iterator is open.