final class AbstractEpollServerChannel.EpollServerSocketUnsafe extends AbstractEpollChannel.AbstractEpollUnsafe
Modifier and Type | Field and Description |
---|---|
private byte[] |
acceptedAddress |
readPending
Constructor and Description |
---|
EpollServerSocketUnsafe() |
Modifier and Type | Method and Description |
---|---|
void |
connect(java.net.SocketAddress socketAddress,
java.net.SocketAddress socketAddress2,
ChannelPromise channelPromise)
|
(package private) void |
epollInReady()
Called once EPOLLIN event is ready to be processed
|
clearEpollIn0, epollOutReady, epollRdHupReady, flush0, isRdHup, shutdownInput
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
public void connect(java.net.SocketAddress socketAddress, java.net.SocketAddress socketAddress2, ChannelPromise channelPromise)
Channel.Unsafe
Channel
of the given ChannelFuture
with the given remote SocketAddress
.
If a specific local SocketAddress
should be used it need to be given as argument. Otherwise just
pass null
to it.
The ChannelPromise
will get notified once the connect operation was complete.void epollInReady()
AbstractEpollChannel.AbstractEpollUnsafe
epollInReady
in class AbstractEpollChannel.AbstractEpollUnsafe