hook the upgrade schedule to splitstore start

This commit is contained in:
vyzo 2021-12-03 12:11:54 +02:00 committed by Jennifer Wang
parent 6cfee12f31
commit 7e43bfc109

View File

@ -78,6 +78,7 @@ func ChainStore(lc fx.Lifecycle,
ds dtypes.MetadataDS, ds dtypes.MetadataDS,
basebs dtypes.BaseBlockstore, basebs dtypes.BaseBlockstore,
weight store.WeightFunc, weight store.WeightFunc,
us stmgr.UpgradeSchedule,
j journal.Journal) *store.ChainStore { j journal.Journal) *store.ChainStore {
chain := store.NewChainStore(cbs, sbs, ds, weight, j) chain := store.NewChainStore(cbs, sbs, ds, weight, j)
@ -89,7 +90,7 @@ func ChainStore(lc fx.Lifecycle,
var startHook func(context.Context) error var startHook func(context.Context) error
if ss, ok := basebs.(*splitstore.SplitStore); ok { if ss, ok := basebs.(*splitstore.SplitStore); ok {
startHook = func(_ context.Context) error { startHook = func(_ context.Context) error {
err := ss.Start(chain) err := ss.Start(chain, us)
if err != nil { if err != nil {
err = xerrors.Errorf("error starting splitstore: %w", err) err = xerrors.Errorf("error starting splitstore: %w", err)
} }