decode() — netty Function Reference

Architecture documentation for the decode() function in HAProxyMessageDecoder.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ decode() — netty Function Reference

Dependency Diagram

graph TD
  5c5e7bc9_025c_6ef6_d933_6646e8180072["decode()"]
  779adff2_46a7_a104_ccd9_84680387d552["HAProxyMessageDecoder"]
  5c5e7bc9_025c_6ef6_d933_6646e8180072 -->|defined in| 779adff2_46a7_a104_ccd9_84680387d552
  a6d80843_53e8_c46e_df6c_c1c99ea1a37a["findVersion()"]
  5c5e7bc9_025c_6ef6_d933_6646e8180072 -->|calls| a6d80843_53e8_c46e_df6c_c1c99ea1a37a
  4bcf7a2e_b41c_ffbf_c326_61a787af2c17["fail()"]
  5c5e7bc9_025c_6ef6_d933_6646e8180072 -->|calls| 4bcf7a2e_b41c_ffbf_c326_61a787af2c17
  style 5c5e7bc9_025c_6ef6_d933_6646e8180072 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-haproxy/src/main/java/io/netty/handler/codec/haproxy/HAProxyMessageDecoder.java lines 234–263

    @Override
    protected final void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        // determine the specification version
        if (version == -1) {
            if ((version = findVersion(in)) == -1) {
                return;
            }
        }

        ByteBuf decoded;

        if (version == 1) {
            decoded = decodeLine(ctx, in);
        } else {
            decoded = decodeStruct(ctx, in);
        }

        if (decoded != null) {
            finished = true;
            try {
                if (version == 1) {
                    out.add(HAProxyMessage.decodeHeader(decoded.toString(CharsetUtil.US_ASCII)));
                } else {
                    out.add(HAProxyMessage.decodeHeader(decoded));
                }
            } catch (HAProxyProtocolException e) {
                fail(ctx, null, e);
            }
        }
    }