@@ -19,7 +19,7 @@ use lighthouse_tracing::{
1919} ;
2020use methods:: LightClientUpdatesByRangeRequest ;
2121use slot_clock:: SlotClock ;
22- use std:: collections:: { HashMap , hash_map:: Entry } ;
22+ use std:: collections:: { HashMap , HashSet , hash_map:: Entry } ;
2323use std:: sync:: Arc ;
2424use tokio_stream:: StreamExt ;
2525use tracing:: { Span , debug, error, field, instrument, warn} ;
@@ -293,6 +293,9 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
293293 inbound_request_id : InboundRequestId ,
294294 request : BlobsByRootRequest ,
295295 ) -> Result < ( ) , ( RpcErrorResponse , & ' static str ) > {
296+ let requested_roots: HashSet < Hash256 > =
297+ request. blob_ids . iter ( ) . map ( |id| id. block_root ) . collect ( ) ;
298+
296299 let mut send_blob_count = 0 ;
297300
298301 let fulu_start_slot = self
@@ -379,7 +382,7 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
379382
380383 debug ! (
381384 %peer_id,
382- block_root = ?slots_by_block_root . keys ( ) ,
385+ ?requested_roots ,
383386 returned = send_blob_count,
384387 "BlobsByRoot outgoing response processed"
385388 ) ;
0 commit comments