fix one bug about MsgUnreachable local type

close tikv/tikv#11371 Signed-off-by: tier-cap <[email protected]> Signed-off-by: tier-cap <[email protected]>
tikv · Apr 21, 2022 · 3dc6ec5 · 3dc6ec5
1 parent f968d2c
commit 3dc6ec5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/raft.rs b/src/raft.rs
@@ -265,6 +265,7 @@ pub struct RaftCore<T: Storage> {
 /// A struct that represents the raft consensus itself. Stores details concerning the current
 /// and possible state the system can take.
 pub struct Raft<T: Storage> {
+    /// the progress tracker of each peer.
     pub prs: ProgressTracker,
 
     /// The list of messages.

diff --git a/src/raw_node.rs b/src/raw_node.rs
@@ -55,11 +55,11 @@ pub enum SnapshotStatus {
 
 /// Checks if certain message type should be used internally.
 pub fn is_local_msg(t: MessageType) -> bool {
+    // remove MessageType::MsgUnreachable
     matches!(
         t,
         MessageType::MsgHup
             | MessageType::MsgBeat
-            | MessageType::MsgUnreachable
             | MessageType::MsgSnapStatus
             | MessageType::MsgCheckQuorum
     )
@@ -805,7 +805,7 @@ mod test {
         let tests = vec![
             (MessageType::MsgHup, true),
             (MessageType::MsgBeat, true),
-            (MessageType::MsgUnreachable, true),
+            (MessageType::MsgUnreachable, false),
             (MessageType::MsgSnapStatus, true),
             (MessageType::MsgCheckQuorum, true),
             (MessageType::MsgPropose, false),