netty Architecture Docs
Home / Class/ SocketGatheringWriteTest Class — netty Architecture

SocketGatheringWriteTest Class — netty Architecture

Architecture documentation for the SocketGatheringWriteTest class in SocketGatheringWriteTest.java from the netty codebase.

Class java

Entity Profile

Dependency Diagram

graph TD
  6d44418a_b3ab_891d_4077_734b9f438867["SocketGatheringWriteTest"]
  41c5cef7_c62b_3a8b_889d_709938bf272c["SocketGatheringWriteTest.java"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|defined in| 41c5cef7_c62b_3a8b_889d_709938bf272c
  448e83b9_590d_e144_68ee_18d9e1c882c3["compressHeapDumps()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| 448e83b9_590d_e144_68ee_18d9e1c882c3
  148f64a2_7910_85e4_0f1e_be939e87470b["testGatheringWrite()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| 148f64a2_7910_85e4_0f1e_be939e87470b
  0ed34e77_d6b0_1f71_523f_bab0958e8bba["testGatheringWriteNotAutoRead()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| 0ed34e77_d6b0_1f71_523f_bab0958e8bba
  053aa526_30ca_cb91_3d75_8b97658f7d33["testGatheringWriteWithComposite()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| 053aa526_30ca_cb91_3d75_8b97658f7d33
  47978516_081a_1ba6_35ec_c278a9e9a7b9["testGatheringWriteWithCompositeNotAutoRead()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| 47978516_081a_1ba6_35ec_c278a9e9a7b9
  3cf2d5b1_3589_fc91_340d_cbfb0a1bfe73["testGatheringWriteBig()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| 3cf2d5b1_3589_fc91_340d_cbfb0a1bfe73
  f09a2d81_a4a2_ecdc_8aab_6fba73e64850["testGatheringWrite0()"]
  6d44418a_b3ab_891d_4077_734b9f438867 -->|method| f09a2d81_a4a2_ecdc_8aab_6fba73e64850

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketGatheringWriteTest.java lines 49–281

public class SocketGatheringWriteTest extends AbstractSocketTest {
    private static final long TIMEOUT = 120000;

    private static final Random random = new Random();
    static final byte[] data = new byte[1048576];

    static {
        random.nextBytes(data);
    }

    @AfterAll
    public static void compressHeapDumps() throws Exception {
        TestUtils.compressHeapDumps();
    }

    @Test
    @Timeout(value = TIMEOUT, unit = TimeUnit.MILLISECONDS)
    public void testGatheringWrite(TestInfo testInfo) throws Throwable {
        run(testInfo, new Runner<ServerBootstrap, Bootstrap>() {
            @Override
            public void run(ServerBootstrap serverBootstrap, Bootstrap bootstrap) throws Throwable {
                testGatheringWrite(serverBootstrap, bootstrap);
            }
        });
    }

    public void testGatheringWrite(ServerBootstrap sb, Bootstrap cb) throws Throwable {
        testGatheringWrite0(sb, cb, data, false, true);
    }

    @Test
    @Timeout(value = TIMEOUT, unit = TimeUnit.MILLISECONDS)
    public void testGatheringWriteNotAutoRead(TestInfo testInfo) throws Throwable {
        run(testInfo, new Runner<ServerBootstrap, Bootstrap>() {
            @Override
            public void run(ServerBootstrap serverBootstrap, Bootstrap bootstrap) throws Throwable {
                testGatheringWriteNotAutoRead(serverBootstrap, bootstrap);
            }
        });
    }

    public void testGatheringWriteNotAutoRead(ServerBootstrap sb, Bootstrap cb) throws Throwable {
        testGatheringWrite0(sb, cb, data, false, false);
    }

    @Test
    @Timeout(value = TIMEOUT, unit = TimeUnit.MILLISECONDS)
    public void testGatheringWriteWithComposite(TestInfo testInfo) throws Throwable {
        run(testInfo, new Runner<ServerBootstrap, Bootstrap>() {
            @Override
            public void run(ServerBootstrap serverBootstrap, Bootstrap bootstrap) throws Throwable {
                testGatheringWriteWithComposite(serverBootstrap, bootstrap);
            }
        });
    }

    public void testGatheringWriteWithComposite(ServerBootstrap sb, Bootstrap cb) throws Throwable {
        testGatheringWrite0(sb, cb, data, true, true);
    }

    @Test
    @Timeout(value = TIMEOUT, unit = TimeUnit.MILLISECONDS)
    public void testGatheringWriteWithCompositeNotAutoRead(TestInfo testInfo) throws Throwable {
        run(testInfo, new Runner<ServerBootstrap, Bootstrap>() {
            @Override
            public void run(ServerBootstrap serverBootstrap, Bootstrap bootstrap) throws Throwable {
                testGatheringWriteWithCompositeNotAutoRead(serverBootstrap, bootstrap);
            }
        });
    }

    public void testGatheringWriteWithCompositeNotAutoRead(ServerBootstrap sb, Bootstrap cb) throws Throwable {
        testGatheringWrite0(sb, cb, data, true, false);
    }

    // Test for https://github.com/netty/netty/issues/2647
    @Test
    @Timeout(value = TIMEOUT, unit = TimeUnit.MILLISECONDS)
    public void testGatheringWriteBig(TestInfo testInfo) throws Throwable {
        run(testInfo, new Runner<ServerBootstrap, Bootstrap>() {
            @Override

Defined In

Source

Frequently Asked Questions

What is the SocketGatheringWriteTest class?
SocketGatheringWriteTest is a class in the netty codebase, defined in testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketGatheringWriteTest.java.
Where is SocketGatheringWriteTest defined?
SocketGatheringWriteTest is defined in testsuite/src/main/java/io/netty/testsuite/transport/socket/SocketGatheringWriteTest.java at line 49.

Analyze Your Own Codebase

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

Try Supermodel Free