File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -265,6 +265,7 @@ pub struct RaftCore<T: Storage> {
265265/// A struct that represents the raft consensus itself. Stores details concerning the current
266266/// and possible state the system can take.
267267pub struct Raft < T : Storage > {
268+ /// the progress tracker of each peer.
268269 pub prs : ProgressTracker ,
269270
270271 /// The list of messages.
Original file line number Diff line number Diff line change @@ -55,11 +55,11 @@ pub enum SnapshotStatus {
5555
5656/// Checks if certain message type should be used internally.
5757pub fn is_local_msg ( t : MessageType ) -> bool {
58+ // remove MessageType::MsgUnreachable
5859 matches ! (
5960 t,
6061 MessageType :: MsgHup
6162 | MessageType :: MsgBeat
62- | MessageType :: MsgUnreachable
6363 | MessageType :: MsgSnapStatus
6464 | MessageType :: MsgCheckQuorum
6565 )
@@ -805,7 +805,7 @@ mod test {
805805 let tests = vec ! [
806806 ( MessageType :: MsgHup , true ) ,
807807 ( MessageType :: MsgBeat , true ) ,
808- ( MessageType :: MsgUnreachable , true ) ,
808+ ( MessageType :: MsgUnreachable , false ) ,
809809 ( MessageType :: MsgSnapStatus , true ) ,
810810 ( MessageType :: MsgCheckQuorum , true ) ,
811811 ( MessageType :: MsgPropose , false ) ,
You can’t perform that action at this time.
0 commit comments