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

Get the good sectors to run windowPost

Browse Source
This commit is contained in:
奇 2020-06-23 20:46:41 +08:00
parent 956c397c3c
commit 55ed45f108
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
storage/wdpost_run.go
View File

@ -383,25 +383,25 @@ func (s *WindowPoStScheduler) runPost(ctx context.Context, di miner.DeadlineInfo
return nil, xerrors.Errorf("get need prove sectors: %w", err) return nil, xerrors.Errorf("get need prove sectors: %w", err)
} }
var skipped *abi.BitField // var skipped *abi.BitField
{ // {
good, err := s.checkSectors(ctx, nps) good, err := s.checkSectors(ctx, nps)
if err != nil { if err != nil {
return nil, xerrors.Errorf("checking sectors to skip: %w", err) return nil, xerrors.Errorf("checking sectors to skip: %w", err)
}
skipped, err = bitfield.SubtractBitField(nps, good)
if err != nil {
return nil, xerrors.Errorf("nps - good: %w", err)
}
} }
skipped, err := bitfield.SubtractBitField(nps, good)
if err != nil {
return nil, xerrors.Errorf("nps - good: %w", err)
}
// }
skipCount, err := skipped.Count() skipCount, err := skipped.Count()
if err != nil { if err != nil {
return nil, xerrors.Errorf("getting skipped sector count: %w", err) return nil, xerrors.Errorf("getting skipped sector count: %w", err)
} }
ssi, err := s.sortedSectorInfo(ctx, nps, ts) ssi, err := s.sortedSectorInfo(ctx, good, ts)
if err != nil { if err != nil {
return nil, xerrors.Errorf("getting sorted sector info: %w", err) return nil, xerrors.Errorf("getting sorted sector info: %w", err)
} }