channelRead0() — netty Function Reference

Architecture documentation for the channelRead0() function in ProxyServer.java from the netty codebase.

Function java Buffer Allocators calls 2 called by 1

Entity Profile

Buffer→ Allocators→ channelRead0() — netty Function Reference

Dependency Diagram

graph TD
  d35cb1df_dc40_6945_08a5_a25b55513228["channelRead0()"]
  f2dc5bef_5555_e698_c0cb_7f1263aedb4d["TerminalHandler"]
  d35cb1df_dc40_6945_08a5_a25b55513228 -->|defined in| f2dc5bef_5555_e698_c0cb_7f1263aedb4d
  c4b3f8a3_81ad_bb3f_ed26_42280222f3f8["channelRead0()"]
  c4b3f8a3_81ad_bb3f_ed26_42280222f3f8 -->|calls| d35cb1df_dc40_6945_08a5_a25b55513228
  c4b3f8a3_81ad_bb3f_ed26_42280222f3f8["channelRead0()"]
  d35cb1df_dc40_6945_08a5_a25b55513228 -->|calls| c4b3f8a3_81ad_bb3f_ed26_42280222f3f8
  184b2fe6_cb56_df45_eecf_a591387f9a36["handleProxyProtocol()"]
  d35cb1df_dc40_6945_08a5_a25b55513228 -->|calls| 184b2fe6_cb56_df45_eecf_a591387f9a36
  style d35cb1df_dc40_6945_08a5_a25b55513228 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler-proxy/src/test/java/io/netty/handler/proxy/ProxyServer.java lines 267–288

        @Override
        protected final void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
            if (finished) {
                String str = ((ByteBuf) msg).toString(CharsetUtil.US_ASCII);
                if ("A\n".equals(str)) {
                    ctx.write(Unpooled.copiedBuffer("1\n", CharsetUtil.US_ASCII));
                } else if ("B\n".equals(str)) {
                    ctx.write(Unpooled.copiedBuffer("2\n", CharsetUtil.US_ASCII));
                } else if ("C\n".equals(str)) {
                    ctx.write(Unpooled.copiedBuffer("3\n", CharsetUtil.US_ASCII))
                       .addListener(ChannelFutureListener.CLOSE);
                } else {
                    throw new IllegalStateException("unexpected message: " + str);
                }
                return;
            }

            boolean finished = handleProxyProtocol(ctx, msg);
            if (finished) {
                this.finished = finished;
            }
        }