mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-04-11 03:07:01 +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 1d20f37810
commit bc62cfe22d
6 changed files with 30 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
blockchain/v1/reactor.go
View File

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

6
blockchain/v2/reactor.go
View File

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

6
blocksync/reactor.go
View File

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

6
consensus/reactor.go
View File

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

6
mempool/v1/reactor.go
View File

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

6
test/maverick/consensus/reactor.go
View File

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