runTest() — netty Function Reference

Architecture documentation for the runTest() function in ThreadPerChannelEventLoopGroupTest.java from the netty codebase.

Function java Buffer Telemetry calls 1 called by 2

Entity Profile

Buffer→ Telemetry→ runTest() — netty Function Reference

Dependency Diagram

graph TD
  a1cc7dac_2447_0e97_a67a_2b155b9c5c4c["runTest()"]
  f4567ea2_d860_6e7e_51e1_01e57493fa4f["ThreadPerChannelEventLoopGroupTest"]
  a1cc7dac_2447_0e97_a67a_2b155b9c5c4c -->|defined in| f4567ea2_d860_6e7e_51e1_01e57493fa4f
  2cc502ae_2a3e_ce82_2c8b_54d2aa14a4fc["testTerminationFutureSuccessInLog()"]
  2cc502ae_2a3e_ce82_2c8b_54d2aa14a4fc -->|calls| a1cc7dac_2447_0e97_a67a_2b155b9c5c4c
  d4190fb8_00e0_9168_b7ab_f0c14a9af675["testTerminationFutureSuccessReflectively()"]
  d4190fb8_00e0_9168_b7ab_f0c14a9af675 -->|calls| a1cc7dac_2447_0e97_a67a_2b155b9c5c4c
  f8ee9534_f94b_51d4_12a7_a7f3031ed8ca["TestEventExecutor()"]
  a1cc7dac_2447_0e97_a67a_2b155b9c5c4c -->|calls| f8ee9534_f94b_51d4_12a7_a7f3031ed8ca
  style a1cc7dac_2447_0e97_a67a_2b155b9c5c4c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ThreadPerChannelEventLoopGroupTest.java lines 82–94

    private static void runTest(ThreadPerChannelEventLoopGroup loopGroup) throws InterruptedException {
        int taskCount = 100;
        EventExecutor testExecutor = new TestEventExecutor();
        ChannelGroup channelGroup = new DefaultChannelGroup(testExecutor);
        while (taskCount-- > 0) {
            Channel channel = new EmbeddedChannel(NOOP_HANDLER);
            loopGroup.register(new DefaultChannelPromise(channel, testExecutor));
            channelGroup.add(channel);
        }
        channelGroup.close().sync();
        loopGroup.shutdownGracefully(100, 200, TimeUnit.MILLISECONDS).sync();
        assertTrue(loopGroup.isTerminated());
    }