Netty tests dynamic port assignment.

Author: kimeta

tests/src/io.netty/netty-common/4.1.115.Final/src/test/java/netty/NettyTests.java

@@ -69,7 +69,7 @@
 import static io.netty.util.NetUtil.LOCALHOST;
 
 public class NettyTests {
-    private static final int PORT = 8080;
+    private int port;
 
     @Test
     void withSsl() throws Exception {
@@ -149,7 +149,7 @@ private void startClient(EventLoopGroup group, boolean ssl, boolean withAdaptive
         if (withAdaptive) {
             b.option(ChannelOption.ALLOCATOR, new AdaptiveByteBufAllocator());
         }
-        Channel ch = b.connect("localhost", PORT).sync().channel();
+        Channel ch = b.connect("localhost", port).sync().channel();
         HttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "/", Unpooled.EMPTY_BUFFER);
         request.headers().set(HttpHeaderNames.HOST, "localhost");
         request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.CLOSE);
@@ -171,7 +171,8 @@ private void startServer(EventLoopGroup bossGroup, EventLoopGroup workerGroup, b
             b.option(ChannelOption.ALLOCATOR, new AdaptiveByteBufAllocator())
                     .childOption(ChannelOption.ALLOCATOR, new AdaptiveByteBufAllocator());
         }
-        b.bind(PORT).sync();
+        Channel channel = b.bind(0).sync().channel();
+        this.port = ((NioServerSocketChannel) channel).localAddress().getPort();
     }
 
     private static final class HttpClientInitializer extends ChannelInitializer<SocketChannel> {

tests/src/io.netty/netty-common/4.1.80.Final/src/test/java/netty/NettyTests.java

@@ -67,7 +67,7 @@
 import static io.netty.util.NetUtil.LOCALHOST;
 
 public class NettyTests {
-    private static final int PORT = 8080;
+    private int port = 8080;
 
     @Test
     void withSsl() throws Exception {
@@ -139,7 +139,7 @@ private void startClient(EventLoopGroup group, boolean ssl, Consumer<Response> c
         }
         Bootstrap b = new Bootstrap();
         b.group(group).channel(NioSocketChannel.class).handler(new HttpClientInitializer(sslContext, callback));
-        Channel ch = b.connect("localhost", PORT).sync().channel();
+        Channel ch = b.connect("localhost", port).sync().channel();
         HttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "/", Unpooled.EMPTY_BUFFER);
         request.headers().set(HttpHeaderNames.HOST, "localhost");
         request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.CLOSE);
@@ -157,7 +157,8 @@ private void startServer(EventLoopGroup bossGroup, EventLoopGroup workerGroup, b
                 .channel(NioServerSocketChannel.class)
                 .handler(new LoggingHandler(LogLevel.INFO))
                 .childHandler(new HttpServerInitializer(sslContext));
-        b.bind(PORT).sync();
+        Channel channel = b.bind(0).sync().channel();
+        this.port = ((NioServerSocketChannel) channel).localAddress().getPort();
     }
 
     private static final class HttpClientInitializer extends ChannelInitializer<SocketChannel> {

tests/src/io.netty/netty-transport/4.1.115.Final/src/test/java/netty/NettyTests.java

@@ -59,7 +59,7 @@
 import org.junit.jupiter.api.Test;
 
 public class NettyTests {
-    private static final int PORT = 8080;
+    private int port;
 
     @Test
     void withSsl() throws Exception {
@@ -101,7 +101,7 @@ private void startClient(EventLoopGroup group, boolean ssl, Consumer<Response> c
         }
         Bootstrap b = new Bootstrap();
         b.group(group).channel(NioSocketChannel.class).handler(new HttpClientInitializer(sslContext, callback));
-        Channel ch = b.connect("localhost", PORT).sync().channel();
+        Channel ch = b.connect("localhost", port).sync().channel();
         HttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "/", Unpooled.EMPTY_BUFFER);
         request.headers().set(HttpHeaderNames.HOST, "localhost");
         request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.CLOSE);
@@ -119,7 +119,8 @@ private void startServer(EventLoopGroup bossGroup, EventLoopGroup workerGroup, b
                 .channel(NioServerSocketChannel.class)
                 .handler(new LoggingHandler(LogLevel.INFO))
                 .childHandler(new HttpServerInitializer(sslContext));
-        b.bind(PORT).sync();
+        Channel channel = b.bind(0).sync().channel();
+        this.port = ((NioServerSocketChannel) channel).localAddress().getPort();
     }
 
     private static final class HttpClientInitializer extends ChannelInitializer<SocketChannel> {

tests/src/io.netty/netty-transport/4.1.80.Final/src/test/java/netty/NettyTests.java

@@ -59,7 +59,7 @@
 import org.junit.jupiter.api.Test;
 
 public class NettyTests {
-    private static final int PORT = 8080;
+    private int port;
 
     @Test
     void withSsl() throws Exception {
@@ -101,7 +101,7 @@ private void startClient(EventLoopGroup group, boolean ssl, Consumer<Response> c
         }
         Bootstrap b = new Bootstrap();
         b.group(group).channel(NioSocketChannel.class).handler(new HttpClientInitializer(sslContext, callback));
-        Channel ch = b.connect("localhost", PORT).sync().channel();
+        Channel ch = b.connect("localhost", port).sync().channel();
         HttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "/", Unpooled.EMPTY_BUFFER);
         request.headers().set(HttpHeaderNames.HOST, "localhost");
         request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.CLOSE);
@@ -119,7 +119,8 @@ private void startServer(EventLoopGroup bossGroup, EventLoopGroup workerGroup, b
                 .channel(NioServerSocketChannel.class)
                 .handler(new LoggingHandler(LogLevel.INFO))
                 .childHandler(new HttpServerInitializer(sslContext));
-        b.bind(PORT).sync();
+        Channel channel = b.bind(0).sync().channel();
+        this.port = ((NioServerSocketChannel) channel).localAddress().getPort();
     }
 
     private static final class HttpClientInitializer extends ChannelInitializer<SocketChannel> {