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

connection() — netty Function Reference

Architecture documentation for the connection() function in UDTClientServerConnectionTest.java from the netty codebase.

Function java Buffer Telemetry calls 6

Entity Profile

Dependency Diagram

graph TD
  098a2fa4_b848_c4c1_4779_df3351dcad97["connection()"]
  d1f4d11f_273b_d830_ba49_5a533bb67ca2["UDTClientServerConnectionTest"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|defined in| d1f4d11f_273b_d830_ba49_5a533bb67ca2
  59192b2b_0b17_9997_b432_7ae855241154["Server()"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|calls| 59192b2b_0b17_9997_b432_7ae855241154
  202b92d3_2598_75c5_0717_6264769764e5["Client()"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|calls| 202b92d3_2598_75c5_0717_6264769764e5
  632a767d_e337_a2b4_e179_e0d936c7c46f["waitForRunning()"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|calls| 632a767d_e337_a2b4_e179_e0d936c7c46f
  d5ad0d45_ae71_a7dc_a011_d131fc7e1b17["waitForActive()"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|calls| d5ad0d45_ae71_a7dc_a011_d131fc7e1b17
  a0134c18_fe0e_5eb1_f2a3_def1ef7cc27e["shutdown()"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|calls| a0134c18_fe0e_5eb1_f2a3_def1ef7cc27e
  6b262873_d5f3_7d06_8c3b_8f45cad9f1bf["waitForShutdown()"]
  098a2fa4_b848_c4c1_4779_df3351dcad97 -->|calls| 6b262873_d5f3_7d06_8c3b_8f45cad9f1bf
  style 098a2fa4_b848_c4c1_4779_df3351dcad97 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite/src/main/java/io/netty/testsuite/transport/udt/UDTClientServerConnectionTest.java lines 356–398

    @Test
    public void connection() throws Exception {
        log.info("Starting server.");
        // Using LOCALHOST4 as UDT transport does not support IPV6 :(
        final Server server = new Server(new InetSocketAddress(NetUtil.LOCALHOST4, 0));
        final Thread serverTread = new Thread(server, "server-*");
        serverTread.start();
        server.waitForRunning(true);
        assertTrue(server.isRunning);

        log.info("Starting client.");
        final Client client = new Client((InetSocketAddress) server.channel.localAddress());
        final Thread clientThread = new Thread(client, "client-*");
        clientThread.start();
        client.waitForRunning(true);
        assertTrue(client.isRunning);

        log.info("Wait till connection is active.");
        client.waitForActive(true);
        server.waitForActive(true);

        log.info("Verify connection is active.");
        assertEquals(1, server.group.size(), "group must have one");

        log.info("Stopping client.");
        client.shutdown();
        client.waitForShutdown();
        assertTrue(client.isShutdown);

        log.info("Wait till connection is inactive.");
        client.waitForActive(false);
        server.waitForActive(false);

        log.info("Verify connection is inactive.");
        assertEquals(0, server.group.size(), "group must be empty");

        log.info("Stopping server.");
        server.shutdown();
        server.waitForShutdown();
        assertTrue(server.isShutdown);

        log.info("Finished server.");
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does connection() do?
connection() is a function in the netty codebase, defined in testsuite/src/main/java/io/netty/testsuite/transport/udt/UDTClientServerConnectionTest.java.
Where is connection() defined?
connection() is defined in testsuite/src/main/java/io/netty/testsuite/transport/udt/UDTClientServerConnectionTest.java at line 356.
What does connection() call?
connection() calls 6 function(s): Client, Server, shutdown, waitForActive, waitForRunning, waitForShutdown.

Analyze Your Own Codebase

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

Try Supermodel Free