protocols

package

v1.14.4 Latest Latest Go to latest Published: Mar 30, 2022 License: LGPL-3.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ontio/ontology

Links

Open Source Insights

Documentation ¶

Index ¶

func ConsensusHandle(ctx *p2p.Context, consensus *msgTypes.Consensus)
func DataReqHandle(ctx *p2p.Context, dataReq *msgTypes.DataReq)
func GetHeadersFromHash(startHash common.Uint256, stopHash common.Uint256) ([]*types.RawHeader, error)
func HeadersReqHandle(ctx *p2p.Context, headersReq *msgTypes.HeadersReq)
func InvHandle(ctx *p2p.Context, inv *msgTypes.Inv)
func RegisterProposeOfflineVote(subnet *subnet.SubNet)
type MsgHandler
- func NewMsgHandler(acct *account.Account, staticReserveFilter p2p.AddressFilter, ...) *MsgHandler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConsensusHandle ¶

func ConsensusHandle(ctx *p2p.Context, consensus *msgTypes.Consensus)

ConsensusHandle handles the consensus message from peer

func DataReqHandle ¶

func DataReqHandle(ctx *p2p.Context, dataReq *msgTypes.DataReq)

DataReqHandle handles the data req(block/Transaction) from peer

func GetHeadersFromHash ¶

func GetHeadersFromHash(startHash common.Uint256, stopHash common.Uint256) ([]*types.RawHeader, error)

get blk hdrs from starthash to stophash

func HeadersReqHandle ¶

func HeadersReqHandle(ctx *p2p.Context, headersReq *msgTypes.HeadersReq)

HeaderReqHandle handles the header sync req from peer

func InvHandle ¶

func InvHandle(ctx *p2p.Context, inv *msgTypes.Inv)

InvHandle handles the inventory message(block, transaction and consensus) from peer.

func RegisterProposeOfflineVote ¶ added in v1.14.1

func RegisterProposeOfflineVote(subnet *subnet.SubNet)

Types ¶

type MsgHandler ¶

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

func NewMsgHandler ¶

func NewMsgHandler(acct *account.Account, staticReserveFilter p2p.AddressFilter, ld *ledger.Ledger,
	txPool common2.TxPoolService, logger msgCommon.Logger) *MsgHandler

func (*MsgHandler) GetMaskAddrFilter ¶ added in v1.11.0

func (self *MsgHandler) GetMaskAddrFilter() p2p.AddressFilter

func (*MsgHandler) GetReservedAddrFilter ¶ added in v1.11.0

func (self *MsgHandler) GetReservedAddrFilter(staticFilterEnabled bool) p2p.AddressFilter

func (*MsgHandler) GetSubnetMembersInfo ¶ added in v1.11.0

func (self *MsgHandler) GetSubnetMembersInfo() []msgCommon.SubnetMemberInfo

func (*MsgHandler) HandlePeerMessage ¶

func (self *MsgHandler) HandlePeerMessage(ctx *p2p.Context, msg msgTypes.Message)

func (*MsgHandler) HandleSystemMessage ¶

func (self *MsgHandler) HandleSystemMessage(net p2p.P2P, msg p2p.SystemMessage)

func (*MsgHandler) ReconnectService ¶

func (mh *MsgHandler) ReconnectService() *reconnect.ReconnectService

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
block_sync
bootstrap * Copyright (C) 2018 The ontology Authors * This file is part of The ontology library.	* Copyright (C) 2018 The ontology Authors * This file is part of The ontology library.
discovery
heatbeat * Copyright (C) 2018 The ontology Authors * This file is part of The ontology library.	* Copyright (C) 2018 The ontology Authors * This file is part of The ontology library.
recent_peers * Copyright (C) 2018 The ontology Authors * This file is part of The ontology library.	* Copyright (C) 2018 The ontology Authors * This file is part of The ontology library.
reconnect
subnet
utils

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