fix(raft): fix election and network issues in raft event loop

src/main.rs

@@ -429,9 +429,10 @@ async fn main() -> anyhow::Result<()> {
     let raft_config = raft::Config {
         id: config.node_id,
         election_tick: 10,             // 10 ticks = 1 second (100ms per tick)
-        heartbeat_tick: 1,             // 1 tick = 100ms heartbeat
+        heartbeat_tick: 2,             // 2 ticks = 200ms heartbeat
         max_size_per_msg: 1024 * 1024, // 1MB
         max_inflight_msgs: 256,
+        max_committed_size_per_ready: 1024 * 1024, // 1MB — 0 means no entries returned
         ..Default::default()
     };
 

src/raft/handle.rs

@@ -74,6 +74,7 @@ pub trait RaftHandle: Send + Sync + 'static {
 /// Returns `Ok(())` if this node is the leader, `Err` with leader redirect info otherwise.
 pub fn require_leader(raft: &dyn RaftHandle, node_id: NodeId) -> Result<(), Status> {
     let current_leader = raft.leader_id();
+    tracing::info!(node_id = node_id, leader_id = ?current_leader, "require_leader check");
     match current_leader {
         Some(id) if id == node_id => Ok(()),
         Some(leader_id) => {

src/raft/network.rs

@@ -50,8 +50,14 @@ impl NetworkSender {
                 .collect();
 
             for fut in futs {
-                if let Err(e) = fut.await {
-                    tracing::warn!(node_id = self.node_id, error = %e, "failed to send raft message");
+                match fut.await {
+                    Ok(Ok(())) => {}
+                    Ok(Err(e)) => {
+                        tracing::warn!(node_id = self.node_id, error = %e, "failed to send raft message");
+                    }
+                    Err(e) => {
+                        tracing::error!(node_id = self.node_id, error = %e, "send task panicked");
+                    }
                 }
             }
         }
@@ -89,6 +95,17 @@ async fn send_message(
 
     let payload = msg.encode_to_vec();
     let msg_type = MessageType::from_i32(msg.msg_type).unwrap_or(MessageType::MsgHup);
+    let target_addr = addrs.get(&to).cloned().unwrap_or_default();
+
+    tracing::info!(
+        to = to,
+        target_addr = %target_addr,
+        msg_type = ?msg_type,
+        term = msg.term,
+        from = msg.from,
+        payload_len = payload.len(),
+        "sending raft message"
+    );
 
     let mut client = get_or_connect(&clients, &addrs, to).await?;