Add missing locks to Get()

filecoin-project · Jan 14, 2022 · d457cb5 · d457cb5
1 parent 0ec8efd
commit d457cb5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/blockstore/autobatch.go b/blockstore/autobatch.go
@@ -180,6 +180,8 @@ func (bs *AutobatchBlockstore) Get(ctx context.Context, c cid.Cid) (block.Block,
 		return blk, err
 	}
 
+	bs.stateLock.Lock()
+	defer bs.stateLock.Unlock()
 	v, ok := bs.flushingBatch.blockMap[c]
 	if ok {
 		return v, nil