Method processRequestVote

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Raft.java:661–691

(RequestVote r)

	}

	@SuppressWarnings("SameReturnValue")
	private long processRequestVote(RequestVote r) throws Exception {
		lock();
		try {
			// 不管任何状态重置下一次时间，使得每个node从大概一个时刻开始。
			nextVoteTime = System.currentTimeMillis() + raftConfig.getElectionTimeout();

			if (logSequence.trySetTerm(r.Argument.getTerm()) == LogSequence.SetTermResult.Newer)
				convertStateTo(RaftState.Follower); // new term found.
			// else continue process

			// RequestVote RPC
			// Receiver implementation:
			// 1.Reply false if term < currentTerm(§5.1)
			// 2.If votedFor is null or candidateId, and candidate's log is at
			// least as up - to - date as receiver's log, grant vote(§5.2, §5.4)

			r.Result.setTerm(logSequence.getTerm());
			r.Result.setVoteGranted(r.Argument.getTerm() == logSequence.getTerm() &&
					logSequence.canVoteFor(r.Argument.getCandidateId()) && isLastLogUpToDate(r.Argument));

			if (r.Result.getVoteGranted())
				logSequence.setVoteFor(r.Argument.getCandidateId());
			logger.info("{}: VoteFor={} Rpc={}", getName(), logSequence.getVoteFor(), r);
			r.SendResultCode(0);

			return Procedure.Success;
		} finally {
			unlock();
		}
	}

	@SuppressWarnings("SameReturnValue")
	private static long processLeaderIs(LeaderIs r) {