You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
361 lines
8.8 KiB
361 lines
8.8 KiB
package quorum
|
|
|
|
import (
|
|
"fmt"
|
|
"math/big"
|
|
|
|
"github.com/harmony-one/harmony/crypto/bls"
|
|
|
|
"github.com/ethereum/go-ethereum/common"
|
|
bls_core "github.com/harmony-one/bls/ffi/go/bls"
|
|
"github.com/harmony-one/harmony/consensus/votepower"
|
|
bls_cosi "github.com/harmony-one/harmony/crypto/bls"
|
|
"github.com/harmony-one/harmony/multibls"
|
|
"github.com/harmony-one/harmony/numeric"
|
|
"github.com/harmony-one/harmony/shard"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
// Phase is a phase that needs quorum to proceed
|
|
type Phase byte
|
|
|
|
const (
|
|
// Prepare ..
|
|
Prepare Phase = iota
|
|
// Commit ..
|
|
Commit
|
|
// ViewChange ..
|
|
ViewChange
|
|
)
|
|
|
|
var (
|
|
phaseNames = map[Phase]string{
|
|
Prepare: "Prepare",
|
|
Commit: "Commit",
|
|
ViewChange: "viewChange",
|
|
}
|
|
errPhaseUnknown = errors.New("invariant of known phase violated")
|
|
)
|
|
|
|
func (p Phase) String() string {
|
|
if name, ok := phaseNames[p]; ok {
|
|
return name
|
|
}
|
|
return fmt.Sprintf("Unknown Quorum Phase %+v", byte(p))
|
|
}
|
|
|
|
// Policy is the rule we used to decide is quorum achieved
|
|
type Policy byte
|
|
|
|
const (
|
|
// SuperMajorityVote is a 2/3s voting mechanism, pre-PoS
|
|
SuperMajorityVote Policy = iota
|
|
// SuperMajorityStake is 2/3s of total staked amount for epoch
|
|
SuperMajorityStake
|
|
)
|
|
|
|
var policyNames = map[Policy]string{
|
|
SuperMajorityStake: "SuperMajorityStake",
|
|
SuperMajorityVote: "SuperMajorityVote",
|
|
}
|
|
|
|
func (p Policy) String() string {
|
|
if name, ok := policyNames[p]; ok {
|
|
return name
|
|
}
|
|
return fmt.Sprintf("Unknown Quorum Policy %+v", byte(p))
|
|
|
|
}
|
|
|
|
// ParticipantTracker ..
|
|
type ParticipantTracker interface {
|
|
Participants() multibls.PublicKeys
|
|
IndexOf(bls.SerializedPublicKey) int
|
|
ParticipantsCount() int64
|
|
NextAfter(*bls.PublicKeyWrapper, int) (bool, *bls.PublicKeyWrapper)
|
|
UpdateParticipants(pubKeys []bls.PublicKeyWrapper)
|
|
}
|
|
|
|
// SignatoryTracker ..
|
|
type SignatoryTracker interface {
|
|
ParticipantTracker
|
|
SubmitVote(
|
|
p Phase, pubkey bls.SerializedPublicKey,
|
|
sig *bls_core.Sign, headerHash common.Hash,
|
|
height, viewID uint64,
|
|
) (*votepower.Ballot, error)
|
|
// Caller assumes concurrency protection
|
|
SignersCount(Phase) int64
|
|
reset([]Phase)
|
|
}
|
|
|
|
// SignatureReader ..
|
|
type SignatureReader interface {
|
|
SignatoryTracker
|
|
ReadAllBallots(Phase) []*votepower.Ballot
|
|
ReadBallot(p Phase, pubkey bls.SerializedPublicKey) *votepower.Ballot
|
|
TwoThirdsSignersCount() int64
|
|
// 96 bytes aggregated signature
|
|
AggregateVotes(p Phase) *bls_core.Sign
|
|
}
|
|
|
|
// DependencyInjectionWriter ..
|
|
type DependencyInjectionWriter interface {
|
|
SetMyPublicKeyProvider(func() (multibls.PublicKeys, error))
|
|
}
|
|
|
|
// DependencyInjectionReader ..
|
|
type DependencyInjectionReader interface {
|
|
MyPublicKey() func() (multibls.PublicKeys, error)
|
|
}
|
|
|
|
// Decider ..
|
|
type Decider interface {
|
|
fmt.Stringer
|
|
SignatureReader
|
|
DependencyInjectionWriter
|
|
SetVoters(subCommittee *shard.Committee, epoch *big.Int) (*TallyResult, error)
|
|
Policy() Policy
|
|
AddNewVote(
|
|
p Phase, pubkey bls.SerializedPublicKey,
|
|
sig *bls_core.Sign, headerHash common.Hash,
|
|
height, viewID uint64,
|
|
) (*votepower.Ballot, error)
|
|
IsQuorumAchieved(Phase) bool
|
|
IsQuorumAchievedByMask(mask *bls_cosi.Mask) bool
|
|
QuorumThreshold() numeric.Dec
|
|
AmIMemberOfCommitee() bool
|
|
IsAllSigsCollected() bool
|
|
ResetPrepareAndCommitVotes()
|
|
ResetViewChangeVotes()
|
|
}
|
|
|
|
// Registry ..
|
|
type Registry struct {
|
|
Deciders map[string]Decider `json:"quorum-deciders"`
|
|
ExternalCount int `json:"external-slot-count"`
|
|
MedianStake numeric.Dec `json:"epos-median-stake"`
|
|
}
|
|
|
|
// NewRegistry ..
|
|
func NewRegistry(extern int) Registry {
|
|
return Registry{map[string]Decider{}, extern, numeric.ZeroDec()}
|
|
}
|
|
|
|
// Transition ..
|
|
type Transition struct {
|
|
Previous Registry `json:"previous"`
|
|
Current Registry `json:"current"`
|
|
}
|
|
|
|
// These maps represent the signatories (validators), keys are BLS public keys
|
|
// and values are BLS private key signed signatures
|
|
type cIdentities struct {
|
|
// Public keys of the committee including leader and validators
|
|
publicKeys []bls.PublicKeyWrapper
|
|
keyIndexMap map[bls.SerializedPublicKey]int
|
|
prepare *votepower.Round
|
|
commit *votepower.Round
|
|
// viewIDSigs: every validator
|
|
// sign on |viewID|blockHash| in view changing message
|
|
viewChange *votepower.Round
|
|
}
|
|
|
|
type depInject struct {
|
|
publicKeyProvider func() (multibls.PublicKeys, error)
|
|
}
|
|
|
|
func (s *cIdentities) AggregateVotes(p Phase) *bls_core.Sign {
|
|
ballots := s.ReadAllBallots(p)
|
|
sigs := make([]*bls_core.Sign, 0, len(ballots))
|
|
for _, ballot := range ballots {
|
|
sig := &bls_core.Sign{}
|
|
// NOTE invariant that shouldn't happen by now
|
|
// but pointers are pointers
|
|
if ballot != nil {
|
|
sig.DeserializeHexStr(common.Bytes2Hex(ballot.Signature))
|
|
sigs = append(sigs, sig)
|
|
}
|
|
}
|
|
return bls_cosi.AggregateSig(sigs)
|
|
}
|
|
|
|
func (s *cIdentities) IndexOf(pubKey bls.SerializedPublicKey) int {
|
|
if index, ok := s.keyIndexMap[pubKey]; ok {
|
|
return index
|
|
}
|
|
return -1
|
|
}
|
|
|
|
// NextAfter return the next pubkey, next can be negative number
|
|
func (s *cIdentities) NextAfter(pubKey *bls.PublicKeyWrapper, next int) (bool, *bls.PublicKeyWrapper) {
|
|
found := false
|
|
|
|
idx := s.IndexOf(pubKey.Bytes)
|
|
if idx != -1 {
|
|
found = true
|
|
}
|
|
idx = (idx + next) % int(s.ParticipantsCount())
|
|
return found, &s.publicKeys[idx]
|
|
}
|
|
|
|
func (s *cIdentities) Participants() multibls.PublicKeys {
|
|
return s.publicKeys
|
|
}
|
|
|
|
func (s *cIdentities) UpdateParticipants(pubKeys []bls.PublicKeyWrapper) {
|
|
keyIndexMap := map[bls.SerializedPublicKey]int{}
|
|
for i := range pubKeys {
|
|
keyIndexMap[pubKeys[i].Bytes] = i
|
|
}
|
|
s.publicKeys = pubKeys
|
|
s.keyIndexMap = keyIndexMap
|
|
}
|
|
|
|
func (s *cIdentities) ParticipantsCount() int64 {
|
|
return int64(len(s.publicKeys))
|
|
}
|
|
|
|
func (s *cIdentities) SignersCount(p Phase) int64 {
|
|
switch p {
|
|
case Prepare:
|
|
return int64(len(s.prepare.BallotBox))
|
|
case Commit:
|
|
return int64(len(s.commit.BallotBox))
|
|
case ViewChange:
|
|
return int64(len(s.viewChange.BallotBox))
|
|
default:
|
|
return 0
|
|
|
|
}
|
|
}
|
|
|
|
func (s *cIdentities) SubmitVote(
|
|
p Phase, pubkey bls.SerializedPublicKey,
|
|
sig *bls_core.Sign, headerHash common.Hash,
|
|
height, viewID uint64,
|
|
) (*votepower.Ballot, error) {
|
|
if ballet := s.ReadBallot(p, pubkey); ballet != nil {
|
|
return nil, errors.Errorf("vote is already submitted %x", pubkey)
|
|
}
|
|
|
|
ballot := &votepower.Ballot{
|
|
SignerPubKey: pubkey,
|
|
BlockHeaderHash: headerHash,
|
|
Signature: common.Hex2Bytes(sig.SerializeToHexStr()),
|
|
Height: height,
|
|
ViewID: viewID,
|
|
}
|
|
switch p {
|
|
case Prepare:
|
|
s.prepare.BallotBox[pubkey] = ballot
|
|
case Commit:
|
|
s.commit.BallotBox[pubkey] = ballot
|
|
case ViewChange:
|
|
s.viewChange.BallotBox[pubkey] = ballot
|
|
default:
|
|
return nil, errors.Wrapf(errPhaseUnknown, "given: %s", p.String())
|
|
}
|
|
return ballot, nil
|
|
}
|
|
|
|
func (s *cIdentities) reset(ps []Phase) {
|
|
for i := range ps {
|
|
switch m := votepower.NewRound(); ps[i] {
|
|
case Prepare:
|
|
s.prepare = m
|
|
case Commit:
|
|
s.commit = m
|
|
case ViewChange:
|
|
s.viewChange = m
|
|
}
|
|
}
|
|
}
|
|
|
|
func (s *cIdentities) TwoThirdsSignersCount() int64 {
|
|
return s.ParticipantsCount()*2/3 + 1
|
|
}
|
|
|
|
func (s *cIdentities) ReadBallot(p Phase, pubkey bls.SerializedPublicKey) *votepower.Ballot {
|
|
ballotBox := map[bls.SerializedPublicKey]*votepower.Ballot{}
|
|
|
|
switch p {
|
|
case Prepare:
|
|
ballotBox = s.prepare.BallotBox
|
|
case Commit:
|
|
ballotBox = s.commit.BallotBox
|
|
case ViewChange:
|
|
ballotBox = s.viewChange.BallotBox
|
|
}
|
|
|
|
payload, ok := ballotBox[pubkey]
|
|
if !ok {
|
|
return nil
|
|
}
|
|
return payload
|
|
}
|
|
|
|
func (s *cIdentities) ReadAllBallots(p Phase) []*votepower.Ballot {
|
|
m := map[bls.SerializedPublicKey]*votepower.Ballot{}
|
|
switch p {
|
|
case Prepare:
|
|
m = s.prepare.BallotBox
|
|
case Commit:
|
|
m = s.commit.BallotBox
|
|
case ViewChange:
|
|
m = s.viewChange.BallotBox
|
|
}
|
|
ballots := make([]*votepower.Ballot, 0, len(m))
|
|
for i := range m {
|
|
ballots = append(ballots, m[i])
|
|
}
|
|
return ballots
|
|
}
|
|
|
|
func newBallotsBackedSignatureReader() *cIdentities {
|
|
return &cIdentities{
|
|
publicKeys: []bls.PublicKeyWrapper{},
|
|
keyIndexMap: map[bls.SerializedPublicKey]int{},
|
|
prepare: votepower.NewRound(),
|
|
commit: votepower.NewRound(),
|
|
viewChange: votepower.NewRound(),
|
|
}
|
|
}
|
|
|
|
type composite struct {
|
|
DependencyInjectionWriter
|
|
DependencyInjectionReader
|
|
SignatureReader
|
|
}
|
|
|
|
func (d *depInject) SetMyPublicKeyProvider(p func() (multibls.PublicKeys, error)) {
|
|
d.publicKeyProvider = p
|
|
}
|
|
|
|
func (d *depInject) MyPublicKey() func() (multibls.PublicKeys, error) {
|
|
return d.publicKeyProvider
|
|
}
|
|
|
|
// NewDecider ..
|
|
func NewDecider(p Policy, shardID uint32) Decider {
|
|
signatureStore := newBallotsBackedSignatureReader()
|
|
deps := &depInject{}
|
|
c := &composite{deps, deps, signatureStore}
|
|
switch p {
|
|
case SuperMajorityVote:
|
|
return &uniformVoteWeight{
|
|
c.DependencyInjectionWriter, c.DependencyInjectionReader, c,
|
|
}
|
|
case SuperMajorityStake:
|
|
return &stakedVoteWeight{
|
|
c.SignatureReader,
|
|
c.DependencyInjectionWriter,
|
|
c.DependencyInjectionWriter.(DependencyInjectionReader),
|
|
*votepower.NewRoster(shardID),
|
|
newVoteTally(),
|
|
}
|
|
default:
|
|
// Should not be possible
|
|
return nil
|
|
}
|
|
}
|
|
|