network

type MsgBuffer struct {
	ReqMsgs        []*consensus.RequestMsg
	PrePrepareMsgs []*consensus.PrePrepareMsg
	PrepareMsgs    []*consensus.VoteMsg
	CommitMsgs     []*consensus.VoteMsg
}

type Node struct {
	NodeID          string
	NodeTable       map[string]string // key=nodeID, value=url
	NTLock          sync.RWMutex
	View            *View
	States          map[int64]*consensus.State
	CommittedMsgs   []*consensus.RequestMsg // kinda block.
	CommitWaitQueue *prque.Prque
	CWLock          sync.Mutex
	MsgBuffer       *MsgBuffer
	MsgEntrance     chan interface{}
	MsgDelivery     chan interface{}
	MsgBackward     chan interface{}
	Alarm           chan bool
	FinishChan      chan int64
	Verify          consensus.ConsensusVerify
	Finish          consensus.ConsensusFinish
	ID              *big.Int

	PrePareLock        sync.Mutex
	CommitLock         sync.Mutex
	CurrentHeight      int64
	RetryPrePrepareMsg map[int64]*consensus.PrePrepareMsg
	Stop               bool
	// contains filtered or unexported fields
}

type Server struct {
	Node *Node
	ID   *big.Int

	ActionChan chan *consensus.ActionIn
	// contains filtered or unexported fields
}

type View struct {
	ID      int64
	Primary string
}