public abstract class AbstractEpollStreamChannel extends AbstractChannel implements DuplexChannel
限定符和类型 | 类和说明 |
---|---|
protected class |
AbstractEpollStreamChannel.SpliceInTask |
AbstractChannel.AbstractUnsafe
Channel.Unsafe
限定符 | 构造器和说明 |
---|---|
protected |
AbstractEpollStreamChannel(Channel parent,
int fd)
|
protected |
AbstractEpollStreamChannel(Channel parent,
Socket fd) |
protected |
AbstractEpollStreamChannel(FileDescriptor fd)
|
protected |
AbstractEpollStreamChannel(int fd)
|
protected |
AbstractEpollStreamChannel(Socket fd)
|
protected |
AbstractEpollStreamChannel(Socket fd,
boolean active) |
限定符和类型 | 方法和说明 |
---|---|
protected static void |
checkResolvable(java.net.InetSocketAddress addr) |
abstract EpollChannelConfig |
config()
Returns the configuration of this channel.
|
protected void |
doBeginRead()
Schedule a read operation.
|
protected void |
doBind(java.net.SocketAddress local)
Bind the
Channel to the SocketAddress |
protected void |
doClose()
Close the
Channel |
protected boolean |
doConnect(java.net.SocketAddress remoteAddress,
java.net.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 |
doShutdownOutput()
Called when conditions justify shutting down the output portion of the channel.
|
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) |
Socket |
fd()
Returns the
FileDescriptor that is used by this Channel . |
protected java.lang.Object |
filterOutboundMessage(java.lang.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. |
boolean |
isInputShutdown()
Returns
true if and only if the remote peer shut down its output so that no more
data is received from this channel. |
boolean |
isOpen()
Returns
true if the Channel is open and may get active later |
boolean |
isOutputShutdown() |
protected java.net.SocketAddress |
localAddress0()
Returns the
SocketAddress which is bound locally. |
ChannelMetadata |
metadata()
|
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. |
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 java.net.SocketAddress |
remoteAddress0()
Return the
SocketAddress which the Channel is connected to. |
ChannelFuture |
shutdownOutput() |
ChannelFuture |
shutdownOutput(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, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr
alloc, bind, bind, close, close, closeFuture, config, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr
@Deprecated protected AbstractEpollStreamChannel(Channel parent, int fd)
@Deprecated protected AbstractEpollStreamChannel(int fd)
@Deprecated protected AbstractEpollStreamChannel(FileDescriptor fd)
@Deprecated protected AbstractEpollStreamChannel(Socket fd)
protected AbstractEpollStreamChannel(Socket fd, boolean active)
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 notifiedIllegalStateException
will be thrown.public 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 notifiedIllegalStateException
will be thrown.protected void doWrite(ChannelOutboundBuffer in) throws java.lang.Exception
AbstractChannel
doWrite
在类中 AbstractChannel
java.lang.Exception
protected boolean doWriteSingle(ChannelOutboundBuffer in, int writeSpinCount) throws java.lang.Exception
java.lang.Exception
protected java.lang.Object filterOutboundMessage(java.lang.Object msg)
AbstractChannel
ChannelOutboundBuffer
of this AbstractChannel
, so that
the Channel
implementation converts the message to another. (e.g. heap buffer -> direct buffer)filterOutboundMessage
在类中 AbstractChannel
@UnstableApi protected final void doShutdownOutput() throws java.lang.Exception
AbstractChannel
doShutdownOutput
在类中 AbstractChannel
java.lang.Exception
public boolean isInputShutdown()
DuplexChannel
true
if and only if the remote peer shut down its output so that no more
data is received from this channel. Note that the semantic of this method is different from
that of Socket.shutdownInput()
and Socket.isInputShutdown()
.isInputShutdown
在接口中 DuplexChannel
public boolean isOutputShutdown()
isOutputShutdown
在接口中 DuplexChannel
Socket.isOutputShutdown()
public ChannelFuture shutdownOutput()
shutdownOutput
在接口中 DuplexChannel
Socket.shutdownOutput()
public ChannelFuture shutdownOutput(ChannelPromise promise)
shutdownOutput
在接口中 DuplexChannel
Will notify the given {@link ChannelPromise}
protected void doClose() throws java.lang.Exception
AbstractChannel
Channel
java.lang.Exception
public final Socket fd()
UnixChannel
FileDescriptor
that is used by this Channel
.fd
在接口中 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 java.lang.Exception
AbstractChannel
Channel
from its remote peerdoDisconnect
在类中 AbstractChannel
java.lang.Exception
protected boolean isCompatible(EventLoop loop)
AbstractChannel
true
if the given EventLoop
is compatible with this instance.isCompatible
在类中 AbstractChannel
public boolean isOpen()
Channel
true
if the Channel
is open and may get active laterprotected void doDeregister() throws java.lang.Exception
AbstractChannel
doDeregister
在类中 AbstractChannel
java.lang.Exception
protected void doBeginRead() throws java.lang.Exception
AbstractChannel
doBeginRead
在类中 AbstractChannel
java.lang.Exception
protected 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
在类中 AbstractChannel
java.lang.Exception
protected 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.Exception
protected final int doWriteBytes(ByteBuf buf, int writeSpinCount) throws java.lang.Exception
java.lang.Exception
protected void doBind(java.net.SocketAddress local) throws java.lang.Exception
AbstractChannel
Channel
to the SocketAddress
doBind
在类中 AbstractChannel
java.lang.Exception
protected boolean doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) throws java.lang.Exception
java.lang.Exception
protected java.net.SocketAddress localAddress0()
AbstractChannel
SocketAddress
which is bound locally.localAddress0
在类中 AbstractChannel
protected java.net.SocketAddress remoteAddress0()
AbstractChannel
SocketAddress
which the Channel
is connected to.remoteAddress0
在类中 AbstractChannel