Support Unix Domain Sockets with io_uring transport

In Netty 4.2, Unix Domain Sockets with io_uring are supported.

But they were not integrated by Vert.x yet.

Signed-off-by: Thomas Segismont <tsegismont@gmail.com>

Author: tsegismont

.github/workflows/ci-matrix-5.x.yml

@@ -24,6 +24,9 @@ jobs:
           - os: ubuntu-latest
             jdk: 11
             profile: '-PNativeEpoll+DomainSockets'
+          - os: ubuntu-latest
+            jdk: 11
+            profile: '-PNativeIoUring+DomainSockets'
           - os: ubuntu-latest
             jdk: 25
           - os: windows-2022

.github/workflows/ci.yml

@@ -32,10 +32,10 @@ jobs:
           java-version: ${{ inputs.jdk }}
           distribution: temurin
       - name: Run tests
-        if: ${{ runner.os != 'Linux' || inputs.profile != '-PNativeIoUring'}}
+        if: ${{ runner.os != 'Linux' || (inputs.profile != '-PNativeIoUring' && inputs.profile != '-PNativeIoUring+DomainSockets')}}
         run: mvn -s .github/maven-ci-settings.xml -q clean verify -B ${{ inputs.profile }}
       - name: Run tests
-        if: ${{ runner.os == 'Linux' && inputs.profile == '-PNativeIoUring' && inputs.io_uring_supported }}
+        if: ${{ runner.os == 'Linux' && (inputs.profile == '-PNativeIoUring' || inputs.profile == '-PNativeIoUring+DomainSockets') && inputs.io_uring_supported }}
         run: |
           # io_uring testing requires more locked memory for kernel ring buffers than the default 8MB limit
           sudo prlimit --pid $$ --memlock=16777216:16777216

vertx-core/pom.xml

@@ -905,6 +905,29 @@
       </properties>
     </profile>
 
+    <profile>
+      <id>NativeIoUring+DomainSockets</id>
+      <properties>
+        <vertx.surefire.nettyTransport>io_uring</vertx.surefire.nettyTransport>
+        <vertx.surefire.useDomainSockets>true</vertx.surefire.useDomainSockets>
+        <vertx.surefire.useModulePath>false</vertx.surefire.useModulePath>
+      </properties>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-surefire-plugin</artifactId>
+            <configuration>
+              <systemPropertyVariables combine.children="append">
+                <io.netty.iouring.ringSize>512</io.netty.iouring.ringSize>
+                <io.netty.iouring.cqSize>1024</io.netty.iouring.cqSize>
+              </systemPropertyVariables>
+            </configuration>
+          </plugin>
+        </plugins>
+      </build>
+    </profile>
+
     <profile>
       <id>NativeKQueue</id>
       <properties>

vertx-core/src/main/java/io/vertx/core/impl/transports/IoUringTransport.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2011-2024 Contributors to the Eclipse Foundation
+ * Copyright (c) 2011-2026 Contributors to the Eclipse Foundation
  *
  * This program and the accompanying materials are made available under the
  * terms of the Eclipse Public License 2.0 which is available at
@@ -8,6 +8,7 @@
  *
  * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
  */
+
 package io.vertx.core.impl.transports;
 
 import io.netty.bootstrap.Bootstrap;
@@ -16,6 +17,7 @@
 import io.netty.channel.socket.DatagramChannel;
 import io.netty.channel.socket.InternetProtocolFamily;
 import io.netty.channel.unix.DomainSocketAddress;
+import io.netty.channel.unix.UnixChannelOption;
 import io.netty.channel.uring.*;
 import io.vertx.core.datagram.DatagramSocketOptions;
 import io.vertx.core.net.TcpConfig;
@@ -61,7 +63,7 @@ public IoUringTransport() {
 
   @Override
   public boolean supportsDomainSockets() {
-    return false;
+    return true;
   }
 
   @Override
@@ -72,7 +74,7 @@ public boolean supportFileRegion() {
   @Override
   public SocketAddress convert(io.vertx.core.net.SocketAddress address) {
     if (address.isDomainSocket()) {
-      throw new IllegalArgumentException("Domain socket not supported by IOUring transport");
+      return new DomainSocketAddress(address.path());
     }
     return Transport.super.convert(address);
   }
@@ -113,15 +115,15 @@ public ChannelFactory<? extends DatagramChannel> datagramChannelFactory() {
   @Override
   public ChannelFactory<? extends Channel> channelFactory(boolean domainSocket) {
     if (domainSocket) {
-      throw new IllegalArgumentException();
+      return IoUringDomainSocketChannel::new;
     }
     return IoUringSocketChannel::new;
   }
 
   @Override
   public ChannelFactory<? extends ServerChannel> serverChannelFactory(boolean domainSocket) {
     if (domainSocket) {
-      throw new IllegalArgumentException();
+      return IoUringServerDomainSocketChannel::new;
     }
     return IoUringServerSocketChannel::new;
   }
@@ -134,26 +136,25 @@ public void configure(DatagramChannel channel, DatagramSocketOptions options) {
 
   @Override
   public void configure(TcpConfig config, boolean domainSocket, ServerBootstrap bootstrap) {
-    if (domainSocket) {
-      throw new IllegalArgumentException();
+    if (!domainSocket) {
+      bootstrap.option(UnixChannelOption.SO_REUSEPORT, config.isSoReusePort());
+      configOption(bootstrap, config, TcpOption.FASTOPEN, IoUringChannelOption.TCP_FASTOPEN);
+      configChildOption(bootstrap, config, TcpOption.USER_TIMEOUT, IoUringChannelOption.TCP_USER_TIMEOUT);
+      configChildOption(bootstrap, config, TcpOption.QUICKACK, IoUringChannelOption.TCP_QUICKACK);
+      configChildOption(bootstrap, config, TcpOption.CORK, IoUringChannelOption.TCP_CORK);
     }
-    bootstrap.option(IoUringChannelOption.SO_REUSEPORT, config.isSoReusePort());
-    configOption(bootstrap, config, TcpOption.FASTOPEN, IoUringChannelOption.TCP_FASTOPEN);
-    configChildOption(bootstrap, config, TcpOption.USER_TIMEOUT, IoUringChannelOption.TCP_USER_TIMEOUT);
-    configChildOption(bootstrap, config, TcpOption.QUICKACK, IoUringChannelOption.TCP_QUICKACK);
-    configChildOption(bootstrap, config, TcpOption.CORK, IoUringChannelOption.TCP_CORK);
-    Transport.super.configure(config, false, bootstrap);
+    Transport.super.configure(config, domainSocket, bootstrap);
   }
 
   @Override
   public void configure(TcpConfig config, boolean domainSocket, Bootstrap bootstrap) {
-    if (domainSocket) {
-      throw new IllegalArgumentException();
+    if (!domainSocket) {
+      NioTransport.configOption(bootstrap, config, TcpOption.FASTOPEN_CONNECT,
+                                IoUringChannelOption.TCP_FASTOPEN_CONNECT);
+      NioTransport.configOption(bootstrap, config, TcpOption.USER_TIMEOUT, IoUringChannelOption.TCP_USER_TIMEOUT);
+      NioTransport.configOption(bootstrap, config, TcpOption.QUICKACK, IoUringChannelOption.TCP_QUICKACK);
+      NioTransport.configOption(bootstrap, config, TcpOption.CORK, IoUringChannelOption.TCP_CORK);
     }
-    NioTransport.configOption(bootstrap, config, TcpOption.FASTOPEN_CONNECT, IoUringChannelOption.TCP_FASTOPEN_CONNECT);
-    NioTransport.configOption(bootstrap, config, TcpOption.USER_TIMEOUT, IoUringChannelOption.TCP_USER_TIMEOUT);
-    NioTransport.configOption(bootstrap, config, TcpOption.QUICKACK, IoUringChannelOption.TCP_QUICKACK);
-    NioTransport.configOption(bootstrap, config, TcpOption.CORK, IoUringChannelOption.TCP_CORK);
-    Transport.super.configure(config, false, bootstrap);
+    Transport.super.configure(config, domainSocket, bootstrap);
   }
 }