synchro

Documentation

Index

• Constants
• type BlockHash
• type Sync
  • func New(cBase *chainbase.ChainBase, p p2p.Service) *Sync
  • func (s *Sync) BroadcastBlock(block *block.Block)
  • func (s *Sync) BroadcastBlockInfo(block *block.Block)
  • func (s *Sync) Close()
  • func (s *Sync) IsCatchingUp() bool
  • func (s *Sync) ValidBlock() <-chan *block.Block

Constants

const (
	BlockHashLeastNeighborNumber = 1
	BlockHashExpiredSeconds      = 60
)

Constant of blockhash sync

Types

type BlockHash

type BlockHash struct {
	Hash   []byte
	Number int64
	PeerID []p2p.PeerID
}

BlockHash return the block hash with the Peers that have it.

type Sync

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

Sync is the synchronizer of blockchain. It includes requestHandler, heightSync, blockhashSync, blockSync.

func New

func New(cBase *chainbase.ChainBase, p p2p.Service) *Sync

New will return a new synchronizer of blockchain.

func (*Sync) BroadcastBlock

func (s *Sync) BroadcastBlock(block *block.Block)

BroadcastBlock will broadcast new block to neighbor nodes.

func (*Sync) BroadcastBlockInfo

func (s *Sync) BroadcastBlockInfo(block *block.Block)

BroadcastBlockInfo will broadcast new block information to neighbor nodes.

func (*Sync) Close

func (s *Sync) Close()

Close will close the synchronizer of blockchain.

func (*Sync) IsCatchingUp

func (s *Sync) IsCatchingUp() bool

IsCatchingUp will return whether it is catching up with other nodes.

func (*Sync) ValidBlock

func (s *Sync) ValidBlock() <-chan *block.Block

ValidBlock will return the valid blocks from other nodes. Including passive request and active broadcast.