mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2024-12-22 03:30:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Drop Down Expected Sync Participation During Fork (#10708)

Browse Source 
* reduce

* skip
This commit is contained in:
Nishant Das 2022-05-19 20:28:56 +08:00 committed by GitHub
parent b74947aa75
commit 1012ec1915
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
testing/endtoend/evaluators/validator.go
View File

@ -188,18 +188,19 @@ func validatorsSyncParticipation(conns ...*grpc.ClientConn) error {
if b.IsNil() {
return errors.New("nil block provided")
}
forkSlot, err := slots.EpochStart(helpers.AltairE2EForkEpoch)
forkStartSlot, err := slots.EpochStart(helpers.AltairE2EForkEpoch)
if err != nil {
return err
}
nexForkSlot, err := slots.EpochStart(helpers.BellatrixE2EForkEpoch)
if err != nil {
return err
}
switch b.Block().Slot() {
case forkSlot, forkSlot + 1, nexForkSlot:
// Skip evaluation of the slot.
if forkStartSlot == b.Block().Slot() {
// Skip fork slot.
continue
}
expectedParticipation := expectedSyncParticipation
switch slots.ToEpoch(b.Block().Slot()) {
case helpers.AltairE2EForkEpoch:
// Drop expected sync participation figure.
expectedParticipation = 0.90
default:
// no-op
}
@ -207,7 +208,7 @@ func validatorsSyncParticipation(conns ...*grpc.ClientConn) error {
if err != nil {
return err
}
threshold := uint64(float64(syncAgg.SyncCommitteeBits.Len()) * expectedSyncParticipation)
threshold := uint64(float64(syncAgg.SyncCommitteeBits.Len()) * expectedParticipation)
if syncAgg.SyncCommitteeBits.Count() < threshold {
return errors.Errorf("In block of slot %d ,the aggregate bitvector with length of %d only got a count of %d", b.Block().Slot(), threshold, syncAgg.SyncCommitteeBits.Count())
}