Method setLeaderReady

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Raft.java:596–630

(RaftLog heart)

	}

	void setLeaderReady(RaftLog heart) throws Exception {
		if (isLeader()) {
			// 是否过期First-Heartbeat。
			// 使用 LeaderReadyFuture 可以更加精确的识别。
			// 但是，由于RaftLog不是常驻内存的，保存不了进程级别的变量。
			if (heart.getTerm() != leaderWaitReadyTerm || heart.getIndex() != leaderWaitReadyIndex)
				return;

			leaderWaitReadyIndex = 0;
			leaderWaitReadyTerm = 0;

			logger.info("{} {} LastIndex={} Count={}", getName(), raftConfig.getDbHome(),
					logSequence.getLastIndex(), logSequence.getTestStateMachineCount());

			leaderReadyFuture.setResult(true);
			signalAll(); // has under lock(this)

			server.foreach(allSocket -> {
				// 本来这个通告发给Agent(client)即可，
				// 但是现在没有区分是来自Raft的连接还是来自Agent，
				// 全部发送。
				// 另外Raft之间有两个连接，会收到多次，Raft不处理这个通告。
				// 由于Raft数量不多，不会造成大的浪费，不做处理了。
				if (allSocket.isHandshakeDone()) {
					var r = new LeaderIs();
					r.Argument.setTerm(logSequence.getTerm());
					r.Argument.setLeaderId(leaderId);
					r.Argument.setLeader(isLeader());
					r.Send(allSocket); // skip response.
				}
			});
			if (onLeaderReady != null)
				onLeaderReady.run();
		}
	}

	private boolean isLastLogUpToDate(BRequestVoteArgument candidate) throws RocksDBException {
		// NodeReady local candidate