reconfig

Documentation

Overview

Package reconfig implements Cypherium reconfiguration.

Package reconfig implements Cypherium reconfiguration.

Index

• Constants
• type Backend
• type Reconfig
  • func NewReconfig(db cphdb.Database, cph Backend, config *params.ChainConfig, mux *event.TypeMux, ...) *Reconfig
  • func (reconf *Reconfig) CheckMinerPort(addr string, blockN uint64, keyblockN uint64)
  • func (reconf *Reconfig) Exceptions(blockNumber int64) []string
  • func (reconf *Reconfig) ReconfigIsRunning() bool
  • func (reconf *Reconfig) Start(config *common.NodeConfig)
  • func (reconf *Reconfig) Stop()
  • func (reconf *Reconfig) TakePartInNumberList(address common.Address, backCheckNumber int64) []string
• type Service
  • func (s *Service) Broadcast(data *hotstuff.HotstuffMessage) []error
  • func (s *Service) CheckView(data []byte) error
  • func (s *Service) Committee_OnStored(keyblock *types.KeyBlock, mb *bftview.Committee)
  • func (s *Service) Committee_Request(kNumber uint64, hash common.Hash)
  • func (s *Service) CurrentState() ([]byte, string, uint64)
  • func (s *Service) Exceptions(blockNumber int64) []string
  • func (s *Service) GetCurrentView() *bftview.View
  • func (s *Service) GetExtra() []byte
  • func (s *Service) GetPublicKey() []*bls.PublicKey
  • func (s *Service) LeaderAckTime() time.Time
  • func (s *Service) OnNewView(data []byte, extraes [][]byte) error
  • func (s *Service) OnPropose(isKeyBlock bool, state []byte, extra []byte) error
  • func (s *Service) OnViewDone(kSign *hotstuff.SignedState, tSign *hotstuff.SignedState) error
  • func (s *Service) Propose() (e error, kState []byte, tState []byte, extra []byte)
  • func (s *Service) ResetLeaderAckTime()
  • func (s *Service) Self() string
  • func (s *Service) SwitchOK() bool
  • func (s *Service) TakePartInNumberList(address common.Address, checkKeyNumber int64) []string
  • func (s *Service) Write(id string, data *hotstuff.HotstuffMessage) error

Constants

const Gossip_MSG = 8

Types

type Backend

type Backend interface {
	BlockChain() *core.BlockChain
	KeyBlockChain() *core.KeyBlockChain
	CandidatePool() *core.CandidatePool
	Engine() pow.Engine
	ExtIP() net.IP
	TxPool() *core.TxPool
}

Backend wraps all methods required for mining.

type Reconfig

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

Reconfig reconfiguration.

func NewReconfig

func NewReconfig(db cphdb.Database, cph Backend, config *params.ChainConfig, mux *event.TypeMux, engine pow.Engine, extIP net.IP) *Reconfig

NewReconfig call by backend

func (*Reconfig) CheckMinerPort

func (reconf *Reconfig) CheckMinerPort(addr string, blockN uint64, keyblockN uint64)

func (*Reconfig) Exceptions

func (reconf *Reconfig) Exceptions(blockNumber int64) []string

func (*Reconfig) ReconfigIsRunning

func (reconf *Reconfig) ReconfigIsRunning() bool

ReconfigIsRunning call by backend

func (*Reconfig) Start

func (reconf *Reconfig) Start(config *common.NodeConfig)

Start call by miner

func (*Reconfig) Stop

func (reconf *Reconfig) Stop()

Stop call by miner

func (*Reconfig) TakePartInNumberList

func (reconf *Reconfig) TakePartInNumberList(address common.Address, backCheckNumber int64) []string

type Service

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

Service work for protcol

func (*Service) Broadcast

func (s *Service) Broadcast(data *hotstuff.HotstuffMessage) []error

Broadcast call by hotstuff

func (*Service) CheckView

func (s *Service) CheckView(data []byte) error

CheckView call by hotstuff

func (*Service) Committee_OnStored

func (s *Service) Committee_OnStored(keyblock *types.KeyBlock, mb *bftview.Committee)

func (*Service) Committee_Request

func (s *Service) Committee_Request(kNumber uint64, hash common.Hash)

Request committee for keyblock

func (*Service) CurrentState

func (s *Service) CurrentState() ([]byte, string, uint64)

CurrentState call by hotstuff

func (*Service) Exceptions

func (s *Service) Exceptions(blockNumber int64) []string

func (*Service) GetCurrentView

func (s *Service) GetCurrentView() *bftview.View

func (*Service) GetExtra

func (s *Service) GetExtra() []byte

GetExtra call by hotstuff

func (*Service) GetPublicKey

func (s *Service) GetPublicKey() []*bls.PublicKey

GetPublicKey call by hotstuff

func (*Service) LeaderAckTime

func (s *Service) LeaderAckTime() time.Time

func (*Service) OnNewView

func (s *Service) OnNewView(data []byte, extraes [][]byte) error

OnNewView --------------------------------------------------------------------------

func (*Service) OnPropose

func (s *Service) OnPropose(isKeyBlock bool, state []byte, extra []byte) error

OnPropose call by hotstuff

func (*Service) OnViewDone

func (s *Service) OnViewDone(kSign *hotstuff.SignedState, tSign *hotstuff.SignedState) error

OnViewDone call by hotstuff

func (*Service) Propose

func (s *Service) Propose() (e error, kState []byte, tState []byte, extra []byte)

Propose call by hotstuff

func (*Service) ResetLeaderAckTime

func (s *Service) ResetLeaderAckTime()

func (*Service) Self

func (s *Service) Self() string

Self call by hotstuff

func (*Service) SwitchOK

func (s *Service) SwitchOK() bool

func (*Service) TakePartInNumberList

func (s *Service) TakePartInNumberList(address common.Address, checkKeyNumber int64) []string

func (*Service) Write

func (s *Service) Write(id string, data *hotstuff.HotstuffMessage) error

Write call by hotstuff------------------------------------------------------------------------------------------------