public final class EpollServerDomainSocketChannel extends AbstractEpollServerChannel implements ServerDomainSocketChannel
AbstractChannel.AbstractUnsafe Channel.Unsafe | Modifier and Type | Field and Description |
|---|---|
protected boolean |
active |
protected int |
flags |
| Constructor and Description |
|---|
EpollServerDomainSocketChannel () |
EpollServerDomainSocketChannel (FileDescriptor fd)
Deprecated.
Use
EpollServerDomainSocketChannel(Socket, boolean).
Creates a new EpollServerDomainSocketChannel from an existing FileDescriptor. |
EpollServerDomainSocketChannel (Socket fd)
Deprecated.
|
EpollServerDomainSocketChannel (Socket fd,
boolean active) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
checkResolvable (java.net.InetSocketAddress addr) |
EpollServerChannelConfig |
config ()
Returns the configuration of this channel.
|
protected void |
doBeginRead ()
Schedule a read operation.
|
protected void |
doBind (java.net.SocketAddress localAddress)
Bind the
Channel to the SocketAddress |
protected void |
doClose ()
Close the
Channel |
protected void |
doDeregister ()
|
protected void |
doDisconnect ()
Disconnect this
Channel from its remote peer |
protected int |
doReadBytes (ByteBuf byteBuf)
Read bytes into the given
ByteBuf and return the amount. |
protected void |
doRegister ()
|
protected int |
doWriteBytes (ByteBuf buf,
int writeSpinCount) |
Socket |
fd ()
Returns the
FileDescriptor that is used by this Channel. |
boolean |
isActive ()
Return
true if the Channel is active and so connected. |
boolean |
isOpen ()
Returns
true if the Channel is open and may get active later |
DomainSocketAddress |
localAddress ()
Returns the local address where this channel is bound to.
|
protected DomainSocketAddress |
localAddress0 ()
Returns the
SocketAddress which is bound locally. |
ChannelMetadata |
metadata ()
|
protected Channel |
newChildChannel (int fd,
byte[] addr,
int offset,
int len) |
protected ByteBuf |
newDirectBuffer (ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf, and releases the original one. |
protected ByteBuf |
newDirectBuffer (java.lang.Object holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf, and releases the specified holder. |
DomainSocketAddress |
remoteAddress ()
Returns the remote address where this channel is connected to.
|
doConnect, doWrite, filterOutboundMessage, isCompatible, newUnsafe, remoteAddress0 alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush attr clone, finalize, getClass, notify, notifyAll, wait, wait, waitfd alloc, bind, bind, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isActive, isOpen, isRegistered, isWritable, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush attr compareToprotected int flags
protected volatile boolean active
public EpollServerDomainSocketChannel()
public EpollServerDomainSocketChannel(FileDescriptor fd)
EpollServerDomainSocketChannel(Socket, boolean).
Creates a new EpollServerDomainSocketChannel from an existing FileDescriptor.public EpollServerDomainSocketChannel(Socket fd)
EpollServerDomainSocketChannel(Socket, boolean).public EpollServerDomainSocketChannel(Socket fd, boolean active)
protected Channel newChildChannel(int fd, byte[] addr, int offset, int len) throws java.lang.Exception
java.lang.Exceptionprotected DomainSocketAddress localAddress0()
AbstractChannel SocketAddress which is bound locally.protected void doBind(java.net.SocketAddress localAddress) throws java.lang.Exception
AbstractChannel Channel to the SocketAddressjava.lang.Exceptionprotected void doClose() throws java.lang.Exception
AbstractChannel Channel java.lang.Exceptionpublic EpollServerChannelConfig config()
Channel public DomainSocketAddress remoteAddress()
Channel SocketAddress is supposed to be down-cast into more
concrete type such as InetSocketAddress to retrieve the detailed
information.remoteAddress in interface Channel remoteAddress in interface ServerDomainSocketChannel remoteAddress in class AbstractChannel null 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()
Channel SocketAddress is supposed to be down-cast into more concrete
type such as InetSocketAddress to retrieve the detailed
information.localAddress in interface Channel localAddress in interface ServerDomainSocketChannel localAddress in class AbstractChannel null if this channel is not bound.public final Socket fd()
UnixChannel FileDescriptor that is used by this Channel.fd in interface UnixChannel public boolean isActive()
Channel true if the Channel is active and so connected.public ChannelMetadata metadata()
Channel protected void doDisconnect() throws java.lang.Exception
AbstractChannel Channel from its remote peerdoDisconnect in class AbstractChannel java.lang.Exceptionpublic boolean isOpen()
Channel true if the Channel is open and may get active laterprotected void doDeregister() throws java.lang.Exception
AbstractChannel doDeregister in class AbstractChannel java.lang.Exceptionprotected void doBeginRead() throws java.lang.Exception
AbstractChannel doBeginRead in class AbstractChannel java.lang.Exceptionprotected void doRegister() throws java.lang.Exception
AbstractChannel Channel is registered with its EventLoop as part of the register process.
Sub-classes may override this methoddoRegister in class AbstractChannel java.lang.Exceptionprotected final ByteBuf newDirectBuffer(ByteBuf buf)
ByteBuf, and releases the original one.protected static void checkResolvable(java.net.InetSocketAddress addr)
protected final int doReadBytes(ByteBuf byteBuf) throws java.lang.Exception
ByteBuf and return the amount.java.lang.Exceptionprotected final int doWriteBytes(ByteBuf buf, int writeSpinCount) throws java.lang.Exception
java.lang.ExceptionCopyright © 2008–2018 The Netty Project. All rights reserved.