channelRead0() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ channelRead0() — netty Function Reference

Dependency Diagram

graph TD
  1760f8cb_e381_5129_4d24_fb1c47a9bc79["channelRead0()"]
  61b39b16_9a10_b838_38b8_fd3f3598cee4["EchoClientHandler"]
  1760f8cb_e381_5129_4d24_fb1c47a9bc79 -->|defined in| 61b39b16_9a10_b838_38b8_fd3f3598cee4
  96f28521_cfc8_a185_ba27_fa0877ab74ae["channelRead0()"]
  96f28521_cfc8_a185_ba27_fa0877ab74ae -->|calls| 1760f8cb_e381_5129_4d24_fb1c47a9bc79
  96f28521_cfc8_a185_ba27_fa0877ab74ae["channelRead0()"]
  1760f8cb_e381_5129_4d24_fb1c47a9bc79 -->|calls| 96f28521_cfc8_a185_ba27_fa0877ab74ae
  style 1760f8cb_e381_5129_4d24_fb1c47a9bc79 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketSslEchoTest.java lines 522–533

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

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

            recvCounter.addAndGet(actual.length);
        }