public abstract class AbstractEpollServerChannel extends AbstractEpollChannel implements ServerChannel
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractEpollServerChannel.EpollServerSocketUnsafe |
AbstractEpollChannel.AbstractEpollUnsafe
AbstractChannel.AbstractUnsafe
Channel.Unsafe
Modifier and Type | Field and Description |
---|---|
private static ChannelMetadata |
METADATA |
active, epollInReadyRunnablePending, flags, inputClosedSeenErrorOnRead, socket
Modifier | Constructor and Description |
---|---|
protected |
AbstractEpollServerChannel(int fd) |
(package private) |
AbstractEpollServerChannel(LinuxSocket fd) |
(package private) |
AbstractEpollServerChannel(LinuxSocket fd,
boolean active) |
Modifier and Type | Method and Description |
---|---|
protected void |
doWrite(ChannelOutboundBuffer in)
Flush the content of the given buffer to the remote peer.
|
protected java.lang.Object |
filterOutboundMessage(java.lang.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 boolean |
isCompatible(EventLoop loop)
Return
true if the given EventLoop is compatible with this instance. |
ChannelMetadata |
metadata()
|
(package private) abstract Channel |
newChildChannel(int fd,
byte[] remote,
int offset,
int len) |
protected AbstractEpollChannel.AbstractEpollUnsafe |
newUnsafe()
Create a new
AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel |
protected java.net.InetSocketAddress |
remoteAddress0()
Return the
SocketAddress which the Channel is connected to. |
checkResolvable, clearEpollIn, clearFlag, config, doBeginRead, doClose, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isAllowHalfClosure, isFlagSet, isOpen, isSoErrorZero, newDirectBuffer, newDirectBuffer, setFlag, shouldBreakEpollInReady
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr, hasAttr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, parent, pipeline, read, remoteAddress, unsafe
attr, hasAttr
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
private static final ChannelMetadata METADATA
protected AbstractEpollServerChannel(int fd)
AbstractEpollServerChannel(LinuxSocket fd)
AbstractEpollServerChannel(LinuxSocket fd, boolean active)
public ChannelMetadata metadata()
Channel
metadata
in interface Channel
metadata
in class AbstractEpollChannel
protected boolean isCompatible(EventLoop loop)
AbstractChannel
true
if the given EventLoop
is compatible with this instance.isCompatible
in class AbstractEpollChannel
protected java.net.InetSocketAddress remoteAddress0()
AbstractChannel
SocketAddress
which the Channel
is connected to.remoteAddress0
in class AbstractChannel
protected AbstractEpollChannel.AbstractEpollUnsafe newUnsafe()
AbstractChannel
AbstractChannel.AbstractUnsafe
instance which will be used for the life-time of the Channel
newUnsafe
in class AbstractEpollChannel
protected void doWrite(ChannelOutboundBuffer in) throws java.lang.Exception
AbstractChannel
doWrite
in class AbstractChannel
java.lang.Exception
protected java.lang.Object filterOutboundMessage(java.lang.Object msg) throws java.lang.Exception
AbstractChannel
ChannelOutboundBuffer
of this AbstractChannel
, so that
the Channel
implementation converts the message to another. (e.g. heap buffer -> direct buffer)filterOutboundMessage
in class AbstractChannel
java.lang.Exception
abstract Channel newChildChannel(int fd, byte[] remote, int offset, int len) throws java.lang.Exception
java.lang.Exception