Method mainRun

ZezeJava/ZezeJava/src/main/java/Zeze/Services/Daemon.java:95–148

()

	}

	private static int mainRun() {
		while (true) {
			try {
				// 轮询：等待Global配置以及等待子进程退出。
				try {
					var cmd = receiveCommand(udpSocket);
					switch (cmd.command()) {
					case Register.Command:
						var reg = (Register)cmd;
						var code = 0;
						if (monitors.containsKey(reg.serverId))
							code = 1;
						else {
							var monitor = new Monitor(reg);
							monitors.put(reg.serverId, monitor);
							monitor.start();
						}
						sendCommand(udpSocket, cmd.peer, new CommonResult(reg.reliableSerialNo, code));
						logger.info("Register! Server={} code={}", reg.serverId, code);
						break;

					case GlobalOn.Command:
						var on = (GlobalOn)cmd;
						code = 0;
						var monitor = monitors.get(on.serverId);
						if (monitor != null) {
							monitor.setConfig(on.globalIndex, on.globalConfig);
							logger.info("GlobalOn! Server={} ServerDaemonTimeout={} ServerReleaseTimeout={}",
									on.serverId, on.globalConfig.serverDaemonTimeout, on.globalConfig.serverReleaseTimeout);
						} else {
							logger.warn("GlobalOn! not found serverId={} ServerDaemonTimeout={} ServerReleaseTimeout={}",
									on.serverId, on.globalConfig.serverDaemonTimeout, on.globalConfig.serverReleaseTimeout);
							code = 1;
						}
						sendCommand(udpSocket, cmd.peer, new CommonResult(on.reliableSerialNo, code));
						break;

					case DeadlockReport.Command:
						logger.warn("deadlock report");
						destroySubprocess();
						break;
					}
				} catch (SocketTimeoutException ex) {
					// skip
				}
				if (subprocess.waitFor(0, TimeUnit.MILLISECONDS))
					return subprocess.exitValue();
			} catch (Throwable ex) { // print stacktrace.
				logger.fatal("Daemon.mainRun", ex);
				fatalExit();
				return -1; // never run here
			}
		}
	}

	private static void fatalExit() {
		subprocess.destroy();