Method setLeader

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:520–545

(LeaderIs r, ConnectorProxy newLeader)

	}

	public boolean setLeader(LeaderIs r, ConnectorProxy newLeader) throws Exception {
		mutex.lock();
		try {
			if (r.Argument.getTerm() < term) {
				logger.warn("Skip LeaderIs {} {}", newLeader.getName(), r);
				return false;
			}

			logger.info("proxy set leader {} {}_{}->{} {}_{}",
					null != leader ? leader.getName() : "",
					null != leader ? leader.getConnector().getHostNameOrAddress() : "",
					null != leader ? leader.getConnector().getPort() : "",
					newLeader.getName(),
					newLeader.getConnector().getHostNameOrAddress(),
					newLeader.getConnector().getPort());
			leader = newLeader; // change current Leader
			term = r.Argument.getTerm();
			newLeader.getConnector().start(); // try connect immediately
			Action1<Agent> onSetLeader = this.onSetLeader;
			if (onSetLeader != null)
				onSetLeader.run(this);
			return true;
		} finally {
			mutex.unlock();
		}
	}

	public static class NetClient extends HandshakeClient {
		private final Agent agent;