Top Fields Constructors Methods
io.vertx.core.impl.transports

public Class EpollTransport

extends Object
implements Transport
Class Inheritance
All Implemented Interfaces
io.vertx.core.spi.transport.Transport
Imports
io.netty.bootstrap.Bootstrap, .ServerBootstrap, io.netty.channel.*, io.netty.channel.epoll.Epoll, .EpollChannelOption, .EpollDatagramChannel, .EpollDomainSocketChannel, .EpollEventLoopGroup, .EpollServerDomainSocketChannel, .EpollServerSocketChannel, .EpollSocketChannel, io.netty.channel.socket.DatagramChannel, .InternetProtocolFamily, io.netty.channel.unix.DomainSocketAddress, io.vertx.core.datagram.DatagramSocketOptions, io.vertx.core.net.ClientOptionsBase, .NetServerOptions, io.vertx.core.net.impl.SocketAddressImpl, io.vertx.core.spi.transport.Transport, java.net.SocketAddress, java.util.concurrent.ThreadFactory
Author
Julien Viet

Field Summary

Modifier and TypeField and Description
private static volatile int
pendingFastOpenRequestsThreshold

Constructor Summary

AccessConstructor and Description
public
EpollTransport()

Method Summary

Modifier and TypeMethod and Description
public ChannelFactory<? extends Channel>
channelFactory(boolean
whether to create a unix domain channel or a socket channel
domainSocket)

Implements io.vertx.core.spi.transport.Transport.channelFactory.

References Deprecated ChannelFactory is deprecated or references (maybe indirectly) at least one deprecated element.

public void
configure(DatagramChannel channel, DatagramSocketOptions options)

Overrides default io.vertx.core.spi.transport.Transport.configure.

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

Overrides default io.vertx.core.spi.transport.Transport.configure.

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

Overrides default io.vertx.core.spi.transport.Transport.configure.

public SocketAddress
convert(SocketAddress address)

Overrides default io.vertx.core.spi.transport.Transport.convert.

public SocketAddress
convert(SocketAddress address)

Overrides default io.vertx.core.spi.transport.Transport.convert.

public DatagramChannel
datagramChannel()

Implements io.vertx.core.spi.transport.Transport.datagramChannel.

public DatagramChannel
datagramChannel(InternetProtocolFamily family)

Implements io.vertx.core.spi.transport.Transport.datagramChannel.

public EventLoopGroup
eventLoopGroup(int
one of ACCEPTOR_EVENT_LOOP_GROUP or IO_EVENT_LOOP_GROUP.
type, int
the number of threads that will be used by this instance.
nThreads, ThreadFactory
the ThreadFactory to use.
threadFactory, int
the IO ratio
ioRatio)

Implements io.vertx.core.spi.transport.Transport.eventLoopGroup.

public static int
getPendingFastOpenRequestsThreshold()

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

public boolean
isAvailable()

Overrides default io.vertx.core.spi.transport.Transport.isAvailable.

public ChannelFactory<? extends ServerChannel>
serverChannelFactory(boolean
whether to create a server unix domain channel or a regular server socket channel
domainSocket)

Implements io.vertx.core.spi.transport.Transport.serverChannelFactory.

References Deprecated ChannelFactory is deprecated or references (maybe indirectly) at least one deprecated element.

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.

public boolean
supportsDomainSockets()

Overrides default io.vertx.core.spi.transport.Transport.supportsDomainSockets.

public Throwable
unavailabilityCause()

Overrides default io.vertx.core.spi.transport.Transport.unavailabilityCause.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

pendingFastOpenRequestsThresholdback to summary
private static volatile int pendingFastOpenRequestsThreshold

Constructor Detail

EpollTransportback to summary
public EpollTransport()

Method Detail

channelFactoryback to summary
public ChannelFactory<? extends Channel> channelFactory(boolean domainSocket)

Implements io.vertx.core.spi.transport.Transport.channelFactory.

References Deprecated

ChannelFactory is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Parameters
domainSocket:boolean

Doc from io.vertx.core.spi.transport.Transport.channelFactory.

whether to create a unix domain channel or a socket channel

Returns:ChannelFactory<? extends Channel>

Doc from io.vertx.core.spi.transport.Transport.channelFactory.

the type for channel

Annotations
@Override
configureback to summary
public void configure(DatagramChannel channel, DatagramSocketOptions options)

Overrides default io.vertx.core.spi.transport.Transport.configure.

Annotations
@Override
configureback to summary
public void configure(NetServerOptions options, boolean domainSocket, ServerBootstrap bootstrap)

Overrides default io.vertx.core.spi.transport.Transport.configure.

Annotations
@Override
configureback to summary
public void configure(ClientOptionsBase options, boolean domainSocket, Bootstrap bootstrap)

Overrides default io.vertx.core.spi.transport.Transport.configure.

Annotations
@Override
convertback to summary
public SocketAddress convert(SocketAddress address)

Overrides default io.vertx.core.spi.transport.Transport.convert.

Annotations
@Override
convertback to summary
public SocketAddress convert(SocketAddress address)

Overrides default io.vertx.core.spi.transport.Transport.convert.

Annotations
@Override
datagramChannelback to summary
public DatagramChannel datagramChannel()

Implements io.vertx.core.spi.transport.Transport.datagramChannel.

Returns:DatagramChannel

Doc from io.vertx.core.spi.transport.Transport.datagramChannel.

a new datagram channel

Annotations
@Override
datagramChannelback to summary
public DatagramChannel datagramChannel(InternetProtocolFamily family)

Implements io.vertx.core.spi.transport.Transport.datagramChannel.

Returns:DatagramChannel

Doc from io.vertx.core.spi.transport.Transport.datagramChannel.

a new datagram channel

Annotations
@Override
eventLoopGroupback to summary
public EventLoopGroup eventLoopGroup(int type, int nThreads, ThreadFactory threadFactory, int ioRatio)

Implements io.vertx.core.spi.transport.Transport.eventLoopGroup.

Parameters
type:int

Doc from io.vertx.core.spi.transport.Transport.eventLoopGroup.

one of ACCEPTOR_EVENT_LOOP_GROUP or IO_EVENT_LOOP_GROUP.

nThreads:int

Doc from io.vertx.core.spi.transport.Transport.eventLoopGroup.

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

threadFactory:ThreadFactory

Doc from io.vertx.core.spi.transport.Transport.eventLoopGroup.

the ThreadFactory to use.

ioRatio:int

Doc from io.vertx.core.spi.transport.Transport.eventLoopGroup.

the IO ratio

Returns:EventLoopGroup

Doc from io.vertx.core.spi.transport.Transport.eventLoopGroup.

a new event loop group

Annotations
@Override
getPendingFastOpenRequestsThresholdback to summary
public static int getPendingFastOpenRequestsThreshold()

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

See Also
setPendingFastOpenRequestsThreshold
isAvailableback to summary
public boolean isAvailable()

Overrides default io.vertx.core.spi.transport.Transport.isAvailable.

Returns:boolean

Doc from io.vertx.core.spi.transport.Transport.isAvailable.

true when the transport is available.

Annotations
@Override
serverChannelFactoryback to summary
public ChannelFactory<? extends ServerChannel> serverChannelFactory(boolean domainSocket)

Implements io.vertx.core.spi.transport.Transport.serverChannelFactory.

References Deprecated

ChannelFactory is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Parameters
domainSocket:boolean

Doc from io.vertx.core.spi.transport.Transport.serverChannelFactory.

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

Returns:ChannelFactory<? extends ServerChannel>

Doc from io.vertx.core.spi.transport.Transport.serverChannelFactory.

the type for server channel

setPendingFastOpenRequestsThresholdback to summary
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.

supportsDomainSocketsback to summary
public boolean supportsDomainSockets()

Overrides default io.vertx.core.spi.transport.Transport.supportsDomainSockets.

Annotations
@Override
unavailabilityCauseback to summary
public Throwable unavailabilityCause()

Overrides default io.vertx.core.spi.transport.Transport.unavailabilityCause.

Returns:Throwable

Doc from io.vertx.core.spi.transport.Transport.unavailabilityCause.

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

Annotations
@Override