Method sendCommand

ZezeJava/ZezeJava/src/main/java/Zeze/Services/Daemon.java:189–221

(DatagramSocket socket, SocketAddress peer, Command cmd)

	}

	public static void sendCommand(DatagramSocket socket, SocketAddress peer, Command cmd) throws IOException {
		var bb = ByteBuffer.Allocate(5);
		bb.WriteInt(cmd.command());
		cmd.encode(bb);
		var p = new DatagramPacket(bb.Bytes, 0, bb.WriteIndex, peer);
		if (cmd.isRequest()) {
			if (pendings.putIfAbsent(cmd.reliableSerialNo, new PendingPacket(socket, p)) != null)
				throw new IllegalStateException("Duplicate ReliableSerialNo=" + cmd.reliableSerialNo);

			// auto start Timer
			if (timer == null) {
				pendingsLock.lock();
				try {
					if (timer == null) {
						timer = Task.scheduleUnsafe(1000, 1000, () -> {
							var now = System.currentTimeMillis();
							for (var pending : pendings) {
								if (now - pending.sendTime > 1000) {
									pending.sendTime = now;
									pending.socket.send(pending.packet);
								}
							}
						});
						//noinspection DataFlowIssue
						ShutdownHook.add(() -> timer.cancel(false));
					}
				} finally {
					pendingsLock.unlock();
				}
			}
		}
		socket.send(p);
	}

	public static Command receiveCommand(DatagramSocket socket) throws IOException {
		var buf = new byte[1024];