Fix missing docs

crates/net/eth-wire/src/types/broadcast.rs

@@ -5,7 +5,7 @@ use alloy_rlp::{
     Decodable, Encodable, RlpDecodable, RlpDecodableWrapper, RlpEncodable, RlpEncodableWrapper,
 };
 
-use derive_more::{Constructor, Deref, DerefMut, IntoIterator, From};
+use derive_more::{Constructor, Deref, DerefMut, From, IntoIterator};
 use reth_codecs::derive_arbitrary;
 use reth_primitives::{
     Block, Bytes, PooledTransactionsElement, TransactionSigned, TxHash, B256, U128,
@@ -656,7 +656,7 @@ impl<V> PartiallyValidData<V> {
 }
 
 /// Partially validated data from an announcement or a
-[`PooledTransactions`](crate::PooledTransactions) response.
+/// [`PooledTransactions`](crate::PooledTransactions) response.
 #[derive(Debug, Deref, DerefMut, IntoIterator, From)]
 #[from(PartiallyValidData<Eth68TxMetadata>)]
 pub struct ValidAnnouncementData {

crates/net/network/src/transactions/fetcher.rs

@@ -931,7 +931,7 @@ impl TransactionFetcher {
 
                 self.remove_hashes_from_transaction_fetcher(fetched);
                 // buffer left over hashes
-                self.buffer_hashes_for_retry(requested_hashes, &peer_id);
+                self.try_buffer_hashes_for_retry(requested_hashes, &peer_id);
 
                 let transactions =
                     valid_payload.into_data().into_values().collect::<PooledTransactions>();
@@ -1096,11 +1096,13 @@ impl Future for GetPooledTxRequestFut {
     }
 }
 
+/// Wrapper of unverified [`PooledTransactions`].
 #[derive(Debug, Constructor, Deref)]
 pub struct UnverifiedPooledTransactions {
     txns: PooledTransactions,
 }
 
+/// [`PooledTransactions`] that have been successfully verified.
 #[derive(Debug, Constructor)]
 pub struct VerifiedPooledTransactions {
     txns: PooledTransactions,

crates/net/network/src/transactions/mod.rs

@@ -573,7 +573,7 @@ where
     fn on_new_pooled_transaction_hashes(
         &mut self,
         peer_id: PeerId,
-        mut msg: NewPooledTransactionHashes,
+        msg: NewPooledTransactionHashes,
         cx: &mut Context<'_>,
     ) {
         // If the node is initially syncing, ignore transactions
@@ -641,7 +641,7 @@ where
         // most hashes will be filtered out here since this the mempool protocol is a gossip
         // protocol, healthy peers will send many of the same hashes.
         //
-        let already_known_by_pool = self.pool.retain_unknown(&mut msg);
+        let already_known_by_pool = self.pool.retain_unknown(&mut partially_valid_msg);
         if let Some(intersection) = already_known_by_pool {
             self.metrics.occurrences_hashes_already_in_pool.increment(intersection.len() as u64);
         }