Netty 4.1.107.Final · io.netty.channel.epoll.AbstractEpollStreamChannel

Modifier and Type	Class and Description
private class	AbstractEpollStreamChannel.EpollSocketWritableByteChannel
pack-priv class	AbstractEpollStreamChannel.EpollStreamUnsafe
private class	AbstractEpollStreamChannel.SpliceFdTask
private class	AbstractEpollStreamChannel.SpliceInChannelTask
protected abstract class	AbstractEpollStreamChannel.SpliceInTask
private class	AbstractEpollStreamChannel.SpliceOutTask

Modifier and Type	Field and Description
private WritableByteChannel	byteChannel
private static final String	EXPECTED_TYPES
private final Runnable	flushTask
private static final InternalLogger	logger Hides io.netty.channel.AbstractChannel.logger.
private static final ChannelMetadata	METADATA Hides io.netty.channel.epoll.AbstractEpollChannel.METADATA.
private FileDescriptor	pipeIn
private FileDescriptor	pipeOut
private volatile Queue<AbstractEpollStreamChannel.SpliceInTask>	spliceQueue

Access	Constructor and Description
protected	AbstractEpollStreamChannel(Channel parent, int fd)
protected	AbstractEpollStreamChannel(int fd)
pack-priv	AbstractEpollStreamChannel(LinuxSocket fd)
pack-priv	AbstractEpollStreamChannel(Channel parent, LinuxSocket fd)
protected	AbstractEpollStreamChannel(Channel parent, LinuxSocket fd, SocketAddress remote)
protected	AbstractEpollStreamChannel(LinuxSocket fd, boolean active)

Method Summary

Modifier and Type	Method and Description
private void	addToSpliceQueue(final AbstractEpollStreamChannel.SpliceInTask task)
private void	adjustMaxBytesPerGatheringWrite(long attempted, long written, long oldMaxBytesPerGatheringWrite)
private void	clearSpliceQueue()
protected void	doClose() Overrides io.netty.channel.epoll.AbstractEpollChannel.doClose. Close the `Channel`
protected final void	doShutdownOutput() Overrides io.netty.channel.AbstractChannel.doShutdownOutput. Called when conditions justify shutting down the output portion of the channel.
protected void	doWrite(ChannelOutboundBuffer in) Implements abstract io.netty.channel.AbstractChannel.doWrite. Flush the content of the given buffer to the remote peer.
private int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted doWriteMultiple(ChannelOutboundBuffer the collection which contains objects to write. in) Attempt to write multiple `ByteBuf` objects.
protected int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted doWriteSingle(ChannelOutboundBuffer the collection which contains objects to write. in) Attempt to write a single object.
private void	failSpliceIfClosed(ChannelPromise promise)
protected Object	filterOutboundMessage(Object msg) Overrides io.netty.channel.AbstractChannel.filterOutboundMessage. Invoked when a new message is added to a `ChannelOutboundBuffer` of this `AbstractChannel`, so that the `Channel` implementation converts the message to another.
public boolean	isInputShutdown() Implements io.netty.channel.socket.DuplexChannel.isInputShutdown. Returns `true` if and only if the remote peer shut down its output so that no more data is received from this channel.
public boolean	isOutputShutdown() Implements io.netty.channel.socket.DuplexChannel.isOutputShutdown.
public boolean	isShutdown() Implements io.netty.channel.socket.DuplexChannel.isShutdown. Determine if both the input and output of this channel have been shutdown.
public ChannelMetadata	metadata() Overrides io.netty.channel.epoll.AbstractEpollChannel.metadata. Implements io.netty.channel.Channel.metadata. Return the `ChannelMetadata` of the `Channel` which describe the nature of the `Channel`.
protected AbstractEpollChannel.AbstractEpollUnsafe	newUnsafe() Implements abstract io.netty.channel.epoll.AbstractEpollChannel.newUnsafe. Create a new `AbstractUnsafe` instance which will be used for the life-time of the `Channel`
private static void	safeClosePipe(FileDescriptor fd)
public ChannelFuture	shutdown() Implements io.netty.channel.socket.DuplexChannel.shutdown. Will shutdown the input and output sides of this channel.
public ChannelFuture	shutdown(final ChannelPromise will be completed when both shutdown operations complete. promise) Implements io.netty.channel.socket.DuplexChannel.shutdown. Will shutdown the input and output sides of this channel.
private static void	shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
public ChannelFuture	shutdownInput() Implements io.netty.channel.socket.DuplexChannel.shutdownInput.
public ChannelFuture	shutdownInput(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdownInput. Will shutdown the input and notify `ChannelPromise`.
private void	shutdownInput0(final ChannelPromise promise)
public ChannelFuture	shutdownOutput() Implements io.netty.channel.socket.DuplexChannel.shutdownOutput.
public ChannelFuture	shutdownOutput(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdownOutput. Will shutdown the output and notify `ChannelPromise`.
private void	shutdownOutputDone(final ChannelFuture shutdownOutputFuture, final ChannelPromise promise)
public final ChannelFuture	spliceTo(final AbstractEpollStreamChannel ch, final int len) Splice from this `AbstractEpollStreamChannel` to another `AbstractEpollStreamChannel`.
public final ChannelFuture	spliceTo(final AbstractEpollStreamChannel ch, final int len, final ChannelPromise promise) Splice from this `AbstractEpollStreamChannel` to another `AbstractEpollStreamChannel`.
public final ChannelFuture	spliceTo(final FileDescriptor ch, final int offset, final int len) Splice from this `AbstractEpollStreamChannel` to another `FileDescriptor`.
public final ChannelFuture	spliceTo(final FileDescriptor ch, final int offset, final int len, final ChannelPromise promise) Splice from this `AbstractEpollStreamChannel` to another `FileDescriptor`.
private int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted writeBytes(ChannelOutboundBuffer the collection which contains objects to write. in, ByteBuf the `ByteBuf` from which the bytes should be written buf) Write bytes form the given `ByteBuf` to the underlying `java.nio.channels.Channel`.
private int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted writeBytesMultiple(ChannelOutboundBuffer the collection which contains objects to write. in, IovArray The array which contains the content to write. array) Write multiple bytes via `IovArray`.
private int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted writeBytesMultiple(ChannelOutboundBuffer the collection which contains objects to write. in, ByteBuffer[] The buffers to write. nioBuffers, int The number of buffers to write. nioBufferCnt, long The number of bytes we expect to write. expectedWrittenBytes, long The maximum number of bytes we should attempt to write. maxBytesPerGatheringWrite) Write multiple bytes via `ByteBuffer` array.
private int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted writeDefaultFileRegion(ChannelOutboundBuffer the collection which contains objects to write. in, DefaultFileRegion the `DefaultFileRegion` from which the bytes should be written region) Write a `DefaultFileRegion`
private int	Returns: The value that should be decremented from the write quantum which starts at `ChannelConfig#getWriteSpinCount()`. The typical use cases are as follows: 0 - if no write was attempted. This is appropriate if an empty `ByteBuf` (or other empty content) is encountered 1 - if a single call to write data was made to the OS `ChannelUtils#WRITE_STATUS_SNDBUF_FULL` - if an attempt to write data was made to the OS, but no data was accepted writeFileRegion(ChannelOutboundBuffer the collection which contains objects to write. in, FileRegion the `FileRegion` from which the bytes should be written region) Write a `FileRegion`

public abstract Class AbstractEpollStreamChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary