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 25, 2023 · 36cee60 · 36cee60
1 parent aff1487
commit 36cee60
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mempool/v1/reactor.go b/mempool/v1/reactor.go
@@ -282,6 +282,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)
 			}
 			schema.WriteMempoolTx(
 				memR.traceClient,