Versions in this module Expand all Collapse all v0 v0.0.1 Jan 19, 2022 Changes in this version + const BlockchainChannel + type BcReactorFSM struct + func NewFSM(height int64, toBcR bcReactor) *BcReactorFSM + func (fsm *BcReactorFSM) FirstTwoBlocks() (first, second *types.Block, err error) + func (fsm *BcReactorFSM) Handle(msg *bcReactorMessage) error + func (fsm *BcReactorFSM) NeedsBlocks() bool + func (fsm *BcReactorFSM) SetLogger(l log.Logger) + func (fsm *BcReactorFSM) Start() + func (fsm *BcReactorFSM) Status() (height, maxPeerHeight int64) + type BlockData struct + type BlockPool struct + Height int64 + MaxPeerHeight int64 + func NewBlockPool(height int64, toBcR bcReactor) *BlockPool + func (pool *BlockPool) AddBlock(peerID p2p.ID, block *types.Block, blockSize int) error + func (pool *BlockPool) BlockAndPeerAtHeight(height int64) (bData *BlockData, err error) + func (pool *BlockPool) Cleanup() + func (pool *BlockPool) FirstTwoBlocksAndPeers() (first, second *BlockData, err error) + func (pool *BlockPool) InvalidateFirstTwoBlocks(err error) + func (pool *BlockPool) MakeNextRequests(maxNumRequests int) + func (pool *BlockPool) NeedsBlocks() bool + func (pool *BlockPool) NumPeers() int + func (pool *BlockPool) ProcessedCurrentHeightBlock() + func (pool *BlockPool) ReachedMaxHeight() bool + func (pool *BlockPool) RemovePeer(peerID p2p.ID, err error) + func (pool *BlockPool) RemovePeerAtCurrentHeights(err error) + func (pool *BlockPool) SetLogger(l log.Logger) + func (pool *BlockPool) UpdatePeer(peerID p2p.ID, base int64, height int64) error + type BlockchainReactor struct + func NewBlockchainReactor(state sm.State, blockExec *sm.BlockExecutor, store *store.BlockStore, ...) *BlockchainReactor + func (bcR *BlockchainReactor) AddPeer(peer p2p.Peer) + func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor + func (bcR *BlockchainReactor) OnStart() error + func (bcR *BlockchainReactor) OnStop() + func (bcR *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + func (bcR *BlockchainReactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (bcR *BlockchainReactor) SetLogger(l log.Logger) + func (bcR *BlockchainReactor) SwitchToFastSync(state sm.State) error + type BpPeer struct + Base int64 + Height int64 + ID p2p.ID + NumPendingBlockRequests int + func NewBpPeer(peerID p2p.ID, base int64, height int64, onErr func(err error, peerID p2p.ID), ...) *BpPeer + func (peer *BpPeer) AddBlock(block *types.Block, recvSize int) error + func (peer *BpPeer) BlockAtHeight(height int64) (*types.Block, error) + func (peer *BpPeer) CheckRate() error + func (peer *BpPeer) Cleanup() + func (peer *BpPeer) RemoveBlock(height int64) + func (peer *BpPeer) RequestSent(height int64) + func (peer *BpPeer) SetLogger(l log.Logger) + func (peer *BpPeer) String() string + type BpPeerParams struct + func BpPeerDefaultParams() *BpPeerParams
Go to main page