channelRead() — netty Function Reference

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

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  5e0c7714_d30e_fe0b_f3a8_4adf2fb3dc51["channelRead()"]
  83b83372_f1af_b71d_b6a1_92ebc4e86f2c["SimpleChannelInboundHandler"]
  5e0c7714_d30e_fe0b_f3a8_4adf2fb3dc51 -->|defined in| 83b83372_f1af_b71d_b6a1_92ebc4e86f2c
  1b07f85f_a730_9068_6e66_e35693971d31["acceptInboundMessage()"]
  5e0c7714_d30e_fe0b_f3a8_4adf2fb3dc51 -->|calls| 1b07f85f_a730_9068_6e66_e35693971d31
  9a9ced9e_c4c4_7c42_0607_73b5f85aeee6["channelRead0()"]
  5e0c7714_d30e_fe0b_f3a8_4adf2fb3dc51 -->|calls| 9a9ced9e_c4c4_7c42_0607_73b5f85aeee6
  style 5e0c7714_d30e_fe0b_f3a8_4adf2fb3dc51 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/SimpleChannelInboundHandler.java lines 92–109

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        boolean release = true;
        try {
            if (acceptInboundMessage(msg)) {
                @SuppressWarnings("unchecked")
                I imsg = (I) msg;
                channelRead0(ctx, imsg);
            } else {
                release = false;
                ctx.fireChannelRead(msg);
            }
        } finally {
            if (autoRelease && release) {
                ReferenceCountUtil.release(msg);
            }
        }
    }