raft/rawnode.go
func (rn *RawNode) Step(m pb.Message) error {
	// ignore unexpected local messages receiving over network
	if IsLocalMsg(m.Type) {
		return ErrStepLocalMsg
	}
	if pr := rn.raft.getProgress(m.From); pr != nil || !IsResponseMsg(m.Type) {
		return rn.raft.Step(m)
	}
	return ErrStepPeerNotFound
}
func (rn *RawNode) Step(m pb.Message) error {
	// ignore unexpected local messages receiving over network
	if IsLocalMsg(m.Type) {
		return ErrStepLocalMsg
	}
	if pr := rn.raft.getProgress(m.From); pr != nil || !IsResponseMsg(m.Type) {
		return rn.raft.Step(m)
	}
	return ErrStepPeerNotFound
}
func ( rn * RawNode ) Step ( m pb . Message ) error { // ignore unexpected local messages receiving over network if IsLocalMsg ( m . Type ) { return ErrStepLocalMsg } if pr := rn . raft . getProgress ( m . From ) ; pr != nil || ! IsResponseMsg ( m . Type ) { return rn . raft . Step ( m ) } return ErrStepPeerNotFound }
// Step advances the state machine using the given message.
Step advances the state machine using the given message .