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

testCloseEventLoopGroupWhileConnected() — netty Function Reference

Architecture documentation for the testCloseEventLoopGroupWhileConnected() function in IoUringBufferRingTest.java from the netty codebase.

Function java Buffer Search

Entity Profile

Dependency Diagram

graph TD
  b32f1401_36aa_7bfe_a47f_20c524820ad0["testCloseEventLoopGroupWhileConnected()"]
  d2c51010_6ec0_7e8f_47d3_2646c5769913["IoUringBufferRingTest"]
  b32f1401_36aa_7bfe_a47f_20c524820ad0 -->|defined in| d2c51010_6ec0_7e8f_47d3_2646c5769913
  style b32f1401_36aa_7bfe_a47f_20c524820ad0 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-native-io_uring/src/test/java/io/netty/channel/uring/IoUringBufferRingTest.java lines 262–299

    @Test
    public void testCloseEventLoopGroupWhileConnected() throws Exception {
        MultiThreadIoEventLoopGroup group = new MultiThreadIoEventLoopGroup(1,
                IoUringIoHandler.newFactory()
        );
        try {
            final BlockingQueue<Channel> acceptedChannels = new LinkedBlockingQueue<>();
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.channel(IoUringServerSocketChannel.class);
            Channel serverChannel = serverBootstrap.group(group)
                    .childHandler(new ChannelInboundHandlerAdapter() {
                        @Override
                        public void channelActive(ChannelHandlerContext ctx) {
                            acceptedChannels.add(ctx.channel());
                        }
                    })
                    .bind(new InetSocketAddress(0))
                    .syncUninterruptibly().channel();

            Bootstrap clientBoostrap = new Bootstrap();
            clientBoostrap.group(group)
                    .channel(IoUringSocketChannel.class)
                    .handler(new ChannelInboundHandlerAdapter());
            ChannelFuture channelFuture = clientBoostrap.connect(serverChannel.localAddress());
            Channel clientChannel = channelFuture.sync().channel();

            group.shutdownGracefully().syncUninterruptibly();
            clientChannel.closeFuture().sync();
            serverChannel.closeFuture().sync();
            acceptedChannels.take().closeFuture().sync();
            assertTrue(acceptedChannels.isEmpty());
        } catch (Throwable t) {
            if (!group.isShutdown()) {
                group.shutdownGracefully().syncUninterruptibly();
            }
            throw t;
        }
    }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does testCloseEventLoopGroupWhileConnected() do?
testCloseEventLoopGroupWhileConnected() is a function in the netty codebase, defined in transport-native-io_uring/src/test/java/io/netty/channel/uring/IoUringBufferRingTest.java.
Where is testCloseEventLoopGroupWhileConnected() defined?
testCloseEventLoopGroupWhileConnected() is defined in transport-native-io_uring/src/test/java/io/netty/channel/uring/IoUringBufferRingTest.java at line 262.

Analyze Your Own Codebase

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

Try Supermodel Free