diff --git a/crates/corro-agent/src/agent/util.rs b/crates/corro-agent/src/agent/util.rs index fd06cebe..f5749917 100644 --- a/crates/corro-agent/src/agent/util.rs +++ b/crates/corro-agent/src/agent/util.rs @@ -1318,7 +1318,8 @@ pub fn check_buffered_meta_to_clear( } pub fn log_at_pow_10(msg: &str, count: &mut u64) { - if is_pow_10(*count + 1) { + *count += 1; + if is_pow_10(*count) { warn!("{} (log count: {})", msg, count) } // reset count diff --git a/crates/corro-agent/src/broadcast/mod.rs b/crates/corro-agent/src/broadcast/mod.rs index bfc18c95..c7ed2de4 100644 --- a/crates/corro-agent/src/broadcast/mod.rs +++ b/crates/corro-agent/src/broadcast/mod.rs @@ -615,7 +615,7 @@ async fn handle_broadcasts( } if drop_oldest_broadcast(&mut to_broadcast, max_queue_len).is_some() { - log_at_pow_10("dropped old change from queue", &mut log_count); + log_at_pow_10("dropped old change from broadcast queue", &mut log_count); } }