protocol

Documentation

Overview

Package protocol p2p protocol

Index

• Constants
• func AuthenticateMessage(message types.Message, stream network.Stream) bool
• func ClearEventHandler()
• func CloseStream(stream network.Stream)
• func EventHandlerWithRecover(f func(m *queue.Message)) func(m *queue.Message)
• func HandleEvent(msg *queue.Message)
• func HandlerWithAuth(f func(request *types.P2PRequest)) network.StreamHandler
• func HandlerWithAuthAndSign(f func(request *types.P2PRequest, response *types.P2PResponse) error) network.StreamHandler
• func HandlerWithClose(f network.StreamHandler) network.StreamHandler
• func HandlerWithRW(f func(request *types.P2PRequest, response *types.P2PResponse) error) network.StreamHandler
• func HandlerWithRead(f func(request *types.P2PRequest)) network.StreamHandler
• func Init(data *prototypes.P2PEnv)
• func InitAllProtocol(env *P2PEnv)
• func ReadStream(data types.Message, stream network.Stream) error
• func ReadStreamAndAuthenticate(message types.Message, stream network.Stream) error
• func RegisterEventHandler(eventID int64, handler EventHandler)
• func RegisterProtocolInitializer(initializer Initializer)
• func SignAndWriteStream(message types.Message, stream network.Stream) error
• func WriteStream(data types.Message, stream network.Stream) error
• type EventHandler
  • func GetEventHandler(eventID int64) EventHandler
• type Initializer
• type P2PEnv

Constants

const (
	//p2pstore protocols
	FetchChunk        = "/chain33/fetch-chunk/" + types2.Version
	StoreChunk        = "/chain33/store-chunk/" + types2.Version
	GetHeader         = "/chain33/headers/" + types2.Version
	GetChunkRecord    = "/chain33/chunk-record/" + types2.Version
	BroadcastFullNode = "/chain33/full-node/" + types2.Version

	//sync protocols
	IsSync        = "/chain33/is-sync/" + types2.Version
	IsHealthy     = "/chain33/is-healthy/" + types2.Version
	GetLastHeader = "/chain33/last-header/" + types2.Version
)

all protocols

Functions

func AuthenticateMessage

func AuthenticateMessage(message types.Message, stream network.Stream) bool

AuthenticateMessage authenticates p2p message.

func ClearEventHandler

func ClearEventHandler()

ClearEventHandler clear event handler map, plugin存在多个p2p实例测试，会导致重复注册，需要清除

func CloseStream

func CloseStream(stream network.Stream)

CloseStream closes the stream after writing, and waits for the EOF.

func EventHandlerWithRecover

func EventHandlerWithRecover(f func(m *queue.Message)) func(m *queue.Message)

EventHandlerWithRecover warps the event handler with recover for catching the panic while processing message.

func HandleEvent

func HandleEvent(msg *queue.Message)

HandleEvent handle p2p event

func HandlerWithAuth

func HandlerWithAuth(f func(request *types.P2PRequest)) network.StreamHandler

HandlerWithAuth wraps HandlerWithRead with authenticating.

func HandlerWithAuthAndSign

func HandlerWithAuthAndSign(f func(request *types.P2PRequest, response *types.P2PResponse) error) network.StreamHandler

HandlerWithAuthAndSign wraps HandlerWithRW with signing and authenticating.

func HandlerWithClose

func HandlerWithClose(f network.StreamHandler) network.StreamHandler

HandlerWithClose wraps handler with closing stream and recovering from panic.

func HandlerWithRW

func HandlerWithRW(f func(request *types.P2PRequest, response *types.P2PResponse) error) network.StreamHandler

HandlerWithRW wraps handler with reading, writing, closing stream and recovering from panic.

func HandlerWithRead

func HandlerWithRead(f func(request *types.P2PRequest)) network.StreamHandler

HandlerWithRead wraps handler with reading, closing stream and recovering from panic.

func Init

func Init(data *prototypes.P2PEnv)

Init init p2p protocol

func InitAllProtocol

func InitAllProtocol(env *P2PEnv)

InitAllProtocol initials all protocols.

func ReadStream

func ReadStream(data types.Message, stream network.Stream) error

ReadStream reads message from stream.

func ReadStreamAndAuthenticate

func ReadStreamAndAuthenticate(message types.Message, stream network.Stream) error

ReadStreamAndAuthenticate verifies the message after reading it from the stream.

func RegisterEventHandler

func RegisterEventHandler(eventID int64, handler EventHandler)

RegisterEventHandler registers a handler with an event ID.

func RegisterProtocolInitializer

func RegisterProtocolInitializer(initializer Initializer)

RegisterProtocolInitializer registers the initial function.

func SignAndWriteStream

func SignAndWriteStream(message types.Message, stream network.Stream) error

SignAndWriteStream signs the message before writing it to the stream.

func WriteStream

func WriteStream(data types.Message, stream network.Stream) error

WriteStream writes message to stream.

Types

type EventHandler

type EventHandler func(*queue.Message)

EventHandler handle chain33 event

func GetEventHandler

func GetEventHandler(eventID int64) EventHandler

GetEventHandler gets event handler by event ID.

type Initializer

type Initializer func(env *P2PEnv)

Initializer is a initial function which any protocol should have.

type P2PEnv

type P2PEnv struct {
	Ctx         context.Context
	ChainCfg    *types.Chain33Config
	QueueClient queue.Client
	Host        core.Host
	P2PManager  *p2p.Manager
	SubConfig   *types2.P2PSubConfig
	DB          ds.Datastore
	*discovery.RoutingDiscovery

	RoutingTable *kbt.RoutingTable
}

P2PEnv p2p全局公共变量