Versions in this module Expand all Collapse all v1 v1.1.0 Nov 15, 2018 v1.0.0 Nov 15, 2018 Changes in this version + var AccountError = errors.New("Acccount Error") + var FakeHeaderError = errors.New("FakeHeader Error") + var HashNoSignNotMatchError = errors.New("hash without sign not match") + var HaveNoGenBlockError = errors.New("have no gen block data") + var HaveNotOKResultError = errors.New("have no satisfy miner result") + var HeightError = errors.New("Height Error") + var MinerPosfail = errors.New("MinerResult POS Fail") + var MinerResultError = errors.New("MinerResult Error") + var NoAccount = errors.New("No Account ") + var NoWallets = errors.New("No Wallets ") + var NodeIDError = errors.New("Node Error") + var Noleader = errors.New("not leader ") + var ParaNull = errors.New("Para is null ") + var PosHeaderError = errors.New("PosHeader Error") + var SignaturesError = errors.New("Signatures Error") + var TimeStampError = errors.New("Timestamp Error") + var TxsError = errors.New("txs Error") + var VoteResultError = errors.New("VoteResultError Error") + type Backend interface + AccountManager func() *accounts.Manager + BlockChain func() *core.BlockChain + ChainDb func() mandb.Database + EventMux func() *event.TypeMux + FetcherNotify func(hash common.Hash, number uint64) + HD func() *hd.HD + ReElection func() *reelection.ReElection + SignHelper func() *signhelper.SignHelper + TxPool func() *core.TxPool + type BlockGenor struct + func New(man Backend) (*BlockGenor, error) + type PowPool struct + func NewPowPool(logInfo string) *PowPool + func (self *PowPool) AddMinerResult(blockHash common.Hash, diff *big.Int, minerResult *mc.HD_MiningRspMsg) error + func (self *PowPool) DelOneResult(blockHash common.Hash, diff *big.Int, from common.Address) + func (self *PowPool) GetMinerResults(blockHash common.Hash, diff *big.Int) ([]*mc.HD_MiningRspMsg, error) + type Process struct + FullBlockReqCache *common.ReuseMsgController + func (p *Process) AddBroadcastMinerResult(result *mc.HD_BroadcastMiningRspMsg) + func (p *Process) AddConsensusBlock(block *mc.BlockLocalVerifyOK) + func (p *Process) AddInsertBlockInfo(blockInsert *mc.HD_BlockInsertNotify) + func (p *Process) AddMinerResult(minerResult *mc.HD_MiningRspMsg) + func (p *Process) Close() + func (p *Process) ProcessFullBlockReq(req *mc.HD_FullBlockReqMsg) + func (p *Process) ProcessFullBlockRsp(rsp *mc.HD_FullBlockRspMsg) + func (p *Process) ProcessRecoveryMsg(msg *mc.RecoveryStateMsg) + func (p *Process) ReInit() + func (p *Process) ReInitNextLeader() + func (p *Process) SetCurLeader(leader common.Address, consensusTurn uint32) + func (p *Process) SetNextLeader(leader common.Address) + func (p *Process) StartRunning(role common.RoleType) + type ProcessManage struct + func NewProcessManage(matrix Backend) *ProcessManage + func (pm *ProcessManage) GetCurNumber() uint64 + func (pm *ProcessManage) GetCurrentProcess() *Process + func (pm *ProcessManage) GetProcess(number uint64) (*Process, error) + func (pm *ProcessManage) GetProcessAndPreProcess(number uint64) (*Process, *Process, error) + func (pm *ProcessManage) SetCurNumber(number uint64) + type State uint16 + const StateBlockBroadcast + const StateBlockInsert + const StateEnd + const StateHeaderGen + const StateIdle + const StateMinerResultVerify + func (s State) String() string + type Work struct + Block *types.Block