diff --git a/crates/net/downloaders/src/bodies/request.rs b/crates/net/downloaders/src/bodies/request.rs index aa455f579..149d476b9 100644 --- a/crates/net/downloaders/src/bodies/request.rs +++ b/crates/net/downloaders/src/bodies/request.rs @@ -25,7 +25,7 @@ use std::{ /// If the response arrived with insufficient number of bodies, the future /// will issue another request until all bodies are collected. /// -/// It then proceeds to verify the downloaded bodies. In case of an validation error, +/// It then proceeds to verify the downloaded bodies. In case of a validation error, /// the future will start over. /// /// The future will filter out any empty headers (see [`alloy_consensus::Header::is_empty`]) from diff --git a/crates/net/downloaders/src/headers/task.rs b/crates/net/downloaders/src/headers/task.rs index f2084de87..5253ca565 100644 --- a/crates/net/downloaders/src/headers/task.rs +++ b/crates/net/downloaders/src/headers/task.rs @@ -175,7 +175,7 @@ impl Future for SpawnedDownloader { } } -/// Commands delegated tot the spawned [`HeaderDownloader`] +/// Commands delegated to the spawned [`HeaderDownloader`] enum DownloaderUpdates { UpdateSyncGap(SealedHeader, SyncTarget), UpdateLocalHead(SealedHeader), diff --git a/crates/net/downloaders/src/metrics.rs b/crates/net/downloaders/src/metrics.rs index 5f705ea48..fb990d5b5 100644 --- a/crates/net/downloaders/src/metrics.rs +++ b/crates/net/downloaders/src/metrics.rs @@ -30,7 +30,7 @@ pub struct BodyDownloaderMetrics { pub buffered_responses: Gauge, /// The number of blocks the internal buffer of the /// downloader. - /// These are bodies that have been received, but not cannot be committed yet because they're + /// These are bodies that have been received, but cannot be committed yet because they're /// not contiguous pub buffered_blocks: Gauge, /// Total amount of memory used by the buffered blocks in bytes @@ -101,7 +101,7 @@ pub struct HeaderDownloaderMetrics { pub buffered_responses: Gauge, /// The number of blocks the internal buffer of the /// downloader. - /// These are bodies that have been received, but not cannot be committed yet because they're + /// These are bodies that have been received, but cannot be committed yet because they're /// not contiguous pub buffered_blocks: Gauge, /// Total amount of memory used by the buffered blocks in bytes diff --git a/crates/net/eth-wire/src/protocol.rs b/crates/net/eth-wire/src/protocol.rs index b9d2eed61..13c39d46e 100644 --- a/crates/net/eth-wire/src/protocol.rs +++ b/crates/net/eth-wire/src/protocol.rs @@ -1,4 +1,4 @@ -//! A Protocol defines a P2P subprotocol in a `RLPx` connection +//! A Protocol defines a P2P subprotocol in an `RLPx` connection use crate::{Capability, EthMessageID, EthVersion}; diff --git a/crates/net/eth-wire/src/test_utils.rs b/crates/net/eth-wire/src/test_utils.rs index 56656d60e..7a2b934b4 100644 --- a/crates/net/eth-wire/src/test_utils.rs +++ b/crates/net/eth-wire/src/test_utils.rs @@ -60,7 +60,7 @@ pub async fn connect_passthrough( p2p_stream } -/// A Rplx subprotocol for testing +/// An Rplx subprotocol for testing pub mod proto { use super::*; use crate::{protocol::Protocol, Capability}; diff --git a/crates/net/network/src/session/handle.rs b/crates/net/network/src/session/handle.rs index 2d72c87aa..ed465d33e 100644 --- a/crates/net/network/src/session/handle.rs +++ b/crates/net/network/src/session/handle.rs @@ -48,7 +48,7 @@ impl PendingSessionHandle { /// An established session with a remote peer. /// -/// Within an active session that supports the `Ethereum Wire Protocol `, three high-level tasks can +/// Within an active session that supports the `Ethereum Wire Protocol`, three high-level tasks can /// be performed: chain synchronization, block propagation and transaction exchange. #[derive(Debug)] pub struct ActiveSessionHandle {