diff --git a/mempool/v1/reactor.go b/mempool/v1/reactor.go index 029faf7e55..99498865c7 100644 --- 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,