jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(downloaders): remove backoff logic (#823)

Browse Source 
Co-authored-by: Enrique Ortiz <evalir@users.noreply.github.com>
This commit is contained in:
Enrique Ortiz
2023-01-11 15:38:29 -04:00
committed by GitHub
parent 20ee1bb1c9
commit 70e528857a
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
crates/net/downloaders/src/bodies/concurrent.rs
View File

@ -1,4 +1,4 @@
use backon::{ExponentialBackoff, Retryable};
use backon::{ConstantBackoff, Retryable};
use futures_util::{stream, StreamExt, TryStreamExt};
use reth_interfaces::{
consensus::Consensus as ConsensusTrait,
@ -12,7 +12,7 @@ use reth_interfaces::{
},
};
use reth_primitives::{SealedBlock, SealedHeader};
use std::{borrow::Borrow, sync::Arc};
use std::{borrow::Borrow, sync::Arc, time::Duration};
/// Downloads bodies in batches.
///
@ -64,7 +64,14 @@ where
.chunks(self.batch_size)
.map(move |headers| {
(move || self.fetch_bodies(headers.clone()))
.retry(ExponentialBackoff::default().with_max_times(self.retries))
// We should not backoff from requests since the downloader does
// not know what peer the request is being delivered to.
// See: https://github.com/paradigmxyz/reth/issues/809
.retry(
ConstantBackoff::default()
.with_delay(Duration::from_secs(0))
.with_max_times(self.retries),
)
})
.buffered(self.concurrency)
.map_ok(|blocks| stream::iter(blocks.into_iter()).map(Ok))