matrixwork

Documentation

Overview

Copyright (c) 2018 The MATRIX Authors Distributed under the MIT software license, see the accompanying file COPYING or http://www.opensource.org/licenses/mit-license.php

Index

• Variables
• type ChainReader
• type Work
  • func NewWork(config *params.ChainConfig, bc ChainReader, gasPool *core.GasPool, ...) (*Work, error)
  • func (env *Work) ConsensusTransactions(mux *event.TypeMux, txs []types.CoinSelfTransaction, ...) error
  • func (env *Work) GetTxs() []types.CoinSelfTransaction
  • func (env *Work) ProcessBroadcastTransactions(mux *event.TypeMux, txs []types.CoinSelfTransaction)
  • func (env *Work) ProcessTransactions(mux *event.TypeMux, tp txPoolReader, upTime map[common.Address]uint64) (listret []*common.RetCallTxN, originalTxs []types.SelfTransaction)

Variables

var (
	_, Abierr = abi.JSON(strings.NewReader(depositDef))
)

Types

type ChainReader

type ChainReader interface {
	StateAt(root []common.CoinRoot) (*state.StateDBManage, error)
	GetBlockByHash(hash common.Hash) *types.Block
	Engine(version []byte) consensus.Engine
	GetHeader(common.Hash, uint64) *types.Header
	Processor(version []byte) core.Processor
}

type Work

type Work struct {
	State *state.StateDBManage // apply state changes here

	Block *types.Block // the new block

	Receipts []types.CoinReceipts
	// contains filtered or unexported fields
}

Work is the workers current environment and holds all of the current state information

func NewWork

func NewWork(config *params.ChainConfig, bc ChainReader, gasPool *core.GasPool, header *types.Header) (*Work, error)

func (*Work) ConsensusTransactions

func (env *Work) ConsensusTransactions(mux *event.TypeMux, txs []types.CoinSelfTransaction, upTime map[common.Address]uint64) error

func (*Work) GetTxs

func (env *Work) GetTxs() []types.CoinSelfTransaction

func (*Work) ProcessBroadcastTransactions

func (env *Work) ProcessBroadcastTransactions(mux *event.TypeMux, txs []types.CoinSelfTransaction)

Broadcast

func (*Work) ProcessTransactions

func (env *Work) ProcessTransactions(mux *event.TypeMux, tp txPoolReader, upTime map[common.Address]uint64) (listret []*common.RetCallTxN, originalTxs []types.SelfTransaction)