mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-04-10 18:59:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

unwrap messages in receive calls

Browse Source
This commit is contained in:
William Banfield
2022-10-28 17:27:11 -04:00
parent 10dca9f5e4
commit bbb50514af
3 changed files with 17 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
p2p/pex/pex_reactor.go
View File

@@ -306,10 +306,14 @@ func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
if err != nil {
panic(err)
}
um, err := msg.Unwrap()
if err != nil {
panic(err)
}
r.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
Message: msg,
Message: um,
})
}

7
p2p/switch_test.go
View File

@@ -87,10 +87,15 @@ func (tr *TestReactor) Receive(chID byte, peer Peer, msgBytes []byte) {
if err != nil {
panic(err)
}
um, err := msg.Unwrap()
if err != nil {
panic(err)
}
tr.NewReceive(Envelope{
ChannelID: chID,
Src: peer,
Message: msg,
Message: um,
})
}

7
statesync/reactor.go
View File

@@ -231,10 +231,15 @@ func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
if err != nil {
panic(err)
}
um, err := msg.Unwrap()
if err != nil {
panic(err)
}
r.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
Message: msg,
Message: um,
})
}