comment out new functions

This commit is contained in:
William Banfield
2022-11-03 15:09:28 -04:00
parent 7417ddf351
commit fbad107210

View File

@@ -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{}) {