diff --git a/blockchain/v1/reactor.go b/blockchain/v1/reactor.go index c83703dd5..133bf179d 100644 --- a/blockchain/v1/reactor.go +++ b/blockchain/v1/reactor.go @@ -173,6 +173,7 @@ func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor { SendQueueCapacity: 2000, RecvBufferCapacity: 50 * 4096, RecvMessageCapacity: bc.MaxMsgSize, + MessageType: &bcproto.Message{}, }, } } diff --git a/blockchain/v2/reactor.go b/blockchain/v2/reactor.go index f59d21339..9d3289ae5 100644 --- a/blockchain/v2/reactor.go +++ b/blockchain/v2/reactor.go @@ -566,6 +566,7 @@ func (r *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor { SendQueueCapacity: 2000, RecvBufferCapacity: 50 * 4096, RecvMessageCapacity: bc.MaxMsgSize, + MessageType: &bcproto.Message{}, }, } } diff --git a/test/maverick/consensus/reactor.go b/test/maverick/consensus/reactor.go index 32c90cda5..6154003af 100644 --- a/test/maverick/consensus/reactor.go +++ b/test/maverick/consensus/reactor.go @@ -148,6 +148,7 @@ func (conR *Reactor) GetChannels() []*p2p.ChannelDescriptor { Priority: 6, SendQueueCapacity: 100, RecvMessageCapacity: maxMsgSize, + MessageType: &tmcons.Message{}, }, { ID: DataChannel, // maybe split between gossiping current block and catchup stuff @@ -156,6 +157,7 @@ func (conR *Reactor) GetChannels() []*p2p.ChannelDescriptor { SendQueueCapacity: 100, RecvBufferCapacity: 50 * 4096, RecvMessageCapacity: maxMsgSize, + MessageType: &tmcons.Message{}, }, { ID: VoteChannel, @@ -163,6 +165,7 @@ func (conR *Reactor) GetChannels() []*p2p.ChannelDescriptor { SendQueueCapacity: 100, RecvBufferCapacity: 100 * 100, RecvMessageCapacity: maxMsgSize, + MessageType: &tmcons.Message{}, }, { ID: VoteSetBitsChannel, @@ -170,6 +173,7 @@ func (conR *Reactor) GetChannels() []*p2p.ChannelDescriptor { SendQueueCapacity: 2, RecvBufferCapacity: 1024, RecvMessageCapacity: maxMsgSize, + MessageType: &tmcons.Message{}, }, } }