pub fn step(&mut self, m: Message) -> Result<(), RaftError> {
        // ignore unexpected local message receiving over the network
        if is_local_message(m.get_field_type()) {
            return Err(RaftError::FromRawRaft(RawRaftError::StepLocalMsg));
        }
        if self.raft.prs.progress.contains_key(&m.get_from())
            || !is_response_message(m.get_field_type())
        {
            return self.raft.step(m);
        }
        Err(RaftError::FromRawRaft(RawRaftError::StepPeerNotFound))
    }
// Step advances the state machine using the given message.
Step advances the state machine using the given message.
Step advances the state machine using the given message .
pub fn step(&mut self, m: Message) -> Result<(), RaftError> {
        // ignore unexpected local message receiving over the network
        if is_local_message(m.get_field_type()) {
            return Err(RaftError::FromRawRaft(RawRaftError::StepLocalMsg));
        }
        if self.raft.prs.progress.contains_key(&m.get_from())
            || !is_response_message(m.get_field_type())
        {
            return self.raft.step(m);
        }
        Err(RaftError::FromRawRaft(RawRaftError::StepPeerNotFound))
    }
pub fn step ( & mut self , m : Message ) -> Result < ( ) , RaftError > { // ignore unexpected local message receiving over the network if is_local_message ( m . get_field_type ( ) ) { return Err ( RaftError :: FromRawRaft ( RawRaftError :: StepLocalMsg ) ) ; } if self . raft . prs . progress . contains_key ( & m . get_from ( ) ) || ! is_response_message ( m . get_field_type ( ) ) { return self . raft . step ( m ) ; } Err ( RaftError :: FromRawRaft ( RawRaftError :: StepPeerNotFound ) ) }
Step advances the state machine using the given message.
Step advances the state machine using the given message .
&mut self
m
Message