decode() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ decode() — netty Function Reference

Dependency Diagram

graph TD
  369c6f86_6367_a22a_3265_e670f55943da["decode()"]
  28215e1f_7aab_a28b_0e47_cb1b781b34f0["SctpMessageCompletionHandler"]
  369c6f86_6367_a22a_3265_e670f55943da -->|defined in| 28215e1f_7aab_a28b_0e47_cb1b781b34f0
  style 369c6f86_6367_a22a_3265_e670f55943da fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-sctp/src/main/java/io/netty/handler/codec/sctp/SctpMessageCompletionHandler.java lines 42–74

    @Override
    protected void decode(ChannelHandlerContext ctx, SctpMessage msg, List<Object> out) throws Exception {
        final ByteBuf byteBuf = msg.content();
        final int protocolIdentifier = msg.protocolIdentifier();
        final int streamIdentifier = msg.streamIdentifier();
        final boolean isComplete = msg.isComplete();
        final boolean isUnordered = msg.isUnordered();

        ByteBuf frag = fragments.remove(streamIdentifier);
        if (frag == null) {
            frag = Unpooled.EMPTY_BUFFER;
        }

        if (isComplete && !frag.isReadable()) {
            //data chunk is not fragmented
            out.add(msg);
        } else if (!isComplete && frag.isReadable()) {
            //more message to complete
            fragments.put(streamIdentifier, Unpooled.wrappedBuffer(frag, byteBuf));
        } else if (isComplete && frag.isReadable()) {
            //last message to complete
            SctpMessage assembledMsg = new SctpMessage(
                    protocolIdentifier,
                    streamIdentifier,
                    isUnordered,
                    Unpooled.wrappedBuffer(frag, byteBuf));
            out.add(assembledMsg);
        } else {
            //first incomplete message
            fragments.put(streamIdentifier, byteBuf);
        }
        byteBuf.retain();
    }