public final class EpollServerSocketChannel extends AbstractEpollServerChannel implements ServerSocketChannel
ServerSocketChannel implementation that uses linux EPOLL Edge-Triggered Mode for
maximal performance.AbstractChannel.AbstractUnsafe Channel.Unsafe | Modifier and Type | Field and Description |
|---|---|
protected boolean |
active |
protected int |
flags |
| Constructor and Description |
|---|
EpollServerSocketChannel () |
EpollServerSocketChannel (FileDescriptor fd)
Deprecated.
Use
EpollServerSocketChannel(Socket, boolean).
Creates a new EpollServerSocketChannel from an existing FileDescriptor. |
EpollServerSocketChannel (Socket fd)
Deprecated.
Use
EpollServerSocketChannel(Socket, boolean).
Creates a new EpollServerSocketChannel from an existing Socket. |
EpollServerSocketChannel (Socket fd,
boolean active) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
checkResolvable (java.net.InetSocketAddress addr) |
EpollServerSocketChannelConfig |
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. |
protected boolean |
isCompatible (EventLoop loop)
Return
true if the given EventLoop is compatible with this instance. |
boolean |
isOpen ()
Returns
true if the Channel is open and may get active later |
java.net.InetSocketAddress |
localAddress ()
Returns the local address where this channel is bound to.
|
protected java.net.SocketAddress |
localAddress0 ()
Returns the
SocketAddress which is bound locally. |
ChannelMetadata |
metadata ()
|
protected Channel |
newChildChannel (int fd,
byte[] address,
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. |
java.net.InetSocketAddress |
remoteAddress ()
Returns the remote address where this channel is connected to.
|
doConnect, doWrite, filterOutboundMessage, 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, waitalloc, 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 EpollServerSocketChannel()
@Deprecated public EpollServerSocketChannel(FileDescriptor fd)
EpollServerSocketChannel(Socket, boolean).
Creates a new EpollServerSocketChannel from an existing FileDescriptor.@Deprecated public EpollServerSocketChannel(Socket fd)
EpollServerSocketChannel(Socket, boolean).
Creates a new EpollServerSocketChannel from an existing Socket.public EpollServerSocketChannel(Socket fd, boolean active)
protected boolean isCompatible(EventLoop loop)
AbstractChannel true if the given EventLoop is compatible with this instance.isCompatible in class AbstractEpollServerChannel protected void doBind(java.net.SocketAddress localAddress) throws java.lang.Exception
AbstractChannel Channel to the SocketAddressjava.lang.Exceptionpublic java.net.InetSocketAddress 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 ServerSocketChannel 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 java.net.InetSocketAddress 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 ServerSocketChannel localAddress in class AbstractChannel null if this channel is not bound.public EpollServerSocketChannelConfig config()
Channel config in interface Channel config in interface ServerSocketChannel protected Channel newChildChannel(int fd, byte[] address, int offset, int len) throws java.lang.Exception
java.lang.Exceptionpublic 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 doClose() throws java.lang.Exception
AbstractChannel Channel doClose in class AbstractChannel java.lang.Exceptionprotected 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.Exceptionprotected java.net.SocketAddress localAddress0()
AbstractChannel SocketAddress which is bound locally.localAddress0 in class AbstractChannel Copyright © 2008–2018 The Netty Project. All rights reserved.