netty Architecture Docs
Home / Function/ testAutoReadDisabled() — netty Function Reference

testAutoReadDisabled() — netty Function Reference

Architecture documentation for the testAutoReadDisabled() function in LocalChannelTest.java from the netty codebase.

Function java Buffer Telemetry calls 4 called by 2

Entity Profile

Dependency Diagram

graph TD
  14d580fd_f7f5_90d7_4ad8_5458f2d095b8["testAutoReadDisabled()"]
  d7e5442a_9b99_814d_2bd6_0be57237db65["LocalChannelTest"]
  14d580fd_f7f5_90d7_4ad8_5458f2d095b8 -->|defined in| d7e5442a_9b99_814d_2bd6_0be57237db65
  cbb52834_2c13_c926_4c0b_cc99bb885de0["testAutoReadDisabledSharedGroup()"]
  cbb52834_2c13_c926_4c0b_cc99bb885de0 -->|calls| 14d580fd_f7f5_90d7_4ad8_5458f2d095b8
  74c0162b_71b8_8459_1a85_049b04a30e2a["testAutoReadDisabledDifferentGroup()"]
  74c0162b_71b8_8459_1a85_049b04a30e2a -->|calls| 14d580fd_f7f5_90d7_4ad8_5458f2d095b8
  8088efe8_c29f_fb7e_c0b6_5eeb1a6637f1["channelActive()"]
  14d580fd_f7f5_90d7_4ad8_5458f2d095b8 -->|calls| 8088efe8_c29f_fb7e_c0b6_5eeb1a6637f1
  edd8ed97_aedc_7cf1_89ef_0d9967b27bab["writeAndFlushReadOnSuccess()"]
  14d580fd_f7f5_90d7_4ad8_5458f2d095b8 -->|calls| edd8ed97_aedc_7cf1_89ef_0d9967b27bab
  d3c8aa54_ac5d_6944_e789_c2c22ce16089["closeChannel()"]
  14d580fd_f7f5_90d7_4ad8_5458f2d095b8 -->|calls| d3c8aa54_ac5d_6944_e789_c2c22ce16089
  c89c9d89_4030_c998_7504_cb2fa2ef2bc8["channelRead()"]
  14d580fd_f7f5_90d7_4ad8_5458f2d095b8 -->|calls| c89c9d89_4030_c998_7504_cb2fa2ef2bc8
  style 14d580fd_f7f5_90d7_4ad8_5458f2d095b8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalChannelTest.java lines 1014–1065

    private static void testAutoReadDisabled(EventLoopGroup serverGroup, EventLoopGroup clientGroup) throws Exception {
        final CountDownLatch latch = new CountDownLatch(100);
        Bootstrap cb = new Bootstrap();
        ServerBootstrap sb = new ServerBootstrap();

        cb.group(serverGroup)
                .channel(LocalChannel.class)
                .option(ChannelOption.AUTO_READ, false)
                .handler(new ChannelInboundHandlerAdapter() {

                    @Override
                    public void channelActive(final ChannelHandlerContext ctx) throws Exception {
                        writeAndFlushReadOnSuccess(ctx, "test");
                    }

                    @Override
                    public void channelRead(final ChannelHandlerContext ctx, Object msg) throws Exception {
                        writeAndFlushReadOnSuccess(ctx, msg);
                    }
                });

        sb.group(clientGroup)
                .channel(LocalServerChannel.class)
                .childOption(ChannelOption.AUTO_READ, false)
                .childHandler(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelActive(final ChannelHandlerContext ctx) throws Exception {
                        ctx.read();
                    }

                    @Override
                    public void channelRead(final ChannelHandlerContext ctx, Object msg) throws Exception {
                        latch.countDown();
                        if (latch.getCount() > 0) {
                            writeAndFlushReadOnSuccess(ctx, msg);
                        }
                    }
                });

        Channel sc = null;
        Channel cc = null;
        try {
            // Start server
            sc = sb.bind(TEST_ADDRESS).sync().channel();
            cc = cb.connect(TEST_ADDRESS).sync().channel();

            latch.await();
        } finally {
            closeChannel(cc);
            closeChannel(sc);
        }
    }

Domain

Subdomains

Defined In

Calls

Called By

Source

Frequently Asked Questions

What does testAutoReadDisabled() do?
testAutoReadDisabled() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/local/LocalChannelTest.java.
Where is testAutoReadDisabled() defined?
testAutoReadDisabled() is defined in transport/src/test/java/io/netty/channel/local/LocalChannelTest.java at line 1014.
What does testAutoReadDisabled() call?
testAutoReadDisabled() calls 4 function(s): channelActive, channelRead, closeChannel, writeAndFlushReadOnSuccess.
What calls testAutoReadDisabled()?
testAutoReadDisabled() is called by 2 function(s): testAutoReadDisabledDifferentGroup, testAutoReadDisabledSharedGroup.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free