Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.embedded |
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context. |
io.netty.channel.epoll |
Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
|
io.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
io.netty.channel.nio |
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.oio |
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.sctp.nio |
NIO-based SCTP Channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.sctp.oio |
Old blocking I/O based SCTP channel API implementation - recommended for
a small number of connections (< 1000).
|
io.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
io.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
Modifier and Type | Field and Description |
---|---|
private ChannelOutboundBuffer |
PendingWriteQueue.buffer |
private ChannelOutboundBuffer |
AbstractChannel.AbstractUnsafe.outboundBuffer |
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.atomic.AtomicLongFieldUpdater<ChannelOutboundBuffer> |
ChannelOutboundBuffer.TOTAL_PENDING_SIZE_UPDATER |
private static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<ChannelOutboundBuffer> |
ChannelOutboundBuffer.UNWRITABLE_UPDATER |
Modifier and Type | Method and Description |
---|---|
ChannelOutboundBuffer |
AbstractChannel.AbstractUnsafe.outboundBuffer() |
ChannelOutboundBuffer |
Channel.Unsafe.outboundBuffer()
Returns the
ChannelOutboundBuffer of the Channel where the pending write requests are stored. |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractChannel.doWrite(ChannelOutboundBuffer in)
Flush the content of the given buffer to the remote peer.
|
protected void |
AbstractServerChannel.doWrite(ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected void |
EmbeddedChannel.doWrite(ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEpollStreamChannel.doWrite(ChannelOutboundBuffer in) |
protected void |
AbstractEpollServerChannel.doWrite(ChannelOutboundBuffer in) |
protected void |
EpollDatagramChannel.doWrite(ChannelOutboundBuffer in) |
private boolean |
AbstractEpollStreamChannel.doWriteMultiple(ChannelOutboundBuffer in,
int writeSpinCount) |
protected boolean |
AbstractEpollStreamChannel.doWriteSingle(ChannelOutboundBuffer in,
int writeSpinCount) |
protected boolean |
EpollDomainSocketChannel.doWriteSingle(ChannelOutboundBuffer in,
int writeSpinCount) |
(package private) static NativeDatagramPacketArray |
NativeDatagramPacketArray.getInstance(ChannelOutboundBuffer buffer)
Returns a
NativeDatagramPacketArray which is filled with the flushed messages of
ChannelOutboundBuffer . |
private boolean |
AbstractEpollStreamChannel.writeBytes(ChannelOutboundBuffer in,
ByteBuf buf,
int writeSpinCount)
Write bytes form the given
ByteBuf to the underlying Channel . |
private boolean |
AbstractEpollStreamChannel.writeBytesMultiple(ChannelOutboundBuffer in,
java.nio.ByteBuffer[] nioBuffers,
int nioBufferCnt,
long expectedWrittenBytes,
int writeSpinCount) |
private boolean |
AbstractEpollStreamChannel.writeBytesMultiple(ChannelOutboundBuffer in,
IovArray array,
int writeSpinCount) |
private boolean |
AbstractEpollStreamChannel.writeDefaultFileRegion(ChannelOutboundBuffer in,
DefaultFileRegion region,
int writeSpinCount)
Write a
DefaultFileRegion |
private boolean |
AbstractEpollStreamChannel.writeFileRegion(ChannelOutboundBuffer in,
FileRegion region,
int writeSpinCount) |
Modifier and Type | Method and Description |
---|---|
protected void |
LocalChannel.doWrite(ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractNioMessageChannel.doWrite(ChannelOutboundBuffer in) |
protected void |
AbstractNioByteChannel.doWrite(ChannelOutboundBuffer in) |
protected abstract boolean |
AbstractNioMessageChannel.doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in)
Write a message to the underlying
Channel . |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractOioByteChannel.doWrite(ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
NioSctpChannel.doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in) |
protected boolean |
NioSctpServerChannel.doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected void |
OioSctpServerChannel.doWrite(ChannelOutboundBuffer in) |
protected void |
OioSctpChannel.doWrite(ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected void |
NioSocketChannel.doWrite(ChannelOutboundBuffer in) |
protected boolean |
NioServerSocketChannel.doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in) |
protected boolean |
NioDatagramChannel.doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in) |
Modifier and Type | Method and Description |
---|---|
protected void |
OioDatagramChannel.doWrite(ChannelOutboundBuffer in) |
protected void |
OioServerSocketChannel.doWrite(ChannelOutboundBuffer in) |