feat: mempool v1 records which peer it has sent the tx (#1089)

This PR records that we have sent the peer the transaction to avoid doing it a second time
celestiaorg · Sep 22, 2023 · 43db8d0 · 43db8d0
1 parent 86e67b7
commit 43db8d0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mempool/v1/reactor.go b/mempool/v1/reactor.go
@@ -269,6 +269,10 @@ func (memR *Reactor) broadcastTxRoutine(peer p2p.Peer) {
 			if !success {
 				time.Sleep(mempool.PeerCatchupSleepIntervalMS * time.Millisecond)
 				continue
+			} else {
+				// record that we have sent the peer the transaction
+				// to avoid doing it a second time
+				memTx.SetPeer(peerID)
 			}
 		}