subproto

Documentation

Index

• Constants
• func NewAddressesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *addressesRequestHandler
• func NewAddressesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *addressesResponseHandler
• func NewBlockProducedNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *blockProducedNoticeHandler
• func NewBlockReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *blockRequestHandler
• func NewBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *blockResponseHandler
• func NewGetAncestorReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getAncestorRequestHandler
• func NewGetAncestorRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getAncestorResponseHandler
• func NewGetHashByNoReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashByNoRequestHandler
• func NewGetHashByNoRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashByNoResponseHandler
• func NewGetHashesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashRequestHandler
• func NewGetHashesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *getHashResponseHandler
• func NewGoAwayHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *goAwayHandler
• func NewListBlockHeadersReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *listBlockHeadersRequestHandler
• func NewListBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *listBlockHeadersResponseHandler
• func NewNewBlockNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *newBlockNoticeHandler
• func NewNewTxNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *newTxNoticeHandler
• func NewPingReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *pingRequestHandler
• func NewPingRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *pingResponseHandler
• func NewTxReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *txRequestHandler
• func NewTxRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, ...) *txResponseHandler
• type BaseMsgHandler
  • func (bh *BaseMsgHandler) CheckAuth(msg p2pcommon.Message, msgBody proto.Message) error
  • func (bh *BaseMsgHandler) PostHandle(msg p2pcommon.Message, msgBody proto.Message)
  • func (bh *BaseMsgHandler) PreHandle()

Constants

const (
	StatusRequest p2pcommon.SubProtocol
	PingRequest
	PingResponse
	GoAway
	AddressesRequest
	AddressesResponse
)

NOTE: change const of protocols_test.go

const (
	GetBlocksRequest p2pcommon.SubProtocol = 0x010 + iota
	GetBlocksResponse
	GetBlockHeadersRequest
	GetBlockHeadersResponse
	GetMissingRequest  // Deprecated
	GetMissingResponse // Deprecated
	NewBlockNotice
	GetAncestorRequest
	GetAncestorResponse
	GetHashesRequest
	GetHashesResponse
	GetHashByNoRequest
	GetHashByNoResponse
)

const (
	GetTXsRequest p2pcommon.SubProtocol = 0x020 + iota
	GetTXsResponse
	NewTxNotice
)

const (
	// BlockProducedNotice from block producer to trusted nodes and other bp nodes
	BlockProducedNotice p2pcommon.SubProtocol = 0x030 + iota
)

subprotocols for block producers and their own trusted nodes

const (
	EmptyGetBlockResponseSize = 12 // roughly estimated maximum size if element is full
)

Functions

func NewAddressesReqHandler

func NewAddressesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *addressesRequestHandler

newAddressesReqHandler creates handler for PingRequest

func NewAddressesRespHandler

func NewAddressesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *addressesResponseHandler

newAddressesRespHandler creates handler for PingRequest

func NewBlockProducedNoticeHandler

func NewBlockProducedNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *blockProducedNoticeHandler

newNewBlockNoticeHandler creates handler for NewBlockNotice

func NewBlockReqHandler

func NewBlockReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *blockRequestHandler

newBlockReqHandler creates handler for GetBlockRequest

func NewBlockRespHandler

func NewBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *blockResponseHandler

newBlockRespHandler creates handler for GetBlockResponse

func NewGetAncestorReqHandler

func NewGetAncestorReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getAncestorRequestHandler

newGetAncestorReqHandler creates handler for GetAncestorRequest

func NewGetAncestorRespHandler

func NewGetAncestorRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getAncestorResponseHandler

newBlockRespHandler creates handler for GetAncestorResponse

func NewGetHashByNoReqHandler

func NewGetHashByNoReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashByNoRequestHandler

newBlockReqHandler creates handler for GetBlockRequest

func NewGetHashByNoRespHandler

func NewGetHashByNoRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashByNoResponseHandler

newBlockReqHandler creates handler for GetBlockRequest

func NewGetHashesReqHandler

func NewGetHashesReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashRequestHandler

newBlockReqHandler creates handler for GetBlockRequest

func NewGetHashesRespHandler

func NewGetHashesRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *getHashResponseHandler

newBlockReqHandler creates handler for GetBlockRequest

func NewGoAwayHandler

func NewGoAwayHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *goAwayHandler

newGoAwayHandler creates handler for PingResponse

func NewListBlockHeadersReqHandler

func NewListBlockHeadersReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *listBlockHeadersRequestHandler

newListBlockHeadersReqHandler creates handler for GetBlockHeadersRequest

func NewListBlockRespHandler

func NewListBlockRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *listBlockHeadersResponseHandler

newListBlockRespHandler creates handler for GetBlockHeadersResponse

func NewNewBlockNoticeHandler

func NewNewBlockNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *newBlockNoticeHandler

newNewBlockNoticeHandler creates handler for NewBlockNotice

func NewNewTxNoticeHandler

func NewNewTxNoticeHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService, sm p2pcommon.SyncManager) *newTxNoticeHandler

newNewTxNoticeHandler creates handler for GetTransactionsResponse

func NewPingReqHandler

func NewPingReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *pingRequestHandler

newPingReqHandler creates handler for PingRequest

func NewPingRespHandler

func NewPingRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *pingResponseHandler

newPingRespHandler creates handler for PingResponse

func NewTxReqHandler

func NewTxReqHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *txRequestHandler

newTxReqHandler creates handler for GetTransactionsRequest

func NewTxRespHandler

func NewTxRespHandler(pm p2pcommon.PeerManager, peer p2pcommon.RemotePeer, logger *log.Logger, actor p2pcommon.ActorService) *txResponseHandler

newTxRespHandler creates handler for GetTransactionsResponse

Types

type BaseMsgHandler

type BaseMsgHandler struct {
	// contains filtered or unexported fields
}

func(msg *types.P2PMessage) BaseMsgHandler contains common attributes of MessageHandler

func (*BaseMsgHandler) CheckAuth

func (bh *BaseMsgHandler) CheckAuth(msg p2pcommon.Message, msgBody proto.Message) error

func (*BaseMsgHandler) PostHandle

func (bh *BaseMsgHandler) PostHandle(msg p2pcommon.Message, msgBody proto.Message)

func (*BaseMsgHandler) PreHandle

func (bh *BaseMsgHandler) PreHandle()