Skip to content

Support Unix Domain Sockets with io_uring transport #6026

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tsegismont merged 1 commit into from
May 13, 2026
+21 −20
Merged

Support Unix Domain Sockets with io_uring transport #6026

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
41 changes: 21 additions & 20 deletions vertx-core/src/main/java/io/vertx/core/impl/transports/IoUringTransport.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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
Expand All @@ -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;
Expand All @@ -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;
Expand Down Expand Up @@ -61,7 +63,7 @@ public IoUringTransport() {

@Override
public boolean supportsDomainSockets() {
return false;
return true;
}

@Override
Expand All @@ -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);
}
Expand Down Expand Up @@ -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;
}
Expand All @@ -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);
}
}
Loading