This commit is contained in:
Jim McDonald 2020-09-30 13:29:26 +01:00
parent cfbe1726da
commit e6e14d9971
No known key found for this signature in database
GPG Key ID: 89CEB61B2AD2A5E7
3 changed files with 6 additions and 6 deletions

View File

@ -95,7 +95,7 @@ func NewErroringAttestationSubmitter() eth2client.AttestationSubmitter {
return &ErroringAttestationSubmitter{}
}
// SubmitErroringAttestation is a mock.
// SubmitAttestation is a mock.
func (m *ErroringAttestationSubmitter) SubmitAttestation(ctx context.Context, attestation *spec.Attestation) error {
return errors.New("error")
}
@ -186,7 +186,7 @@ func NewBeaconBlockProposalProvider() eth2client.BeaconBlockProposalProvider {
return &BeaconBlockProposalProvider{}
}
// SubmitBeaconBlock is a mock.
// BeaconBlockProposal is a mock.
func (m *BeaconBlockProposalProvider) BeaconBlockProposal(ctx context.Context, slot uint64, randaoReveal []byte, graffiti []byte) (*spec.BeaconBlock, error) {
// Graffiti should be 32 bytes.
fixedGraffiti := make([]byte, 32)

View File

@ -156,7 +156,7 @@ func (s *Service) UpdateAccountsState(ctx context.Context) error {
return nil
}
log.Trace().Int("total", len(s.accounts)).Int("unactivated", len(validatorIDs)).Msg("Updating state of unactivated keys")
validators := make(map[uint64]*api.Validator)
var validators map[uint64]*api.Validator
var err error
if validatorsWithoutBalanceProvider, isProvider := s.validatorsProvider.(eth2client.ValidatorsWithoutBalanceProvider); isProvider {
validators, err = validatorsWithoutBalanceProvider.ValidatorsWithoutBalance(ctx, "head", validatorIDs)
@ -224,7 +224,7 @@ func (s *Service) RefreshAccounts(ctx context.Context) error {
}
log.Trace().Int("accounts", len(validatorIDs)).Msg("Obtaining validator state of accounts")
validators := make(map[uint64]*api.Validator)
var validators map[uint64]*api.Validator
var err error
if validatorsWithoutBalanceProvider, isProvider := s.validatorsProvider.(eth2client.ValidatorsWithoutBalanceProvider); isProvider {
validators, err = validatorsWithoutBalanceProvider.ValidatorsWithoutBalance(ctx, "head", validatorIDs)

View File

@ -36,9 +36,9 @@ func scoreBeaconBlockProposal(ctx context.Context, name string, blockProposal *s
// Add attestation scores.
for _, attestation := range blockProposal.Body.Attestations {
inclusionDistance := float64(blockProposal.Slot - attestation.Data.Slot)
attestationScore += float64(attestation.AggregationBits.Count()) * (float64(0.75) + float64(0.25)/float64(inclusionDistance))
attestationScore += float64(attestation.AggregationBits.Count()) * (float64(0.75) + float64(0.25)/inclusionDistance)
if inclusionDistance == 1 {
immediateAttestationScore += float64(attestation.AggregationBits.Count()) * (float64(0.75) + float64(0.25)/float64(inclusionDistance))
immediateAttestationScore += float64(attestation.AggregationBits.Count()) * (float64(0.75) + float64(0.25)/inclusionDistance)
}
}