blocksync

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2019 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvBlocksToPbBlocks 

func ConvBlocksToPbBlocks(blocks []*coreTypes.Block) ([]*corepb.Block, error)

ConvBlocksToPbBlocks convert []*coreTypes.Block to []*corepb.Block

func ConvBytesArrayToHashes 

func ConvBytesArrayToHashes(bytesArray [][]byte) ([]*crypto.HashType, error)

ConvBytesArrayToHashes convert [][]byte to []*crypto.HashType

func ConvHashesToBytesArray 

func ConvHashesToBytesArray(hashes []*crypto.HashType) [][]byte

ConvHashesToBytesArray convert []*crypto.HashType to [][]byte

func ConvHeadersToPbHeaders 

func ConvHeadersToPbHeaders(headers []*coreTypes.BlockHeader) (
	[]*corepb.BlockHeader, error)

ConvHeadersToPbHeaders convert []*coreTypes.BlockHeader to []*corepb.BlockHeader

func ConvPbBlocksToBlocks 

func ConvPbBlocksToBlocks(pbBlocks []*corepb.Block) ([]*coreTypes.Block, error)

ConvPbBlocksToBlocks convert []*corepb.Block to []*coreTypes.Block

func ConvPbHeadersToHeaders 

func ConvPbHeadersToHeaders(pbHeaders []*corepb.BlockHeader) (
	[]*coreTypes.BlockHeader, error)

ConvPbHeadersToHeaders convert []*corepb.BlockHeader to []*coreTypes.BlockHeader

Types

type CheckHash 

type CheckHash struct {
	BeginHash *crypto.HashType
	Length    uint32
}

CheckHash defines information about synchronizing check hash with the peer's chain, it only needs to check Length headers. Remote peer will send a root hash from the corresponding Headers

func (*CheckHash) FromProtoMessage 

func (ch *CheckHash) FromProtoMessage(message proto.Message) error

FromProtoMessage converts proto message to CheckHash

func (*CheckHash) Marshal 

func (ch *CheckHash) Marshal() (data []byte, err error)

Marshal method marshal CheckHash object to binary

func (*CheckHash) ToProtoMessage 

func (ch *CheckHash) ToProtoMessage() (proto.Message, error)

ToProtoMessage converts CheckHash to proto message.

func (*CheckHash) Unmarshal 

func (ch *CheckHash) Unmarshal(data []byte) error

Unmarshal method unmarshal binary data to CheckHash object

type FetchBlockHeaders 

type FetchBlockHeaders struct {
	// the index to indicate which hashes chunk in sync hashes
	// it is used to find out which hashes chunk needed to re-sync when
	// error happen in the sync with some remote peer
	Idx uint32
	CheckHash
}

FetchBlockHeaders includes headers sent to a sync peer to fetch blocks

func (*FetchBlockHeaders) FromProtoMessage 

func (fbh *FetchBlockHeaders) FromProtoMessage(message proto.Message) error

FromProtoMessage converts proto message to FetchBlockHeaders

func (*FetchBlockHeaders) Marshal 

func (fbh *FetchBlockHeaders) Marshal() (data []byte, err error)

Marshal method marshal FetchBlockHeaders object to binary

func (*FetchBlockHeaders) ToProtoMessage 

func (fbh *FetchBlockHeaders) ToProtoMessage() (proto.Message, error)

ToProtoMessage converts FetchBlockHeaders to proto message.

func (*FetchBlockHeaders) Unmarshal 

func (fbh *FetchBlockHeaders) Unmarshal(data []byte) error

Unmarshal method unmarshal binary data to FetchBlockHeaders object

type LocateHeaders 

type LocateHeaders struct {
	Hashes []*crypto.HashType
}

LocateHeaders includes hashes sent to a peer to locate fork point in the peer's chain

func (*LocateHeaders) FromProtoMessage 

func (lh *LocateHeaders) FromProtoMessage(message proto.Message) error

FromProtoMessage converts proto message to LocateHeaders

func (*LocateHeaders) Marshal 

func (lh *LocateHeaders) Marshal() (data []byte, err error)

Marshal method marshal LocateHeaders object to binary

func (*LocateHeaders) ToProtoMessage 

func (lh *LocateHeaders) ToProtoMessage() (proto.Message, error)

ToProtoMessage converts LocateHeaders to proto message.

func (*LocateHeaders) Unmarshal 

func (lh *LocateHeaders) Unmarshal(data []byte) error

Unmarshal method unmarshal binary data to LocateHeaders object

type SyncBlocks 

type SyncBlocks struct {
	// the index to indicate which hashes chunk in sync hashes
	// it is used to find out which hashes chunk needed to re-sync when
	// error happen in the sync with some remote peer
	Idx    uint32
	Blocks []*coreTypes.Block
}

SyncBlocks includes blocks sent from synchronized peer to local node

func (*SyncBlocks) FromProtoMessage 

func (sb *SyncBlocks) FromProtoMessage(message proto.Message) error

FromProtoMessage converts proto message to SyncBlocks

func (*SyncBlocks) Marshal 

func (sb *SyncBlocks) Marshal() (data []byte, err error)

Marshal method marshal SyncBlocks object to binary

func (*SyncBlocks) ToProtoMessage 

func (sb *SyncBlocks) ToProtoMessage() (proto.Message, error)

ToProtoMessage converts SyncBlocks to proto message.

func (*SyncBlocks) Unmarshal 

func (sb *SyncBlocks) Unmarshal(data []byte) error

Unmarshal method unmarshal binary data to SyncBlocks object

type SyncCheckHash 

type SyncCheckHash struct {
	RootHash *crypto.HashType
}

SyncCheckHash defines information about root hash for check in sync scenario. the RootHash is the hash for headers that CheckHash indicate

func (*SyncCheckHash) FromProtoMessage 

func (sch *SyncCheckHash) FromProtoMessage(message proto.Message) error

FromProtoMessage converts proto message to SyncCheckHash

func (*SyncCheckHash) Marshal 

func (sch *SyncCheckHash) Marshal() (data []byte, err error)

Marshal method marshal SyncCheckHash object to binary

func (*SyncCheckHash) ToProtoMessage 

func (sch *SyncCheckHash) ToProtoMessage() (proto.Message, error)

ToProtoMessage converts SyncCheckHash to proto message.

func (*SyncCheckHash) Unmarshal 

func (sch *SyncCheckHash) Unmarshal(data []byte) error

Unmarshal method unmarshal binary data to SyncCheckHash object

type SyncHeaders 

type SyncHeaders struct {
	LocateHeaders
}

SyncHeaders includes the hashes that local node needs to sync with the peer's chain. SyncHeaders may contain overlapped block hashes with local chain

func (*SyncHeaders) FromProtoMessage 

func (sh *SyncHeaders) FromProtoMessage(message proto.Message) error

FromProtoMessage converts proto message to SyncHeaders

func (*SyncHeaders) Marshal 

func (sh *SyncHeaders) Marshal() (data []byte, err error)

Marshal method marshal LocateHeaders object to binary

func (*SyncHeaders) ToProtoMessage 

func (sh *SyncHeaders) ToProtoMessage() (proto.Message, error)

ToProtoMessage converts SyncHeaders to proto message.

func (*SyncHeaders) Unmarshal 

func (sh *SyncHeaders) Unmarshal(data []byte) error

Unmarshal method unmarshal binary data to SyncHeaders object

type SyncManager 

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

SyncManager syncs blocks with peers

func NewSyncManager 

func NewSyncManager(blockChain *chain.BlockChain, p2pNet p2p.Net,
	consensus *dpos.Dpos, parent goprocess.Process) *SyncManager

NewSyncManager returns new block sync manager.

func (*SyncManager) ActiveLightSync 

func (sm *SyncManager) ActiveLightSync(pid peer.ID) error

ActiveLightSync active light sync from remote peer.

func (*SyncManager) Run 

func (sm *SyncManager) Run()

Run start sync task and handle sync message

func (*SyncManager) StartSync 

func (sm *SyncManager) StartSync()

StartSync start sync block message from remote peers.

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.