Log thread name and number of socket retries in stats output.

int08h · May 29, 2024 · ecb9716 · ecb9716
1 parent c3703d9
commit ecb9716
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/src/server.rs b/src/server.rs
@@ -288,20 +288,22 @@ impl Server {
 
         for (addr, counts) in vec {
             info!(
-                "{:16}: {} classic req, {} rfc req; {} invalid requests; {} classic resp, {} rfc resp ({} sent); {} failed sends",
+                "{:16}: {} classic req, {} rfc req; {} invalid requests; {} classic resp, {} rfc resp ({} sent); {} failed sends, {} retried sends",
                 format!("{}", addr),
                 counts.classic_requests,
                 counts.rfc_requests,
                 counts.invalid_requests,
                 counts.classic_responses_sent,
                 counts.rfc_responses_sent,
                 counts.bytes_sent.file_size(fsopts::BINARY).unwrap(),
-                counts.failed_send_attempts
+                counts.failed_send_attempts,
+                counts.retried_send_attempts
             );
         }
 
         info!(
-            "Totals: {} unique clients; {} total req ({} classic req, {} rfc req); {} invalid requests; {} total resp ({} classic resp, {} rfc resp); {} sent; {} failed sends",
+            "{} Totals: {} unique clients; {} total req ({} classic req, {} rfc req); {} invalid requests; {} total resp ({} classic resp, {} rfc resp); {} sent; {} failed sends, {} retried sends",
+            self.thread_name(),
             self.stats.total_unique_clients(),
             self.stats.total_valid_requests(),
             self.stats.num_classic_requests(),
@@ -311,7 +313,8 @@ impl Server {
             self.stats.num_classic_responses_sent(),
             self.stats.num_rfc_responses_sent(),
             self.stats.total_bytes_sent().file_size(fsopts::BINARY).unwrap(),
-            self.stats.total_failed_send_attempts()
+            self.stats.total_failed_send_attempts(),
+            self.stats.total_retried_send_attempts()
         );
 
         self.stats.clear();