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

wdpost: Only add proven partitions to message params

Browse Source
This commit is contained in:
Łukasz Magiera 2020-09-18 02:39:08 +02:00
parent dcc5643473
commit 8419dda84b
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
storage/wdpost_run.go
View File

@ -431,7 +431,9 @@ func (s *WindowPoStScheduler) runPost(ctx context.Context, di dline.Info, ts *ty
postSkipped := bitfield.New() postSkipped := bitfield.New()
var postOut []proof.PoStProof var postOut []proof.PoStProof
somethingToProve := true somethingToProve := true
for retries := 0; retries < 5; retries++ { for retries := 0; retries < 5; retries++ {
var partitions []miner.PoStPartition
var sinfos []proof.SectorInfo var sinfos []proof.SectorInfo
for partIdx, partition := range batch { for partIdx, partition := range batch {
// TODO: Can do this in parallel // TODO: Can do this in parallel
@ -477,7 +479,7 @@ func (s *WindowPoStScheduler) runPost(ctx context.Context, di dline.Info, ts *ty
} }
sinfos = append(sinfos, ssi...) sinfos = append(sinfos, ssi...)
params.Partitions = append(params.Partitions, miner.PoStPartition{ partitions = append(params.Partitions, miner.PoStPartition{
Index: uint64(batchPartitionStartIdx + partIdx), Index: uint64(batchPartitionStartIdx + partIdx),
Skipped: skipped, Skipped: skipped,
}) })
@ -511,6 +513,8 @@ func (s *WindowPoStScheduler) runPost(ctx context.Context, di dline.Info, ts *ty
if err == nil { if err == nil {
// Proof generation successful, stop retrying // Proof generation successful, stop retrying
params.Partitions = append(params.Partitions, partitions...)
break break
} }