mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
Refactoring and adding unit test of compareSignersLists
This commit is contained in:
parent
1a51d2d34c
commit
152b564ef7
2 changed files with 39 additions and 8 deletions
|
|
@ -428,14 +428,7 @@ func (c *Posv) verifyCascadingFields(chain consensus.ChainReader, header *types.
|
|||
}
|
||||
extraSuffix := len(header.Extra) - extraSeal
|
||||
masternodesFromCheckpointHeader := common.ExtractAddressFromBytes(header.Extra[extraVanity:extraSuffix])
|
||||
validSigners := true
|
||||
sort.Slice(masternodesFromCheckpointHeader, func(i, j int) bool {
|
||||
return masternodesFromCheckpointHeader[i].String() <= masternodesFromCheckpointHeader[j].String()
|
||||
})
|
||||
sort.Slice(signers, func(i, j int) bool {
|
||||
return signers[i].String() <= signers[j].String()
|
||||
})
|
||||
validSigners = reflect.DeepEqual(masternodesFromCheckpointHeader, signers)
|
||||
validSigners := compareSignersLists(masternodesFromCheckpointHeader, signers)
|
||||
if !validSigners {
|
||||
log.Error("Masternodes lists are different in checkpoint header and snapshot", "number", number, "masternodes_from_checkpoint_header", masternodesFromCheckpointHeader, "masternodes_in_snapshot", signers, "penList", penPenalties)
|
||||
return errInvalidCheckpointSigners
|
||||
|
|
@ -451,6 +444,18 @@ func (c *Posv) verifyCascadingFields(chain consensus.ChainReader, header *types.
|
|||
return c.verifySeal(chain, header, parents, fullVerify)
|
||||
}
|
||||
|
||||
// compare 2 signers lists
|
||||
// return true if they are same elements, otherwise return false
|
||||
func compareSignersLists(list1 []common.Address, list2 []common.Address) bool {
|
||||
sort.Slice(list1, func(i, j int) bool {
|
||||
return list1[i].String() <= list1[j].String()
|
||||
})
|
||||
sort.Slice(list2, func(i, j int) bool {
|
||||
return list2[i].String() <= list2[j].String()
|
||||
})
|
||||
return reflect.DeepEqual(list1, list2)
|
||||
}
|
||||
|
||||
func (c *Posv) GetSnapshot(chain consensus.ChainReader, header *types.Header) (*Snapshot, error) {
|
||||
number := header.Number.Uint64()
|
||||
log.Trace("take snapshot", "number", number, "hash", header.Hash())
|
||||
|
|
|
|||
|
|
@ -47,3 +47,29 @@ func TestGetM1M2FromCheckpointHeader(t *testing.T) {
|
|||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestCompareSignersLists(t *testing.T) {
|
||||
list1 := []common.Address{
|
||||
common.StringToAddress("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"),
|
||||
common.StringToAddress("bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb"),
|
||||
common.StringToAddress("cccccccccccccccccccccccccccccccccccccccc"),
|
||||
common.StringToAddress("dddddddddddddddddddddddddddddddddddddddd"),
|
||||
}
|
||||
list2 := []common.Address{
|
||||
common.StringToAddress("cccccccccccccccccccccccccccccccccccccccc"),
|
||||
common.StringToAddress("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"),
|
||||
common.StringToAddress("dddddddddddddddddddddddddddddddddddddddd"),
|
||||
common.StringToAddress("bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb"),
|
||||
}
|
||||
list3 := []common.Address{
|
||||
common.StringToAddress("cccccccccccccccccccccccccccccccccccccccc"),
|
||||
common.StringToAddress("dddddddddddddddddddddddddddddddddddddddd"),
|
||||
common.StringToAddress("bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb"),
|
||||
}
|
||||
if !compareSignersLists(list1, list2) {
|
||||
t.Error("list1 should be equal to list2", "list1", list1, "list2", list2)
|
||||
}
|
||||
if compareSignersLists(list1, list3) {
|
||||
t.Error("list1 and list3 should not be same", "list1", list1, "list3", list3)
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue