QpackEncoderDecoderTest Class — netty Architecture

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/QpackEncoderDecoderTest.java lines 46–543

public class QpackEncoderDecoderTest {

    private QpackEncoder encoder;
    private QpackDecoder decoder;
    private boolean stateSyncStrategyAckNextInsert = true;
    private int headersAdded;
    private int maxEntries;
    private QpackEncoderDynamicTable encDynamicTable;
    private QpackDecoderDynamicTable decDynamicTable;
    private BlockingQueue<Callable<Void>> suspendedEncoderInstructions;

    private final QpackDecoderStateSyncStrategy syncStrategy = mock(QpackDecoderStateSyncStrategy.class);
    private final Http3Headers encHeaders = new DefaultHttp3Headers();
    private final Http3Headers decHeaders = new DefaultHttp3Headers();
    private final ByteBuf out = Unpooled.buffer();
    private final EmbeddedQuicChannel parent = new EmbeddedQuicChannel(true);
    private QpackAttributes attributes;

    @AfterEach
    public void tearDown() {
        out.release();
    }

    @Test
    public void dynamicIndexed() throws Exception {
        setup(128, 0);
        headersAdded++;
        testDynamicTableIndexed("foo", "bar");
    }

    @Test
    public void dynamicIndexedWithBlockedStreams() throws Exception {
        setup(128, 100);
        headersAdded++;
        testDynamicTableIndexedWithBlockedStreams("foo", "bar");
    }

    @Test
    public void dynamicIndexedWithStaticTableNameRef() throws Exception {
        setup(128, 0);
        headersAdded++;
        testDynamicTableIndexed(":authority", "netty.quic");
    }

    @Test
    public void dynamicIndexedWithStaticTableNameRefWithBlockedStreams() throws Exception {
        setup(128, 100);
        headersAdded++;
        testDynamicTableIndexedWithBlockedStreams(":authority", "netty.quic");
    }

    @Test
    public void dynamicIndexedWithNameRef() throws Exception {
        setup(128, 0);

        headersAdded++;
        testDynamicTableIndexed("foo", "bar");

        resetState();

        headersAdded++;
        testDynamicTableIndexed("foo", "bar2");

        resetState();

        testDynamicTableIndexed("foo", "bar");
    }

    @Test
    public void dynamicIndexedWithNameRefWithBlockedStream() throws Exception {
        setup(128, 100);

        headersAdded++;
        testDynamicTableIndexedWithBlockedStreams("foo", "bar");

        resetState();

        headersAdded++;
        testDynamicTableIndexedWithBlockedStreams("foo", "bar2");
    }