p2p

package
v0.0.0-...-24e5678 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2023 License: LGPL-3.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidHandshake           = errors.New("invalid handshake")
	ErrInvalidLength              = errors.New("invalid length")
	ErrUnknownMessage             = errors.New("unknown message")
	ErrNotExistPeer               = errors.New("not exist peer")
	ErrSelfConnection             = errors.New("self connection")
	ErrInvalidUTXO                = errors.New("invalid UTXO")
	ErrTooManyTrasactionInMessage = errors.New("too many transaction in message")
	ErrExistSerializableType      = errors.New("exist serializable type")
	ErrInvalidSerializableTypeID  = errors.New("invalid serializable type id")
	ErrInvalidSignatureCount      = errors.New("invalid signature count")
	ErrActiveGeneratorsNotAllowed = errors.New("not allowd for active generators")
)

errors

View Source 
var (
	StatusMessageType                     = RegisterSerializableType(&StatusMessage{})
	RequestMessageType                    = RegisterSerializableType(&RequestMessage{})
	BlockMessageType                      = RegisterSerializableType(&BlockMessage{})
	TransactionMessageType                = RegisterSerializableType(&TransactionMessage{})
	PeerListMessageType                   = RegisterSerializableType(&PeerListMessage{})
	RequestPeerListMessageType            = RegisterSerializableType(&RequestPeerListMessage{})
	ActiveGeneratorListMessageType        = RegisterSerializableType(&ActiveGeneratorListMessage{})
	RequestActiveGeneratorListMessageType = RegisterSerializableType(&RequestActiveGeneratorListMessage{})
)

message types

Functions

func BlockPacketWithCache 

func BlockPacketWithCache(msg *RequestMessage, provider types.Provider, batchCache gcache.Cache, singleCache gcache.Cache) ([]byte, error)

func FillBytes 

func FillBytes(r io.Reader, bs []byte) (int64, error)

FillBytes reads bytes from the reader until the given bytes array is filled

func MakeHandSharkBs 

func MakeHandSharkBs(chainID *big.Int, rn uint64, ti uint64) ([]byte, error)

func MessageToPacket 

func MessageToPacket(m Serializable) []byte

MessageToPacket returns packet of the message

func PacketMessageType 

func PacketMessageType(bs []byte) uint32

func ReadBool 

func ReadBool(r io.Reader) (bool, int64, error)

ReadBool reads a bool using a uint8 from the reader

func ReadBytes 

func ReadBytes(r io.Reader) ([]byte, int64, error)

ReadBytes reads a byte array from the reader

func ReadString 

func ReadString(r io.Reader) (string, int64, error)

ReadString reads a string array from the reader

func ReadUint16 

func ReadUint16(r io.Reader) (uint16, int64, error)

ReadUint16 reads a uint16 number from the reader

func ReadUint32 

func ReadUint32(r io.Reader) (uint32, int64, error)

ReadUint32 reads a uint32 number from the reader

func ReadUint64 

func ReadUint64(r io.Reader) (uint64, int64, error)

ReadUint64 reads a uint64 number from the reader

func ReadUint8 

func ReadUint8(r io.Reader) (uint8, int64, error)

ReadUint8 reads a uint8 number from the reader

func RecoveryHandSharkBs 

func RecoveryHandSharkBs(bs []byte) (chainID *big.Int, rn uint64, ti uint64, err error)

func RegisterSerializableType 

func RegisterSerializableType(s Serializable) uint32

func SerializableName 

func SerializableName(TypeID uint32) string

func ToTypeID 

func ToTypeID(name string) uint32

Types

type ActiveGeneratorListMessage 

type ActiveGeneratorListMessage struct {
	Timestamp  uint64
	Generators []common.Address
}

GeneratorListMessage used to send a genreator list to a peer

func (*ActiveGeneratorListMessage) ReadFrom 

func (s *ActiveGeneratorListMessage) ReadFrom(r io.Reader) (int64, error)

func (*ActiveGeneratorListMessage) TypeID 

func (s *ActiveGeneratorListMessage) TypeID() uint32

func (*ActiveGeneratorListMessage) WriteTo 

func (s *ActiveGeneratorListMessage) WriteTo(w io.Writer) (int64, error)

type BlockMessage 

type BlockMessage struct {
	Blocks []*types.Block
}

BlockMessage used to send a chain block to a peer

func (*BlockMessage) ReadFrom 

func (s *BlockMessage) ReadFrom(r io.Reader) (int64, error)

func (*BlockMessage) TypeID 

func (s *BlockMessage) TypeID() uint32

func (*BlockMessage) WriteTo 

func (s *BlockMessage) WriteTo(w io.Writer) (int64, error)

type Handler 

type Handler interface {
	OnConnected(p peer.Peer)
	OnDisconnected(p peer.Peer)
	OnRecv(p peer.Peer, bs []byte) error
}

Handler is a interface for connection events

type Node 

type Node struct {
	sync.Mutex
	ChainID *big.Int
	// contains filtered or unexported fields
}

Node receives a block by the consensus

func NewNode 

func NewNode(ChainID *big.Int, key key.Key, SeedNodeMap map[common.PublicKey]string, cn *chain.Chain, peerStorePath string) *Node

NewNode returns a Node

func (*Node) ActiveGenerators 

func (fr *Node) ActiveGenerators() ([]common.Address, error)

ActiveGenerators returns the received active generators from observer channel closed after 2 seconds

func (*Node) AddTx 

func (nd *Node) AddTx(tx *types.Transaction, sig common.Signature) error

AddTx adds tx to txpool

func (*Node) Close 

func (nd *Node) Close()

Close terminates the node

func (*Node) GetTxFromTXPool 

func (nd *Node) GetTxFromTXPool(TxHash hash.Hash256) *txpool.PoolItem

GetTxFromTXPool returned tx from txpool

func (*Node) HasPeer 

func (nd *Node) HasPeer() int

GetTxFromTXPool returned tx from txpool

func (*Node) Init 

func (nd *Node) Init() error

Init initializes node

func (*Node) OnConnected 

func (nd *Node) OnConnected(p peer.Peer)

OnConnected called when peer connected

func (*Node) OnDisconnected 

func (nd *Node) OnDisconnected(p peer.Peer)

OnDisconnected called when peer disconnected

func (*Node) OnItemExpired 

func (nd *Node) OnItemExpired(Interval time.Duration, Key string, Item interface{}, IsLast bool) queue.TxExpiredType

OnItemExpired is called when the item is expired

func (*Node) OnRecv 

func (nd *Node) OnRecv(p peer.Peer, bs []byte) error

OnRecv called when message received

func (*Node) OnTimerExpired 

func (nd *Node) OnTimerExpired(height uint32, value string)

OnTimerExpired called when rquest expired

func (*Node) PacketProcess 

func (nd *Node) PacketProcess()

func (*Node) PushTx 

func (nd *Node) PushTx(tx *types.Transaction, sig common.Signature) error

PushTx pushes transaction

func (*Node) Run 

func (nd *Node) Run(BindAddress string)

Run starts the node

func (*Node) TestFullTx 

func (nd *Node) TestFullTx() bool

func (*Node) TxPoolList 

func (nd *Node) TxPoolList() []*txpool.PoolItem

TxPoolList returned tx list from txpool

func (*Node) TxPoolSize 

func (nd *Node) TxPoolSize() int

TxPoolSize returned tx list size txpool

type NodeMesh 

type NodeMesh struct {
	sync.Mutex
	BindAddress string
	// contains filtered or unexported fields
}

NodeMesh is a mesh for networking between nodes

func NewNodeMesh 

func NewNodeMesh(ChainID *big.Int, key key.Key, SeedNodeMap map[common.PublicKey]string, handler Handler, peerStorePath string) *NodeMesh

NewNodeMesh returns a NodeMesh

func (*NodeMesh) AddBadPoint 

func (ms *NodeMesh) AddBadPoint(ID string, Point int)

AddBadPoint adds bad points to to the peer

func (*NodeMesh) AddPeerList 

func (ms *NodeMesh) AddPeerList(ips []string, hashs []string)

func (*NodeMesh) BroadcastPacket 

func (ms *NodeMesh) BroadcastPacket(bs []byte)

BroadcastPacket sends a packet to all peers

func (*NodeMesh) ExceptCast 

func (ms *NodeMesh) ExceptCast(ID string, bs []byte)

ExceptCast sends a message except the peer

func (*NodeMesh) GetPeer 

func (ms *NodeMesh) GetPeer(ID string) peer.Peer

GetPeer returns the peer of the id

func (*NodeMesh) HasPeer 

func (ms *NodeMesh) HasPeer() bool

func (*NodeMesh) Peers 

func (ms *NodeMesh) Peers() []peer.Peer

Peers returns peers of the node mesh

func (*NodeMesh) RemovePeer 

func (ms *NodeMesh) RemovePeer(ID string)

RemovePeer removes peers from the mesh

func (*NodeMesh) RequestConnect 

func (ms *NodeMesh) RequestConnect(Address string, TargetPubHash common.PublicKey)

func (*NodeMesh) RequestPeerList 

func (ms *NodeMesh) RequestPeerList(targetHash string)

func (*NodeMesh) Run 

func (ms *NodeMesh) Run(BindAddress string)

Run starts the node mesh

func (*NodeMesh) SendPeerList 

func (ms *NodeMesh) SendPeerList(targetHash string)

func (*NodeMesh) SendTo 

func (ms *NodeMesh) SendTo(pubhash common.PublicKey, bs []byte)

SendTo sends a message to the node

type PeerListMessage 

type PeerListMessage struct {
	Ips   []string
	Hashs []string
}

PeerListMessage is a message for a peer list

func (*PeerListMessage) ReadFrom 

func (s *PeerListMessage) ReadFrom(r io.Reader) (int64, error)

func (*PeerListMessage) TypeID 

func (s *PeerListMessage) TypeID() uint32

func (*PeerListMessage) WriteTo 

func (s *PeerListMessage) WriteTo(w io.Writer) (int64, error)

type RecvMessageItem 

type RecvMessageItem struct {
	PeerID string
	Packet []byte
}

RecvMessageItem used to store recv message

type RequestActiveGeneratorListMessage 

type RequestActiveGeneratorListMessage struct {
	Timestamp uint64
}

RequestGeneratorListMessage is a request message for a generator list

func (*RequestActiveGeneratorListMessage) ReadFrom 

func (s *RequestActiveGeneratorListMessage) ReadFrom(r io.Reader) (int64, error)

func (*RequestActiveGeneratorListMessage) TypeID 

func (s *RequestActiveGeneratorListMessage) TypeID() uint32

func (*RequestActiveGeneratorListMessage) WriteTo 

func (s *RequestActiveGeneratorListMessage) WriteTo(w io.Writer) (int64, error)

type RequestExpireHandler 

type RequestExpireHandler interface {
	OnTimerExpired(height uint32, value string)
}

RequestExpireHandler handles a request expire event

type RequestMessage 

type RequestMessage struct {
	Height uint32
	Count  uint8
}

RequestMessage used to request a chain data to a peer

func (*RequestMessage) ReadFrom 

func (s *RequestMessage) ReadFrom(r io.Reader) (int64, error)

func (*RequestMessage) TypeID 

func (s *RequestMessage) TypeID() uint32

func (*RequestMessage) WriteTo 

func (s *RequestMessage) WriteTo(w io.Writer) (int64, error)

type RequestPeerListMessage 

type RequestPeerListMessage struct {
}

RequestPeerListMessage is a request message for a peer list

func (*RequestPeerListMessage) ReadFrom 

func (s *RequestPeerListMessage) ReadFrom(r io.Reader) (int64, error)

func (*RequestPeerListMessage) TypeID 

func (s *RequestPeerListMessage) TypeID() uint32

func (*RequestPeerListMessage) WriteTo 

func (s *RequestPeerListMessage) WriteTo(w io.Writer) (int64, error)

type RequestTimer 

type RequestTimer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

RequestTimer triggers a event when a request is expired

func NewRequestTimer 

func NewRequestTimer(handler RequestExpireHandler) *RequestTimer

NewRequestTimer returns a RequestTimer

func (*RequestTimer) Add 

func (rm *RequestTimer) Add(height uint32, t time.Duration, value string)

Add adds the timer of the request

func (*RequestTimer) Exist 

func (rm *RequestTimer) Exist(height uint32) bool

Exist returns the target height request exists or not

func (*RequestTimer) RemovesByValue 

func (rm *RequestTimer) RemovesByValue(value string)

RemovesByValue removes requests by the value

func (*RequestTimer) Run 

func (rm *RequestTimer) Run()

Run is the main loop of RequestTimer

type SendMessageItem 

type SendMessageItem struct {
	Target  common.PublicKey
	Address common.Address
	Except  bool
	Packet  []byte
}

SendMessageItem used to store send message

type Serializable 

type Serializable interface {
	TypeID() uint32
	io.WriterTo
	io.ReaderFrom
}

func CreateSerializable 

func CreateSerializable(TypeID uint32) (Serializable, error)

func PacketToMessage 

func PacketToMessage(bs []byte) (Serializable, error)

type Status 

type Status struct {
	Height uint32
}

Status represents the status of the peer

type StatusMessage 

type StatusMessage struct {
	Version  uint16
	Height   uint32
	LastHash hash.Hash256
}

StatusMessage used to provide the chain information to a peer

func (*StatusMessage) ReadFrom 

func (s *StatusMessage) ReadFrom(r io.Reader) (int64, error)

func (*StatusMessage) TypeID 

func (s *StatusMessage) TypeID() uint32

func (*StatusMessage) WriteTo 

func (s *StatusMessage) WriteTo(w io.Writer) (int64, error)

type TCPAsyncPeer 

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

TCPAsyncPeer manages send and recv of the connection

func NewTCPAsyncPeer 

func NewTCPAsyncPeer(conn net.Conn, ID string, Name string, connectedTime int64) *TCPAsyncPeer

NewTCPAsyncPeer returns a TCPAsyncPeer

func (*TCPAsyncPeer) Close 

func (p *TCPAsyncPeer) Close()

Close closes TCPAsyncPeer

func (*TCPAsyncPeer) ConnectedTime 

func (p *TCPAsyncPeer) ConnectedTime() int64

ConnectedTime returns peer connected time

func (*TCPAsyncPeer) ID 

func (p *TCPAsyncPeer) ID() string

ID returns the id of the peer

func (*TCPAsyncPeer) IsClosed 

func (p *TCPAsyncPeer) IsClosed() bool

IsClosed returns it is closed or not

func (*TCPAsyncPeer) Name 

func (p *TCPAsyncPeer) Name() string

Name returns the name of the peer

func (*TCPAsyncPeer) ReadPacket 

func (p *TCPAsyncPeer) ReadPacket() ([]byte, error)

ReadPacket returns a packet data

func (*TCPAsyncPeer) SendPacket 

func (p *TCPAsyncPeer) SendPacket(bs []byte)

SendPacket sends packet to the WebsocketPeer

type TCPPeer 

type TCPPeer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

TCPPeer manages send and recv of the connection

func NewTCPPeer 

func NewTCPPeer(conn net.Conn, ID string, Name string, connectedTime int64) *TCPPeer

NewTCPPeer returns a TCPPeer

func (*TCPPeer) Close 

func (p *TCPPeer) Close()

Close closes TCPPeer

func (*TCPPeer) ConnectedTime 

func (p *TCPPeer) ConnectedTime() int64

ConnectedTime returns peer connected time

func (*TCPPeer) ID 

func (p *TCPPeer) ID() string

ID returns the id of the peer

func (*TCPPeer) IsClosed 

func (p *TCPPeer) IsClosed() bool

IsClosed returns it is closed or not

func (*TCPPeer) Name 

func (p *TCPPeer) Name() string

Name returns the name of the peer

func (*TCPPeer) ReadPacket 

func (p *TCPPeer) ReadPacket() ([]byte, error)

ReadPacket returns a packet data

func (*TCPPeer) SendPacket 

func (p *TCPPeer) SendPacket(bs []byte)

SendPacket sends packet to the WebsocketPeer

type TransactionMessage 

type TransactionMessage struct {
	Txs        []*types.Transaction //MAXLEN : 65535
	Signatures []common.Signature   //MAXLEN : 65535
}

TransactionMessage is a message for a transaction

func (*TransactionMessage) ReadFrom 

func (s *TransactionMessage) ReadFrom(r io.Reader) (int64, error)

func (*TransactionMessage) TypeID 

func (s *TransactionMessage) TypeID() uint32

func (*TransactionMessage) WriteTo 

func (s *TransactionMessage) WriteTo(w io.Writer) (int64, error)

type TxMsgItem 

type TxMsgItem struct {
	TxHash hash.Hash256
	Tx     *types.Transaction
	Sig    common.Signature
	PeerID string
	ErrCh  *chan error
}

TxMsgItem used to store transaction message

type WebsocketPeer 

type WebsocketPeer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

WebsocketPeer manages send and recv of the connection

func NewWebsocketPeer 

func NewWebsocketPeer(conn *websocket.Conn, ID string, Name string, connectedTime int64) *WebsocketPeer

NewWebsocketPeer returns a WebsocketPeer

func (*WebsocketPeer) Close 

func (p *WebsocketPeer) Close()

Close closes WebsocketPeer

func (*WebsocketPeer) ConnectedTime 

func (p *WebsocketPeer) ConnectedTime() int64

ConnectedTime returns peer connected time

func (*WebsocketPeer) ID 

func (p *WebsocketPeer) ID() string

ID returns the id of the peer

func (*WebsocketPeer) IsClosed 

func (p *WebsocketPeer) IsClosed() bool

IsClosed returns it is closed or not

func (*WebsocketPeer) Name 

func (p *WebsocketPeer) Name() string

Name returns the name of the peer

func (*WebsocketPeer) ReadPacket 

func (p *WebsocketPeer) ReadPacket() ([]byte, error)

ReadPacket returns a packet data

func (*WebsocketPeer) SendPacket 

func (p *WebsocketPeer) SendPacket(bs []byte)

SendPacket sends packet to the WebsocketPeer

Source Files

View all Source files

Directories

Path Synopsis

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.