window

package
v1.24.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 11, 2024 License: Apache-2.0, MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EpochsPerDeadline = miner.WPoStProvingPeriod() / abi.ChainEpoch(miner.WPoStPeriodDeadlines)

Functions

func NewDeadlineInfo 

func NewDeadlineInfo(periodStart abi.ChainEpoch, deadlineIdx uint64, currEpoch abi.ChainEpoch) *dline.Info

Types

type CheckSectorsAPI 

type CheckSectorsAPI interface {
	StateMinerSectors(ctx context.Context, addr address.Address, bf *bitfield.BitField, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
}

type FaultTracker added in v1.23.1 

type FaultTracker interface {
	CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storiface.SectorRef, rg storiface.RGetter) (map[abi.SectorID]string, error)
}

type MsgPrepAPI 

type MsgPrepAPI interface {
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	GasEstimateMessageGas(context.Context, *types.Message, *api.MessageSendSpec, types.TipSetKey) (*types.Message, error)
	GasEstimateFeeCap(context.Context, *types.Message, int64, types.TipSetKey) (types.BigInt, error)
	GasEstimateGasPremium(ctx context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (types.BigInt, error)

	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)
	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}

type ProverPoSt 

type ProverPoSt interface {
	GenerateWindowPoStAdv(ctx context.Context, ppt abi.RegisteredPoStProof, mid abi.ActorID, sectors []storiface.PostSectorChallenge, partitionIdx int, randomness abi.PoStRandomness, allowSkip bool) (storiface.WindowPoStResult, error)
}

type SimpleFaultTracker 

type SimpleFaultTracker struct {
	// contains filtered or unexported fields
}

func NewSimpleFaultTracker 

func NewSimpleFaultTracker(storage paths.Store, index paths.SectorIndex,
	parallelCheckLimit int, singleCheckTimeout time.Duration, partitionCheckTimeout time.Duration) *SimpleFaultTracker

func (*SimpleFaultTracker) CheckProvable 

func (m *SimpleFaultTracker) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storiface.SectorRef, rg storiface.RGetter) (map[abi.SectorID]string, error)

type WDPoStAPI 

type WDPoStAPI interface {
	ChainHead(context.Context) (*types.TipSet, error)
	ChainGetTipSet(context.Context, types.TipSetKey) (*types.TipSet, error)
	StateMinerProvingDeadline(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	ChainGetTipSetAfterHeight(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)
	StateMinerPartitions(context.Context, address.Address, uint64, types.TipSetKey) ([]api.Partition, error)
	StateGetRandomnessFromBeacon(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error)
	StateNetworkVersion(context.Context, types.TipSetKey) (network.Version, error)
	StateMinerSectors(context.Context, address.Address, *bitfield.BitField, types.TipSetKey) ([]*miner.SectorOnChainInfo, error)
}

type WdPoStSubmitTaskApi 

type WdPoStSubmitTaskApi interface {
	ChainHead(context.Context) (*types.TipSet, error)

	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)

	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	StateGetRandomnessFromTickets(ctx context.Context, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte, tsk types.TipSetKey) (abi.Randomness, error)

	GasEstimateMessageGas(context.Context, *types.Message, *api.MessageSendSpec, types.TipSetKey) (*types.Message, error)
	GasEstimateFeeCap(context.Context, *types.Message, int64, types.TipSetKey) (types.BigInt, error)
	GasEstimateGasPremium(_ context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (types.BigInt, error)
}

type WdPostRecoverDeclareTask 

type WdPostRecoverDeclareTask struct {
	// contains filtered or unexported fields
}

func NewWdPostRecoverDeclareTask 

func NewWdPostRecoverDeclareTask(sender *message.Sender,
	db *harmonydb.DB,
	api WdPostRecoverDeclareTaskApi,
	faultTracker FaultTracker,
	as *multictladdr.MultiAddressSelector,
	pcs *chainsched.CurioChainSched,

	maxDeclareRecoveriesGasFee types.FIL,
	actors map[dtypes.MinerAddress]bool) (*WdPostRecoverDeclareTask, error)

func (*WdPostRecoverDeclareTask) Adder 

func (w *WdPostRecoverDeclareTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*WdPostRecoverDeclareTask) CanAccept 

func (w *WdPostRecoverDeclareTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*WdPostRecoverDeclareTask) Do 

func (w *WdPostRecoverDeclareTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*WdPostRecoverDeclareTask) GetSpid added in v1.22.1 

func (w *WdPostRecoverDeclareTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*WdPostRecoverDeclareTask) TypeDetails 

func (w *WdPostRecoverDeclareTask) TypeDetails() harmonytask.TaskTypeDetails

type WdPostRecoverDeclareTaskApi 

type WdPostRecoverDeclareTaskApi interface {
	ChainHead(context.Context) (*types.TipSet, error)
	StateMinerProvingDeadline(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
	StateMinerPartitions(context.Context, address.Address, uint64, types.TipSetKey) ([]api.Partition, error)
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error)
	StateMinerSectors(ctx context.Context, addr address.Address, bf *bitfield.BitField, tsk types.TipSetKey) ([]*miner.SectorOnChainInfo, error)

	GasEstimateMessageGas(context.Context, *types.Message, *api.MessageSendSpec, types.TipSetKey) (*types.Message, error)
	GasEstimateFeeCap(context.Context, *types.Message, int64, types.TipSetKey) (types.BigInt, error)
	GasEstimateGasPremium(_ context.Context, nblocksincl uint64, sender address.Address, gaslimit int64, tsk types.TipSetKey) (types.BigInt, error)

	WalletBalance(context.Context, address.Address) (types.BigInt, error)
	WalletHas(context.Context, address.Address) (bool, error)
	StateAccountKey(context.Context, address.Address, types.TipSetKey) (address.Address, error)
	StateLookupID(context.Context, address.Address, types.TipSetKey) (address.Address, error)
}

type WdPostSubmitTask 

type WdPostSubmitTask struct {
	// contains filtered or unexported fields
}

func NewWdPostSubmitTask 

func NewWdPostSubmitTask(pcs *chainsched.CurioChainSched, send *message.Sender, db *harmonydb.DB, api WdPoStSubmitTaskApi, maxWindowPoStGasFee types.FIL, as *multictladdr.MultiAddressSelector) (*WdPostSubmitTask, error)

func (*WdPostSubmitTask) Adder 

func (w *WdPostSubmitTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*WdPostSubmitTask) CanAccept 

func (w *WdPostSubmitTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*WdPostSubmitTask) Do 

func (w *WdPostSubmitTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*WdPostSubmitTask) GetSpid added in v1.22.1 

func (w *WdPostSubmitTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*WdPostSubmitTask) TypeDetails 

func (w *WdPostSubmitTask) TypeDetails() harmonytask.TaskTypeDetails

type WdPostTask 

type WdPostTask struct {
	// contains filtered or unexported fields
}

func NewWdPostTask 

func NewWdPostTask(db *harmonydb.DB,
	api WDPoStAPI,
	faultTracker FaultTracker,
	storage paths.Store,
	verifier storiface.Verifier,
	paramck func() (bool, error),
	pcs *chainsched.CurioChainSched,
	actors map[dtypes.MinerAddress]bool,
	max int,
	parallel int,
	challengeReadTimeout time.Duration,
) (*WdPostTask, error)

func (*WdPostTask) Adder 

func (t *WdPostTask) Adder(taskFunc harmonytask.AddTaskFunc)

func (*WdPostTask) CanAccept 

func (t *WdPostTask) CanAccept(ids []harmonytask.TaskID, te *harmonytask.TaskEngine) (*harmonytask.TaskID, error)

func (*WdPostTask) Do 

func (t *WdPostTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)

func (*WdPostTask) DoPartition 

func (t *WdPostTask) DoPartition(ctx context.Context, ts *types.TipSet, maddr address.Address, di *dline.Info, partIdx uint64, test bool) (out *miner2.SubmitWindowedPoStParams, err error)

func (*WdPostTask) GenerateWindowPoStAdv 

func (t *WdPostTask) GenerateWindowPoStAdv(ctx context.Context, ppt abi.RegisteredPoStProof, mid abi.ActorID, sectors []storiface.PostSectorChallenge, partitionIdx int, randomness abi.PoStRandomness, allowSkip bool) (storiface.WindowPoStResult, error)

func (*WdPostTask) GenerateWindowPoStWithVanilla 

func (t *WdPostTask) GenerateWindowPoStWithVanilla(ctx context.Context, proofType abi.RegisteredPoStProof, minerID abi.ActorID, randomness abi.PoStRandomness, proofs [][]byte, partitionIdx int) (proof.PoStProof, error)

func (*WdPostTask) GetSpid added in v1.22.1 

func (t *WdPostTask) GetSpid(db *harmonydb.DB, taskID int64) string

func (*WdPostTask) TypeDetails 

func (t *WdPostTask) TypeDetails() harmonytask.TaskTypeDetails

type WdPostTaskDetails 

type WdPostTaskDetails struct {
	Ts       *types.TipSet
	Deadline *dline.Info
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.