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

verifier: Skip sectors which can't be acquired

Browse Source
This commit is contained in:
Łukasz Magiera 2020-06-08 19:36:41 +02:00
parent 8c58fcb1cc
commit 8e489cdbdb
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
ffiwrapper/verifier_cgo.go
View File

@ -44,15 +44,20 @@ func (sb *Sealer) pubSectorToPriv(ctx context.Context, mid abi.ActorID, sectorIn
fmap[fault] = struct{}{} fmap[fault] = struct{}{}
} }
var skipped []abi.SectorID
var out []ffi.PrivateSectorInfo var out []ffi.PrivateSectorInfo
for _, s := range sectorInfo { for _, s := range sectorInfo {
if _, faulty := fmap[s.SectorNumber]; faulty { if _, faulty := fmap[s.SectorNumber]; faulty {
continue continue
} }
paths, done, err := sb.sectors.AcquireSector(ctx, abi.SectorID{Miner: mid, Number: s.SectorNumber}, stores.FTCache|stores.FTSealed, 0, false) sid := abi.SectorID{Miner: mid, Number: s.SectorNumber}
paths, done, err := sb.sectors.AcquireSector(ctx, sid, stores.FTCache|stores.FTSealed, 0, false)
if err != nil { if err != nil {
return ffi.SortedPrivateSectorInfo{}, nil, xerrors.Errorf("acquire sector paths: %w", err) log.Warnw("failed to acquire sector, skipping", "sector", sid, "error", err)
skipped = append(skipped, sid)
continue
} }
done() // TODO: This is a tiny bit suboptimal done() // TODO: This is a tiny bit suboptimal
@ -69,7 +74,7 @@ func (sb *Sealer) pubSectorToPriv(ctx context.Context, mid abi.ActorID, sectorIn
}) })
} }
return ffi.NewSortedPrivateSectorInfo(out...), nil, nil return ffi.NewSortedPrivateSectorInfo(out...), skipped, nil
} }
var _ Verifier = ProofVerifier var _ Verifier = ProofVerifier