mirror of
https://github.com/jmcorgan/fips.git
synced 2026-08-09 08:14:42 +00:00
Logging level overhaul: reduce verbosity at info and debug levels
Per-packet happy-path events (UDP send/receive, TUN I/O, MMP report processing, TreeAnnounce/FilterAnnounce sent, RTT samples) moved from debug to trace. Periodic maintenance and retry scheduling moved from info to debug. Session state changes (established, initiated, torn down) and transport stop promoted from debug to info. MMP report send failures demoted from warn to debug (normal under churn).
This commit is contained in:
+3
-3
@@ -9,7 +9,7 @@ use crate::NodeAddr;
|
||||
|
||||
use super::{Node, NodeError};
|
||||
use std::collections::HashMap;
|
||||
use tracing::{debug, info};
|
||||
use tracing::{debug, trace};
|
||||
|
||||
impl Node {
|
||||
/// Collect inbound filters from all peers for outgoing filter computation.
|
||||
@@ -77,7 +77,7 @@ impl Node {
|
||||
peer.clear_filter_update_needed();
|
||||
}
|
||||
|
||||
debug!(peer = %peer_addr, seq = announce.sequence, "Sent FilterAnnounce");
|
||||
trace!(peer = %peer_addr, seq = announce.sequence, "Sent FilterAnnounce");
|
||||
Ok(())
|
||||
}
|
||||
|
||||
@@ -161,7 +161,7 @@ impl Node {
|
||||
peer.update_filter(announce.filter, announce.sequence, now_ms);
|
||||
}
|
||||
|
||||
info!(
|
||||
debug!(
|
||||
from = %from,
|
||||
seq = announce.sequence,
|
||||
"Received FilterAnnounce"
|
||||
|
||||
@@ -13,7 +13,7 @@ use crate::protocol::{
|
||||
};
|
||||
use crate::NodeAddr;
|
||||
use std::time::Instant;
|
||||
use tracing::{debug, info, warn};
|
||||
use tracing::{debug, info, trace};
|
||||
|
||||
/// Format bytes/sec as human-readable throughput.
|
||||
fn format_throughput(bps: f64) -> String {
|
||||
@@ -55,7 +55,7 @@ impl Node {
|
||||
return;
|
||||
}
|
||||
|
||||
debug!(
|
||||
trace!(
|
||||
from = %from,
|
||||
cum_pkts = sr.cumulative_packets_sent,
|
||||
interval_bytes = sr.interval_bytes_sent,
|
||||
@@ -116,7 +116,7 @@ impl Node {
|
||||
mmp.metrics.set_delivery_ratio_reverse(reverse_ratio);
|
||||
}
|
||||
|
||||
debug!(
|
||||
trace!(
|
||||
from = %from,
|
||||
rtt_ms = ?mmp.metrics.srtt_ms(),
|
||||
loss = format_args!("{:.1}%", mmp.metrics.loss_rate() * 100.0),
|
||||
@@ -168,13 +168,13 @@ impl Node {
|
||||
// Send collected reports
|
||||
for (node_addr, encoded) in sender_reports {
|
||||
if let Err(e) = self.send_encrypted_link_message(&node_addr, &encoded).await {
|
||||
warn!(peer = %node_addr, error = %e, "Failed to send SenderReport");
|
||||
debug!(peer = %node_addr, error = %e, "Failed to send SenderReport");
|
||||
}
|
||||
}
|
||||
|
||||
for (node_addr, encoded) in receiver_reports {
|
||||
if let Err(e) = self.send_encrypted_link_message(&node_addr, &encoded).await {
|
||||
warn!(peer = %node_addr, error = %e, "Failed to send ReceiverReport");
|
||||
debug!(peer = %node_addr, error = %e, "Failed to send ReceiverReport");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -22,7 +22,7 @@ use crate::protocol::{
|
||||
};
|
||||
use crate::NodeAddr;
|
||||
use secp256k1::PublicKey;
|
||||
use tracing::debug;
|
||||
use tracing::{debug, info, trace};
|
||||
|
||||
impl Node {
|
||||
/// Handle a locally-delivered session datagram payload.
|
||||
@@ -160,7 +160,7 @@ impl Node {
|
||||
entry.set_coords_warmup_remaining(self.config.node.session.coords_warmup_packets);
|
||||
entry.mark_established(Self::now_ms());
|
||||
entry.init_mmp(&self.config.node.session_mmp);
|
||||
debug!(src = %src_addr, "Session established (responder, on first encrypted message)");
|
||||
info!(src = %src_addr, "Session established (responder, on first encrypted message)");
|
||||
}
|
||||
|
||||
// Decrypt with AAD = the 12-byte header
|
||||
@@ -235,7 +235,7 @@ impl Node {
|
||||
debug!(error = %e, "Failed to deliver decrypted packet to TUN");
|
||||
}
|
||||
} else {
|
||||
debug!(
|
||||
trace!(
|
||||
src = %src_addr,
|
||||
"DataPacket decrypted (no TUN interface, plaintext dropped)"
|
||||
);
|
||||
@@ -434,7 +434,7 @@ impl Node {
|
||||
// Flush any queued outbound packets for this destination
|
||||
self.flush_pending_packets(src_addr).await;
|
||||
|
||||
debug!(src = %src_addr, "Session established (initiator)");
|
||||
info!(src = %src_addr, "Session established (initiator)");
|
||||
}
|
||||
|
||||
// === Session-layer MMP report handlers ===
|
||||
@@ -452,7 +452,7 @@ impl Node {
|
||||
}
|
||||
};
|
||||
|
||||
debug!(
|
||||
trace!(
|
||||
src = %src_addr,
|
||||
cum_pkts = sr.cumulative_packets_sent,
|
||||
interval_bytes = sr.interval_bytes_sent,
|
||||
@@ -519,7 +519,7 @@ impl Node {
|
||||
mmp.metrics.set_delivery_ratio_reverse(reverse_ratio);
|
||||
}
|
||||
|
||||
debug!(
|
||||
trace!(
|
||||
src = %src_addr,
|
||||
rtt_ms = ?mmp.metrics.srtt_ms(),
|
||||
loss = format_args!("{:.1}%", mmp.metrics.loss_rate() * 100.0),
|
||||
@@ -703,7 +703,7 @@ impl Node {
|
||||
let entry = SessionEntry::new(dest_addr, dest_pubkey, EndToEndState::Initiating(handshake), now_ms, true);
|
||||
self.sessions.insert(dest_addr, entry);
|
||||
|
||||
debug!(dest = %dest_addr, "Session initiation started");
|
||||
info!(dest = %dest_addr, "Session initiation started");
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
||||
@@ -166,13 +166,13 @@ impl Node {
|
||||
.map(|a| format!(" ({})", a))
|
||||
.unwrap_or_default();
|
||||
|
||||
info!("Peer connection initiated{}", alias_display);
|
||||
info!(" npub: {}", peer_config.npub);
|
||||
info!(" node_addr: {}", peer_node_addr);
|
||||
info!(" transport: {}", addr.transport);
|
||||
info!(" addr: {}", addr.addr);
|
||||
info!(" link_id: {}", link_id);
|
||||
info!(" our_index: {}", our_index);
|
||||
debug!("Peer connection initiated{}", alias_display);
|
||||
debug!(" npub: {}", peer_config.npub);
|
||||
debug!(" node_addr: {}", peer_node_addr);
|
||||
debug!(" transport: {}", addr.transport);
|
||||
debug!(" addr: {}", addr.addr);
|
||||
debug!(" link_id: {}", link_id);
|
||||
debug!(" our_index: {}", our_index);
|
||||
|
||||
// Track in pending_outbound for msg2 dispatch
|
||||
self.pending_outbound.insert((transport_id, our_index.as_u32()), link_id);
|
||||
|
||||
+3
-3
@@ -79,7 +79,7 @@ impl Node {
|
||||
}
|
||||
let delay = state.backoff_ms(base_interval_ms, max_backoff_ms);
|
||||
state.retry_after_ms = now_ms + delay;
|
||||
info!(
|
||||
debug!(
|
||||
node_addr = %node_addr,
|
||||
retry = state.retry_count,
|
||||
delay_secs = delay / 1000,
|
||||
@@ -102,7 +102,7 @@ impl Node {
|
||||
state.retry_count = 1;
|
||||
let delay = state.backoff_ms(base_interval_ms, max_backoff_ms);
|
||||
state.retry_after_ms = now_ms + delay;
|
||||
info!(
|
||||
debug!(
|
||||
node_addr = %node_addr,
|
||||
delay_secs = delay / 1000,
|
||||
"First connection attempt failed, scheduling retry"
|
||||
@@ -144,7 +144,7 @@ impl Node {
|
||||
None => continue,
|
||||
};
|
||||
|
||||
info!(
|
||||
debug!(
|
||||
node_addr = %node_addr,
|
||||
retry = state.retry_count,
|
||||
"Attempting connection retry"
|
||||
|
||||
+2
-2
@@ -7,7 +7,7 @@ use crate::protocol::TreeAnnounce;
|
||||
use crate::NodeAddr;
|
||||
|
||||
use super::{Node, NodeError};
|
||||
use tracing::{debug, info, warn};
|
||||
use tracing::{debug, info, trace, warn};
|
||||
|
||||
impl Node {
|
||||
/// Build a TreeAnnounce from our current tree state.
|
||||
@@ -68,7 +68,7 @@ impl Node {
|
||||
peer.record_tree_announce_sent(now_ms);
|
||||
}
|
||||
|
||||
debug!(peer = %peer_addr, "Sent TreeAnnounce");
|
||||
trace!(peer = %peer_addr, "Sent TreeAnnounce");
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user