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

refactor genesis state loading code into its own method

Browse Source
This commit is contained in:
vyzo 2021-06-16 13:58:16 +03:00
parent 41573f1fb2
commit 7c814cd2e3
1 changed files with 65 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

121
blockstore/splitstore/splitstore.go
View File

@ -128,8 +128,6 @@ type SplitStore struct {
cold bstore.Blockstore cold bstore.Blockstore
tracker TrackingStore tracker TrackingStore
genesis, genesisStateRoot cid.Cid
env MarkSetEnv env MarkSetEnv
markSetSize int64 markSetSize int64
@ -329,60 +327,6 @@ func (s *SplitStore) Start(chain ChainAccessor) error {
s.chain = chain s.chain = chain
s.curTs = chain.GetHeaviestTipSet() s.curTs = chain.GetHeaviestTipSet()
// make sure the genesis and its state root are hot
gb, err := chain.GetGenesis()
if err != nil {
return xerrors.Errorf("error getting genesis: %w", err)
}
s.genesis = gb.Cid()
s.genesisStateRoot = gb.ParentStateRoot
has, err := s.hot.Has(s.genesis)
if err != nil {
return xerrors.Errorf("error checking hotstore for genesis: %w", err)
}
if !has {
blk, err := gb.ToStorageBlock()
if err != nil {
return xerrors.Errorf("error converting genesis block to storage block: %w", err)
}
err = s.hot.Put(blk)
if err != nil {
return xerrors.Errorf("error putting genesis block to hotstore: %w", err)
}
}
err = s.walkLinks(s.genesisStateRoot, cid.NewSet(), func(c cid.Cid) error {
has, err = s.hot.Has(c)
if err != nil {
return xerrors.Errorf("error checking hotstore for genesis state root: %w", err)
}
if !has {
blk, err := s.cold.Get(c)
if err != nil {
if err == bstore.ErrNotFound {
return nil
}
return xerrors.Errorf("error retrieving genesis state linked object from coldstore: %w", err)
}
err = s.hot.Put(blk)
if err != nil {
return xerrors.Errorf("error putting genesis state linked object to hotstore: %w", err)
}
}
return nil
})
if err != nil {
return xerrors.Errorf("error walking genesis state root links: %w", err)
}
// load base epoch from metadata ds // load base epoch from metadata ds
// if none, then use current epoch because it's a fresh start // if none, then use current epoch because it's a fresh start
bs, err := s.ds.Get(baseEpochKey) bs, err := s.ds.Get(baseEpochKey)
@ -415,6 +359,12 @@ func (s *SplitStore) Start(chain ChainAccessor) error {
s.warm = true s.warm = true
case dstore.ErrNotFound: case dstore.ErrNotFound:
// the hotstore hasn't warmed up, load the genesis into the hotstore
err = s.loadGenesisState()
if err != nil {
return xerrors.Errorf("error loading genesis state: %w", err)
}
default: default:
return xerrors.Errorf("error loading warmup epoch: %w", err) return xerrors.Errorf("error loading warmup epoch: %w", err)
} }
@ -534,6 +484,65 @@ func (s *SplitStore) HeadChange(_, apply []*types.TipSet) error {
return nil return nil
} }
func (s *SplitStore) loadGenesisState() error {
// makes sure the genesis and its state root are hot
gb, err := s.chain.GetGenesis()
if err != nil {
return xerrors.Errorf("error getting genesis: %w", err)
}
genesis := gb.Cid()
genesisStateRoot := gb.ParentStateRoot
has, err := s.hot.Has(genesis)
if err != nil {
return xerrors.Errorf("error checking hotstore for genesis: %w", err)
}
if !has {
blk, err := gb.ToStorageBlock()
if err != nil {
return xerrors.Errorf("error converting genesis block to storage block: %w", err)
}
err = s.hot.Put(blk)
if err != nil {
return xerrors.Errorf("error putting genesis block to hotstore: %w", err)
}
}
err = s.walkLinks(genesisStateRoot, cid.NewSet(), func(c cid.Cid) error {
has, err = s.hot.Has(c)
if err != nil {
return xerrors.Errorf("error checking hotstore for genesis state root: %w", err)
}
if !has {
blk, err := s.cold.Get(c)
if err != nil {
if err == bstore.ErrNotFound {
return nil
}
return xerrors.Errorf("error retrieving genesis state linked object from coldstore: %w", err)
}
err = s.hot.Put(blk)
if err != nil {
return xerrors.Errorf("error putting genesis state linked object to hotstore: %w", err)
}
}
return nil
})
if err != nil {
return xerrors.Errorf("error walking genesis state root links: %w", err)
}
return nil
}
func (s *SplitStore) warmup(curTs *types.TipSet) error { func (s *SplitStore) warmup(curTs *types.TipSet) error {
epoch := curTs.Height() epoch := curTs.Height()