mySetupClientHostnameValidation() — netty Function Reference

Source Code

testsuite-jpms/src/test/java/io/netty/testsuite_jpms/test/NativeTransportTest.java lines 84–152

    private void mySetupClientHostnameValidation(IoHandlerFactory ioHandlerFactory,
                                                 Class<? extends ServerSocketChannel> serverSocketChannelFactory,
                                                 Class<? extends SocketChannel> socketChannelFactory
    ) throws InterruptedException {

        ServerBootstrap sb = new ServerBootstrap();
        Bootstrap cb = new Bootstrap();

        sb.group(new MultiThreadIoEventLoopGroup(ioHandlerFactory));
        sb.channel(serverSocketChannelFactory);
        sb.childHandler(new ChannelInitializer() {
            @Override
            protected void initChannel(Channel ch) throws Exception {
                ChannelPipeline p = ch.pipeline();

                p.addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                        if (msg instanceof ByteBuf) {
                            ctx.write(msg);
                        } else {
                            super.channelRead(ctx, msg);
                        }
                    }
                    @Override
                    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
                        ctx.flush();
                    }
                });
            }
        });

        List<String> received = Collections.synchronizedList(new ArrayList<>());

        cb.group(new MultiThreadIoEventLoopGroup(ioHandlerFactory));
        cb.channel(socketChannelFactory);
        cb.handler(new ChannelInitializer<Channel>() {
            @Override
            protected void initChannel(Channel ch) throws Exception {
                ChannelPipeline p = ch.pipeline();
                p.addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                        if (msg instanceof ByteBuf) {
                            ByteBuf buff = (ByteBuf) msg;
                            try {
                                received.add(buff.toString(StandardCharsets.UTF_8));
                            } finally {
                                buff.release();
                            }
                        }
                    }
                });
            }
        });

        Channel serverChannel = sb.bind(new InetSocketAddress("localhost", 0)).sync().channel();
        final int port = ((InetSocketAddress) serverChannel.localAddress()).getPort();

        ChannelFuture ccf = cb.connect(new InetSocketAddress("localhost", port));
        assertTrue(ccf.awaitUninterruptibly().isSuccess());
        Channel clientChannel = ccf.channel();
        clientChannel.writeAndFlush(Unpooled.copiedBuffer("hello", StandardCharsets.UTF_8)).sync();

        while (received.isEmpty()) {
            Thread.sleep(100);
        }
        assertEquals("hello", received.get(0));
    }