testAsyncResolutionFailure() — netty Function Reference

Architecture documentation for the testAsyncResolutionFailure() function in BootstrapTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testAsyncResolutionFailure() — netty Function Reference

Dependency Diagram

graph TD
  c292f17c_9a9f_368f_b184_959cd554534b["testAsyncResolutionFailure()"]
  7a7606db_8d2a_bfe0_9993_4aaa8e0a6e42["BootstrapTest"]
  c292f17c_9a9f_368f_b184_959cd554534b -->|defined in| 7a7606db_8d2a_bfe0_9993_4aaa8e0a6e42
  2073fa87_a419_13b7_1449_424dbe932785["TestAddressResolverGroup()"]
  c292f17c_9a9f_368f_b184_959cd554534b -->|calls| 2073fa87_a419_13b7_1449_424dbe932785
  style c292f17c_9a9f_368f_b184_959cd554534b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/bootstrap/BootstrapTest.java lines 368–390

    @Test
    public void testAsyncResolutionFailure() throws Exception {
        final Bootstrap bootstrapA = new Bootstrap();
        bootstrapA.group(groupA);
        bootstrapA.channel(LocalChannel.class);
        bootstrapA.resolver(new TestAddressResolverGroup(false));
        bootstrapA.handler(dummyHandler);

        final ServerBootstrap bootstrapB = new ServerBootstrap();
        bootstrapB.group(groupB);
        bootstrapB.channel(LocalServerChannel.class);
        bootstrapB.childHandler(dummyHandler);
        SocketAddress localAddress = bootstrapB.bind(LocalAddress.ANY).sync().channel().localAddress();

        // Connect to the server using the asynchronous resolver.
        ChannelFuture connectFuture = bootstrapA.connect(localAddress);

        // Should fail with the UnknownHostException.
        assertTrue(connectFuture.await(10000));
        assertInstanceOf(UnknownHostException.class, connectFuture.cause());
        connectFuture.channel().closeFuture().await(10000);
        assertFalse(connectFuture.channel().isOpen());
    }