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

Pubsub ignore messages from yourself (#4337)

Browse Source 
* ignore messages from myself
This commit is contained in:
Preston Van Loon 2019-12-20 11:37:25 -08:00 committed by prylabs-bulldozer[bot]
parent 996f4c7f5a
commit a949673e33
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
beacon-chain/sync/subscriber.go
View File

@ -158,6 +158,10 @@ func (r *Service) subscribe(topic string, validator pubsub.Validator, handle sub
continue continue
} }
if msg.ReceivedFrom == r.p2p.PeerID() {
continue
}
messageReceivedCounter.WithLabelValues(topic + r.p2p.Encoding().ProtocolSuffix()).Inc() messageReceivedCounter.WithLabelValues(topic + r.p2p.Encoding().ProtocolSuffix()).Inc()
go pipeline(msg) go pipeline(msg)