From fbad1072103df01834076f3d850387421de65fa6 Mon Sep 17 00:00:00 2001 From: William Banfield Date: Thu, 3 Nov 2022 15:09:28 -0400 Subject: [PATCH] comment out new functions --- p2p/peer.go | 28 ++++++++++++++++------------ 1 file changed, 16 insertions(+), 12 deletions(-) diff --git a/p2p/peer.go b/p2p/peer.go index 36b58f0e4..a2d5e66f8 100644 --- a/p2p/peer.go +++ b/p2p/peer.go @@ -64,9 +64,11 @@ type EnvelopeSender interface { // // Deprecated: Will be removed in v0.37. func SendEnvelopeShim(p Peer, e Envelope, lg log.Logger) bool { - if es, ok := p.(EnvelopeSender); ok { - return es.SendEnvelope(e) - } + /* + if es, ok := p.(EnvelopeSender); ok { + return es.SendEnvelope(e) + } + */ msg := e.Message if w, ok := msg.(Wrapper); ok { msg = w.Wrap() @@ -534,15 +536,17 @@ func createMConnection( } p.metrics.PeerReceiveBytesTotal.With(labels...).Add(float64(len(msgBytes))) p.metrics.MessageReceiveBytesTotal.With("message_type", p.mlc.ValueToMetricLabel(msg)).Add(float64(len(msgBytes))) - if nr, ok := reactor.(EnvelopeReceiver); ok { - nr.ReceiveEnvelope(Envelope{ - ChannelID: chID, - Src: p, - Message: msg, - }) - } else { - reactor.Receive(chID, p, msgBytes) - } + /* + if nr, ok := reactor.(EnvelopeReceiver); ok { + nr.ReceiveEnvelope(Envelope{ + ChannelID: chID, + Src: p, + Message: msg, + }) + } else { + */ + reactor.Receive(chID, p, msgBytes) + // } } onError := func(r interface{}) {