240 lines
6.1 KiB
Go
240 lines
6.1 KiB
Go
package storage
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/filecoin-project/go-address"
|
|
"github.com/filecoin-project/specs-actors/actors/abi"
|
|
"github.com/filecoin-project/specs-actors/actors/builtin"
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/miner"
|
|
"github.com/filecoin-project/specs-actors/actors/crypto"
|
|
"go.opencensus.io/trace"
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/lotus/chain/actors"
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
)
|
|
|
|
func (s *WindowPoStScheduler) failPost(deadline *miner.DeadlineInfo) {
|
|
log.Errorf("TODO")
|
|
/*s.failLk.Lock()
|
|
if eps > s.failed {
|
|
s.failed = eps
|
|
}
|
|
s.failLk.Unlock()*/
|
|
}
|
|
|
|
func (s *WindowPoStScheduler) doPost(ctx context.Context, deadline *miner.DeadlineInfo, ts *types.TipSet) {
|
|
ctx, abort := context.WithCancel(ctx)
|
|
|
|
s.abort = abort
|
|
s.activeDeadline = deadline
|
|
|
|
go func() {
|
|
defer abort()
|
|
|
|
ctx, span := trace.StartSpan(ctx, "WindowPoStScheduler.doPost")
|
|
defer span.End()
|
|
|
|
proof, err := s.runPost(ctx, *deadline, ts)
|
|
if err != nil {
|
|
log.Errorf("runPost failed: %+v", err)
|
|
s.failPost(deadline)
|
|
return
|
|
}
|
|
|
|
if err := s.submitPost(ctx, proof); err != nil {
|
|
log.Errorf("submitPost failed: %+v", err)
|
|
s.failPost(deadline)
|
|
return
|
|
}
|
|
|
|
}()
|
|
}
|
|
|
|
func (s *WindowPoStScheduler) checkFaults(ctx context.Context, ssi []abi.SectorNumber) ([]abi.SectorNumber, error) {
|
|
//faults := s.prover.Scrub(ssi)
|
|
log.Warnf("Stub checkFaults")
|
|
var faults []struct {
|
|
SectorNum abi.SectorNumber
|
|
Err error
|
|
}
|
|
|
|
declaredFaults := map[abi.SectorNumber]struct{}{}
|
|
|
|
{
|
|
chainFaults, err := s.api.StateMinerFaults(ctx, s.actor, types.EmptyTSK)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("checking on-chain faults: %w", err)
|
|
}
|
|
|
|
for _, fault := range chainFaults {
|
|
declaredFaults[fault] = struct{}{}
|
|
}
|
|
}
|
|
|
|
var faultIDs []abi.SectorNumber
|
|
if len(faults) > 0 {
|
|
panic("Aaaaaaaaaaaaaaaaaaaa")
|
|
}
|
|
|
|
return faultIDs, nil
|
|
}
|
|
|
|
func (s *WindowPoStScheduler) runPost(ctx context.Context, di miner.DeadlineInfo, ts *types.TipSet) (*miner.SubmitWindowedPoStParams, error) {
|
|
ctx, span := trace.StartSpan(ctx, "storage.runPost")
|
|
defer span.End()
|
|
|
|
buf := new(bytes.Buffer)
|
|
if err := s.actor.MarshalCBOR(buf); err != nil {
|
|
return nil, xerrors.Errorf("failed to marshal address to cbor: %w", err)
|
|
}
|
|
rand, err := s.api.ChainGetRandomness(ctx, ts.Key(), crypto.DomainSeparationTag_WindowedPoStChallengeSeed, di.Challenge, buf.Bytes())
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("failed to get chain randomness for windowPost (ts=%d; deadline=%d): %w", ts.Height(), di, err)
|
|
}
|
|
|
|
deadlines, err := s.api.StateMinerDeadlines(ctx, s.actor, ts.Key())
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
firstPartition, _, err := miner.PartitionsForDeadline(deadlines, di.Index)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("getting partitions for deadline: %w", err)
|
|
}
|
|
|
|
partitionCount, _, err := miner.DeadlineCount(deadlines, di.Index)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("getting deadline partition count: %w", err)
|
|
}
|
|
|
|
if partitionCount == 0 {
|
|
return nil, xerrors.Errorf("runPost with no partitions!")
|
|
}
|
|
|
|
partitions := make([]uint64, partitionCount)
|
|
for i := range partitions {
|
|
partitions[i] = firstPartition + uint64(i)
|
|
}
|
|
|
|
ssi, err := s.sortedSectorInfo(ctx, deadlines.Due[di.Index], ts)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("getting sorted sector info: %w", err)
|
|
}
|
|
|
|
if len(ssi) == 0 {
|
|
log.Warn("attempted to run windowPost without any sectors...")
|
|
return nil, xerrors.Errorf("no sectors to run windowPost on")
|
|
}
|
|
|
|
log.Infow("running windowPost",
|
|
"chain-random", rand,
|
|
"deadline", di,
|
|
"height", ts.Height())
|
|
|
|
var snums []abi.SectorNumber
|
|
for _, si := range ssi {
|
|
snums = append(snums, si.SectorNumber)
|
|
}
|
|
|
|
faults, err := s.checkFaults(ctx, snums)
|
|
if err != nil {
|
|
log.Errorf("Failed to declare faults: %+v", err)
|
|
}
|
|
|
|
tsStart := time.Now()
|
|
|
|
log.Infow("generating windowPost",
|
|
"sectors", len(ssi),
|
|
"faults", len(faults))
|
|
|
|
mid, err := address.IDFromAddress(s.actor)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// TODO: Faults!
|
|
postOut, err := s.prover.GenerateWindowPoSt(ctx, abi.ActorID(mid), ssi, abi.PoStRandomness(rand))
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("running post failed: %w", err)
|
|
}
|
|
|
|
if len(postOut) == 0 {
|
|
return nil, xerrors.Errorf("received proofs back from generate window post")
|
|
}
|
|
|
|
elapsed := time.Since(tsStart)
|
|
log.Infow("submitting PoSt", "elapsed", elapsed)
|
|
|
|
return &miner.SubmitWindowedPoStParams{
|
|
Partitions: partitions,
|
|
Proofs: postOut,
|
|
Skipped: *abi.NewBitField(), // TODO: Faults here?
|
|
}, nil
|
|
}
|
|
|
|
func (s *WindowPoStScheduler) sortedSectorInfo(ctx context.Context, deadlineSectors *abi.BitField, ts *types.TipSet) ([]abi.SectorInfo, error) {
|
|
sset, err := s.api.StateMinerSectors(ctx, s.actor, deadlineSectors, ts.Key())
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
sbsi := make([]abi.SectorInfo, len(sset))
|
|
for k, sector := range sset {
|
|
sbsi[k] = abi.SectorInfo{
|
|
SectorNumber: sector.ID,
|
|
SealedCID: sector.Info.Info.SealedCID,
|
|
RegisteredProof: sector.Info.Info.RegisteredProof,
|
|
}
|
|
}
|
|
|
|
return sbsi, nil
|
|
}
|
|
|
|
func (s *WindowPoStScheduler) submitPost(ctx context.Context, proof *miner.SubmitWindowedPoStParams) error {
|
|
ctx, span := trace.StartSpan(ctx, "storage.commitPost")
|
|
defer span.End()
|
|
|
|
enc, aerr := actors.SerializeParams(proof)
|
|
if aerr != nil {
|
|
return xerrors.Errorf("could not serialize submit post parameters: %w", aerr)
|
|
}
|
|
|
|
msg := &types.Message{
|
|
To: s.actor,
|
|
From: s.worker,
|
|
Method: builtin.MethodsMiner.SubmitWindowedPoSt,
|
|
Params: enc,
|
|
Value: types.NewInt(1000), // currently hard-coded late fee in actor, returned if not late
|
|
GasLimit: 10000000, // i dont know help
|
|
GasPrice: types.NewInt(1),
|
|
}
|
|
|
|
// TODO: consider maybe caring about the output
|
|
sm, err := s.api.MpoolPushMessage(ctx, msg)
|
|
if err != nil {
|
|
return xerrors.Errorf("pushing message to mpool: %w", err)
|
|
}
|
|
|
|
log.Infof("Submitted fallback post: %s", sm.Cid())
|
|
|
|
go func() {
|
|
rec, err := s.api.StateWaitMsg(context.TODO(), sm.Cid())
|
|
if err != nil {
|
|
log.Error(err)
|
|
return
|
|
}
|
|
|
|
if rec.Receipt.ExitCode == 0 {
|
|
return
|
|
}
|
|
|
|
log.Errorf("Submitting fallback post %s failed: exit %d", sm.Cid(), rec.Receipt.ExitCode)
|
|
}()
|
|
|
|
return nil
|
|
}
|