Method loadTimer

ZezeJava/ZezeJava/src/main/java/Zeze/Component/Timer.java:1168–1206

()

	}

	private void loadTimer() throws Exception {
		var serverId = zeze.getConfig().getServerId();
		var outRoot = new BNodeRoot();
		var r = Task.call(zeze.newProcedure(() -> {
			var root = _tNodeRoot.getOrAdd(serverId);
			// 本地每次load都递增。用来处理和接管的并发。
			root.setLoadSerialNo(root.getLoadSerialNo() + 1);
			outRoot.assign(root);
			return 0;
		}, "Timer.loadTimerLocal"));
		if (r == Procedure.Success) {
			var offlineNotify = new BOfflineNotify();
			offlineNotify.serverId = serverId;
			offlineNotify.notifyId = "Zeze.Component.Timer.OfflineNotify";
			offlineNotify.notifySerialId = outRoot.getLoadSerialNo();
			zeze.getServiceManager().offlineRegister(offlineNotify,
					notify -> spliceLoadTimer(notify.serverId, notify.notifySerialId));
			loadTimer(outRoot.getHeadNodeId(), outRoot.getHeadNodeId(), serverId); // last也填头节点是因为链表是循环的
		} else
			logger.error("loadTimer failed: r={}", r);

		var agent = zeze.getServiceManager();
		if (agent instanceof Agent) { // 暂时只支持非Raft的ServiceManager
			var p = new AnnounceServers();
			p.Argument.notifyId = "Zeze.Component.Timer.NotifyOffline";
			p.Argument.serverId = serverId;
			_tNodeRoot.walk((k, v) -> {
				if (v.getHeadNodeId() != 0) {
					p.Argument.watchServerIds.add(k);
					p.Argument.watchSerialIds.add(v.getLoadSerialNo());
				}
				return true;
			});
			((Agent)agent).offlineRegister(p.Argument.notifyId,
					notify -> spliceLoadTimer(notify.serverId, notify.notifySerialId));
			agent.waitReady();
			p.SendAndWaitCheckResultCode(((Agent)agent).getClient().getSocket());
		}
	}

	/**
	 * 收到接管通知的服务器调用这个函数进行接管处理。