QpackDecoderTest Class — netty Architecture

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/QpackDecoderTest.java lines 35–169

public class QpackDecoderTest {
    private static final String FOO = "foo";
    private static final String BAR = "bar";
    private QpackDecoderDynamicTable table;
    private EmbeddedQuicStreamChannel decoderStream;

    private QpackDecoder decoder;
    private int inserted;
    private int maxEntries;
    private QpackAttributes attributes;

    public static Collection<Object[]> data() {
        int capacity = 128; // maxEntries = 128/32 = 4, maxIndex = 2*4 = 8
        return asList(
                new Object[]{capacity, 0},
                new Object[]{capacity, 1},
                new Object[]{capacity, 5},
                new Object[]{capacity, 8},
                new Object[]{capacity, 16},
                new Object[]{capacity, 25},
                new Object[]{capacity, 64},
                new Object[]{capacity, 89}
        );
    }

    @ParameterizedTest(name = "capacity: {0}, inserts: {1}")
    @MethodSource("data")
    public void requiredInsertCountAsInserted(int capacity, int insertionCount) throws Exception {
        setup(capacity);

        insertLiterals(insertionCount);
        encodeDecodeVerifyRequiredInsertCount(inserted);
    }

    @ParameterizedTest(name = "capacity: {0}, inserts: {1}")
    @MethodSource("data")
    public void requiredInsertCountLessThanInserted(int capacity, int insertionCount) throws Exception {
        setup(capacity);
        assumeTrue(insertionCount > 0);

        insertLiterals(insertionCount);
        encodeDecodeVerifyRequiredInsertCount(insertionCount - 1);
    }

    @ParameterizedTest(name = "capacity: {0}, inserts: {1}")
    @MethodSource("data")
    public void requiredInsertCountBehindMax(int capacity, int insertionCount) throws Exception {
        setup(capacity);
        assumeTrue(insertionCount > maxEntries);

        insertLiterals(insertionCount);
        encodeDecodeVerifyRequiredInsertCount(insertionCount - maxEntries + 1);
    }

    @ParameterizedTest(name = "capacity: {0}, inserts: {1}")
    @MethodSource("data")
    public void getWithRelativeIndex(int capacity, int insertionCount) throws Exception {
        setup(capacity);
        assumeTrue(insertionCount > 3);

        insertLiterals(insertionCount);
        int requiredInsertCount = encodeDecodeRequiredInsertCount(insertionCount);
        int base = encodeDecodeDeltaBase(requiredInsertCount, false, 1);
        int relativeIndex = 1;
        final QpackHeaderField entry = table.getEntryRelativeEncodedField(base - relativeIndex);
        verifyField(entry, insertionCount - 2);
    }

    @ParameterizedTest(name = "capacity: {0}, inserts: {1}")
    @MethodSource("data")
    public void getWithPostBaseRelativeIndex(int capacity, int insertionCount) throws Exception {
        setup(capacity);
        assumeTrue(insertionCount > 2);

        insertLiterals(insertionCount);
        int requiredInsertCount = encodeDecodeRequiredInsertCount(insertionCount - 1);
        int base = encodeDecodeDeltaBase(requiredInsertCount, true, 0);
        int relativeIndex = 1;
        final QpackHeaderField entry = table.getEntryRelativeEncodedField(base - relativeIndex);
        verifyField(entry, insertionCount - 1);
    }