consensus

package
v1.10.3 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2024 License: LGPL-3.0 Imports: 55 Imported by: 0

README

Consensus package includes the Intelchain BFT consensus protocol code, which uses BLS-based multi-signature to cosign the new block. The details are in Intelchain's new consensus protocol design.

Introduction to Intelchain BFT with BLS signatures

Intelchain BFT consensus protocol consist of normal mode and view changing mode which is same as the PBFT(practical byzantine fault tolerance) protocol. The difference is we use the BLS aggregated signature to reduce O(N^2) communications to O(N), which is more efficient and scalable to traditional PBFT. For brevity, we will still call the whole process as PBFT.

Normal mode

To reach the consensus of the next block, there are 3 phases: announce(i.e. pre-prepare in PBFT), prepare and commit.

  • Announce(leader): The leader broadcasts ANNOUNCE message along with candidate of the next block.
  • Prepare(validator): The validator will validate the block sent by leader and send PREPARE message; if the block is invalid, the validator will propose view change. If the prepare timeout, the validator will also propose view change.
  • Prepared(leader): The leader will collect 2f+1 PREPARE message including itself and broadcast PREPARED message with the aggregated signature
  • Commit(validator): The validator will check the validity of aggregated signature (# of signatures >= 2f+1) and send COMMIT message; if the commit timeout, the validator will also propose view change.
  • Committed(leader): The leader will collect 2f+1 COMMIT message including itself and broadcast COMMITTED message with the aggregated signature
  • Finalize(leader and validators): Both the leader and validators will finalize the block into blockchain together with 2f+1 aggregated signatures.

View changing mode

  • ViewChange(validator): whenever a validator receives invalid block/signature from the leader, it should send VIEWCHANGE message with view v+1 together with its own prepared message(>=2f+1 aggregated prepare signatures) from previous views.
  • NewView(new leader): when the new leader (uniquely determined) collect enough (2f+1) view change messages, it broadcasts the NEWVIEW message with aggregated VIEWCHANGE signatures.
  • During the view changing process, if the new leader not send NEWVIEW message on time, the validator will propose ViewChange for the next view v+2 and so on...

State Machine

The whole process of PBFT can be described as a state machine. We don't separate the roles of leader and validators, instead we use PBFTState structure to describe the role and phase of a given node who is joining the consensus process. When a node receives a new message from its peer, its state will be updated. i.e. pbft_state --(upon receive new PBFTMessage)--> new_pbft_state. Thus the most nature and clear way is to describe the whole process as state machine.

// PBFTState holds the state of a node in PBFT process
type PBFTState struct {
   IsLeader bool
   phase PBFTPhase // Announce, Prepare(d), Commit(ted)
   ...

}

// PBFTLog stores the data in PBFT process, it will be used in different phases in order to determine whether a new PBFTMessage is valid or not.
type PBFTLog struct {
    blocks []*types.Block
    messages []*PBFTMessage
}

// entry point and main loop;
// in each loop, the node will receive PBFT message from peers with timeout,
// then update its state accordingly. handleMessageUpdate function handles various kinds of messages and update its state
// it will also send new PBFT message (if not null) to its peers.
// in the same loop, the node will also check whether it should send view changing message to new leader
// finally, it will periodically try to publish new block into blockchain
func (consensus *Consensus) Start(stopChan chan struct{}, stoppedChan chan struct{}) {
    defer close(stoppedChan)
    tick := time.NewTicker(blockDuration)
    consensus.idleTimeout.Start()
    for {
        select {
        default:
            msg := consensus.recvWithTimeout(receiveTimeout)
            consensus.handleMessageUpdate(msg)
            if consensus.idleTimeout.CheckExpire() {
                consensus.startViewChange(consensus.viewID + 1)
            }
            if consensus.commitTimeout.CheckExpire() {
                consensus.startViewChange(consensus.viewID + 1)
            }
            if consensus.viewChangeTimeout.CheckExpire() {
                if consensus.mode.Mode() == Normal {
                    continue
                }
                viewID := consensus.mode.ViewID()
                consensus.startViewChange(viewID + 1)
            }
        case <-tick.C:
            consensus.tryPublishBlock()
        case <-stopChan:
            return
        }
    }

}

Documentation

Index

Constants

View Source 
const (
	IncomingReceiptsLimit = 6000 // 2000 * (numShards - 1)
	SleepPeriod           = 20 * time.Millisecond
)

Constants of proposing a new block

View Source 
const (
	// CommitSigSenderTimeout is the timeout for sending the commit sig to finish block proposal
	CommitSigSenderTimeout = 10 * time.Second
)

timeout constant

View Source 
const MaxBlockNumDiff = 100

MaxBlockNumDiff limits the received block number to only 100 further from the current block number

View Source 
const MaxViewIDDiff = 249

MaxViewIDDiff limits the received view ID to only 249 further from the current view ID

View Source 
const (
	// RetryIntervalInSec is the interval for message retry
	RetryIntervalInSec = 7
)
View Source 
const (
	// ValidPayloadLength is the valid length for viewchange payload
	ValidPayloadLength = 32 + bls.BLSSignatureSizeInBytes
)

Variables

View Source 
var (
	// NIL is the m2 type message, which suppose to be nil/empty, however
	// we cannot sign on empty message, instead we sign on some default "nil" message
	// to indicate there is no prepared message received when we start view change
	NIL = []byte{0x01}
)

Functions

func BroadcastCXReceipts added in v1.10.3 

func BroadcastCXReceipts(newBlock *types.Block, consensus *Consensus)

BroadcastCXReceipts broadcasts cross shard receipts to correspoding destination shards

func BroadcastCXReceiptsWithShardID added in v1.10.3 

func BroadcastCXReceiptsWithShardID(block *block.Header, commitSig []byte, commitBitmap []byte, toShardID uint32, consensus *Consensus)

BroadcastCXReceiptsWithShardID broadcasts cross shard receipts to given ToShardID

func BroadcastMissingCXReceipts added in v1.10.3 

func BroadcastMissingCXReceipts(c *Consensus)

BroadcastMissingCXReceipts broadcasts missing cross shard receipts per request

func BroadcastNewBlock added in v1.10.3 

func BroadcastNewBlock(host p2p.Host, newBlock *types.Block, nodeConfig *nodeconfig.ConfigType)

BroadcastNewBlock is called by consensus leader to sync new blocks with other clients/nodes. NOTE: For now, just send to the client (basically not broadcasting) TODO (lc): broadcast the new blocks to new nodes doing state sync

func IsRunningBeaconChain added in v1.10.3 

func IsRunningBeaconChain(c *Consensus) bool

Types

type Consensus 

type Consensus struct {

	// Minimal number of peers in the shard
	// If the number of validators is less than minPeers, the consensus won't start
	MinPeers int

	// Shard Id which this node belongs to
	ShardID uint32
	// IgnoreViewIDCheck determines whether to ignore viewID check
	IgnoreViewIDCheck *abool.AtomicBool

	// verified block to state sync broadcast
	VerifiedNewBlock chan *types.Block
	// Channel for DRG protocol to send pRnd (preimage of randomness resulting from combined vrf
	// randomnesses) to consensus. The first 32 bytes are randomness, the rest is for bitmap.
	PRndChannel chan []byte
	// Channel for DRG protocol to send VDF. The first 516 bytes are the VDF/Proof and the last 32
	// bytes are the seed for deriving VDF
	RndChannel chan [vdfAndSeedSize]byte

	// Have a dedicated reader thread pull from this chan, like in node
	SlashChan chan slash.Record
	// How long in second the leader needs to wait to propose a new block.
	BlockPeriod time.Duration
	// The time due for next block proposal
	NextBlockDue time.Time
	// Temporary flag to control whether aggregate signature signing is enabled
	AggregateSig bool
	// contains filtered or unexported fields
}

Consensus is the main struct with all states and data related to consensus process.

func New 

func New(
	host p2p.Host, shard uint32, multiBLSPriKey multibls.PrivateKeys,
	registry *registry.Registry,
	Decider quorum.Decider, minPeers int, aggregateSig bool,
) (*Consensus, error)

New create a new Consensus record

func (*Consensus) AddConsensusLastMile 

func (consensus *Consensus) AddConsensusLastMile() error

func (*Consensus) AddPendingReceipts added in v1.10.3 

func (consensus *Consensus) AddPendingReceipts(receipts *types.CXReceiptsProof)

func (*Consensus) AddPubkeyMetrics 

func (consensus *Consensus) AddPubkeyMetrics()

AddPubkeyMetrics add the list of blskeys to prometheus metrics

func (*Consensus) Beaconchain 

func (consensus *Consensus) Beaconchain() core.BlockChain

Beaconchain returns the beaconchain.

func (*Consensus) BlockChannel 

func (consensus *Consensus) BlockChannel(newBlock *types.Block)

func (*Consensus) BlockCommitSigs 

func (consensus *Consensus) BlockCommitSigs(blockNum uint64) ([]byte, error)

BlockCommitSigs returns the byte array of aggregated commit signature and bitmap signed on the block

func (*Consensus) BlockNum 

func (consensus *Consensus) BlockNum() uint64

func (*Consensus) BlockVerifier 

func (consensus *Consensus) BlockVerifier(newBlock *types.Block) error

BlockVerifier is called by consensus participants to verify the block (account model) they are running consensus on.

func (*Consensus) Blockchain 

func (consensus *Consensus) Blockchain() core.BlockChain

Blockchain returns the blockchain.

func (*Consensus) BlocksNotSynchronized 

func (consensus *Consensus) BlocksNotSynchronized(reason string)

BlocksNotSynchronized lets the main loop know that block is not synchronized

func (*Consensus) BlocksSynchronized 

func (consensus *Consensus) BlocksSynchronized()

BlocksSynchronized lets the main loop know that block synchronization finished thus the blockchain is likely to be up to date.

func (*Consensus) ChainReader 

func (consensus *Consensus) ChainReader() engine.ChainReader

ChainReader returns the chain reader. This is mostly the same as Blockchain, but it returns only read methods, so we assume it's safe for concurrent use.

func (*Consensus) Decider 

func (consensus *Consensus) Decider() quorum.Decider

func (*Consensus) DeleteBlocksLessThan 

func (consensus *Consensus) DeleteBlocksLessThan(number uint64)

DeleteBlocksLessThan deletes blocks less than given block number

func (*Consensus) DeleteMessagesLessThan 

func (consensus *Consensus) DeleteMessagesLessThan(number uint64)

DeleteMessagesLessThan deletes messages less than given block number.

func (*Consensus) FBFTLog 

func (consensus *Consensus) FBFTLog() FBFT

func (*Consensus) FinishFinalityCount 

func (consensus *Consensus) FinishFinalityCount()

FinishFinalityCount calculate the current finality

func (*Consensus) GenerateVdfAndProof 

func (consensus *Consensus) GenerateVdfAndProof(newBlock *types.Block, vrfBlockNumbers []uint64)

GenerateVdfAndProof generates new VDF/Proof from VRFs in the current epoch

func (*Consensus) GenerateVrfAndProof 

func (consensus *Consensus) GenerateVrfAndProof(newHeader *block.Header) error

GenerateVrfAndProof generates new VRF/Proof from hash of previous block

func (*Consensus) GetCommitSigChannel 

func (consensus *Consensus) GetCommitSigChannel() chan []byte

func (*Consensus) GetConsensusMode 

func (consensus *Consensus) GetConsensusMode() string

GetConsensusMode returns the current mode of the consensus

func (*Consensus) GetConsensusPhase 

func (consensus *Consensus) GetConsensusPhase() string

GetConsensusPhase returns the current phase of the consensus.

func (*Consensus) GetCurBlockViewID 

func (consensus *Consensus) GetCurBlockViewID() uint64

GetCurBlockViewID returns the current view ID of the consensus Method is thread safe.

func (*Consensus) GetFinality 

func (consensus *Consensus) GetFinality() int64

GetFinality returns the finality time in milliseconds of previous consensus

func (*Consensus) GetHost 

func (consensus *Consensus) GetHost() p2p.Host

func (*Consensus) GetLastMileBlockIter 

func (consensus *Consensus) GetLastMileBlockIter(bnStart uint64, cb func(iter *LastMileBlockIter) error) error

GetLastMileBlockIter get the iterator of the last mile blocks starting from number bnStart

func (*Consensus) GetLeaderPubKey 

func (consensus *Consensus) GetLeaderPubKey() *bls_cosi.PublicKeyWrapper

func (*Consensus) GetLogger 

func (consensus *Consensus) GetLogger() *zerolog.Logger

GetLogger returns logger for consensus contexts added.

func (*Consensus) GetNextRnd 

func (consensus *Consensus) GetNextRnd() ([vdFAndProofSize]byte, [32]byte, error)

GetNextRnd returns the oldest available randomness along with the hash of the block there randomness preimage is committed.

func (*Consensus) GetPrivateKeys 

func (consensus *Consensus) GetPrivateKeys() multibls.PrivateKeys

func (*Consensus) GetPublicKeys 

func (consensus *Consensus) GetPublicKeys() multibls.PublicKeys

GetPublicKeys returns the public keys

func (*Consensus) GetReadySignal 

func (consensus *Consensus) GetReadySignal() chan Proposal

func (*Consensus) GetViewChangingID 

func (consensus *Consensus) GetViewChangingID() uint64

GetViewChangingID returns the current view changing ID of the consensus. Method is thread safe.

func (*Consensus) HandleMessageUpdate 

func (consensus *Consensus) HandleMessageUpdate(ctx context.Context, peer libp2p_peer.ID, msg *msg_pb.Message, senderKey *bls.SerializedPublicKey) error

HandleMessageUpdate will update the consensus state according to received message

func (*Consensus) InitConsensusWithValidators 

func (consensus *Consensus) InitConsensusWithValidators() (err error)

InitConsensusWithValidators initialize shard state from latest epoch and update committee pub keys for consensus

func (*Consensus) IsBackup 

func (consensus *Consensus) IsBackup() bool

func (*Consensus) IsLeader 

func (consensus *Consensus) IsLeader() bool

IsLeader check if the node is a leader or not by comparing the public key of the node with the leader public key Method is thread safe

func (*Consensus) IsValidatorInCommittee 

func (consensus *Consensus) IsValidatorInCommittee(pubKey bls.SerializedPublicKey) bool

IsValidatorInCommittee returns whether the given validator BLS address is part of my committee

func (*Consensus) IsViewChangingMode 

func (consensus *Consensus) IsViewChangingMode() bool

IsViewChangingMode return true if current mode is viewchanging. Method is thread safe.

func (*Consensus) Mode 

func (consensus *Consensus) Mode() Mode

Mode returns the mode of consensus Method is thread safe.

func (*Consensus) NumSignaturesIncludedInBlock 

func (consensus *Consensus) NumSignaturesIncludedInBlock(block *types.Block) uint32

NumSignaturesIncludedInBlock returns the number of signatures included in the block Method is thread safe.

func (*Consensus) ParseFBFTMessage 

func (consensus *Consensus) ParseFBFTMessage(msg *msg_pb.Message) (*FBFTMessage, error)

ParseFBFTMessage parses FBFT message into FBFTMessage structure

func (*Consensus) PendingCXReceipts added in v1.10.3 

func (consensus *Consensus) PendingCXReceipts() []*types.CXReceiptsProof

PendingCXReceipts returns node.pendingCXReceiptsProof

func (*Consensus) PostConsensusProcessing added in v1.10.3 

func (consensus *Consensus) PostConsensusProcessing(newBlock *types.Block) error

PostConsensusProcessing is called by consensus participants, after consensus is done, to: 1. [leader] send new block to the client 2. [leader] send cross shard tx receipts to destination shard

func (*Consensus) ProposeNewBlock added in v1.10.3 

func (consensus *Consensus) ProposeNewBlock(commitSigs chan []byte) (*types.Block, error)

ProposeNewBlock proposes a new block...

func (*Consensus) ReadSignatureBitmapPayload 

func (consensus *Consensus) ReadSignatureBitmapPayload(recvPayload []byte, offset int) (*bls_core.Sign, *bls_cosi.Mask, error)

ReadSignatureBitmapPayload read the payload for signature and bitmap; offset is the beginning position of reading

func (*Consensus) ReadySignal 

func (consensus *Consensus) ReadySignal(p Proposal)

func (*Consensus) RegisterPRndChannel 

func (consensus *Consensus) RegisterPRndChannel(pRndChannel chan []byte)

RegisterPRndChannel registers the channel for receiving randomness preimage from DRG protocol

func (*Consensus) RegisterRndChannel 

func (consensus *Consensus) RegisterRndChannel(rndChannel chan [548]byte)

RegisterRndChannel registers the channel for receiving final randomness from DRG protocol

func (*Consensus) Registry 

func (consensus *Consensus) Registry() *registry.Registry

func (*Consensus) ResetViewChangeState 

func (consensus *Consensus) ResetViewChangeState()

ResetViewChangeState resets the view change structure

func (*Consensus) SetBlockNum 

func (consensus *Consensus) SetBlockNum(blockNum uint64)

SetBlockNum sets the blockNum in consensus object, called at node bootstrap

func (*Consensus) SetCurBlockViewID 

func (consensus *Consensus) SetCurBlockViewID(viewID uint64) uint64

SetCurBlockViewID set the current view ID

func (*Consensus) SetDownloader 

func (consensus *Consensus) SetDownloader(d downloader)

Set downloader set the downloader of the shard to consensus TODO: It will be better to move this to consensus.New and register consensus as a service

func (*Consensus) SetIsBackup 

func (consensus *Consensus) SetIsBackup(isBackup bool)

SetIsBackup sets the mode of consensus

func (*Consensus) SetLeaderPubKey 

func (consensus *Consensus) SetLeaderPubKey(pub *bls_cosi.PublicKeyWrapper)

func (*Consensus) SetMode 

func (consensus *Consensus) SetMode(m Mode)

SetMode sets the mode of consensus

func (*Consensus) SetViewChangingID 

func (consensus *Consensus) SetViewChangingID(viewID uint64)

SetViewChangingID set the current view change ID

func (*Consensus) SetViewIDs 

func (consensus *Consensus) SetViewIDs(height uint64)

SetViewIDs set both current view ID and view changing ID to the height of the blockchain. It is used during client startup to recover the state

func (*Consensus) Start 

func (consensus *Consensus) Start(
	stopChan chan struct{},
)

Start waits for the next new block and run consensus

func (*Consensus) StartChannel 

func (consensus *Consensus) StartChannel()

func (*Consensus) StartFinalityCount 

func (consensus *Consensus) StartFinalityCount()

StartFinalityCount set the finality counter to current time

func (*Consensus) Tick 

func (consensus *Consensus) Tick()

func (*Consensus) UpdateConsensusInformation 

func (consensus *Consensus) UpdateConsensusInformation() Mode

UpdateConsensusInformation will update shard information (epoch, publicKeys, blockNum, viewID) based on the local blockchain. It is called in two cases for now: 1. consensus object initialization. because of current dependency where chainreader is only available after node is initialized; node is only available after consensus is initialized we need call this function separately after create consensus object 2. after state syncing is finished It will return the mode: (a) node not in committed: Listening mode (b) node in committed but has any err during processing: Syncing mode (c) node in committed and everything looks good: Normal mode

func (*Consensus) UpdateLeaderMetrics 

func (consensus *Consensus) UpdateLeaderMetrics(numCommits float64, blockNum float64)

UpdateLeaderMetrics will udpate leader metrics

func (*Consensus) UpdatePreimageGenerationMetrics 

func (consensus *Consensus) UpdatePreimageGenerationMetrics(
	preimageStart uint64,
	preimageEnd uint64,
	lastPreimageImport uint64,
	verifiedAddresses uint64,
	shard uint32,
)

func (*Consensus) UpdatePublicKeys 

func (consensus *Consensus) UpdatePublicKeys(pubKeys, allowlist []bls_cosi.PublicKeyWrapper) int64

UpdatePublicKeys updates the PublicKeys for quorum on current subcommittee, protected by a mutex

func (*Consensus) UpdateValidatorMetrics 

func (consensus *Consensus) UpdateValidatorMetrics(numSig float64, blockNum float64)

UpdateValidatorMetrics will udpate validator metrics

func (*Consensus) ValidateNewBlock 

func (consensus *Consensus) ValidateNewBlock(recvMsg *FBFTMessage) (*types.Block, error)

func (*Consensus) ValidateVdfAndProof 

func (consensus *Consensus) ValidateVdfAndProof(headerObj *block.Header) bool

ValidateVdfAndProof validates the VDF/proof in the current epoch

func (*Consensus) VdfSeedSize 

func (consensus *Consensus) VdfSeedSize() int

VdfSeedSize returns the number of VRFs for VDF computation

func (*Consensus) WaitForConsensusReadyV2 added in v1.10.3 

func (consensus *Consensus) WaitForConsensusReadyV2(stopChan chan struct{}, stoppedChan chan struct{})

WaitForConsensusReadyV2 listen for the readiness signal from consensus and generate new block for consensus. only leader will receive the ready signal

func (*Consensus) WaitForNewRandomness 

func (consensus *Consensus) WaitForNewRandomness()

WaitForNewRandomness listens to the RndChannel to receive new VDF randomness.

type DownloadAsync 

type DownloadAsync interface {
	DownloadAsync()
}

type FBFT 

type FBFT interface {
	GetMessagesByTypeSeq(typ msg_pb.MessageType, blockNum uint64) []*FBFTMessage
	IsBlockVerified(hash common.Hash) bool
	DeleteBlockByNumber(number uint64)
	GetBlockByHash(hash common.Hash) *types.Block
	AddVerifiedMessage(msg *FBFTMessage)
	AddBlock(block *types.Block)
	GetMessagesByTypeSeqHash(typ msg_pb.MessageType, blockNum uint64, blockHash common.Hash) []*FBFTMessage
}

type FBFTLog 

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

FBFTLog represents the log stored by a node during FBFT process

func NewFBFTLog 

func NewFBFTLog() *FBFTLog

NewFBFTLog returns new instance of FBFTLog

func (*FBFTLog) AddBlock 

func (log *FBFTLog) AddBlock(block *types.Block)

AddBlock add a new block into the log

func (*FBFTLog) AddNotVerifiedMessage 

func (log *FBFTLog) AddNotVerifiedMessage(msg *FBFTMessage)

AddNotVerifiedMessage adds a not signature verified pbft message into the log

func (*FBFTLog) AddVerifiedMessage 

func (log *FBFTLog) AddVerifiedMessage(msg *FBFTMessage)

AddVerifiedMessage adds a signature verified pbft message into the log

func (*FBFTLog) DeleteBlockByNumber 

func (log *FBFTLog) DeleteBlockByNumber(number uint64)

DeleteBlockByNumber deletes block of specific number

func (*FBFTLog) FindMessageByMaxViewID 

func (log *FBFTLog) FindMessageByMaxViewID(msgs []*FBFTMessage) *FBFTMessage

FindMessageByMaxViewID returns the message that has maximum ViewID

func (*FBFTLog) GetBlockByHash 

func (log *FBFTLog) GetBlockByHash(hash common.Hash) *types.Block

GetBlockByHash returns the block matches the given block hash

func (*FBFTLog) GetBlocksByNumber 

func (log *FBFTLog) GetBlocksByNumber(number uint64) []*types.Block

GetBlocksByNumber returns the blocks match the given block number

func (*FBFTLog) GetCommittedBlockAndMsgsFromNumber 

func (log *FBFTLog) GetCommittedBlockAndMsgsFromNumber(bn uint64, logger *zerolog.Logger) (*types.Block, *FBFTMessage, error)

GetCommittedBlockAndMsgsFromNumber get committed block and message starting from block number bn.

func (*FBFTLog) GetMessagesByTypeSeq 

func (log *FBFTLog) GetMessagesByTypeSeq(typ msg_pb.MessageType, blockNum uint64) []*FBFTMessage

GetMessagesByTypeSeq returns pbft messages with matching type, blockNum

func (*FBFTLog) GetMessagesByTypeSeqHash 

func (log *FBFTLog) GetMessagesByTypeSeqHash(typ msg_pb.MessageType, blockNum uint64, blockHash common.Hash) []*FBFTMessage

GetMessagesByTypeSeqHash returns pbft messages with matching type, blockNum

func (*FBFTLog) GetMessagesByTypeSeqView 

func (log *FBFTLog) GetMessagesByTypeSeqView(typ msg_pb.MessageType, blockNum uint64, viewID uint64) []*FBFTMessage

GetMessagesByTypeSeqView returns pbft messages with matching type, blockNum and viewID

func (*FBFTLog) GetMessagesByTypeSeqViewHash 

func (log *FBFTLog) GetMessagesByTypeSeqViewHash(typ msg_pb.MessageType, blockNum uint64, viewID uint64, blockHash common.Hash) []*FBFTMessage

GetMessagesByTypeSeqViewHash returns pbft messages with matching type, blockNum, viewID and blockHash

func (*FBFTLog) GetNotVerifiedCommittedMessages 

func (log *FBFTLog) GetNotVerifiedCommittedMessages(blockNum uint64, viewID uint64, blockHash common.Hash) []*FBFTMessage

GetNotVerifiedCommittedMessages returns not verified committed pbft messages with matching blockNum, viewID and blockHash

func (*FBFTLog) HasMatchingAnnounce 

func (log *FBFTLog) HasMatchingAnnounce(blockNum uint64, blockHash common.Hash) bool

HasMatchingAnnounce returns whether the log contains announce type message with given blockNum, blockHash

func (*FBFTLog) HasMatchingPrepared 

func (log *FBFTLog) HasMatchingPrepared(blockNum uint64, blockHash common.Hash) bool

HasMatchingPrepared returns whether the log contains prepared message with given blockNum, viewID and blockHash

func (*FBFTLog) HasMatchingViewAnnounce 

func (log *FBFTLog) HasMatchingViewAnnounce(blockNum uint64, viewID uint64, blockHash common.Hash) bool

HasMatchingViewAnnounce returns whether the log contains announce type message with given blockNum, viewID and blockHash

func (*FBFTLog) HasMatchingViewPrepared 

func (log *FBFTLog) HasMatchingViewPrepared(blockNum uint64, viewID uint64, blockHash common.Hash) bool

HasMatchingViewPrepared returns whether the log contains prepared message with given blockNum, viewID and blockHash

func (*FBFTLog) IsBlockVerified 

func (log *FBFTLog) IsBlockVerified(hash common.Hash) bool

IsBlockVerified checks whether the block is verified

func (*FBFTLog) MarkBlockVerified 

func (log *FBFTLog) MarkBlockVerified(block *types.Block)

MarkBlockVerified marks the block as verified

func (*FBFTLog) PruneCacheBeforeBlock 

func (log *FBFTLog) PruneCacheBeforeBlock(bn uint64)

PruneCacheBeforeBlock prune all blocks before bn

type FBFTMessage 

type FBFTMessage struct {
	MessageType        msg_pb.MessageType
	ViewID             uint64
	BlockNum           uint64
	BlockHash          common.Hash
	Block              []byte
	SenderPubkeys      []*bls.PublicKeyWrapper
	SenderPubkeyBitmap []byte
	LeaderPubkey       *bls.PublicKeyWrapper
	Payload            []byte
	ViewchangeSig      *bls_core.Sign
	ViewidSig          *bls_core.Sign
	M2AggSig           *bls_core.Sign
	M2Bitmap           *bls_cosi.Mask
	M3AggSig           *bls_core.Sign
	M3Bitmap           *bls_cosi.Mask
	Verified           bool
}

FBFTMessage is the record of pbft messages received by a node during FBFT process

func ParseNewViewMessage 

func ParseNewViewMessage(msg *msg_pb.Message, members multibls.PublicKeys) (*FBFTMessage, error)

ParseNewViewMessage parses new view message into FBFTMessage structure

func ParseViewChangeMessage 

func ParseViewChangeMessage(msg *msg_pb.Message) (*FBFTMessage, error)

ParseViewChangeMessage parses view change message into FBFTMessage structure

func (*FBFTMessage) HasSingleSender 

func (m *FBFTMessage) HasSingleSender() bool

HasSingleSender returns whether the message has only a single sender

func (*FBFTMessage) Hash 

func (m *FBFTMessage) Hash() []byte

func (*FBFTMessage) String 

func (m *FBFTMessage) String() string

String ..

type FBFTPhase 

type FBFTPhase byte

FBFTPhase : different phases of consensus 

const (
	FBFTAnnounce FBFTPhase = iota
	FBFTPrepare
	FBFTCommit
)

Enum for FBFTPhase

func (FBFTPhase) String 

func (p FBFTPhase) String() string

type LastMileBlockIter 

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

LastMileBlockIter is the iterator to iterate over the last mile blocks in consensus cache. All blocks returned are guaranteed to pass the verification.

func (*LastMileBlockIter) Next 

func (iter *LastMileBlockIter) Next() *types.Block

Next iterate to the next last mile block

type MessageRetry 

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

MessageRetry controls the message that can be retried

type MessageSender 

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

MessageSender is the wrapper object that controls how a consensus message is sent

func NewMessageSender 

func NewMessageSender(host p2p.Host) *MessageSender

NewMessageSender initializes the consensus message sender.

func (*MessageSender) DelayedSendWithRetry 

func (sender *MessageSender) DelayedSendWithRetry(blockNum uint64, msgType msg_pb.MessageType, groups []nodeconfig.GroupID, p2pMsg []byte)

DelayedSendWithRetry is similar to SendWithRetry but without the initial message sending but only retries.

func (*MessageSender) Reset 

func (sender *MessageSender) Reset(blockNum uint64)

Reset resets the sender's state for new block

func (*MessageSender) Retry 

func (sender *MessageSender) Retry(msgRetry *MessageRetry)

Retry will retry the consensus message for <RetryTimes> times.

func (*MessageSender) SendWithRetry 

func (sender *MessageSender) SendWithRetry(blockNum uint64, msgType msg_pb.MessageType, groups []nodeconfig.GroupID, p2pMsg []byte) error

SendWithRetry sends message with retry logic.

func (*MessageSender) SendWithoutRetry 

func (sender *MessageSender) SendWithoutRetry(groups []nodeconfig.GroupID, p2pMsg []byte) error

SendWithoutRetry sends message without retry logic.

func (*MessageSender) StopAllRetriesExceptCommitted 

func (sender *MessageSender) StopAllRetriesExceptCommitted()

StopAllRetriesExceptCommitted stops all the existing retries except committed message (which lives across consensus).

func (*MessageSender) StopRetry 

func (sender *MessageSender) StopRetry(msgType msg_pb.MessageType)

StopRetry stops the retry.

type Mode 

type Mode uint32

Mode is the current 

const (
	// Normal ..
	Normal Mode = iota
	// ViewChanging ..
	ViewChanging
	// Syncing ..
	Syncing
	// Listening ..
	Listening
)

func (Mode) String 

func (m Mode) String() string

type NetworkMessage 

type NetworkMessage struct {
	MessageType                msg_pb.MessageType
	Bytes                      []byte
	FBFTMsg                    *FBFTMessage
	OptionalAggregateSignature *bls_core.Sign
}

NetworkMessage is a message intended to be created only for distribution to all the other quorum members.

type Proposal added in v1.10.3 

type Proposal struct {
	Type   ProposalType
	Caller string
}

func NewProposal added in v1.10.3 

func NewProposal(t ProposalType) Proposal

NewProposal creates a new proposal

type ProposalType 

type ProposalType byte

ProposalType is to indicate the type of signal for new block proposal 

const (
	SyncProposal ProposalType = iota
	AsyncProposal
)

Constant of the type of new block proposal

type State 

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

State contains current mode and current viewID

func NewState added in v1.10.3 

func NewState(mode Mode) State

func (*State) GetCurBlockViewID 

func (pm *State) GetCurBlockViewID() uint64

GetCurBlockViewID return the current view id

func (*State) GetViewChangeDuraion 

func (pm *State) GetViewChangeDuraion() time.Duration

GetViewChangeDuraion return the duration of the current view change It increase in the power of difference betweeen view changing ID and current view ID

func (*State) GetViewChangingID 

func (pm *State) GetViewChangingID() uint64

GetViewChangingID return the current view changing id It is meaningful during view change mode

func (*State) Mode 

func (pm *State) Mode() Mode

Mode return the current node mode

func (*State) SetCurBlockViewID 

func (pm *State) SetCurBlockViewID(viewID uint64) uint64

SetCurBlockViewID sets the current view id

func (*State) SetMode 

func (pm *State) SetMode(s Mode)

SetMode set the node mode as required

func (*State) SetViewChangingID 

func (pm *State) SetViewChangingID(id uint64)

SetViewChangingID set the current view changing id It is meaningful during view change mode

type TimeoutType 

type TimeoutType int

TimeoutType is the type of timeout in view change protocol

func (TimeoutType) String 

func (t TimeoutType) String() string

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.