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

fix(lotus-sim): mark provecommit stage initialized

Browse Source
This commit is contained in:
Steven Allen 2021-06-16 00:30:42 -07:00
parent f0d0b40bd3
commit a26cd5a809
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/lotus-sim/simulation/stages/provecommit_stage.go
View File

@ -348,14 +348,14 @@ func (stage *ProveCommitStage) filterProveCommits(
} }
func (stage *ProveCommitStage) load(ctx context.Context, bb *blockbuilder.BlockBuilder) error { func (stage *ProveCommitStage) load(ctx context.Context, bb *blockbuilder.BlockBuilder) error {
stage.commitQueue.advanceEpoch(bb.Height()) stage.initialized = false // in case something failes while we're doing this.
stage.commitQueue = commitQueue{offset: bb.Height()}
powerState, err := loadPower(bb.ActorStore(), bb.ParentStateTree()) powerState, err := loadPower(bb.ActorStore(), bb.ParentStateTree())
if err != nil { if err != nil {
return err return err
} }
return powerState.ForEachClaim(func(minerAddr address.Address, claim power.Claim) error { err = powerState.ForEachClaim(func(minerAddr address.Address, claim power.Claim) error {
// TODO: If we want to finish pre-commits for "new" miners, we'll need to change // TODO: If we want to finish pre-commits for "new" miners, we'll need to change
// this. // this.
if claim.RawBytePower.IsZero() { if claim.RawBytePower.IsZero() {
@ -363,4 +363,10 @@ func (stage *ProveCommitStage) load(ctx context.Context, bb *blockbuilder.BlockB
} }
return stage.loadMiner(ctx, bb, minerAddr) return stage.loadMiner(ctx, bb, minerAddr)
}) })
if err != nil {
return err
}
stage.initialized = true
return nil
} }