node/pkg/p2p: remove support for plain heartbeats
Change-Id: I621467615c2a46ab08ecae6227021b1e4efc1196
This commit is contained in:
parent
327f71d3f7
commit
8718e31fb4
|
@ -292,13 +292,6 @@ func Run(obsvC chan *gossipv1.SignedObservation, sendC chan []byte, rawHeartbeat
|
||||||
zap.String("from", envelope.GetFrom().String()))
|
zap.String("from", envelope.GetFrom().String()))
|
||||||
|
|
||||||
switch m := msg.Message.(type) {
|
switch m := msg.Message.(type) {
|
||||||
// TODO(leo): remove Heartbeat support after upgrade
|
|
||||||
case *gossipv1.GossipMessage_Heartbeat:
|
|
||||||
logger.Debug("unsigned heartbeat received",
|
|
||||||
zap.Any("value", m.Heartbeat),
|
|
||||||
zap.String("from", envelope.GetFrom().String()))
|
|
||||||
rawHeartbeatListeners.PublishHeartbeat(msg.GetHeartbeat())
|
|
||||||
p2pMessagesReceived.WithLabelValues("heartbeat").Inc()
|
|
||||||
case *gossipv1.GossipMessage_SignedHeartbeat:
|
case *gossipv1.GossipMessage_SignedHeartbeat:
|
||||||
s := m.SignedHeartbeat
|
s := m.SignedHeartbeat
|
||||||
gs := gst.Get()
|
gs := gst.Get()
|
||||||
|
|
Loading…
Reference in New Issue