cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

add blockstore 'Has' caching

Browse Source
This commit is contained in:
Jeromy 2020-05-16 11:31:14 -07:00
parent 54b3eafd6d
commit 9804bd3c4c
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/lotus-bench/import.go
View File

@ -67,6 +67,11 @@ var importBenchCmd = &cli.Command{
return err return err
} }
bs := blockstore.NewBlockstore(bds) bs := blockstore.NewBlockstore(bds)
cbs, err := blockstore.CachedBlockstore(context.TODO(), bs, blockstore.DefaultCacheOpts())
if err != nil {
return err
}
bs = cbs
ds := datastore.NewMapDatastore() ds := datastore.NewMapDatastore()
cs := store.NewChainStore(bs, ds, vm.Syscalls(ffiwrapper.ProofVerifier)) cs := store.NewChainStore(bs, ds, vm.Syscalls(ffiwrapper.ProofVerifier))
stm := stmgr.NewStateManager(cs) stm := stmgr.NewStateManager(cs)

9
node/modules/chain.go
View File

@ -60,14 +60,19 @@ func MessagePool(lc fx.Lifecycle, sm *stmgr.StateManager, ps *pubsub.PubSub, ds
return mp, nil return mp, nil
} }
func ChainBlockstore(r repo.LockedRepo) (dtypes.ChainBlockstore, error) { func ChainBlockstore(lc fx.Lifecycle, mctx helpers.MetricsCtx, r repo.LockedRepo) (dtypes.ChainBlockstore, error) {
blocks, err := r.Datastore("/blocks") blocks, err := r.Datastore("/blocks")
if err != nil { if err != nil {
return nil, err return nil, err
} }
bs := blockstore.NewBlockstore(blocks) bs := blockstore.NewBlockstore(blocks)
return blockstore.NewIdStore(bs), nil cbs, err := blockstore.CachedBlockstore(helpers.LifecycleCtx(mctx, lc), bs, blockstore.DefaultCacheOpts())
if err != nil {
return nil, err
}
return blockstore.NewIdStore(cbs), nil
} }
func ChainGCBlockstore(bs dtypes.ChainBlockstore, gcl dtypes.ChainGCLocker) dtypes.ChainGCBlockstore { func ChainGCBlockstore(bs dtypes.ChainBlockstore, gcl dtypes.ChainGCLocker) dtypes.ChainGCBlockstore {