poanetwork
/
quorum
mirror of https://github.com/poanetwork/quorum.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

When checking messages from higher round, only check messages from unique validators (#112)

This commit is contained in:
Jitendra Bhurat 2020-06-05 11:35:31 -04:00 committed by GitHub
parent 164d32caf2
commit 1d80555093
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
consensus/qibft/core/roundchange.go
View File

@ -236,17 +236,20 @@ func (rcs *roundChangeSet) Add(r *big.Int, msg *message, preparedRound *big.Int,
}
// higherRoundMessages returns the number of Round Change messages received for the round greater than the given round
// and from different validators
func (rcs *roundChangeSet) higherRoundMessages(round *big.Int) int {
rcs.mu.Lock()
defer rcs.mu.Unlock()
num := 0
addresses := make(map[common.Address]struct{})
for k, rms := range rcs.roundChanges {
if k > round.Uint64() {
num = num + len(rms.messages)
for addr := range rms.messages {
addresses[addr] = struct{}{}
}
}
}
return num
return len(addresses)
}
func (rcs *roundChangeSet) getRCMessagesForGivenRound(round *big.Int) int {