Class Protocol

ZezeJava/ZezeJava/src/main/java/Zeze/Net/Protocol.java:19–364

import org.jetbrains.annotations.Nullable;

public abstract class Protocol<TArgument extends Serializable> implements Serializable {
	public static final int HEADER_SIZE = 12; // moduleId[4] + protocolId[4] + size[4]
	private static final @NotNull Logger logger = LogManager.getLogger(Protocol.class);
	private static final LongConcurrentHashMap<Class<? extends Protocol<?>>> protocolClasses = new LongConcurrentHashMap<>();
	private static final @NotNull VarHandle userStateHandle;
	protected static final IOException noHandlerException = new IOException("noHandler");

	public static final int eCriticalPlus = 0;
	public static final int eCritical = 1;
	public static final int eNormal = 2;
	public static final int eSheddable = 3;

	private transient AsyncSocket sender; // AsyncSocket
	@SuppressWarnings("unused")
	private transient @Nullable Object userState;
	public TArgument Argument;
	protected long resultCode;

	static {
		try {
			userStateHandle = MethodHandles.lookup().findVarHandle(Protocol.class, "userState", Object.class);
		} catch (ReflectiveOperationException e) {
			throw new ExceptionInInitializerError(e);
		}
	}

	public int getCriticalLevel() {
		return eCriticalPlus;
	}

	private static final class UserStateWithEncoded {
		private transient @Nullable Object userState;
		private transient final @NotNull ByteBuffer encodeShared;

		private UserStateWithEncoded(@Nullable Object userState, @NotNull ByteBuffer encodeShared) {
			this.userState = userState;
			this.encodeShared = encodeShared;
		}
	}

	public int getFamilyClass() {
		return FamilyClass.Protocol;
	}

	public AsyncSocket getSender() {
		return sender;
	}

	public void setSender(AsyncSocket sender) {
		this.sender = sender;
	}

	public @Nullable Service getService() {
		return sender.getService();
	}

	public @Nullable Object getUserState() {
		var us = userState;