public final class EpollServerDomainSocketChannel extends AbstractEpollServerChannel implements ServerDomainSocketChannel
AbstractEpollServerChannel.EpollServerSocketUnsafeAbstractEpollChannel.AbstractEpollUnsafeAbstractChannel.AbstractUnsafeChannel.Unsafe| Modifier and Type | Field and Description |
|---|---|
private EpollServerChannelConfig |
config |
private DomainSocketAddress |
local |
private static InternalLogger |
logger |
active, epollInReadyRunnablePending, flags, inputClosedSeenErrorOnRead, socket| Constructor and Description |
|---|
EpollServerDomainSocketChannel() |
EpollServerDomainSocketChannel(int fd) |
EpollServerDomainSocketChannel(LinuxSocket fd) |
EpollServerDomainSocketChannel(LinuxSocket fd,
boolean active) |
| Modifier and Type | Method and Description |
|---|---|
EpollServerChannelConfig |
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, clearEpollIn, clearFlag, doBeginRead, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isAllowHalfClosure, isFlagSet, isOpen, isSoErrorZero, newDirectBuffer, newDirectBuffer, setFlag, shouldBreakEpollInReadyalloc, 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 EpollServerChannelConfig config
private volatile DomainSocketAddress local
public EpollServerDomainSocketChannel()
public EpollServerDomainSocketChannel(int fd)
EpollServerDomainSocketChannel(LinuxSocket fd)
EpollServerDomainSocketChannel(LinuxSocket fd, boolean active)
protected Channel newChildChannel(int fd, byte[] addr, int offset, int len) throws java.lang.Exception
newChildChannel in class AbstractEpollServerChanneljava.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 AbstractEpollChanneljava.lang.Exceptionpublic EpollServerChannelConfig config()
Channelconfig in interface Channelconfig in class AbstractEpollChannelpublic 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.