EmbeddedQuicChannel Class — netty Architecture

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/EmbeddedQuicChannel.java lines 59–359

final class EmbeddedQuicChannel extends EmbeddedChannel implements QuicChannel {
    private static final AttributeKey<AtomicLong> streamIdGeneratorKey =
            valueOf("embedded_channel_stream_id_generator");
    private final Map<QuicStreamType, Long> peerAllowedStreams = new EnumMap<>(QuicStreamType.class);
    private final AtomicBoolean closed = new AtomicBoolean();
    private final ConcurrentLinkedQueue<Integer> closeErrorCodes = new ConcurrentLinkedQueue<>();
    private QuicChannelConfig config;

    /**
     * TWO bits reserved for Variable-Length Integer Encoding
     * <a href="https://datatracker.ietf.org/doc/html/rfc9000?#name-variable-length-integer-enc">rfc9000</a>
     * TWO LSB used for distinguish Client/Server initiated stream & Bi/unidirection
     * these are not reserved but part of it
     * <a href="https://datatracker.ietf.org/doc/html/rfc9000?#name-stream-types-and-identifier">rfc9000</a>
     * so we can max stream per stream type (bi/uni) = (2^62-1)/2
     */
    private static final long MAX_PEER_STREAMS_PER_STREAM_TYPE = ((1L << 62) - 1) / 2;

    EmbeddedQuicChannel(boolean server) {
        this(server, new ChannelHandler[0]);
    }

    EmbeddedQuicChannel(boolean server, ChannelHandler... handlers) {
        super(prependChannelConsumer(channel -> channel.attr(streamIdGeneratorKey).set(new AtomicLong(server ? 1 : 0)),
                handlers));
    }

    static ChannelHandler[] prependChannelConsumer(Consumer<Channel> channelConsumer,
                                                   ChannelHandler... handlers) {
        ChannelHandler[] toReturn = new ChannelHandler[handlers.length + 1];
        toReturn[0] = new ChannelInboundHandlerAdapter() {
            @Override
            public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
                channelConsumer.accept(ctx.channel());
                super.handlerAdded(ctx);
            }
        };
        arraycopy(handlers, 0, toReturn, 1, handlers.length);
        return toReturn;
    }

    @Override
    public QuicConnectionAddress localAddress() {
        return null;
    }

    @Override
    public QuicConnectionAddress remoteAddress() {
        return null;
    }

    @Override
    public SocketAddress localSocketAddress() {
        return null;
    }

    @Override
    public SocketAddress remoteSocketAddress() {
        return null;
    }

    @Override
    public boolean isTimedOut() {
        return false;
    }

    @Override
    @Nullable
    public SSLEngine sslEngine() {
        return null;
    }

    @Override
    public QuicChannelConfig config() {
        if (config == null) {
            config = new EmbeddedQuicChannelConfig(super.config());
        }
        return config;
    }

    @Override