io.vertx.uring

Class IOUringTransport

java.lang.Object

io.vertx.uring.IOUringTransport

All Implemented Interfaces:

Transport

public class IOUringTransport
extends Object
implements Transport

Field Summary

Fields inherited from interface io.vertx.core.spi.transport.Transport

ACCEPTOR_EVENT_LOOP_GROUP, IO_EVENT_LOOP_GROUP

Constructor Summary

Constructors

Constructor and Description
IOUringTransport()

Method Summary

Modifier and Type	Method and Description
io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel>	channelFactory(boolean domainSocket)
void	configure(ClientOptionsBase options, boolean domainSocket, io.netty.bootstrap.Bootstrap bootstrap)
void	configure(io.netty.channel.socket.DatagramChannel channel, DatagramSocketOptions options)
void	configure(NetServerOptions options, boolean domainSocket, io.netty.bootstrap.ServerBootstrap bootstrap)
SocketAddress	convert(SocketAddress address)
SocketAddress	convert(SocketAddress address)
io.netty.channel.socket.DatagramChannel	datagramChannel()
io.netty.channel.socket.DatagramChannel	datagramChannel(io.netty.channel.socket.InternetProtocolFamily family)
io.netty.channel.EventLoopGroup	eventLoopGroup(int type, int nThreads, ThreadFactory threadFactory, int ignoredIoRatio)
static int	getPendingFastOpenRequestsThreshold() Return the number of of pending TFO connections in SYN-RCVD state for TCP_FASTOPEN.
boolean	isAvailable()
io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel>	serverChannelFactory(boolean domainSocket)
static void	setPendingFastOpenRequestsThreshold(int value) Set the number of of pending TFO connections in SYN-RCVD state for TCP_FASTOPEN If this value goes over a certain limit the server disables all TFO connections.
boolean	supportFileRegion()
boolean	supportsDomainSockets()
Throwable	unavailabilityCause()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IOUringTransport

public IOUringTransport()

Method Detail

getPendingFastOpenRequestsThreshold

public static int getPendingFastOpenRequestsThreshold()

Return the number of of pending TFO connections in SYN-RCVD state for TCP_FASTOPEN.

setPendingFastOpenRequestsThreshold(int)

setPendingFastOpenRequestsThreshold

public static void setPendingFastOpenRequestsThreshold(int value)

Set the number of of pending TFO connections in SYN-RCVD state for TCP_FASTOPEN

If this value goes over a certain limit the server disables all TFO connections.

supportsDomainSockets

public boolean supportsDomainSockets()

Specified by:

supportsDomainSockets in interface Transport

supportFileRegion

public boolean supportFileRegion()

Specified by:

supportFileRegion in interface Transport

convert

public SocketAddress convert(SocketAddress address)

Specified by:

convert in interface Transport

convert

public SocketAddress convert(SocketAddress address)

Specified by:

convert in interface Transport

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface Transport

Returns:

true when the transport is available.

unavailabilityCause

public Throwable unavailabilityCause()

Specified by:

unavailabilityCause in interface Transport

Returns:

the error that cause the unavailability when Transport.isAvailable() returns null.

eventLoopGroup

public io.netty.channel.EventLoopGroup eventLoopGroup(int type,
                                                      int nThreads,
                                                      ThreadFactory threadFactory,
                                                      int ignoredIoRatio)

Specified by:

eventLoopGroup in interface Transport

Parameters:

type - one of Transport.ACCEPTOR_EVENT_LOOP_GROUP or Transport.IO_EVENT_LOOP_GROUP.

nThreads - the number of threads that will be used by this instance.

threadFactory - the ThreadFactory to use.

ignoredIoRatio - the IO ratio

Returns:

a new event loop group

datagramChannel

public io.netty.channel.socket.DatagramChannel datagramChannel()

Specified by:

datagramChannel in interface Transport

Returns:

a new datagram channel

datagramChannel

public io.netty.channel.socket.DatagramChannel datagramChannel(io.netty.channel.socket.InternetProtocolFamily family)

Specified by:

datagramChannel in interface Transport

Returns:

a new datagram channel

channelFactory

public io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel> channelFactory(boolean domainSocket)

Specified by:

channelFactory in interface Transport

Parameters:

domainSocket - whether to create a unix domain channel or a socket channel

Returns:

the type for channel

serverChannelFactory

public io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> serverChannelFactory(boolean domainSocket)

Specified by:

serverChannelFactory in interface Transport

Parameters:

domainSocket - whether to create a server unix domain channel or a regular server socket channel

Returns:

the type for server channel

configure

public void configure(io.netty.channel.socket.DatagramChannel channel,
                      DatagramSocketOptions options)

Specified by:

configure in interface Transport

configure

public void configure(NetServerOptions options,
                      boolean domainSocket,
                      io.netty.bootstrap.ServerBootstrap bootstrap)

Specified by:

configure in interface Transport

configure

public void configure(ClientOptionsBase options,
                      boolean domainSocket,
                      io.netty.bootstrap.Bootstrap bootstrap)

Specified by:

configure in interface Transport