mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-04-22 00:30:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

reactors have channel and peer in new receive

Browse Source
This commit is contained in:
William Banfield
2022-10-28 15:44:48 -04:00
parent 3e111ac4cd
commit 39b2e4b878
12 changed files with 45 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
blockchain/v1/reactor.go
View File

@@ -307,7 +307,10 @@ func (bcR *BlockchainReactor) NewReceive(e p2p.Envelope) {
}
func (bcR *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
bcR.NewReceive(p2p.Envelope{})
bcR.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// processBlocksRoutine processes blocks until signlaed to stop over the stopProcessing channel

5
blockchain/v2/reactor.go
View File

@@ -514,7 +514,10 @@ func (r *BlockchainReactor) NewReceive(e p2p.Envelope) {
}
func (r *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
r.NewReceive(p2p.Envelope{})
r.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// AddPeer implements Reactor interface

5
blocksync/reactor.go
View File

@@ -234,7 +234,10 @@ func (bcR *Reactor) NewReceive(e p2p.Envelope) {
}
func (bcR *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
bcR.NewReceive(p2p.Envelope{})
bcR.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// Handle messages from the poolReactor telling the reactor what to do.

4
consensus/byzantine_test.go
View File

@@ -602,9 +602,7 @@ func (br *ByzantineReactor) RemovePeer(peer p2p.Peer, reason interface{}) {
func (br *ByzantineReactor) NewReceive(e p2p.Envelope) {
br.reactor.NewReceive(e)
}
func (br *ByzantineReactor) Receive(chID byte, p p2p.Peer, m []byte)
br.NewReceive(p2p.Envelope{})
{
func (br *ByzantineReactor) Receive(chID byte, p p2p.Peer, m []byte) {
br.reactor.Receive(chID, p, m)
}
func (br *ByzantineReactor) InitPeer(peer p2p.Peer) p2p.Peer { return peer }

5
consensus/reactor.go
View File

@@ -388,7 +388,10 @@ func (conR *Reactor) NewReceive(e p2p.Envelope) {
}
func (conR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
conR.NewReceive(p2p.Envelope{})
conR.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// SetEventBus sets event bus.

5
evidence/reactor.go
View File

@@ -93,7 +93,10 @@ func (evR *Reactor) NewReceive(e p2p.Envelope) {
}
func (evR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
evR.NewReceive(p2p.Envelope{})
evR.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// SetEventBus implements events.Eventable.

5
mempool/v1/reactor.go
View File

@@ -188,7 +188,10 @@ func (memR *Reactor) NewReceive(e p2p.Envelope) {
}
func (memR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
memR.NewReceive(p2p.Envelope{})
memR.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// PeerState describes the state of a peer.

5
p2p/mock/reactor.go
View File

@@ -22,5 +22,8 @@ func NewReactor() *Reactor {
func (r *Reactor) GetChannels() []*conn.ChannelDescriptor { return r.Channels }
func (r *Reactor) AddPeer(peer p2p.Peer) {}
func (r *Reactor) RemovePeer(peer p2p.Peer, reason interface{}) {}
func (r *Reactor) NewReceive(e p2p.Envelope) {}
func (r *Reactor) NewReceive(e p2p.Envelope)
ChannelID: chID,
Src: peer,
{}
func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {}

5
p2p/pex/pex_reactor.go
View File

@@ -299,7 +299,10 @@ func (r *Reactor) NewReceive(e p2p.Envelope) {
}
func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
r.NewReceive(p2p.Envelope{})
r.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// enforces a minimum amount of time between requests

5
p2p/switch_test.go
View File

@@ -83,7 +83,10 @@ func (tr *TestReactor) NewReceive(e Envelope) {
}
func (tr *TestReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
tr.NewReceive(p2p.Envelope{})
tr.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
func (tr *TestReactor) getMsgs(chID byte) []PeerMessage {

5
statesync/reactor.go
View File

@@ -224,7 +224,10 @@ func (r *Reactor) NewReceive(e p2p.Envelope) {
}
func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
r.NewReceive(p2p.Envelope{})
r.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// recentSnapshots fetches the n most recent snapshots from the app

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

@@ -388,7 +388,10 @@ func (conR *Reactor) NewReceive(e p2p.Envelope) {
}
func (conR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
conR.NewReceive(p2p.Envelope{})
conR.NewReceive(p2p.Envelope{
ChannelID: chID,
Src: peer,
})
}
// SetEventBus sets event bus.