From e91616c15fef5582696fceae8775b16ddf29957e Mon Sep 17 00:00:00 2001
From: William Banfield <wbanfield@gmail.com>
Date: Thu, 3 Nov 2022 15:20:41 -0400
Subject: [PATCH] add allocate in Receive calls

---
 blockchain/v0/reactor.go           | 2 +-
 blockchain/v1/reactor.go           | 2 +-
 blockchain/v2/reactor.go           | 2 +-
 consensus/reactor.go               | 2 +-
 evidence/reactor.go                | 2 +-
 mempool/v0/reactor.go              | 2 +-
 mempool/v1/reactor.go              | 2 +-
 p2p/pex/pex_reactor.go             | 2 +-
 p2p/switch_test.go                 | 2 +-
 statesync/reactor.go               | 2 +-
 test/maverick/consensus/reactor.go | 2 +-
 11 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/blockchain/v0/reactor.go b/blockchain/v0/reactor.go
index 2054bf946..0ac278041 100644
--- a/blockchain/v0/reactor.go
+++ b/blockchain/v0/reactor.go
@@ -234,7 +234,7 @@ func (bcR *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (bcR *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *bcproto.Message
+	msg := &bcproto.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/blockchain/v1/reactor.go b/blockchain/v1/reactor.go
index 94ab3ef2a..f6fb93ab8 100644
--- a/blockchain/v1/reactor.go
+++ b/blockchain/v1/reactor.go
@@ -312,7 +312,7 @@ func (bcR *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (bcR *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *bcproto.Message
+	msg := &bcproto.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/blockchain/v2/reactor.go b/blockchain/v2/reactor.go
index 4b3296dfd..f42897485 100644
--- a/blockchain/v2/reactor.go
+++ b/blockchain/v2/reactor.go
@@ -518,7 +518,7 @@ func (r *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (r *BlockchainReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *bcproto.Message
+	msg := &bcproto.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/consensus/reactor.go b/consensus/reactor.go
index 2b99d9aa0..e052f197a 100644
--- a/consensus/reactor.go
+++ b/consensus/reactor.go
@@ -393,7 +393,7 @@ func (conR *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (conR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *tmcons.Message
+	msg := &tmcons.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/evidence/reactor.go b/evidence/reactor.go
index baf4ceb53..d0e843fc1 100644
--- a/evidence/reactor.go
+++ b/evidence/reactor.go
@@ -93,7 +93,7 @@ func (evR *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (evR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *tmproto.EvidenceList
+	msg := &tmproto.EvidenceList{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/mempool/v0/reactor.go b/mempool/v0/reactor.go
index 3ac2e010e..52ed18514 100644
--- a/mempool/v0/reactor.go
+++ b/mempool/v0/reactor.go
@@ -191,7 +191,7 @@ func (memR *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (memR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *protomem.Message
+	msg := &protomem.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/mempool/v1/reactor.go b/mempool/v1/reactor.go
index d16b4bd41..00fe65e79 100644
--- a/mempool/v1/reactor.go
+++ b/mempool/v1/reactor.go
@@ -190,7 +190,7 @@ func (memR *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (memR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *protomem.Message
+	msg := &protomem.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/p2p/pex/pex_reactor.go b/p2p/pex/pex_reactor.go
index ff5f98f01..bcc8c4cce 100644
--- a/p2p/pex/pex_reactor.go
+++ b/p2p/pex/pex_reactor.go
@@ -301,7 +301,7 @@ func (r *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *tmp2p.Message
+	msg := &tmp2p.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/p2p/switch_test.go b/p2p/switch_test.go
index 4e10a61c5..5695d03dd 100644
--- a/p2p/switch_test.go
+++ b/p2p/switch_test.go
@@ -80,7 +80,7 @@ func (tr *TestReactor) ReceiveEnvelope(e Envelope) {
 }
 
 func (tr *TestReactor) Receive(chID byte, peer Peer, msgBytes []byte) {
-	var msg *p2pproto.Message
+	msg := &p2pproto.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/statesync/reactor.go b/statesync/reactor.go
index cedd9204d..835b6313b 100644
--- a/statesync/reactor.go
+++ b/statesync/reactor.go
@@ -226,7 +226,7 @@ func (r *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *ssproto.Message
+	msg := &ssproto.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)
diff --git a/test/maverick/consensus/reactor.go b/test/maverick/consensus/reactor.go
index 6e730721c..31c6db16e 100644
--- a/test/maverick/consensus/reactor.go
+++ b/test/maverick/consensus/reactor.go
@@ -396,7 +396,7 @@ func (conR *Reactor) ReceiveEnvelope(e p2p.Envelope) {
 }
 
 func (conR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) {
-	var msg *tmcons.Message
+	msg := &tmcons.Message{}
 	err := proto.Unmarshal(msgBytes, msg)
 	if err != nil {
 		panic(err)