back to reporting pending positions

lichess-org · Jan 1, 2024 · e592ff4 · e592ff4
1 parent 8fd07d6
commit e592ff4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/logger.rs b/src/logger.rs
@@ -84,7 +84,7 @@ impl Logger {
         P: Into<ProgressAt>,
     {
         let line = format!(
-            "{} {} cores, {} chunks, latest: {}",
+            "{} {} cores, {} queued, latest: {}",
             queue,
             queue.cores,
             queue.pending,

diff --git a/src/queue.rs b/src/queue.rs
@@ -146,7 +146,7 @@ impl QueueState {
 
     fn status_bar(&self) -> QueueStatusBar {
         QueueStatusBar {
-            pending: self.incoming.len(),
+            pending: self.pending.values().map(|p| p.pending()).sum(),
             cores: self.cores,
         }
     }