@UnstableApi public final class KQueueServerDomainSocketChannel extends AbstractKQueueServerChannel implements ServerDomainSocketChannel
AbstractKQueueServerChannel.KQueueServerSocketUnsafeAbstractKQueueChannel.AbstractKQueueUnsafeAbstractChannel.AbstractUnsafeChannel.Unsafe| Modifier and Type | Field and Description |
|---|---|
private KQueueServerChannelConfig |
config |
private DomainSocketAddress |
local |
private static InternalLogger |
logger |
active, inputClosedSeenErrorOnRead, jniSelfPtr, readReadyRunnablePending, socket| Constructor and Description |
|---|
KQueueServerDomainSocketChannel() |
KQueueServerDomainSocketChannel(BsdSocket socket,
boolean active) |
KQueueServerDomainSocketChannel(int fd) |
| Modifier and Type | Method and Description |
|---|---|
KQueueServerChannelConfig |
config()
Returns the configuration of this channel.
|
protected void |
doBind(java.net.SocketAddress localAddress)
Bind the
Channel to the SocketAddress |
protected void |
doClose()
Close the
Channel |
DomainSocketAddress |
localAddress()
Returns the local address where this channel is bound to.
|
protected DomainSocketAddress |
localAddress0()
Returns the
SocketAddress which is bound locally. |
protected Channel |
newChildChannel(int fd,
byte[] addr,
int offset,
int len) |
DomainSocketAddress |
remoteAddress()
Returns the remote address where this channel is connected to.
|
doWrite, filterOutboundMessage, isCompatible, metadata, newUnsafe, remoteAddress0checkResolvable, clearReadFilter, doBeginRead, 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, waitfdalloc, 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 static final InternalLogger logger
private final KQueueServerChannelConfig config
private volatile DomainSocketAddress local
public KQueueServerDomainSocketChannel()
public KQueueServerDomainSocketChannel(int fd)
KQueueServerDomainSocketChannel(BsdSocket socket, boolean active)
protected Channel newChildChannel(int fd, byte[] addr, int offset, int len) throws java.lang.Exception
newChildChannel in class AbstractKQueueServerChanneljava.lang.Exceptionprotected DomainSocketAddress localAddress0()
AbstractChannelSocketAddress which is bound locally.localAddress0 in class AbstractChannelprotected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannelChannel to the SocketAddressdoBind in class AbstractChanneljava.lang.Exceptionprotected void doClose()
throws java.lang.Exception
AbstractChannelChanneldoClose in class AbstractKQueueChanneljava.lang.Exceptionpublic KQueueServerChannelConfig config()
Channelconfig in interface Channelconfig in class AbstractKQueueChannelpublic DomainSocketAddress 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 ServerDomainSocketChannelremoteAddress 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 DomainSocketAddress 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 ServerDomainSocketChannellocalAddress in class AbstractChannelnull if this channel is not bound.