Versions in this module Expand all Collapse all v0 v0.0.5 Oct 27, 2022 v0.0.2 Oct 27, 2022 Changes in this version + const BlockResponseMessageFieldKeySize + const BlockResponseMessagePrefixSize + const BlocksyncChannel + const MaxMsgSize + func DecodeMsg(bz []byte) (proto.Message, error) + func EncodeMsg(pb proto.Message) ([]byte, error) + func ValidateMsg(pb proto.Message) error + type BlockPool struct + func NewBlockPool(start int64, requestsCh chan<- BlockRequest, errorsCh chan<- peerError) *BlockPool + func (pool *BlockPool) AddBlock(peerID p2p.ID, block *types.Block, blockSize int) + func (pool *BlockPool) GetStatus() (height int64, numPending int32, lenRequesters int) + func (pool *BlockPool) IsCaughtUp() bool + func (pool *BlockPool) MaxPeerHeight() int64 + func (pool *BlockPool) OnStart() error + func (pool *BlockPool) PeekTwoBlocks() (first *types.Block, second *types.Block) + func (pool *BlockPool) PopRequest() + func (pool *BlockPool) RedoRequest(height int64) p2p.ID + func (pool *BlockPool) RemovePeer(peerID p2p.ID) + func (pool *BlockPool) SetPeerRange(peerID p2p.ID, base int64, height int64) + type BlockRequest struct + Height int64 + PeerID p2p.ID + type Reactor struct + func NewReactor(state sm.State, blockExec *sm.BlockExecutor, store *store.BlockStore, ...) *Reactor + func (bcR *Reactor) AddPeer(peer p2p.Peer) + func (bcR *Reactor) BroadcastStatusRequest() error + func (bcR *Reactor) GetChannels() []*p2p.ChannelDescriptor + func (bcR *Reactor) OnStart() error + func (bcR *Reactor) OnStop() + func (bcR *Reactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + func (bcR *Reactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (bcR *Reactor) SetLogger(l log.Logger) + func (bcR *Reactor) SwitchToBlockSync(state sm.State) error
Go to main page