channelRead() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  39163b4d_6655_a05c_9205_fe0c42419b89["channelRead()"]
  c003ff1d_d8db_49f7_4ce5_9520b745d318["BufferingClientHandler"]
  39163b4d_6655_a05c_9205_fe0c42419b89 -->|defined in| c003ff1d_d8db_49f7_4ce5_9520b745d318
  d58eaa9b_d09e_69a1_69f3_838a1edbf736["channelRead()"]
  d58eaa9b_d09e_69a1_69f3_838a1edbf736 -->|calls| 39163b4d_6655_a05c_9205_fe0c42419b89
  d58eaa9b_d09e_69a1_69f3_838a1edbf736["channelRead()"]
  39163b4d_6655_a05c_9205_fe0c42419b89 -->|calls| d58eaa9b_d09e_69a1_69f3_838a1edbf736
  style 39163b4d_6655_a05c_9205_fe0c42419b89 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketConnectTest.java lines 246–257

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            if (msg instanceof ByteBuf) {
                ByteBuf buf = (ByteBuf) msg;
                int readableBytes = buf.readableBytes();
                buf.readBytes(streamBuffer, readableBytes);
                semaphore.release(readableBytes);
                buf.release();
            } else {
                throw new IllegalArgumentException("Unexpected message type: " + msg);
            }
        }