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: retry empty responses (#13923)

Browse Source
This commit is contained in:
Matthias Seitz
2025-01-22 19:29:22 +01:00
committed by GitHub
parent 82a0734c19
commit 22a5c10a07
2 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
crates/cli/commands/src/stage/run.rs
View File

@ -45,8 +45,7 @@ use reth_stages::{
IndexStorageHistoryStage, MerkleStage, SenderRecoveryStage, StorageHashingStage,
TransactionLookupStage,
},
ExecInput, ExecOutput, ExecutionStageThresholds, Stage, StageError, StageExt, UnwindInput,
UnwindOutput,
ExecInput, ExecOutput, ExecutionStageThresholds, Stage, StageExt, UnwindInput, UnwindOutput,
};
use std::{any::Any, net::SocketAddr, sync::Arc, time::Instant};
use tokio::sync::watch;
@ -190,16 +189,18 @@ impl<C: ChainSpecParser<ChainSpec: EthChainSpec + Hardforks + EthereumHardforks>
// Use `to` as the tip for the stage
let tip: P::BlockHeader = loop {
match fetch_client.get_header(BlockHashOrNumber::Number(self.to)).await {
Ok(header) => break header,
Err(error) if error.is_retryable() => {
warn!(target: "reth::cli", "Error requesting header: {error}. Retrying...")
match fetch_client.get_header(BlockHashOrNumber::Number(self.to)).await {
Ok(header) => {
if let Some(header) = header.into_data() {
break header
}
Err(error) => return Err(error.into()),
}
Err(error) if error.is_retryable() => {
warn!(target: "reth::cli", "Error requesting header: {error}. Retrying...")
}
Err(error) => return Err(error.into()),
}
.into_data()
.ok_or(StageError::MissingSyncGap)?;
};
let (_, rx) = watch::channel(tip.hash_slow());
(
Box::new(HeaderStage::new(

2
crates/net/p2p/src/headers/client.rs
View File

@ -94,6 +94,8 @@ pub trait HeadersClient: DownloadClient {
}
/// A Future that resolves to a single block body.
///
/// Returns `None` if the peer responded with an empty header response.
#[derive(Debug)]
#[must_use = "futures do nothing unless polled"]
pub struct SingleHeaderRequest<Fut> {