public abstract class AbstractEpollStreamChannel extends AbstractChannel
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractEpollStreamChannel.SpliceInTask |
AbstractChannel.AbstractUnsafe
Channel.Unsafe
Modifier and Type | Field and Description |
---|---|
protected boolean |
active |
protected int |
flags |
Modifier | Constructor and Description |
---|---|
protected |
AbstractEpollStreamChannel(Channel parent,
int fd) |
protected |
AbstractEpollStreamChannel(FileDescriptor fd) |
protected |
AbstractEpollStreamChannel(int fd) |
Modifier and Type | Method and Description |
---|---|
protected static void |
checkResolvable(InetSocketAddress addr) |
abstract EpollChannelConfig |
config()
Returns the configuration of this channel.
|
protected void |
doBeginRead()
Schedule a read operation.
|
protected void |
doClose()
Close the
Channel |
protected boolean |
doConnect(SocketAddress remoteAddress,
SocketAddress localAddress)
Connect to the remote peer
|
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 void |
doWrite(ChannelOutboundBuffer in)
Flush the content of the given buffer to the remote peer.
|
protected int |
doWriteBytes(ByteBuf buf,
int writeSpinCount) |
protected boolean |
doWriteSingle(ChannelOutboundBuffer in,
int writeSpinCount) |
FileDescriptor |
fd()
Returns the
FileDescriptor that is used by this Channel . |
protected Object |
filterOutboundMessage(Object msg)
Invoked when a new message is added to a
ChannelOutboundBuffer of this AbstractChannel , so that
the Channel implementation converts the message to another. |
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. |
protected boolean |
isInputShutdown0() |
boolean |
isOpen()
Returns
true if the Channel is open and may get active later |
protected boolean |
isOutputShutdown0() |
ChannelMetadata |
metadata()
|
protected ByteBuf |
newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
newDirectBuffer(Object holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
protected io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe |
newUnsafe()
Create a new
AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel |
protected void |
shutdownOutput0(ChannelPromise promise) |
ChannelFuture |
spliceTo(AbstractEpollStreamChannel ch,
int len)
Splice from this
AbstractEpollStreamChannel to another AbstractEpollStreamChannel . |
ChannelFuture |
spliceTo(AbstractEpollStreamChannel ch,
int len,
ChannelPromise promise)
Splice from this
AbstractEpollStreamChannel to another AbstractEpollStreamChannel . |
ChannelFuture |
spliceTo(FileDescriptor ch,
int offset,
int len)
Splice from this
AbstractEpollStreamChannel to another FileDescriptor . |
ChannelFuture |
spliceTo(FileDescriptor ch,
int offset,
int len,
ChannelPromise promise)
Splice from this
AbstractEpollStreamChannel to another FileDescriptor . |
alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bind, bind, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isRegistered, isWritable, localAddress, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr
compareTo
protected AbstractEpollStreamChannel(Channel parent, int fd)
protected AbstractEpollStreamChannel(int fd)
protected AbstractEpollStreamChannel(FileDescriptor fd)
protected io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe newUnsafe()
AbstractChannel
AbstractChannel.AbstractUnsafe
instance which will be used for the life-time of the Channel
public final ChannelFuture spliceTo(AbstractEpollStreamChannel ch, int len)
AbstractEpollStreamChannel
to another AbstractEpollStreamChannel
.
The len
is the number of bytes to splice. If using Integer.MAX_VALUE
it will
splice until the ChannelFuture
was canceled or it was failed.
Please note:
EventLoop
, otherwise an
IllegalArgumentException
is thrown. EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this and the
target AbstractEpollStreamChannel
public final ChannelFuture spliceTo(AbstractEpollStreamChannel ch, int len, ChannelPromise promise)
AbstractEpollStreamChannel
to another AbstractEpollStreamChannel
.
The len
is the number of bytes to splice. If using Integer.MAX_VALUE
it will
splice until the ChannelFuture
was canceled or it was failed.
Please note:
EventLoop
, otherwise an
IllegalArgumentException
is thrown. EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this and the
target AbstractEpollStreamChannel
public final ChannelFuture spliceTo(FileDescriptor ch, int offset, int len)
AbstractEpollStreamChannel
to another FileDescriptor
.
The offset
is the offset for the FileDescriptor
and len
is the
number of bytes to splice. If using Integer.MAX_VALUE
it will splice until the
ChannelFuture
was canceled or it was failed.
Please note:
EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this
AbstractEpollStreamChannel
FileDescriptor
will not be closed after the ChannelFuture
is notifiedpublic final ChannelFuture spliceTo(FileDescriptor ch, int offset, int len, ChannelPromise promise)
AbstractEpollStreamChannel
to another FileDescriptor
.
The offset
is the offset for the FileDescriptor
and len
is the
number of bytes to splice. If using Integer.MAX_VALUE
it will splice until the
ChannelFuture
was canceled or it was failed.
Please note:
EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this
AbstractEpollStreamChannel
FileDescriptor
will not be closed after the ChannelPromise
is notifiedprotected void doWrite(ChannelOutboundBuffer in) throws Exception
AbstractChannel
doWrite
in class AbstractChannel
Exception
protected boolean doWriteSingle(ChannelOutboundBuffer in, int writeSpinCount) throws Exception
Exception
protected Object filterOutboundMessage(Object msg)
AbstractChannel
ChannelOutboundBuffer
of this AbstractChannel
, so that
the Channel
implementation converts the message to another. (e.g. heap buffer -> direct buffer)filterOutboundMessage
in class AbstractChannel
protected boolean isInputShutdown0()
protected boolean isOutputShutdown0()
protected void shutdownOutput0(ChannelPromise promise)
protected void doClose() throws Exception
AbstractChannel
Channel
Exception
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
Exception
public final FileDescriptor fd()
UnixChannel
FileDescriptor
that is used by this Channel
.fd
in interface UnixChannel
public abstract EpollChannelConfig config()
Channel
public boolean isActive()
Channel
true
if the Channel
is active and so connected.public ChannelMetadata metadata()
Channel
protected void doDisconnect() throws Exception
AbstractChannel
Channel
from its remote peerdoDisconnect
in class AbstractChannel
Exception
protected boolean isCompatible(EventLoop loop)
AbstractChannel
true
if the given EventLoop
is compatible with this instance.isCompatible
in class AbstractChannel
public boolean isOpen()
Channel
true
if the Channel
is open and may get active laterprotected void doDeregister() throws Exception
AbstractChannel
doDeregister
in class AbstractChannel
Exception
protected void doBeginRead() throws Exception
AbstractChannel
doBeginRead
in class AbstractChannel
Exception
protected void doRegister() throws Exception
AbstractChannel
Channel
is registered with its EventLoop
as part of the register process.
Sub-classes may override this methoddoRegister
in class AbstractChannel
Exception
protected final ByteBuf newDirectBuffer(ByteBuf buf)
ByteBuf
, and releases the original one.protected static void checkResolvable(InetSocketAddress addr)
protected final int doReadBytes(ByteBuf byteBuf) throws Exception
ByteBuf
and return the amount.Exception
Copyright © 2008–2015 The Netty Project. All rights reserved.