Netty5/Transport/Classes/Epoll 5.0.0.Alpha5 · io.netty5.channel.epoll.EpollSocketChannel

`ChannelOption`	`INET`	`INET6`	`UNIX`
`IntegerUnixChannelOption`	X	X	X
`RawUnixChannelOption`	X	X	X
`EpollChannelOption#TCP_CORK`	X	X	-
`EpollChannelOption#TCP_NOTSENT_LOWAT`	X	X	-
`EpollChannelOption#TCP_KEEPCNT`	X	X	-
`EpollChannelOption#TCP_KEEPIDLE`	X	X	-
`EpollChannelOption#TCP_KEEPINTVL`	X	X	-
`EpollChannelOption#TCP_MD5SIG`	X	X	-
`EpollChannelOption#TCP_QUICKACK`	X	X	-
`EpollChannelOption#TCP_INFO`	X	X	-
`ChannelOption#TCP_FASTOPEN_CONNECT`	X	X	-
`EpollChannelOption#IP_TRANSPARENT`	X	X	-
`EpollChannelOption#SO_BUSY_POLL`	X	X	-
`UnixChannelOption#SO_PEERCRED`			X
`UnixChannelOption#DOMAIN_SOCKET_READ_MODE`			X

Modifier and Type	Class and Description
private class	EpollSocketChannel.EpollSocketWritableByteChannel

Modifier and Type	Field and Description
private WritableByteChannel	byteChannel
private static final String	EXPECTED_TYPES
private volatile DomainSocketReadMode	mode
private static final Set<ChannelOption<?>>	SUPPORTED_OPTIONS
private static final Set<ChannelOption<?>>	SUPPORTED_OPTIONS_DOMAIN_SOCKET
private volatile boolean	tcpFastopen
private volatile Collection<InetAddress>	tcpMd5SigAddresses

Access	Constructor and Description
public	EpollSocketChannel(EventLoop eventLoop)
public	EpollSocketChannel(EventLoop eventLoop, ProtocolFamily protocolFamily)
public	EpollSocketChannel(EventLoop eventLoop, int fd, ProtocolFamily family)
private	EpollSocketChannel(EventLoop eventLoop, LinuxSocket socket)
pack-priv	EpollSocketChannel(EpollServerSocketChannel parent, EventLoop eventLoop, LinuxSocket fd, SocketAddress remoteAddress)

Method Summary

Modifier and Type	Method and Description
protected boolean	doConnect0(SocketAddress remote, Buffer initialData) Overrides io.netty5.channel.epoll.AbstractEpollChannel.doConnect0.
protected void	doShutdown(ChannelShutdownDirection the direction to shut down. direction) Implements abstract io.netty5.channel.AbstractChannel.doShutdown. Shutdown one direction of the `Channel`.
private void	Returns: if we should continue with writing more messages. doWriteMultiple(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.WriteSink the `WriteSink` used to track write results. writeSink) Attempt to write multiple `Buffer` objects.
protected void	doWriteNow(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.WriteSink the `WriteSink` that must be completed with the write progress. `WriteSink#complete(long, long, int, boolean)` or `WriteSink#complete(long, Throwable, boolean)` must be called exactly once before this method returns non-exceptional. writeSink) Implements abstract io.netty5.channel.AbstractChannel.doWriteNow. Called in a loop when writes should be performed until this method returns `false` or there are no more messages to write.
private void	Returns: if we should continue with writing more messages. doWriteSingle(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.WriteSink the `WriteSink` used to track write results. writeSink) Attempt to write a single object.
private AbstractEpollChannel.ReadState	epollInReadFd(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.ReadSink readSink)
protected AbstractEpollChannel.ReadState	epollInReady(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.ReadSink readSink) Implements abstract io.netty5.channel.epoll.AbstractEpollChannel.epollInReady. Called once EPOLLIN event is ready to be processed
private AbstractEpollChannel.ReadState	epollInReadyBytes(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.ReadSink readSink)
protected Object	filterOutboundMessage(Object the message to filter / convert. msg) Overrides io.netty5.channel.AbstractChannel.filterOutboundMessage. Invoked when a new message is added to to the outbound queue of this `AbstractChannel`, so that the `Channel` implementation converts the message to another.
protected <T> T	getExtendedOption(ChannelOption<T> the `ChannelOption`. option) Overrides io.netty5.channel.epoll.AbstractEpollChannel.getExtendedOption. Override to add support for more `ChannelOption`s.
private PeerCredentials	getPeerCredentials()
private DomainSocketReadMode	getReadMode()
private int	getReceiveBufferSize()
private int	getSendBufferSize()
private int	getSoBusyPoll() Get the `SO_BUSY_POLL` option on the socket.
private int	getSoLinger()
private EpollTcpInfo	getTcpInfo() Updates and returns the `TCP_INFO` for the current socket.
private int	getTcpKeepCnt() Get the `TCP_KEEPCNT` option on the socket.
private int	getTcpKeepIdle() Get the `TCP_KEEPIDLE` option on the socket.
private int	getTcpKeepIntvl() Get the `TCP_KEEPINTVL` option on the socket.
private long	Returns: value is a uint32_t getTcpNotSentLowAt() Get the `TCP_NOTSENT_LOWAT` option on the socket.
private int	getTcpUserTimeout() Get the `TCP_USER_TIMEOUT` option on the socket.
private int	getTrafficClass()
protected boolean	isExtendedOptionSupported(ChannelOption<?> the `ChannelOption`. option) Overrides io.netty5.channel.epoll.AbstractEpollChannel.isExtendedOptionSupported. Override to add support for more `ChannelOption`s.
public boolean	isIpTransparent() Returns `true` if IP_TRANSPARENT is enabled, `false` otherwise.
private boolean	isKeepAlive()
private static boolean	isOptionSupported(SocketProtocolFamily family, ChannelOption<?> option)
private boolean	isReuseAddress()
public boolean	isShutdown(ChannelShutdownDirection direction) Implements io.netty5.channel.Channel.isShutdown. Returns `true` if the `ChannelShutdownDirection` of the `Channel` was shutdown before.
private boolean	isTcpCork() Get the `TCP_CORK` option on the socket.
private boolean	isTcpFastOpenConnect() Returns `true` if TCP fast open is enabled, `false` otherwise.
private boolean	isTcpNoDelay()
private boolean	isTcpQuickAck() Returns `true` if TCP_QUICKACK is enabled, `false` otherwise.
private static WriteHandleFactory	newWriteHandleFactory()
protected Future<Executor>	prepareToClose() Overrides io.netty5.channel.AbstractChannel.prepareToClose. Prepares to close the `Channel`.
protected <T> void	setExtendedOption(ChannelOption<T> the `ChannelOption`. option, T value) Overrides io.netty5.channel.epoll.AbstractEpollChannel.setExtendedOption. Override to add support for more `ChannelOption`s.
private void	setIpTransparent(boolean transparent) If `true` is used IP_TRANSPARENT is enabled, `false` for disable it.
private void	setKeepAlive(boolean keepAlive)
private void	setReadMode(DomainSocketReadMode mode)
private void	setReceiveBufferSize(int receiveBufferSize)
private void	setReuseAddress(boolean reuseAddress)
private void	setSendBufferSize(int sendBufferSize)
private void	setSoBusyPoll(int loopMicros) Set the `SO_BUSY_POLL` option on the socket.
private void	setSoLinger(int soLinger)
private void	setTcpCork(boolean tcpCork) Set the `TCP_CORK` option on the socket.
private void	setTcpFastOpenConnect(boolean fastOpenConnect) Enables client TCP fast open.
private void	setTcpKeepCnt(int probes) Set the `TCP_KEEPCNT` option on the socket.
private void	setTcpKeepIdle(int seconds) Set the `TCP_KEEPIDLE` option on the socket.
private void	setTcpKeepIntvl(int seconds) Set the `TCP_KEEPINTVL` option on the socket.
private void	setTcpMd5Sig(Map<InetAddress, byte[]> keys) Set the `TCP_MD5SIG` option on the socket.
private void	setTcpNoDelay(boolean tcpNoDelay)
private void	setTcpNotSentLowAt(long is a uint32_t tcpNotSentLowAt) Set the `TCP_NOTSENT_LOWAT` option on the socket.
private void	setTcpQuickAck(boolean quickAck) Set the `TCP_QUICKACK` option on the socket.
private void	setTcpUserTimeout(int milliseconds) Set the `TCP_USER_TIMEOUT` option on the socket.
private void	setTrafficClass(int trafficClass)
private static Set<ChannelOption<?>>	supportedOptions() Hides io.netty5.channel.AbstractChannel.supportedOptions.
private static Set<ChannelOption<?>>	supportedOptionsDomainSocket()
private void	Returns: if we should continue with writing more messages. writeBytes(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.WriteSink the `WriteSink` used to track write results. writeSink) Write bytes form the given `Buffer` to the underlying `java.nio.channels.Channel`.
private long	Returns: if we should continue with writing more messages. writeBytesMultiple(IovArray The array which contains the content to write. array) Write multiple bytes via `IovArray`.
private long	Returns: write result. writeBytesMultiple(ByteBuffer[] The buffers to write. nioBuffers, int The number of buffers to write. nioBufferCnt, long The number of bytes we expect to write. expectedWrittenBytes, long The maximum number of bytes we should attempt to write. maxBytesPerGatheringWrite) Write multiple bytes via `ByteBuffer` array.
private void	Returns: if we should continue with writing more messages. writeDefaultFileRegion(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.WriteSink the `WriteSink` used to track write results. writeSink) Write a `DefaultFileRegion`
private void	Returns: if we should continue with writing more messages. writeFileRegion(AbstractChannel<EpollServerSocketChannel, SocketAddress, SocketAddress>.WriteSink the `WriteSink` used to track write results. writeSink) Write a `FileRegion`

public final Class EpollSocketChannel

Available options

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary