channelRead0() — netty Function Reference

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

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ channelRead0() — netty Function Reference

Dependency Diagram

graph TD
  53875a44_f73f_3381_8d02_448eff69f5a4["channelRead0()"]
  b557b3ec_58e6_8714_041d_c4548d470956["EchoHandler"]
  53875a44_f73f_3381_8d02_448eff69f5a4 -->|defined in| b557b3ec_58e6_8714_041d_c4548d470956
  style 53875a44_f73f_3381_8d02_448eff69f5a4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-native-epoll/src/test/java/io/netty/channel/epoll/EpollSpliceTest.java lines 250–265

        @Override
        public void channelRead0(ChannelHandlerContext ctx, ByteBuf in) throws Exception {
            byte[] actual = new byte[in.readableBytes()];
            in.readBytes(actual);

            int lastIdx = counter;
            for (int i = 0; i < actual.length; i ++) {
                assertEquals(data[i + lastIdx], actual[i]);
            }

            if (channel.parent() != null) {
                channel.write(Unpooled.wrappedBuffer(actual));
            }

            counter += actual.length;
        }