| Package | Description |
|---|---|
| org.jboss.netty.buffer |
Abstraction of a byte buffer - the fundamental data structure
to represent a low-level binary and text message.
|
| org.jboss.netty.channel.socket.http |
An HTTP-based client-side
SocketChannel
and its corresponding server-side Servlet implementation that make your
existing server application work in a firewalled network. |
| org.jboss.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
| org.jboss.netty.example.discard | |
| org.jboss.netty.example.echo | |
| org.jboss.netty.example.factorial | |
| org.jboss.netty.example.http.websocketx.server |
This package contains an example web socket web server.
|
| org.jboss.netty.example.portunification | |
| org.jboss.netty.handler.codec.base64 |
Encoder and decoder which transform a
Base64-encoded
String or ChannelBuffer
into a decoded ChannelBuffer and vice versa. |
| org.jboss.netty.handler.codec.compression |
Encoder and decoder which compresses and decompresses
ChannelBuffers
in a compression format such as zlib
and gzip. |
| org.jboss.netty.handler.codec.frame |
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.
|
| org.jboss.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
| org.jboss.netty.handler.codec.http.multipart |
HTTP multipart support.
|
| org.jboss.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
| org.jboss.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
| org.jboss.netty.handler.codec.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message into a ChannelBuffer
and vice versa. |
| org.jboss.netty.handler.codec.replay |
Specialized variation of
FrameDecoder
which enables implementation of a non-blocking decoder in the blocking I/O
paradigm. |
| org.jboss.netty.handler.codec.rtsp |
An RTSP
extension based on the HTTP codec.
|
| org.jboss.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
| org.jboss.netty.handler.codec.socks |
Encoder, decoder and their related message types for Socks.
|
| org.jboss.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
| org.jboss.netty.handler.logging |
Logs a
ChannelEvent for debugging purpose
using an InternalLogger. |
| org.jboss.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
| Modifier and Type | Interface and Description |
|---|---|
interface |
WrappedChannelBuffer
The common interface for buffer wrappers and derived buffers.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractChannelBuffer
A skeletal implementation of a buffer.
|
class |
BigEndianHeapChannelBuffer
A big-endian Java heap buffer.
|
class |
ByteBufferBackedChannelBuffer
A NIO
ByteBuffer based buffer. |
class |
CompositeChannelBuffer
A virtual buffer which shows multiple buffers as a single merged buffer.
|
class |
DuplicatedChannelBuffer
A derived buffer which simply forwards all data access requests to its
parent.
|
class |
DynamicChannelBuffer
A dynamic capacity buffer which increases its capacity as needed.
|
class |
EmptyChannelBuffer
An immutable empty buffer implementation.
|
class |
HeapChannelBuffer
A skeletal implementation for Java heap buffers.
|
class |
LittleEndianHeapChannelBuffer
A little-endian Java heap buffer.
|
class |
ReadOnlyChannelBuffer
A derived buffer which forbids any write requests to its parent.
|
class |
SlicedChannelBuffer
A derived buffer which exposes its parent's sub-region only.
|
class |
TruncatedChannelBuffer
A derived buffer which hides its parent's tail data beyond a certain index.
|
| Modifier and Type | Field and Description |
|---|---|
private ChannelBuffer |
ChannelBufferInputStream.buffer |
private ChannelBuffer |
ChannelBufferOutputStream.buffer |
private ChannelBuffer |
DuplicatedChannelBuffer.buffer |
private ChannelBuffer |
DynamicChannelBuffer.buffer |
private ChannelBuffer |
ReadOnlyChannelBuffer.buffer |
private ChannelBuffer |
SlicedChannelBuffer.buffer |
private ChannelBuffer |
TruncatedChannelBuffer.buffer |
private ChannelBuffer[] |
CompositeChannelBuffer.components |
static ChannelBuffer |
ChannelBuffers.EMPTY_BUFFER
A buffer whose capacity is
0. |
private ChannelBuffer |
DirectChannelBufferFactory.preallocatedBEBuf |
private ChannelBuffer |
DirectChannelBufferFactory.preallocatedLEBuf |
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
DirectChannelBufferFactory.allocateBigEndianBuffer(int capacity) |
private ChannelBuffer |
DirectChannelBufferFactory.allocateLittleEndianBuffer(int capacity) |
ChannelBuffer |
ChannelBufferOutputStream.buffer()
Returns the buffer where this stream is writing data.
|
static ChannelBuffer |
ChannelBuffers.buffer(java.nio.ByteOrder endianness,
int capacity)
Creates a new Java heap buffer with the specified
endianness
and capacity. |
static ChannelBuffer |
ChannelBuffers.buffer(int capacity)
Creates a new big-endian Java heap buffer with the specified
capacity. |
private static ChannelBuffer |
ChannelBuffers.compositeBuffer(java.nio.ByteOrder endianness,
java.util.List<ChannelBuffer> components,
boolean gathering) |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(byte[]... arrays)
Creates a new big-endian buffer whose content is a merged copy of
the specified
arrays. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(byte[] array)
Creates a new big-endian buffer whose content is a copy of the
specified
array. |
static ChannelBuffer |
ChannelBuffers.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 ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteBuffer... buffers)
Creates a new buffer whose content is a merged copy of the specified
buffers' slices. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteBuffer buffer)
Creates a new buffer whose content is a copy of the specified
buffer's current slice. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
byte[]... arrays)
Creates a new buffer with the specified
endianness whose
content is a merged copy of the specified arrays. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
byte[] array)
Creates a new buffer with the specified
endianness whose
content is a copy of the specified array. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
byte[] array,
int offset,
int length)
Creates a new buffer with the specified
endianness whose
content is a copy of the specified array's sub-region. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
char[] array,
java.nio.charset.Charset charset)
Creates a new buffer with the specified
endianness whose
content is the specified array encoded in the specified
charset. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
char[] array,
int offset,
int length,
java.nio.charset.Charset charset)
Creates a new buffer with the specified
endianness whose
content is a subregion of the specified array encoded in the
specified charset. |
private static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
java.nio.CharBuffer buffer,
java.nio.charset.Charset charset) |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
java.lang.CharSequence string,
java.nio.charset.Charset charset)
Creates a new buffer with the specified
endianness whose
content is the specified string encoded in the specified
charset. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteOrder endianness,
java.lang.CharSequence string,
int offset,
int length,
java.nio.charset.Charset charset)
Creates a new buffer with the specified
endianness whose
content is a subregion of the specified string encoded in the
specified charset. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(ChannelBuffer... buffers)
Creates a new buffer whose content is a merged copy of the specified
buffers' readable bytes. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(ChannelBuffer buffer)
Creates a new buffer whose content is a copy of the specified
buffer's readable bytes. |
static ChannelBuffer |
ChannelBuffers.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 ChannelBuffer |
ChannelBuffers.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. |
static ChannelBuffer |
ChannelBuffers.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 ChannelBuffer |
ChannelBuffers.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. |
ChannelBuffer |
AbstractChannelBuffer.copy() |
ChannelBuffer |
ChannelBuffer.copy()
Returns a copy of this buffer's readable bytes.
|
ChannelBuffer |
BigEndianHeapChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
ByteBufferBackedChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
ChannelBuffer.copy(int index,
int length)
Returns a copy of this buffer's sub-region.
|
ChannelBuffer |
CompositeChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
DuplicatedChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
DynamicChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
LittleEndianHeapChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
ReadOnlyChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
SlicedChannelBuffer.copy(int index,
int length) |
ChannelBuffer |
TruncatedChannelBuffer.copy(int index,
int length) |
static ChannelBuffer |
ChannelBuffers.directBuffer(java.nio.ByteOrder endianness,
int capacity)
Creates a new direct buffer with the specified
endianness and
capacity. |
static ChannelBuffer |
ChannelBuffers.directBuffer(int capacity)
Creates a new big-endian direct buffer with the specified
capacity. |
ChannelBuffer |
BigEndianHeapChannelBuffer.duplicate() |
ChannelBuffer |
ByteBufferBackedChannelBuffer.duplicate() |
ChannelBuffer |
ChannelBuffer.duplicate()
Returns a buffer which shares the whole region of this buffer.
|
ChannelBuffer |
CompositeChannelBuffer.duplicate() |
ChannelBuffer |
DuplicatedChannelBuffer.duplicate() |
ChannelBuffer |
DynamicChannelBuffer.duplicate() |
ChannelBuffer |
LittleEndianHeapChannelBuffer.duplicate() |
ChannelBuffer |
ReadOnlyChannelBuffer.duplicate() |
ChannelBuffer |
SlicedChannelBuffer.duplicate() |
ChannelBuffer |
TruncatedChannelBuffer.duplicate() |
static ChannelBuffer |
ChannelBuffers.dynamicBuffer()
Creates a new big-endian dynamic buffer whose estimated data length is
256 bytes. |
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(java.nio.ByteOrder endianness,
int estimatedLength)
Creates a new dynamic buffer with the specified endianness and
the specified estimated data length.
|
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(java.nio.ByteOrder endianness,
int estimatedLength,
ChannelBufferFactory factory)
Creates a new dynamic buffer with the specified endianness and
the specified estimated data length using the specified factory.
|
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(ChannelBufferFactory factory) |
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(int estimatedLength)
Creates a new big-endian dynamic buffer with the specified estimated
data length.
|
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(int estimatedLength,
ChannelBufferFactory factory)
Creates a new big-endian dynamic buffer with the specified estimated
data length using the specified factory.
|
ChannelBuffer |
AbstractChannelBufferFactory.getBuffer(byte[] array,
int offset,
int length) |
ChannelBuffer |
ChannelBufferFactory.getBuffer(byte[] array,
int offset,
int length)
Returns a
ChannelBuffer whose content is equal to the sub-region
of the specified array. |
ChannelBuffer |
ChannelBufferFactory.getBuffer(java.nio.ByteBuffer nioBuffer)
Returns a
ChannelBuffer whose content is equal to the sub-region
of the specified nioBuffer. |
ChannelBuffer |
DirectChannelBufferFactory.getBuffer(java.nio.ByteBuffer nioBuffer) |
ChannelBuffer |
HeapChannelBufferFactory.getBuffer(java.nio.ByteBuffer nioBuffer) |
ChannelBuffer |
ChannelBufferFactory.getBuffer(java.nio.ByteOrder endianness,
byte[] array,
int offset,
int length)
Returns a
ChannelBuffer whose content is equal to the sub-region
of the specified array. |
ChannelBuffer |
DirectChannelBufferFactory.getBuffer(java.nio.ByteOrder order,
byte[] array,
int offset,
int length) |
ChannelBuffer |
HeapChannelBufferFactory.getBuffer(java.nio.ByteOrder order,
byte[] array,
int offset,
int length) |
ChannelBuffer |
ChannelBufferFactory.getBuffer(java.nio.ByteOrder endianness,
int capacity)
|
ChannelBuffer |
DirectChannelBufferFactory.getBuffer(java.nio.ByteOrder order,
int capacity) |
ChannelBuffer |
HeapChannelBufferFactory.getBuffer(java.nio.ByteOrder order,
int capacity) |
ChannelBuffer |
AbstractChannelBufferFactory.getBuffer(int capacity) |
ChannelBuffer |
ChannelBufferFactory.getBuffer(int capacity)
Returns a
ChannelBuffer with the specified capacity. |
ChannelBuffer |
CompositeChannelBuffer.getBuffer(int index)
|
static ChannelBuffer |
ChannelBuffers.hexDump(java.lang.String hexString)
Create a
ChannelBuffer from the given hex dump |
ChannelBuffer |
AbstractChannelBuffer.readBytes(int length) |
ChannelBuffer |
ChannelBuffer.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). |
ChannelBuffer |
EmptyChannelBuffer.readBytes(int length) |
ChannelBuffer |
AbstractChannelBuffer.readSlice(int length) |
ChannelBuffer |
ChannelBuffer.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). |
ChannelBuffer |
EmptyChannelBuffer.readSlice(int length) |
ChannelBuffer |
AbstractChannelBuffer.slice() |
ChannelBuffer |
ChannelBuffer.slice()
Returns a slice of this buffer's readable bytes.
|
ChannelBuffer |
ByteBufferBackedChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
ChannelBuffer.slice(int index,
int length)
Returns a slice of this buffer's sub-region.
|
ChannelBuffer |
CompositeChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
DuplicatedChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
DynamicChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
HeapChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
ReadOnlyChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
SlicedChannelBuffer.slice(int index,
int length) |
ChannelBuffer |
TruncatedChannelBuffer.slice(int index,
int length) |
static ChannelBuffer |
ChannelBuffers.unmodifiableBuffer(ChannelBuffer buffer)
Creates a read-only buffer which disallows any modification operations
on the specified
buffer. |
ChannelBuffer |
DuplicatedChannelBuffer.unwrap() |
ChannelBuffer |
ReadOnlyChannelBuffer.unwrap() |
ChannelBuffer |
SlicedChannelBuffer.unwrap() |
ChannelBuffer |
TruncatedChannelBuffer.unwrap() |
ChannelBuffer |
WrappedChannelBuffer.unwrap()
Returns this buffer's parent that this buffer is wrapping.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(boolean gathering,
java.nio.ByteBuffer... buffers)
Creates a new composite buffer which wraps the slices of the specified
NIO buffers without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(boolean gathering,
ChannelBuffer... buffers)
Creates a new composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(byte[]... arrays)
Creates a new big-endian composite buffer which wraps the specified
arrays without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(byte[] array)
Creates a new big-endian buffer which wraps the specified
array. |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(byte[] array,
int offset,
int length)
Creates a new big-endian buffer which wraps the sub-region of the
specified
array. |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(java.nio.ByteBuffer... buffers)
Creates a new composite buffer which wraps the slices of the specified
NIO buffers without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(java.nio.ByteBuffer buffer)
Creates a new buffer which wraps the specified NIO buffer's current
slice.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(java.nio.ByteOrder endianness,
byte[]... arrays)
Creates a new composite buffer which wraps the specified arrays without
copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(java.nio.ByteOrder endianness,
byte[] array)
Creates a new buffer which wraps the specified
array with the
specified endianness. |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(java.nio.ByteOrder endianness,
byte[] array,
int offset,
int length)
Creates a new buffer which wraps the sub-region of the specified
array with the specified endianness. |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(ChannelBuffer... buffers)
Creates a new composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(ChannelBuffer buffer)
Creates a new buffer which wraps the specified buffer's readable bytes.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ChannelBuffer> |
CompositeChannelBuffer.decompose(int index,
int length)
Same with
CompositeChannelBuffer.slice(int, int) except that this method returns a list. |
| Modifier and Type | Method and Description |
|---|---|
static int |
ChannelBuffers.compare(ChannelBuffer bufferA,
ChannelBuffer bufferB)
Compares the two specified buffers as described in
compareTo(ChannelBuffer). |
int |
AbstractChannelBuffer.compareTo(ChannelBuffer that) |
int |
ChannelBuffer.compareTo(ChannelBuffer buffer)
Compares the content of the specified buffer to the content of this
buffer.
|
static ChannelBuffer |
ChannelBuffers.copiedBuffer(ChannelBuffer... buffers)
Creates a new buffer whose content is a merged copy of the specified
buffers' readable bytes. |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(ChannelBuffer buffer)
Creates a new buffer whose content is a copy of the specified
buffer's readable bytes. |
private void |
CompositeChannelBuffer.copyTo(int index,
int length,
int componentId,
ChannelBuffer dst) |
static boolean |
ChannelBuffers.equals(ChannelBuffer bufferA,
ChannelBuffer bufferB)
Returns
true if and only if the two specified buffers are
identical to each other as described in ChannelBuffer#equals(Object). |
boolean |
ChannelBufferIndexFinder.find(ChannelBuffer buffer,
int guessedIndex)
Returns
true if and only if the data is found at the specified
guessedIndex of the specified buffer. |
private static int |
ChannelBuffers.firstIndexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
byte value) |
private static int |
ChannelBuffers.firstIndexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
ChannelBufferIndexFinder indexFinder) |
void |
AbstractChannelBuffer.getBytes(int index,
ChannelBuffer dst) |
void |
ChannelBuffer.getBytes(int index,
ChannelBuffer dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination becomes
non-writable. |
void |
AbstractChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int length) |
void |
ChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index. |
void |
ByteBufferBackedChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
ChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index. |
void |
CompositeChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
DuplicatedChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
DynamicChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
HeapChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
ReadOnlyChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
SlicedChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
TruncatedChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
static int |
ChannelBuffers.hashCode(ChannelBuffer buffer)
Calculates the hash code of the specified buffer.
|
static java.lang.String |
ChannelBuffers.hexDump(ChannelBuffer buffer)
Returns a hex dump
of the specified buffer's readable bytes.
|
static java.lang.String |
ChannelBuffers.hexDump(ChannelBuffer buffer,
int fromIndex,
int length)
Returns a hex dump
of the specified buffer's sub-region.
|
static int |
ChannelBuffers.indexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
byte value)
The default implementation of
indexOf(int, int, byte). |
static int |
ChannelBuffers.indexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
ChannelBufferIndexFinder indexFinder)
The default implementation of
indexOf(int, int, ChannelBufferIndexFinder). |
private static int |
ChannelBuffers.lastIndexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
byte value) |
private static int |
ChannelBuffers.lastIndexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
ChannelBufferIndexFinder indexFinder) |
void |
AbstractChannelBuffer.readBytes(ChannelBuffer dst) |
void |
ChannelBuffer.readBytes(ChannelBuffer 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. |
void |
EmptyChannelBuffer.readBytes(ChannelBuffer dst) |
void |
AbstractChannelBuffer.readBytes(ChannelBuffer dst,
int length) |
void |
ChannelBuffer.readBytes(ChannelBuffer 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). |
void |
EmptyChannelBuffer.readBytes(ChannelBuffer dst,
int length) |
void |
AbstractChannelBuffer.readBytes(ChannelBuffer dst,
int dstIndex,
int length) |
void |
ChannelBuffer.readBytes(ChannelBuffer 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). |
void |
EmptyChannelBuffer.readBytes(ChannelBuffer dst,
int dstIndex,
int length) |
void |
AbstractChannelBuffer.setBytes(int index,
ChannelBuffer src) |
void |
ChannelBuffer.setBytes(int index,
ChannelBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the source buffer becomes
unreadable. |
void |
AbstractChannelBuffer.setBytes(int index,
ChannelBuffer src,
int length) |
void |
ChannelBuffer.setBytes(int index,
ChannelBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index. |
void |
ByteBufferBackedChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
ChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index. |
void |
CompositeChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
DuplicatedChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
DynamicChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
HeapChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
ReadOnlyChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
SlicedChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
TruncatedChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
static ChannelBuffer |
ChannelBuffers.unmodifiableBuffer(ChannelBuffer buffer)
Creates a read-only buffer which disallows any modification operations
on the specified
buffer. |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(boolean gathering,
ChannelBuffer... buffers)
Creates a new composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(ChannelBuffer... buffers)
Creates a new composite buffer which wraps the readable bytes of the
specified buffers without copying them.
|
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(ChannelBuffer buffer)
Creates a new buffer which wraps the specified buffer's readable bytes.
|
void |
AbstractChannelBuffer.writeBytes(ChannelBuffer src) |
void |
ChannelBuffer.writeBytes(ChannelBuffer 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. |
void |
AbstractChannelBuffer.writeBytes(ChannelBuffer src,
int length) |
void |
ChannelBuffer.writeBytes(ChannelBuffer 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). |
void |
EmptyChannelBuffer.writeBytes(ChannelBuffer src,
int length) |
void |
AbstractChannelBuffer.writeBytes(ChannelBuffer src,
int srcIndex,
int length) |
void |
ChannelBuffer.writeBytes(ChannelBuffer 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). |
void |
DynamicChannelBuffer.writeBytes(ChannelBuffer src,
int srcIndex,
int length) |
void |
EmptyChannelBuffer.writeBytes(ChannelBuffer src,
int srcIndex,
int length) |
| Modifier and Type | Method and Description |
|---|---|
private static ChannelBuffer |
ChannelBuffers.compositeBuffer(java.nio.ByteOrder endianness,
java.util.List<ChannelBuffer> components,
boolean gathering) |
private void |
CompositeChannelBuffer.setComponents(java.util.List<ChannelBuffer> newComponents)
Setup this ChannelBuffer from the list
|
| Constructor and Description |
|---|
ChannelBufferInputStream(ChannelBuffer buffer)
Creates a new stream which reads data from the specified
buffer
starting at the current readerIndex and ending at the current
writerIndex. |
ChannelBufferInputStream(ChannelBuffer buffer,
int length)
Creates a new stream which reads data from the specified
buffer
starting at the current readerIndex and ending at
readerIndex + length. |
ChannelBufferOutputStream(ChannelBuffer buffer)
Creates a new stream which writes data to the specified
buffer. |
DuplicatedChannelBuffer(ChannelBuffer buffer) |
ReadOnlyChannelBuffer(ChannelBuffer buffer) |
SlicedChannelBuffer(ChannelBuffer buffer,
int index,
int length) |
TruncatedChannelBuffer(ChannelBuffer buffer,
int length) |
| Constructor and Description |
|---|
CompositeChannelBuffer(java.nio.ByteOrder endianness,
java.util.List<ChannelBuffer> buffers,
boolean gathering) |
| Modifier and Type | Method and Description |
|---|---|
private static ChannelBuffer |
HttpTunnelingServlet.read(java.io.PushbackInputStream in) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
HttpTunnelingClientSocketChannel.writeReal(ChannelBuffer a,
ChannelFuture future) |
| Modifier and Type | Method and Description |
|---|---|
private SocketSendBufferPool.SendBuffer |
SocketSendBufferPool.acquire(ChannelBuffer src) |
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
DiscardClientHandler.nextMessage() |
| Modifier and Type | Field and Description |
|---|---|
private ChannelBuffer |
EchoClientHandler.firstMessage |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
BigIntegerDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
static ChannelBuffer |
WebSocketServerIndexPage.getContent(java.lang.String webSocketLocation) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
PortUnificationServerHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
private boolean |
PortUnificationServerHandler.isSsl(ChannelBuffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
static ChannelBuffer |
Base64.decode(ChannelBuffer src) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
ChannelBufferFactory bufferFactory) |
| Modifier and Type | Method and Description |
|---|---|
static ChannelBuffer |
Base64.decode(ChannelBuffer src) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.decode(ChannelBuffer src,
int off,
int len,
ChannelBufferFactory bufferFactory) |
private static int |
Base64.decode4to3(byte[] src,
int srcOffset,
ChannelBuffer dest,
int destOffset,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
boolean breakLines,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines,
Base64Dialect dialect,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
boolean breakLines,
ChannelBufferFactory bufferFactory) |
static ChannelBuffer |
Base64.encode(ChannelBuffer src,
int off,
int len,
ChannelBufferFactory bufferFactory) |
private static void |
Base64.encode3to4(ChannelBuffer src,
int srcOffset,
int numSigBytes,
ChannelBuffer dest,
int destOffset,
Base64Dialect dialect) |
| Modifier and Type | Method and Description |
|---|---|
private void |
JdkZlibEncoder.deflate(ChannelBuffer out) |
| Modifier and Type | Field and Description |
|---|---|
protected ChannelBuffer |
FrameDecoder.cumulation |
private ChannelBuffer[] |
DelimiterBasedFrameDecoder.delimiters |
| Modifier and Type | Method and Description |
|---|---|
protected ChannelBuffer |
FrameDecoder.appendToCumulation(ChannelBuffer input) |
protected ChannelBuffer |
FrameDecoder.extractFrame(ChannelBuffer buffer,
int index,
int length)
Extract a Frame of the specified buffer.
|
protected ChannelBuffer |
FrameDecoder.internalBuffer()
Returns the internal cumulative buffer of this decoder.
|
static ChannelBuffer[] |
Delimiters.lineDelimiter()
Returns
CR ('\r') and LF ('\n') delimiters, which could
be used for text-based line protocols. |
protected ChannelBuffer |
FixedLengthFrameDecoder.newCumulationBuffer(ChannelHandlerContext ctx,
int minimumCapacity) |
protected ChannelBuffer |
FrameDecoder.newCumulationBuffer(ChannelHandlerContext ctx,
int minimumCapacity)
Create a new
ChannelBuffer which is used for the cumulation. |
static ChannelBuffer[] |
Delimiters.nulDelimiter()
Returns a
NUL (0x00) delimiter, which could be used for
Flash XML socket or any similar protocols. |
protected ChannelBuffer |
FrameDecoder.updateCumulation(ChannelHandlerContext ctx,
ChannelBuffer input) |
| Modifier and Type | Method and Description |
|---|---|
protected ChannelBuffer |
FrameDecoder.appendToCumulation(ChannelBuffer input) |
private void |
FrameDecoder.callDecode(ChannelHandlerContext context,
Channel channel,
ChannelBuffer cumulation,
java.net.SocketAddress remoteAddress) |
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected abstract java.lang.Object |
FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received packets so far into a frame.
|
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
FrameDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received data so far into a frame when the channel is
disconnected.
|
protected ChannelBuffer |
FrameDecoder.extractFrame(ChannelBuffer buffer,
int index,
int length)
Extract a Frame of the specified buffer.
|
private static int |
LineBasedFrameDecoder.findEndOfLine(ChannelBuffer buffer)
Returns the index in the buffer of the end of line found.
|
private static int |
DelimiterBasedFrameDecoder.indexOf(ChannelBuffer haystack,
ChannelBuffer 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(ChannelBuffer[] delimiters)
Returns true if the delimiters are "\n" and "\r\n".
|
protected ChannelBuffer |
FrameDecoder.updateCumulation(ChannelHandlerContext ctx,
ChannelBuffer input) |
private static void |
DelimiterBasedFrameDecoder.validateDelimiter(ChannelBuffer delimiter) |
| Constructor and Description |
|---|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
boolean failFast,
ChannelBuffer... delimiters)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
boolean failFast,
ChannelBuffer delimiter)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
ChannelBuffer... delimiters)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
boolean stripDelimiter,
ChannelBuffer delimiter)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
ChannelBuffer... delimiters)
Creates a new instance.
|
DelimiterBasedFrameDecoder(int maxFrameLength,
ChannelBuffer delimiter)
Creates a new instance.
|
| Modifier and Type | Field and Description |
|---|---|
private ChannelBuffer |
DefaultHttpChunk.content |
private ChannelBuffer |
DefaultHttpMessage.content |
private ChannelBuffer |
HttpMessageDecoder.content |
private static ChannelBuffer |
HttpChunkAggregator.CONTINUE |
private static ChannelBuffer |
HttpMessageEncoder.LAST_CHUNK |
| Modifier and Type | Field and Description |
|---|---|
private DecoderEmbedder<ChannelBuffer> |
HttpContentDecoder.decoder |
private EncoderEmbedder<ChannelBuffer> |
HttpContentEncoder.encoder |
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
HttpContentDecoder.decode(ChannelBuffer buf) |
private ChannelBuffer |
HttpContentEncoder.encode(ChannelBuffer buf) |
private ChannelBuffer |
HttpContentDecoder.finishDecode() |
private ChannelBuffer |
HttpContentEncoder.finishEncode() |
ChannelBuffer |
DefaultHttpChunk.getContent() |
ChannelBuffer |
DefaultHttpChunkTrailer.getContent() |
ChannelBuffer |
DefaultHttpMessage.getContent() |
ChannelBuffer |
HttpChunk.getContent()
Returns the content of this chunk.
|
ChannelBuffer |
HttpMessage.getContent()
Returns the content of this message.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract DecoderEmbedder<ChannelBuffer> |
HttpContentDecoder.newContentDecoder(java.lang.String contentEncoding)
Returns a new
DecoderEmbedder that decodes the HTTP message
content encoded in the specified contentEncoding. |
protected DecoderEmbedder<ChannelBuffer> |
HttpContentDecompressor.newContentDecoder(java.lang.String contentEncoding) |
protected EncoderEmbedder<ChannelBuffer> |
HttpContentCompressor.newContentEncoder(HttpMessage msg,
java.lang.String acceptEncoding) |
protected abstract EncoderEmbedder<ChannelBuffer> |
HttpContentEncoder.newContentEncoder(HttpMessage msg,
java.lang.String acceptEncoding)
Returns a new
EncoderEmbedder that encodes the HTTP message
content. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
HttpChunkAggregator.appendToCumulation(ChannelBuffer input) |
private ChannelBuffer |
HttpContentDecoder.decode(ChannelBuffer buf) |
protected java.lang.Object |
HttpClientCodec.Decoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected java.lang.Object |
HttpMessageDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
private ChannelBuffer |
HttpContentEncoder.encode(ChannelBuffer buf) |
protected static void |
HttpMessageEncoder.encodeAscii(java.lang.String s,
ChannelBuffer buf) |
private static void |
HttpMessageEncoder.encodeHeader(ChannelBuffer buf,
java.lang.String header,
java.lang.String value) |
private static void |
HttpMessageEncoder.encodeHeaders(ChannelBuffer buf,
HttpMessage message) |
protected abstract void |
HttpMessageEncoder.encodeInitialLine(ChannelBuffer buf,
HttpMessage message) |
protected void |
HttpRequestEncoder.encodeInitialLine(ChannelBuffer buf,
HttpMessage message) |
protected void |
HttpResponseEncoder.encodeInitialLine(ChannelBuffer buf,
HttpMessage message) |
private static void |
HttpMessageEncoder.encodeTrailingHeaders(ChannelBuffer buf,
HttpChunkTrailer trailer) |
private java.lang.Object |
HttpMessageDecoder.readFixedLengthContent(ChannelBuffer buffer) |
private java.lang.String |
HttpMessageDecoder.readHeader(ChannelBuffer buffer) |
private HttpMessageDecoder.State |
HttpMessageDecoder.readHeaders(ChannelBuffer buffer) |
private static java.lang.String |
HttpMessageDecoder.readLine(ChannelBuffer buffer,
int maxLineLength) |
private HttpChunkTrailer |
HttpMessageDecoder.readTrailingHeaders(ChannelBuffer buffer) |
void |
DefaultHttpChunk.setContent(ChannelBuffer content) |
void |
DefaultHttpChunkTrailer.setContent(ChannelBuffer content) |
void |
DefaultHttpMessage.setContent(ChannelBuffer content) |
void |
HttpChunk.setContent(ChannelBuffer content)
Sets the content of this chunk.
|
void |
HttpMessage.setContent(ChannelBuffer content)
Sets the content of this message.
|
private static void |
HttpMessageDecoder.skipControlCharacters(ChannelBuffer buffer) |
| Constructor and Description |
|---|
DefaultHttpChunk(ChannelBuffer content)
Creates a new instance with the specified chunk content.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) ChannelBuffer |
HttpPostBodyUtil.SeekAheadOptimize.buffer |
private ChannelBuffer |
AbstractMemoryHttpData.channelBuffer |
private ChannelBuffer |
HttpPostRequestEncoder.currentBuffer
The ChannelBuffer currently used by the encoder
|
private ChannelBuffer |
HttpPostMultipartRequestDecoder.undecodedChunk
The current channelBuffer
|
private ChannelBuffer |
HttpPostStandardRequestDecoder.undecodedChunk
The current channelBuffer
|
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
HttpPostRequestEncoder.fillChannelBuffer() |
ChannelBuffer |
AbstractDiskHttpData.getChannelBuffer() |
ChannelBuffer |
AbstractMemoryHttpData.getChannelBuffer()
Utility to go from a In Memory FileUpload
to a Disk (or another implementation) FileUpload
|
ChannelBuffer |
HttpData.getChannelBuffer()
Returns the content of the file item as a ChannelBuffer
|
ChannelBuffer |
MixedAttribute.getChannelBuffer() |
ChannelBuffer |
MixedFileUpload.getChannelBuffer() |
ChannelBuffer |
AbstractDiskHttpData.getChunk(int length) |
ChannelBuffer |
AbstractMemoryHttpData.getChunk(int length) |
ChannelBuffer |
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.
|
ChannelBuffer |
MixedAttribute.getChunk(int length) |
ChannelBuffer |
MixedFileUpload.getChunk(int length) |
ChannelBuffer |
InternalAttribute.toChannelBuffer() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractDiskHttpData.addContent(ChannelBuffer buffer,
boolean last) |
void |
AbstractMemoryHttpData.addContent(ChannelBuffer buffer,
boolean last) |
void |
DiskAttribute.addContent(ChannelBuffer buffer,
boolean last) |
void |
HttpData.addContent(ChannelBuffer buffer,
boolean last)
Add the content from the ChannelBuffer
|
void |
MemoryAttribute.addContent(ChannelBuffer buffer,
boolean last) |
void |
MixedAttribute.addContent(ChannelBuffer buffer,
boolean last) |
void |
MixedFileUpload.addContent(ChannelBuffer buffer,
boolean last) |
void |
AbstractDiskHttpData.setContent(ChannelBuffer buffer) |
void |
AbstractMemoryHttpData.setContent(ChannelBuffer buffer) |
void |
HttpData.setContent(ChannelBuffer buffer)
Set the content from the ChannelBuffer (erase any previous data)
|
void |
MixedAttribute.setContent(ChannelBuffer buffer) |
void |
MixedFileUpload.setContent(ChannelBuffer buffer) |
private void |
HttpPostStandardRequestDecoder.setFinalBuffer(ChannelBuffer buffer) |
| Constructor and Description |
|---|
SeekAheadOptimize(ChannelBuffer buffer) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelBuffer |
WebSocketFrame.binaryData
Contents of this frame
|
private ChannelBuffer |
WebSocketClientHandshaker00.expectedChallengeResponseBytes |
private ChannelBuffer |
WebSocket08FrameDecoder.framePayload |
private ChannelBuffer |
WebSocket08FrameDecoder.maskingKey |
| Modifier and Type | Method and Description |
|---|---|
ChannelBuffer |
WebSocketFrame.getBinaryData()
Returns binary data
|
(package private) static ChannelBuffer |
WebSocketUtil.md5(ChannelBuffer buffer)
Performs an MD5 hash
|
(package private) static ChannelBuffer |
WebSocketUtil.sha1(ChannelBuffer buffer)
Performs an SHA-1 hash
|
| Modifier and Type | Method and Description |
|---|---|
(package private) static java.lang.String |
WebSocketUtil.base64(ChannelBuffer buffer)
Base 64 encoding
|
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected java.lang.Object |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
WebSocket08FrameDecoder.State state) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeBinaryFrame(byte type,
ChannelBuffer buffer) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeTextFrame(ChannelBuffer buffer) |
(package private) static ChannelBuffer |
WebSocketUtil.md5(ChannelBuffer buffer)
Performs an MD5 hash
|
void |
WebSocketFrame.setBinaryData(ChannelBuffer binaryData)
Sets the binary data for this frame
|
(package private) static ChannelBuffer |
WebSocketUtil.sha1(ChannelBuffer buffer)
Performs an SHA-1 hash
|
private void |
WebSocket08FrameDecoder.unmask(ChannelBuffer frame) |
| Constructor and Description |
|---|
BinaryWebSocketFrame(boolean finalFragment,
int rsv,
ChannelBuffer binaryData)
Creates a new binary frame with the specified binary data and the final fragment flag.
|
BinaryWebSocketFrame(ChannelBuffer binaryData)
Creates a new binary frame with the specified binary data.
|
CloseWebSocketFrame(boolean finalFragment,
int rsv,
ChannelBuffer binaryData)
Creates a new close frame
|
ContinuationWebSocketFrame(boolean finalFragment,
int rsv,
ChannelBuffer binaryData)
Creates a new continuation frame with the specified binary data
|
ContinuationWebSocketFrame(ChannelBuffer binaryData)
Creates a new continuation frame with the specified binary data.
|
PingWebSocketFrame(boolean finalFragment,
int rsv,
ChannelBuffer binaryData)
Creates a new ping frame with the specified binary data
|
PingWebSocketFrame(ChannelBuffer binaryData)
Creates a new ping frame with the specified binary data.
|
PongWebSocketFrame(boolean finalFragment,
int rsv,
ChannelBuffer binaryData)
Creates a new pong frame with the specified binary data
|
PongWebSocketFrame(ChannelBuffer binaryData)
Creates a new pong frame with the specified binary data.
|
TextWebSocketFrame(boolean finalFragment,
int rsv,
ChannelBuffer binaryData)
Creates a new text frame with the specified binary data.
|
TextWebSocketFrame(ChannelBuffer binaryData)
Creates a new text frame with the specified binary data.
|
| Modifier and Type | Field and Description |
|---|---|
private ChannelBuffer |
ChannelBufferByteInput.buffer |
private ChannelBuffer |
ChannelBufferByteOutput.buffer |
| Modifier and Type | Method and Description |
|---|---|
protected ChannelBuffer |
MarshallingDecoder.extractFrame(ChannelBuffer buffer,
int index,
int length) |
ChannelBuffer |
ChannelBufferByteOutput.getBuffer()
Return the
ChannelBuffer which contains the written content |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected java.lang.Object |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected ChannelBuffer |
MarshallingDecoder.extractFrame(ChannelBuffer buffer,
int index,
int length) |
| Constructor and Description |
|---|
ChannelBufferByteInput(ChannelBuffer buffer) |
ChannelBufferByteOutput(ChannelBuffer buffer)
Create a new instance which use the given
ChannelBuffer |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
ReplayingDecoderBuffer |
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
ReplayingDecoderBuffer.buf() |
ChannelBuffer |
ReplayingDecoderBuffer.copy() |
ChannelBuffer |
ReplayingDecoderBuffer.copy(int index,
int length) |
ChannelBuffer |
ReplayingDecoderBuffer.duplicate() |
protected ChannelBuffer |
ReplayingDecoder.internalBuffer() |
ChannelBuffer |
ReplayingDecoderBuffer.readBytes(int length) |
ChannelBuffer |
ReplayingDecoderBuffer.readSlice(int length) |
ChannelBuffer |
ReplayingDecoderBuffer.slice() |
ChannelBuffer |
ReplayingDecoderBuffer.slice(int index,
int length) |
| Modifier and Type | Method and Description |
|---|---|
private void |
ReplayingDecoder.callDecode(ChannelHandlerContext context,
Channel channel,
ChannelBuffer input,
ChannelBuffer replayableInput,
java.net.SocketAddress remoteAddress) |
int |
ReplayingDecoderBuffer.compareTo(ChannelBuffer buffer) |
protected java.lang.Object |
ReplayingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
|
protected abstract java.lang.Object |
ReplayingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
T state)
Decodes the received packets so far into a frame.
|
protected java.lang.Object |
ReplayingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
ReplayingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
T state)
Decodes the received data so far into a frame when the channel is
disconnected.
|
void |
ReplayingDecoderBuffer.getBytes(int index,
ChannelBuffer dst) |
void |
ReplayingDecoderBuffer.getBytes(int index,
ChannelBuffer dst,
int length) |
void |
ReplayingDecoderBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length) |
void |
ReplayingDecoderBuffer.readBytes(ChannelBuffer dst) |
void |
ReplayingDecoderBuffer.readBytes(ChannelBuffer dst,
int length) |
void |
ReplayingDecoderBuffer.readBytes(ChannelBuffer dst,
int dstIndex,
int length) |
void |
ReplayingDecoderBuffer.setBytes(int index,
ChannelBuffer src) |
void |
ReplayingDecoderBuffer.setBytes(int index,
ChannelBuffer src,
int length) |
void |
ReplayingDecoderBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length) |
void |
ReplayingDecoderBuffer.writeBytes(ChannelBuffer src) |
void |
ReplayingDecoderBuffer.writeBytes(ChannelBuffer src,
int length) |
void |
ReplayingDecoderBuffer.writeBytes(ChannelBuffer src,
int srcIndex,
int length) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
RtspMessageDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected void |
RtspRequestEncoder.encodeInitialLine(ChannelBuffer buf,
HttpMessage message) |
protected void |
RtspResponseEncoder.encodeInitialLine(ChannelBuffer buf,
HttpMessage message) |
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.atomic.AtomicReference<ChannelBuffer> |
CompatibleObjectEncoder.buffer |
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
CompatibleObjectEncoder.buffer(ChannelHandlerContext ctx) |
protected ChannelBuffer |
ObjectDecoder.extractFrame(ChannelBuffer buffer,
int index,
int length) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected ChannelBuffer |
ObjectDecoder.extractFrame(ChannelBuffer buffer,
int index,
int length) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksAuthRequestDecoder.State state) |
protected java.lang.Object |
SocksAuthResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksAuthResponseDecoder.State state) |
protected java.lang.Object |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksCmdRequestDecoder.State state) |
protected java.lang.Object |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksCmdResponseDecoder.State state) |
protected java.lang.Object |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksInitRequestDecoder.State state) |
protected java.lang.Object |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksInitResponseDecoder.State state) |
void |
SocksAuthRequest.encodeAsByteBuf(ChannelBuffer channelBuffer) |
void |
SocksAuthResponse.encodeAsByteBuf(ChannelBuffer channelBuffer) |
void |
SocksCmdRequest.encodeAsByteBuf(ChannelBuffer channelBuffer) |
void |
SocksCmdResponse.encodeAsByteBuf(ChannelBuffer channelBuffer) |
void |
SocksInitRequest.encodeAsByteBuf(ChannelBuffer channelBuffer) |
void |
SocksInitResponse.encodeAsByteBuf(ChannelBuffer channelBuffer) |
abstract void |
SocksMessage.encodeAsByteBuf(ChannelBuffer channelBuffer)
Encode socks message into its byte representation and write it into byteBuf
|
void |
UnknownSocksMessage.encodeAsByteBuf(ChannelBuffer byteBuf) |
void |
UnknownSocksRequest.encodeAsByteBuf(ChannelBuffer buffer) |
void |
UnknownSocksResponse.encodeAsByteBuf(ChannelBuffer buffer) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelBuffer |
SpdyHeaderBlockRawDecoder.cumulation |
private ChannelBuffer |
DefaultSpdyDataFrame.data |
private ChannelBuffer |
SpdyHeaderBlockZlibDecoder.decompressed |
| Modifier and Type | Method and Description |
|---|---|
(package private) abstract ChannelBuffer |
SpdyHeaderBlockEncoder.encode(SpdyHeadersFrame frame) |
ChannelBuffer |
SpdyHeaderBlockJZlibEncoder.encode(SpdyHeadersFrame frame) |
ChannelBuffer |
SpdyHeaderBlockRawEncoder.encode(SpdyHeadersFrame headerFrame) |
ChannelBuffer |
SpdyHeaderBlockZlibEncoder.encode(SpdyHeadersFrame frame) |
ChannelBuffer |
SpdyFrameEncoder.encodeDataFrame(int streamId,
boolean last,
ChannelBuffer data) |
ChannelBuffer |
SpdyFrameEncoder.encodeGoAwayFrame(int lastGoodStreamId,
int statusCode) |
ChannelBuffer |
SpdyFrameEncoder.encodeHeadersFrame(int streamId,
boolean last,
ChannelBuffer headerBlock) |
ChannelBuffer |
SpdyFrameEncoder.encodePingFrame(int id) |
ChannelBuffer |
SpdyFrameEncoder.encodeRstStreamFrame(int streamId,
int statusCode) |
ChannelBuffer |
SpdyFrameEncoder.encodeSettingsFrame(SpdySettingsFrame spdySettingsFrame) |
ChannelBuffer |
SpdyFrameEncoder.encodeSynReplyFrame(int streamId,
boolean last,
ChannelBuffer headerBlock) |
ChannelBuffer |
SpdyFrameEncoder.encodeSynStreamFrame(int streamId,
int associatedToStreamId,
byte priority,
boolean last,
boolean unidirectional,
ChannelBuffer headerBlock) |
ChannelBuffer |
SpdyFrameEncoder.encodeWindowUpdateFrame(int streamId,
int deltaWindowSize) |
ChannelBuffer |
DefaultSpdyDataFrame.getData() |
ChannelBuffer |
SpdyDataFrame.getData()
Returns the data payload of this frame.
|
| Modifier and Type | Method and Description |
|---|---|
private boolean |
SpdyHeaderBlockZlibEncoder.compressInto(ChannelBuffer compressed) |
private SpdyDataFrame[] |
SpdyHttpEncoder.createSpdyDataFrames(int streamId,
ChannelBuffer content) |
void |
SpdyFrameDecoder.decode(ChannelBuffer buffer) |
(package private) abstract void |
SpdyHeaderBlockDecoder.decode(ChannelBuffer headerBlock,
SpdyHeadersFrame frame)
Decodes a SPDY Header Block, adding the Name/Value pairs to the given Headers frame.
|
(package private) void |
SpdyHeaderBlockRawDecoder.decode(ChannelBuffer headerBlock,
SpdyHeadersFrame frame) |
(package private) void |
SpdyHeaderBlockZlibDecoder.decode(ChannelBuffer headerBlock,
SpdyHeadersFrame frame) |
protected java.lang.Object |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected void |
SpdyHeaderBlockRawDecoder.decodeHeaderBlock(ChannelBuffer headerBlock,
SpdyHeadersFrame frame) |
private void |
SpdyHeaderBlockJZlibEncoder.encode(ChannelBuffer compressed) |
private void |
SpdyHeaderBlockZlibEncoder.encode(ChannelBuffer compressed) |
ChannelBuffer |
SpdyFrameEncoder.encodeDataFrame(int streamId,
boolean last,
ChannelBuffer data) |
ChannelBuffer |
SpdyFrameEncoder.encodeHeadersFrame(int streamId,
boolean last,
ChannelBuffer headerBlock) |
ChannelBuffer |
SpdyFrameEncoder.encodeSynReplyFrame(int streamId,
boolean last,
ChannelBuffer headerBlock) |
ChannelBuffer |
SpdyFrameEncoder.encodeSynStreamFrame(int streamId,
int associatedToStreamId,
byte priority,
boolean last,
boolean unidirectional,
ChannelBuffer headerBlock) |
(package private) static int |
SpdyCodecUtil.getSignedInt(ChannelBuffer buf,
int offset)
Reads a big-endian signed integer from the buffer.
|
(package private) static int |
SpdyCodecUtil.getUnsignedInt(ChannelBuffer buf,
int offset)
Reads a big-endian (31-bit) integer from the buffer.
|
(package private) static int |
SpdyCodecUtil.getUnsignedMedium(ChannelBuffer buf,
int offset)
Reads a big-endian unsigned medium integer from the buffer.
|
(package private) static int |
SpdyCodecUtil.getUnsignedShort(ChannelBuffer buf,
int offset)
Reads a big-endian unsigned short integer from the buffer.
|
void |
SpdyFrameCodec.readDataFrame(int streamId,
boolean last,
ChannelBuffer data) |
void |
SpdyFrameDecoderDelegate.readDataFrame(int streamId,
boolean last,
ChannelBuffer data)
Called when a DATA frame is received.
|
void |
SpdyFrameCodec.readHeaderBlock(ChannelBuffer headerBlock) |
void |
SpdyFrameDecoderDelegate.readHeaderBlock(ChannelBuffer headerBlock)
Called when the header block within a SYN_STREAM, SYN_REPLY, or HEADERS frame is received.
|
private int |
SpdyHeaderBlockRawDecoder.readLengthField(ChannelBuffer buffer) |
void |
DefaultSpdyDataFrame.setData(ChannelBuffer data) |
void |
SpdyDataFrame.setData(ChannelBuffer data)
Sets the data payload of this frame.
|
private void |
SpdyHeaderBlockJZlibEncoder.setInput(ChannelBuffer decompressed) |
private int |
SpdyHeaderBlockZlibDecoder.setInput(ChannelBuffer compressed) |
private int |
SpdyHeaderBlockZlibEncoder.setInput(ChannelBuffer decompressed) |
private static void |
SpdyHeaderBlockRawEncoder.setLengthField(ChannelBuffer buffer,
int writerIndex,
int length) |
private void |
SpdyFrameEncoder.writeControlFrameHeader(ChannelBuffer buffer,
int type,
byte flags,
int length) |
private static void |
SpdyHeaderBlockRawEncoder.writeLengthField(ChannelBuffer buffer,
int length) |
| Modifier and Type | Method and Description |
|---|---|
private static java.lang.String |
LoggingHandler.formatBuffer(ChannelBuffer buf) |
| Modifier and Type | Method and Description |
|---|---|
(package private) static ChannelBuffer[] |
PemReader.readCertificates(java.io.File file) |
(package private) static ChannelBuffer |
PemReader.readPrivateKey(java.io.File file) |
private ChannelBuffer |
SslHandler.unwrap(ChannelHandlerContext ctx,
Channel channel,
java.nio.ByteBuffer nioInNetBuf,
int initialNettyOutAppBufCapacity,
boolean mightNeedHandshake)
Unwraps inbound SSL records.
|
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
SslHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer in) |
private static int |
SslHandler.getEncryptedPacketLength(ChannelBuffer buffer,
int offset)
Return how much bytes can be read out of the encrypted data.
|
private static short |
SslHandler.getShort(ChannelBuffer buf,
int offset)
Reads a big-endian short integer from the buffer.
|
static boolean |
SslHandler.isEncrypted(ChannelBuffer buffer)
Returns
true if the given ChannelBuffer is encrypted. |