pbftserver

package

v0.10.1 Latest Latest Go to latest Published: Mar 15, 2019 License: GPL-3.0 Imports: 17 Imported by: 0

Details

View Source

const (
	Start int = iota
	Stop
	Switch

	ServerWait    = 5
	BlockSleepMax = 5
)

This section is empty.

func DelayStop(id uint64, ss *PbftServerMgr)

type PbftServerMgr struct {
	Agent types.PbftAgentProxy

	Close bool
	// contains filtered or unexported fields
}

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