diff --git a/ctxc/fetcher/tx_fetcher.go b/ctxc/fetcher/tx_fetcher.go index 73d51bd4c5..2b7c2d0193 100644 --- a/ctxc/fetcher/tx_fetcher.go +++ b/ctxc/fetcher/tx_fetcher.go @@ -322,9 +322,9 @@ func (f *TxFetcher) Enqueue(peer string, txs []*types.Transaction, direct bool) otherRejectMeter.Mark(otherreject) // If 'other reject' is >25% of the deliveries in any batch, sleep a bit. - if otherreject > addTxsBatchSize/4 { + if otherreject > int64((len(batch)+3)/4) { + log.Debug("Peer delivering stale or invalid transactions", "peer", peer, "rejected", otherreject) time.Sleep(200 * time.Millisecond) - log.Trace("Peer delivering stale transactions", "peer", peer, "rejected", otherreject) } } select {