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

sealing: Check ticket expiration

Browse Source
This commit is contained in:
Łukasz Magiera 2020-01-23 15:05:44 +01:00
parent 8414569428
commit 02c8ab7839
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
storage/sealing/checks.go
View File

@ -6,6 +6,8 @@ import (
"golang.org/x/xerrors" "golang.org/x/xerrors"
"github.com/filecoin-project/go-address" "github.com/filecoin-project/go-address"
"github.com/filecoin-project/lotus/build"
"github.com/filecoin-project/lotus/chain/actors" "github.com/filecoin-project/lotus/chain/actors"
"github.com/filecoin-project/lotus/chain/types" "github.com/filecoin-project/lotus/chain/types"
) )
@ -15,6 +17,9 @@ type ErrApi error
type ErrInvalidDeals error type ErrInvalidDeals error
type ErrExpiredDeals error type ErrExpiredDeals error
type ErrBadCommD error
type ErrExpiredTicket error
func checkPieces(ctx context.Context, si SectorInfo, api sealingApi) error { func checkPieces(ctx context.Context, si SectorInfo, api sealingApi) error {
head, err := api.ChainHead(ctx) head, err := api.ChainHead(ctx)
if err != nil { if err != nil {
@ -44,9 +49,14 @@ func checkPieces(ctx context.Context, si SectorInfo, api sealingApi) error {
} }
func checkSeal(ctx context.Context, maddr address.Address, si SectorInfo, api sealingApi) (err error) { func checkSeal(ctx context.Context, maddr address.Address, si SectorInfo, api sealingApi) (err error) {
ssize, err := api.StateMinerSectorSize(ctx, maddr, nil) head, err := api.ChainHead(ctx)
if err != nil { if err != nil {
return err return ErrApi(xerrors.Errorf("getting chain head: %w", err))
}
ssize, err := api.StateMinerSectorSize(ctx, maddr, head)
if err != nil {
return ErrApi(err)
} }
ccparams, err := actors.SerializeParams(&actors.ComputeDataCommitmentParams{ ccparams, err := actors.SerializeParams(&actors.ComputeDataCommitmentParams{
@ -71,10 +81,14 @@ func checkSeal(ctx context.Context, maddr address.Address, si SectorInfo, api se
return xerrors.Errorf("calling ComputeDataCommitment: %w", err) return xerrors.Errorf("calling ComputeDataCommitment: %w", err)
} }
if r.ExitCode != 0 { if r.ExitCode != 0 {
return xerrors.Errorf("receipt for ComputeDataCommitment had exit code %d", r.ExitCode) return ErrBadCommD(xerrors.Errorf("receipt for ComputeDataCommitment had exit code %d", r.ExitCode))
} }
if string(r.Return) != string(si.CommD) { if string(r.Return) != string(si.CommD) {
return xerrors.Errorf("on chain CommD differs from sector: %x != %x", r.Return, si.CommD) return ErrBadCommD(xerrors.Errorf("on chain CommD differs from sector: %x != %x", r.Return, si.CommD))
}
if int64(head.Height()) - int64(si.Ticket.BlockHeight + build.SealRandomnessLookback) > build.SealRandomnessLookbackLimit {
return ErrExpiredTicket(xerrors.Errorf("ticket expired: seal height: %d, head: %d", si.Ticket.BlockHeight + build.SealRandomnessLookback, head.Height()))
} }
return nil return nil