fix double mutex.

This commit is contained in:
Raúl Kripalani 2020-09-28 23:14:20 +01:00
parent 0070d2716c
commit 044674487e

View File

@ -42,14 +42,11 @@ type Stores struct {
// ChainReadObj RPC.
func NewProxyingStores(ctx context.Context, api api.FullNode) *Stores {
ds := dssync.MutexWrap(ds.NewMapDatastore())
ds = dssync.MutexWrap(ds)
bs := &proxyingBlockstore{
ctx: ctx,
api: api,
Blockstore: blockstore.NewBlockstore(ds),
}
return NewStores(ctx, ds, bs)
}