IoUringBufferRingSocketHalfClosedTest Class — netty Architecture

Source Code

transport-native-io_uring/src/test/java/io/netty/channel/uring/IoUringBufferRingSocketHalfClosedTest.java lines 34–65

public class IoUringBufferRingSocketHalfClosedTest extends SocketHalfClosedTest {

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

    @Override
    protected List<TestsuitePermutation.BootstrapComboFactory<ServerBootstrap, Bootstrap>> newFactories() {
        return IoUringSocketTestPermutation.INSTANCE.socket();
    }

    @Disabled
    @Test
    public void testAutoCloseFalseDoesShutdownOutput(TestInfo testInfo) throws Throwable {
        // This test only works on Linux / BSD / MacOS as we assume some semantics that are not true for Windows.
        Assumptions.assumeFalse(PlatformDependent.isWindows());
        this.run(testInfo, new Runner<ServerBootstrap, Bootstrap>() {
            public void run(ServerBootstrap serverBootstrap, Bootstrap bootstrap) throws Throwable {
                testAutoCloseFalseDoesShutdownOutput(serverBootstrap, bootstrap);
            }
        });
    }

    @Override
    protected void configure(ServerBootstrap sb, Bootstrap cb, ByteBufAllocator allocator) {
        super.configure(sb, cb, allocator);
        sb.childOption(IoUringChannelOption.IO_URING_BUFFER_GROUP_ID, IoUringSocketTestPermutation.BGID);
        cb.option(IoUringChannelOption.IO_URING_BUFFER_GROUP_ID, IoUringSocketTestPermutation.BGID);
    }
}