p2p

package
v0.0.0-...-5e88e9b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 17, 2019 License: GPL-3.0 Imports: 44 Imported by: 0

Documentation

Overview

Package p2p implements the Hpb p2p network protocols.

Index

Constants

View Source 
const (
	StatusMsg         uint64 = 0x1010
	ExchangeMsg       uint64 = 0x1011
	ReqNodesMsg       uint64 = 0x1020
	ResNodesMsg       uint64 = 0x1021
	ReqBWTestMsg      uint64 = 0x1030
	ResBWTestMsg      uint64 = 0x1031
	ReqRemoteStateMsg uint64 = 0x1040
	ResRemoteStateMsg uint64 = 0x1041

	NewBlockHashesMsg  uint64 = 0x2012
	TxMsg              uint64 = 0x2013
	GetBlockHeadersMsg uint64 = 0x2014
	BlockHeadersMsg    uint64 = 0x2015
	GetBlockBodiesMsg  uint64 = 0x2016
	BlockBodiesMsg     uint64 = 0x2017
	NewBlockMsg        uint64 = 0x2018
	GetNodeDataMsg     uint64 = 0x2019
	NodeDataMsg        uint64 = 0x201a
	GetReceiptsMsg     uint64 = 0x201b
	ReceiptsMsg        uint64 = 0x201c

	NewHashBlockMsg uint64 = 0x2020
)

message of hpb protocol

View Source 
const (
	PeerEventAdd     event.EventType = 0x01
	PeerEventDrop    event.EventType = 0x02
	PeerEventMsgSend event.EventType = 0x03
	PeerEventMsgRecv event.EventType = 0x04
)
View Source 
const (
	ErrMsgTooLarge = iota
	ErrDecode
	ErrProtocolVersionMismatch
	ErrNetworkIdMismatch
	ErrGenesisBlockMismatch
	ErrNoStatusMsg
	ErrNoExchangeMsg
)
View Source 
const (
	MaxMsgSize = 50 * 1024 * 1024
)
View Source 
const ProtoName = "hpb"

HPB 支持的协议消息

View Source 
const ProtoVersion100 uint = 100
View Source 
const RandNonceSize = 32

Variables

View Source 
var INSTANCE = atomic.Value{}
View Source 
var ProtocolVersions = []uint{ProtoVersion100}

Functions

func ErrResp 

func ErrResp(code errCode, format string, v ...interface{}) error

func ExpectMsg 

func ExpectMsg(r MsgReader, code uint64, content interface{}) error

ExpectMsg reads a message from r and verifies that its code and encoded RLP content match the provided values. If content is nil, the payload is discarded and not verified.

func HandleReqNodesMsg 

func HandleReqNodesMsg(p *Peer, msg Msg) error

func HandleReqRemoteStateMsg 

func HandleReqRemoteStateMsg(p *Peer, msg Msg) error

func HandleResNodesMsg 

func HandleResNodesMsg(p *Peer, msg Msg) error

func HandleResRemoteStateMsg 

func HandleResRemoteStateMsg(p *Peer, msg Msg) error

func SendData 

func SendData(p *Peer, msgCode uint64, data interface{}) error

Types

type Cap 

type Cap struct {
	Name    string
	Version uint
}

func (Cap) String 

func (cap Cap) String() string

type ChanStatusCB 

type ChanStatusCB func() (td *big.Int, currentBlock common.Hash, genesisBlock common.Hash)

type Config 

type Config struct {
	PrivateKey     *ecdsa.PrivateKey `toml:"-"`
	Name           string            `toml:"-"`
	BootstrapNodes []*discover.Node
	StaticNodes    []*discover.Node
	NetRestrict    *netutil.Netlist `toml:",omitempty"`
	NodeDatabase   string           `toml:",omitempty"`
	Protocols      []Protocol       `toml:"-"`
	ListenAddr     string
	NAT            nat.Interface `toml:",omitempty"`

	EnableMsgEvents bool
	NetworkId       uint64
	CoinBase        common.Address

	TestMode bool
}

Config holds Server options.

type DiscReason 

type DiscReason uint
const (
	DiscRequested DiscReason = iota
	DiscNetworkError
	DiscProtocolError
	DiscUselessPeer
	DiscPeerBySyn
	DiscAlreadyConnected
	DiscIncompatibleVersion
	DiscInvalidIdentity
	DiscQuitting
	DiscUnexpectedIdentity
	DiscSelf
	DiscReadTimeout
	DiscUnknownNode
	DiscUnexpectedConnected
	DiscHwSignError
	DiscSubprotocolError = 0x10
)

func (DiscReason) Error 

func (d DiscReason) Error() string

func (DiscReason) String 

func (d DiscReason) String() string

type HpbInfo 

type HpbInfo struct {
	TD   *big.Int `json:"handshakeTD"` // Total difficulty of the peer's blockchain
	Head string   `json:"handshakeHD"` // SHA3 hash of the peer's best owned block
}

type HpbProto 

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

//////////////////////////////////////////////////////

func NewProtos 

func NewProtos() *HpbProto

func (*HpbProto) Protocols 

func (s *HpbProto) Protocols() []Protocol

type HwPair 

type HwPair struct {
	Adr string
	Cid []byte
	Hid []byte
}

type ModuleType 

type ModuleType uint

type Msg 

type Msg struct {
	Code       uint64
	Size       uint32 // size of the paylod
	Payload    io.Reader
	ReceivedAt time.Time
}

Msg defines the structure of a p2p message.

Note that a Msg can only be sent once since the Payload reader is consumed during sending. It is not possible to create a Msg and send it any number of times. If you want to reuse an encoded structure, encode the payload into a byte array and create a separate Msg with a bytes.Reader as Payload for each send.

func (Msg) Decode 

func (msg Msg) Decode(val interface{}) error

Decode parses the RLP content of a message into the given value, which must be a pointer.

For the decoding rules, please see package rlp.

func (Msg) Discard 

func (msg Msg) Discard() error

Discard reads any remaining payload data into a black hole.

func (Msg) String 

func (msg Msg) String() string

type MsgProcessCB 

type MsgProcessCB func(p *Peer, msg Msg) error

type MsgReadWriter 

type MsgReadWriter interface {
	MsgReader
	MsgWriter
}

MsgReadWriter provides reading and writing of encoded messages. Implementations should ensure that ReadMsg and WriteMsg can be called simultaneously from multiple goroutines.

type MsgReader 

type MsgReader interface {
	ReadMsg() (Msg, error)
}

type MsgWriter 

type MsgWriter interface {
	// WriteMsg sends a message. It will block until the message's
	// Payload has been consumed by the other end.
	//
	// Note that messages can be sent only once because their
	// payload reader is drained.
	WriteMsg(Msg) error
}

type NodeDialer 

type NodeDialer interface {
	Dial(*discover.Node) (net.Conn, error)
}

NodeDialer is used to connect to nodes in the network, typically by using an underlying net.Dialer but also using net.Pipe in tests

type NodeInfo 

type NodeInfo struct {
	ID    string `json:"id"`    // Unique node identifier (also the encryption key)
	Name  string `json:"name"`  // Name of the node, including client type, version, OS, custom data
	Local string `json:"local"` // Local node type
	IP    string `json:"ip"`    // IP address of the node
	Ports struct {
		UDP int `json:"udp"` // UDP listening port for discovery protocol
		TCP int `json:"tcp"` // TCP listening port for RLPx
	} `json:"ports"`
	ListenAddr string `json:"listenAddr"`
}

type OnAddPeerCB 

type OnAddPeerCB func(p *Peer) error

type OnDropPeerCB 

type OnDropPeerCB func(p *Peer) error

type Peer 

type Peer struct {
	*PeerBase
	// contains filtered or unexported fields
}

func NewPeer 

func NewPeer(version uint, pr *PeerBase, rw MsgReadWriter) *Peer

func (*Peer) Bandwidth 

func (p *Peer) Bandwidth() float64

func (*Peer) Exchange 

func (p *Peer) Exchange(our *exchangeData) (*exchangeData, error)

func (*Peer) GetID 

func (p *Peer) GetID() string

func (*Peer) GetVersion 

func (p *Peer) GetVersion() uint

func (*Peer) Handshake 

func (p *Peer) Handshake(network uint64, td *big.Int, head common.Hash, genesis common.Hash) error

Handshake executes the eth protocol handshake, negotiating version number, network IDs, difficulties, head and genesis blocks.

func (*Peer) Head 

func (p *Peer) Head() (hash common.Hash, td *big.Int)

Head retrieves a copy of the current head hash and total difficulty of the peer.

func (*Peer) KnownBlockAdd 

func (p *Peer) KnownBlockAdd(hash common.Hash)

func (*Peer) KnownBlockHas 

func (p *Peer) KnownBlockHas(hash common.Hash) bool

func (*Peer) KnownBlockSize 

func (p *Peer) KnownBlockSize() int

func (*Peer) KnownTxsAdd 

func (p *Peer) KnownTxsAdd(hash common.Hash)

func (*Peer) KnownTxsHas 

func (p *Peer) KnownTxsHas(hash common.Hash) bool

func (*Peer) KnownTxsSize 

func (p *Peer) KnownTxsSize() int

func (*Peer) SetHead 

func (p *Peer) SetHead(hash common.Hash, td *big.Int)

SetHead updates the head hash and total difficulty of the peer.

func (*Peer) SetTxsRate 

func (p *Peer) SetTxsRate(txs float64)

TODO: set txs rate value

func (*Peer) String 

func (p *Peer) String() string

String implements fmt.Stringer.

func (*Peer) TxsRate 

func (p *Peer) TxsRate() float64

type PeerBase 

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

Peer represents a connected remote node.

func (*PeerBase) Address 

func (p *PeerBase) Address() common.Address

func (*PeerBase) Caps 

func (p *PeerBase) Caps() []Cap

Caps returns the capabilities (supported subprotocols) of the remote peer.

func (*PeerBase) Disconnect 

func (p *PeerBase) Disconnect(reason DiscReason)

Disconnect terminates the peer connection with the given reason. It returns immediately and does not wait until the connection is closed.

func (*PeerBase) ID 

func (p *PeerBase) ID() discover.NodeID

ID returns the node's public key.

func (*PeerBase) LocalAddr 

func (p *PeerBase) LocalAddr() net.Addr

LocalAddr returns the local address of the network connection.

func (*PeerBase) LocalType 

func (p *PeerBase) LocalType() discover.NodeType

LocalType returns the local type of the node.

func (*PeerBase) Name 

func (p *PeerBase) Name() string

Name returns the node name that the remote node advertised.

func (*PeerBase) RemoteAddr 

func (p *PeerBase) RemoteAddr() net.Addr

RemoteAddr returns the remote address of the network connection.

func (*PeerBase) RemoteIP 

func (p *PeerBase) RemoteIP() string

func (*PeerBase) RemoteIperfPort 

func (p *PeerBase) RemoteIperfPort() int

func (*PeerBase) RemoteListenPort 

func (p *PeerBase) RemoteListenPort() int

func (*PeerBase) RemoteType 

func (p *PeerBase) RemoteType() discover.NodeType

RemoteType returns the remote type of the node.

func (*PeerBase) SetRemoteType 

func (p *PeerBase) SetRemoteType(nt discover.NodeType) bool

func (*PeerBase) String 

func (p *PeerBase) String() string

String implements fmt.Stringer.

func (*PeerBase) Version 

func (p *PeerBase) Version() string

type PeerEvent 

type PeerEvent struct {
	Type     event.EventType `json:"type"`
	Peer     discover.NodeID `json:"peer"`
	Error    string          `json:"error,omitempty"`
	Protocol string          `json:"protocol,omitempty"`
	MsgCode  *uint64         `json:"msg_code,omitempty"`
	MsgSize  *uint32         `json:"msg_size,omitempty"`
}

type PeerEventType 

type PeerEventType string

PeerEventType is the type of peer events emitted by a p2p.Server

type PeerInfo 

type PeerInfo struct {
	ID      string `json:"id"`      // Unique node identifier (also the encryption key)
	Name    string `json:"name"`    // Name of the node, including client type, version, OS, custom data
	Version string `json:"version"` // Ghpb version
	Remote  string `json:"remote"`  // Remote node type
	Cap     string `json:"cap"`     // Sum-protocols advertised by this particular peer
	Network struct {
		Local  string `json:"local"`  // Local endpoint of the TCP data connection
		Remote string `json:"remote"` // Remote endpoint of the TCP data connection
	} `json:"network"`
	Start  string      `json:"start"`  //
	Beat   string      `json:"beat"`   //
	Mining string      `json:"mining"` //
	HPB    interface{} `json:"hpb"`    // Sub-protocol specific metadata fields
}

type PeerManager 

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

func PeerMgrInst 

func PeerMgrInst() *PeerManager

func (*PeerManager) BestPeer 

func (prm *PeerManager) BestPeer() *Peer

BestPeer retrieves the known peer with the currently highest total difficulty.

func (*PeerManager) DefaultAddr 

func (prm *PeerManager) DefaultAddr() common.Address

func (*PeerManager) GetHwInfo 

func (prm *PeerManager) GetHwInfo() []HwPair

func (*PeerManager) GetLocalType 

func (prm *PeerManager) GetLocalType() discover.NodeType

func (*PeerManager) HandleReqBWTestMsg 

func (prm *PeerManager) HandleReqBWTestMsg(p *Peer, msg Msg) error

func (*PeerManager) HandleResBWTestMsg 

func (prm *PeerManager) HandleResBWTestMsg(p *Peer, msg Msg) error

func (*PeerManager) Len 

func (prm *PeerManager) Len() int
func (prm *PeerManager) SetHpRemoteFlag(flag bool) {
	//log.Info("Change hp remote flag","from",prm.server.hpflag,"to",flag)
	if prm.server.hpflag != flag {
		prm.server.hpflag = flag
	}
}

Len returns if the current number of peers in the set.

func (*PeerManager) NodeInfo 

func (prm *PeerManager) NodeInfo() *NodeInfo

func (*PeerManager) P2pSvr 

func (prm *PeerManager) P2pSvr() *Server

func (*PeerManager) Peer 

func (prm *PeerManager) Peer(id string) *Peer

Peer retrieves the registered peer with the given id.

func (*PeerManager) PeersAll 

func (prm *PeerManager) PeersAll() []*Peer

func (*PeerManager) PeersInfo 

func (prm *PeerManager) PeersInfo() []*PeerInfo

func (*PeerManager) PeersWithoutBlock 

func (prm *PeerManager) PeersWithoutBlock(hash common.Hash) []*Peer

PeersWithoutBlock retrieves a list of peers that do not have a given block in their set of known hashes.

func (*PeerManager) PeersWithoutTx 

func (prm *PeerManager) PeersWithoutTx(hash common.Hash) []*Peer

PeersWithoutTx retrieves a list of peers that do not have a given transaction in their set of known hashes.

func (*PeerManager) Protocol 

func (prm *PeerManager) Protocol() []Protocol

func (*PeerManager) RegChanStatus 

func (prm *PeerManager) RegChanStatus(cb ChanStatusCB)

func (*PeerManager) RegMsgProcess 

func (prm *PeerManager) RegMsgProcess(msg uint64, cb MsgProcessCB)

//////////////////////////////////////////////////////////////////

func (*PeerManager) RegOnAddPeer 

func (prm *PeerManager) RegOnAddPeer(cb OnAddPeerCB)

func (*PeerManager) RegOnDropPeer 

func (prm *PeerManager) RegOnDropPeer(cb OnDropPeerCB)

func (*PeerManager) RegStatMining 

func (prm *PeerManager) RegStatMining(cb StatMining)

func (*PeerManager) Register 

func (prm *PeerManager) Register(p *Peer) error

Register injects a new peer into the working set, or returns an error if the peer is already known.

func (*PeerManager) SetHwInfo 

func (prm *PeerManager) SetHwInfo(pairs []HwPair) error

func (*PeerManager) SetLocalType 

func (prm *PeerManager) SetLocalType(nt discover.NodeType) bool

func (*PeerManager) Start 

func (prm *PeerManager) Start(coinbase common.Address) error

func (*PeerManager) Stop 

func (prm *PeerManager) Stop()

type Protocol 

type Protocol struct {
	Name    string
	Version uint
	Run     func(p *PeerBase, rw MsgReadWriter) error
}

Protocol represents a P2P subprotocol implementation.

type Server 

type Server struct {
	// Config fields may not be modified while the server is running.
	Config
	// contains filtered or unexported fields
}

Server manages all peer connections.

func (*Server) AddPeer 

func (srv *Server) AddPeer(node *discover.Node)

AddPeer connects to the given node and maintains the connection until the server is shut down. If the connection fails for any reason, the server will attempt to reconnect the peer.

func (*Server) PeerCount 

func (srv *Server) PeerCount() int

PeerCount returns the number of connected peers.

func (*Server) Peers 

func (srv *Server) Peers() []*PeerBase

Peers returns all connected peers.

func (*Server) RemovePeer 

func (srv *Server) RemovePeer(node *discover.Node)

RemovePeer disconnects from the given node

func (*Server) Self 

func (srv *Server) Self() *discover.Node

Self returns the local node's endpoint information.

func (*Server) SetupConn 

func (srv *Server) SetupConn(fd net.Conn, flags connFlag, dialDest *discover.Node)

SetupConn runs the handshakes and attempts to add the connection as a peer. It returns when the connection has been added as a peer or the handshakes have failed.

func (*Server) Start 

func (srv *Server) Start() (err error)

Start starts running the server. Servers can not be re-used after stopping.

func (*Server) Stop 

func (srv *Server) Stop()

Stop terminates the server and all active peer connections. It blocks until all active connections have been closed.

func (*Server) SubscribeEvents 

func (srv *Server) SubscribeEvents(et event.EventType) event.Subscriber

SubscribePeers subscribes the given channel to peer events

type StatDetail 

type StatDetail struct {
	ID     uint
	Detail string
}

//////////////////////////////////////////////////////

type StatMining 

type StatMining func() bool

type SynnodePid 

type SynnodePid struct {
	PID string `json:"pid"`
}

type TCPDialer 

type TCPDialer struct {
	*net.Dialer
}

TCPDialer implements the NodeDialer interface by using a net.Dialer to create TCP connections to nodes in the network

func (TCPDialer) Dial 

func (t TCPDialer) Dial(dest *discover.Node) (net.Conn, error)

Dial creates a TCP connection to the node

Source Files

View all Source files

Directories

Path Synopsis
Package nat provides access to common network port mapping protocols.
 Package nat provides access to common network port mapping protocols.
Package netutil contains extensions to the net package.
 Package netutil contains extensions to the net package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.