Method onTimerTask

ZezeJava/ZezeJava/src/main/java/Zeze/Arch/LoadBase.java:73–111

()

	public abstract int getServicePort();

	private void onTimerTask() {
		var overload = this.overload.getOverload();
		int online = getOnlineLocalCount();
		long loginTimes = getOnlineLoginTimes();
		int onlineNew = (int)(loginTimes - lastLoginTime);
		lastLoginTime = loginTimes;
		int onlineNewPerSecond = onlineNew / timeoutDelaySeconds;
		var config = getLoadConfig();
		if (overload != BLoad.eWorkFine) {
			// fast report
			report(overload, online, onlineNewPerSecond);
			start(config.getDigestionDelayExSeconds());
			return;
		}
		if (onlineNewPerSecond > config.getMaxOnlineNew()) {
			// 最近上线太多，马上报告负载。linkd不会再分配用户过来。
			report(overload, online, onlineNewPerSecond);
			// new delay for digestion
			start(onlineNewPerSecond / config.getMaxOnlineNew() + config.getDigestionDelayExSeconds());
			// 消化完后，下一次强迫报告Load。
			reportDelaySeconds = config.getReportDelaySeconds();
			return;
		}
		if (online > config.getProposeMaxOnline()) {
			// 在线数量超过建议最大在线，马上报告。
			report(overload, online, onlineNewPerSecond);
			start(config.getDigestionDelayExSeconds());
			// 超过最大建议值，强迫报告。
			reportDelaySeconds = config.getReportDelaySeconds();
			return;
		}
		// slow report
		reportDelaySeconds += timeoutDelaySeconds;
		if (reportDelaySeconds >= config.getReportDelaySeconds()) {
			reportDelaySeconds = 0;
			report(overload, online, onlineNewPerSecond);
		}
		start();
	}

	public void report(int overload, int online, int onlineNew) {
		var load = new BLoad.Data();