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

testConnectAlreadyConnected() — netty Function Reference

Architecture documentation for the testConnectAlreadyConnected() function in QuicChannelConnectTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Dependency Diagram

graph TD
  73d6a63c_be4a_a21a_a0be_186ced120265["testConnectAlreadyConnected()"]
  1e1bc485_1969_4537_ef9b_f28971b2f663["QuicChannelConnectTest"]
  73d6a63c_be4a_a21a_a0be_186ced120265 -->|defined in| 1e1bc485_1969_4537_ef9b_f28971b2f663
  5f0fc68a_3438_a865_1307_d0a3144b2c00["assertState()"]
  73d6a63c_be4a_a21a_a0be_186ced120265 -->|calls| 5f0fc68a_3438_a865_1307_d0a3144b2c00
  style 73d6a63c_be4a_a21a_a0be_186ced120265 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicChannelConnectTest.java lines 564–599

    @ParameterizedTest
    @MethodSource("newSslTaskExecutors")
    public void testConnectAlreadyConnected(Executor executor) throws Throwable {
        ChannelActiveVerifyHandler serverQuicChannelHandler = new ChannelActiveVerifyHandler();
        ChannelStateVerifyHandler serverQuicStreamHandler = new ChannelStateVerifyHandler();

        Channel server = QuicTestUtils.newServer(executor, serverQuicChannelHandler, serverQuicStreamHandler);
        InetSocketAddress address = (InetSocketAddress) server.localAddress();
        Channel channel = QuicTestUtils.newClient(executor);
        try {
            ChannelActiveVerifyHandler clientQuicChannelHandler = new ChannelActiveVerifyHandler();
            QuicChannel quicChannel = QuicTestUtils.newQuicChannelBootstrap(channel)
                    .handler(clientQuicChannelHandler)
                    .streamHandler(new ChannelInboundHandlerAdapter())
                    .remoteAddress(address)
                    .connect()
                    .get();

            // Try to connect again
            ChannelFuture connectFuture = quicChannel.connect(QuicConnectionAddress.random());
            Throwable cause = connectFuture.await().cause();
            assertInstanceOf(AlreadyConnectedException.class, cause);
            assertTrue(quicChannel.close().await().isSuccess());
            ChannelFuture closeFuture = quicChannel.closeFuture().await();
            assertTrue(closeFuture.isSuccess());
            clientQuicChannelHandler.assertState();
            serverQuicChannelHandler.assertState();
            serverQuicStreamHandler.assertState();
        } finally {
            server.close().sync();
            // Close the parent Datagram channel as well.
            channel.close().sync();

            shutdown(executor);
        }
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does testConnectAlreadyConnected() do?
testConnectAlreadyConnected() is a function in the netty codebase, defined in codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicChannelConnectTest.java.
Where is testConnectAlreadyConnected() defined?
testConnectAlreadyConnected() is defined in codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicChannelConnectTest.java at line 564.
What does testConnectAlreadyConnected() call?
testConnectAlreadyConnected() calls 1 function(s): assertState.

Analyze Your Own Codebase

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

Try Supermodel Free