Merge branch 'fix-mempool-spam' into test/abci-routing

dashpay · Feb 14, 2024 · 160fc86 · 160fc86
2 parents cc8bbb1 + 1870ef9
commit 160fc86
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/mempool/reactor.go b/internal/mempool/reactor.go
@@ -205,6 +205,9 @@ func (r *Reactor) broadcastTxRoutine(ctx context.Context, peerID types.NodeID) {
 				r.logger.Error("failed to gossip transaction", "peerID", peerID, "error", err)
 				return
 			}
+			// This is optimistic approach, we assume that the transaction was successfully
+			// gossiped to the peer.
+			memTx.SetPeer(peerMempoolID)
 
 			r.logger.Debug("gossiped tx to peer",
 				"tx", tmstrings.LazySprintf("%X", memTx.tx.Hash()),