tryEncodeWithDynamicTable() — netty Function Reference

Source Code

codec-http3/src/main/java/io/netty/handler/codec/http3/QpackEncoder.java lines 284–335

    private int tryEncodeWithDynamicTable(QpackAttributes qpackAttributes, ByteBuf out, int base, CharSequence name,
                                          CharSequence value) {
        if (qpackAttributes.dynamicTableDisabled()) {
            return DYNAMIC_TABLE_ENCODE_NOT_POSSIBLE;
        }
        assert qpackAttributes.encoderStreamAvailable();
        final QuicStreamChannel encoderStream = qpackAttributes.encoderStream();

        int idx = dynamicTable.getEntryIndex(name, value);
        if (idx == QpackEncoderDynamicTable.NOT_FOUND) {
            return DYNAMIC_TABLE_ENCODE_NOT_DONE;
        }
        if (idx >= 0) {
            if (dynamicTable.requiresDuplication(idx, sizeOf(name, value))) {
                idx = dynamicTable.add(name, value, sizeOf(name, value));
                assert idx >= 0;
                // https://www.rfc-editor.org/rfc/rfc9204.html#section-4.3.4
                //  0   1   2   3   4   5   6   7
                // +---+---+---+---+---+---+---+---+
                // | 0 | 0 | 0 |    Index (5+)     |
                // +---+---+---+-------------------+
                ByteBuf duplicate = encoderStream.alloc().buffer(8);
                encodePrefixedInteger(duplicate, (byte) 0b0000_0000, 5,
                        dynamicTable.relativeIndexForEncoderInstructions(idx));
                closeOnFailure(encoderStream.writeAndFlush(duplicate));
                if (mayNotBlockStream()) {
                    // Add to the table but do not use the entry in the header block to avoid blocking.
                    return DYNAMIC_TABLE_ENCODE_NOT_POSSIBLE;
                }
            }
            if (idx >= base) {
                encodePostBaseIndexed(out, base, idx);
            } else {
                encodeIndexedDynamicTable(out, base, idx);
            }
        } else { // name match
            idx = -(idx + 1);
            int addIdx = tryAddToDynamicTable(qpackAttributes, false,
                    dynamicTable.relativeIndexForEncoderInstructions(idx), name, value);
            if (addIdx < 0) {
                return DYNAMIC_TABLE_ENCODE_NOT_POSSIBLE;
            }
            idx = addIdx;

            if (idx >= base) {
                encodeLiteralWithPostBaseNameRef(out, base, idx, value);
            } else {
                encodeLiteralWithNameRefDynamicTable(out, base, idx, value);
            }
        }
        return idx;
    }