netsync

package
v0.0.0-...-9eea1c9 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2019 License: AGPL-3.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BlockchainChannel = byte(0x40)

	BlockRequestByte    = byte(0x10)
	BlockResponseByte   = byte(0x11)
	HeadersRequestByte  = byte(0x12)
	HeadersResponseByte = byte(0x13)
	BlocksRequestByte   = byte(0x14)
	BlocksResponseByte  = byte(0x15)
	StatusRequestByte   = byte(0x20)
	StatusResponseByte  = byte(0x21)
	NewTransactionByte  = byte(0x30)
	NewMineBlockByte    = byte(0x40)
	FilterLoadByte      = byte(0x50)
	FilterAddByte       = byte(0x51)
	FilterClearByte     = byte(0x52)
	MerkleRequestByte   = byte(0x60)
	MerkleResponseByte  = byte(0x61)
)

protocol msg byte

Variables

This section is empty.

Functions

This section is empty.

Types

type BasePeer 

type BasePeer interface {
	Addr() net.Addr
	ID() string
	ServiceFlag() consensus.ServiceFlag
	TrySend(byte, interface{}) bool
}

BasePeer is the interface for connection level peer

type BasePeerSet 

type BasePeerSet interface {
	AddBannedPeer(string) error
	StopPeerGracefully(string)
}

BasePeerSet is the intergace for connection level peer manager

type BlockMessage 

type BlockMessage struct {
	RawBlock []byte
}

BlockMessage response get block msg

func NewBlockMessage 

func NewBlockMessage(block *types.Block) (*BlockMessage, error)

NewBlockMessage construct bock response msg

func (*BlockMessage) GetBlock 

func (m *BlockMessage) GetBlock() (*types.Block, error)

GetBlock get block from msg

func (*BlockMessage) String 

func (m *BlockMessage) String() string

type BlockchainMessage 

type BlockchainMessage interface {
	String() string
}

BlockchainMessage is a generic message for this reactor.

func DecodeMessage 

func DecodeMessage(bz []byte) (msgType byte, msg BlockchainMessage, err error)

DecodeMessage decode msg

type BlocksMessage 

type BlocksMessage struct {
	RawBlocks [][]byte
}

BlocksMessage is one of the bytom msg type

func NewBlocksMessage 

func NewBlocksMessage(blocks []*types.Block) (*BlocksMessage, error)

NewBlocksMessage create a new BlocksMessage

func (*BlocksMessage) GetBlocks 

func (m *BlocksMessage) GetBlocks() ([]*types.Block, error)

GetBlocks returns the blocks in the msg

func (*BlocksMessage) String 

func (m *BlocksMessage) String() string

type Chain 

type Chain interface {
	BestBlockHeader() *types.BlockHeader
	BestBlockHeight() uint64
	CalcNextSeed(*bc.Hash) (*bc.Hash, error)
	GetBlockByHash(*bc.Hash) (*types.Block, error)
	GetBlockByHeight(uint64) (*types.Block, error)
	GetHeaderByHash(*bc.Hash) (*types.BlockHeader, error)
	GetHeaderByHeight(uint64) (*types.BlockHeader, error)
	GetTransactionStatus(*bc.Hash) (*bc.TransactionStatus, error)
	InMainChain(bc.Hash) bool
	ProcessBlock(*types.Block) (bool, error)
	ValidateTx(*types.Tx) (bool, error)
}

Chain is the interface for Bytom core

type FilterAddMessage 

type FilterAddMessage struct {
	Address []byte
}

FilterAddMessage tells the receiving peer to add address to the filter.

func (*FilterAddMessage) String 

func (m *FilterAddMessage) String() string

type FilterClearMessage 

type FilterClearMessage struct{}

FilterClearMessage tells the receiving peer to remove a previously-set filter.

func (*FilterClearMessage) String 

func (m *FilterClearMessage) String() string

type FilterLoadMessage 

type FilterLoadMessage struct {
	Addresses [][]byte
}

FilterLoadMessage tells the receiving peer to filter the transactions according to address.

func (*FilterLoadMessage) String 

func (m *FilterLoadMessage) String() string

type GetBlockMessage 

type GetBlockMessage struct {
	Height  uint64
	RawHash [32]byte
}

GetBlockMessage request blocks from remote peers by height/hash

func (*GetBlockMessage) GetHash 

func (m *GetBlockMessage) GetHash() *bc.Hash

GetHash reutrn the hash of the request

func (*GetBlockMessage) String 

func (m *GetBlockMessage) String() string

type GetBlocksMessage 

type GetBlocksMessage struct {
	RawBlockLocator [][32]byte
	RawStopHash     [32]byte
}

GetBlocksMessage is one of the bytom msg type

func NewGetBlocksMessage 

func NewGetBlocksMessage(blockLocator []*bc.Hash, stopHash *bc.Hash) *GetBlocksMessage

NewGetBlocksMessage create a new GetBlocksMessage

func (*GetBlocksMessage) GetBlockLocator 

func (m *GetBlocksMessage) GetBlockLocator() []*bc.Hash

GetBlockLocator return the locator of the msg

func (*GetBlocksMessage) GetStopHash 

func (m *GetBlocksMessage) GetStopHash() *bc.Hash

GetStopHash return the stop hash of the msg

func (*GetBlocksMessage) String 

func (m *GetBlocksMessage) String() string

type GetHeadersMessage 

type GetHeadersMessage struct {
	RawBlockLocator [][32]byte
	RawStopHash     [32]byte
}

GetHeadersMessage is one of the bytom msg type

func NewGetHeadersMessage 

func NewGetHeadersMessage(blockLocator []*bc.Hash, stopHash *bc.Hash) *GetHeadersMessage

NewGetHeadersMessage return a new GetHeadersMessage

func (*GetHeadersMessage) GetBlockLocator 

func (m *GetHeadersMessage) GetBlockLocator() []*bc.Hash

GetBlockLocator return the locator of the msg

func (*GetHeadersMessage) GetStopHash 

func (m *GetHeadersMessage) GetStopHash() *bc.Hash

GetStopHash return the stop hash of the msg

func (*GetHeadersMessage) String 

func (m *GetHeadersMessage) String() string

type GetMerkleBlockMessage 

type GetMerkleBlockMessage struct {
	Height  uint64
	RawHash [32]byte
}

GetMerkleBlockMessage request merkle blocks from remote peers by height/hash

func (*GetMerkleBlockMessage) GetHash 

func (m *GetMerkleBlockMessage) GetHash() *bc.Hash

GetHash reutrn the hash of the request

func (*GetMerkleBlockMessage) String 

func (m *GetMerkleBlockMessage) String() string

type HeadersMessage 

type HeadersMessage struct {
	RawHeaders [][]byte
}

HeadersMessage is one of the bytom msg type

func NewHeadersMessage 

func NewHeadersMessage(headers []*types.BlockHeader) (*HeadersMessage, error)

NewHeadersMessage create a new HeadersMessage

func (*HeadersMessage) GetHeaders 

func (m *HeadersMessage) GetHeaders() ([]*types.BlockHeader, error)

GetHeaders return the headers in the msg

func (*HeadersMessage) String 

func (m *HeadersMessage) String() string

type MerkleBlockMessage 

type MerkleBlockMessage struct {
	RawBlockHeader []byte
	TxHashes       [][32]byte
	RawTxDatas     [][]byte
	StatusHashes   [][32]byte
	RawTxStatuses  [][]byte
	Flags          []byte
}

MerkleBlockMessage return the merkle block to client

func NewMerkleBlockMessage 

func NewMerkleBlockMessage() *MerkleBlockMessage

NewMerkleBlockMessage construct merkle block message

func (*MerkleBlockMessage) String 

func (m *MerkleBlockMessage) String() string

type MineBlockMessage 

type MineBlockMessage struct {
	RawBlock []byte
}

MineBlockMessage new mined block msg

func NewMinedBlockMessage 

func NewMinedBlockMessage(block *types.Block) (*MineBlockMessage, error)

NewMinedBlockMessage construct new mined block msg

func (*MineBlockMessage) GetMineBlock 

func (m *MineBlockMessage) GetMineBlock() (*types.Block, error)

GetMineBlock get mine block from msg

func (*MineBlockMessage) String 

func (m *MineBlockMessage) String() string

type PeerInfo 

type PeerInfo struct {
	ID         string `json:"peer_id"`
	RemoteAddr string `json:"remote_addr"`
	Height     uint64 `json:"height"`
	Delay      uint32 `json:"delay"`
}

PeerInfo indicate peer status snap

type ProtocolReactor 

type ProtocolReactor struct {
	p2p.BaseReactor
	// contains filtered or unexported fields
}

ProtocolReactor handles new coming protocol message.

func NewProtocolReactor 

func NewProtocolReactor(sm *SyncManager, peers *peerSet) *ProtocolReactor

NewProtocolReactor returns the reactor of whole blockchain.

func (*ProtocolReactor) AddPeer 

func (pr *ProtocolReactor) AddPeer(peer *p2p.Peer) error

AddPeer implements Reactor by sending our state to peer.

func (*ProtocolReactor) GetChannels 

func (pr *ProtocolReactor) GetChannels() []*connection.ChannelDescriptor

GetChannels implements Reactor

func (*ProtocolReactor) OnStart 

func (pr *ProtocolReactor) OnStart() error

OnStart implements BaseService

func (*ProtocolReactor) OnStop 

func (pr *ProtocolReactor) OnStop()

OnStop implements BaseService

func (*ProtocolReactor) Receive 

func (pr *ProtocolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte)

Receive implements Reactor by handling 4 types of messages (look below).

func (*ProtocolReactor) RemovePeer 

func (pr *ProtocolReactor) RemovePeer(peer *p2p.Peer, reason interface{})

RemovePeer implements Reactor by removing peer from the pool.

type StatusRequestMessage 

type StatusRequestMessage struct{}

StatusRequestMessage status request msg

func (*StatusRequestMessage) String 

func (m *StatusRequestMessage) String() string

type StatusResponseMessage 

type StatusResponseMessage struct {
	Height      uint64
	RawHash     [32]byte
	GenesisHash [32]byte
}

StatusResponseMessage get status response msg

func NewStatusResponseMessage 

func NewStatusResponseMessage(blockHeader *types.BlockHeader, hash *bc.Hash) *StatusResponseMessage

NewStatusResponseMessage construct get status response msg

func (*StatusResponseMessage) GetGenesisHash 

func (m *StatusResponseMessage) GetGenesisHash() *bc.Hash

GetGenesisHash get hash from msg

func (*StatusResponseMessage) GetHash 

func (m *StatusResponseMessage) GetHash() *bc.Hash

GetHash get hash from msg

func (*StatusResponseMessage) String 

func (m *StatusResponseMessage) String() string

type SyncManager 

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

SyncManager Sync Manager is responsible for the business layer information synchronization

func NewSyncManager 

func NewSyncManager(config *cfg.Config, chain Chain, txPool *core.TxPool, newBlockCh chan *bc.Hash) (*SyncManager, error)

NewSyncManager create a sync manager

func (*SyncManager) BestPeer 

func (sm *SyncManager) BestPeer() *PeerInfo

BestPeer return the highest p2p peerInfo

func (*SyncManager) GetNewTxCh 

func (sm *SyncManager) GetNewTxCh() chan *types.Tx

GetNewTxCh return a unconfirmed transaction feed channel

func (*SyncManager) GetPeerInfos 

func (sm *SyncManager) GetPeerInfos() []*PeerInfo

GetPeerInfos return peer info of all peers

func (*SyncManager) IsCaughtUp 

func (sm *SyncManager) IsCaughtUp() bool

IsCaughtUp check wheather the peer finish the sync

func (*SyncManager) NodeInfo 

func (sm *SyncManager) NodeInfo() *p2p.NodeInfo

NodeInfo get P2P peer node info

func (*SyncManager) Start 

func (sm *SyncManager) Start()

Start start sync manager service

func (*SyncManager) Stop 

func (sm *SyncManager) Stop()

Stop stop sync manager

func (*SyncManager) StopPeer 

func (sm *SyncManager) StopPeer(peerID string) error

StopPeer try to stop peer by given ID

func (*SyncManager) Switch 

func (sm *SyncManager) Switch() *p2p.Switch

Switch get sync manager switch

type TransactionMessage 

type TransactionMessage struct {
	RawTx []byte
}

TransactionMessage notify new tx msg

func NewTransactionMessage 

func NewTransactionMessage(tx *types.Tx) (*TransactionMessage, error)

NewTransactionMessage construct notify new tx msg

func (*TransactionMessage) GetTransaction 

func (m *TransactionMessage) GetTransaction() (*types.Tx, error)

GetTransaction get tx from msg

func (*TransactionMessage) String 

func (m *TransactionMessage) String() string

Source Files

View all Source files

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.