ioUringTest() — netty Function Reference

Architecture documentation for the ioUringTest() function in PollRemoveTest.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ ioUringTest() — netty Function Reference

Dependency Diagram

graph TD
  48dab5e8_a309_bea2_771a_866672d03caf["ioUringTest()"]
  97f9051d_0b4a_2085_3e9e_eb03d8e4b0b0["PollRemoveTest"]
  48dab5e8_a309_bea2_771a_866672d03caf -->|defined in| 97f9051d_0b4a_2085_3e9e_eb03d8e4b0b0
  cc670b6c_5441_3e97_0ef8_740333d7d40c["test()"]
  cc670b6c_5441_3e97_0ef8_740333d7d40c -->|calls| 48dab5e8_a309_bea2_771a_866672d03caf
  style 48dab5e8_a309_bea2_771a_866672d03caf fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

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

    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();
        }
    }