From 7fb953c5a30973da9a6319a9698f8905a049a927 Mon Sep 17 00:00:00 2001
From: Claude <noreply@anthropic.com>
Date: Wed, 12 Nov 2025 06:59:24 +0000
Subject: [PATCH] Add INFO-level logging to pipeline and TimerNode for
 debugging

---
 pmoaudio/src/nodes/timer_node.rs | 2 +-
 pmoaudio/src/pipeline.rs         | 9 +++++++--
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/pmoaudio/src/nodes/timer_node.rs b/pmoaudio/src/nodes/timer_node.rs
index 794e3b59..4c4f65f8 100644
--- a/pmoaudio/src/nodes/timer_node.rs
+++ b/pmoaudio/src/nodes/timer_node.rs
@@ -95,7 +95,7 @@ impl NodeLogic for TimerNodeLogic {
         stop_token: CancellationToken,
     ) -> Result<(), AudioError> {
         let mut rx = input.expect("TimerNode must have input");
-        tracing::debug!(
+        tracing::info!(
             "TimerNodeLogic::process started (max_lead_time={:.1}s), {} children",
             self.max_lead_time_sec,
             output.len()
diff --git a/pmoaudio/src/pipeline.rs b/pmoaudio/src/pipeline.rs
index 7cffac38..c400e5fd 100755
--- a/pmoaudio/src/pipeline.rs
+++ b/pmoaudio/src/pipeline.rs
@@ -518,18 +518,22 @@ impl<L: NodeLogic> AudioPipelineNode for Node<L> {
             ..
         } = *self;
 
+        tracing::info!("Node::run() starting with {} children", children.len());
+
         // ═══════════════════════════════════════════════════════════════════
         // PHASE 1: SPAWNER TOUS LES ENFANTS
         // ═══════════════════════════════════════════════════════════════════
 
         let mut child_handles = Vec::new();
-        for child in children {
+        for (i, child) in children.into_iter().enumerate() {
+            tracing::info!("Spawning child {}", i);
             let child_token = stop_token.child_token();
             let handle = tokio::spawn(async move {
                 child.run(child_token).await
             });
             child_handles.push(handle);
         }
+        tracing::info!("All {} children spawned", child_handles.len());
 
         // ═══════════════════════════════════════════════════════════════════
         // PHASE 2: MONITORER LES ENFANTS EN PARALLÈLE
@@ -626,9 +630,10 @@ impl<L: NodeLogic> AudioPipelineNode for Node<L> {
 
                 // Logique métier du nœud
                 process_result = logic.process(rx, child_txs.clone(), stop_token.clone()) => {
+                    tracing::info!("Node logic.process() returned");
                     match process_result {
                         Ok(()) => {
-                            tracing::debug!("Node process completed successfully");
+                            tracing::info!("Node process completed successfully");
                             (StopReason::Completed, Ok(()), false)
                         }
                         Err(e) => {