protocols

package

v2.0.1 Latest Latest Go to latest Published: Jul 5, 2020 License: LGPL-3.0 Imports: 22 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

This section is empty.

This section is empty.

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

ConsensusHandle handles the consensus message from peer

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

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

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

get blk hdrs from starthash to stophash

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

HeaderReqHandle handles the header sync req from peer

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

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

func TransactionHandle(ctx *p2p.Context, trn *msgTypes.Trn)

TransactionHandle handles the transaction message from peer

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

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

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

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

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

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

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

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

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