public abstract class AbstractEpollStreamChannel extends AbstractChannel implements DuplexChannel
| 限定符和类型 | 类和说明 |
|---|---|
protected class |
AbstractEpollStreamChannel.SpliceInTask |
AbstractChannel.AbstractUnsafeChannel.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, writeAndFlushattralloc, 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, writeAndFlushattr@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()
AbstractChannelAbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channelpublic 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 AbstractEpollStreamChannelpublic 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 AbstractEpollStreamChannelpublic 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
AbstractEpollStreamChannelFileDescriptor 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
AbstractEpollStreamChannelFileDescriptor will not be closed after the ChannelPromise is notifiedIllegalStateException will be thrown.protected void doWrite(ChannelOutboundBuffer in) throws java.lang.Exception
AbstractChanneldoWrite 在类中 AbstractChanneljava.lang.Exceptionprotected boolean doWriteSingle(ChannelOutboundBuffer in, int writeSpinCount) throws java.lang.Exception
java.lang.Exceptionprotected java.lang.Object filterOutboundMessage(java.lang.Object msg)
AbstractChannelChannelOutboundBuffer 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
AbstractChanneldoShutdownOutput 在类中 AbstractChanneljava.lang.Exceptionpublic boolean isInputShutdown()
DuplexChanneltrue 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 在接口中 DuplexChannelpublic boolean isOutputShutdown()
isOutputShutdown 在接口中 DuplexChannelSocket.isOutputShutdown()public ChannelFuture shutdownOutput()
shutdownOutput 在接口中 DuplexChannelSocket.shutdownOutput()public ChannelFuture shutdownOutput(ChannelPromise promise)
shutdownOutput 在接口中 DuplexChannelWill notify the given {@link ChannelPromise}protected void doClose()
throws java.lang.Exception
AbstractChannelChanneljava.lang.Exceptionpublic final Socket fd()
UnixChannelFileDescriptor that is used by this Channel.fd 在接口中 UnixChannelpublic abstract EpollChannelConfig config()
Channelpublic boolean isActive()
Channeltrue if the Channel is active and so connected.public ChannelMetadata metadata()
Channelprotected void doDisconnect()
throws java.lang.Exception
AbstractChannelChannel from its remote peerdoDisconnect 在类中 AbstractChanneljava.lang.Exceptionprotected boolean isCompatible(EventLoop loop)
AbstractChanneltrue if the given EventLoop is compatible with this instance.isCompatible 在类中 AbstractChannelpublic boolean isOpen()
Channeltrue if the Channel is open and may get active laterprotected void doDeregister()
throws java.lang.Exception
AbstractChanneldoDeregister 在类中 AbstractChanneljava.lang.Exceptionprotected void doBeginRead()
throws java.lang.Exception
AbstractChanneldoBeginRead 在类中 AbstractChanneljava.lang.Exceptionprotected void doRegister()
throws java.lang.Exception
AbstractChannelChannel is registered with its EventLoop as part of the register process.
Sub-classes may override this methoddoRegister 在类中 AbstractChanneljava.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 void doBind(java.net.SocketAddress local)
throws java.lang.Exception
AbstractChannelChannel to the SocketAddressdoBind 在类中 AbstractChanneljava.lang.Exceptionprotected boolean doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
throws java.lang.Exception
java.lang.Exceptionprotected java.net.SocketAddress localAddress0()
AbstractChannelSocketAddress which is bound locally.localAddress0 在类中 AbstractChannelprotected java.net.SocketAddress remoteAddress0()
AbstractChannelSocketAddress which the Channel is connected to.remoteAddress0 在类中 AbstractChannel