fix: verify that the datastore is still open when querying

fixes part of ipfs/kubo#6986 (the other part is that we should be shutting down in the right order)
ipfs · Apr 8, 2020 · 390ae7d · 390ae7d
1 parent adacbc2
commit 390ae7d
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.