From 2e73e213c4197adf987d3d06cebc1fcc9c2872d6 Mon Sep 17 00:00:00 2001
From: Dan Cline <6798349+Rjected@users.noreply.github.com>
Date: Fri, 3 Nov 2023 16:12:33 -0400
Subject: [PATCH] chore(downloaders): add traces when not pushing new requests

---
 crates/net/downloaders/src/bodies/bodies.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/crates/net/downloaders/src/bodies/bodies.rs b/crates/net/downloaders/src/bodies/bodies.rs
index 9b9fcb2b60..e0c4d4d748 100644
--- a/crates/net/downloaders/src/bodies/bodies.rs
+++ b/crates/net/downloaders/src/bodies/bodies.rs
@@ -100,6 +100,7 @@ where
         max_non_empty: u64,
     ) -> DownloadResult<Option<Vec<SealedHeader>>> {
         if range.is_empty() || max_non_empty == 0 {
+            tracing::trace!(target: "downloaders::bodies", ?range, max_non_empty, "No more headers to request");
             return Ok(None)
         }
 
@@ -405,7 +406,10 @@ where
                         );
                         new_request_submitted = true;
                     }
-                    Ok(None) => break 'inner,
+                    Ok(None) => {
+                        tracing::trace!(target: "downloaders::bodies", last_requested_block_number=this.in_progress_queue.last_requested_block_number, "Not pushing new requests");
+                        break 'inner;
+                    }
                     Err(error) => {
                         tracing::error!(target: "downloaders::bodies", ?error, "Failed to download from next request");
                         this.clear();
@@ -429,6 +433,7 @@ where
         // All requests are handled, stream is finished
         if this.in_progress_queue.is_empty() {
             if this.queued_bodies.is_empty() {
+                tracing::trace!(target: "downloaders::bodies", "Yielding empty batch");
                 return Poll::Ready(None)
             }
             let batch_size = this.stream_batch_size.min(this.queued_bodies.len());