testTransport() — netty Function Reference

Source Code

testsuite-native-image/src/main/java/io/netty/testsuite/svm/HttpNativeServer.java lines 77–112

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