PollRemoveTest Class — netty Architecture

Source Code

transport-native-io_uring/src/test/java/io/netty/channel/uring/PollRemoveTest.java lines 35–71

public class PollRemoveTest {

    @BeforeAll
    public static void loadJNI() {
        assumeTrue(IoUring.isAvailable());
    }

    private static void ioUringTest() throws Exception {
        Class<? extends ServerSocketChannel> clazz = IoUringServerSocketChannel.class;
        final EventLoopGroup bossGroup = new MultiThreadIoEventLoopGroup(1, IoUringIoHandler.newFactory());

        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup)
                    .channel(clazz)
                    .handler(new LoggingHandler(LogLevel.TRACE))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) { }
                    });

            Channel sc = b.bind(new InetSocketAddress(0)).sync().channel();

            // close ServerChannel
            sc.close().sync();
        } finally {
            bossGroup.shutdownGracefully().sync();
        }
    }

    @Test
    @Timeout(10)
    public void test() throws Exception {
        ioUringTest();
        ioUringTest();
    }
}