Class Session

ZezeJava/ZezeJava/src/main/java/Zeze/Net/ReliableUdp.java:154–182

	}

	public class Session {
		private final ReliableUdpHandle handle;
		private final SocketAddress peer;
		private final LongConcurrentHashMap<Packet> sendWindow = new LongConcurrentHashMap<>();
		private final AtomicLong serialIdGenerator = new AtomicLong(1);
		private final LongConcurrentHashMap<Packet> recvWindow = new LongConcurrentHashMap<>();

		private long lastDispatchedSerialId;
		private long maxRecvPacketSerialId;

		public Session(SocketAddress peer, ReliableUdpHandle handle) {
			this.handle = handle;
			this.peer = peer;
			sessions.put(peer, this);
		}

		public boolean send(byte[] bytes, int offset, int length) {
			if (length > MaxPacketLength)
				throw new IllegalArgumentException("length > MaxPacketLength: " + MaxPacketLength);

			var serialId = serialIdGenerator.getAndIncrement();
			var packet = new Packet(serialId, bytes, offset, length);
			sendWindow.put(packet.serialId, packet);

			// start auto resend timer.
			packet.resendTimerTask = Task.scheduleUnsafe(3000, 3000, () -> sendTo(peer, packet));
			return sendTo(peer, packet);
		}
	}

	private boolean sendTo(SocketAddress peer, Serializable p) {
		try {