commit
b584f44661
@ -560,12 +560,12 @@ func (s *WindowPoStScheduler) runPoStCycle(ctx context.Context, di dline.Info, t
|
|||||||
Proofs: nil,
|
Proofs: nil,
|
||||||
}
|
}
|
||||||
|
|
||||||
skipCount := uint64(0)
|
|
||||||
postSkipped := bitfield.New()
|
postSkipped := bitfield.New()
|
||||||
somethingToProve := false
|
somethingToProve := false
|
||||||
|
|
||||||
// Retry until we run out of sectors to prove.
|
// Retry until we run out of sectors to prove.
|
||||||
for retries := 0; ; retries++ {
|
for retries := 0; ; retries++ {
|
||||||
|
skipCount := uint64(0)
|
||||||
var partitions []miner.PoStPartition
|
var partitions []miner.PoStPartition
|
||||||
var sinfos []proof2.SectorInfo
|
var sinfos []proof2.SectorInfo
|
||||||
for partIdx, partition := range batch {
|
for partIdx, partition := range batch {
|
||||||
@ -705,7 +705,6 @@ func (s *WindowPoStScheduler) runPoStCycle(ctx context.Context, di dline.Info, t
|
|||||||
return nil, ctx.Err()
|
return nil, ctx.Err()
|
||||||
}
|
}
|
||||||
|
|
||||||
skipCount += uint64(len(ps))
|
|
||||||
for _, sector := range ps {
|
for _, sector := range ps {
|
||||||
postSkipped.Set(uint64(sector.Number))
|
postSkipped.Set(uint64(sector.Number))
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user