worker

Documentation

Index

• type Worker
  • func New(config *params.ChainConfig, chain core.BlockChain, beacon core.BlockChain, ...) *Worker
  • func (w *Worker) CollectVerifiedSlashes() error
  • func (w *Worker) CommitReceipts(receiptsList []*types.CXReceiptsProof) error
  • func (w *Worker) CommitSortedTransactions(txs *types.TransactionsByPriceAndNonce, coinbase common.Address)
  • func (w *Worker) CommitTransactions(pendingNormal map[common.Address]types.Transactions, ...) error
  • func (w *Worker) FinalizeNewBlock(commitSigs chan []byte, viewID func() uint64, coinbase common.Address, ...) (*types.Block, error)
  • func (w *Worker) GetCurrentHeader() *block.Header
  • func (w *Worker) GetCurrentReceipts() []*types.Receipt
  • func (w *Worker) GetCurrentResult() *core.ProcessorResult
  • func (w *Worker) GetCurrentState() *state.DB
  • func (w *Worker) GetNewEpoch() *big.Int
  • func (w *Worker) IncomingReceipts() []*types.CXReceiptsProof
  • func (w *Worker) OutgoingReceipts() []*types.CXReceipt
  • func (w *Worker) UpdateCurrent() error

Types

type Worker

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

Worker is the main object which takes care of submitting new work to consensus engine and gathering the sealing result.

func New

func New(
	config *params.ChainConfig, chain core.BlockChain, beacon core.BlockChain, engine consensus_engine.Engine,
) *Worker

New create a new worker object.

func (*Worker) CollectVerifiedSlashes

func (w *Worker) CollectVerifiedSlashes() error

CollectVerifiedSlashes sets w.current.slashes only to those that past verification

func (*Worker) CommitReceipts

func (w *Worker) CommitReceipts(receiptsList []*types.CXReceiptsProof) error

CommitReceipts commits a list of already verified incoming cross shard receipts

func (*Worker) CommitSortedTransactions

func (w *Worker) CommitSortedTransactions(
	txs *types.TransactionsByPriceAndNonce,
	coinbase common.Address,
)

CommitSortedTransactions commits transactions for new block.

func (*Worker) CommitTransactions

func (w *Worker) CommitTransactions(
	pendingNormal map[common.Address]types.Transactions,
	pendingStaking staking.StakingTransactions, coinbase common.Address,
) error

CommitTransactions commits transactions for new block.

func (*Worker) FinalizeNewBlock

func (w *Worker) FinalizeNewBlock(
	commitSigs chan []byte, viewID func() uint64, coinbase common.Address,
	crossLinks types.CrossLinks, shardState *shard.State,
) (*types.Block, error)

FinalizeNewBlock generate a new block for the next consensus round.

func (*Worker) GetCurrentHeader

func (w *Worker) GetCurrentHeader() *block.Header

GetCurrentHeader returns the current header to propose

func (*Worker) GetCurrentReceipts

func (w *Worker) GetCurrentReceipts() []*types.Receipt

GetCurrentReceipts get the receipts generated starting from the last state.

func (*Worker) GetCurrentResult

func (w *Worker) GetCurrentResult() *core.ProcessorResult

GetCurrentResult gets the current block processing result.

func (*Worker) GetCurrentState

func (w *Worker) GetCurrentState() *state.DB

GetCurrentState gets the current state.

func (*Worker) GetNewEpoch

func (w *Worker) GetNewEpoch() *big.Int

GetNewEpoch gets the current epoch.

func (*Worker) IncomingReceipts

func (w *Worker) IncomingReceipts() []*types.CXReceiptsProof

IncomingReceipts get incoming receipts in destination shard that is received from source shard

func (*Worker) OutgoingReceipts

func (w *Worker) OutgoingReceipts() []*types.CXReceipt

OutgoingReceipts get the receipts generated starting from the last state.

func (*Worker) UpdateCurrent

func (w *Worker) UpdateCurrent() error

UpdateCurrent updates the current environment with the current state and header.