@UnstableApi public final class KQueueServerSocketChannel extends AbstractKQueueServerChannel implements ServerSocketChannel
AbstractKQueueServerChannel.KQueueServerSocketUnsafeAbstractKQueueChannel.AbstractKQueueUnsafeAbstractChannel.AbstractUnsafeChannel.Unsafe| Modifier and Type | Field and Description |
|---|---|
private KQueueServerSocketChannelConfig |
config |
private java.net.InetSocketAddress |
local |
active, inputClosedSeenErrorOnRead, jniSelfPtr, readReadyRunnablePending, socket| Constructor and Description |
|---|
KQueueServerSocketChannel() |
KQueueServerSocketChannel(BsdSocket fd) |
KQueueServerSocketChannel(BsdSocket fd,
boolean active) |
KQueueServerSocketChannel(int fd) |
| Modifier and Type | Method and Description |
|---|---|
KQueueServerSocketChannelConfig |
config()
Returns the configuration of this channel.
|
protected void |
doBind(java.net.SocketAddress localAddress)
Bind the
Channel to the SocketAddress |
protected boolean |
isCompatible(EventLoop loop)
Return
true if the given EventLoop is compatible with this instance. |
java.net.InetSocketAddress |
localAddress()
Returns the local address where this channel is bound to.
|
protected java.net.InetSocketAddress |
localAddress0()
Returns the
SocketAddress which is bound locally. |
protected Channel |
newChildChannel(int fd,
byte[] address,
int offset,
int len) |
java.net.InetSocketAddress |
remoteAddress()
Returns the remote address where this channel is connected to.
|
doWrite, filterOutboundMessage, metadata, newUnsafe, remoteAddress0checkResolvable, clearReadFilter, doBeginRead, doClose, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isAllowHalfClosure, isOpen, isSoErrorZero, newDirectBuffer, newDirectBuffer, readFilter, shouldBreakReadReady, writeFilteralloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitalloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, metadata, parent, pipeline, read, unsafeattr, hasAttrbind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlushprivate final KQueueServerSocketChannelConfig config
private volatile java.net.InetSocketAddress local
public KQueueServerSocketChannel()
public KQueueServerSocketChannel(int fd)
KQueueServerSocketChannel(BsdSocket fd)
KQueueServerSocketChannel(BsdSocket fd, boolean active)
protected boolean isCompatible(EventLoop loop)
AbstractChanneltrue if the given EventLoop is compatible with this instance.isCompatible in class AbstractKQueueServerChannelprotected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannelChannel to the SocketAddressdoBind in class AbstractChanneljava.lang.Exceptionpublic java.net.InetSocketAddress remoteAddress()
ChannelSocketAddress is supposed to be down-cast into more
concrete type such as InetSocketAddress to retrieve the detailed
information.remoteAddress in interface ChannelremoteAddress in interface ServerSocketChannelremoteAddress in class AbstractChannelnull if this channel is not connected.
If this channel is not connected but it can receive messages
from arbitrary remote addresses (e.g. DatagramChannel,
use DefaultAddressedEnvelope.recipient() to determine
the origination of the received message as this method will
return null.public java.net.InetSocketAddress localAddress()
ChannelSocketAddress is supposed to be down-cast into more concrete
type such as InetSocketAddress to retrieve the detailed
information.localAddress in interface ChannellocalAddress in interface ServerSocketChannellocalAddress in class AbstractChannelnull if this channel is not bound.public KQueueServerSocketChannelConfig config()
Channelconfig in interface Channelconfig in interface ServerSocketChannelconfig in class AbstractKQueueChannelprotected java.net.InetSocketAddress localAddress0()
AbstractChannelSocketAddress which is bound locally.localAddress0 in class AbstractChannelprotected Channel newChildChannel(int fd, byte[] address, int offset, int len) throws java.lang.Exception
newChildChannel in class AbstractKQueueServerChanneljava.lang.Exception