pbftserver

Mar 6, 2019

Changes in this version

+ const BlockSleepMax

+ const ServerWait

+ const Start

+ const Stop

+ const Switch

+ func DelayStop(id uint64, ss *PbftServerMgr)

+ type PbftServerMgr struct

+ Agent types.PbftAgentProxy

+ Close bool

+ func NewPbftServerMgr(pk *ecdsa.PublicKey, priv *ecdsa.PrivateKey, agent types.PbftAgentProxy) *PbftServerMgr

+ func (ss *PbftServerMgr) Broadcast(height *big.Int)

+ func (ss *PbftServerMgr) CheckMsg(msg *consensus.RequestMsg) (*types.PbftSign, error)

+ func (ss *PbftServerMgr) Finish() error

+ func (ss *PbftServerMgr) GetCommitteeStatus(committeeID *big.Int) map[string]interface{}

+ func (ss *PbftServerMgr) GetRequest(id *big.Int) (*consensus.RequestMsg, error)

+ func (ss *PbftServerMgr) InsertBlock(msg *consensus.PrePrepareMsg) bool

+ func (ss *PbftServerMgr) Notify(id *big.Int, action int) error

+ func (ss *PbftServerMgr) PutCommittee(committeeInfo *types.CommitteeInfo) error

+ func (ss *PbftServerMgr) PutNodes(id *big.Int, nodes []*types.CommitteeNode) error

+ func (ss *PbftServerMgr) RepeatFetch(id *big.Int, height int64)

+ func (ss *PbftServerMgr) ReplyResult(msg *consensus.RequestMsg, signs []*types.PbftSign, res uint) bool

+ func (ss *PbftServerMgr) SetCommitteeStop(committeeId *big.Int, stop uint64) error

+ func (ss *PbftServerMgr) SignMsg(h int64, res uint) *consensus.SignedVoteMsg