testMaxMessagesPerReadRespected() — netty Function Reference

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

Function java Buffer Search calls 3 called by 4

Entity Profile

Buffer→ Search→ testMaxMessagesPerReadRespected() — netty Function Reference

Dependency Diagram

graph TD
  50477df6_2dac_e5be_8ce3_1d6fd14815a2["testMaxMessagesPerReadRespected()"]
  d7e5442a_9b99_814d_2bd6_0be57237db65["LocalChannelTest"]
  50477df6_2dac_e5be_8ce3_1d6fd14815a2 -->|defined in| d7e5442a_9b99_814d_2bd6_0be57237db65
  426a7149_5123_fb13_0881_9cc66635dd90["testMaxMessagesPerReadRespectedWithAutoReadSharedGroup()"]
  426a7149_5123_fb13_0881_9cc66635dd90 -->|calls| 50477df6_2dac_e5be_8ce3_1d6fd14815a2
  30ed6d55_f17d_210d_f73e_2fbc45620335["testMaxMessagesPerReadRespectedWithoutAutoReadSharedGroup()"]
  30ed6d55_f17d_210d_f73e_2fbc45620335 -->|calls| 50477df6_2dac_e5be_8ce3_1d6fd14815a2
  1614a921_03c7_9f3c_ff30_da8769591e3d["testMaxMessagesPerReadRespectedWithAutoReadDifferentGroup()"]
  1614a921_03c7_9f3c_ff30_da8769591e3d -->|calls| 50477df6_2dac_e5be_8ce3_1d6fd14815a2
  5701afa1_4b2a_58ca_82d9_a80226c4c3e0["testMaxMessagesPerReadRespectedWithoutAutoReadDifferentGroup()"]
  5701afa1_4b2a_58ca_82d9_a80226c4c3e0 -->|calls| 50477df6_2dac_e5be_8ce3_1d6fd14815a2
  5b2d9136_7a5a_b6bb_cfbc_ebeb20c2e2ec["ChannelReadHandler()"]
  50477df6_2dac_e5be_8ce3_1d6fd14815a2 -->|calls| 5b2d9136_7a5a_b6bb_cfbc_ebeb20c2e2ec
  8088efe8_c29f_fb7e_c0b6_5eeb1a6637f1["channelActive()"]
  50477df6_2dac_e5be_8ce3_1d6fd14815a2 -->|calls| 8088efe8_c29f_fb7e_c0b6_5eeb1a6637f1
  d3c8aa54_ac5d_6944_e789_c2c22ce16089["closeChannel()"]
  50477df6_2dac_e5be_8ce3_1d6fd14815a2 -->|calls| d3c8aa54_ac5d_6944_e789_c2c22ce16089
  style 50477df6_2dac_e5be_8ce3_1d6fd14815a2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalChannelTest.java lines 1091–1126

    private static void testMaxMessagesPerReadRespected(
            EventLoopGroup serverGroup, EventLoopGroup clientGroup, final boolean autoRead) throws Exception {
        final CountDownLatch countDownLatch = new CountDownLatch(5);
        Bootstrap cb = new Bootstrap();
        ServerBootstrap sb = new ServerBootstrap();

        cb.group(serverGroup)
                .channel(LocalChannel.class)
                .option(ChannelOption.AUTO_READ, autoRead)
                .option(ChannelOption.MAX_MESSAGES_PER_READ, 1)
                .handler(new ChannelReadHandler(countDownLatch, autoRead));
        sb.group(clientGroup)
                .channel(LocalServerChannel.class)
                .childHandler(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelActive(final ChannelHandlerContext ctx) {
                        for (int i = 0; i < 10; i++) {
                            ctx.write(i);
                        }
                        ctx.flush();
                    }
                });

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

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

Domain

Buffer

Subdomains

Defined In

transport/src/test/java/io/netty/channel/local/LocalChannelTest.java

Calls

Called By

Source

View on GitHub

Frequently Asked Questions

What does testMaxMessagesPerReadRespected() do?

testMaxMessagesPerReadRespected() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/local/LocalChannelTest.java.

Where is testMaxMessagesPerReadRespected() defined?

testMaxMessagesPerReadRespected() is defined in transport/src/test/java/io/netty/channel/local/LocalChannelTest.java at line 1091.

What does testMaxMessagesPerReadRespected() call?

testMaxMessagesPerReadRespected() calls 3 function(s): ChannelReadHandler, channelActive, closeChannel.

What calls testMaxMessagesPerReadRespected()?

testMaxMessagesPerReadRespected() is called by 4 function(s): testMaxMessagesPerReadRespectedWithAutoReadDifferentGroup, testMaxMessagesPerReadRespectedWithAutoReadSharedGroup, testMaxMessagesPerReadRespectedWithoutAutoReadDifferentGroup, testMaxMessagesPerReadRespectedWithoutAutoReadSharedGroup.

Analyze Your Own Codebase

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

Try Supermodel Free