channelRead0() — netty Function Reference

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

Function java Buffer Search calls 2 called by 1

Entity Profile

Buffer→ Search→ channelRead0() — netty Function Reference

Dependency Diagram

graph TD
  96f28521_cfc8_a185_ba27_fa0877ab74ae["channelRead0()"]
  e767f6ee_a0d3_e9a4_f167_526f950d1a6c["EchoServerHandler"]
  96f28521_cfc8_a185_ba27_fa0877ab74ae -->|defined in| e767f6ee_a0d3_e9a4_f167_526f950d1a6c
  1760f8cb_e381_5129_4d24_fb1c47a9bc79["channelRead0()"]
  1760f8cb_e381_5129_4d24_fb1c47a9bc79 -->|calls| 96f28521_cfc8_a185_ba27_fa0877ab74ae
  1760f8cb_e381_5129_4d24_fb1c47a9bc79["channelRead0()"]
  96f28521_cfc8_a185_ba27_fa0877ab74ae -->|calls| 1760f8cb_e381_5129_4d24_fb1c47a9bc79
  4102d101_df19_f944_0dcd_20e90713eade["logStats()"]
  96f28521_cfc8_a185_ba27_fa0877ab74ae -->|calls| 4102d101_df19_f944_0dcd_20e90713eade
  style 96f28521_cfc8_a185_ba27_fa0877ab74ae fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketSslEchoTest.java lines 559–593

        @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]);
            }

            ByteBuf buf = randomBufferType(ctx.alloc(), actual, 0, actual.length);
            if (useCompositeByteBuf) {
                buf = Unpooled.compositeBuffer().addComponent(true, buf);
            }
            ctx.writeAndFlush(buf);

            recvCounter.addAndGet(actual.length);

            // Perform server-initiated renegotiation if necessary.
            if (renegotiation.type == RenegotiationType.SERVER_INITIATED &&
                recvCounter.get() > data.length / 2 && renegoFuture == null) {

                SslHandler sslHandler = ctx.pipeline().get(SslHandler.class);

                Future<Channel> hf = sslHandler.handshakeFuture();
                assertTrue(hf.isDone());

                sslHandler.engine().setEnabledCipherSuites(new String[] { renegotiation.cipherSuite });
                logStats("SERVER RENEGOTIATES");
                renegoFuture = sslHandler.renegotiate();
                assertNotSame(renegoFuture, hf);
                assertSame(renegoFuture, sslHandler.handshakeFuture());
                assertFalse(renegoFuture.isDone());
            }
        }