@UnstableApi public abstract class AbstractKQueueServerChannel extends AbstractKQueueChannel implements ServerChannel
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractKQueueServerChannel.KQueueServerSocketUnsafe |
AbstractKQueueChannel.AbstractKQueueUnsafe
AbstractChannel.AbstractUnsafe
Channel.Unsafe
Modifier and Type | Field and Description |
---|---|
private static ChannelMetadata |
METADATA |
active, inputClosedSeenErrorOnRead, jniSelfPtr, readReadyRunnablePending, socket
Constructor and Description |
---|
AbstractKQueueServerChannel(BsdSocket fd) |
AbstractKQueueServerChannel(BsdSocket 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 AbstractKQueueChannel.AbstractKQueueUnsafe |
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, clearReadFilter, config, doBeginRead, doClose, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isAllowHalfClosure, isOpen, isSoErrorZero, newDirectBuffer, newDirectBuffer, readFilter, shouldBreakReadReady, writeFilter
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
AbstractKQueueServerChannel(BsdSocket fd)
AbstractKQueueServerChannel(BsdSocket fd, boolean active)
public ChannelMetadata metadata()
Channel
metadata
in interface Channel
metadata
in class AbstractKQueueChannel
protected boolean isCompatible(EventLoop loop)
AbstractChannel
true
if the given EventLoop
is compatible with this instance.isCompatible
in class AbstractKQueueChannel
protected java.net.InetSocketAddress remoteAddress0()
AbstractChannel
SocketAddress
which the Channel
is connected to.remoteAddress0
in class AbstractChannel
protected AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()
AbstractChannel
AbstractChannel.AbstractUnsafe
instance which will be used for the life-time of the Channel
newUnsafe
in class AbstractKQueueChannel
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