manager

package

Go to main page

Versions in this module

v0

v0.4.2

Mar 5, 2020

v0.4.1

Jan 8, 2020

v0.4.0

Dec 11, 2019

v0.3.9

Nov 21, 2019

v0.3.8

Oct 23, 2019

v0.3.7

Aug 17, 2019

v0.3.6

Aug 8, 2019

v0.3.5

Aug 1, 2019

v0.3.4

Jul 20, 2019

Changes in this version

type ProposalDispatcher

+ func (p *ProposalDispatcher) GetFinishedBlockHash() common.Uint256

+ func (p *ProposalDispatcher) GetFinishedHeight() uint32

v0.3.3

Jun 14, 2019

v0.3.2

Jun 2, 2019

Changes in this version

type DPOSHandlerConfig

+ TimeSource dtime.MedianTimeSource

type DPOSManager

+ func (d *DPOSManager) DoRecover()

+ func (d *DPOSManager) OnInactiveArbitratorsAccepted(p *payload.InactiveArbitrators)

+ func (d *DPOSManager) OnRecover()

+ func (d *DPOSManager) OnRecoverTimeout()

type DPOSManagerConfig

+ Server elanet.Server

+ TimeSource dtime.MedianTimeSource

type DPOSNetwork

+ RecoverTimeout func()

type DPOSNetworkConfig

+ AnnounceAddr func()

type IllegalBehaviorMonitor

+ func (i *IllegalBehaviorMonitor) CleanByBlock(b *types.Block)

type NetworkEventListener

+ OnInactiveArbitratorsAccepted func(p *payload.InactiveArbitrators)

+ OnRecover func()

+ OnRecoverTimeout func()

type ProposalDispatcher

+ func (p *ProposalDispatcher) AppendConfirm()

+ func (p *ProposalDispatcher) IsCRCBadNetWork() bool

+ func (p *ProposalDispatcher) OnIllegalBlocksTxReceived(i *payload.DPOSIllegalBlocks)

+ func (p *ProposalDispatcher) ResetByCurrentView()

+ func (p *ProposalDispatcher) UpdatePrecociousProposals()

type ProposalDispatcherConfig

+ TimeSource dtime.MedianTimeSource

v0.3.2-e935

Jun 10, 2019

v0.3.1

Apr 12, 2019

v0.3.0

Mar 28, 2019

Changes in this version

type Consensus

+ func (c *Consensus) CollectConsensusStatus(height uint32, status *msg.ConsensusStatus) error

+ func (c *Consensus) RecoverFromConsensusStatus(status *msg.ConsensusStatus) error

+ type DPOSEventConditionHandler interface

+ ChangeView func(firstBlockHash *common.Uint256)

+ ProcessAcceptVote func(id peer.PID, p *payload.DPOSProposalVote) (succeed bool, finished bool)

+ ProcessProposal func(id peer.PID, p *payload.DPOSProposal) (handled bool)

+ ProcessRejectVote func(id peer.PID, p *payload.DPOSProposalVote) (succeed bool, finished bool)

+ TryStartNewConsensus func(b *types.Block) bool

+ type DPOSHandlerConfig struct

+ Arbitrators state.Arbitrators

+ Manager *DPOSManager

+ Monitor *log.EventMonitor

+ Network DPOSNetwork

+ type DPOSHandlerSwitch struct

+ func (h *DPOSHandlerSwitch) AddListeners(listeners ...log.EventListener)

+ func (h *DPOSHandlerSwitch) ChangeView(firstBlockHash *common.Uint256)

+ func (h *DPOSHandlerSwitch) FinishConsensus()

+ func (h *DPOSHandlerSwitch) HelpToRecoverAbnormal(id peer.PID, height uint32)

+ func (h *DPOSHandlerSwitch) Initialize(dispatcher *ProposalDispatcher, consensus *Consensus)

+ func (h *DPOSHandlerSwitch) IsAbnormal() bool

+ func (h *DPOSHandlerSwitch) OnViewChanged(isOnDuty bool)

+ func (h *DPOSHandlerSwitch) ProcessAcceptVote(id peer.PID, p *payload.DPOSProposalVote) (bool, bool)

+ func (h *DPOSHandlerSwitch) ProcessProposal(id peer.PID, p *payload.DPOSProposal) (handled bool)

+ func (h *DPOSHandlerSwitch) ProcessRejectVote(id peer.PID, p *payload.DPOSProposalVote) (bool, bool)

+ func (h *DPOSHandlerSwitch) RecoverAbnormal(status *msg.ConsensusStatus)

+ func (h *DPOSHandlerSwitch) RequestAbnormalRecovering()

+ func (h *DPOSHandlerSwitch) ResponseGetBlocks(id peer.PID, startBlockHeight, endBlockHeight uint32)

+ func (h *DPOSHandlerSwitch) SwitchTo(onDuty bool)

+ func (h *DPOSHandlerSwitch) TryStartNewConsensus(b *types.Block) bool

+ type DPOSManager struct

+ func (d *DPOSManager) AppendBlock(block *types.Block)

+ func (d *DPOSManager) AppendConfirm(confirm *payload.Confirm) (bool, bool, error)

+ func (d *DPOSManager) AppendToTxnPool(txn *types.Transaction) errors.ErrCode

+ func (d *DPOSManager) Broadcast(msg p2p.Message)

+ func (d *DPOSManager) ChangeConsensus(onDuty bool)

+ func (d *DPOSManager) ConfirmBlock()

+ func (d *DPOSManager) GetArbitrators() state.Arbitrators

+ func (d *DPOSManager) GetBlockCache() *ConsensusBlockCache

+ func (d *DPOSManager) GetPublicKey() []byte

+ func (d *DPOSManager) Initialize(handler *DPOSHandlerSwitch, dispatcher *ProposalDispatcher, ...)

+ func (d *DPOSManager) OnBadNetwork()

+ func (d *DPOSManager) OnBlock(id dpeer.PID, block *types.Block)

+ func (d *DPOSManager) OnBlockReceived(b *types.Block, confirmed bool)

+ func (d *DPOSManager) OnChangeView()

+ func (d *DPOSManager) OnConfirmReceived(p *payload.Confirm)

+ func (d *DPOSManager) OnGetBlock(id dpeer.PID, blockHash common.Uint256)

+ func (d *DPOSManager) OnGetBlocks(id dpeer.PID, startBlockHeight, endBlockHeight uint32)

+ func (d *DPOSManager) OnIllegalBlocksTxReceived(i *payload.DPOSIllegalBlocks)

+ func (d *DPOSManager) OnIllegalProposalReceived(id dpeer.PID, proposals *payload.DPOSIllegalProposals)

+ func (d *DPOSManager) OnIllegalVotesReceived(id dpeer.PID, votes *payload.DPOSIllegalVotes)

+ func (d *DPOSManager) OnInactiveArbitratorsReceived(tx *types.Transaction)

+ func (d *DPOSManager) OnInv(id dpeer.PID, blockHash common.Uint256)

+ func (d *DPOSManager) OnPing(id dpeer.PID, height uint32)

+ func (d *DPOSManager) OnPong(id dpeer.PID, height uint32)

+ func (d *DPOSManager) OnProposalReceived(id dpeer.PID, p *payload.DPOSProposal)

+ func (d *DPOSManager) OnRequestConsensus(id dpeer.PID, height uint32)

+ func (d *DPOSManager) OnRequestProposal(id dpeer.PID, hash common.Uint256)

+ func (d *DPOSManager) OnResponseBlocks(id dpeer.PID, blockConfirms []*types.DposBlock)

+ func (d *DPOSManager) OnResponseConsensus(id dpeer.PID, status *dmsg.ConsensusStatus)

+ func (d *DPOSManager) OnResponseInactiveArbitratorsReceived(txHash *common.Uint256, signers []byte, signs []byte)

+ func (d *DPOSManager) OnSidechainIllegalEvidenceReceived(s *payload.SidechainIllegalData)

+ func (d *DPOSManager) OnVoteAccepted(id dpeer.PID, p *payload.DPOSProposalVote)

+ func (d *DPOSManager) OnVoteRejected(id dpeer.PID, p *payload.DPOSProposalVote)

+ func (d *DPOSManager) ProcessHigherBlock(b *types.Block)

+ func (d *DPOSManager) Recover()

+ type DPOSManagerConfig struct

+ Arbitrators state.Arbitrators

+ ChainParams *config.Params

+ PublicKey []byte

+ type DPOSNetwork interface

+ BroadcastMessage func(msg p2p.Message)

+ GetActivePeers func() []dp2p.Peer

+ Initialize func(dnConfig DPOSNetworkConfig)

+ SendMessageToPeer func(id dpeer.PID, msg p2p.Message) error

+ Start func()

+ Stop func() error

+ UpdatePeers func(arbitrators map[string]*dp2p.PeerAddr) error

+ type DPOSNetworkConfig struct

+ ProposalDispatcher *ProposalDispatcher

+ PublicKey []byte

+ Store store.IDposStore

+ type DPOSNormalHandler struct

+ func (h *DPOSNormalHandler) ChangeView(firstBlockHash *common.Uint256)

+ func (h *DPOSNormalHandler) ProcessAcceptVote(id peer.PID, p *payload.DPOSProposalVote) (succeed bool, finished bool)

+ func (h *DPOSNormalHandler) ProcessProposal(id peer.PID, p *payload.DPOSProposal) (handled bool)

+ func (h *DPOSNormalHandler) ProcessRejectVote(id peer.PID, p *payload.DPOSProposalVote) (succeed bool, finished bool)

+ func (h *DPOSNormalHandler) TryStartNewConsensus(b *types.Block) bool

+ type DPOSOnDutyHandler struct

+ func (h *DPOSOnDutyHandler) ChangeView(firstBlockHash *common.Uint256)

+ func (h *DPOSOnDutyHandler) ProcessAcceptVote(id peer.PID, p *payload.DPOSProposalVote) (succeed bool, finished bool)

+ func (h *DPOSOnDutyHandler) ProcessProposal(id peer.PID, p *payload.DPOSProposal) (handled bool)

+ func (h *DPOSOnDutyHandler) ProcessRejectVote(id peer.PID, p *payload.DPOSProposalVote) (succeed bool, finished bool)

+ func (h *DPOSOnDutyHandler) TryStartNewConsensus(b *types.Block) bool

type IllegalBehaviorMonitor

+ func (i *IllegalBehaviorMonitor) AddEvidence(evidence payload.DPOSIllegalData)

+ func (i *IllegalBehaviorMonitor) SendSidechainIllegalEvidenceTransaction(evidence *payload.SidechainIllegalData)

+ func (i *IllegalBehaviorMonitor) SetInactiveArbitratorsTxHash(hash common.Uint256)

type NetworkEventListener

+ OnIllegalBlocksTxReceived func(i *payload.DPOSIllegalBlocks)

+ OnInactiveArbitratorsReceived func(tx *types.Transaction)

+ OnResponseInactiveArbitratorsReceived func(txHash *common.Uint256, Signer []byte, Sign []byte)

+ OnSidechainIllegalEvidenceReceived func(s *payload.SidechainIllegalData)

+ OnVoteAccepted func(id dpeer.PID, p *payload.DPOSProposalVote)

type ProposalDispatcher

+ func (p *ProposalDispatcher) CollectConsensusStatus(height uint32, status *dmsg.ConsensusStatus) error

+ func (p *ProposalDispatcher) CreateInactiveArbitrators() (*types.Transaction, error)

+ func (p *ProposalDispatcher) IsViewChangedTimeOut() bool

+ func (p *ProposalDispatcher) OnBlockAdded(b *types.Block)

+ func (p *ProposalDispatcher) OnInactiveArbitratorsReceived(tx *types.Transaction)

+ func (p *ProposalDispatcher) OnResponseInactiveArbitratorsReceived(txHash *common.Uint256, signer []byte, sign []byte)

+ func (p *ProposalDispatcher) RecoverFromConsensusStatus(status *dmsg.ConsensusStatus) error

+ type ProposalDispatcherConfig struct

+ Account account.DposAccount

+ ChainParams *config.Params

+ Consensus *Consensus

+ EventMonitor *log.EventMonitor

+ Manager *DPOSManager

+ Network DPOSNetwork

+ type ViewChangesCountDown struct

+ func (c *ViewChangesCountDown) IsTimeOut() bool

+ func (c *ViewChangesCountDown) Reset()

+ func (c *ViewChangesCountDown) SetEliminated()

v0.2.2

Feb 19, 2019

Changes in this version

+ const WaitHeightTolerance

+ func NewDispatcherAndIllegalMonitor(consensus Consensus, eventMonitor *log.EventMonitor, network DposNetwork, ...) (ProposalDispatcher, IllegalBehaviorMonitor)

+ type AbnormalRecovering interface

+ CollectConsensusStatus func(height uint32, status *msg.ConsensusStatus) error

+ RecoverFromConsensusStatus func(status *msg.ConsensusStatus) error

+ type Consensus interface

+ ChangeView func()

+ GetOnDutyArbitrator func() string

+ GetViewOffset func() uint32

+ IsArbitratorOnDuty func(arbitrator string) bool

+ IsOnDuty func() bool

+ IsReady func() bool

+ IsRunning func() bool

+ ProcessBlock func(b *types.Block)

+ SetOnDuty func(onDuty bool)

+ SetReady func()

+ SetRunning func()

+ StartConsensus func(b *types.Block)

+ TryChangeView func() bool

+ func NewConsensus(manager DposManager, tolerance time.Duration, viewListener ViewListener) Consensus

+ type ConsensusBlockCache struct

+ ConsensusBlockList []common.Uint256

+ ConsensusBlocks map[common.Uint256]*types.Block

+ Listener ConsensusBlockCacheListener

+ func (c *ConsensusBlockCache) AddValue(key common.Uint256, value *types.Block)

+ func (c *ConsensusBlockCache) GetFirstArrivedBlockHash() (common.Uint256, bool)

+ func (c *ConsensusBlockCache) Reset()

+ func (c *ConsensusBlockCache) TryGetValue(key common.Uint256) (*types.Block, bool)

+ type ConsensusBlockCacheListener interface

+ OnBlockAdded func(b *types.Block)

+ type DposEventConditionHandler interface

+ ChangeView func(firstBlockHash *common.Uint256)

+ ProcessAcceptVote func(id peer.PID, p types.DPosProposalVote)

+ ProcessRejectVote func(id peer.PID, p types.DPosProposalVote)

+ StartNewProposal func(p types.DPosProposal)

+ TryStartNewConsensus func(b *types.Block) bool

+ type DposHandlerSwitch interface

+ FinishConsensus func()

+ HelpToRecoverAbnormal func(id peer.PID, height uint32)

+ Initialize func(dispatcher ProposalDispatcher, consensus Consensus)

+ RecoverAbnormal func(status *msg2.ConsensusStatus)

+ RequestAbnormalRecovering func()

+ ResponseGetBlocks func(id peer.PID, startBlockHeight, endBlockHeight uint32)

+ SwitchTo func(isOnDuty bool)

+ func NewHandler(network DposNetwork, manager DposManager, monitor *log.EventMonitor) DposHandlerSwitch

+ type DposManager interface

+ AppendConfirm func(confirm *types.DPosProposalVoteSlot) (bool, bool, error)

+ AppendToTxnPool func(txn *types.Transaction) errors.ErrCode

+ ChangeConsensus func(onDuty bool)

+ ConfirmBlock func()

+ GetArbitrators func() interfaces.Arbitrators

+ GetBlockCache func() *ConsensusBlockCache

+ GetPublicKey func() string

+ Initialize func(handler DposHandlerSwitch, dispatcher ProposalDispatcher, consensus Consensus, ...)

+ ProcessHigherBlock func(b *types.Block)

+ Recover func()

+ Relay func(from protocol.Noder, message interface{}) error

+ func NewManager(name string, arbitrators interfaces.Arbitrators) DposManager

+ type DposNetwork interface

+ BroadcastMessage func(msg elap2p.Message)

+ ChangeHeight func(height uint32) error

+ GetActivePeer func() *peer.PID

+ Initialize func(dnConfig DposNetworkConfig)

+ SendMessageToPeer func(id peer.PID, msg elap2p.Message) error

+ Start func()

+ Stop func() error

+ UpdatePeers func(arbitrators [][]byte) error

+ type DposNetworkConfig struct

+ ProposalDispatcher ProposalDispatcher

+ Store interfaces.IDposStore

+ type DposNormalHandler struct

+ func (h *DposNormalHandler) ChangeView(firstBlockHash *common.Uint256)

+ func (h *DposNormalHandler) ProcessAcceptVote(id peer.PID, p types.DPosProposalVote)

+ func (h *DposNormalHandler) ProcessRejectVote(id peer.PID, p types.DPosProposalVote)

+ func (h *DposNormalHandler) StartNewProposal(p types.DPosProposal)

+ func (h *DposNormalHandler) TryStartNewConsensus(b *types.Block) bool

+ func (h DposNormalHandler) AddListeners(listeners ...log.EventListener)

+ func (h DposNormalHandler) FinishConsensus()

+ func (h DposNormalHandler) HelpToRecoverAbnormal(id peer.PID, height uint32)

+ func (h DposNormalHandler) Initialize(dispatcher ProposalDispatcher, consensus Consensus)

+ func (h DposNormalHandler) OnViewChanged(isOnDuty bool)

+ func (h DposNormalHandler) RecoverAbnormal(status *msg2.ConsensusStatus)

+ func (h DposNormalHandler) RequestAbnormalRecovering()

+ func (h DposNormalHandler) ResponseGetBlocks(id peer.PID, startBlockHeight, endBlockHeight uint32)

+ func (h DposNormalHandler) SwitchTo(onDuty bool)

+ type DposOnDutyHandler struct

+ func (h *DposOnDutyHandler) ChangeView(firstBlockHash *common.Uint256)

+ func (h *DposOnDutyHandler) ProcessAcceptVote(id peer.PID, p types.DPosProposalVote)

+ func (h *DposOnDutyHandler) ProcessRejectVote(id peer.PID, p types.DPosProposalVote)

+ func (h *DposOnDutyHandler) StartNewProposal(p types.DPosProposal)

+ func (h *DposOnDutyHandler) TryStartNewConsensus(b *types.Block) bool

+ func (h DposOnDutyHandler) AddListeners(listeners ...log.EventListener)

+ func (h DposOnDutyHandler) FinishConsensus()

+ func (h DposOnDutyHandler) HelpToRecoverAbnormal(id peer.PID, height uint32)

+ func (h DposOnDutyHandler) Initialize(dispatcher ProposalDispatcher, consensus Consensus)

+ func (h DposOnDutyHandler) OnViewChanged(isOnDuty bool)

+ func (h DposOnDutyHandler) RecoverAbnormal(status *msg2.ConsensusStatus)

+ func (h DposOnDutyHandler) RequestAbnormalRecovering()

+ func (h DposOnDutyHandler) ResponseGetBlocks(id peer.PID, startBlockHeight, endBlockHeight uint32)

+ func (h DposOnDutyHandler) SwitchTo(onDuty bool)

+ type IllegalBehaviorMonitor interface

+ AddBlockEvidence func(evidence *types.DposIllegalBlocks)

+ AddProposal func(proposal types.DPosProposal)

+ AddProposalEvidence func(evidence *types.DposIllegalProposals)

+ AddVoteEvidence func(evidence *types.DposIllegalVotes)

+ IsBlockValid func(block *types.Block) bool

+ IsLegalProposal func(p *types.DPosProposal) (*types.DPosProposal, bool)

+ IsLegalVote func(v *types.DPosProposalVote) (*types.DPosProposalVote, bool)

+ ProcessIllegalProposal func(first, second *types.DPosProposal)

+ ProcessIllegalVote func(first, second *types.DPosProposalVote)

+ Reset func(changeView bool)

+ type NetworkEventListener interface

+ OnBadNetwork func()

+ OnBlockReceived func(b *types.Block, confirmed bool)

+ OnChangeView func()

+ OnConfirmReceived func(p *types.DPosProposalVoteSlot)

+ OnIllegalBlocksReceived func(i *types.DposIllegalBlocks)

+ OnProposalReceived func(id peer.PID, p types.DPosProposal)

+ OnVoteReceived func(id peer.PID, p types.DPosProposalVote)

+ OnVoteRejected func(id peer.PID, p types.DPosProposalVote)

+ type ProposalDispatcher interface

+ AddPendingVote func(v types.DPosProposalVote)

+ CleanProposals func(changeView bool)

+ CurrentHeight func() uint32

+ FinishConsensus func()

+ FinishProposal func()

+ GetProcessingBlock func() *types.Block

+ GetProcessingProposal func() *types.DPosProposal

+ IsProcessingBlockEmpty func() bool

+ OnAbnormalStateDetected func()

+ ProcessProposal func(d types.DPosProposal)

+ ProcessVote func(v types.DPosProposalVote, accept bool)

+ RequestAbnormalRecovering func()

+ StartProposal func(b *types.Block)

+ TryAppendAndBroadcastConfirmBlockMsg func() bool

+ TryStartSpeculatingProposal func(b *types.Block)

+ type StatusSyncEventListener interface

+ OnBlock func(id peer.PID, block *types.Block)

+ OnGetBlock func(id peer.PID, blockHash common.Uint256)

+ OnGetBlocks func(id peer.PID, startBlockHeight, endBlockHeight uint32)

+ OnIllegalProposalReceived func(id peer.PID, proposals *types.DposIllegalProposals)

+ OnIllegalVotesReceived func(id peer.PID, votes *types.DposIllegalVotes)

+ OnInv func(id peer.PID, blockHash common.Uint256)

+ OnPing func(id peer.PID, height uint32)

+ OnPong func(id peer.PID, height uint32)

+ OnRequestConsensus func(id peer.PID, height uint32)

+ OnRequestProposal func(id peer.PID, hash common.Uint256)

+ OnResponseBlocks func(id peer.PID, blockConfirms []*types.DposBlock)

+ OnResponseConsensus func(id peer.PID, status *msg.ConsensusStatus)

+ type ViewListener interface

+ OnViewChanged func(isOnDuty bool)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL