raft leader hangs log replication until next heart beat about openraft HOT 4 CLOSED

    1 pub async fn line_rate_loop(&mut self) -> Result<(), ReplicationError> {
    2     loop {
    3         loop {
    4             let res = self.send_append_entries().await;
    5
    6             if let Err(err) = res {...}
    7
    8             if self.matched.index == self.max_possible_matched_index {
    9                 break;
   10             }
   11         }
   12
   13         self.try_drain_raft_rx().await?;
   14         if self.has_more_log() {
   15             continue;
   16         }
   17
   18         tokio::select! {
   19             _ = self.heartbeat.tick() => { continue }
   20
   21             event_span = self.repl_rx.recv() => {
   22                 match event_span {
   23                     Some((event, _span)) => {
   24                         self.process_raft_event(event)?;
   25                         self.try_drain_raft_rx().await?;
   26                     },
   27                     None => {
   28                         return Err(ReplicationError::Closed);
   29                     },
   30                 }
   31             }
   32         }
   33     }
   34 }