eric/pmomusic
1
0
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Merge pull request #53 from coissac/claude/audio-ext-flac-http-stream-011CV2DP9Ny4U56rdR5XH6D8

Browse Source 
Reduce verbose logging from INFO to DEBUG/TRACE
This commit is contained in:
coissac
2025-11-12 11:04:10 +01:00
committed by GitHub
parent 4bae8b00dd 8ba6c1365a
commit dc50e5d12b
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pmoaudio-ext/src/sinks/streaming_flac_sink.rs
View File

@@ -752,7 +752,7 @@ async fn broadcast_flac_stream(
Ok(n) => { Ok(n) => {
total_bytes += n as u64; total_bytes += n as u64;
if total_bytes % 100000 == 0 || total_bytes < 10000 { if total_bytes % 100000 == 0 || total_bytes < 10000 {
info!("Read {} bytes from FLAC encoder (total: {})", n, total_bytes); trace!("Read {} bytes from FLAC encoder (total: {})", n, total_bytes);
} }
// Precise pacing based on audio timestamp // Precise pacing based on audio timestamp

6
pmoaudio/src/nodes/timer_node.rs
View File

@@ -137,7 +137,7 @@ impl NodeLogic for TimerNodeLogic {
SyncMarker::TopZeroSync => { SyncMarker::TopZeroSync => {
// Reset le timer de référence // Reset le timer de référence
self.start_time = Some(Instant::now()); self.start_time = Some(Instant::now());
tracing::info!("TimerNodeLogic: TopZeroSync received, timer reset"); tracing::debug!("TimerNodeLogic: TopZeroSync received, timer reset");
} }
_ => { _ => {
// Autres markers: passthrough transparent // Autres markers: passthrough transparent
@@ -156,7 +156,7 @@ impl NodeLogic for TimerNodeLogic {
if lead_time > self.max_lead_time_sec { if lead_time > self.max_lead_time_sec {
// On est trop en avance, attendre // On est trop en avance, attendre
let sleep_duration = lead_time - self.max_lead_time_sec; let sleep_duration = lead_time - self.max_lead_time_sec;
tracing::info!( tracing::trace!(
"TimerNodeLogic: SLEEPING {:.3}s (lead_time={:.3}s > max={:.1}s)", "TimerNodeLogic: SLEEPING {:.3}s (lead_time={:.3}s > max={:.1}s)",
sleep_duration, sleep_duration,
lead_time, lead_time,
@@ -166,7 +166,7 @@ impl NodeLogic for TimerNodeLogic {
tokio::select! { tokio::select! {
_ = tokio::time::sleep(Duration::from_secs_f64(sleep_duration)) => {} _ = tokio::time::sleep(Duration::from_secs_f64(sleep_duration)) => {}
_ = stop_token.cancelled() => { _ = stop_token.cancelled() => {
tracing::info!("TimerNodeLogic cancelled during sleep"); tracing::debug!("TimerNodeLogic cancelled during sleep");
break; break;
} }
} }

6
pmoaudio/src/pipeline.rs
View File

@@ -518,7 +518,7 @@ impl<L: NodeLogic> AudioPipelineNode for Node<L> {
.. ..
} = *self; } = *self;
tracing::info!("Node::run() starting with {} children", children.len()); tracing::debug!("Node::run() starting with {} children", children.len());
// ═══════════════════════════════════════════════════════════════════ // ═══════════════════════════════════════════════════════════════════
// PHASE 1: SPAWNER TOUS LES ENFANTS // PHASE 1: SPAWNER TOUS LES ENFANTS
@@ -526,14 +526,14 @@ impl<L: NodeLogic> AudioPipelineNode for Node<L> {
let mut child_handles = Vec::new(); let mut child_handles = Vec::new();
for (i, child) in children.into_iter().enumerate() { for (i, child) in children.into_iter().enumerate() {
tracing::info!("Spawning child {}", i); tracing::debug!("Spawning child {}", i);
let child_token = stop_token.child_token(); let child_token = stop_token.child_token();
let handle = tokio::spawn(async move { let handle = tokio::spawn(async move {
child.run(child_token).await child.run(child_token).await
}); });
child_handles.push(handle); child_handles.push(handle);
} }
tracing::info!("All {} children spawned", child_handles.len()); tracing::debug!("All {} children spawned", child_handles.len());
// ═══════════════════════════════════════════════════════════════════ // ═══════════════════════════════════════════════════════════════════
// PHASE 2: MONITORER LES ENFANTS EN PARALLÈLE // PHASE 2: MONITORER LES ENFANTS EN PARALLÈLE