Method processLeaderIs

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:392–438

(LeaderIs r)

	}

	private long processLeaderIs(LeaderIs r) throws Exception {
		ConnectorProxy leader = this.leader;
		logger.info("=============== LEADERIS Old={} New={} From={}",
				leader != null ? leader.getName() : null, r.Argument.getLeaderId(), r.getSender());

		// 启用代理（多个raft共享连接）。
		if (null != proxyAgent) {
			var newLeader = proxyAgent.getLeader(raftConfig.getNodes().get(r.Argument.getLeaderId()));
			if (null != newLeader) {
				if (setLeader(r, newLeader))
					resend(true);

				r.SendResultCode(0);
				return Procedure.Success;
			}
			// else continue old process;
		}
		// else continue old process

		var node = client.getConfig().findConnector(r.Argument.getLeaderId());
		if (node == null) {
			// 当前 Agent 没有 Leader 的配置，创建一个。
			// 由于 Agent 在新增 node 时也会得到新配置广播，
			// 一般不会发生这种情况。
			var address = r.Argument.getLeaderId().split("_");
			if (address.length != 2)
				return 0;

			OutObject<Connector> outNode = new OutObject<>();
			if (client.getConfig().tryGetOrAddConnector(address[0], Integer.parseInt(address[1]), true, outNode))
				outNode.value.start();
		} else {
			//noinspection DataFlowIssue
			if (!r.Argument.isLeader() && r.Argument.getLeaderId().equals(r.getSender().getConnector().getName())) {
				// 【错误处理】用来观察。
				logger.warn("New Leader Is Not A Leader.");
				// 发送者不是Leader，但它的发送的LeaderId又是自己，【尝试选择另外一个Node】。
				node = getRandomConnector(node);
			}
		}

		if (setLeader(r, new ConnectorProxy(node)))
			resend(true);

		r.SendResultCode(0);
		return Procedure.Success;
	}

	private void resend() {
		resend(false);