decodeVariableByteInteger() — netty Function Reference

Architecture documentation for the decodeVariableByteInteger() function in MqttDecoder.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ decodeVariableByteInteger() — netty Function Reference

Dependency Diagram

graph TD
  12d15f6d_1e3a_b75b_353d_a5cbfc12349a["decodeVariableByteInteger()"]
  c4faa729_e212_a3dd_9d90_3e8fd908d755["MqttDecoder"]
  12d15f6d_1e3a_b75b_353d_a5cbfc12349a -->|defined in| c4faa729_e212_a3dd_9d90_3e8fd908d755
  8cad50bc_08ed_5075_a0f7_de30f00ba977["decodeProperties()"]
  8cad50bc_08ed_5075_a0f7_de30f00ba977 -->|calls| 12d15f6d_1e3a_b75b_353d_a5cbfc12349a
  823009ab_d3c4_7d58_e37e_8c1f154013af["packInts()"]
  12d15f6d_1e3a_b75b_353d_a5cbfc12349a -->|calls| 823009ab_d3c4_7d58_e37e_8c1f154013af
  style 12d15f6d_1e3a_b75b_353d_a5cbfc12349a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java lines 732–748

    private static long decodeVariableByteInteger(ByteBuf buffer) {
        int remainingLength = 0;
        int multiplier = 1;

        for (int i = 0; i < 4; i++) {
            short digit = buffer.readUnsignedByte();
            remainingLength += (digit & 127) * multiplier;

            if ((digit & 128) == 0) {
                return packInts(remainingLength, i + 1);
            }

            multiplier *= 128;
        }

        throw new DecoderException("MQTT protocol limits Remaining Length to 4 bytes");
    }