Package | Description |
---|---|
io.netty.buffer |
Abstraction of a byte buffer - the fundamental data structure
to represent a low-level binary and text message.
|
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.epoll |
Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
|
io.netty.channel.kqueue |
BSD specific transport.
|
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 |
Abstract SCTP socket interfaces which extend the core channel API.
|
io.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
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).
|
io.netty.channel.unix |
Unix specific transport.
|
io.netty.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.base64 | |
io.netty.handler.codec.bytes |
Encoder and decoder which transform an array of bytes into a
ByteBuf and vice versa. |
io.netty.handler.codec.compression | |
io.netty.handler.codec.dns |
DNS codec.
|
io.netty.handler.codec.haproxy |
Decodes an HAProxy proxy protocol header
|
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.multipart |
HTTP multipart support.
|
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.codec.json |
JSON specific codecs.
|
io.netty.handler.codec.memcache |
Common superset of ascii and binary classes.
|
io.netty.handler.codec.memcache.binary |
Implementations and Interfaces for the Memcache Binary protocol.
|
io.netty.handler.codec.mqtt |
Encoder, decoder and different Message Types for MQTT.
|
io.netty.handler.codec.redis |
Encoder, decoder for Redis.
|
io.netty.handler.codec.rtsp |
An RTSP
extension based on the HTTP codec.
|
io.netty.handler.codec.sctp |
Decoder and encoders to manage message completion and multi-streaming codec in SCTP/IP.
|
io.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
io.netty.handler.codec.smtp |
SMTP codec.
|
io.netty.handler.codec.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.socksx |
Encoder, decoder and their related message types for SOCKS protocol.
|
io.netty.handler.codec.socksx.v4 |
Encoder, decoder and their related message types for SOCKSv4 protocol.
|
io.netty.handler.codec.socksx.v5 |
Encoder, decoder and their related message types for SOCKSv5 protocol.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ByteBuf and vice versa. |
io.netty.handler.codec.xml |
Xml specific codecs.
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
io.netty.resolver.dns |
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractByteBuf
A skeletal implementation of a buffer.
|
class |
AbstractDerivedByteBuf
Deprecated.
Do not use.
|
(package private) class |
AbstractPooledDerivedByteBuf
Abstract base class for derived
ByteBuf implementations. |
private static class |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf |
private static class |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf |
class |
AbstractReferenceCountedByteBuf
Abstract base class for
ByteBuf implementations that count references. |
(package private) class |
AbstractUnpooledSlicedByteBuf |
(package private) class |
AbstractUnsafeSwappedByteBuf
Special
SwappedByteBuf for ByteBuf s that is using unsafe. |
(package private) class |
AdvancedLeakAwareByteBuf |
(package private) class |
AdvancedLeakAwareCompositeByteBuf |
(package private) static class |
ByteBufUtil.ThreadLocalDirectByteBuf |
(package private) static class |
ByteBufUtil.ThreadLocalUnsafeDirectByteBuf |
class |
CompositeByteBuf
A virtual buffer which shows multiple buffers as a single merged buffer.
|
class |
DuplicatedByteBuf
Deprecated.
Do not use.
|
class |
EmptyByteBuf
An empty
ByteBuf whose capacity and maximum capacity are all 0 . |
(package private) class |
FixedCompositeByteBuf
|
(package private) class |
PooledByteBuf<T> |
(package private) class |
PooledDirectByteBuf |
(package private) class |
PooledDuplicatedByteBuf |
(package private) class |
PooledHeapByteBuf |
(package private) class |
PooledSlicedByteBuf |
(package private) class |
PooledUnsafeDirectByteBuf |
(package private) class |
PooledUnsafeHeapByteBuf |
class |
ReadOnlyByteBuf
Deprecated.
Do not use.
|
(package private) class |
ReadOnlyByteBufferBuf
Read-only ByteBuf which wraps a read-only ByteBuffer.
|
(package private) class |
ReadOnlyUnsafeDirectByteBuf
Read-only ByteBuf which wraps a read-only direct ByteBuffer and use unsafe for best performance.
|
(package private) class |
SimpleLeakAwareByteBuf |
(package private) class |
SimpleLeakAwareCompositeByteBuf |
class |
SlicedByteBuf
Deprecated.
Do not use.
|
class |
SwappedByteBuf
Deprecated.
use the Little Endian accessors, e.g.
getShortLE , getIntLE
instead. |
private static class |
UnpooledByteBufAllocator.InstrumentedUnpooledDirectByteBuf |
private static class |
UnpooledByteBufAllocator.InstrumentedUnpooledHeapByteBuf |
private static class |
UnpooledByteBufAllocator.InstrumentedUnpooledUnsafeDirectByteBuf |
private static class |
UnpooledByteBufAllocator.InstrumentedUnpooledUnsafeHeapByteBuf |
private static class |
UnpooledByteBufAllocator.InstrumentedUnpooledUnsafeNoCleanerDirectByteBuf |
class |
UnpooledDirectByteBuf
A NIO
ByteBuffer based buffer. |
(package private) class |
UnpooledDuplicatedByteBuf
DuplicatedByteBuf implementation that can do optimizations because it knows the duplicated buffer
is of type AbstractByteBuf . |
class |
UnpooledHeapByteBuf
Big endian Java heap buffer implementation.
|
(package private) class |
UnpooledSlicedByteBuf
A special
AbstractUnpooledSlicedByteBuf that can make optimizations because it knows the sliced buffer is of
type AbstractByteBuf . |
class |
UnpooledUnsafeDirectByteBuf
A NIO
ByteBuffer based buffer. |
(package private) class |
UnpooledUnsafeHeapByteBuf |
(package private) class |
UnpooledUnsafeNoCleanerDirectByteBuf |
(package private) class |
UnreleasableByteBuf
A
ByteBuf implementation that wraps another buffer to prevent a user from increasing or decreasing the
wrapped buffer's reference count. |
(package private) class |
UnsafeDirectSwappedByteBuf
|
(package private) class |
UnsafeHeapSwappedByteBuf
Special
SwappedByteBuf for ByteBuf s that use unsafe to access the byte array. |
(package private) class |
WrappedByteBuf
Wraps another
ByteBuf . |
(package private) class |
WrappedCompositeByteBuf |
(package private) class |
WrappedUnpooledUnsafeDirectByteBuf |
Modifier and Type | Field and Description |
---|---|
protected ByteBuf |
WrappedByteBuf.buf |
private ByteBuf |
FixedCompositeByteBuf.Component.buf |
(package private) ByteBuf |
CompositeByteBuf.Component.buf |
private ByteBuf |
SwappedByteBuf.buf
Deprecated.
|
private ByteBuf |
AbstractUnpooledSlicedByteBuf.buffer |
private ByteBuf |
ByteBufOutputStream.buffer |
private ByteBuf |
DuplicatedByteBuf.buffer
Deprecated.
|
private ByteBuf |
ByteBufInputStream.buffer |
private ByteBuf |
ReadOnlyByteBuf.buffer
Deprecated.
|
private ByteBuf |
DefaultByteBufHolder.data |
private static ByteBuf[] |
FixedCompositeByteBuf.EMPTY |
static ByteBuf |
Unpooled.EMPTY_BUFFER
A buffer whose capacity is
0 . |
private ByteBuf |
AbstractByteBufAllocator.emptyBuf |
private ByteBuf |
AbstractPooledDerivedByteBuf.parent
Deallocations of a pooled derived buffer should always propagate through the entire chain of derived buffers.
|
private ByteBuf |
SimpleLeakAwareByteBuf.trackedByteBuf
This object's is associated with the
ResourceLeakTracker . |
Modifier and Type | Field and Description |
---|---|
private static java.util.Iterator<ByteBuf> |
CompositeByteBuf.EMPTY_ITERATOR |
(package private) ResourceLeakTracker<ByteBuf> |
SimpleLeakAwareByteBuf.leak |
(package private) ResourceLeakTracker<ByteBuf> |
SimpleLeakAwareCompositeByteBuf.leak |
(package private) static ResourceLeakDetector<ByteBuf> |
AbstractByteBuf.leakDetector |
Modifier and Type | Method and Description |
---|---|
private ByteBuf |
CompositeByteBuf.allocBuffer(int capacity) |
ByteBuf |
AbstractByteBuf.asReadOnly() |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.asReadOnly() |
ByteBuf |
EmptyByteBuf.asReadOnly() |
ByteBuf |
WrappedByteBuf.asReadOnly() |
ByteBuf |
SimpleLeakAwareByteBuf.asReadOnly() |
ByteBuf |
WrappedCompositeByteBuf.asReadOnly() |
abstract ByteBuf |
ByteBuf.asReadOnly()
Returns a read-only version of this buffer.
|
ByteBuf |
SwappedByteBuf.asReadOnly()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.asReadOnly() |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.asReadOnly() |
ByteBuf |
UnreleasableByteBuf.asReadOnly() |
ByteBuf |
ReadOnlyByteBuf.asReadOnly()
Deprecated.
|
ByteBuf |
ByteBufOutputStream.buffer()
Returns the buffer where this stream is writing data.
|
static ByteBuf |
Unpooled.buffer()
Creates a new big-endian Java heap buffer with reasonably small initial capacity, which
expands its capacity boundlessly on demand.
|
ByteBuf |
ByteBufAllocator.buffer()
Allocate a
ByteBuf . |
ByteBuf |
AbstractByteBufAllocator.buffer() |
private ByteBuf |
FixedCompositeByteBuf.buffer(int i)
Return the
ByteBuf stored at the given index of the array. |
static ByteBuf |
Unpooled.buffer(int initialCapacity)
Creates a new big-endian Java heap buffer with the specified
capacity , which
expands its capacity boundlessly on demand. |
ByteBuf |
ByteBufAllocator.buffer(int initialCapacity)
Allocate a
ByteBuf with the given initial capacity. |
ByteBuf |
AbstractByteBufAllocator.buffer(int initialCapacity) |
static ByteBuf |
Unpooled.buffer(int initialCapacity,
int maxCapacity)
Creates a new big-endian Java heap buffer with the specified
initialCapacity , that may grow up to maxCapacity
The new buffer's readerIndex and writerIndex are
0 . |
ByteBuf |
ByteBufAllocator.buffer(int initialCapacity,
int maxCapacity)
Allocate a
ByteBuf with the given initial capacity and the given
maximal capacity. |
ByteBuf |
AbstractByteBufAllocator.buffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
EmptyByteBuf.capacity(int newCapacity) |
ByteBuf |
PooledDuplicatedByteBuf.capacity(int newCapacity) |
ByteBuf |
UnpooledUnsafeNoCleanerDirectByteBuf.capacity(int newCapacity) |
ByteBuf |
WrappedByteBuf.capacity(int newCapacity) |
ByteBuf |
ReadOnlyByteBufferBuf.capacity(int newCapacity) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.capacity(int newCapacity) |
ByteBuf |
FixedCompositeByteBuf.capacity(int newCapacity) |
ByteBuf |
UnpooledDirectByteBuf.capacity(int newCapacity) |
ByteBuf |
DuplicatedByteBuf.capacity(int newCapacity)
Deprecated.
|
abstract ByteBuf |
ByteBuf.capacity(int newCapacity)
Adjusts the capacity of this buffer.
|
ByteBuf |
PooledSlicedByteBuf.capacity(int newCapacity) |
ByteBuf |
SwappedByteBuf.capacity(int newCapacity)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.capacity(int newCapacity) |
ByteBuf |
PooledByteBuf.capacity(int newCapacity) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.capacity(int newCapacity) |
ByteBuf |
ReadOnlyByteBuf.capacity(int newCapacity)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.capacity(int newCapacity) |
private ByteBuf |
EmptyByteBuf.checkIndex(int index) |
private ByteBuf |
EmptyByteBuf.checkIndex(int index,
int length) |
private ByteBuf |
EmptyByteBuf.checkLength(int length) |
ByteBuf |
AbstractByteBuf.clear() |
ByteBuf |
EmptyByteBuf.clear() |
ByteBuf |
WrappedByteBuf.clear() |
abstract ByteBuf |
ByteBuf.clear()
Sets the
readerIndex and writerIndex of this buffer to
0 . |
ByteBuf |
SwappedByteBuf.clear()
Deprecated.
|
ByteBuf |
WrappedCompositeByteBuf.component(int cIndex) |
ByteBuf |
CompositeByteBuf.component(int cIndex)
Return the
ByteBuf on the specified index |
ByteBuf |
WrappedCompositeByteBuf.componentAtOffset(int offset) |
ByteBuf |
CompositeByteBuf.componentAtOffset(int offset)
Return the
ByteBuf on the specified index |
ByteBuf |
ByteBufHolder.content()
Return the data which is held by this
ByteBufHolder . |
ByteBuf |
DefaultByteBufHolder.content() |
static ByteBuf |
Unpooled.copiedBuffer(byte[]... arrays)
Creates a new big-endian buffer whose content is a merged copy of
the specified
arrays . |
static ByteBuf |
Unpooled.copiedBuffer(byte[] array)
Creates a new big-endian buffer whose content is a copy of the
specified
array . |
static ByteBuf |
Unpooled.copiedBuffer(byte[] array,
int offset,
int length)
Creates a new big-endian buffer whose content is a copy of the
specified
array 's sub-region. |
static ByteBuf |
Unpooled.copiedBuffer(ByteBuf... buffers)
Creates a new buffer whose content is a merged copy of the specified
buffers ' readable bytes. |
static ByteBuf |
Unpooled.copiedBuffer(ByteBuf buffer)
Creates a new buffer whose content is a copy of the specified
buffer 's readable bytes. |
static ByteBuf |
Unpooled.copiedBuffer(java.nio.ByteBuffer... buffers)
Creates a new buffer whose content is a merged copy of the specified
buffers ' slices. |
static ByteBuf |
Unpooled.copiedBuffer(java.nio.ByteBuffer buffer)
Creates a new buffer whose content is a copy of the specified
buffer 's current slice. |
static ByteBuf |
Unpooled.copiedBuffer(char[] array,
java.nio.charset.Charset charset)
Creates a new big-endian buffer whose content is the specified
array encoded in the specified charset . |
static ByteBuf |
Unpooled.copiedBuffer(char[] array,
int offset,
int length,
java.nio.charset.Charset charset)
Creates a new big-endian buffer whose content is a subregion of
the specified
array encoded in the specified charset . |
private static ByteBuf |
Unpooled.copiedBuffer(java.nio.CharBuffer buffer,
java.nio.charset.Charset charset) |
static ByteBuf |
Unpooled.copiedBuffer(java.lang.CharSequence string,
java.nio.charset.Charset charset)
Creates a new big-endian buffer whose content is the specified
string encoded in the specified charset . |
static ByteBuf |
Unpooled.copiedBuffer(java.lang.CharSequence string,
int offset,
int length,
java.nio.charset.Charset charset)
Creates a new big-endian buffer whose content is a subregion of
the specified
string encoded in the specified charset . |
ByteBuf |
AbstractByteBuf.copy() |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.copy() |
ByteBuf |
EmptyByteBuf.copy() |
ByteBuf |
WrappedByteBuf.copy() |
ByteBuf |
WrappedCompositeByteBuf.copy() |
abstract ByteBuf |
ByteBuf.copy()
Returns a copy of this buffer's readable bytes.
|
ByteBuf |
SwappedByteBuf.copy()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.copy() |
(package private) static ByteBuf |
UnsafeByteBufUtil.copy(AbstractByteBuf buf,
long addr,
int index,
int length) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.copy(int index,
int length) |
ByteBuf |
EmptyByteBuf.copy(int index,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.copy(int index,
int length) |
ByteBuf |
WrappedByteBuf.copy(int index,
int length) |
ByteBuf |
ReadOnlyUnsafeDirectByteBuf.copy(int index,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.copy(int index,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.copy(int index,
int length) |
ByteBuf |
FixedCompositeByteBuf.copy(int index,
int length) |
ByteBuf |
WrappedCompositeByteBuf.copy(int index,
int length) |
ByteBuf |
UnpooledDirectByteBuf.copy(int index,
int length) |
ByteBuf |
DuplicatedByteBuf.copy(int index,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.copy(int index,
int length)
Returns a copy of this buffer's sub-region.
|
ByteBuf |
PooledSlicedByteBuf.copy(int index,
int length) |
ByteBuf |
CompositeByteBuf.copy(int index,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.copy(int index,
int length) |
ByteBuf |
SwappedByteBuf.copy(int index,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.copy(int index,
int length) |
ByteBuf |
PooledDirectByteBuf.copy(int index,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.copy(int index,
int length) |
ByteBuf |
ReadOnlyByteBuf.copy(int index,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.copy(int index,
int length) |
ByteBuf |
UnpooledHeapByteBuf.copy(int index,
int length) |
static ByteBuf |
Unpooled.copyBoolean(boolean... values)
Create a new big-endian buffer that holds a sequence of the specified boolean values.
|
static ByteBuf |
Unpooled.copyBoolean(boolean value)
Creates a new single-byte big-endian buffer that holds the specified boolean value.
|
static ByteBuf |
Unpooled.copyDouble(double... values)
Create a new big-endian buffer that holds a sequence of the specified 64-bit floating point numbers.
|
static ByteBuf |
Unpooled.copyDouble(double value)
Creates a new 8-byte big-endian buffer that holds the specified 64-bit floating point number.
|
static ByteBuf |
Unpooled.copyFloat(float... values)
Create a new big-endian buffer that holds a sequence of the specified 32-bit floating point numbers.
|
static ByteBuf |
Unpooled.copyFloat(float value)
Creates a new 4-byte big-endian buffer that holds the specified 32-bit floating point number.
|
static ByteBuf |
Unpooled.copyInt(int... values)
Create a big-endian buffer that holds a sequence of the specified 32-bit integers.
|
static ByteBuf |
Unpooled.copyInt(int value)
Creates a new 4-byte big-endian buffer that holds the specified 32-bit integer.
|
static ByteBuf |
Unpooled.copyLong(long... values)
Create a new big-endian buffer that holds a sequence of the specified 64-bit integers.
|
static ByteBuf |
Unpooled.copyLong(long value)
Creates a new 8-byte big-endian buffer that holds the specified 64-bit integer.
|
static ByteBuf |
Unpooled.copyMedium(int... values)
Create a new big-endian buffer that holds a sequence of the specified 24-bit integers.
|
static ByteBuf |
Unpooled.copyMedium(int value)
Creates a new 3-byte big-endian buffer that holds the specified 24-bit integer.
|
static ByteBuf |
Unpooled.copyShort(int... values)
Create a new big-endian buffer that holds a sequence of the specified 16-bit integers.
|
static ByteBuf |
Unpooled.copyShort(int value)
Creates a new 2-byte big-endian buffer that holds the specified 16-bit integer.
|
static ByteBuf |
Unpooled.copyShort(short... values)
Create a new big-endian buffer that holds a sequence of the specified 16-bit integers.
|
static ByteBuf |
Unpooled.directBuffer()
Creates a new big-endian direct buffer with reasonably small initial capacity, which
expands its capacity boundlessly on demand.
|
ByteBuf |
ByteBufAllocator.directBuffer()
Allocate a direct
ByteBuf . |
ByteBuf |
AbstractByteBufAllocator.directBuffer() |
static ByteBuf |
Unpooled.directBuffer(int initialCapacity)
Creates a new big-endian direct buffer with the specified
capacity , which
expands its capacity boundlessly on demand. |
ByteBuf |
ByteBufAllocator.directBuffer(int initialCapacity)
Allocate a direct
ByteBuf with the given initial capacity. |
ByteBuf |
AbstractByteBufAllocator.directBuffer(int initialCapacity) |
static ByteBuf |
Unpooled.directBuffer(int initialCapacity,
int maxCapacity)
Creates a new big-endian direct buffer with the specified
initialCapacity , that may grow up to maxCapacity . |
ByteBuf |
ByteBufAllocator.directBuffer(int initialCapacity,
int maxCapacity)
Allocate a direct
ByteBuf with the given initial capacity and the given
maximal capacity. |
ByteBuf |
AbstractByteBufAllocator.directBuffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
AbstractByteBuf.discardReadBytes() |
ByteBuf |
EmptyByteBuf.discardReadBytes() |
ByteBuf |
WrappedByteBuf.discardReadBytes() |
ByteBuf |
FixedCompositeByteBuf.discardReadBytes() |
abstract ByteBuf |
ByteBuf.discardReadBytes()
Discards the bytes between the 0th index and
readerIndex . |
ByteBuf |
SwappedByteBuf.discardReadBytes()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.discardReadBytes() |
ByteBuf |
ReadOnlyByteBuf.discardReadBytes()
Deprecated.
|
ByteBuf |
AbstractByteBuf.discardSomeReadBytes() |
ByteBuf |
EmptyByteBuf.discardSomeReadBytes() |
ByteBuf |
WrappedByteBuf.discardSomeReadBytes() |
abstract ByteBuf |
ByteBuf.discardSomeReadBytes()
Similar to
discardReadBytes() except that this method might discard
some, all, or none of read bytes depending on its internal implementation to reduce
overall memory bandwidth consumption at the cost of potentially additional memory
consumption. |
ByteBuf |
SwappedByteBuf.discardSomeReadBytes()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.discardSomeReadBytes() |
ByteBuf |
AbstractByteBuf.duplicate() |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.duplicate() |
ByteBuf |
EmptyByteBuf.duplicate() |
ByteBuf |
PooledDuplicatedByteBuf.duplicate() |
ByteBuf |
WrappedByteBuf.duplicate() |
ByteBuf |
AbstractUnpooledSlicedByteBuf.duplicate() |
ByteBuf |
SimpleLeakAwareByteBuf.duplicate() |
ByteBuf |
WrappedCompositeByteBuf.duplicate() |
abstract ByteBuf |
ByteBuf.duplicate()
Returns a buffer which shares the whole region of this buffer.
|
ByteBuf |
PooledSlicedByteBuf.duplicate() |
ByteBuf |
SwappedByteBuf.duplicate()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.duplicate() |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.duplicate() |
ByteBuf |
UnreleasableByteBuf.duplicate() |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.duplicate() |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.duplicate() |
ByteBuf |
ReadOnlyByteBuf.duplicate()
Deprecated.
|
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.duplicate0() |
static ByteBuf |
ByteBufUtil.encodeString(ByteBufAllocator alloc,
java.nio.CharBuffer src,
java.nio.charset.Charset charset)
Encode the given
CharBuffer using the given Charset into a new ByteBuf which
is allocated via the ByteBufAllocator . |
static ByteBuf |
ByteBufUtil.encodeString(ByteBufAllocator alloc,
java.nio.CharBuffer src,
java.nio.charset.Charset charset,
int extraCapacity)
Encode the given
CharBuffer using the given Charset into a new ByteBuf which
is allocated via the ByteBufAllocator . |
(package private) static ByteBuf |
ByteBufUtil.encodeString0(ByteBufAllocator alloc,
boolean enforceHeap,
java.nio.CharBuffer src,
java.nio.charset.Charset charset,
int extraCapacity) |
ByteBuf |
AbstractByteBuf.ensureWritable(int minWritableBytes) |
ByteBuf |
EmptyByteBuf.ensureWritable(int minWritableBytes) |
ByteBuf |
WrappedByteBuf.ensureWritable(int minWritableBytes) |
abstract ByteBuf |
ByteBuf.ensureWritable(int minWritableBytes)
Makes sure the number of the writable bytes
is equal to or greater than the specified value.
|
ByteBuf |
SwappedByteBuf.ensureWritable(int writableBytes)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.ensureWritable(int minWritableBytes) |
ByteBuf |
AbstractByteBuf.getBytes(int index,
byte[] dst) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
byte[] dst) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
byte[] dst) |
abstract ByteBuf |
ByteBuf.getBytes(int index,
byte[] dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
ByteBuf |
SwappedByteBuf.getBytes(int index,
byte[] dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
byte[] dst) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyUnsafeDirectByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
FixedCompositeByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
DuplicatedByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledHeapByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
AbstractByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
ByteBuf dst) |
abstract ByteBuf |
ByteBuf.getBytes(int index,
ByteBuf dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination becomes
non-writable. |
ByteBuf |
SwappedByteBuf.getBytes(int index,
ByteBuf dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
PooledDuplicatedByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
ReadOnlyUnsafeDirectByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
ReadOnlyByteBufferBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
FixedCompositeByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
UnpooledDirectByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
DuplicatedByteBuf.getBytes(int index,
java.nio.ByteBuffer dst)
Deprecated.
|
abstract ByteBuf |
ByteBuf.getBytes(int index,
java.nio.ByteBuffer dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination's position
reaches its limit. |
ByteBuf |
PooledSlicedByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
PooledUnsafeDirectByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
java.nio.ByteBuffer dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
PooledDirectByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
ReadOnlyByteBuf.getBytes(int index,
java.nio.ByteBuffer dst)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
UnpooledHeapByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
AbstractByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
abstract ByteBuf |
ByteBuf.getBytes(int index,
ByteBuf dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
ByteBuf |
SwappedByteBuf.getBytes(int index,
ByteBuf dst,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyUnsafeDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
FixedCompositeByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
DuplicatedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledHeapByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
FixedCompositeByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
UnpooledDirectByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
DuplicatedByteBuf.getBytes(int index,
java.io.OutputStream out,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.getBytes(int index,
java.io.OutputStream out,
int length)
Transfers this buffer's data to the specified stream starting at the
specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
java.io.OutputStream out,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
PooledDirectByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
ReadOnlyByteBuf.getBytes(int index,
java.io.OutputStream out,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
UnpooledHeapByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
ByteBuf |
ByteBufAllocator.heapBuffer()
Allocate a heap
ByteBuf . |
ByteBuf |
AbstractByteBufAllocator.heapBuffer() |
ByteBuf |
ByteBufAllocator.heapBuffer(int initialCapacity)
Allocate a heap
ByteBuf with the given initial capacity. |
ByteBuf |
AbstractByteBufAllocator.heapBuffer(int initialCapacity) |
ByteBuf |
ByteBufAllocator.heapBuffer(int initialCapacity,
int maxCapacity)
Allocate a heap
ByteBuf with the given initial capacity and the given
maximal capacity. |
ByteBuf |
AbstractByteBufAllocator.heapBuffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
WrappedCompositeByteBuf.internalComponent(int cIndex) |
ByteBuf |
CompositeByteBuf.internalComponent(int cIndex)
Return the internal
ByteBuf on the specified index. |
ByteBuf |
WrappedCompositeByteBuf.internalComponentAtOffset(int offset) |
ByteBuf |
CompositeByteBuf.internalComponentAtOffset(int offset)
Return the internal
ByteBuf on the specified offset. |
ByteBuf |
ByteBufAllocator.ioBuffer()
Allocate a
ByteBuf , preferably a direct buffer which is suitable for I/O. |
ByteBuf |
AbstractByteBufAllocator.ioBuffer() |
ByteBuf |
ByteBufAllocator.ioBuffer(int initialCapacity)
Allocate a
ByteBuf , preferably a direct buffer which is suitable for I/O. |
ByteBuf |
AbstractByteBufAllocator.ioBuffer(int initialCapacity) |
ByteBuf |
ByteBufAllocator.ioBuffer(int initialCapacity,
int maxCapacity)
Allocate a
ByteBuf , preferably a direct buffer which is suitable for I/O. |
ByteBuf |
AbstractByteBufAllocator.ioBuffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
AbstractByteBuf.markReaderIndex() |
ByteBuf |
EmptyByteBuf.markReaderIndex() |
ByteBuf |
WrappedByteBuf.markReaderIndex() |
abstract ByteBuf |
ByteBuf.markReaderIndex()
Marks the current
readerIndex in this buffer. |
ByteBuf |
SwappedByteBuf.markReaderIndex()
Deprecated.
|
ByteBuf |
AbstractByteBuf.markWriterIndex() |
ByteBuf |
EmptyByteBuf.markWriterIndex() |
ByteBuf |
WrappedByteBuf.markWriterIndex() |
abstract ByteBuf |
ByteBuf.markWriterIndex()
Marks the current
writerIndex in this buffer. |
ByteBuf |
SwappedByteBuf.markWriterIndex()
Deprecated.
|
protected ByteBuf |
UnpooledByteBufAllocator.newDirectBuffer(int initialCapacity,
int maxCapacity) |
protected ByteBuf |
PooledByteBufAllocator.newDirectBuffer(int initialCapacity,
int maxCapacity) |
protected abstract ByteBuf |
AbstractByteBufAllocator.newDirectBuffer(int initialCapacity,
int maxCapacity)
Create a direct
ByteBuf with the given initialCapacity and maxCapacity. |
protected ByteBuf |
UnpooledByteBufAllocator.newHeapBuffer(int initialCapacity,
int maxCapacity) |
protected ByteBuf |
PooledByteBufAllocator.newHeapBuffer(int initialCapacity,
int maxCapacity) |
protected abstract ByteBuf |
AbstractByteBufAllocator.newHeapBuffer(int initialCapacity,
int maxCapacity)
Create a heap
ByteBuf with the given initialCapacity and maxCapacity. |
ByteBuf |
CompositeByteBuf.CompositeByteBufIterator.next() |
ByteBuf |
AbstractByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
EmptyByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
WrappedByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
SimpleLeakAwareByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
WrappedCompositeByteBuf.order(java.nio.ByteOrder endianness) |
abstract ByteBuf |
ByteBuf.order(java.nio.ByteOrder endianness)
Deprecated.
use the Little Endian accessors, e.g.
getShortLE , getIntLE
instead of creating a buffer with swapped endianness . |
ByteBuf |
SwappedByteBuf.order(java.nio.ByteOrder endianness)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
UnreleasableByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
AbstractByteBuf.readBytes(byte[] dst) |
ByteBuf |
EmptyByteBuf.readBytes(byte[] dst) |
ByteBuf |
WrappedByteBuf.readBytes(byte[] dst) |
abstract ByteBuf |
ByteBuf.readBytes(byte[] dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= dst.length ). |
ByteBuf |
SwappedByteBuf.readBytes(byte[] dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(byte[] dst) |
ByteBuf |
AbstractByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
ByteBuf |
EmptyByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
ByteBuf |
WrappedByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
abstract ByteBuf |
ByteBuf.readBytes(byte[] dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.readBytes(byte[] dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
ByteBuf |
AbstractByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
EmptyByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
WrappedByteBuf.readBytes(ByteBuf dst) |
abstract ByteBuf |
ByteBuf.readBytes(ByteBuf dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex until the destination becomes
non-writable, and increases the readerIndex by the number of the
transferred bytes. |
ByteBuf |
SwappedByteBuf.readBytes(ByteBuf dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(ByteBuf dst) |
static ByteBuf |
ByteBufUtil.readBytes(ByteBufAllocator alloc,
ByteBuf buffer,
int length)
Read the given amount of bytes into a new
ByteBuf that is allocated from the ByteBufAllocator . |
ByteBuf |
AbstractByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
EmptyByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
WrappedByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
UnpooledDirectByteBuf.readBytes(java.nio.ByteBuffer dst) |
abstract ByteBuf |
ByteBuf.readBytes(java.nio.ByteBuffer dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex until the destination's position
reaches its limit, and increases the readerIndex by the
number of the transferred bytes. |
ByteBuf |
PooledUnsafeDirectByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
SwappedByteBuf.readBytes(java.nio.ByteBuffer dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
PooledDirectByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
AbstractByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
EmptyByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
WrappedByteBuf.readBytes(ByteBuf dst,
int length) |
abstract ByteBuf |
ByteBuf.readBytes(ByteBuf dst,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.readBytes(ByteBuf dst,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
AbstractByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
EmptyByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
WrappedByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
abstract ByteBuf |
ByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
AbstractByteBuf.readBytes(int length) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.readBytes(int length) |
ByteBuf |
EmptyByteBuf.readBytes(int length) |
ByteBuf |
WrappedByteBuf.readBytes(int length) |
ByteBuf |
WrappedCompositeByteBuf.readBytes(int length) |
abstract ByteBuf |
ByteBuf.readBytes(int length)
Transfers this buffer's data to a newly created buffer starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.readBytes(int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(int length) |
ByteBuf |
AbstractByteBuf.readBytes(java.io.OutputStream out,
int length) |
ByteBuf |
EmptyByteBuf.readBytes(java.io.OutputStream out,
int length) |
ByteBuf |
WrappedByteBuf.readBytes(java.io.OutputStream out,
int length) |
ByteBuf |
UnpooledDirectByteBuf.readBytes(java.io.OutputStream out,
int length) |
abstract ByteBuf |
ByteBuf.readBytes(java.io.OutputStream out,
int length)
Transfers this buffer's data to the specified stream starting at the
current
readerIndex . |
ByteBuf |
SwappedByteBuf.readBytes(java.io.OutputStream out,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(java.io.OutputStream out,
int length) |
ByteBuf |
PooledDirectByteBuf.readBytes(java.io.OutputStream out,
int length) |
ByteBuf |
AbstractByteBuf.readerIndex(int readerIndex) |
ByteBuf |
EmptyByteBuf.readerIndex(int readerIndex) |
ByteBuf |
WrappedByteBuf.readerIndex(int readerIndex) |
abstract ByteBuf |
ByteBuf.readerIndex(int readerIndex)
Sets the
readerIndex of this buffer. |
ByteBuf |
SwappedByteBuf.readerIndex(int readerIndex)
Deprecated.
|
ByteBuf |
AbstractByteBuf.readRetainedSlice(int length) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.readRetainedSlice(int length) |
ByteBuf |
EmptyByteBuf.readRetainedSlice(int length) |
ByteBuf |
WrappedByteBuf.readRetainedSlice(int length) |
ByteBuf |
SimpleLeakAwareByteBuf.readRetainedSlice(int length) |
ByteBuf |
WrappedCompositeByteBuf.readRetainedSlice(int length) |
abstract ByteBuf |
ByteBuf.readRetainedSlice(int length)
Returns a new retained slice of this buffer's sub-region starting at the current
readerIndex and increases the readerIndex by the size
of the new slice (= length ). |
ByteBuf |
SwappedByteBuf.readRetainedSlice(int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readRetainedSlice(int length) |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.readRetainedSlice(int length) |
ByteBuf |
UnreleasableByteBuf.readRetainedSlice(int length) |
ByteBuf |
AbstractByteBuf.readSlice(int length) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.readSlice(int length) |
ByteBuf |
EmptyByteBuf.readSlice(int length) |
ByteBuf |
WrappedByteBuf.readSlice(int length) |
ByteBuf |
SimpleLeakAwareByteBuf.readSlice(int length) |
ByteBuf |
WrappedCompositeByteBuf.readSlice(int length) |
abstract ByteBuf |
ByteBuf.readSlice(int length)
Returns a new slice of this buffer's sub-region starting at the current
readerIndex and increases the readerIndex by the size
of the new slice (= length ). |
ByteBuf |
SwappedByteBuf.readSlice(int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readSlice(int length) |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.readSlice(int length) |
ByteBuf |
UnreleasableByteBuf.readSlice(int length) |
ByteBuf |
AbstractByteBuf.resetReaderIndex() |
ByteBuf |
EmptyByteBuf.resetReaderIndex() |
ByteBuf |
WrappedByteBuf.resetReaderIndex() |
abstract ByteBuf |
ByteBuf.resetReaderIndex()
Repositions the current
readerIndex to the marked
readerIndex in this buffer. |
ByteBuf |
SwappedByteBuf.resetReaderIndex()
Deprecated.
|
ByteBuf |
AbstractByteBuf.resetWriterIndex() |
ByteBuf |
EmptyByteBuf.resetWriterIndex() |
ByteBuf |
WrappedByteBuf.resetWriterIndex() |
abstract ByteBuf |
ByteBuf.resetWriterIndex()
Repositions the current
writerIndex to the marked
writerIndex in this buffer. |
ByteBuf |
SwappedByteBuf.resetWriterIndex()
Deprecated.
|
ByteBuf |
AbstractDerivedByteBuf.retain()
Deprecated.
|
ByteBuf |
EmptyByteBuf.retain() |
ByteBuf |
WrappedByteBuf.retain() |
abstract ByteBuf |
ByteBuf.retain() |
ByteBuf |
SwappedByteBuf.retain()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.retain() |
ByteBuf |
UnreleasableByteBuf.retain() |
ByteBuf |
AbstractReferenceCountedByteBuf.retain() |
ByteBuf |
AbstractDerivedByteBuf.retain(int increment)
Deprecated.
|
ByteBuf |
EmptyByteBuf.retain(int increment) |
ByteBuf |
WrappedByteBuf.retain(int increment) |
abstract ByteBuf |
ByteBuf.retain(int increment) |
ByteBuf |
SwappedByteBuf.retain(int increment)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.retain(int increment) |
ByteBuf |
UnreleasableByteBuf.retain(int increment) |
ByteBuf |
AbstractReferenceCountedByteBuf.retain(int increment) |
(package private) ByteBuf |
AbstractDerivedByteBuf.retain0()
Deprecated.
|
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.retain0() |
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.retain0() |
(package private) ByteBuf |
AbstractDerivedByteBuf.retain0(int increment)
Deprecated.
|
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.retain0(int increment) |
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.retain0(int increment) |
private ByteBuf |
AbstractReferenceCountedByteBuf.retain0(int increment) |
ByteBuf |
AbstractByteBuf.retainedDuplicate() |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.retainedDuplicate() |
ByteBuf |
EmptyByteBuf.retainedDuplicate() |
ByteBuf |
PooledDuplicatedByteBuf.retainedDuplicate() |
ByteBuf |
WrappedByteBuf.retainedDuplicate() |
ByteBuf |
SimpleLeakAwareByteBuf.retainedDuplicate() |
ByteBuf |
WrappedCompositeByteBuf.retainedDuplicate() |
abstract ByteBuf |
ByteBuf.retainedDuplicate()
Returns a retained buffer which shares the whole region of this buffer.
|
ByteBuf |
PooledSlicedByteBuf.retainedDuplicate() |
ByteBuf |
SwappedByteBuf.retainedDuplicate()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.retainedDuplicate() |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.retainedDuplicate() |
ByteBuf |
UnreleasableByteBuf.retainedDuplicate() |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.retainedDuplicate() |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.retainedDuplicate() |
ByteBuf |
PooledByteBuf.retainedDuplicate() |
ByteBuf |
AbstractByteBuf.retainedSlice() |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.retainedSlice() |
ByteBuf |
EmptyByteBuf.retainedSlice() |
ByteBuf |
WrappedByteBuf.retainedSlice() |
ByteBuf |
SimpleLeakAwareByteBuf.retainedSlice() |
ByteBuf |
WrappedCompositeByteBuf.retainedSlice() |
abstract ByteBuf |
ByteBuf.retainedSlice()
Returns a retained slice of this buffer's readable bytes.
|
ByteBuf |
SwappedByteBuf.retainedSlice()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.retainedSlice() |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.retainedSlice() |
ByteBuf |
UnreleasableByteBuf.retainedSlice() |
ByteBuf |
AbstractPooledDerivedByteBuf.retainedSlice() |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.retainedSlice() |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.retainedSlice() |
ByteBuf |
PooledByteBuf.retainedSlice() |
ByteBuf |
AbstractByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
EmptyByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
WrappedByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
SimpleLeakAwareByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
WrappedCompositeByteBuf.retainedSlice(int index,
int length) |
abstract ByteBuf |
ByteBuf.retainedSlice(int index,
int length)
Returns a retained slice of this buffer's sub-region.
|
ByteBuf |
PooledSlicedByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
SwappedByteBuf.retainedSlice(int index,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
UnreleasableByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
PooledByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
AbstractByteBuf.setBoolean(int index,
boolean value) |
ByteBuf |
EmptyByteBuf.setBoolean(int index,
boolean value) |
ByteBuf |
WrappedByteBuf.setBoolean(int index,
boolean value) |
abstract ByteBuf |
ByteBuf.setBoolean(int index,
boolean value)
Sets the specified boolean at the specified absolute
index in this
buffer. |
ByteBuf |
SwappedByteBuf.setBoolean(int index,
boolean value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBoolean(int index,
boolean value) |
ByteBuf |
AbstractByteBuf.setByte(int index,
int value) |
ByteBuf |
EmptyByteBuf.setByte(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setByte(int index,
int value) |
ByteBuf |
WrappedByteBuf.setByte(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setByte(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setByte(int index,
int value) |
ByteBuf |
FixedCompositeByteBuf.setByte(int index,
int value) |
ByteBuf |
UnpooledDirectByteBuf.setByte(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setByte(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setByte(int index,
int value)
Sets the specified byte at the specified absolute
index in this
buffer. |
ByteBuf |
PooledSlicedByteBuf.setByte(int index,
int value) |
ByteBuf |
SwappedByteBuf.setByte(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setByte(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setByte(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setByte(int index,
int value)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.setByte(int index,
int value) |
ByteBuf |
AbstractByteBuf.setBytes(int index,
byte[] src) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
byte[] src) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
byte[] src) |
abstract ByteBuf |
ByteBuf.setBytes(int index,
byte[] src)
Transfers the specified source array's data to this buffer starting at
the specified absolute
index . |
ByteBuf |
SwappedByteBuf.setBytes(int index,
byte[] src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
byte[] src) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
FixedCompositeByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
DuplicatedByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length)
Transfers the specified source array's data to this buffer starting at
the specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
SwappedByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
ReadOnlyByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
UnpooledHeapByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
AbstractByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
ByteBuf src) |
abstract ByteBuf |
ByteBuf.setBytes(int index,
ByteBuf src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the source buffer becomes
unreadable. |
ByteBuf |
SwappedByteBuf.setBytes(int index,
ByteBuf src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
PooledDuplicatedByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
ReadOnlyByteBufferBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
FixedCompositeByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
UnpooledDirectByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
DuplicatedByteBuf.setBytes(int index,
java.nio.ByteBuffer src)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setBytes(int index,
java.nio.ByteBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the source buffer's position
reaches its limit. |
ByteBuf |
PooledSlicedByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
PooledUnsafeDirectByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
SwappedByteBuf.setBytes(int index,
java.nio.ByteBuffer src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
PooledDirectByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
ReadOnlyByteBuf.setBytes(int index,
java.nio.ByteBuffer src)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
UnpooledHeapByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
AbstractByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
ByteBuf src,
int length) |
abstract ByteBuf |
ByteBuf.setBytes(int index,
ByteBuf src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
ByteBuf |
SwappedByteBuf.setBytes(int index,
ByteBuf src,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
FixedCompositeByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
DuplicatedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
SwappedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
ReadOnlyByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
UnpooledHeapByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
AbstractByteBuf.setChar(int index,
int value) |
ByteBuf |
EmptyByteBuf.setChar(int index,
int value) |
ByteBuf |
WrappedByteBuf.setChar(int index,
int value) |
abstract ByteBuf |
ByteBuf.setChar(int index,
int value)
Sets the specified 2-byte UTF-16 character at the specified absolute
index in this buffer. |
ByteBuf |
SwappedByteBuf.setChar(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setChar(int index,
int value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.setChar(int index,
int value) |
ByteBuf |
AbstractByteBuf.setDouble(int index,
double value) |
ByteBuf |
EmptyByteBuf.setDouble(int index,
double value) |
ByteBuf |
WrappedByteBuf.setDouble(int index,
double value) |
abstract ByteBuf |
ByteBuf.setDouble(int index,
double value)
Sets the specified 64-bit floating-point number at the specified
absolute
index in this buffer. |
ByteBuf |
SwappedByteBuf.setDouble(int index,
double value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setDouble(int index,
double value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.setDouble(int index,
double value) |
ByteBuf |
AbstractByteBuf.setFloat(int index,
float value) |
ByteBuf |
EmptyByteBuf.setFloat(int index,
float value) |
ByteBuf |
WrappedByteBuf.setFloat(int index,
float value) |
abstract ByteBuf |
ByteBuf.setFloat(int index,
float value)
Sets the specified 32-bit floating-point number at the specified
absolute
index in this buffer. |
ByteBuf |
SwappedByteBuf.setFloat(int index,
float value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setFloat(int index,
float value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.setFloat(int index,
float value) |
ByteBuf |
AbstractByteBuf.setIndex(int readerIndex,
int writerIndex) |
ByteBuf |
EmptyByteBuf.setIndex(int readerIndex,
int writerIndex) |
ByteBuf |
WrappedByteBuf.setIndex(int readerIndex,
int writerIndex) |
abstract ByteBuf |
ByteBuf.setIndex(int readerIndex,
int writerIndex)
Sets the
readerIndex and writerIndex of this buffer
in one shot. |
ByteBuf |
SwappedByteBuf.setIndex(int readerIndex,
int writerIndex)
Deprecated.
|
ByteBuf |
AbstractByteBuf.setInt(int index,
int value) |
ByteBuf |
EmptyByteBuf.setInt(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setInt(int index,
int value) |
ByteBuf |
WrappedByteBuf.setInt(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setInt(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setInt(int index,
int value) |
ByteBuf |
FixedCompositeByteBuf.setInt(int index,
int value) |
ByteBuf |
UnpooledDirectByteBuf.setInt(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setInt(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setInt(int index,
int value)
Sets the specified 32-bit integer at the specified absolute
index in this buffer. |
ByteBuf |
PooledSlicedByteBuf.setInt(int index,
int value) |
ByteBuf |
SwappedByteBuf.setInt(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setInt(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setInt(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setInt(int index,
int value)
Deprecated.
|
ByteBuf |
AbstractUnsafeSwappedByteBuf.setInt(int index,
int value) |
ByteBuf |
UnpooledHeapByteBuf.setInt(int index,
int value) |
ByteBuf |
AbstractByteBuf.setIntLE(int index,
int value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.setIntLE(int index,
int value) |
ByteBuf |
EmptyByteBuf.setIntLE(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setIntLE(int index,
int value) |
ByteBuf |
WrappedByteBuf.setIntLE(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setIntLE(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setIntLE(int index,
int value) |
ByteBuf |
WrappedCompositeByteBuf.setIntLE(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setIntLE(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setIntLE(int index,
int value)
Sets the specified 32-bit integer at the specified absolute
index in this buffer with Little Endian byte order
. |
ByteBuf |
PooledSlicedByteBuf.setIntLE(int index,
int value) |
ByteBuf |
SwappedByteBuf.setIntLE(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setIntLE(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setIntLE(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setIntLE(int index,
int value)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.setIntLE(int index,
int value) |
ByteBuf |
AbstractByteBuf.setLong(int index,
long value) |
ByteBuf |
EmptyByteBuf.setLong(int index,
long value) |
ByteBuf |
PooledDuplicatedByteBuf.setLong(int index,
long value) |
ByteBuf |
WrappedByteBuf.setLong(int index,
long value) |
ByteBuf |
ReadOnlyByteBufferBuf.setLong(int index,
long value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setLong(int index,
long value) |
ByteBuf |
FixedCompositeByteBuf.setLong(int index,
long value) |
ByteBuf |
UnpooledDirectByteBuf.setLong(int index,
long value) |
ByteBuf |
DuplicatedByteBuf.setLong(int index,
long value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setLong(int index,
long value)
Sets the specified 64-bit long integer at the specified absolute
index in this buffer. |
ByteBuf |
PooledSlicedByteBuf.setLong(int index,
long value) |
ByteBuf |
SwappedByteBuf.setLong(int index,
long value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setLong(int index,
long value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setLong(int index,
long value) |
ByteBuf |
ReadOnlyByteBuf.setLong(int index,
long value)
Deprecated.
|
ByteBuf |
AbstractUnsafeSwappedByteBuf.setLong(int index,
long value) |
ByteBuf |
UnpooledHeapByteBuf.setLong(int index,
long value) |
ByteBuf |
AbstractByteBuf.setLongLE(int index,
long value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.setLongLE(int index,
long value) |
ByteBuf |
EmptyByteBuf.setLongLE(int index,
long value) |
ByteBuf |
PooledDuplicatedByteBuf.setLongLE(int index,
long value) |
ByteBuf |
WrappedByteBuf.setLongLE(int index,
long value) |
ByteBuf |
ReadOnlyByteBufferBuf.setLongLE(int index,
long value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setLongLE(int index,
long value) |
ByteBuf |
WrappedCompositeByteBuf.setLongLE(int index,
long value) |
ByteBuf |
DuplicatedByteBuf.setLongLE(int index,
long value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setLongLE(int index,
long value)
Sets the specified 64-bit long integer at the specified absolute
index in this buffer in Little Endian Byte Order. |
ByteBuf |
PooledSlicedByteBuf.setLongLE(int index,
long value) |
ByteBuf |
SwappedByteBuf.setLongLE(int index,
long value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setLongLE(int index,
long value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setLongLE(int index,
long value) |
ByteBuf |
ReadOnlyByteBuf.setLongLE(int index,
long value)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.setLongLE(int index,
long value) |
ByteBuf |
AbstractByteBuf.setMedium(int index,
int value) |
ByteBuf |
EmptyByteBuf.setMedium(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setMedium(int index,
int value) |
ByteBuf |
WrappedByteBuf.setMedium(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setMedium(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setMedium(int index,
int value) |
ByteBuf |
FixedCompositeByteBuf.setMedium(int index,
int value) |
ByteBuf |
UnpooledDirectByteBuf.setMedium(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setMedium(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setMedium(int index,
int value)
Sets the specified 24-bit medium integer at the specified absolute
index in this buffer. |
ByteBuf |
PooledSlicedByteBuf.setMedium(int index,
int value) |
ByteBuf |
SwappedByteBuf.setMedium(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setMedium(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setMedium(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setMedium(int index,
int value)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.setMedium(int index,
int value) |
ByteBuf |
AbstractByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
EmptyByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
WrappedByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setMediumLE(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
WrappedCompositeByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setMediumLE(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setMediumLE(int index,
int value)
Sets the specified 24-bit medium integer at the specified absolute
index in this buffer in the Little Endian Byte Order. |
ByteBuf |
PooledSlicedByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
SwappedByteBuf.setMediumLE(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setMediumLE(int index,
int value)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
AbstractByteBuf.setShort(int index,
int value) |
ByteBuf |
EmptyByteBuf.setShort(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setShort(int index,
int value) |
ByteBuf |
WrappedByteBuf.setShort(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setShort(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setShort(int index,
int value) |
ByteBuf |
FixedCompositeByteBuf.setShort(int index,
int value) |
ByteBuf |
UnpooledDirectByteBuf.setShort(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setShort(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setShort(int index,
int value)
Sets the specified 16-bit short integer at the specified absolute
index in this buffer. |
ByteBuf |
PooledSlicedByteBuf.setShort(int index,
int value) |
ByteBuf |
SwappedByteBuf.setShort(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setShort(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setShort(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setShort(int index,
int value)
Deprecated.
|
ByteBuf |
AbstractUnsafeSwappedByteBuf.setShort(int index,
int value) |
ByteBuf |
UnpooledHeapByteBuf.setShort(int index,
int value) |
ByteBuf |
AbstractByteBuf.setShortLE(int index,
int value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.setShortLE(int index,
int value) |
ByteBuf |
EmptyByteBuf.setShortLE(int index,
int value) |
ByteBuf |
PooledDuplicatedByteBuf.setShortLE(int index,
int value) |
ByteBuf |
WrappedByteBuf.setShortLE(int index,
int value) |
ByteBuf |
ReadOnlyByteBufferBuf.setShortLE(int index,
int value) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setShortLE(int index,
int value) |
ByteBuf |
WrappedCompositeByteBuf.setShortLE(int index,
int value) |
ByteBuf |
DuplicatedByteBuf.setShortLE(int index,
int value)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setShortLE(int index,
int value)
Sets the specified 16-bit short integer at the specified absolute
index in this buffer with the Little Endian Byte Order. |
ByteBuf |
PooledSlicedByteBuf.setShortLE(int index,
int value) |
ByteBuf |
SwappedByteBuf.setShortLE(int index,
int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setShortLE(int index,
int value) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setShortLE(int index,
int value) |
ByteBuf |
ReadOnlyByteBuf.setShortLE(int index,
int value)
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.setShortLE(int index,
int value) |
ByteBuf |
AbstractByteBuf.setZero(int index,
int length) |
ByteBuf |
EmptyByteBuf.setZero(int index,
int length) |
ByteBuf |
WrappedByteBuf.setZero(int index,
int length) |
abstract ByteBuf |
ByteBuf.setZero(int index,
int length)
Fills this buffer with NUL (0x00) starting at the specified
absolute
index . |
ByteBuf |
PooledUnsafeDirectByteBuf.setZero(int index,
int length) |
ByteBuf |
SwappedByteBuf.setZero(int index,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setZero(int index,
int length) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.setZero(int index,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.setZero(int index,
int length) |
ByteBuf |
PooledUnsafeHeapByteBuf.setZero(int index,
int length) |
ByteBuf |
AbstractByteBuf.skipBytes(int length) |
ByteBuf |
EmptyByteBuf.skipBytes(int length) |
ByteBuf |
WrappedByteBuf.skipBytes(int length) |
abstract ByteBuf |
ByteBuf.skipBytes(int length)
Increases the current
readerIndex by the specified
length in this buffer. |
ByteBuf |
SwappedByteBuf.skipBytes(int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.skipBytes(int length) |
ByteBuf |
AbstractByteBuf.slice() |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.slice() |
ByteBuf |
EmptyByteBuf.slice() |
ByteBuf |
WrappedByteBuf.slice() |
ByteBuf |
SimpleLeakAwareByteBuf.slice() |
ByteBuf |
WrappedCompositeByteBuf.slice() |
abstract ByteBuf |
ByteBuf.slice()
Returns a slice of this buffer's readable bytes.
|
ByteBuf |
SwappedByteBuf.slice()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.slice() |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.slice() |
ByteBuf |
UnreleasableByteBuf.slice() |
ByteBuf |
AbstractByteBuf.slice(int index,
int length) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.slice(int index,
int length) |
ByteBuf |
EmptyByteBuf.slice(int index,
int length) |
ByteBuf |
WrappedByteBuf.slice(int index,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.slice(int index,
int length) |
ByteBuf |
SimpleLeakAwareByteBuf.slice(int index,
int length) |
ByteBuf |
WrappedCompositeByteBuf.slice(int index,
int length) |
ByteBuf |
DuplicatedByteBuf.slice(int index,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.slice(int index,
int length)
Returns a slice of this buffer's sub-region.
|
ByteBuf |
PooledSlicedByteBuf.slice(int index,
int length) |
ByteBuf |
SwappedByteBuf.slice(int index,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.slice(int index,
int length) |
ByteBuf |
SimpleLeakAwareCompositeByteBuf.slice(int index,
int length) |
ByteBuf |
UnreleasableByteBuf.slice(int index,
int length) |
ByteBuf |
AbstractPooledDerivedByteBuf.slice(int index,
int length) |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.slice(int index,
int length) |
ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.slice(int index,
int length) |
ByteBuf |
ReadOnlyByteBuf.slice(int index,
int length)
Deprecated.
|
static ByteBuf |
ByteBufUtil.threadLocalDirectBuffer()
Returns a cached thread-local direct buffer, if available.
|
protected static ByteBuf |
AbstractByteBufAllocator.toLeakAwareBuffer(ByteBuf buf) |
ByteBuf |
AbstractDerivedByteBuf.touch()
Deprecated.
|
ByteBuf |
EmptyByteBuf.touch() |
ByteBuf |
WrappedByteBuf.touch() |
ByteBuf |
SimpleLeakAwareByteBuf.touch() |
abstract ByteBuf |
ByteBuf.touch() |
ByteBuf |
SwappedByteBuf.touch()
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.touch() |
ByteBuf |
UnreleasableByteBuf.touch() |
ByteBuf |
AbstractReferenceCountedByteBuf.touch() |
ByteBuf |
AbstractDerivedByteBuf.touch(java.lang.Object hint)
Deprecated.
|
ByteBuf |
EmptyByteBuf.touch(java.lang.Object hint) |
ByteBuf |
WrappedByteBuf.touch(java.lang.Object hint) |
ByteBuf |
SimpleLeakAwareByteBuf.touch(java.lang.Object hint) |
abstract ByteBuf |
ByteBuf.touch(java.lang.Object hint) |
ByteBuf |
SwappedByteBuf.touch(java.lang.Object hint)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.touch(java.lang.Object hint) |
ByteBuf |
UnreleasableByteBuf.touch(java.lang.Object hint) |
ByteBuf |
AbstractReferenceCountedByteBuf.touch(java.lang.Object hint) |
(package private) ByteBuf |
AbstractDerivedByteBuf.touch0()
Deprecated.
|
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.touch0() |
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.touch0() |
(package private) ByteBuf |
AbstractDerivedByteBuf.touch0(java.lang.Object hint)
Deprecated.
|
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedDuplicateByteBuf.touch0(java.lang.Object hint) |
(package private) ByteBuf |
AbstractPooledDerivedByteBuf.PooledNonRetainedSlicedByteBuf.touch0(java.lang.Object hint) |
static ByteBuf |
Unpooled.unmodifiableBuffer(ByteBuf... buffers)
|
static ByteBuf |
Unpooled.unmodifiableBuffer(ByteBuf buffer)
Deprecated.
Use
asReadOnly() . |
static ByteBuf |
Unpooled.unreleasableBuffer(ByteBuf buf)
Return a unreleasable view on the given
ByteBuf which will just ignore release and retain calls. |
ByteBuf |
EmptyByteBuf.unwrap() |
ByteBuf |
WrappedByteBuf.unwrap() |
ByteBuf |
ReadOnlyByteBufferBuf.unwrap() |
ByteBuf |
AbstractUnpooledSlicedByteBuf.unwrap() |
ByteBuf |
FixedCompositeByteBuf.unwrap() |
ByteBuf |
WrappedCompositeByteBuf.unwrap() |
ByteBuf |
UnpooledDirectByteBuf.unwrap() |
ByteBuf |
DuplicatedByteBuf.unwrap()
Deprecated.
|
abstract ByteBuf |
ByteBuf.unwrap()
Return the underlying buffer instance if this buffer is a wrapper of another buffer.
|
ByteBuf |
CompositeByteBuf.unwrap() |
ByteBuf |
SwappedByteBuf.unwrap()
Deprecated.
|
ByteBuf |
PooledByteBuf.unwrap() |
ByteBuf |
UnpooledUnsafeDirectByteBuf.unwrap() |
ByteBuf |
ReadOnlyByteBuf.unwrap()
Deprecated.
|
ByteBuf |
UnpooledHeapByteBuf.unwrap() |
private ByteBuf |
SimpleLeakAwareByteBuf.unwrappedDerived(ByteBuf derived) |
private static ByteBuf |
SimpleLeakAwareByteBuf.unwrapSwapped(ByteBuf buf) |
static ByteBuf |
Unpooled.wrappedBuffer(byte[]... arrays)
Creates a new big-endian composite buffer which wraps the specified
arrays without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(byte[] array)
Creates a new big-endian buffer which wraps the specified
array . |
static ByteBuf |
Unpooled.wrappedBuffer(byte[] array,
int offset,
int length)
Creates a new big-endian buffer which wraps the sub-region of the
specified
array . |
static ByteBuf |
Unpooled.wrappedBuffer(ByteBuf... buffers)
Creates a new big-endian composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(ByteBuf buffer)
Creates a new buffer which wraps the specified buffer's readable bytes.
|
static ByteBuf |
Unpooled.wrappedBuffer(java.nio.ByteBuffer... buffers)
Creates a new big-endian composite buffer which wraps the slices of the specified
NIO buffers without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(java.nio.ByteBuffer buffer)
Creates a new buffer which wraps the specified NIO buffer's current
slice.
|
static ByteBuf |
Unpooled.wrappedBuffer(int maxNumComponents,
byte[]... arrays)
Creates a new big-endian composite buffer which wraps the specified
arrays without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(int maxNumComponents,
ByteBuf... buffers)
Creates a new big-endian composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(int maxNumComponents,
java.nio.ByteBuffer... buffers)
Creates a new big-endian composite buffer which wraps the slices of the specified
NIO buffers without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(long memoryAddress,
int size,
boolean doFree)
Creates a new buffer which wraps the specified memory address.
|
static ByteBuf |
ByteBufUtil.writeAscii(ByteBufAllocator alloc,
java.lang.CharSequence seq)
|
ByteBuf |
AbstractByteBuf.writeBoolean(boolean value) |
ByteBuf |
EmptyByteBuf.writeBoolean(boolean value) |
ByteBuf |
WrappedByteBuf.writeBoolean(boolean value) |
abstract ByteBuf |
ByteBuf.writeBoolean(boolean value)
Sets the specified boolean at the current
writerIndex
and increases the writerIndex by 1 in this buffer. |
ByteBuf |
SwappedByteBuf.writeBoolean(boolean value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBoolean(boolean value) |
ByteBuf |
AbstractByteBuf.writeByte(int value) |
ByteBuf |
EmptyByteBuf.writeByte(int value) |
ByteBuf |
WrappedByteBuf.writeByte(int value) |
abstract ByteBuf |
ByteBuf.writeByte(int value)
Sets the specified byte at the current
writerIndex
and increases the writerIndex by 1 in this buffer. |
ByteBuf |
SwappedByteBuf.writeByte(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeByte(int value) |
ByteBuf |
AbstractByteBuf.writeBytes(byte[] src) |
ByteBuf |
EmptyByteBuf.writeBytes(byte[] src) |
ByteBuf |
WrappedByteBuf.writeBytes(byte[] src) |
abstract ByteBuf |
ByteBuf.writeBytes(byte[] src)
Transfers the specified source array's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= src.length ). |
ByteBuf |
SwappedByteBuf.writeBytes(byte[] src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(byte[] src) |
ByteBuf |
AbstractByteBuf.writeBytes(byte[] src,
int srcIndex,
int length) |
ByteBuf |
EmptyByteBuf.writeBytes(byte[] src,
int srcIndex,
int length) |
ByteBuf |
WrappedByteBuf.writeBytes(byte[] src,
int srcIndex,
int length) |
abstract ByteBuf |
ByteBuf.writeBytes(byte[] src,
int srcIndex,
int length)
Transfers the specified source array's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.writeBytes(byte[] src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(byte[] src,
int srcIndex,
int length) |
ByteBuf |
AbstractByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
EmptyByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
WrappedByteBuf.writeBytes(ByteBuf src) |
abstract ByteBuf |
ByteBuf.writeBytes(ByteBuf src)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex until the source buffer becomes
unreadable, and increases the writerIndex by the number of
the transferred bytes. |
ByteBuf |
SwappedByteBuf.writeBytes(ByteBuf src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
AbstractByteBuf.writeBytes(java.nio.ByteBuffer src) |
ByteBuf |
EmptyByteBuf.writeBytes(java.nio.ByteBuffer src) |
ByteBuf |
WrappedByteBuf.writeBytes(java.nio.ByteBuffer src) |
abstract ByteBuf |
ByteBuf.writeBytes(java.nio.ByteBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex until the source buffer's position
reaches its limit, and increases the writerIndex by the
number of the transferred bytes. |
ByteBuf |
SwappedByteBuf.writeBytes(java.nio.ByteBuffer src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(java.nio.ByteBuffer src) |
ByteBuf |
AbstractByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
EmptyByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
WrappedByteBuf.writeBytes(ByteBuf src,
int length) |
abstract ByteBuf |
ByteBuf.writeBytes(ByteBuf src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.writeBytes(ByteBuf src,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
AbstractByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
EmptyByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
WrappedByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
abstract ByteBuf |
ByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length ). |
ByteBuf |
SwappedByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
AbstractByteBuf.writeChar(int value) |
ByteBuf |
EmptyByteBuf.writeChar(int value) |
ByteBuf |
WrappedByteBuf.writeChar(int value) |
abstract ByteBuf |
ByteBuf.writeChar(int value)
Sets the specified 2-byte UTF-16 character at the current
writerIndex and increases the writerIndex by 2
in this buffer. |
ByteBuf |
SwappedByteBuf.writeChar(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeChar(int value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.writeChar(int value) |
ByteBuf |
AbstractByteBuf.writeDouble(double value) |
ByteBuf |
EmptyByteBuf.writeDouble(double value) |
ByteBuf |
WrappedByteBuf.writeDouble(double value) |
abstract ByteBuf |
ByteBuf.writeDouble(double value)
Sets the specified 64-bit floating point number at the current
writerIndex and increases the writerIndex by 8
in this buffer. |
ByteBuf |
SwappedByteBuf.writeDouble(double value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeDouble(double value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.writeDouble(double value) |
ByteBuf |
AbstractByteBuf.writeFloat(float value) |
ByteBuf |
EmptyByteBuf.writeFloat(float value) |
ByteBuf |
WrappedByteBuf.writeFloat(float value) |
abstract ByteBuf |
ByteBuf.writeFloat(float value)
Sets the specified 32-bit floating point number at the current
writerIndex and increases the writerIndex by 4
in this buffer. |
ByteBuf |
SwappedByteBuf.writeFloat(float value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeFloat(float value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.writeFloat(float value) |
ByteBuf |
AbstractByteBuf.writeInt(int value) |
ByteBuf |
EmptyByteBuf.writeInt(int value) |
ByteBuf |
WrappedByteBuf.writeInt(int value) |
abstract ByteBuf |
ByteBuf.writeInt(int value)
Sets the specified 32-bit integer at the current
writerIndex
and increases the writerIndex by 4 in this buffer. |
ByteBuf |
SwappedByteBuf.writeInt(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeInt(int value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.writeInt(int value) |
ByteBuf |
AbstractByteBuf.writeIntLE(int value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeIntLE(int value) |
ByteBuf |
EmptyByteBuf.writeIntLE(int value) |
ByteBuf |
WrappedByteBuf.writeIntLE(int value) |
ByteBuf |
WrappedCompositeByteBuf.writeIntLE(int value) |
abstract ByteBuf |
ByteBuf.writeIntLE(int value)
Sets the specified 32-bit integer at the current
writerIndex
in the Little Endian Byte Order and increases the writerIndex
by 4 in this buffer. |
ByteBuf |
SwappedByteBuf.writeIntLE(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeIntLE(int value) |
ByteBuf |
AbstractByteBuf.writeLong(long value) |
ByteBuf |
EmptyByteBuf.writeLong(long value) |
ByteBuf |
WrappedByteBuf.writeLong(long value) |
abstract ByteBuf |
ByteBuf.writeLong(long value)
Sets the specified 64-bit long integer at the current
writerIndex and increases the writerIndex by 8
in this buffer. |
ByteBuf |
SwappedByteBuf.writeLong(long value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeLong(long value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.writeLong(long value) |
ByteBuf |
AbstractByteBuf.writeLongLE(long value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeLongLE(long value) |
ByteBuf |
EmptyByteBuf.writeLongLE(long value) |
ByteBuf |
WrappedByteBuf.writeLongLE(long value) |
ByteBuf |
WrappedCompositeByteBuf.writeLongLE(long value) |
abstract ByteBuf |
ByteBuf.writeLongLE(long value)
Sets the specified 64-bit long integer at the current
writerIndex in the Little Endian Byte Order and
increases the writerIndex by 8
in this buffer. |
ByteBuf |
SwappedByteBuf.writeLongLE(long value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeLongLE(long value) |
ByteBuf |
AbstractByteBuf.writeMedium(int value) |
ByteBuf |
EmptyByteBuf.writeMedium(int value) |
ByteBuf |
WrappedByteBuf.writeMedium(int value) |
abstract ByteBuf |
ByteBuf.writeMedium(int value)
Sets the specified 24-bit medium integer at the current
writerIndex and increases the writerIndex by 3
in this buffer. |
ByteBuf |
SwappedByteBuf.writeMedium(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeMedium(int value) |
ByteBuf |
AbstractByteBuf.writeMediumLE(int value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeMediumLE(int value) |
ByteBuf |
EmptyByteBuf.writeMediumLE(int value) |
ByteBuf |
WrappedByteBuf.writeMediumLE(int value) |
ByteBuf |
WrappedCompositeByteBuf.writeMediumLE(int value) |
abstract ByteBuf |
ByteBuf.writeMediumLE(int value)
Sets the specified 24-bit medium integer at the current
writerIndex in the Little Endian Byte Order and
increases the writerIndex by 3 in this
buffer. |
ByteBuf |
SwappedByteBuf.writeMediumLE(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeMediumLE(int value) |
ByteBuf |
AbstractByteBuf.writerIndex(int writerIndex) |
ByteBuf |
EmptyByteBuf.writerIndex(int writerIndex) |
ByteBuf |
WrappedByteBuf.writerIndex(int writerIndex) |
abstract ByteBuf |
ByteBuf.writerIndex(int writerIndex)
Sets the
writerIndex of this buffer. |
ByteBuf |
SwappedByteBuf.writerIndex(int writerIndex)
Deprecated.
|
ByteBuf |
AbstractByteBuf.writeShort(int value) |
ByteBuf |
EmptyByteBuf.writeShort(int value) |
ByteBuf |
WrappedByteBuf.writeShort(int value) |
abstract ByteBuf |
ByteBuf.writeShort(int value)
Sets the specified 16-bit short integer at the current
writerIndex and increases the writerIndex by 2
in this buffer. |
ByteBuf |
SwappedByteBuf.writeShort(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeShort(int value) |
ByteBuf |
AbstractUnsafeSwappedByteBuf.writeShort(int value) |
ByteBuf |
AbstractByteBuf.writeShortLE(int value) |
ByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeShortLE(int value) |
ByteBuf |
EmptyByteBuf.writeShortLE(int value) |
ByteBuf |
WrappedByteBuf.writeShortLE(int value) |
ByteBuf |
WrappedCompositeByteBuf.writeShortLE(int value) |
abstract ByteBuf |
ByteBuf.writeShortLE(int value)
Sets the specified 16-bit short integer in the Little Endian Byte
Order at the current
writerIndex and increases the
writerIndex by 2 in this buffer. |
ByteBuf |
SwappedByteBuf.writeShortLE(int value)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeShortLE(int value) |
static ByteBuf |
ByteBufUtil.writeUtf8(ByteBufAllocator alloc,
java.lang.CharSequence seq)
|
ByteBuf |
AbstractByteBuf.writeZero(int length) |
ByteBuf |
EmptyByteBuf.writeZero(int length) |
ByteBuf |
WrappedByteBuf.writeZero(int length) |
abstract ByteBuf |
ByteBuf.writeZero(int length)
Fills this buffer with NUL (0x00) starting at the current
writerIndex and increases the writerIndex by the
specified length . |
ByteBuf |
PooledUnsafeDirectByteBuf.writeZero(int length) |
ByteBuf |
SwappedByteBuf.writeZero(int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeZero(int length) |
ByteBuf |
UnpooledUnsafeHeapByteBuf.writeZero(int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.writeZero(int length) |
ByteBuf |
PooledUnsafeHeapByteBuf.writeZero(int length) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ByteBuf> |
AdvancedLeakAwareCompositeByteBuf.decompose(int offset,
int length) |
java.util.List<ByteBuf> |
WrappedCompositeByteBuf.decompose(int offset,
int length) |
java.util.List<ByteBuf> |
CompositeByteBuf.decompose(int offset,
int length)
Same with
AbstractByteBuf.slice(int, int) except that this method returns a list. |
java.util.Iterator<ByteBuf> |
AdvancedLeakAwareCompositeByteBuf.iterator() |
java.util.Iterator<ByteBuf> |
WrappedCompositeByteBuf.iterator() |
java.util.Iterator<ByteBuf> |
CompositeByteBuf.iterator() |
Modifier and Type | Method and Description |
---|---|
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponent(boolean increaseWriterIndex,
ByteBuf buffer) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponent(boolean increaseWriterIndex,
ByteBuf buffer) |
CompositeByteBuf |
CompositeByteBuf.addComponent(boolean increaseWriterIndex,
ByteBuf buffer)
|
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponent(boolean increaseWriterIndex,
int cIndex,
ByteBuf buffer) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponent(boolean increaseWriterIndex,
int cIndex,
ByteBuf buffer) |
CompositeByteBuf |
CompositeByteBuf.addComponent(boolean increaseWriterIndex,
int cIndex,
ByteBuf buffer)
Add the given
ByteBuf on the specific index and increase the writerIndex
if increaseWriterIndex is true . |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponent(ByteBuf buffer) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponent(ByteBuf buffer) |
CompositeByteBuf |
CompositeByteBuf.addComponent(ByteBuf buffer)
Add the given
ByteBuf . |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponent(int cIndex,
ByteBuf buffer) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponent(int cIndex,
ByteBuf buffer) |
CompositeByteBuf |
CompositeByteBuf.addComponent(int cIndex,
ByteBuf buffer)
Add the given
ByteBuf on the specific index. |
private int |
CompositeByteBuf.addComponent0(boolean increaseWriterIndex,
int cIndex,
ByteBuf buffer)
Precondition is that
buffer != null . |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponents(boolean increaseWriterIndex,
ByteBuf... buffers) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponents(boolean increaseWriterIndex,
ByteBuf... buffers) |
CompositeByteBuf |
CompositeByteBuf.addComponents(boolean increaseWriterIndex,
ByteBuf... buffers)
|
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponents(ByteBuf... buffers) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponents(ByteBuf... buffers) |
CompositeByteBuf |
CompositeByteBuf.addComponents(ByteBuf... buffers)
Add the given
ByteBuf s. |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponents(int cIndex,
ByteBuf... buffers) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponents(int cIndex,
ByteBuf... buffers) |
CompositeByteBuf |
CompositeByteBuf.addComponents(int cIndex,
ByteBuf... buffers)
Add the given
ByteBuf s on the specific index |
private int |
CompositeByteBuf.addComponents0(boolean increaseWriterIndex,
int cIndex,
ByteBuf[] buffers,
int offset,
int len) |
static void |
ByteBufUtil.appendPrettyHexDump(java.lang.StringBuilder dump,
ByteBuf buf)
Appends the prettified multi-line hexadecimal dump of the specified
ByteBuf to the specified
StringBuilder that is easy to read by humans. |
static void |
ByteBufUtil.appendPrettyHexDump(java.lang.StringBuilder dump,
ByteBuf buf,
int offset,
int length)
Appends the prettified multi-line hexadecimal dump of the specified
ByteBuf to the specified
StringBuilder that is easy to read by humans, starting at the given offset using
the given length . |
private static void |
ByteBufUtil.HexUtil.appendPrettyHexDump(java.lang.StringBuilder dump,
ByteBuf buf,
int offset,
int length) |
(package private) static void |
AbstractUnpooledSlicedByteBuf.checkSliceOutOfBounds(int index,
int length,
ByteBuf buffer) |
private void |
SimpleLeakAwareCompositeByteBuf.closeLeak(ByteBuf trackedByteBuf) |
static int |
ByteBufUtil.compare(ByteBuf bufferA,
ByteBuf bufferB)
Compares the two specified buffers as described in
compareTo(ByteBuf) . |
int |
AbstractByteBuf.compareTo(ByteBuf that) |
int |
EmptyByteBuf.compareTo(ByteBuf buffer) |
int |
WrappedByteBuf.compareTo(ByteBuf buffer) |
int |
WrappedCompositeByteBuf.compareTo(ByteBuf that) |
abstract int |
ByteBuf.compareTo(ByteBuf buffer)
Compares the content of the specified buffer to the content of this
buffer.
|
int |
SwappedByteBuf.compareTo(ByteBuf buffer)
Deprecated.
|
private static long |
ByteBufUtil.compareUintBigEndian(ByteBuf bufferA,
ByteBuf bufferB,
int aIndex,
int bIndex,
int uintCountIncrement) |
private static long |
ByteBufUtil.compareUintBigEndianA(ByteBuf bufferA,
ByteBuf bufferB,
int aIndex,
int bIndex,
int uintCountIncrement) |
private static long |
ByteBufUtil.compareUintBigEndianB(ByteBuf bufferA,
ByteBuf bufferB,
int aIndex,
int bIndex,
int uintCountIncrement) |
private static long |
ByteBufUtil.compareUintLittleEndian(ByteBuf bufferA,
ByteBuf bufferB,
int aIndex,
int bIndex,
int uintCountIncrement) |
static ByteBuf |
Unpooled.copiedBuffer(ByteBuf... buffers)
Creates a new buffer whose content is a merged copy of the specified
buffers ' readable bytes. |
static ByteBuf |
Unpooled.copiedBuffer(ByteBuf buffer)
Creates a new buffer whose content is a copy of the specified
buffer 's readable bytes. |
static void |
ByteBufUtil.copy(AsciiString src,
ByteBuf dst)
|
static void |
ByteBufUtil.copy(AsciiString src,
int srcIdx,
ByteBuf dst,
int length)
|
static void |
ByteBufUtil.copy(AsciiString src,
int srcIdx,
ByteBuf dst,
int dstIdx,
int length)
|
private void |
CompositeByteBuf.copyTo(int index,
int length,
int componentId,
ByteBuf dst) |
(package private) static java.lang.String |
ByteBufUtil.decodeString(ByteBuf src,
int readerIndex,
int len,
java.nio.charset.Charset charset) |
static boolean |
ByteBufUtil.equals(ByteBuf bufferA,
ByteBuf bufferB)
Returns
true if and only if the two specified buffers are
identical to each other as described in equals(Object) . |
static boolean |
ByteBufUtil.equals(ByteBuf a,
int aStartIndex,
ByteBuf b,
int bStartIndex,
int length)
Returns
true if and only if the two specified buffers are
identical to each other for length bytes starting at aStartIndex
index for the a buffer and bStartIndex index for the b buffer. |
private static int |
ByteBufUtil.firstIndexOf(ByteBuf buffer,
int fromIndex,
int toIndex,
byte value) |
(package private) static void |
UnsafeByteBufUtil.getBytes(AbstractByteBuf buf,
long addr,
int index,
ByteBuf dst,
int dstIndex,
int length) |
static byte[] |
ByteBufUtil.getBytes(ByteBuf buf)
Create a copy of the underlying storage from
buf into a byte array. |
static byte[] |
ByteBufUtil.getBytes(ByteBuf buf,
int start,
int length)
Create a copy of the underlying storage from
buf into a byte array. |
static byte[] |
ByteBufUtil.getBytes(ByteBuf buf,
int start,
int length,
boolean copy)
Return an array of the underlying storage from
buf into a byte array. |
ByteBuf |
AbstractByteBuf.getBytes(int index,
ByteBuf dst) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
ByteBuf dst) |
CompositeByteBuf |
WrappedCompositeByteBuf.getBytes(int index,
ByteBuf dst) |
abstract ByteBuf |
ByteBuf.getBytes(int index,
ByteBuf dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination becomes
non-writable. |
CompositeByteBuf |
CompositeByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
ByteBuf dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
AbstractByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
abstract ByteBuf |
ByteBuf.getBytes(int index,
ByteBuf dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
CompositeByteBuf |
CompositeByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
ByteBuf dst,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
EmptyByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
WrappedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyUnsafeDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
FixedCompositeByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
DuplicatedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
CompositeByteBuf |
CompositeByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
SwappedByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReadOnlyByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
UnpooledHeapByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
static int |
ByteBufUtil.hashCode(ByteBuf buffer)
Calculates the hash code of the specified buffer.
|
static java.lang.String |
ByteBufUtil.hexDump(ByteBuf buffer)
Returns a hex dump
of the specified buffer's readable bytes.
|
static java.lang.String |
ByteBufUtil.hexDump(ByteBuf buffer,
int fromIndex,
int length)
Returns a hex dump
of the specified buffer's sub-region.
|
private static java.lang.String |
ByteBufUtil.HexUtil.hexDump(ByteBuf buffer,
int fromIndex,
int length) |
private static int |
UnsafeHeapSwappedByteBuf.idx(ByteBuf wrapped,
int index) |
static int |
ByteBufUtil.indexOf(ByteBuf needle,
ByteBuf haystack)
Returns the reader index of needle in haystack, or -1 if needle is not in haystack.
|
static int |
ByteBufUtil.indexOf(ByteBuf buffer,
int fromIndex,
int toIndex,
byte value)
The default implementation of
indexOf(int, int, byte) . |
(package private) <U extends AbstractPooledDerivedByteBuf> |
AbstractPooledDerivedByteBuf.init(AbstractByteBuf unwrapped,
ByteBuf wrapped,
int readerIndex,
int writerIndex,
int maxCapacity) |
private static boolean |
ByteBufUtil.isAscii(ByteBuf buf,
int index,
int length)
Returns
true if the specified ByteBuf starting at index with length is valid
ASCII text, otherwise return false . |
static boolean |
ByteBufUtil.isText(ByteBuf buf,
java.nio.charset.Charset charset)
|
static boolean |
ByteBufUtil.isText(ByteBuf buf,
int index,
int length,
java.nio.charset.Charset charset)
Returns
true if the specified ByteBuf starting at index with length is valid
text using the given Charset , otherwise return false . |
private static boolean |
ByteBufUtil.isUtf8(ByteBuf buf,
int index,
int length)
Returns
true if the specified ByteBuf starting at index with length is valid
UTF8 text, otherwise return false . |
private static int |
ByteBufUtil.lastIndexOf(ByteBuf buffer,
int fromIndex,
int toIndex,
byte value) |
(package private) static PooledDuplicatedByteBuf |
PooledDuplicatedByteBuf.newInstance(AbstractByteBuf unwrapped,
ByteBuf wrapped,
int readerIndex,
int writerIndex) |
(package private) static PooledSlicedByteBuf |
PooledSlicedByteBuf.newInstance(AbstractByteBuf unwrapped,
ByteBuf wrapped,
int index,
int length) |
private static PooledSlicedByteBuf |
PooledSlicedByteBuf.newInstance0(AbstractByteBuf unwrapped,
ByteBuf wrapped,
int adjustment,
int length) |
private SimpleLeakAwareByteBuf |
SimpleLeakAwareCompositeByteBuf.newLeakAwareByteBuf(ByteBuf wrapped) |
protected AdvancedLeakAwareByteBuf |
AdvancedLeakAwareCompositeByteBuf.newLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
protected SimpleLeakAwareByteBuf |
SimpleLeakAwareByteBuf.newLeakAwareByteBuf(ByteBuf buf,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
protected AdvancedLeakAwareByteBuf |
AdvancedLeakAwareByteBuf.newLeakAwareByteBuf(ByteBuf buf,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
protected SimpleLeakAwareByteBuf |
SimpleLeakAwareCompositeByteBuf.newLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
private SimpleLeakAwareByteBuf |
SimpleLeakAwareByteBuf.newLeakAwareByteBuf(ByteBuf wrapped,
ResourceLeakTracker<ByteBuf> leakTracker) |
private SimpleLeakAwareByteBuf |
SimpleLeakAwareByteBuf.newSharedLeakAwareByteBuf(ByteBuf wrapped) |
(package private) void |
AbstractPooledDerivedByteBuf.parent(ByteBuf newParent) |
static java.lang.String |
ByteBufUtil.prettyHexDump(ByteBuf buffer)
Returns a multi-line hexadecimal dump of the specified
ByteBuf that is easy to read by humans. |
static java.lang.String |
ByteBufUtil.prettyHexDump(ByteBuf buffer,
int offset,
int length)
Returns a multi-line hexadecimal dump of the specified
ByteBuf that is easy to read by humans,
starting at the given offset using the given length . |
private static java.lang.String |
ByteBufUtil.HexUtil.prettyHexDump(ByteBuf buffer,
int offset,
int length) |
ByteBuf |
AbstractByteBuf.readBytes(ByteBuf dst) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
EmptyByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
WrappedByteBuf.readBytes(ByteBuf dst) |
CompositeByteBuf |
WrappedCompositeByteBuf.readBytes(ByteBuf dst) |
abstract ByteBuf |
ByteBuf.readBytes(ByteBuf dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex until the destination becomes
non-writable, and increases the readerIndex by the number of the
transferred bytes. |
CompositeByteBuf |
CompositeByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
SwappedByteBuf.readBytes(ByteBuf dst)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(ByteBuf dst) |
static ByteBuf |
ByteBufUtil.readBytes(ByteBufAllocator alloc,
ByteBuf buffer,
int length)
Read the given amount of bytes into a new
ByteBuf that is allocated from the ByteBufAllocator . |
ByteBuf |
AbstractByteBuf.readBytes(ByteBuf dst,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
EmptyByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
WrappedByteBuf.readBytes(ByteBuf dst,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.readBytes(ByteBuf dst,
int length) |
abstract ByteBuf |
ByteBuf.readBytes(ByteBuf dst,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length ). |
CompositeByteBuf |
CompositeByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
SwappedByteBuf.readBytes(ByteBuf dst,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
AbstractByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
EmptyByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
WrappedByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
abstract ByteBuf |
ByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length ). |
CompositeByteBuf |
CompositeByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
SwappedByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBufHolder |
ByteBufHolder.replace(ByteBuf content)
Returns a new
ByteBufHolder which contains the specified content . |
ByteBufHolder |
DefaultByteBufHolder.replace(ByteBuf content)
Returns a new
ByteBufHolder which contains the specified content . |
(package private) static void |
UnsafeByteBufUtil.setBytes(AbstractByteBuf buf,
long addr,
int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
AbstractByteBuf.setBytes(int index,
ByteBuf src) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
ByteBuf src) |
CompositeByteBuf |
WrappedCompositeByteBuf.setBytes(int index,
ByteBuf src) |
abstract ByteBuf |
ByteBuf.setBytes(int index,
ByteBuf src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the source buffer becomes
unreadable. |
CompositeByteBuf |
CompositeByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
SwappedByteBuf.setBytes(int index,
ByteBuf src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
AbstractByteBuf.setBytes(int index,
ByteBuf src,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
ByteBuf src,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.setBytes(int index,
ByteBuf src,
int length) |
abstract ByteBuf |
ByteBuf.setBytes(int index,
ByteBuf src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
CompositeByteBuf |
CompositeByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
SwappedByteBuf.setBytes(int index,
ByteBuf src,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
ByteBuf src,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
EmptyByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
PooledDuplicatedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
WrappedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
ReadOnlyByteBufferBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
AbstractUnpooledSlicedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
FixedCompositeByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
UnpooledDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
DuplicatedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
abstract ByteBuf |
ByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
ByteBuf |
PooledSlicedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
CompositeByteBuf |
CompositeByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
PooledUnsafeDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
SwappedByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
PooledDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
UnpooledUnsafeDirectByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
ReadOnlyByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
PooledHeapByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
UnpooledHeapByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
protected static ByteBuf |
AbstractByteBufAllocator.toLeakAwareBuffer(ByteBuf buf) |
static ByteBuf |
Unpooled.unmodifiableBuffer(ByteBuf... buffers)
|
static ByteBuf |
Unpooled.unmodifiableBuffer(ByteBuf buffer)
Deprecated.
Use
asReadOnly() . |
static ByteBuf |
Unpooled.unreleasableBuffer(ByteBuf buf)
Return a unreleasable view on the given
ByteBuf which will just ignore release and retain calls. |
private ByteBuf |
SimpleLeakAwareByteBuf.unwrappedDerived(ByteBuf derived) |
private static ByteBuf |
SimpleLeakAwareByteBuf.unwrapSwapped(ByteBuf buf) |
static ByteBuf |
Unpooled.wrappedBuffer(ByteBuf... buffers)
Creates a new big-endian composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ByteBuf |
Unpooled.wrappedBuffer(ByteBuf buffer)
Creates a new buffer which wraps the specified buffer's readable bytes.
|
static ByteBuf |
Unpooled.wrappedBuffer(int maxNumComponents,
ByteBuf... buffers)
Creates a new big-endian composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static int |
ByteBufUtil.writeAscii(ByteBuf buf,
java.lang.CharSequence seq)
|
ByteBuf |
AbstractByteBuf.writeBytes(ByteBuf src) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
EmptyByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
WrappedByteBuf.writeBytes(ByteBuf src) |
CompositeByteBuf |
WrappedCompositeByteBuf.writeBytes(ByteBuf src) |
abstract ByteBuf |
ByteBuf.writeBytes(ByteBuf src)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex until the source buffer becomes
unreadable, and increases the writerIndex by the number of
the transferred bytes. |
CompositeByteBuf |
CompositeByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
SwappedByteBuf.writeBytes(ByteBuf src)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
AbstractByteBuf.writeBytes(ByteBuf src,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
EmptyByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
WrappedByteBuf.writeBytes(ByteBuf src,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.writeBytes(ByteBuf src,
int length) |
abstract ByteBuf |
ByteBuf.writeBytes(ByteBuf src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length ). |
CompositeByteBuf |
CompositeByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
SwappedByteBuf.writeBytes(ByteBuf src,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
AbstractByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
EmptyByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
WrappedByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
CompositeByteBuf |
WrappedCompositeByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
abstract ByteBuf |
ByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length ). |
CompositeByteBuf |
CompositeByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
SwappedByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length)
Deprecated.
|
ByteBuf |
AdvancedLeakAwareByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
static int |
ByteBufUtil.writeUtf8(ByteBuf buf,
java.lang.CharSequence seq)
|
Modifier and Type | Method and Description |
---|---|
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponents(boolean increaseWriterIndex,
java.lang.Iterable<ByteBuf> buffers) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponents(boolean increaseWriterIndex,
java.lang.Iterable<ByteBuf> buffers) |
CompositeByteBuf |
CompositeByteBuf.addComponents(boolean increaseWriterIndex,
java.lang.Iterable<ByteBuf> buffers)
|
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponents(int cIndex,
java.lang.Iterable<ByteBuf> buffers) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponents(int cIndex,
java.lang.Iterable<ByteBuf> buffers) |
CompositeByteBuf |
CompositeByteBuf.addComponents(int cIndex,
java.lang.Iterable<ByteBuf> buffers)
Add the given
ByteBuf s on the specific index
Be aware that this method does not increase the writerIndex of the CompositeByteBuf . |
CompositeByteBuf |
AdvancedLeakAwareCompositeByteBuf.addComponents(java.lang.Iterable<ByteBuf> buffers) |
CompositeByteBuf |
WrappedCompositeByteBuf.addComponents(java.lang.Iterable<ByteBuf> buffers) |
CompositeByteBuf |
CompositeByteBuf.addComponents(java.lang.Iterable<ByteBuf> buffers)
Add the given
ByteBuf s. |
private int |
CompositeByteBuf.addComponents0(boolean increaseIndex,
int cIndex,
java.lang.Iterable<ByteBuf> buffers) |
protected AdvancedLeakAwareByteBuf |
AdvancedLeakAwareCompositeByteBuf.newLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
protected SimpleLeakAwareByteBuf |
SimpleLeakAwareByteBuf.newLeakAwareByteBuf(ByteBuf buf,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
protected AdvancedLeakAwareByteBuf |
AdvancedLeakAwareByteBuf.newLeakAwareByteBuf(ByteBuf buf,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
protected SimpleLeakAwareByteBuf |
SimpleLeakAwareCompositeByteBuf.newLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leakTracker) |
private SimpleLeakAwareByteBuf |
SimpleLeakAwareByteBuf.newLeakAwareByteBuf(ByteBuf wrapped,
ResourceLeakTracker<ByteBuf> leakTracker) |
(package private) static void |
AdvancedLeakAwareByteBuf.recordLeakNonRefCountingOperation(ResourceLeakTracker<ByteBuf> leak) |
Constructor and Description |
---|
AbstractUnpooledSlicedByteBuf(ByteBuf buffer,
int index,
int length) |
AdvancedLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leak) |
AdvancedLeakAwareByteBuf(ByteBuf buf,
ResourceLeakTracker<ByteBuf> leak) |
ByteBufInputStream(ByteBuf buffer)
Creates a new stream which reads data from the specified
buffer
starting at the current readerIndex and ending at the current
writerIndex . |
ByteBufInputStream(ByteBuf buffer,
boolean releaseOnClose)
Creates a new stream which reads data from the specified
buffer
starting at the current readerIndex and ending at the current
writerIndex . |
ByteBufInputStream(ByteBuf buffer,
int length)
Creates a new stream which reads data from the specified
buffer
starting at the current readerIndex and ending at
readerIndex + length . |
ByteBufInputStream(ByteBuf buffer,
int length,
boolean releaseOnClose)
Creates a new stream which reads data from the specified
buffer
starting at the current readerIndex and ending at
readerIndex + length . |
ByteBufOutputStream(ByteBuf buffer)
Creates a new stream which writes data to the specified
buffer . |
Component(ByteBuf buf) |
Component(int index,
int offset,
ByteBuf buf) |
CompositeByteBuf(ByteBufAllocator alloc,
boolean direct,
int maxNumComponents,
ByteBuf... buffers) |
CompositeByteBuf(ByteBufAllocator alloc,
boolean direct,
int maxNumComponents,
ByteBuf[] buffers,
int offset,
int len) |
DefaultByteBufHolder(ByteBuf data) |
DuplicatedByteBuf(ByteBuf buffer)
Deprecated.
|
DuplicatedByteBuf(ByteBuf buffer,
int readerIndex,
int writerIndex)
Deprecated.
|
FixedCompositeByteBuf(ByteBufAllocator allocator,
ByteBuf... buffers) |
ReadOnlyByteBuf(ByteBuf buffer)
Deprecated.
|
SimpleLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leak) |
SimpleLeakAwareByteBuf(ByteBuf wrapped,
ResourceLeakTracker<ByteBuf> leak) |
SlicedByteBuf(ByteBuf buffer,
int index,
int length)
Deprecated.
|
SwappedByteBuf(ByteBuf buf)
Deprecated.
|
UnreleasableByteBuf(ByteBuf buf) |
WrappedByteBuf(ByteBuf buf) |
Constructor and Description |
---|
AdvancedLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leak) |
AdvancedLeakAwareByteBuf(ByteBuf buf,
ResourceLeakTracker<ByteBuf> leak) |
AdvancedLeakAwareCompositeByteBuf(CompositeByteBuf wrapped,
ResourceLeakTracker<ByteBuf> leak) |
CompositeByteBuf(ByteBufAllocator alloc,
boolean direct,
int maxNumComponents,
java.lang.Iterable<ByteBuf> buffers) |
SimpleLeakAwareByteBuf(ByteBuf wrapped,
ByteBuf trackedByteBuf,
ResourceLeakTracker<ByteBuf> leak) |
SimpleLeakAwareByteBuf(ByteBuf wrapped,
ResourceLeakTracker<ByteBuf> leak) |
SimpleLeakAwareCompositeByteBuf(CompositeByteBuf wrapped,
ResourceLeakTracker<ByteBuf> leak) |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
RecvByteBufAllocator.Handle.allocate(ByteBufAllocator alloc)
Deprecated.
Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small
enough not to waste its space.
|
ByteBuf |
RecvByteBufAllocator.DelegatingHandle.allocate(ByteBufAllocator alloc) |
ByteBuf |
DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle.allocate(ByteBufAllocator alloc) |
ByteBuf |
DefaultMaxBytesRecvByteBufAllocator.HandleImpl.allocate(ByteBufAllocator alloc) |
private ByteBuf |
CoalescingBufferQueue.compose(ByteBuf current,
ByteBuf next)
Compose the current buffer with another.
|
ByteBuf |
CoalescingBufferQueue.remove(int bytes,
ChannelPromise aggregatePromise)
Remove a
ByteBuf from the queue with the specified number of bytes. |
Modifier and Type | Method and Description |
---|---|
void |
CoalescingBufferQueue.add(ByteBuf buf)
Add a buffer to the end of the queue.
|
void |
CoalescingBufferQueue.add(ByteBuf buf,
ChannelFutureListener listener)
Add a buffer to the end of the queue and associate a listener with it that should be completed when
all the buffers bytes have been consumed from the queue and written.
|
void |
CoalescingBufferQueue.add(ByteBuf buf,
ChannelPromise promise)
Add a buffer to the end of the queue and associate a promise with it that should be completed when
all the buffers bytes have been consumed from the queue and written.
|
private ByteBuf |
CoalescingBufferQueue.compose(ByteBuf current,
ByteBuf next)
Compose the current buffer with another.
|
Modifier and Type | Method and Description |
---|---|
ByteBuf |
EpollRecvByteAllocatorHandle.allocate(ByteBufAllocator alloc) |
protected ByteBuf |
AbstractEpollChannel.newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
AbstractEpollChannel.newDirectBuffer(java.lang.Object holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
private static ByteBuf |
AbstractEpollChannel.newDirectBuffer0(java.lang.Object holder,
ByteBuf buf,
ByteBufAllocator alloc,
int capacity) |
Modifier and Type | Method and Description |
---|---|
protected int |
AbstractEpollChannel.doReadBytes(ByteBuf byteBuf)
Read bytes into the given
ByteBuf and return the amount. |
protected int |
AbstractEpollChannel.doWriteBytes(ByteBuf buf,
int writeSpinCount) |
private void |
AbstractEpollStreamChannel.EpollStreamUnsafe.handleReadException(ChannelPipeline pipeline,
ByteBuf byteBuf,
java.lang.Throwable cause,
boolean close,
EpollRecvByteAllocatorHandle allocHandle) |
private boolean |
NativeDatagramPacketArray.NativeDatagramPacket.init(ByteBuf buf,
java.net.InetSocketAddress recipient)
Init this instance and return
true if the init was successful. |
protected ByteBuf |
AbstractEpollChannel.newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
AbstractEpollChannel.newDirectBuffer(java.lang.Object holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
private static ByteBuf |
AbstractEpollChannel.newDirectBuffer0(java.lang.Object holder,
ByteBuf buf,
ByteBufAllocator alloc,
int capacity) |
private boolean |
AbstractEpollStreamChannel.writeBytes(ChannelOutboundBuffer in,
ByteBuf buf,
int writeSpinCount)
Write bytes form the given
ByteBuf to the underlying Channel . |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
KQueueRecvByteAllocatorHandle.allocate(ByteBufAllocator alloc) |
protected ByteBuf |
AbstractKQueueChannel.newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
AbstractKQueueChannel.newDirectBuffer(java.lang.Object holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
private static ByteBuf |
AbstractKQueueChannel.newDirectBuffer0(java.lang.Object holder,
ByteBuf buf,
ByteBufAllocator alloc,
int capacity) |
Modifier and Type | Method and Description |
---|---|
protected int |
AbstractKQueueChannel.doReadBytes(ByteBuf byteBuf)
Read bytes into the given
ByteBuf and return the amount. |
protected int |
AbstractKQueueChannel.doWriteBytes(ByteBuf buf,
int writeSpinCount) |
private void |
AbstractKQueueStreamChannel.KQueueStreamUnsafe.handleReadException(ChannelPipeline pipeline,
ByteBuf byteBuf,
java.lang.Throwable cause,
boolean close,
KQueueRecvByteAllocatorHandle allocHandle) |
protected ByteBuf |
AbstractKQueueChannel.newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
AbstractKQueueChannel.newDirectBuffer(java.lang.Object holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
private static ByteBuf |
AbstractKQueueChannel.newDirectBuffer0(java.lang.Object holder,
ByteBuf buf,
ByteBufAllocator alloc,
int capacity) |
private boolean |
AbstractKQueueStreamChannel.writeBytes(ChannelOutboundBuffer in,
ByteBuf buf,
int writeSpinCount)
Write bytes form the given
ByteBuf to the underlying Channel . |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
PreferHeapByteBufAllocator.buffer() |
ByteBuf |
PreferHeapByteBufAllocator.buffer(int initialCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.buffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.directBuffer() |
ByteBuf |
PreferHeapByteBufAllocator.directBuffer(int initialCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.directBuffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.heapBuffer() |
ByteBuf |
PreferHeapByteBufAllocator.heapBuffer(int initialCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.heapBuffer(int initialCapacity,
int maxCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.ioBuffer() |
ByteBuf |
PreferHeapByteBufAllocator.ioBuffer(int initialCapacity) |
ByteBuf |
PreferHeapByteBufAllocator.ioBuffer(int initialCapacity,
int maxCapacity) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
AbstractNioChannel.newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
AbstractNioChannel.newDirectBuffer(ReferenceCounted holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
Modifier and Type | Method and Description |
---|---|
protected abstract int |
AbstractNioByteChannel.doReadBytes(ByteBuf buf)
Read bytes into the given
ByteBuf and return the amount. |
protected abstract int |
AbstractNioByteChannel.doWriteBytes(ByteBuf buf)
Write bytes form the given
ByteBuf to the underlying Channel . |
private void |
AbstractNioByteChannel.NioByteUnsafe.handleReadException(ChannelPipeline pipeline,
ByteBuf byteBuf,
java.lang.Throwable cause,
boolean close,
RecvByteBufAllocator.Handle allocHandle) |
protected ByteBuf |
AbstractNioChannel.newDirectBuffer(ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected ByteBuf |
AbstractNioChannel.newDirectBuffer(ReferenceCounted holder,
ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
Modifier and Type | Method and Description |
---|---|
protected int |
OioByteStreamChannel.doReadBytes(ByteBuf buf) |
protected abstract int |
AbstractOioByteChannel.doReadBytes(ByteBuf buf)
Read bytes from the underlying Socket.
|
protected void |
OioByteStreamChannel.doWriteBytes(ByteBuf buf) |
protected abstract void |
AbstractOioByteChannel.doWriteBytes(ByteBuf buf)
Write the data which is hold by the
ByteBuf to the underlying Socket. |
private void |
AbstractOioByteChannel.handleReadException(ChannelPipeline pipeline,
ByteBuf byteBuf,
java.lang.Throwable cause,
boolean close,
RecvByteBufAllocator.Handle allocHandle) |
Modifier and Type | Method and Description |
---|---|
SctpMessage |
SctpMessage.replace(ByteBuf content) |
Constructor and Description |
---|
SctpMessage(int protocolIdentifier,
int streamIdentifier,
boolean unordered,
ByteBuf payloadBuffer)
Essential data that is being carried within SCTP Data Chunk
|
SctpMessage(int protocolIdentifier,
int streamIdentifier,
ByteBuf payloadBuffer)
Essential data that is being carried within SCTP Data Chunk
|
SctpMessage(MessageInfo msgInfo,
ByteBuf payloadBuffer)
Essential data that is being carried within SCTP Data Chunk
|
Modifier and Type | Method and Description |
---|---|
DatagramPacket |
DatagramPacket.replace(ByteBuf content) |
Constructor and Description |
---|
DatagramPacket(ByteBuf data,
java.net.InetSocketAddress recipient)
Create a new instance with the specified packet
data and recipient address. |
DatagramPacket(ByteBuf data,
java.net.InetSocketAddress recipient,
java.net.InetSocketAddress sender)
Create a new instance with the specified packet
data , recipient address, and sender
address. |
Modifier and Type | Method and Description |
---|---|
protected int |
NioSocketChannel.doReadBytes(ByteBuf byteBuf) |
protected int |
NioSocketChannel.doWriteBytes(ByteBuf buf) |
private static boolean |
NioDatagramChannel.isSingleDirectBuffer(ByteBuf buf)
Checks if the specified buffer is a direct buffer and is composed of a single NIO buffer.
|
Modifier and Type | Method and Description |
---|---|
protected int |
OioSocketChannel.doReadBytes(ByteBuf buf) |
Modifier and Type | Method and Description |
---|---|
boolean |
IovArray.add(ByteBuf buf)
Try to add the given
ByteBuf . |
static boolean |
UnixChannelUtil.isBufferCopyNeededForWrite(ByteBuf byteBuf)
Checks if the specified buffer has memory address or is composed of n(n <= IOV_MAX) NIO direct buffers.
|
(package private) static boolean |
UnixChannelUtil.isBufferCopyNeededForWrite(ByteBuf byteBuf,
int iovMax) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
ReplayingDecoderByteBuf
Special
ByteBuf implementation which is used by the ReplayingDecoder |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
AsciiHeadersEncoder.buf |
private ByteBuf |
ReplayingDecoderByteBuf.buffer |
(package private) ByteBuf |
ByteToMessageDecoder.cumulation |
private ByteBuf[] |
DelimiterBasedFrameDecoder.delimiters |
Modifier and Type | Field and Description |
---|---|
private MessageToMessageDecoder<ByteBuf> |
DatagramPacketDecoder.decoder |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
ByteBuf |
ReplayingDecoderByteBuf.asReadOnly() |
ByteBuf |
ReplayingDecoderByteBuf.capacity(int newCapacity) |
ByteBuf |
ReplayingDecoderByteBuf.clear() |
ByteBuf |
ReplayingDecoderByteBuf.copy() |
ByteBuf |
ReplayingDecoderByteBuf.copy(int index,
int length) |
ByteBuf |
ByteToMessageDecoder.Cumulator.cumulate(ByteBufAllocator alloc,
ByteBuf cumulation,
ByteBuf in)
|
ByteBuf |
ReplayingDecoderByteBuf.discardReadBytes() |
ByteBuf |
ReplayingDecoderByteBuf.discardSomeReadBytes() |
ByteBuf |
ReplayingDecoderByteBuf.duplicate() |
ByteBuf |
ReplayingDecoderByteBuf.ensureWritable(int writableBytes) |
(package private) static ByteBuf |
ByteToMessageDecoder.expandCumulation(ByteBufAllocator alloc,
ByteBuf cumulation,
int readable) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
byte[] dst) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
java.nio.ByteBuffer dst) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
java.io.OutputStream out,
int length) |
protected ByteBuf |
ByteToMessageDecoder.internalBuffer()
Returns the internal cumulative buffer of this decoder.
|
static ByteBuf[] |
Delimiters.lineDelimiter()
Returns
CR ('\r') and LF ('\n') delimiters, which could
be used for text-based line protocols. |
ByteBuf |
ReplayingDecoderByteBuf.markReaderIndex() |
ByteBuf |
ReplayingDecoderByteBuf.markWriterIndex() |
static ByteBuf[] |
Delimiters.nulDelimiter()
Returns a
NUL (0x00) delimiter, which could be used for
Flash XML socket or any similar protocols. |
ByteBuf |
ReplayingDecoderByteBuf.order(java.nio.ByteOrder endianness) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(byte[] dst) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(byte[] dst,
int dstIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(java.nio.ByteBuffer dst) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(int length) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(java.io.OutputStream out,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.readerIndex(int readerIndex) |
ByteBuf |
ReplayingDecoderByteBuf.readRetainedSlice(int length) |
ByteBuf |
ReplayingDecoderByteBuf.readSlice(int length) |
ByteBuf |
ReplayingDecoderByteBuf.resetReaderIndex() |
ByteBuf |
ReplayingDecoderByteBuf.resetWriterIndex() |
ByteBuf |
ReplayingDecoderByteBuf.retain() |
ByteBuf |
ReplayingDecoderByteBuf.retain(int increment) |
ByteBuf |
ReplayingDecoderByteBuf.retainedDuplicate() |
ByteBuf |
ReplayingDecoderByteBuf.retainedSlice() |
ByteBuf |
ReplayingDecoderByteBuf.retainedSlice(int index,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.setBoolean(int index,
boolean value) |
ByteBuf |
ReplayingDecoderByteBuf.setByte(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
byte[] src) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
byte[] src,
int srcIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
java.nio.ByteBuffer src) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.setChar(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setDouble(int index,
double value) |
ByteBuf |
ReplayingDecoderByteBuf.setFloat(int index,
float value) |
ByteBuf |
ReplayingDecoderByteBuf.setIndex(int readerIndex,
int writerIndex) |
ByteBuf |
ReplayingDecoderByteBuf.setInt(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setIntLE(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setLong(int index,
long value) |
ByteBuf |
ReplayingDecoderByteBuf.setLongLE(int index,
long value) |
ByteBuf |
ReplayingDecoderByteBuf.setMedium(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setMediumLE(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setShort(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setShortLE(int index,
int value) |
ByteBuf |
ReplayingDecoderByteBuf.setZero(int index,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.skipBytes(int length) |
ByteBuf |
ReplayingDecoderByteBuf.slice() |
ByteBuf |
ReplayingDecoderByteBuf.slice(int index,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.touch() |
ByteBuf |
ReplayingDecoderByteBuf.touch(java.lang.Object hint) |
ByteBuf |
ReplayingDecoderByteBuf.unwrap() |
ByteBuf |
ReplayingDecoderByteBuf.writeBoolean(boolean value) |
ByteBuf |
ReplayingDecoderByteBuf.writeByte(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(byte[] src) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(byte[] src,
int srcIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(java.nio.ByteBuffer src) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.writeChar(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeDouble(double value) |
ByteBuf |
ReplayingDecoderByteBuf.writeFloat(float value) |
ByteBuf |
ReplayingDecoderByteBuf.writeInt(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeIntLE(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeLong(long value) |
ByteBuf |
ReplayingDecoderByteBuf.writeLongLE(long value) |
ByteBuf |
ReplayingDecoderByteBuf.writeMedium(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeMediumLE(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writerIndex(int writerIndex) |
ByteBuf |
ReplayingDecoderByteBuf.writeShort(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeShortLE(int value) |
ByteBuf |
ReplayingDecoderByteBuf.writeZero(int length) |
Modifier and Type | Method and Description |
---|---|
private static void |
MessageAggregator.appendPartialContent(CompositeByteBuf content,
ByteBuf partialContent) |
protected abstract O |
MessageAggregator.beginAggregation(S start,
ByteBuf content)
Creates a new aggregated message from the specified start message and the specified content.
|
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called once data should be decoded from the given
ByteBuf . |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
int |
ReplayingDecoderByteBuf.compareTo(ByteBuf buffer) |
ByteBuf |
ByteToMessageDecoder.Cumulator.cumulate(ByteBufAllocator alloc,
ByteBuf cumulation,
ByteBuf in)
|
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
(package private) void |
ByteToMessageDecoder.decodeRemovalReentryProtection(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected void |
ByteToMessageCodec.Encoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
(package private) static ByteBuf |
ByteToMessageDecoder.expandCumulation(ByteBufAllocator alloc,
ByteBuf cumulation,
int readable) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
private static int |
LineBasedFrameDecoder.findEndOfLine(ByteBuf buffer)
Returns the index in the buffer of the end of line found.
|
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
ByteBuf dst) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
ByteBuf dst,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.getBytes(int index,
ByteBuf dst,
int dstIndex,
int length) |
protected long |
LengthFieldBasedFrameDecoder.getUnadjustedFrameLength(ByteBuf buf,
int offset,
int length,
java.nio.ByteOrder order)
Decodes the specified region of the buffer into an unadjusted frame length.
|
private static int |
DelimiterBasedFrameDecoder.indexOf(ByteBuf haystack,
ByteBuf needle)
Returns the number of bytes between the readerIndex of the haystack and
the first needle found in the haystack.
|
private static boolean |
DelimiterBasedFrameDecoder.isLineBased(ByteBuf[] delimiters)
Returns true if the delimiters are "\n" and "\r\n".
|
ByteBuf |
ReplayingDecoderByteBuf.readBytes(ByteBuf dst) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(ByteBuf dst,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.readBytes(ByteBuf dst,
int dstIndex,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
ByteBuf src) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
ByteBuf src,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.setBytes(int index,
ByteBuf src,
int srcIndex,
int length) |
(package private) void |
ReplayingDecoderByteBuf.setCumulation(ByteBuf buffer) |
private static void |
DelimiterBasedFrameDecoder.validateDelimiter(ByteBuf delimiter) |
private static void |
AsciiHeadersEncoder.writeAscii(ByteBuf buf,
int offset,
java.lang.CharSequence value) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(ByteBuf src) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(ByteBuf src,
int length) |
ByteBuf |
ReplayingDecoderByteBuf.writeBytes(ByteBuf src,
int srcIndex,
int length) |
Constructor and Description |
---|
AsciiHeadersEncoder(ByteBuf buf) |
AsciiHeadersEncoder(ByteBuf buf,
AsciiHeadersEncoder.SeparatorType separatorType,
AsciiHeadersEncoder.NewlineType newlineType) |
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
boolean failFast,
ByteBuf... delimiters)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
boolean failFast,
ByteBuf delimiter)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
ByteBuf... delimiters)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
ByteBuf delimiter)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
ByteBuf... delimiters)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
ByteBuf delimiter)
Creates a new instance.
|
ReplayingDecoderByteBuf(ByteBuf buffer) |
Constructor and Description |
---|
DatagramPacketDecoder(MessageToMessageDecoder<ByteBuf> decoder)
Create a
DatagramPacket decoder using the specified ByteBuf decoder. |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
Base64.Decoder.dest |
Modifier and Type | Method and Description |
---|---|
static ByteBuf |
Base64.decode(ByteBuf src) |
static ByteBuf |
Base64.decode(ByteBuf src,
Base64Dialect dialect) |
static ByteBuf |
Base64.decode(ByteBuf src,
int off,
int len) |
static ByteBuf |
Base64.decode(ByteBuf src,
int off,
int len,
Base64Dialect dialect) |
static ByteBuf |
Base64.decode(ByteBuf src,
int off,
int len,
Base64Dialect dialect,
ByteBufAllocator allocator) |
(package private) ByteBuf |
Base64.Decoder.decode(ByteBuf src,
int off,
int len,
ByteBufAllocator allocator,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src) |
static ByteBuf |
Base64.encode(ByteBuf src,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
boolean breakLines) |
static ByteBuf |
Base64.encode(ByteBuf src,
boolean breakLines,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
boolean breakLines) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect,
ByteBufAllocator allocator) |
Modifier and Type | Method and Description |
---|---|
static ByteBuf |
Base64.decode(ByteBuf src) |
static ByteBuf |
Base64.decode(ByteBuf src,
Base64Dialect dialect) |
static ByteBuf |
Base64.decode(ByteBuf src,
int off,
int len) |
static ByteBuf |
Base64.decode(ByteBuf src,
int off,
int len,
Base64Dialect dialect) |
static ByteBuf |
Base64.decode(ByteBuf src,
int off,
int len,
Base64Dialect dialect,
ByteBufAllocator allocator) |
(package private) ByteBuf |
Base64.Decoder.decode(ByteBuf src,
int off,
int len,
ByteBufAllocator allocator,
Base64Dialect dialect) |
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
private static int |
Base64.Decoder.decode4to3(byte[] src,
ByteBuf dest,
int destOffset,
byte[] decodabet) |
static ByteBuf |
Base64.encode(ByteBuf src) |
static ByteBuf |
Base64.encode(ByteBuf src,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
boolean breakLines) |
static ByteBuf |
Base64.encode(ByteBuf src,
boolean breakLines,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
boolean breakLines) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect) |
static ByteBuf |
Base64.encode(ByteBuf src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect,
ByteBufAllocator allocator) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
private static void |
Base64.encode3to4(ByteBuf src,
int srcOffset,
int numSigBytes,
ByteBuf dest,
int destOffset,
byte[] alphabet) |
private static void |
Base64.encode3to4BigEndian(int inBuff,
int numSigBytes,
ByteBuf dest,
int destOffset,
byte[] alphabet) |
private static void |
Base64.encode3to4LittleEndian(int inBuff,
int numSigBytes,
ByteBuf dest,
int destOffset,
byte[] alphabet) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
Bzip2BitReader.in
The
ByteBuf from which to read data. |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
private static void |
SnappyFrameEncoder.calculateAndWriteChecksum(ByteBuf slice,
ByteBuf out)
Calculates and writes the 4-byte checksum to the output buffer
|
(package private) static int |
Snappy.calculateChecksum(ByteBuf data)
Computes the CRC32C checksum of the supplied data and performs the "mask" operation
on the computed checksum
|
(package private) static int |
Snappy.calculateChecksum(ByteBuf data,
int offset,
int length)
Computes the CRC32C checksum of the supplied data and performs the "mask" operation
on the computed checksum
|
(package private) static void |
CompressionUtil.checkChecksum(ByteBufChecksum checksum,
ByteBuf uncompressed,
int currentChecksum) |
(package private) void |
Bzip2BlockCompressor.close(ByteBuf out)
Compresses and writes out the block.
|
private void |
Bzip2Encoder.closeBlock(ByteBuf out)
Close current block and update
Bzip2Encoder.streamCRC . |
void |
Snappy.decode(ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private static int |
Snappy.decodeCopyWith1ByteOffset(byte tag,
ByteBuf in,
ByteBuf out,
int writtenSoFar)
Reads a compressed reference offset and length from the supplied input
buffer, seeks back to the appropriate place in the input buffer and
writes the found data to the supplied output stream.
|
private static int |
Snappy.decodeCopyWith2ByteOffset(byte tag,
ByteBuf in,
ByteBuf out,
int writtenSoFar)
Reads a compressed reference offset and length from the supplied input
buffer, seeks back to the appropriate place in the input buffer and
writes the found data to the supplied output stream.
|
private static int |
Snappy.decodeCopyWith4ByteOffset(byte tag,
ByteBuf in,
ByteBuf out,
int writtenSoFar)
Reads a compressed reference offset and length from the supplied input
buffer, seeks back to the appropriate place in the input buffer and
writes the found data to the supplied output stream.
|
(package private) static int |
Snappy.decodeLiteral(byte tag,
ByteBuf in,
ByteBuf out)
Reads a literal from the input buffer directly to the output buffer.
|
private void |
JdkZlibEncoder.deflate(ByteBuf out) |
(package private) void |
Bzip2HuffmanStageEncoder.encode(ByteBuf out)
Encodes and writes the block data.
|
void |
Snappy.encode(ByteBuf in,
ByteBuf out,
int length) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
private static void |
Snappy.encodeCopy(ByteBuf out,
int offset,
int length)
Encodes a series of copies, each at most 64 bytes in length.
|
private static void |
Snappy.encodeCopyWithOffset(ByteBuf out,
int offset,
int length) |
(package private) static void |
Snappy.encodeLiteral(ByteBuf in,
ByteBuf out,
int length)
Writes a literal to the supplied output buffer by directly copying from
the input buffer.
|
private static int |
Snappy.findMatchingLength(ByteBuf in,
int minIndex,
int inIndex,
int maxIndex)
Iterates over the supplied input buffer between the supplied minIndex and
maxIndex to find how long our matched copy overlaps with an already-written
literal value.
|
(package private) void |
Bzip2BitWriter.flush(ByteBuf out)
Writes any remaining bits to the output
ByteBuf ,
zero padding to a whole byte as required. |
private static int |
Snappy.hash(ByteBuf in,
int index,
int shift)
Hashes the 4 bytes located at index, shifting the resulting hash into
the appropriate range for our hash table.
|
private boolean |
JdkZlibDecoder.readGZIPFooter(ByteBuf buf) |
private boolean |
JdkZlibDecoder.readGZIPHeader(ByteBuf in) |
private static int |
Snappy.readPreamble(ByteBuf in)
Reads the length varint (a series of bytes, where the lower 7 bits
are data and the upper bit is a flag to indicate more bytes to be
read).
|
(package private) static java.nio.ByteBuffer |
CompressionUtil.safeNioBuffer(ByteBuf buffer) |
(package private) void |
Bzip2BitReader.setByteBuf(ByteBuf in)
Set the
ByteBuf from which to read data. |
private static void |
SnappyFrameEncoder.setChunkLength(ByteBuf out,
int lengthIdx) |
void |
ByteBufChecksum.update(ByteBuf b,
int off,
int len) |
void |
ByteBufChecksum.ReflectiveByteBufChecksum.update(ByteBuf b,
int off,
int len) |
(package private) static void |
Snappy.validateChecksum(int expectedChecksum,
ByteBuf data)
Computes the CRC32C checksum of the supplied data, performs the "mask" operation
on the computed checksum, and then compares the resulting masked checksum to the
supplied checksum.
|
(package private) static void |
Snappy.validateChecksum(int expectedChecksum,
ByteBuf data,
int offset,
int length)
Computes the CRC32C checksum of the supplied data, performs the "mask" operation
on the computed checksum, and then compares the resulting masked checksum to the
supplied checksum.
|
private void |
JdkZlibDecoder.verifyCrc(ByteBuf in) |
(package private) int |
Bzip2BlockCompressor.write(ByteBuf buffer,
int offset,
int length)
Writes an array to the block.
|
(package private) void |
Bzip2BitWriter.writeBits(ByteBuf out,
int count,
long value)
Writes up to 32 bits to the output
ByteBuf . |
private void |
Bzip2HuffmanStageEncoder.writeBlockData(ByteBuf out)
Writes out the encoded block data.
|
(package private) void |
Bzip2BitWriter.writeBoolean(ByteBuf out,
boolean value)
Writes a single bit to the output
ByteBuf . |
private static void |
SnappyFrameEncoder.writeChunkLength(ByteBuf out,
int chunkLength)
Writes the 2-byte chunk length to the output buffer.
|
(package private) void |
Bzip2BitWriter.writeInt(ByteBuf out,
int value)
Writes an integer as 32 bits to the output
ByteBuf . |
private void |
Bzip2HuffmanStageEncoder.writeSelectorsAndHuffmanTables(ByteBuf out)
Write out the selector list and Huffman tables.
|
private void |
Bzip2BlockCompressor.writeSymbolMap(ByteBuf out)
Write the Huffman symbol to output byte map.
|
(package private) void |
Bzip2BitWriter.writeUnary(ByteBuf out,
int value)
Writes a zero-terminated unary number to the output
ByteBuf . |
private static void |
SnappyFrameEncoder.writeUnencodedChunk(ByteBuf in,
ByteBuf out,
int dataLength) |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
DefaultDnsRawRecord.content |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
ByteBuf |
DefaultDnsRawRecord.content() |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
DefaultDnsRecordDecoder.decodeName(ByteBuf in)
Retrieves a domain name given a buffer containing a DNS packet.
|
protected java.lang.String |
DefaultDnsRecordDecoder.decodeName0(ByteBuf in)
Retrieves a domain name given a buffer containing a DNS packet.
|
DnsQuestion |
DnsRecordDecoder.decodeQuestion(ByteBuf in)
Decodes a DNS question into its object representation.
|
DnsQuestion |
DefaultDnsRecordDecoder.decodeQuestion(ByteBuf in) |
private void |
DatagramDnsQueryDecoder.decodeQuestions(DnsQuery query,
ByteBuf buf,
int questionCount) |
private void |
DatagramDnsResponseDecoder.decodeQuestions(DnsResponse response,
ByteBuf buf,
int questionCount) |
<T extends DnsRecord> |
DnsRecordDecoder.decodeRecord(ByteBuf in)
Decodes a DNS record into its object representation.
|
<T extends DnsRecord> |
DefaultDnsRecordDecoder.decodeRecord(ByteBuf in) |
protected DnsRecord |
DefaultDnsRecordDecoder.decodeRecord(java.lang.String name,
DnsRecordType type,
int dnsClass,
long timeToLive,
ByteBuf in,
int offset,
int length)
Decodes a record from the information decoded so far by
DefaultDnsRecordDecoder.decodeRecord(ByteBuf) . |
private void |
DatagramDnsQueryDecoder.decodeRecords(DnsQuery query,
DnsSection section,
ByteBuf buf,
int count) |
private void |
DatagramDnsResponseDecoder.decodeRecords(DnsResponse response,
DnsSection section,
ByteBuf buf,
int count) |
private static void |
DatagramDnsQueryEncoder.encodeHeader(DnsQuery query,
ByteBuf buf)
Encodes the header that is always 12 bytes long.
|
private static void |
DatagramDnsResponseEncoder.encodeHeader(DnsResponse response,
ByteBuf buf)
Encodes the header that is always 12 bytes long.
|
protected void |
DefaultDnsRecordEncoder.encodeName(java.lang.String name,
ByteBuf buf) |
private void |
DefaultDnsRecordEncoder.encodeOptEcsRecord(DnsOptEcsRecord record,
ByteBuf out) |
private void |
DefaultDnsRecordEncoder.encodeOptPseudoRecord(DnsOptPseudoRecord record,
ByteBuf out) |
private void |
DefaultDnsRecordEncoder.encodePtrRecord(DnsPtrRecord record,
ByteBuf out) |
void |
DefaultDnsRecordEncoder.encodeQuestion(DnsQuestion question,
ByteBuf out) |
void |
DnsRecordEncoder.encodeQuestion(DnsQuestion question,
ByteBuf out)
Encodes a
DnsQuestion . |
private void |
DatagramDnsQueryEncoder.encodeQuestions(DnsQuery query,
ByteBuf buf) |
private void |
DatagramDnsResponseEncoder.encodeQuestions(DnsResponse response,
ByteBuf buf) |
private void |
DefaultDnsRecordEncoder.encodeRawRecord(DnsRawRecord record,
ByteBuf out) |
void |
DefaultDnsRecordEncoder.encodeRecord(DnsRecord record,
ByteBuf out) |
void |
DnsRecordEncoder.encodeRecord(DnsRecord record,
ByteBuf out)
Encodes a
DnsRecord . |
private void |
DefaultDnsRecordEncoder.encodeRecord0(DnsRecord record,
ByteBuf out) |
private void |
DatagramDnsQueryEncoder.encodeRecords(DnsQuery query,
DnsSection section,
ByteBuf buf) |
private void |
DatagramDnsResponseEncoder.encodeRecords(DnsResponse response,
DnsSection section,
ByteBuf buf) |
private static DnsQuery |
DatagramDnsQueryDecoder.newQuery(DatagramPacket packet,
ByteBuf buf) |
private static DnsResponse |
DatagramDnsResponseDecoder.newResponse(DatagramPacket packet,
ByteBuf buf) |
DnsRawRecord |
DefaultDnsRawRecord.replace(ByteBuf content) |
DnsRawRecord |
DnsRawRecord.replace(ByteBuf content) |
Constructor and Description |
---|
DefaultDnsRawRecord(java.lang.String name,
DnsRecordType type,
int dnsClass,
long timeToLive,
ByteBuf content)
Creates a new record.
|
DefaultDnsRawRecord(java.lang.String name,
DnsRecordType type,
long timeToLive,
ByteBuf content)
Creates a new
IN-class record. |
Modifier and Type | Method and Description |
---|---|
private ByteBuf |
HAProxyMessageDecoder.decodeLine(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
private ByteBuf |
HAProxyMessageDecoder.decodeStruct(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
Modifier and Type | Method and Description |
---|---|
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
(package private) static HAProxyMessage |
HAProxyMessage.decodeHeader(ByteBuf header)
Decodes a version 2, binary proxy protocol header.
|
private ByteBuf |
HAProxyMessageDecoder.decodeLine(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
private ByteBuf |
HAProxyMessageDecoder.decodeStruct(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
static ProtocolDetectionResult<HAProxyProtocolVersion> |
HAProxyMessageDecoder.detectProtocol(ByteBuf buffer)
Returns the
ProtocolDetectionResult for the given ByteBuf . |
private static int |
HAProxyMessageDecoder.findEndOfHeader(ByteBuf buffer)
Returns the index in the buffer of the end of header if found.
|
private static int |
HAProxyMessageDecoder.findEndOfLine(ByteBuf buffer)
Returns the index in the buffer of the end of line found.
|
private static int |
HAProxyMessageDecoder.findVersion(ByteBuf buffer)
Returns the proxy protocol specification version in the buffer if the version is found.
|
private static java.lang.String |
HAProxyMessage.ipBytesToString(ByteBuf header,
int addressLen)
Convert ip address bytes to string representation
|
private static boolean |
HAProxyMessageDecoder.match(byte[] prefix,
ByteBuf buffer,
int idx) |
private static HAProxyTLV |
HAProxyMessage.readNextTLV(ByteBuf header) |
private static java.util.List<HAProxyTLV> |
HAProxyMessage.readTlvs(ByteBuf header) |
HAProxyTLV |
HAProxyTLV.replace(ByteBuf content) |
Constructor and Description |
---|
HAProxySSLTLV(int verify,
byte clientBitField,
java.util.List<HAProxyTLV> tlvs,
ByteBuf rawContent)
Creates a new HAProxySSLTLV
|
HAProxyTLV(HAProxyTLV.Type type,
byte typeByteValue,
ByteBuf content)
Creates a new HAProxyTLV
|
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
DefaultFullHttpResponse.content |
private ByteBuf |
HttpObjectAggregator.AggregatedFullHttpMessage.content |
private ByteBuf |
DefaultFullHttpRequest.content |
private ByteBuf |
DefaultHttpContent.content |
private static ByteBuf |
HttpObjectEncoder.CRLF_BUF |
private static ByteBuf |
HttpObjectEncoder.ZERO_CRLF_CRLF_BUF |
Modifier and Type | Field and Description |
---|---|
private ChunkedInput<ByteBuf> |
HttpChunkedInput.input |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
DefaultFullHttpResponse.content() |
ByteBuf |
ComposedLastHttpContent.content() |
ByteBuf |
HttpObjectAggregator.AggregatedFullHttpMessage.content() |
ByteBuf |
DefaultFullHttpRequest.content() |
ByteBuf |
DefaultHttpContent.content() |
Modifier and Type | Method and Description |
---|---|
protected FullHttpMessage |
HttpObjectAggregator.beginAggregation(HttpMessage start,
ByteBuf content) |
private void |
HttpContentDecoder.decode(ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpServerCodec.HttpServerRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpClientCodec.Decoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
(package private) void |
HttpVersion.encode(ByteBuf buf) |
(package private) void |
HttpResponseStatus.encode(ByteBuf buf) |
private void |
HttpContentEncoder.encode(ByteBuf in,
java.util.List<java.lang.Object> out) |
static void |
HttpHeaders.encodeAscii(java.lang.CharSequence seq,
ByteBuf buf)
Deprecated.
|
protected static void |
HttpObjectEncoder.encodeAscii(java.lang.String s,
ByteBuf buf)
Deprecated.
|
protected void |
HttpObjectEncoder.encodeHeaders(HttpHeaders headers,
ByteBuf buf)
Encode the
HttpHeaders into a ByteBuf . |
protected abstract void |
HttpObjectEncoder.encodeInitialLine(ByteBuf buf,
H message) |
protected void |
HttpRequestEncoder.encodeInitialLine(ByteBuf buf,
HttpRequest request) |
protected void |
HttpResponseEncoder.encodeInitialLine(ByteBuf buf,
HttpResponse response) |
(package private) static void |
HttpHeadersEncoder.encoderHeader(java.lang.CharSequence name,
java.lang.CharSequence value,
ByteBuf buf) |
private HttpContent |
HttpObjectDecoder.invalidChunk(ByteBuf in,
java.lang.Exception cause) |
private HttpMessage |
HttpObjectDecoder.invalidMessage(ByteBuf in,
java.lang.Exception cause) |
AppendableCharSequence |
HttpObjectDecoder.HeaderParser.parse(ByteBuf buffer) |
AppendableCharSequence |
HttpObjectDecoder.LineParser.parse(ByteBuf buffer) |
private HttpObjectDecoder.State |
HttpObjectDecoder.readHeaders(ByteBuf buffer) |
private LastHttpContent |
HttpObjectDecoder.readTrailingHeaders(ByteBuf buffer) |
HttpContent |
HttpContent.replace(ByteBuf content) |
FullHttpResponse |
DefaultFullHttpResponse.replace(ByteBuf content) |
LastHttpContent |
DefaultLastHttpContent.replace(ByteBuf content) |
LastHttpContent |
LastHttpContent.replace(ByteBuf content) |
FullHttpMessage |
FullHttpMessage.replace(ByteBuf content) |
LastHttpContent |
ComposedLastHttpContent.replace(ByteBuf content) |
FullHttpRequest |
FullHttpRequest.replace(ByteBuf content) |
FullHttpResponse |
FullHttpResponse.replace(ByteBuf content) |
FullHttpRequest |
HttpObjectAggregator.AggregatedFullHttpRequest.replace(ByteBuf content) |
FullHttpResponse |
HttpObjectAggregator.AggregatedFullHttpResponse.replace(ByteBuf content) |
FullHttpRequest |
DefaultFullHttpRequest.replace(ByteBuf content) |
HttpContent |
DefaultHttpContent.replace(ByteBuf content) |
private static boolean |
HttpObjectDecoder.skipControlCharacters(ByteBuf buffer) |
private static void |
HttpHeadersEncoder.writeAscii(ByteBuf buf,
int offset,
java.lang.CharSequence value) |
Constructor and Description |
---|
AggregatedFullHttpMessage(HttpMessage message,
ByteBuf content,
HttpHeaders trailingHeaders) |
AggregatedFullHttpRequest(HttpRequest request,
ByteBuf content,
HttpHeaders trailingHeaders) |
AggregatedFullHttpResponse(HttpResponse message,
ByteBuf content,
HttpHeaders trailingHeaders) |
DefaultFullHttpRequest(HttpVersion httpVersion,
HttpMethod method,
java.lang.String uri,
ByteBuf content) |
DefaultFullHttpRequest(HttpVersion httpVersion,
HttpMethod method,
java.lang.String uri,
ByteBuf content,
boolean validateHeaders) |
DefaultFullHttpRequest(HttpVersion httpVersion,
HttpMethod method,
java.lang.String uri,
ByteBuf content,
HttpHeaders headers,
HttpHeaders trailingHeader) |
DefaultFullHttpResponse(HttpVersion version,
HttpResponseStatus status,
ByteBuf content) |
DefaultFullHttpResponse(HttpVersion version,
HttpResponseStatus status,
ByteBuf content,
boolean validateHeaders) |
DefaultFullHttpResponse(HttpVersion version,
HttpResponseStatus status,
ByteBuf content,
boolean validateHeaders,
boolean singleFieldHeaders) |
DefaultFullHttpResponse(HttpVersion version,
HttpResponseStatus status,
ByteBuf content,
HttpHeaders headers,
HttpHeaders trailingHeaders) |
DefaultHttpContent(ByteBuf content)
Creates a new instance with the specified chunk content.
|
DefaultLastHttpContent(ByteBuf content) |
DefaultLastHttpContent(ByteBuf content,
boolean validateHeaders) |
Constructor and Description |
---|
HttpChunkedInput(ChunkedInput<ByteBuf> input)
Creates a new instance using the specified input.
|
HttpChunkedInput(ChunkedInput<ByteBuf> input,
LastHttpContent lastHttpContent)
Creates a new instance using the specified input.
|
Modifier and Type | Field and Description |
---|---|
(package private) ByteBuf |
HttpPostBodyUtil.SeekAheadOptimize.buffer |
private ByteBuf |
AbstractMemoryHttpData.byteBuf |
private ByteBuf |
HttpPostRequestEncoder.currentBuffer
The ByteBuf currently used by the encoder
|
private ByteBuf |
HttpPostMultipartRequestDecoder.undecodedChunk
The current channelBuffer
|
private ByteBuf |
HttpPostStandardRequestDecoder.undecodedChunk
The current channelBuffer
|
Modifier and Type | Field and Description |
---|---|
private java.util.List<ByteBuf> |
InternalAttribute.value |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
AbstractHttpData.content() |
ByteBuf |
MixedAttribute.content() |
ByteBuf |
MixedFileUpload.content() |
ByteBuf |
HttpPostRequestEncoder.WrappedFullHttpRequest.content() |
private ByteBuf |
HttpPostRequestEncoder.fillByteBuf() |
ByteBuf |
AbstractMemoryHttpData.getByteBuf()
Utility to go from a In Memory FileUpload
to a Disk (or another implementation) FileUpload
|
ByteBuf |
AbstractDiskHttpData.getByteBuf() |
ByteBuf |
MixedAttribute.getByteBuf() |
ByteBuf |
HttpData.getByteBuf()
Returns the content of the file item as a ByteBuf
|
ByteBuf |
MixedFileUpload.getByteBuf() |
ByteBuf |
AbstractMemoryHttpData.getChunk(int length) |
ByteBuf |
AbstractDiskHttpData.getChunk(int length) |
ByteBuf |
MixedAttribute.getChunk(int length) |
ByteBuf |
HttpData.getChunk(int length)
Returns a ChannelBuffer for the content from the current position with at
most length read bytes, increasing the current position of the Bytes
read.
|
ByteBuf |
MixedFileUpload.getChunk(int length) |
ByteBuf |
InternalAttribute.toByteBuf() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMemoryHttpData.addContent(ByteBuf buffer,
boolean last) |
void |
AbstractDiskHttpData.addContent(ByteBuf buffer,
boolean last) |
void |
MixedAttribute.addContent(ByteBuf buffer,
boolean last) |
void |
HttpData.addContent(ByteBuf buffer,
boolean last)
Add the content from the ChannelBuffer
|
void |
MixedFileUpload.addContent(ByteBuf buffer,
boolean last) |
void |
DiskAttribute.addContent(ByteBuf buffer,
boolean last) |
void |
MemoryAttribute.addContent(ByteBuf buffer,
boolean last) |
private static void |
HttpPostMultipartRequestDecoder.loadFieldMultipart(ByteBuf undecodedChunk,
java.lang.String delimiter,
Attribute currentAttribute)
Load the field value from a Multipart request
|
private static void |
HttpPostMultipartRequestDecoder.loadFieldMultipartStandard(ByteBuf undecodedChunk,
java.lang.String delimiter,
Attribute currentAttribute)
Load the field value from a Multipart request
|
private static java.lang.String |
HttpPostMultipartRequestDecoder.readDelimiter(ByteBuf undecodedChunk,
java.lang.String delimiter)
Read one line up to --delimiter or --delimiter-- and if existing the CRLF
or LF.
|
private static java.lang.String |
HttpPostMultipartRequestDecoder.readDelimiterStandard(ByteBuf undecodedChunk,
java.lang.String delimiter)
Read one line up to --delimiter or --delimiter-- and if existing the CRLF
or LF Read one line up to --delimiter or --delimiter-- and if existing
the CRLF or LF.
|
private static void |
HttpPostMultipartRequestDecoder.readFileUploadByteMultipart(ByteBuf undecodedChunk,
java.lang.String delimiter,
FileUpload currentFileUpload)
Read a FileUpload data as Byte (Binary) and add the bytes directly to the
FileUpload.
|
private static void |
HttpPostMultipartRequestDecoder.readFileUploadByteMultipartStandard(ByteBuf undecodedChunk,
java.lang.String delimiter,
FileUpload currentFileUpload)
Read a FileUpload data as Byte (Binary) and add the bytes directly to the
FileUpload.
|
private static java.lang.String |
HttpPostMultipartRequestDecoder.readLine(ByteBuf undecodedChunk,
java.nio.charset.Charset charset)
Read one line up to the CRLF or LF
|
private static java.lang.String |
HttpPostMultipartRequestDecoder.readLineStandard(ByteBuf undecodedChunk,
java.nio.charset.Charset charset)
Read one line up to the CRLF or LF
|
FileUpload |
MemoryFileUpload.replace(ByteBuf content) |
Attribute |
Attribute.replace(ByteBuf content) |
Attribute |
MixedAttribute.replace(ByteBuf content) |
HttpData |
HttpData.replace(ByteBuf content) |
FileUpload |
MixedFileUpload.replace(ByteBuf content) |
FileUpload |
DiskFileUpload.replace(ByteBuf content) |
FileUpload |
FileUpload.replace(ByteBuf content) |
Attribute |
DiskAttribute.replace(ByteBuf content) |
Attribute |
MemoryAttribute.replace(ByteBuf content) |
FullHttpRequest |
HttpPostRequestEncoder.WrappedFullHttpRequest.replace(ByteBuf content) |
void |
AbstractMemoryHttpData.setContent(ByteBuf buffer) |
void |
AbstractDiskHttpData.setContent(ByteBuf buffer) |
void |
MixedAttribute.setContent(ByteBuf buffer) |
void |
HttpData.setContent(ByteBuf buffer)
Set the content from the ChannelBuffer (erase any previous data)
|
void |
MixedFileUpload.setContent(ByteBuf buffer) |
private void |
HttpPostStandardRequestDecoder.setFinalBuffer(ByteBuf buffer) |
private static void |
HttpPostMultipartRequestDecoder.skipControlCharacters(ByteBuf undecodedChunk)
Skip control Characters
|
private static void |
HttpPostMultipartRequestDecoder.skipControlCharactersStandard(ByteBuf undecodedChunk) |
Constructor and Description |
---|
SeekAheadOptimize(ByteBuf buffer) |
Modifier and Type | Field and Description |
---|---|
private static ByteBuf |
WebSocket00FrameEncoder._0X00 |
private static ByteBuf |
WebSocket00FrameEncoder._0XFF |
private static ByteBuf |
WebSocket00FrameEncoder._0XFF_0X00 |
private ByteBuf |
WebSocketClientHandshaker00.expectedChallengeResponseBytes |
Modifier and Type | Field and Description |
---|---|
private ChunkedInput<ByteBuf> |
WebSocketChunkedInput.input |
Modifier and Type | Method and Description |
---|---|
private static ByteBuf |
TextWebSocketFrame.fromText(java.lang.String text) |
private static ByteBuf |
ContinuationWebSocketFrame.fromText(java.lang.String text)
Sets the string for this frame
|
private static ByteBuf |
CloseWebSocketFrame.newBinaryData(int statusCode,
java.lang.String reasonText) |
Modifier and Type | Method and Description |
---|---|
protected WebSocketFrame |
WebSocketFrameAggregator.beginAggregation(WebSocketFrame start,
ByteBuf content) |
void |
Utf8Validator.check(ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
private void |
Utf8FrameValidator.checkUTF8String(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeBinaryFrame(ChannelHandlerContext ctx,
byte type,
ByteBuf buffer) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeTextFrame(ChannelHandlerContext ctx,
ByteBuf buffer) |
TextWebSocketFrame |
TextWebSocketFrame.replace(ByteBuf content) |
ContinuationWebSocketFrame |
ContinuationWebSocketFrame.replace(ByteBuf content) |
abstract WebSocketFrame |
WebSocketFrame.replace(ByteBuf content) |
PongWebSocketFrame |
PongWebSocketFrame.replace(ByteBuf content) |
BinaryWebSocketFrame |
BinaryWebSocketFrame.replace(ByteBuf content) |
PingWebSocketFrame |
PingWebSocketFrame.replace(ByteBuf content) |
CloseWebSocketFrame |
CloseWebSocketFrame.replace(ByteBuf content) |
private void |
WebSocket08FrameDecoder.unmask(ByteBuf frame) |
Constructor and Description |
---|
BinaryWebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData)
Creates a new binary frame with the specified binary data and the final fragment flag.
|
BinaryWebSocketFrame(ByteBuf binaryData)
Creates a new binary frame with the specified binary data.
|
CloseWebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData)
Creates a new close frame
|
ContinuationWebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData)
Creates a new continuation frame with the specified binary data
|
ContinuationWebSocketFrame(ByteBuf binaryData)
Creates a new continuation frame with the specified binary data.
|
PingWebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData)
Creates a new ping frame with the specified binary data
|
PingWebSocketFrame(ByteBuf binaryData)
Creates a new ping frame with the specified binary data.
|
PongWebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData)
Creates a new pong frame with the specified binary data
|
PongWebSocketFrame(ByteBuf binaryData)
Creates a new pong frame with the specified binary data.
|
TextWebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData)
Creates a new text frame with the specified binary data.
|
TextWebSocketFrame(ByteBuf binaryData)
Creates a new text frame with the specified binary data.
|
WebSocketFrame(boolean finalFragment,
int rsv,
ByteBuf binaryData) |
WebSocketFrame(ByteBuf binaryData) |
Constructor and Description |
---|
WebSocketChunkedInput(ChunkedInput<ByteBuf> input)
Creates a new instance using the specified input.
|
WebSocketChunkedInput(ChunkedInput<ByteBuf> input,
int rsv)
Creates a new instance using the specified input.
|
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
DefaultHttp2FrameWriter.DataFrameHeader.buffer |
private ByteBuf |
Http2ConnectionHandler.PrefaceDecoder.clientPrefaceString |
private static ByteBuf |
CleartextHttp2ServerUpgradeHandler.CONNECTION_PREFACE |
private static ByteBuf |
Http2CodecUtil.CONNECTION_PREFACE |
private ByteBuf |
DefaultHttp2DataFrame.content |
(package private) ByteBuf |
StreamBufferingEncoder.DataFrame.data |
private static ByteBuf |
Http2CodecUtil.EMPTY_PING |
private ByteBuf |
DefaultHttp2FrameWriter.DataFrameHeader.frameHeader |
private ByteBuf |
DefaultHttp2FrameReader.HeadersBlockBuilder.headerBlock |
private static ByteBuf |
Http2ConnectionHandler.HTTP_1_X_BUF |
(package private) ByteBuf |
HpackHuffmanEncoder.EncodeProcessor.out |
private ByteBuf |
DefaultHttp2HeadersEncoder.tableSizeChangeOutput |
private static ByteBuf |
DefaultHttp2FrameWriter.ZERO_BUFFER
This buffer is allocated to the maximum size of the padding field, and filled with zeros.
|
Modifier and Type | Method and Description |
---|---|
private static ByteBuf |
Http2ConnectionHandler.clientPrefaceString(Http2Connection connection)
Returns the client preface string if this is a client connection, otherwise returns
null . |
static ByteBuf |
Http2CodecUtil.connectionPrefaceBuf()
Returns a buffer containing the the
Http2CodecUtil.CONNECTION_PREFACE . |
ByteBuf |
DefaultHttp2DataFrame.content() |
ByteBuf |
Http2DataFrame.content()
Payload of DATA frame.
|
ByteBuf |
Http2GoAwayFrame.content()
Optional debugging information describing cause the GOAWAY.
|
private static ByteBuf |
Http2ServerUpgradeCodec.createSettingsFrame(ChannelHandlerContext ctx,
ByteBuf payload)
Creates an HTTP2-Settings header with the given payload.
|
static ByteBuf |
Http2CodecUtil.emptyPingBuf()
Returns a buffer filled with all zeros that is the appropriate length for a PING frame.
|
private static ByteBuf |
DelegatingDecompressorFrameListener.nextReadableBuf(EmbeddedChannel decompressor)
|
private static ByteBuf |
CompressorHttp2ConnectionEncoder.nextReadableBuf(EmbeddedChannel compressor)
|
(package private) ByteBuf |
DefaultHttp2FrameWriter.DataFrameHeader.slice(int data,
int padding,
boolean endOfStream)
Gets the frame header buffer configured for the current frame.
|
static ByteBuf |
Http2CodecUtil.toByteBuf(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Creates a buffer containing the error message from the given exception.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
DefaultHttp2FrameReader.HeadersBlockBuilder.addFragment(ByteBuf fragment,
ByteBufAllocator alloc,
boolean endOfHeaders)
Adds a fragment to the block.
|
private void |
StreamBufferingEncoder.cancelGoAwayStreams(int lastStreamId,
long errorCode,
ByteBuf debugData) |
private static ByteBuf |
Http2ServerUpgradeCodec.createSettingsFrame(ChannelHandlerContext ctx,
ByteBuf payload)
Creates an HTTP2-Settings header with the given payload.
|
AsciiString |
HpackHuffmanDecoder.decode(ByteBuf buf,
int length)
Decompresses the given Huffman coded string literal.
|
protected void |
CleartextHttp2ServerUpgradeHandler.PriorKnowledgeHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Http2ConnectionHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
abstract void |
Http2ConnectionHandler.BaseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionHandler.PrefaceDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionHandler.FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
HpackDecoder.decode(int streamId,
ByteBuf in,
Http2Headers headers)
Decode the header block into header fields.
|
void |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called by the
Http2ConnectionHandler to decode the next frame from the input buffer. |
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
Http2Headers |
DefaultHttp2HeadersDecoder.decodeHeaders(int streamId,
ByteBuf headerBlock) |
Http2Headers |
Http2HeadersDecoder.decodeHeaders(int streamId,
ByteBuf headerBlock)
Decodes the given headers block and returns the headers.
|
private Http2Settings |
Http2ServerUpgradeCodec.decodeSettings(ChannelHandlerContext ctx,
ByteBuf frame)
Decodes the settings frame and returns the settings.
|
(package private) static int |
HpackDecoder.decodeULE128(ByteBuf in,
int result)
Unsigned Little Endian Base 128 Variable-Length Integer Encoding
|
(package private) static long |
HpackDecoder.decodeULE128(ByteBuf in,
long result)
Unsigned Little Endian Base 128 Variable-Length Integer Encoding
|
void |
HpackHuffmanEncoder.encode(ByteBuf out,
java.lang.CharSequence data)
Compresses the input string literal using the Huffman coding.
|
private void |
HpackEncoder.encodeHeader(ByteBuf out,
java.lang.CharSequence name,
java.lang.CharSequence value,
boolean sensitive,
long headerSize)
Encode the header field into the header block.
|
void |
HpackEncoder.encodeHeaders(int streamId,
ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector)
Encode the header field into the header block.
|
void |
Http2HeadersEncoder.encodeHeaders(int streamId,
Http2Headers headers,
ByteBuf buffer)
Encodes the given headers and writes the output headers block to the given output buffer.
|
void |
DefaultHttp2HeadersEncoder.encodeHeaders(int streamId,
Http2Headers headers,
ByteBuf buffer) |
private void |
HpackEncoder.encodeHeadersEnforceMaxHeaderListSize(int streamId,
ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector) |
private void |
HpackEncoder.encodeHeadersIgnoreMaxHeaderListSize(ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector) |
private static void |
HpackEncoder.encodeInteger(ByteBuf out,
int mask,
int n,
int i)
Encode integer according to Section 5.1.
|
private static void |
HpackEncoder.encodeInteger(ByteBuf out,
int mask,
int n,
long i)
Encode integer according to Section 5.1.
|
private void |
HpackEncoder.encodeLiteral(ByteBuf out,
java.lang.CharSequence name,
java.lang.CharSequence value,
HpackUtil.IndexType indexType,
int nameIndex)
Encode literal header field according to Section 6.2.
|
private void |
HpackHuffmanEncoder.encodeSlowPath(ByteBuf out,
java.lang.CharSequence data) |
private void |
HpackEncoder.encodeStringLiteral(ByteBuf out,
java.lang.CharSequence string)
Encode string literal according to Section 5.2.
|
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Prevents the peer from creating streams and close the connection if
errorCode is not
Http2Error.NO_ERROR . |
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
void |
DefaultHttp2Connection.goAwayReceived(int lastKnownStream,
long errorCode,
ByteBuf debugData) |
void |
Http2Connection.goAwayReceived(int lastKnownStream,
long errorCode,
ByteBuf message)
Indicates that a
GOAWAY was received from the remote endpoint and sets the last known stream. |
void |
DefaultHttp2Connection.goAwaySent(int lastKnownStream,
long errorCode,
ByteBuf debugData) |
void |
Http2Connection.goAwaySent(int lastKnownStream,
long errorCode,
ByteBuf message)
Indicates that a
GOAWAY was sent to the remote endpoint and sets the last known stream. |
void |
Http2FrameLogger.logData(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logGoAway(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameLogger.logPing(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameLogger.logPingAck(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameLogger.logUnknownFrame(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf data) |
private static java.lang.IllegalArgumentException |
HpackDecoder.notEnoughDataException(ByteBuf in) |
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream)
Handles an inbound
DATA frame. |
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2EventAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DefaultHttp2ConnectionDecoder.FrameReadListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameCodec.FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData)
Handles an inbound
GO_AWAY frame. |
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
(package private) void |
DefaultHttp2ConnectionDecoder.onGoAwayRead0(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2EventAdapter.onGoAwayReceived(int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2ConnectionAdapter.onGoAwayReceived(int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2Connection.Listener.onGoAwayReceived(int lastStreamId,
long errorCode,
ByteBuf debugData)
Called when a
GOAWAY was received from the remote endpoint. |
void |
Http2FrameCodec.ConnectionListener.onGoAwayReceived(int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2EventAdapter.onGoAwaySent(int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2ConnectionAdapter.onGoAwaySent(int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2Connection.Listener.onGoAwaySent(int lastStreamId,
long errorCode,
ByteBuf debugData)
Called when a
GOAWAY frame was sent for the connection. |
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING acknowledgment. |
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING frame. |
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload)
Handler for a frame not defined by the HTTP/2 spec.
|
void |
Http2FrameListenerDecorator.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
(package private) void |
DefaultHttp2ConnectionDecoder.onUnknownFrame0(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
(package private) abstract void |
DefaultHttp2FrameReader.HeadersContinuation.processFragment(boolean endOfHeaders,
ByteBuf fragment,
Http2FrameListener listener)
Processes the next fragment for the current header block.
|
private static void |
Http2ConnectionHandler.processGoAwayWriteResult(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelFuture future) |
private void |
DefaultHttp2FrameReader.processHeaderState(ByteBuf in) |
private void |
DefaultHttp2FrameReader.processPayloadState(ChannelHandlerContext ctx,
ByteBuf in,
Http2FrameListener listener) |
private boolean |
Http2ConnectionHandler.PrefaceDecoder.readClientPrefaceString(ByteBuf in)
Decodes the client connection preface string from the input buffer.
|
private void |
DefaultHttp2FrameReader.readContinuationFrame(ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readDataFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
void |
Http2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener)
Attempts to read the next frame from the input buffer.
|
void |
DefaultHttp2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
void |
Http2InboundFrameLogger.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
private static void |
DefaultHttp2FrameReader.readGoAwayFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readHeadersFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private int |
DefaultHttp2FrameReader.readPadding(ByteBuf payload)
If padding is present in the payload, reads the next byte as padding.
|
private void |
DefaultHttp2FrameReader.readPingFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPriorityFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPushPromiseFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readRstStreamFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readSettingsFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private java.lang.CharSequence |
HpackDecoder.readStringLiteral(ByteBuf in,
int length,
boolean huffmanEncoded) |
private void |
DefaultHttp2FrameReader.readUnknownFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
static int |
Http2CodecUtil.readUnsignedInt(ByteBuf buf)
Reads a big-endian (31-bit) integer from the buffer.
|
private void |
DefaultHttp2FrameReader.readWindowUpdateFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.receiveFlowControlledFrame(Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
DefaultHttp2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream)
Receives an inbound
DATA frame from the remote endpoint and applies flow control policies to it for both
the stream as well as the connection. |
DefaultHttp2DataFrame |
DefaultHttp2DataFrame.replace(ByteBuf content) |
Http2GoAwayFrame |
DefaultHttp2GoAwayFrame.replace(ByteBuf content) |
Http2DataFrame |
Http2DataFrame.replace(ByteBuf content) |
Http2GoAwayFrame |
Http2GoAwayFrame.replace(ByteBuf content) |
void |
HpackEncoder.setMaxHeaderTableSize(ByteBuf out,
long maxHeaderTableSize)
Set the maximum table size.
|
private java.lang.String |
Http2FrameLogger.toString(ByteBuf buf) |
private boolean |
Http2ConnectionHandler.PrefaceDecoder.verifyFirstFrameIsSettings(ByteBuf in)
Peeks at that the next frame in the buffer and verifies that it is a non-ack
SETTINGS frame. |
private static void |
DefaultHttp2FrameWriter.verifyPingPayload(ByteBuf data) |
private ChannelFuture |
DefaultHttp2FrameWriter.writeContinuationFrames(ChannelHandlerContext ctx,
int streamId,
ByteBuf headerBlock,
int padding,
Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator)
Writes as many continuation frames as needed until
padding and headerBlock are consumed. |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a
DATA frame to the remote endpoint. |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Writes the given data to the internal
Http2FrameWriter without performing any
state checks on the connection/stream. |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Generic write method for any HTTP/2 frame.
|
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
static void |
Http2CodecUtil.writeFrameHeader(ByteBuf out,
int payloadLength,
byte type,
Http2Flags flags,
int streamId)
Writes an HTTP/2 frame header to the output buffer.
|
(package private) static void |
Http2CodecUtil.writeFrameHeaderInternal(ByteBuf out,
int payloadLength,
byte type,
Http2Flags flags,
int streamId) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Writes a GO_AWAY frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
private static void |
DefaultHttp2FrameWriter.writePaddingLength(ByteBuf buf,
int padding) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise)
Writes a PING frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
Constructor and Description |
---|
DataFrame(ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
DefaultHttp2DataFrame(ByteBuf content)
Equivalent to
new DefaultHttp2DataFrame(content, false) . |
DefaultHttp2DataFrame(ByteBuf content,
boolean endStream)
Equivalent to
new DefaultHttp2DataFrame(content, endStream, 0) . |
DefaultHttp2DataFrame(ByteBuf content,
boolean endStream,
int padding)
Construct a new data message.
|
DefaultHttp2GoAwayFrame(Http2Error error,
ByteBuf content) |
DefaultHttp2GoAwayFrame(int lastStreamId,
long errorCode,
ByteBuf content)
Construct a new GOAWAY message.
|
DefaultHttp2GoAwayFrame(long errorCode,
ByteBuf content)
Construct a new GOAWAY message.
|
FlowControlledData(Http2Stream stream,
ByteBuf buf,
int padding,
boolean endOfStream,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JsonObjectDecoder.extractObject(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Override this method if you want to filter the json objects/arrays that get passed through the pipeline.
|
Modifier and Type | Method and Description |
---|---|
protected void |
JsonObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private void |
JsonObjectDecoder.decodeByte(byte c,
ByteBuf in,
int idx) |
protected ByteBuf |
JsonObjectDecoder.extractObject(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Override this method if you want to filter the json objects/arrays that get passed through the pipeline.
|
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
DefaultMemcacheContent.content |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
DefaultMemcacheContent.content() |
protected abstract ByteBuf |
AbstractMemcacheObjectEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg)
Take the given
MemcacheMessage and encode it into a writable ByteBuf . |
Modifier and Type | Method and Description |
---|---|
MemcacheContent |
MemcacheContent.replace(ByteBuf content) |
MemcacheContent |
DefaultMemcacheContent.replace(ByteBuf content) |
LastMemcacheContent |
LastMemcacheContent.replace(ByteBuf content) |
FullMemcacheMessage |
FullMemcacheMessage.replace(ByteBuf content) |
LastMemcacheContent |
DefaultLastMemcacheContent.replace(ByteBuf content) |
Constructor and Description |
---|
DefaultLastMemcacheContent(ByteBuf content) |
DefaultMemcacheContent(ByteBuf content)
Creates a new instance with the specified content.
|
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
DefaultFullBinaryMemcacheResponse.content |
private ByteBuf |
DefaultFullBinaryMemcacheRequest.content |
private ByteBuf |
AbstractBinaryMemcacheMessage.extras
Contains the optional extras.
|
private ByteBuf |
AbstractBinaryMemcacheMessage.key
Contains the optional key.
|
Modifier and Type | Method and Description |
---|---|
ByteBuf |
DefaultFullBinaryMemcacheResponse.content() |
ByteBuf |
DefaultFullBinaryMemcacheRequest.content() |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg) |
ByteBuf |
BinaryMemcacheMessage.extras()
Returns a
ByteBuf representation of the optional extras. |
ByteBuf |
AbstractBinaryMemcacheMessage.extras() |
ByteBuf |
BinaryMemcacheMessage.key()
Returns the optional key of the document.
|
ByteBuf |
AbstractBinaryMemcacheMessage.key() |
Modifier and Type | Method and Description |
---|---|
protected FullMemcacheMessage |
BinaryMemcacheObjectAggregator.beginAggregation(BinaryMemcacheMessage start,
ByteBuf content) |
protected void |
AbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
BinaryMemcacheClientCodec.Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected BinaryMemcacheResponse |
BinaryMemcacheResponseDecoder.decodeHeader(ByteBuf in) |
protected abstract M |
AbstractBinaryMemcacheDecoder.decodeHeader(ByteBuf in)
Decode and return the parsed
BinaryMemcacheMessage . |
protected BinaryMemcacheRequest |
BinaryMemcacheRequestDecoder.decodeHeader(ByteBuf in) |
private static void |
AbstractBinaryMemcacheEncoder.encodeExtras(ByteBuf buf,
ByteBuf extras)
Encode the extras.
|
protected void |
BinaryMemcacheRequestEncoder.encodeHeader(ByteBuf buf,
BinaryMemcacheRequest msg) |
protected void |
BinaryMemcacheResponseEncoder.encodeHeader(ByteBuf buf,
BinaryMemcacheResponse msg) |
protected abstract void |
AbstractBinaryMemcacheEncoder.encodeHeader(ByteBuf buf,
M msg)
Encode the header.
|
private static void |
AbstractBinaryMemcacheEncoder.encodeKey(ByteBuf buf,
ByteBuf key)
Encode the key.
|
FullBinaryMemcacheResponse |
DefaultFullBinaryMemcacheResponse.replace(ByteBuf content) |
FullBinaryMemcacheRequest |
DefaultFullBinaryMemcacheRequest.replace(ByteBuf content) |
FullBinaryMemcacheRequest |
FullBinaryMemcacheRequest.replace(ByteBuf content) |
FullBinaryMemcacheResponse |
FullBinaryMemcacheResponse.replace(ByteBuf content) |
BinaryMemcacheMessage |
BinaryMemcacheMessage.setExtras(ByteBuf extras)
Sets the extras buffer on the message.
|
BinaryMemcacheMessage |
AbstractBinaryMemcacheMessage.setExtras(ByteBuf extras) |
BinaryMemcacheMessage |
BinaryMemcacheMessage.setKey(ByteBuf key)
Sets the key of the document.
|
BinaryMemcacheMessage |
AbstractBinaryMemcacheMessage.setKey(ByteBuf key) |
private static FullBinaryMemcacheRequest |
BinaryMemcacheObjectAggregator.toFullRequest(BinaryMemcacheRequest request,
ByteBuf content) |
private static FullBinaryMemcacheResponse |
BinaryMemcacheObjectAggregator.toFullResponse(BinaryMemcacheResponse response,
ByteBuf content) |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
MqttMessageBuilders.PublishBuilder.payload |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
MqttPublishMessage.content() |
(package private) static ByteBuf |
MqttEncoder.doEncode(ByteBufAllocator byteBufAllocator,
MqttMessage message)
This is the main encoding method.
|
private static ByteBuf |
MqttEncoder.encodeConnAckMessage(ByteBufAllocator byteBufAllocator,
MqttConnAckMessage message) |
private static ByteBuf |
MqttEncoder.encodeConnectMessage(ByteBufAllocator byteBufAllocator,
MqttConnectMessage message) |
private static ByteBuf |
MqttEncoder.encodeMessageWithOnlySingleByteFixedHeader(ByteBufAllocator byteBufAllocator,
MqttMessage message) |
private static ByteBuf |
MqttEncoder.encodeMessageWithOnlySingleByteFixedHeaderAndMessageId(ByteBufAllocator byteBufAllocator,
MqttMessage message) |
private static ByteBuf |
MqttEncoder.encodePublishMessage(ByteBufAllocator byteBufAllocator,
MqttPublishMessage message) |
private static ByteBuf |
MqttEncoder.encodeSubAckMessage(ByteBufAllocator byteBufAllocator,
MqttSubAckMessage message) |
private static ByteBuf |
MqttEncoder.encodeSubscribeMessage(ByteBufAllocator byteBufAllocator,
MqttSubscribeMessage message) |
private static ByteBuf |
MqttEncoder.encodeUnsubscribeMessage(ByteBufAllocator byteBufAllocator,
MqttUnsubscribeMessage message) |
ByteBuf |
MqttPublishMessage.payload() |
Modifier and Type | Method and Description |
---|---|
private static MqttDecoder.Result<ByteBuf> |
MqttDecoder.decodePublishPayload(ByteBuf buffer,
int bytesRemainingInVariablePart) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
private static MqttDecoder.Result<byte[]> |
MqttDecoder.decodeByteArray(ByteBuf buffer) |
private static MqttDecoder.Result<MqttConnAckVariableHeader> |
MqttDecoder.decodeConnAckVariableHeader(ByteBuf buffer) |
private static MqttDecoder.Result<MqttConnectPayload> |
MqttDecoder.decodeConnectionPayload(ByteBuf buffer,
MqttConnectVariableHeader mqttConnectVariableHeader) |
private static MqttDecoder.Result<MqttConnectVariableHeader> |
MqttDecoder.decodeConnectionVariableHeader(ByteBuf buffer) |
private static MqttFixedHeader |
MqttDecoder.decodeFixedHeader(ByteBuf buffer)
Decodes the fixed header.
|
private static MqttDecoder.Result<java.lang.Integer> |
MqttDecoder.decodeMessageId(ByteBuf buffer) |
private static MqttDecoder.Result<MqttMessageIdVariableHeader> |
MqttDecoder.decodeMessageIdVariableHeader(ByteBuf buffer) |
private static MqttDecoder.Result<java.lang.Integer> |
MqttDecoder.decodeMsbLsb(ByteBuf buffer) |
private static MqttDecoder.Result<java.lang.Integer> |
MqttDecoder.decodeMsbLsb(ByteBuf buffer,
int min,
int max) |
private static MqttDecoder.Result<?> |
MqttDecoder.decodePayload(ByteBuf buffer,
MqttMessageType messageType,
int bytesRemainingInVariablePart,
java.lang.Object variableHeader)
Decodes the payload.
|
private static MqttDecoder.Result<ByteBuf> |
MqttDecoder.decodePublishPayload(ByteBuf buffer,
int bytesRemainingInVariablePart) |
private static MqttDecoder.Result<MqttPublishVariableHeader> |
MqttDecoder.decodePublishVariableHeader(ByteBuf buffer,
MqttFixedHeader mqttFixedHeader) |
private static MqttDecoder.Result<java.lang.String> |
MqttDecoder.decodeString(ByteBuf buffer) |
private static MqttDecoder.Result<java.lang.String> |
MqttDecoder.decodeString(ByteBuf buffer,
int minBytes,
int maxBytes) |
private static MqttDecoder.Result<MqttSubAckPayload> |
MqttDecoder.decodeSubackPayload(ByteBuf buffer,
int bytesRemainingInVariablePart) |
private static MqttDecoder.Result<MqttSubscribePayload> |
MqttDecoder.decodeSubscribePayload(ByteBuf buffer,
int bytesRemainingInVariablePart) |
private static MqttDecoder.Result<MqttUnsubscribePayload> |
MqttDecoder.decodeUnsubscribePayload(ByteBuf buffer,
int bytesRemainingInVariablePart) |
private static MqttDecoder.Result<?> |
MqttDecoder.decodeVariableHeader(ByteBuf buffer,
MqttFixedHeader mqttFixedHeader)
Decodes the variable header (if any)
|
MqttMessageBuilders.PublishBuilder |
MqttMessageBuilders.PublishBuilder.payload(ByteBuf payload) |
MqttPublishMessage |
MqttPublishMessage.replace(ByteBuf content) |
private static void |
MqttEncoder.writeVariableLengthInt(ByteBuf buf,
int num) |
Constructor and Description |
---|
MqttPublishMessage(MqttFixedHeader mqttFixedHeader,
MqttPublishVariableHeader variableHeader,
ByteBuf payload) |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<ByteBuf,ErrorRedisMessage> |
FixedRedisMessagePool.byteBufToErrors |
private java.util.Map<ByteBuf,IntegerRedisMessage> |
FixedRedisMessagePool.byteBufToIntegers |
private java.util.Map<ByteBuf,SimpleStringRedisMessage> |
FixedRedisMessagePool.byteBufToSimpleStrings |
Modifier and Type | Method and Description |
---|---|
private static ByteBuf |
RedisDecoder.readLine(ByteBuf in) |
Modifier and Type | Method and Description |
---|---|
protected FullBulkStringRedisMessage |
RedisBulkStringAggregator.beginAggregation(BulkStringHeaderRedisMessage start,
ByteBuf content) |
protected void |
RedisDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private boolean |
RedisDecoder.decodeBulkString(ByteBuf in,
java.util.List<java.lang.Object> out) |
private boolean |
RedisDecoder.decodeBulkStringContent(ByteBuf in,
java.util.List<java.lang.Object> out) |
private boolean |
RedisDecoder.decodeBulkStringEndOfLine(ByteBuf in,
java.util.List<java.lang.Object> out) |
private boolean |
RedisDecoder.decodeInline(ByteBuf in,
java.util.List<java.lang.Object> out) |
private boolean |
RedisDecoder.decodeLength(ByteBuf in,
java.util.List<java.lang.Object> out) |
private boolean |
RedisDecoder.decodeType(ByteBuf in) |
ErrorRedisMessage |
FixedRedisMessagePool.getError(ByteBuf content) |
ErrorRedisMessage |
RedisMessagePool.getError(ByteBuf content)
Returns
ErrorRedisMessage for given content . |
IntegerRedisMessage |
FixedRedisMessagePool.getInteger(ByteBuf content) |
IntegerRedisMessage |
RedisMessagePool.getInteger(ByteBuf content)
Returns
IntegerRedisMessage for given content . |
SimpleStringRedisMessage |
FixedRedisMessagePool.getSimpleString(ByteBuf content) |
SimpleStringRedisMessage |
RedisMessagePool.getSimpleString(ByteBuf content)
Returns
SimpleStringRedisMessage for given content . |
private RedisMessage |
RedisDecoder.newInlineRedisMessage(RedisMessageType messageType,
ByteBuf content) |
private long |
RedisDecoder.parsePositiveNumber(ByteBuf byteBuf) |
private long |
RedisDecoder.parseRedisNumber(ByteBuf byteBuf) |
private static void |
RedisDecoder.readEndOfLine(ByteBuf in) |
private static ByteBuf |
RedisDecoder.readLine(ByteBuf in) |
FullBulkStringRedisMessage |
FullBulkStringRedisMessage.replace(ByteBuf content) |
BulkStringRedisContent |
BulkStringRedisContent.replace(ByteBuf content) |
BulkStringRedisContent |
DefaultBulkStringRedisContent.replace(ByteBuf content) |
LastBulkStringRedisContent |
LastBulkStringRedisContent.replace(ByteBuf content) |
LastBulkStringRedisContent |
DefaultLastBulkStringRedisContent.replace(ByteBuf content) |
Constructor and Description |
---|
DefaultBulkStringRedisContent(ByteBuf content)
Creates a
DefaultBulkStringRedisContent for the given content . |
DefaultLastBulkStringRedisContent(ByteBuf content)
Creates a
DefaultLastBulkStringRedisContent for the given content . |
FullBulkStringRedisMessage(ByteBuf content)
Creates a
FullBulkStringRedisMessage for the given content . |
Modifier and Type | Method and Description |
---|---|
protected void |
RtspEncoder.encodeInitialLine(ByteBuf buf,
HttpMessage message) |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.Integer,ByteBuf> |
SctpMessageCompletionHandler.fragments |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
Modifier and Type | Field and Description |
---|---|
private static ByteBuf |
SmtpRequestEncoder.DOT_CRLF_BUFFER |
Modifier and Type | Method and Description |
---|---|
protected SmtpResponse |
SmtpResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer) |
(package private) void |
SmtpCommand.encode(ByteBuf buffer) |
private static DecoderException |
SmtpResponseDecoder.newDecoderException(ByteBuf buffer,
int readerIndex,
int readable) |
private static int |
SmtpResponseDecoder.parseCode(ByteBuf buffer)
Parses the io.netty.handler.codec.smtp code without any allocation, which is three digits.
|
LastSmtpContent |
DefaultLastSmtpContent.replace(ByteBuf content) |
SmtpContent |
DefaultSmtpContent.replace(ByteBuf content) |
LastSmtpContent |
LastSmtpContent.replace(ByteBuf content) |
SmtpContent |
SmtpContent.replace(ByteBuf content) |
private static void |
SmtpRequestEncoder.writeParameters(java.util.List<java.lang.CharSequence> parameters,
ByteBuf out) |
Constructor and Description |
---|
DefaultLastSmtpContent(ByteBuf data)
Creates a new instance using the given data.
|
DefaultSmtpContent(ByteBuf data)
Creates a new instance using the given data.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
SocksMessage msg,
ByteBuf out) |
void |
SocksCmdRequest.encodeAsByteBuf(ByteBuf byteBuf) |
void |
SocksCmdResponse.encodeAsByteBuf(ByteBuf byteBuf) |
void |
SocksInitRequest.encodeAsByteBuf(ByteBuf byteBuf) |
void |
UnknownSocksResponse.encodeAsByteBuf(ByteBuf byteBuf) |
void |
SocksInitResponse.encodeAsByteBuf(ByteBuf byteBuf) |
abstract void |
SocksMessage.encodeAsByteBuf(ByteBuf byteBuf)
Deprecated.
Do not use; this method was intended for an internal use only.
|
void |
SocksAuthRequest.encodeAsByteBuf(ByteBuf byteBuf) |
void |
UnknownSocksRequest.encodeAsByteBuf(ByteBuf byteBuf) |
void |
SocksAuthResponse.encodeAsByteBuf(ByteBuf byteBuf) |
(package private) static java.lang.String |
SocksCommonUtils.readUsAscii(ByteBuf buffer,
int length) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksPortUnificationServerHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks4ClientDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks4ServerDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks4ClientEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandRequest msg,
ByteBuf out) |
protected void |
Socks4ServerEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandResponse msg,
ByteBuf out) |
private static java.lang.String |
Socks4ServerDecoder.readString(java.lang.String fieldName,
ByteBuf in)
Reads a variable-length NUL-terminated string as defined in SOCKS4.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
java.lang.String |
Socks5AddressDecoder.decodeAddress(Socks5AddressType addrType,
ByteBuf in)
Decodes a SOCKS5 address field into its string representation.
|
protected void |
Socks5ServerEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
protected void |
Socks5ClientEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
void |
Socks5AddressEncoder.encodeAddress(Socks5AddressType addrType,
java.lang.String addrValue,
ByteBuf out)
Encodes a SOCKS5 address.
|
private static void |
Socks5ClientEncoder.encodeAuthMethodRequest(Socks5InitialRequest msg,
ByteBuf out) |
private static void |
Socks5ServerEncoder.encodeAuthMethodResponse(Socks5InitialResponse msg,
ByteBuf out) |
private void |
Socks5ClientEncoder.encodeCommandRequest(Socks5CommandRequest msg,
ByteBuf out) |
private void |
Socks5ServerEncoder.encodeCommandResponse(Socks5CommandResponse msg,
ByteBuf out) |
private static void |
Socks5ClientEncoder.encodePasswordAuthRequest(Socks5PasswordAuthRequest msg,
ByteBuf out) |
private static void |
Socks5ServerEncoder.encodePasswordAuthResponse(Socks5PasswordAuthResponse msg,
ByteBuf out) |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
SpdyHeaderBlockRawDecoder.cumulation |
private ByteBuf |
DefaultSpdyDataFrame.data |
private ByteBuf |
SpdyHeaderBlockZlibDecoder.decompressed |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
DefaultSpdyDataFrame.content() |
ByteBuf |
SpdyDataFrame.content()
Returns the data payload of this frame.
|
private ByteBuf |
SpdyHeaderBlockJZlibEncoder.encode(ByteBufAllocator alloc) |
private ByteBuf |
SpdyHeaderBlockZlibEncoder.encode(ByteBufAllocator alloc,
int len) |
ByteBuf |
SpdyHeaderBlockRawEncoder.encode(ByteBufAllocator alloc,
SpdyHeadersFrame frame) |
ByteBuf |
SpdyHeaderBlockZlibEncoder.encode(ByteBufAllocator alloc,
SpdyHeadersFrame frame) |
(package private) abstract ByteBuf |
SpdyHeaderBlockEncoder.encode(ByteBufAllocator alloc,
SpdyHeadersFrame frame) |
ByteBuf |
SpdyHeaderBlockJZlibEncoder.encode(ByteBufAllocator alloc,
SpdyHeadersFrame frame) |
ByteBuf |
SpdyFrameEncoder.encodeDataFrame(ByteBufAllocator allocator,
int streamId,
boolean last,
ByteBuf data) |
ByteBuf |
SpdyFrameEncoder.encodeGoAwayFrame(ByteBufAllocator allocator,
int lastGoodStreamId,
int statusCode) |
ByteBuf |
SpdyFrameEncoder.encodeHeadersFrame(ByteBufAllocator allocator,
int streamId,
boolean last,
ByteBuf headerBlock) |
ByteBuf |
SpdyFrameEncoder.encodePingFrame(ByteBufAllocator allocator,
int id) |
ByteBuf |
SpdyFrameEncoder.encodeRstStreamFrame(ByteBufAllocator allocator,
int streamId,
int statusCode) |
ByteBuf |
SpdyFrameEncoder.encodeSettingsFrame(ByteBufAllocator allocator,
SpdySettingsFrame spdySettingsFrame) |
ByteBuf |
SpdyFrameEncoder.encodeSynReplyFrame(ByteBufAllocator allocator,
int streamId,
boolean last,
ByteBuf headerBlock) |
ByteBuf |
SpdyFrameEncoder.encodeSynStreamFrame(ByteBufAllocator allocator,
int streamId,
int associatedToStreamId,
byte priority,
boolean last,
boolean unidirectional,
ByteBuf headerBlock) |
ByteBuf |
SpdyFrameEncoder.encodeWindowUpdateFrame(ByteBufAllocator allocator,
int streamId,
int deltaWindowSize) |
private static ByteBuf |
DefaultSpdyDataFrame.validate(ByteBuf data) |
Modifier and Type | Method and Description |
---|---|
private boolean |
SpdyHeaderBlockZlibEncoder.compressInto(ByteBuf compressed) |
void |
SpdyFrameDecoder.decode(ByteBuf buffer) |
(package private) abstract void |
SpdyHeaderBlockDecoder.decode(ByteBufAllocator alloc,
ByteBuf headerBlock,
SpdyHeadersFrame frame)
Decodes a SPDY Header Block, adding the Name/Value pairs to the given Headers frame.
|
(package private) void |
SpdyHeaderBlockRawDecoder.decode(ByteBufAllocator alloc,
ByteBuf headerBlock,
SpdyHeadersFrame frame) |
(package private) void |
SpdyHeaderBlockZlibDecoder.decode(ByteBufAllocator alloc,
ByteBuf headerBlock,
SpdyHeadersFrame frame) |
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHeaderBlockRawDecoder.decodeHeaderBlock(ByteBuf headerBlock,
SpdyHeadersFrame frame) |
ByteBuf |
SpdyFrameEncoder.encodeDataFrame(ByteBufAllocator allocator,
int streamId,
boolean last,
ByteBuf data) |
ByteBuf |
SpdyFrameEncoder.encodeHeadersFrame(ByteBufAllocator allocator,
int streamId,
boolean last,
ByteBuf headerBlock) |
ByteBuf |
SpdyFrameEncoder.encodeSynReplyFrame(ByteBufAllocator allocator,
int streamId,
boolean last,
ByteBuf headerBlock) |
ByteBuf |
SpdyFrameEncoder.encodeSynStreamFrame(ByteBufAllocator allocator,
int streamId,
int associatedToStreamId,
byte priority,
boolean last,
boolean unidirectional,
ByteBuf headerBlock) |
(package private) static int |
SpdyCodecUtil.getSignedInt(ByteBuf buf,
int offset)
Reads a big-endian signed integer from the buffer.
|
(package private) static int |
SpdyCodecUtil.getUnsignedInt(ByteBuf buf,
int offset)
Reads a big-endian (31-bit) integer from the buffer.
|
(package private) static int |
SpdyCodecUtil.getUnsignedMedium(ByteBuf buf,
int offset)
Reads a big-endian unsigned medium integer from the buffer.
|
(package private) static int |
SpdyCodecUtil.getUnsignedShort(ByteBuf buf,
int offset)
Reads a big-endian unsigned short integer from the buffer.
|
void |
SpdyFrameCodec.readDataFrame(int streamId,
boolean last,
ByteBuf data) |
void |
SpdyFrameDecoderDelegate.readDataFrame(int streamId,
boolean last,
ByteBuf data)
Called when a DATA frame is received.
|
void |
SpdyFrameCodec.readHeaderBlock(ByteBuf headerBlock) |
void |
SpdyFrameDecoderDelegate.readHeaderBlock(ByteBuf headerBlock)
Called when the header block within a SYN_STREAM, SYN_REPLY, or HEADERS frame is received.
|
private static int |
SpdyHeaderBlockRawDecoder.readLengthField(ByteBuf buffer) |
SpdyDataFrame |
DefaultSpdyDataFrame.replace(ByteBuf content) |
SpdyDataFrame |
SpdyDataFrame.replace(ByteBuf content) |
private int |
SpdyHeaderBlockZlibDecoder.setInput(ByteBuf compressed) |
private int |
SpdyHeaderBlockZlibEncoder.setInput(ByteBuf decompressed) |
private void |
SpdyHeaderBlockJZlibEncoder.setInput(ByteBuf decompressed) |
private static void |
SpdyHeaderBlockRawEncoder.setLengthField(ByteBuf buffer,
int writerIndex,
int length) |
private static ByteBuf |
DefaultSpdyDataFrame.validate(ByteBuf data) |
private void |
SpdyFrameEncoder.writeControlFrameHeader(ByteBuf buffer,
int type,
byte flags,
int length) |
private static void |
SpdyHeaderBlockRawEncoder.writeLengthField(ByteBuf buffer,
int length) |
Constructor and Description |
---|
DefaultSpdyDataFrame(int streamId,
ByteBuf data)
Creates a new instance.
|
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
DefaultStompFrame.content |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
DefaultStompFrame.content() |
private static ByteBuf |
StompSubframeEncoder.encodeContent(StompContentSubframe content,
ChannelHandlerContext ctx) |
private static ByteBuf |
StompSubframeEncoder.encodeFrame(StompHeadersSubframe frame,
ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected StompFrame |
StompSubframeAggregator.beginAggregation(StompHeadersSubframe start,
ByteBuf content) |
protected void |
StompSubframeDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private StompCommand |
StompSubframeDecoder.readCommand(ByteBuf in) |
private StompSubframeDecoder.State |
StompSubframeDecoder.readHeaders(ByteBuf buffer,
StompHeaders headers) |
private static java.lang.String |
StompSubframeDecoder.readLine(ByteBuf buffer,
int maxLineLength) |
StompContentSubframe |
StompContentSubframe.replace(ByteBuf content) |
LastStompContentSubframe |
DefaultLastStompContentSubframe.replace(ByteBuf content) |
StompFrame |
StompFrame.replace(ByteBuf content) |
StompFrame |
DefaultStompFrame.replace(ByteBuf content) |
StompContentSubframe |
DefaultStompContentSubframe.replace(ByteBuf content) |
LastStompContentSubframe |
LastStompContentSubframe.replace(ByteBuf content) |
private static void |
StompSubframeDecoder.skipControlCharacters(ByteBuf buffer) |
private static void |
StompSubframeDecoder.skipNullCharacter(ByteBuf buffer) |
Constructor and Description |
---|
DefaultLastStompContentSubframe(ByteBuf content) |
DefaultStompContentSubframe(ByteBuf content) |
DefaultStompFrame(StompCommand command,
ByteBuf content) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
private static ByteBuf |
XmlFrameDecoder.extractFrame(ByteBuf buffer,
int index,
int length) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private static ByteBuf |
XmlFrameDecoder.extractFrame(ByteBuf buffer,
int index,
int length) |
private static boolean |
XmlFrameDecoder.isCDATABlockStart(ByteBuf in,
int i) |
private static boolean |
XmlFrameDecoder.isCommentBlockStart(ByteBuf in,
int i) |
Modifier and Type | Method and Description |
---|---|
private static java.lang.String |
LoggingHandler.formatByteBuf(ChannelHandlerContext ctx,
java.lang.String eventName,
ByteBuf msg)
Generates the default log message of the specified event whose argument is a
ByteBuf . |
Modifier and Type | Field and Description |
---|---|
private ByteBuf |
PemValue.content |
private ByteBuf |
PemPrivateKey.content |
private ByteBuf |
PemX509Certificate.content |
Modifier and Type | Method and Description |
---|---|
private ByteBuf |
SslHandler.allocate(ChannelHandlerContext ctx,
int capacity)
Always prefer a direct buffer when it's pooled, so that we reduce the number of memory copies
in
OpenSslEngine . |
private ByteBuf |
SslHandler.allocateOutNetBuf(ChannelHandlerContext ctx,
int pendingBytes,
int numComponents)
Allocates an outbound network buffer for
SSLEngine.wrap(ByteBuffer, ByteBuffer) which can encrypt
the specified amount of pending bytes. |
private static ByteBuf |
PemX509Certificate.append(ByteBufAllocator allocator,
boolean useDirect,
PemEncoded encoded,
int count,
ByteBuf pem)
Appends the
PemEncoded value to the ByteBuf (last arg) and returns it. |
private static ByteBuf |
PemX509Certificate.append(ByteBufAllocator allocator,
boolean useDirect,
java.security.cert.X509Certificate cert,
int count,
ByteBuf pem)
Appends the
X509Certificate value to the ByteBuf (last arg) and returns it. |
ByteBuf |
PemValue.content() |
ByteBuf |
PemPrivateKey.content() |
ByteBuf |
PemX509Certificate.content() |
private static ByteBuf |
PemX509Certificate.newBuffer(ByteBufAllocator allocator,
boolean useDirect,
int initialCapacity) |
(package private) static ByteBuf[] |
PemReader.readCertificates(java.io.File file) |
(package private) static ByteBuf[] |
PemReader.readCertificates(java.io.InputStream in) |
(package private) static ByteBuf |
PemReader.readPrivateKey(java.io.File file) |
(package private) static ByteBuf |
PemReader.readPrivateKey(java.io.InputStream in) |
(package private) static ByteBuf |
SslUtils.toBase64(ByteBufAllocator allocator,
ByteBuf src)
Same as
Base64.encode(ByteBuf, boolean) but allows the use of a custom ByteBufAllocator . |
Modifier and Type | Method and Description |
---|---|
private static ByteBuf |
PemX509Certificate.append(ByteBufAllocator allocator,
boolean useDirect,
PemEncoded encoded,
int count,
ByteBuf pem)
Appends the
PemEncoded value to the ByteBuf (last arg) and returns it. |
private static ByteBuf |
PemX509Certificate.append(ByteBufAllocator allocator,
boolean useDirect,
java.security.cert.X509Certificate cert,
int count,
ByteBuf pem)
Appends the
X509Certificate value to the ByteBuf (last arg) and returns it. |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
AbstractSniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private void |
SslHandler.finishWrap(ChannelHandlerContext ctx,
ByteBuf out,
ChannelPromise promise,
boolean inUnwrap,
boolean needUnwrap) |
private static java.security.cert.X509Certificate[] |
SslContext.getCertificatesFromBuffers(ByteBuf[] certs) |
(package private) static int |
SslUtils.getEncryptedPacketLength(ByteBuf buffer,
int offset)
Return how much bytes can be read out of the encrypted data.
|
private static java.security.PrivateKey |
SslContext.getPrivateKeyFromByteBuffer(ByteBuf encodedKeyBuf,
java.lang.String keyPassword) |
static boolean |
SslHandler.isEncrypted(ByteBuf buffer)
Returns
true if the given ByteBuf is encrypted. |
PemValue |
PemValue.replace(ByteBuf content) |
PemPrivateKey |
PemPrivateKey.replace(ByteBuf content) |
PemEncoded |
PemEncoded.replace(ByteBuf content) |
PemX509Certificate |
PemX509Certificate.replace(ByteBuf content) |
private static short |
SslUtils.shortBE(ByteBuf buffer,
int offset) |
(package private) static ByteBuf |
SslUtils.toBase64(ByteBufAllocator allocator,
ByteBuf src)
Same as
Base64.encode(ByteBuf, boolean) but allows the use of a custom ByteBufAllocator . |
private static java.nio.ByteBuffer |
SslHandler.toByteBuffer(ByteBuf out,
int index,
int len) |
private static int |
SslUtils.unsignedShortBE(ByteBuf buffer,
int offset) |
private boolean |
SslHandler.unwrap(ChannelHandlerContext ctx,
ByteBuf packet,
int offset,
int length)
Unwraps inbound SSL records.
|
(package private) abstract javax.net.ssl.SSLEngineResult |
SslHandler.SslEngineType.unwrap(SslHandler handler,
ByteBuf in,
int readerIndex,
int len,
ByteBuf out) |
static PemPrivateKey |
PemPrivateKey.valueOf(ByteBuf key)
Creates a
PemPrivateKey from raw ByteBuf . |
static PemX509Certificate |
PemX509Certificate.valueOf(ByteBuf key)
Creates a
PemX509Certificate from raw ByteBuf . |
private javax.net.ssl.SSLEngineResult |
SslHandler.wrap(ByteBufAllocator alloc,
javax.net.ssl.SSLEngine engine,
ByteBuf in,
ByteBuf out) |
(package private) static void |
SslUtils.zeroout(ByteBuf buffer)
Fills the
ByteBuf with zero bytes. |
(package private) static void |
SslUtils.zerooutAndRelease(ByteBuf buffer)
Fills the
ByteBuf with zero bytes and releases it. |
Constructor and Description |
---|
PemPrivateKey(ByteBuf content) |
PemValue(ByteBuf content,
boolean sensitive) |
PemX509Certificate(ByteBuf content) |
Modifier and Type | Method and Description |
---|---|
ByteBuf |
ChunkedNioFile.readChunk(ByteBufAllocator allocator) |
ByteBuf |
ChunkedFile.readChunk(ByteBufAllocator allocator) |
ByteBuf |
ChunkedNioStream.readChunk(ByteBufAllocator allocator) |
ByteBuf |
ChunkedStream.readChunk(ByteBufAllocator allocator) |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
(package private) static java.lang.String |
DnsNameResolverContext.decodeDomainName(ByteBuf in) |