Skip to content

Commit

Permalink
Merge pull request #2975 from iotaledger/workaround-disable-req-rebro…
Browse files Browse the repository at this point in the history
…adcast

Workaround: Disable request re-broadcast.
  • Loading branch information
fijter authored Oct 24, 2023
2 parents 113341e + d188714 commit 46bcaeb
Showing 1 changed file with 9 additions and 7 deletions.
16 changes: 9 additions & 7 deletions packages/chain/mempool/mempool.go
Original file line number Diff line number Diff line change
Expand Up @@ -882,13 +882,15 @@ func (mpi *mempoolImpl) handleDistSyncTimeTick() {
// Re-send off-ledger messages that are hanging here for a long time.
// Probably not a lot of nodes have them.
func (mpi *mempoolImpl) handleRePublishTimeTick() {
retryOlder := time.Now().Add(-distShareRePublishTick)
mpi.offLedgerPool.Filter(func(request isc.OffLedgerRequest, ts time.Time) bool {
if ts.Before(retryOlder) {
mpi.sendMessages(mpi.distSync.Input(distsync.NewInputPublishRequest(request)))
}
return true
})
mpi.log.Debugf("Skipping the re-publish step.") // TODO: Temporarily disabled.

// retryOlder := time.Now().Add(-distShareRePublishTick)
// mpi.offLedgerPool.Filter(func(request isc.OffLedgerRequest, ts time.Time) bool {
// if ts.Before(retryOlder) {
// mpi.sendMessages(mpi.distSync.Input(distsync.NewInputPublishRequest(request)))
// }
// return true
// })
}

func (mpi *mempoolImpl) tryReAddRequest(req isc.Request) {
Expand Down

0 comments on commit 46bcaeb

Please sign in to comment.