java.lang.Object
- io.netty5.util.DefaultAttributeMap
- - io.netty5.channel.AbstractChannel<P,SocketAddress,SocketAddress>
 - - io.netty5.channel.epoll.EpollDatagramChannel

All Implemented Interfaces:: Channel, ChannelOutboundInvoker, IoHandle, DatagramChannel, UnixChannel, AttributeMap, FuturePromiseFactory, Comparable<Channel>

public final class EpollDatagramChannel
extends AbstractChannel<P,SocketAddress,SocketAddress>
implements DatagramChannel

DatagramChannel implementation that uses linux EPOLL Edge-Triggered Mode for maximal performance.

Available options

In addition to the options provided by DatagramChannel and UnixChannel, EpollDatagramChannel allows the following options in the option map:

`ChannelOption`	`INET`	`INET6`	{@code UNIX
{@link IntegerUnixChannelOption}	X	X	X
{@link RawUnixChannelOption}	X	X	X
{@link UnixChannelOption#SO_REUSEPORT}	X	X	X
{@link EpollChannelOption#IP_FREEBIND}	X	X	-
{@link EpollChannelOption#IP_RECVORIGDSTADDR}	X	X	-
{@link EpollChannelOption#MAX_DATAGRAM_PAYLOAD_SIZE}	X	X	-
{@link EpollChannelOption#UDP_GRO}	X	X	-

Nested Class Summary
- Nested classes/interfaces inherited from class io.netty5.channel.AbstractChannel
  AbstractChannel.DefaultAbstractChannelPipeline

Field Summary

Fields
Modifier and Type Field Description

protected boolean active

protected LinuxSocket socket

Constructor Summary

Constructors
Constructor	Description
`EpollDatagramChannel(EventLoop eventLoop)`	Create a new instance which selects the `ProtocolFamily` to use depending on the Operation Systems default which will be chosen.
`EpollDatagramChannel(EventLoop eventLoop, int fd, ProtocolFamily family)`	Create a new instance which selects the `ProtocolFamily` to use depending on the Operation Systems default which will be chosen.
`EpollDatagramChannel(EventLoop eventLoop, ProtocolFamily family)`	Create a new instance using the given `ProtocolFamily`.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`autoReadCleared()`	Is called once `AbstractChannel.setAutoRead(boolean)` is called with `false` and `AbstractChannel.isAutoRead()` was `true` before.
`Future<Void>`	`block(InetAddress multicastAddress, InetAddress sourceToBlock)`	Block the given sourceToBlock address for the given multicastAddress and notifies the `Future` once the operation completes.
`Future<Void>`	`block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)`	Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the `Future` once the operation completes.
`protected static void`	`checkResolvable(InetSocketAddress addr)`
`protected void`	`clearFlag(int flag)`
`protected void`	`doBeginRead()`	Schedule a read operation.
`protected void`	`doBind(SocketAddress localAddress)`	Bind the `Channel` to the `SocketAddress`
`protected void`	`doClose()`	Close the `Channel`
`protected boolean`	`doConnect(SocketAddress remoteAddress, SocketAddress localAddress)`	Connect to the remote peer
`protected boolean`	`doConnect0(SocketAddress remote)`
`protected void`	`doDisconnect()`	Disconnect this `Channel` from its remote peer
`protected boolean`	`doFinishConnect(SocketAddress requestedRemoteAddress)`	Finish a connect request.
`protected void`	`doReadBytes(Buffer buffer)`	Read bytes into the given `Buffer` and return the amount.
`protected void`	`doShutdown(ChannelShutdownDirection direction)`	Shutdown one direction of the `Channel`.
`protected void`	`doWrite(ChannelOutboundBuffer in)`	Flush the content of the given buffer to the remote peer.
`protected int`	`doWriteBytes(ChannelOutboundBuffer in, Buffer buf)`
`protected long`	`doWriteOrSendBytes(Buffer data, SocketAddress remoteAddress, boolean fastOpen)`	Write bytes to the socket, with or without a remote address.
`protected void`	`epollInReady(RecvBufferAllocator.Handle handle, BufferAllocator recvBufferAllocator, boolean receivedRdHup)`	Called once EPOLLIN event is ready to be processed
`FileDescriptor`	`fd()`	Returns the `FileDescriptor` that is used by this `Channel`.
`protected boolean`	`fetchLocalAddress()`
`protected Object`	`filterOutboundMessage(Object msg)`	Invoked when a new message is added to a `ChannelOutboundBuffer` of this `AbstractChannel`, so that the `Channel` implementation converts the message to another.
`protected <T> T`	`getExtendedOption(ChannelOption<T> option)`	Override to add support for more `ChannelOption`s.
`boolean`	`isActive()`	Return `true` if the `Channel` is active and so connected.
`boolean`	`isConnected()`	Return `true` if the `DatagramChannel` is connected to the remote peer.
`protected boolean`	`isExtendedOptionSupported(ChannelOption<?> option)`	Override to add support for more `ChannelOption`s.
`boolean`	`isOpen()`	Returns `true` if the `Channel` is open and may get active later
`static boolean`	`isSegmentedDatagramPacketSupported()`	Returns `true` if `SegmentedDatagramPacket` is supported natively.
`boolean`	`isShutdown(ChannelShutdownDirection direction)`	Returns `true` if the `ChannelShutdownDirection` of the `Channel` was shutdown before.
`protected static boolean`	`isSoErrorZero(Socket fd)`
`Future<Void>`	`joinGroup(InetAddress multicastAddress)`	Joins a multicast group and notifies the `Future` once the operation completes.
`Future<Void>`	`joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)`	Joins the specified multicast group at the specified interface and notifies the `Future` once the operation completes.
`Future<Void>`	`leaveGroup(InetAddress multicastAddress)`	Leaves a multicast group and notifies the `Future` once the operation completes.
`Future<Void>`	`leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)`	Leave the specified multicast group at the specified interface using the specified source and notifies the `Future` once the operation completes.
`protected SocketAddress`	`localAddress0()`	Returns the `SocketAddress` which is bound locally.
`protected boolean`	`maybeMoreDataToRead(RecvBufferAllocator.Handle handle)`
`protected Buffer`	`newDirectBuffer(Buffer buf)`	Returns an off-heap copy of, and then closes, the given `Buffer`.
`protected Buffer`	`newDirectBuffer(Resource<?> holder, Buffer buf)`	Returns an off-heap copy of the given `Buffer`, and then closes the `holder` under the assumption that it owned (or was itself) the buffer.
`protected io.netty5.channel.epoll.EpollRegistration`	`registration()`
`protected SocketAddress`	`remoteAddress0()`	Return the `SocketAddress` which the `Channel` is connected to.
`protected <T> void`	`setExtendedOption(ChannelOption<T> option, T value)`	Override to add support for more `ChannelOption`s.
`protected void`	`setFlag(int flag)`
`protected void`	`shutdownInput(boolean rdHup)`	Shutdown the input side of the channel.
`protected void`	`writeFlushed()`	Write previous flushed messages.

Methods inherited from class io.netty5.channel.AbstractChannel
annotateConnectException, assertEventLoop, bufferAllocator, cacheAddresses, closeForciblyTransport, closeFuture, closeIfClosed, closeTransport, compareTo, deregisterTransport, ensureOpen, equals, executor, finishConnect, fireChannelActiveIfNotActiveBefore, getMaxMessagesPerWrite, getOption, getWriteSpinCount, handleWriteError, hashCode, id, isAllowHalfClosure, isAutoRead, isConnectPending, isOptionSupported, isRegistered, localAddress, metadata, newChannelPipeline, newSupportedIdentityOptionsSet, outboundBuffer, parent, pipeline, prepareToClose, readIfIsAutoRead, recvBufAllocHandle, remoteAddress, runAfterTransportAction, safeSetFailure, safeSetSuccess, setBufferAllocator, setOption, shutdownTransport, toString, validate, validateEventLoopGroup, validateFileRegion, writableBytes

Methods inherited from class io.netty5.util.DefaultAttributeMap
attr, hasAttr

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty5.util.AttributeMap
attr, hasAttr

Methods inherited from interface io.netty5.channel.Channel
bind, bufferAllocator, close, closeFuture, connect, connect, deregister, disconnect, executor, flush, getOption, id, isOpen, isOptionSupported, isWritable, localAddress, metadata, parent, pipeline, read, register, remoteAddress, sendOutboundEvent, setOption, shutdown, writableBytes, write, writeAndFlush

Methods inherited from interface io.netty5.channel.ChannelOutboundInvoker
newFailedFuture, newPromise, newSucceededFuture, newSucceededFuture

Methods inherited from interface java.lang.Comparable
compareTo

Methods inherited from interface io.netty5.channel.IoHandle
isRegistered

- Field Detail
 - socket
```
protected final LinuxSocket socket
```
 - active
```
protected volatile boolean active
```
- Constructor Detail
 - EpollDatagramChannel
```
public EpollDatagramChannel(EventLoop eventLoop)
```
 Create a new instance which selects the ProtocolFamily to use depending on the Operation Systems default which will be chosen.
 - EpollDatagramChannel
```
public EpollDatagramChannel(EventLoop eventLoop,
 ProtocolFamily family)
```
 Create a new instance using the given ProtocolFamily. If null is used it will depend on the Operation Systems default which will be chosen.
 - EpollDatagramChannel
```
public EpollDatagramChannel(EventLoop eventLoop,
 int fd,
 ProtocolFamily family)
```
 Create a new instance which selects the ProtocolFamily to use depending on the Operation Systems default which will be chosen.
- Method Detail
 - isSegmentedDatagramPacketSupported
```
public static boolean isSegmentedDatagramPacketSupported()
```
 Returns true if SegmentedDatagramPacket is supported natively.
 
 Returns:
 
 true if supported, false otherwise.
 - isActive
```
public boolean isActive()
```
 Description copied from interface: Channel
 
 Return true if the Channel is active and so connected.
 
 Specified by:
 
 isActive in interface Channel
 - isConnected
```
public boolean isConnected()
```
 Description copied from interface: DatagramChannel
 
 Return true if the DatagramChannel is connected to the remote peer.
 
 Specified by:
 
 isConnected in interface DatagramChannel
 - joinGroup
```
public Future<Void> joinGroup(InetAddress multicastAddress)
```
 Description copied from interface: DatagramChannel
 
 Joins a multicast group and notifies the Future once the operation completes.
 If the underlying implementation does not support this operation it will return a Future which is failed with an UnsupportedOperationException.
 
 Specified by:
 
 joinGroup in interface DatagramChannel
 
 Parameters:
 
 multicastAddress - the multicast group address.
 
 Returns:
 
 a Future which is notified once the operation completes.
 - joinGroup
```
public Future<Void> joinGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source)
```
 Description copied from interface: DatagramChannel
 
 Joins the specified multicast group at the specified interface and notifies the Future once the operation completes.
 If the underlying implementation does not support this operation it will return a Future which is failed with an UnsupportedOperationException.
 
 Specified by:
 
 joinGroup in interface DatagramChannel
 
 Parameters:
 
 multicastAddress - the multicast group address.
 
 networkInterface - the interface to use.
 
 source - the source address (might be null).
 
 Returns:
 
 a Future which is notified once the operation completes.
 - leaveGroup
```
public Future<Void> leaveGroup(InetAddress multicastAddress)
```
 Description copied from interface: DatagramChannel
 
 Leaves a multicast group and notifies the Future once the operation completes.
 If the underlying implementation does not support this operation it will return a Future which is failed with an UnsupportedOperationException.
 
 Specified by:
 
 leaveGroup in interface DatagramChannel
 
 Parameters:
 
 multicastAddress - the multicast group address.
 
 Returns:
 
 a Future which is notified once the operation completes.
 - leaveGroup
```
public Future<Void> leaveGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source)
```
 Description copied from interface: DatagramChannel
 
 Leave the specified multicast group at the specified interface using the specified source and notifies the Future once the operation completes.
 If the underlying implementation does not support this operation it will return a Future which is failed with an UnsupportedOperationException.
 
 Specified by:
 
 leaveGroup in interface DatagramChannel
 
 Parameters:
 
 multicastAddress - the multicast group address.
 
 networkInterface - the interface to use.
 
 source - the source address (might be null).
 
 Returns:
 
 a Future which is notified once the operation completes.
 - block
```
public Future<Void> block(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress sourceToBlock)
```
 Description copied from interface: DatagramChannel
 
 Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the Future once the operation completes.
 If the underlying implementation does not support this operation it will return a Future which is failed with an UnsupportedOperationException.
 
 Specified by:
 
 block in interface DatagramChannel
 
 Parameters:
 
 multicastAddress - the multicast group address.
 
 networkInterface - the interface to use.
 
 sourceToBlock - the source address.
 
 Returns:
 
 a Future which is notified once the operation completes.
 - block
```
public Future<Void> block(InetAddress multicastAddress,
 InetAddress sourceToBlock)
```
 Description copied from interface: DatagramChannel
 
 Block the given sourceToBlock address for the given multicastAddress and notifies the Future once the operation completes.
 If the underlying implementation does not support this operation it will return a Future which is failed with an UnsupportedOperationException.
 
 Specified by:
 
 block in interface DatagramChannel
 
 Parameters:
 
 multicastAddress - the multicast group address.
 
 sourceToBlock - the source address.
 
 Returns:
 
 a Future which is notified once the operation completes.
 - doShutdown
```
protected void doShutdown(ChannelShutdownDirection direction)
```
 Description copied from class: AbstractChannel
 
 Shutdown one direction of the Channel.
 
 Specified by:
 
 doShutdown in class AbstractChannel<UnixChannel,SocketAddress,SocketAddress>
 
 Parameters:
 
 direction - the direction to shutdown.
 - isShutdown
```
public boolean isShutdown(ChannelShutdownDirection direction)
```
 Description copied from interface: Channel
 
 Returns true if the ChannelShutdownDirection of the Channel was shutdown before.
 
 Specified by:
 
 isShutdown in interface Channel
 - doBind
```
protected void doBind(SocketAddress localAddress)
 throws Exception
```
 Description copied from class: AbstractChannel
 
 Bind the Channel to the SocketAddress
 
 Throws:
 
 Exception
 - doWrite
```
protected void doWrite(ChannelOutboundBuffer in)
 throws Exception
```
 Description copied from class: AbstractChannel
 
 Flush the content of the given buffer to the remote peer.
 
 Specified by:
 
 doWrite in class AbstractChannel<UnixChannel,SocketAddress,SocketAddress>
 
 Throws:
 
 Exception
 - filterOutboundMessage
```
protected Object filterOutboundMessage(Object msg)
```
 Description copied from class: AbstractChannel
 
 Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another. (e.g. heap buffer -> direct buffer)
 
 Overrides:
 
 filterOutboundMessage in class AbstractChannel<UnixChannel,SocketAddress,SocketAddress>
 - doDisconnect
```
protected void doDisconnect()
 throws Exception
```
 Description copied from class: AbstractChannel
 
 Disconnect this Channel from its remote peer
 
 Throws:
 
 Exception
 - doConnect
```
protected boolean doConnect(SocketAddress remoteAddress,
 SocketAddress localAddress)
 throws Exception
```
 Connect to the remote peer
 
 Parameters:
 
 remoteAddress - the address of the remote peer.
 
 localAddress - the local address of this channel.
 
 Returns:
 
 true if the connect was completed, false if AbstractChannel.finishConnect() will be called later again to try finishing the connect.
 
 Throws:
 
 Exception - thrown on error.
 - doClose
```
protected void doClose()
 throws Exception
```
 Description copied from class: AbstractChannel
 
 Close the Channel
 
 Throws:
 
 Exception
 - epollInReady
```
protected void epollInReady(RecvBufferAllocator.Handle handle,
 BufferAllocator recvBufferAllocator,
 boolean receivedRdHup)
```
 Called once EPOLLIN event is ready to be processed
 - maybeMoreDataToRead
```
protected boolean maybeMoreDataToRead(RecvBufferAllocator.Handle handle)
```
 - getExtendedOption
```
protected <T> T getExtendedOption(ChannelOption<T> option)
```
 Description copied from class: AbstractChannel
 
 Override to add support for more ChannelOptions. You need to also call {@link super} after handling the extra options.
 
 Type Parameters:
 
 T - the value type.
 
 Parameters:
 
 option - the ChannelOption.
 
 Returns:
 
 the value for the option
 - setExtendedOption
```
protected <T> void setExtendedOption(ChannelOption<T> option,
 T value)
```
 Description copied from class: AbstractChannel
 
 Override to add support for more ChannelOptions. You need to also call {@link super} after handling the extra options.
 
 Type Parameters:
 
 T - the value type.
 
 Parameters:
 
 option - the ChannelOption.
 - isExtendedOptionSupported
```
protected boolean isExtendedOptionSupported(ChannelOption<?> option)
```
 Description copied from class: AbstractChannel
 
 Override to add support for more ChannelOptions. You need to also call {@link super} after handling the extra options.
 
 Parameters:
 
 option - the ChannelOption.
 
 Returns:
 
 true if supported, false otherwise.
 - fetchLocalAddress
```
protected final boolean fetchLocalAddress()
```
 - isSoErrorZero
```
protected static boolean isSoErrorZero(Socket fd)
```
 - setFlag
```
protected final void setFlag(int flag)
 throws IOException
```
 Throws:
 
 IOException
 - clearFlag
```
protected final void clearFlag(int flag)
 throws IOException
```
 Throws:
 
 IOException
 - registration
```
protected final io.netty5.channel.epoll.EpollRegistration registration()
```
 - fd
```
public final FileDescriptor fd()
```
 Description copied from interface: UnixChannel
 
 Returns the FileDescriptor that is used by this Channel.
 
 Specified by:
 
 fd in interface UnixChannel
 - isOpen
```
public final boolean isOpen()
```
 Description copied from interface: Channel
 
 Returns true if the Channel is open and may get active later
 
 Specified by:
 
 isOpen in interface Channel
 - doBeginRead
```
protected final void doBeginRead()
 throws Exception
```
 Description copied from class: AbstractChannel
 
 Schedule a read operation.
 
 Specified by:
 
 doBeginRead in class AbstractChannel
 
 Throws:
 
 Exception
 - newDirectBuffer
```
protected final Buffer newDirectBuffer(Buffer buf)
```
 Returns an off-heap copy of, and then closes, the given Buffer.
 - newDirectBuffer
```
protected final Buffer newDirectBuffer(Resource<?> holder,
 Buffer buf)
```
 Returns an off-heap copy of the given Buffer, and then closes the holder under the assumption that it owned (or was itself) the buffer.
 - checkResolvable
```
protected static void checkResolvable(InetSocketAddress addr)
```
 - doReadBytes
```
protected final void doReadBytes(Buffer buffer)
 throws Exception
```
 Read bytes into the given Buffer and return the amount.
 
 Throws:
 
 Exception
 - doWriteBytes
```
protected final int doWriteBytes(ChannelOutboundBuffer in,
 Buffer buf)
 throws Exception
```
 Throws:
 
 Exception
 - doWriteOrSendBytes
```
protected final long doWriteOrSendBytes(Buffer data,
 SocketAddress remoteAddress,
 boolean fastOpen)
 throws IOException
```
 Write bytes to the socket, with or without a remote address. Used for datagram and TCP client fast open writes.
 
 Throws:
 
 IOException
 - shutdownInput
```
protected final void shutdownInput(boolean rdHup)
```
 Shutdown the input side of the channel.
 - writeFlushed
```
protected final void writeFlushed()
```
 Description copied from class: AbstractChannel
 
 Write previous flushed messages.
 
 Overrides:
 
 writeFlushed in class AbstractChannel
 - doFinishConnect
```
protected boolean doFinishConnect(SocketAddress requestedRemoteAddress)
 throws Exception
```
 Description copied from class: AbstractChannel
 
 Finish a connect request.
 
 Specified by:
 
 doFinishConnect in class AbstractChannel
 
 Parameters:
 
 requestedRemoteAddress - the remote address of the peer.
 
 Returns:
 
 true if the connect was completed, false if AbstractChannel.finishConnect() will be called later again to try finishing the connect.
 
 Throws:
 
 Exception - thrown on error.
 - doConnect0
```
protected boolean doConnect0(SocketAddress remote)
 throws Exception
```
 Throws:
 
 Exception
 - localAddress0
```
protected final SocketAddress localAddress0()
```
 Description copied from class: AbstractChannel
 
 Returns the SocketAddress which is bound locally.
 
 Specified by:
 
 localAddress0 in class AbstractChannel
 - remoteAddress0
```
protected final SocketAddress remoteAddress0()
```
 Description copied from class: AbstractChannel
 
 Return the SocketAddress which the Channel is connected to.
 
 Specified by:
 
 remoteAddress0 in class AbstractChannel
 - autoReadCleared
```
protected final void autoReadCleared()
```
 Description copied from class: AbstractChannel
 
 Is called once AbstractChannel.setAutoRead(boolean) is called with false and AbstractChannel.isAutoRead() was true before.
 
 Overrides:
 
 autoReadCleared in class AbstractChannel

Class EpollDatagramChannel

Available options

Nested Class Summary

Nested classes/interfaces inherited from class io.netty5.channel.AbstractChannel

Field Summary

Constructor Summary

Method Summary

Methods inherited from class io.netty5.channel.AbstractChannel

Methods inherited from class io.netty5.util.DefaultAttributeMap

Methods inherited from class java.lang.Object

Methods inherited from interface io.netty5.util.AttributeMap

Methods inherited from interface io.netty5.channel.Channel

Methods inherited from interface io.netty5.channel.ChannelOutboundInvoker

Methods inherited from interface java.lang.Comparable

Methods inherited from interface io.netty5.channel.IoHandle

Field Detail

socket

active

Constructor Detail

EpollDatagramChannel

EpollDatagramChannel

EpollDatagramChannel

Method Detail

isSegmentedDatagramPacketSupported

isActive

isConnected

joinGroup

joinGroup

leaveGroup

leaveGroup

block

block

doShutdown

isShutdown

doBind

doWrite

filterOutboundMessage

doDisconnect

doConnect

doClose

epollInReady

maybeMoreDataToRead

getExtendedOption

setExtendedOption

isExtendedOptionSupported

fetchLocalAddress

isSoErrorZero

setFlag

clearFlag

registration

fd

isOpen

doBeginRead

newDirectBuffer

newDirectBuffer

checkResolvable

doReadBytes

doWriteBytes

doWriteOrSendBytes

shutdownInput

writeFlushed

doFinishConnect

doConnect0

localAddress0

remoteAddress0

autoReadCleared