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

testFdReuse() — netty Function Reference

Architecture documentation for the testFdReuse() function in KqueueRegistrationTest.java from the netty codebase.

Function java Buffer Search

Entity Profile

Dependency Diagram

graph TD
  f0d0b1f4_0be9_eb5c_984e_e075507a4dac["testFdReuse()"]
  9dcb66d1_f1bf_d5d1_58a3_458fb1c06004["KqueueRegistrationTest"]
  f0d0b1f4_0be9_eb5c_984e_e075507a4dac -->|defined in| 9dcb66d1_f1bf_d5d1_58a3_458fb1c06004
  style f0d0b1f4_0be9_eb5c_984e_e075507a4dac fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-native-kqueue/src/test/java/io/netty/channel/kqueue/KqueueRegistrationTest.java lines 42–70

    @Test
    void testFdReuse() throws Exception {
        Bootstrap bootstrap = new Bootstrap();
        EventLoopGroup group = new MultiThreadIoEventLoopGroup(1, KQueueIoHandler.newFactory());
        Promise<Throwable> promise = ImmediateEventExecutor.INSTANCE.newPromise();
        try {
            bootstrap.group(group)
                    .channel(KQueueSocketChannel.class)
                    .handler(new LoggingHandler());
            bootstrap.connect(new InetSocketAddress(NetUtil.LOCALHOST, SocketTestPermutation.UNASSIGNED_PORT))
                    .addListener((ChannelFutureListener) f1 -> {
                        if (f1.cause() instanceof ConnectException) {
                            f1.channel().close();
                            bootstrap.connect(new InetSocketAddress(NetUtil.LOCALHOST,
                                            SocketTestPermutation.UNASSIGNED_PORT))
                                    .addListener((ChannelFutureListener) f2 -> {
                                        f2.channel().close();
                                        promise.setSuccess(f2.cause());
                                    });
                        } else {
                            promise.setFailure(new IllegalStateException());
                        }
                    });
            Throwable cause = promise.sync().getNow();
            assertInstanceOf(ConnectException.class, cause);
        } finally {
            group.shutdownGracefully();
        }
    }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does testFdReuse() do?
testFdReuse() is a function in the netty codebase, defined in transport-native-kqueue/src/test/java/io/netty/channel/kqueue/KqueueRegistrationTest.java.
Where is testFdReuse() defined?
testFdReuse() is defined in transport-native-kqueue/src/test/java/io/netty/channel/kqueue/KqueueRegistrationTest.java at line 42.

Analyze Your Own Codebase

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

Try Supermodel Free