ACCEPTOR_EVENT_LOOP_GROUP, IO_EVENT_LOOP_GROUP| Constructor and Description |
|---|
IOUringTransport() |
| 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() |
public static int getPendingFastOpenRequestsThreshold()
public static void setPendingFastOpenRequestsThreshold(int value)
public boolean supportsDomainSockets()
supportsDomainSockets in interface Transportpublic boolean supportFileRegion()
supportFileRegion in interface Transportpublic SocketAddress convert(SocketAddress address)
public SocketAddress convert(SocketAddress address)
public boolean isAvailable()
isAvailable in interface Transportpublic Throwable unavailabilityCause()
unavailabilityCause in interface TransportTransport.isAvailable() returns null.public io.netty.channel.EventLoopGroup eventLoopGroup(int type,
int nThreads,
ThreadFactory threadFactory,
int ignoredIoRatio)
eventLoopGroup in interface Transporttype - 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 ratiopublic io.netty.channel.socket.DatagramChannel datagramChannel()
datagramChannel in interface Transportpublic io.netty.channel.socket.DatagramChannel datagramChannel(io.netty.channel.socket.InternetProtocolFamily family)
datagramChannel in interface Transportpublic io.netty.channel.ChannelFactory<? extends io.netty.channel.Channel> channelFactory(boolean domainSocket)
channelFactory in interface TransportdomainSocket - whether to create a unix domain channel or a socket channelpublic io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> serverChannelFactory(boolean domainSocket)
serverChannelFactory in interface TransportdomainSocket - whether to create a server unix domain channel or a regular server socket channelpublic void configure(io.netty.channel.socket.DatagramChannel channel,
DatagramSocketOptions options)
public void configure(NetServerOptions options, boolean domainSocket, io.netty.bootstrap.ServerBootstrap bootstrap)
public void configure(ClientOptionsBase options, boolean domainSocket, io.netty.bootstrap.Bootstrap bootstrap)
Copyright © 2023 Eclipse. All rights reserved.