channelRead() — netty Function Reference

Architecture documentation for the channelRead() function in MessageToMessageDecoder.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  7ed6d4ea_1d23_84d2_c2a8_695d44953576["channelRead()"]
  bd1eaa52_3883_2c3e_1720_8a64708c4ba9["MessageToMessageDecoder"]
  7ed6d4ea_1d23_84d2_c2a8_695d44953576 -->|defined in| bd1eaa52_3883_2c3e_1720_8a64708c4ba9
  095ef3ed_2575_aae4_4a81_0edeb0c150e4["acceptInboundMessage()"]
  7ed6d4ea_1d23_84d2_c2a8_695d44953576 -->|calls| 095ef3ed_2575_aae4_4a81_0edeb0c150e4
  fff8cb3d_c690_9cfb_7f27_6efff322946f["decode()"]
  7ed6d4ea_1d23_84d2_c2a8_695d44953576 -->|calls| fff8cb3d_c690_9cfb_7f27_6efff322946f
  style 7ed6d4ea_1d23_84d2_c2a8_695d44953576 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/main/java/io/netty/handler/codec/MessageToMessageDecoder.java lines 82–113

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        decodeCalled = true;
        CodecOutputList out = CodecOutputList.newInstance();
        try {
            if (acceptInboundMessage(msg)) {
                @SuppressWarnings("unchecked")
                I cast = (I) msg;
                try {
                    decode(ctx, cast, out);
                } finally {
                    ReferenceCountUtil.release(cast);
                }
            } else {
                out.add(msg);
            }
        } catch (DecoderException e) {
            throw e;
        } catch (Exception e) {
            throw new DecoderException(e);
        } finally {
            try {
                int size = out.size();
                messageProduced |= size > 0;
                for (int i = 0; i < size; i++) {
                    ctx.fireChannelRead(out.getUnsafe(i));
                }
            } finally {
                out.recycle();
            }
        }
    }