diff --git a/src/raft/node.rs b/src/raft/node.rs index 5a6b767..72573fd 100644 --- a/src/raft/node.rs +++ b/src/raft/node.rs @@ -325,7 +325,12 @@ fn raft_event_loop( // Step incoming raft messages. if !msgs.is_empty() { - tracing::info!(node_id = config.id, messages_count = msgs.len(), "stepping {} messages", msgs.len()); + tracing::info!( + node_id = config.id, + messages_count = msgs.len(), + "stepping {} messages", + msgs.len() + ); } for msg in msgs { if let Err(e) = node.step(msg) { @@ -419,7 +424,6 @@ fn raft_event_loop( // Process all available ready states before blocking again. while node.has_ready() { - let mut ready = node.ready(); // Step 1: Send outgoing messages from Leader BEFORE persisting. @@ -427,7 +431,10 @@ fn raft_event_loop( // Only Leader has messages in take_messages(); Follower messages come from take_persisted_messages(). let mut messages = ready.take_messages(); if !messages.is_empty() { - tracing::info!(messages_count = messages.len(), "sending leader messages before persistence"); + tracing::info!( + messages_count = messages.len(), + "sending leader messages before persistence" + ); for msg in &messages { tracing::debug!(from = msg.from, to = msg.to, msg_type = ?raft::eraftpb::MessageType::from_i32(msg.msg_type), "leader outgoing message"); } @@ -453,7 +460,10 @@ fn raft_event_loop( // Step 2: Persist entries to the log store. if !ready.entries().is_empty() { - tracing::info!(entries_count = ready.entries().len(), "persisting entries from Ready"); + tracing::info!( + entries_count = ready.entries().len(), + "persisting entries from Ready" + ); if let Err(e) = node.store().append_entries(ready.entries()) { tracing::error!(error = %e, "failed to persist entries"); return; @@ -471,7 +481,10 @@ fn raft_event_loop( // Step 4: Send persisted messages (mainly for Follower nodes). let persisted_msgs = ready.take_persisted_messages(); if !persisted_msgs.is_empty() { - tracing::info!(persisted_count = persisted_msgs.len(), "sending persisted messages"); + tracing::info!( + persisted_count = persisted_msgs.len(), + "sending persisted messages" + ); for msg in &persisted_msgs { tracing::debug!(from = msg.from, to = msg.to, msg_type = ?raft::eraftpb::MessageType::from_i32(msg.msg_type), "persisted outgoing message"); } @@ -511,7 +524,10 @@ fn raft_event_loop( // Step 6b: Send messages from LightReady (may contain responses after advance). let light_msgs = light_ready.take_messages(); if !light_msgs.is_empty() { - tracing::info!(messages_count = light_msgs.len(), "sending messages from LightReady"); + tracing::info!( + messages_count = light_msgs.len(), + "sending messages from LightReady" + ); let _ = msg_out_tx.blocking_send(light_msgs); }