AtHeartEngineer/prysm
1
0
Fork 0
mirror of https://github.com/OffchainLabs/prysm.git synced 2026-01-09 21:38:05 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix error message of subscriber (#11622)

Browse Source 
Co-authored-by: terencechain <terence@prysmaticlabs.com>
Co-authored-by: Radosław Kapka <rkapka@wp.pl>
This commit is contained in:
int88
2022-11-08 00:44:38 +08:00
committed by GitHub
parent 19f6d3bef6
commit 4d68211ad4
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
beacon-chain/sync/subscriber_beacon_aggregate_proof.go
View File

@@ -15,7 +15,7 @@ import (
func (s *Service) beaconAggregateProofSubscriber(_ context.Context, msg proto.Message) error {
a, ok := msg.(*ethpb.SignedAggregateAttestationAndProof)
if !ok {
return fmt.Errorf("message was not type *eth.SignedAggregateAttestationAndProof, type=%T", msg)
return fmt.Errorf("message was not type *ethpb.SignedAggregateAttestationAndProof, type=%T", msg)
}
if a.Message.Aggregate == nil || a.Message.Aggregate.Data == nil {

2
beacon-chain/sync/subscriber_sync_committee_message.go
View File

@@ -13,7 +13,7 @@ import (
func (s *Service) syncCommitteeMessageSubscriber(_ context.Context, msg proto.Message) error {
m, ok := msg.(*ethpb.SyncCommitteeMessage)
if !ok {
return fmt.Errorf("message was not type *eth.SyncCommitteeMessage, type=%T", msg)
return fmt.Errorf("message was not type *ethpb.SyncCommitteeMessage, type=%T", msg)
}
if m == nil {

2
beacon-chain/sync/subscriber_sync_contribution_proof.go
View File

@@ -15,7 +15,7 @@ import (
func (s *Service) syncContributionAndProofSubscriber(_ context.Context, msg proto.Message) error {
sContr, ok := msg.(*ethpb.SignedContributionAndProof)
if !ok {
return fmt.Errorf("message was not type *eth.SignedAggregateAttestationAndProof, type=%T", msg)
return fmt.Errorf("message was not type *ethpb.SignedContributionAndProof, type=%T", msg)
}
if sContr.Message == nil || sContr.Message.Contribution == nil {