finishsync

Documentation

Index

• Variables
• func NewDefaultFinishSyncMsgPool()
• type FinishSyncLogger
  • func (self *FinishSyncLogger) Init(inst common.Logger)
• type FinishSyncMsgPool
  • func NewFinishSyncMsgPool() FinishSyncMsgPool
  • func NewFinishSyncMsgPoolWithValue(validators map[byte]map[string]bool) FinishSyncMsgPool
  • func (f *FinishSyncMsgPool) AddFinishedSyncValidators(newFinishedSyncValidators []string, syncPool []string, shardID byte, ...)
  • func (f *FinishSyncMsgPool) Clean(allSyncPoolValidators map[byte][]string)
  • func (f *FinishSyncMsgPool) Clone() FinishSyncMsgPool
  • func (f *FinishSyncMsgPool) GetFinishedSyncValidators() map[byte][]string
  • func (f *FinishSyncMsgPool) Instructions(allSyncPool map[byte][]string, currentBeaconHeight uint64) []*instruction.FinishSyncInstruction
  • func (f *FinishSyncMsgPool) RemoveValidators(validators []string, shardID byte)
  • func (f *FinishSyncMsgPool) Validators(shardID byte) []string

Variables

var Logger = FinishSyncLogger{}

Global instant to use

Functions

func NewDefaultFinishSyncMsgPool

func NewDefaultFinishSyncMsgPool()

Types

type FinishSyncLogger

type FinishSyncLogger struct {
	common.Logger
}

func (*FinishSyncLogger) Init

func (self *FinishSyncLogger) Init(inst common.Logger)

type FinishSyncMsgPool

type FinishSyncMsgPool struct {
	FinishedSyncValidators map[byte]map[string]bool `json:"FinishedSyncValidators"`
	ReceiveTime            map[string]uint64        //beacon block height that receive the msg
	// contains filtered or unexported fields
}

FinishSyncMsgPool manages FinishedSyncValidators in sync pool of attached view FinishedSyncValidators must only compatible with sync pool. It must only contain keys that also in sync pool FinishSyncMsgPool could maintain different data in different beacon nodes

var (
	DefaultFinishSyncMsgPool *FinishSyncMsgPool
)

func NewFinishSyncMsgPool

func NewFinishSyncMsgPool() FinishSyncMsgPool

func NewFinishSyncMsgPoolWithValue

func NewFinishSyncMsgPoolWithValue(validators map[byte]map[string]bool) FinishSyncMsgPool

func (*FinishSyncMsgPool) AddFinishedSyncValidators

func (f *FinishSyncMsgPool) AddFinishedSyncValidators(
	newFinishedSyncValidators []string,
	syncPool []string,
	shardID byte,
	beaconHeight uint64,
)

AddFinishedSyncValidators only add FinishedSyncValidators in sync pool of attached view and NOT duplicate in FinishSyncMsgPool.validator list

func (*FinishSyncMsgPool) Clean

func (f *FinishSyncMsgPool) Clean(allSyncPoolValidators map[byte][]string)

func (*FinishSyncMsgPool) Clone

func (f *FinishSyncMsgPool) Clone() FinishSyncMsgPool

func (*FinishSyncMsgPool) GetFinishedSyncValidators

func (f *FinishSyncMsgPool) GetFinishedSyncValidators() map[byte][]string

func (*FinishSyncMsgPool) Instructions

func (f *FinishSyncMsgPool) Instructions(allSyncPool map[byte][]string, currentBeaconHeight uint64) []*instruction.FinishSyncInstruction

Instructions ....

func (*FinishSyncMsgPool) RemoveValidators

func (f *FinishSyncMsgPool) RemoveValidators(validators []string, shardID byte)

RemoveValidators only remove FinishSyncMsgPool.validator list ONCE ignore FinishedSyncValidators not in FinishSyncMsgPool.FinishedSyncValidators list

func (*FinishSyncMsgPool) Validators

func (f *FinishSyncMsgPool) Validators(shardID byte) []string