mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-05-02 13:25:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

wrapper used in send

Browse Source
This commit is contained in:
William Banfield
2022-10-20 17:27:57 -04:00
parent 42fc1fc1cc
commit 9742dac312
1 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
p2p/peer.go
View File

@@ -261,7 +261,15 @@ func (p *peer) Send(e Envelope) bool {
} else if !p.hasChannel(e.ChannelID) {
return false
}
msgBytes, err := proto.Marshal(e.Message)
msg := e.Message
if w, ok := msg.(Wrapper); ok {
var err error
msg, err = w.Wrap()
if err != nil {
panic(err)
}
}
msgBytes, err := proto.Marshal(msg)
if err != nil {
panic(err) // Q: should this panic or error?
}
@@ -284,7 +292,15 @@ func (p *peer) TrySend(e Envelope) bool {
} else if !p.hasChannel(e.ChannelID) {
return false
}
msgBytes, err := proto.Marshal(e.Message)
msg := e.Message
if w, ok := msg.(Wrapper); ok {
var err error
msg, err = w.Wrap()
if err != nil {
panic(err)
}
}
msgBytes, err := proto.Marshal(msg)
if err != nil {
panic(err)
}