From efe9ec4906d667a79f6d4860e5b9bf8e4af18f06 Mon Sep 17 00:00:00 2001 From: Aayush Rajasekaran Date: Wed, 12 Jan 2022 17:22:54 -0500 Subject: [PATCH] Add missing locks to Get() --- blockstore/autobatch.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/blockstore/autobatch.go b/blockstore/autobatch.go index 53764d15c..778995dbd 100644 --- a/blockstore/autobatch.go +++ b/blockstore/autobatch.go @@ -162,6 +162,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