HttpNativeServer Class — netty Architecture

Source Code

testsuite-native-image/src/main/java/io/netty/testsuite/svm/HttpNativeServer.java lines 55–183

public final class HttpNativeServer {

    /**
     * Main entry point (not instantiable)
     */
    private HttpNativeServer() {
    }

    public static void main(String[] args) throws Exception {
        for (TransportType value : TransportType.values()) {
            for (AllocatorType allocatorType : AllocatorType.values()) {
                boolean serverStartSucess = testTransport(value, allocatorType);
                System.out.println("Server started with transport type " + value + ": " + serverStartSucess);
                if (!serverStartSucess) {
                    System.exit(1);
                }
            }
        }
        // return the right system exit code to signal success
        System.exit(0);
    }

    public static boolean testTransport(TransportType ioType, AllocatorType allocatorType) throws Exception {
        // Configure the server.
        EventLoopGroup group = new MultiThreadIoEventLoopGroup(chooseFactory(ioType));
        // Control status.
        boolean serverStartSucess = false;
        try {
            CompletableFuture<Void> httpRequestFuture = new CompletableFuture<>();
            ServerBootstrap b = new ServerBootstrap();
            b.option(ChannelOption.SO_BACKLOG, 1024);
            b.group(group)
                    .channel(chooseServerChannelClass(ioType))
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .childOption(ChannelOption.ALLOCATOR, chooseAllocator(allocatorType))
                    .childHandler(new HttpNativeServerInitializer(httpRequestFuture));

            Channel channel = b.bind(0).sync().channel();
            System.err.println("Server started, will shutdown now.");

            Channel httpClient = new HttpNativeClient(
                    ((InetSocketAddress) channel.localAddress()).getPort(),
                    group, chooseChannelClass(ioType)
            ).initClient();
            DefaultFullHttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "/hello");

            httpClient.writeAndFlush(request).sync();

            httpRequestFuture.get();

            channel.close().sync();
            httpClient.close().sync();
            serverStartSucess = true;
        } finally {
            group.shutdownGracefully();
        }
        return serverStartSucess;
    }

    public static IoHandlerFactory chooseFactory(TransportType ioType) {
        if (ioType == TransportType.EPOLL) {
            return EpollIoHandler.newFactory();
        }

        if (ioType == TransportType.IO_URING) {
            IoUringIoHandlerConfig config = new IoUringIoHandlerConfig();
            if (IoUring.isRegisterBufferRingSupported()) {
                config.setBufferRingConfig(
                        IoUringBufferRingConfig.builder()
                                .bufferGroupId((short) 0)
                                .bufferRingSize((short) 16)
                                .batchSize(16)
                                .allocator(new IoUringFixedBufferRingAllocator(1024))
                                .batchAllocation(false)
                                .build()
                );
            }

           return IoUringIoHandler.newFactory(config);
        }