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
active, flags
Modifier | Constructor and Description |
---|---|
protected |
AbstractEpollServerChannel(FileDescriptor fd)
Deprecated.
|
protected |
AbstractEpollServerChannel(int fd)
Deprecated.
|
protected |
AbstractEpollServerChannel(Socket fd)
Deprecated.
|
protected |
AbstractEpollServerChannel(Socket 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. |
(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, isFlagSet, isOpen, isSoErrorZero, metadata, newDirectBuffer, newDirectBuffer, setFlag
alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bind, bind, close, close, closeFuture, config, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr
@Deprecated protected AbstractEpollServerChannel(int fd)
AbstractEpollServerChannel(Socket, boolean)
.@Deprecated protected AbstractEpollServerChannel(FileDescriptor fd)
AbstractEpollServerChannel(Socket, boolean)
.@Deprecated protected AbstractEpollServerChannel(Socket fd)
AbstractEpollServerChannel(Socket, boolean)
.protected AbstractEpollServerChannel(Socket fd, boolean active)
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