Skip to content

Commit

Permalink
Initialize payload att message verfier in sync (#14323)
Browse files Browse the repository at this point in the history
  • Loading branch information
terencechain authored and potuz committed Sep 13, 2024
1 parent e1943b7 commit fa944ad
Showing 1 changed file with 8 additions and 0 deletions.
8 changes: 8 additions & 0 deletions beacon-chain/sync/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ import (
lruwrpr "github.com/prysmaticlabs/prysm/v5/cache/lru"
"github.com/prysmaticlabs/prysm/v5/config/params"
"github.com/prysmaticlabs/prysm/v5/consensus-types/blocks"
payloadattestation "github.com/prysmaticlabs/prysm/v5/consensus-types/epbs/payload-attestation"
"github.com/prysmaticlabs/prysm/v5/consensus-types/interfaces"
leakybucket "github.com/prysmaticlabs/prysm/v5/container/leaky-bucket"
ethpb "github.com/prysmaticlabs/prysm/v5/proto/prysm/v1alpha1"
Expand Down Expand Up @@ -217,6 +218,12 @@ func newBlobVerifierFromInitializer(ini *verification.Initializer) verification.
}
}

func newPayloadAttestationMessageFromInitializer(ini *verification.Initializer) verification.NewPayloadAttestationMsgVerifier {
return func(pa payloadattestation.ROMessage, reqs []verification.Requirement) verification.PayloadAttestationMsgVerifier {
return ini.NewPayloadAttestationMsgVerifier(pa, reqs)
}
}

// Start the regular sync service.
func (s *Service) Start() {
v, err := s.verifierWaiter.WaitForInitializer(s.ctx)
Expand All @@ -225,6 +232,7 @@ func (s *Service) Start() {
return
}
s.newBlobVerifier = newBlobVerifierFromInitializer(v)
s.newPayloadAttestationVerifier = newPayloadAttestationMessageFromInitializer(v)

go s.verifierRoutine()
go s.registerHandlers()
Expand Down

0 comments on commit fa944ad

Please sign in to comment.