enable logging when there is 0 pipeline usage

tari-project · Sep 14, 2022 · 6867013 · 6867013
1 parent f16051b
commit 6867013
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 18 deletions.
diff --git a/comms/core/src/pipeline/inbound.rs b/comms/core/src/pipeline/inbound.rs
@@ -88,15 +88,12 @@ where
 
             let num_available = self.executor.num_available();
             let max_available = self.executor.max_available();
-            // Only emit this message if there is any concurrent usage
-            if num_available < max_available {
-                debug!(
-                    target: LOG_TARGET,
-                    "Inbound pipeline usage: {}/{}",
-                    max_available - num_available,
-                    max_available
-                );
-            }
+            debug!(
+                target: LOG_TARGET,
+                "Inbound pipeline usage: {}/{}",
+                max_available - num_available,
+                max_available
+            );
 
             let id = current_id;
             current_id = (current_id + 1) % u64::MAX;

diff --git a/comms/core/src/pipeline/outbound.rs b/comms/core/src/pipeline/outbound.rs
@@ -62,15 +62,12 @@ where
             // Pipeline IN received a message. Spawn a new task for the pipeline
             let num_available = self.executor.num_available();
             if let Some(max_available) = self.executor.max_available() {
-                // Only emit this message if there is any concurrent usage
-                if num_available < max_available {
-                    debug!(
-                        target: LOG_TARGET,
-                        "Outbound pipeline usage: {}/{}",
-                        max_available - num_available,
-                        max_available
-                    );
-                }
+                debug!(
+                    target: LOG_TARGET,
+                    "Outbound pipeline usage: {}/{}",
+                    max_available - num_available,
+                    max_available
+                );
             }
             let pipeline = self.config.pipeline.clone();
             let id = current_id;