QuicEndpoint#bind returned future should be succeeded with the port of the UDP channel of the bind operation.

Author: vietj

vertx-core/src/main/java/io/vertx/core/net/QuicEndpoint.java

@@ -36,9 +36,10 @@ public interface QuicEndpoint extends Measured {
    * </ul>
    *
    * @param address the bind address
-   * @return a future signaling the success or failure of the bind operation
+   * @return a future signaling the success or failure of the bind operation, the future completion is the bound this
+   *         endpoint was bound to
    */
-  Future<Void> bind(SocketAddress address);
+  Future<Integer> bind(SocketAddress address);
 
   /**
    * Close the endpoint and release all associated resources.

vertx-core/src/main/java/io/vertx/core/net/impl/quic/QuicEndpointImpl.java

@@ -189,7 +189,7 @@ protected void handleClose(Completable<Void> completion) {
   }
 
   @Override
-  public Future<Void> bind(SocketAddress address) {
+  public Future<Integer> bind(SocketAddress address) {
     ContextInternal context = vertx.getOrCreateContext();
     Future<SslContextProvider> f1 = manager.resolveSslContextProvider(options.getSslOptions(), context);
     return f1.compose(sslContextProvider -> {
@@ -203,7 +203,7 @@ public Future<Void> bind(SocketAddress address) {
       return bind(context, address, metrics)
         .map(ch -> {
           handleBind(ch, metrics);
-          return null;
+          return ((InetSocketAddress)ch.localAddress()).getPort();
         });
     });
   }

vertx-core/src/test/java/io/vertx/tests/net/quic/QuicServerTest.java

@@ -102,6 +102,15 @@ public void testBind() {
 
   @Test
   public void testConnect() throws Exception {
+    testConnect(9999);
+  }
+
+  @Test
+  public void testConnectRandomPort() throws Exception {
+    testConnect(0);
+  }
+
+  private void testConnect(int port) throws Exception {
     QuicServer server = QuicServer.create(vertx, serverOptions());
     server.handler(conn -> {
       assertEquals("test-protocol", conn.applicationLayerProtocol());
@@ -115,11 +124,16 @@ public void testConnect() throws Exception {
         });
       });
     });
-    server.bind(SocketAddress.inetSocketAddress(9999, "localhost")).await();
+    int actualPort = server.bind(SocketAddress.inetSocketAddress(port, "localhost")).await();
+    if (port == 0) {
+      assertTrue(actualPort > 0);
+    } else {
+      assertEquals(port, actualPort);
+    }
     QuicTestClient client = new QuicTestClient(new NioEventLoopGroup(1));
     try {
       client = new QuicTestClient(new NioEventLoopGroup(1));
-      QuicTestClient.Connection connection = client.connect(new InetSocketAddress(NetUtil.LOCALHOST4, 9999));
+      QuicTestClient.Connection connection = client.connect(new InetSocketAddress(NetUtil.LOCALHOST4, actualPort));
       QuicTestClient.Stream stream = connection.newStream();
       List<String> received = Collections.synchronizedList(new ArrayList<>());
       stream.handler(data -> {