Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.asReadOnlyBuffer()
Creates a new, read-only
Buffer that shares this buffer's
content. |
Buffer |
Buffer.clear()
Clears this buffer.
|
Buffer |
Buffer.compact()
Compacts this buffer (optional operation).
|
Buffer |
Buffer.duplicate()
Creates a new
Buffer that shares this buffer's content. |
Buffer |
Buffer.flip()
Flips this buffer.
|
Buffer |
Buffer.get(byte[] dst)
Relative bulk get method.
|
Buffer |
Buffer.get(byte[] dst,
int offset,
int length)
Relative bulk get method.
|
Buffer |
Buffer.get(ByteBuffer dst)
Relative bulk get method.
|
Buffer |
Buffer.get(ByteBuffer dst,
int offset,
int length)
Relative bulk get method.
|
Buffer |
Buffer.limit(int newLimit)
Sets this buffer's limit.
|
Buffer |
Buffer.mark()
Sets this buffer's mark at its position.
|
Buffer |
Buffer.order(ByteOrder bo)
Modifies this buffer's byte order.
|
Buffer |
Buffer.position(int newPosition)
Sets this buffer's position.
|
Buffer |
Buffer.prepend(Buffer header)
Prepend data from header.position() to header.limit() to the
current buffer.
|
Buffer |
Buffer.put(Buffer src)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(Buffer src,
int position,
int length)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(byte b)
Relative put method (optional operation).
|
Buffer |
Buffer.put(byte[] src)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(byte[] src,
int offset,
int length)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(ByteBuffer src)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(ByteBuffer src,
int position,
int length)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(int index,
byte b)
Absolute put method (optional operation).
|
Buffer |
Buffer.put8BitString(String s)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.putChar(char value)
Relative put method for writing a char
value (optional operation).
|
Buffer |
Buffer.putChar(int index,
char value)
Absolute put method for writing a char
value (optional operation).
|
Buffer |
Buffer.putDouble(double value)
Relative put method for writing a double
value (optional operation).
|
Buffer |
Buffer.putDouble(int index,
double value)
Absolute put method for writing a double
value (optional operation).
|
Buffer |
Buffer.putFloat(float value)
Relative put method for writing a float
value (optional operation).
|
Buffer |
Buffer.putFloat(int index,
float value)
Absolute put method for writing a float
value (optional operation).
|
Buffer |
Buffer.putInt(int value)
Relative put method for writing an int
value (optional operation).
|
Buffer |
Buffer.putInt(int index,
int value)
Absolute put method for writing an int
value (optional operation).
|
Buffer |
Buffer.putLong(int index,
long value)
Absolute put method for writing a long
value (optional operation).
|
Buffer |
Buffer.putLong(long value)
Relative put method for writing a long
value (optional operation).
|
Buffer |
Buffer.putShort(int index,
short value)
Absolute put method for writing a short
value (optional operation).
|
Buffer |
Buffer.putShort(short value)
Relative put method for writing a short
value (optional operation).
|
Buffer |
Buffer.reset()
Resets this buffer's position to the previously-marked position.
|
Buffer |
Buffer.rewind()
Rewinds this buffer.
|
Buffer |
Buffer.slice()
Creates a new
Buffer whose content is a shared subsequence
of this buffer's content. |
Buffer |
Buffer.slice(int position,
int limit)
Creates a new
Buffer whose content is a shared subsequence of
this buffer's content. |
Buffer |
Buffer.split(int splitPosition)
Split up the buffer into two parts: [0..splitPosition) and [splitPosition, capacity).
|
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection<L> connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionProbe.onReadEvent(Connection connection,
Buffer data,
int size)
Method will be called, when the
Connection has read data. |
void |
ConnectionProbe.Adapter.onReadEvent(Connection connection,
Buffer data,
int size)
Method will be called, when the
Connection has read data. |
void |
ConnectionProbe.onWriteEvent(Connection connection,
Buffer data,
long size)
Method will be called, when the
Connection has written data. |
void |
ConnectionProbe.Adapter.onWriteEvent(Connection connection,
Buffer data,
long size)
Method will be called, when the
Connection has written data. |
Buffer |
Buffer.prepend(Buffer header)
Prepend data from header.position() to header.limit() to the
current buffer.
|
Buffer |
Buffer.put(Buffer src)
Relative bulk put method (optional operation).
|
Buffer |
Buffer.put(Buffer src,
int position,
int length)
Relative bulk put method (optional operation).
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
AbstractReader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
Modifier and Type | Method and Description |
---|---|
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
AbstractReader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
Modifier and Type | Method and Description |
---|---|
static AsyncReadQueueRecord |
AsyncReadQueueRecord.create(Connection connection,
Buffer message,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
Modifier and Type | Method and Description |
---|---|
Buffer |
LZMAEncoder.LZMAOutputState.getDst() |
Buffer |
LZMADecoder.LZMAInputState.getDst() |
Buffer |
LZMAEncoder.LZMAOutputState.getSrc() |
Buffer |
LZMADecoder.LZMAInputState.getSrc() |
Modifier and Type | Method and Description |
---|---|
protected AbstractTransformer.LastResultAwareState<Buffer,Buffer> |
LZMAEncoder.createStateObject() |
protected AbstractTransformer.LastResultAwareState<Buffer,Buffer> |
LZMAEncoder.createStateObject() |
protected AbstractTransformer.LastResultAwareState<Buffer,Buffer> |
LZMADecoder.createStateObject() |
protected AbstractTransformer.LastResultAwareState<Buffer,Buffer> |
LZMADecoder.createStateObject() |
protected TransformationResult<Buffer,Buffer> |
LZMAEncoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
LZMAEncoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
LZMADecoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
LZMADecoder.transformImpl(AttributeStorage storage,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
boolean |
LZMAEncoder.hasInputRemaining(AttributeStorage storage,
Buffer input) |
boolean |
LZMADecoder.hasInputRemaining(AttributeStorage storage,
Buffer input) |
boolean |
LZMADecoder.LZMAInputState.initialize(Buffer buffer) |
void |
LZMAEncoder.LZMAOutputState.setDst(Buffer dst) |
void |
LZMADecoder.LZMAInputState.setDst(Buffer dst) |
void |
LZMAEncoder.LZMAOutputState.setSrc(Buffer src) |
void |
LZMADecoder.LZMAInputState.setSrc(Buffer src) |
protected TransformationResult<Buffer,Buffer> |
LZMAEncoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
LZMADecoder.transformImpl(AttributeStorage storage,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
void |
Encoder.writeCoderProperties(Buffer dst) |
Modifier and Type | Method and Description |
---|---|
void |
InWindow.setBuffer(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
RangeEncoder.releaseBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
RangeEncoder.setBuffer(Buffer dst,
MemoryManager mm) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
GZipEncoder.deflate(Deflater deflater,
MemoryManager memoryManager)
Writes next block of compressed data to the output stream.
|
Buffer |
GZipEncoder.finish(AttributeStorage storage)
Finishes to compress data to the output stream without closing
the underlying stream.
|
Modifier and Type | Method and Description |
---|---|
protected TransformationResult<Buffer,Buffer> |
GZipEncoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
GZipEncoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
GZipDecoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
GZipDecoder.transformImpl(AttributeStorage storage,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
boolean |
GZipEncoder.hasInputRemaining(AttributeStorage storage,
Buffer input) |
boolean |
GZipDecoder.hasInputRemaining(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
GZipEncoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
GZipDecoder.transformImpl(AttributeStorage storage,
Buffer input) |
Modifier and Type | Field and Description |
---|---|
protected Buffer |
HttpContent.content |
protected Buffer |
HttpContent.Builder.content |
Modifier and Type | Method and Description |
---|---|
Buffer |
Cookie.asClientCookieBuffer() |
Buffer |
Cookie.asClientCookieBuffer(MemoryManager memoryManager) |
Buffer |
Cookie.asServerCookieBuffer() |
Buffer |
Cookie.asServerCookieBuffer(MemoryManager memoryManager) |
protected Buffer |
HttpCodecFilter.encodeHttpPacket(FilterChainContext ctx,
HttpHeader httpHeader,
HttpContent httpContent,
boolean isContentAlreadyEncoded) |
protected Buffer |
HttpClientFilter.encodeHttpPacket(FilterChainContext ctx,
HttpPacket input) |
protected Buffer |
HttpServerFilter.encodeHttpPacket(FilterChainContext ctx,
HttpPacket input) |
protected Buffer |
HttpCodecFilter.encodeHttpPacket(FilterChainContext ctx,
HttpPacket input) |
protected static Buffer |
HttpCodecFilter.encodeKnownHeaders(MemoryManager memoryManager,
Buffer buffer,
HttpHeader httpHeader) |
protected static Buffer |
HttpCodecFilter.encodeMimeHeader(MemoryManager memoryManager,
Buffer buffer,
DataChunk name,
DataChunk value,
byte[] tempBuffer,
boolean encodeLastCRLF) |
protected static Buffer |
HttpCodecFilter.encodeMimeHeaders(MemoryManager memoryManager,
Buffer buffer,
MimeHeaders mimeHeaders,
byte[] tempEncodingBuffer) |
Buffer |
HttpBrokenContent.getContent()
Get the HTTP message content
Buffer . |
Buffer |
HttpContent.getContent()
Get the HTTP message content
Buffer . |
Buffer |
ParsingResult.getRemainderBuffer() |
Buffer |
FixedLengthTransferEncoding.serializePacket(FilterChainContext ctx,
HttpContent httpContent)
Serialize HTTP packet payload, represented by
HttpContent
using specific transfer encoding. |
Buffer |
TransferEncoding.serializePacket(FilterChainContext ctx,
HttpContent httpContent)
Serialize HTTP packet payload, represented by
HttpContent
using specific transfer encoding. |
Buffer |
ChunkedTransferEncoding.serializePacket(FilterChainContext ctx,
HttpContent httpContent)
Serialize HTTP packet payload, represented by
HttpContent
using specific transfer encoding. |
Modifier and Type | Method and Description |
---|---|
T |
HttpContent.Builder.content(Buffer content)
Set the HttpContent chunk content
Buffer . |
static ParsingResult |
ParsingResult.create(HttpContent httpContent,
Buffer remainderBuffer) |
static HttpContent |
HttpContent.create(HttpHeader httpHeader,
boolean isLast,
Buffer content) |
protected boolean |
HttpCodecFilter.decodeHttpPacket(FilterChainContext ctx,
HttpPacketParsing httpPacket,
Buffer input) |
protected boolean |
HttpCodecFilter.decodeHttpPacketFromBuffer(FilterChainContext ctx,
HttpPacketParsing httpPacket,
Buffer input) |
protected boolean |
HttpCodecFilter.decodeHttpPacketFromBytes(FilterChainContext ctx,
HttpPacketParsing httpPacket,
Buffer inputBuffer) |
protected static Buffer |
HttpCodecFilter.encodeKnownHeaders(MemoryManager memoryManager,
Buffer buffer,
HttpHeader httpHeader) |
protected static Buffer |
HttpCodecFilter.encodeMimeHeader(MemoryManager memoryManager,
Buffer buffer,
DataChunk name,
DataChunk value,
byte[] tempBuffer,
boolean encodeLastCRLF) |
protected static Buffer |
HttpCodecFilter.encodeMimeHeaders(MemoryManager memoryManager,
Buffer buffer,
MimeHeaders mimeHeaders,
byte[] tempEncodingBuffer) |
void |
HttpProbe.onContentEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onContentEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.onContentEncodingParseResultEvent(Connection connection,
HttpHeader header,
Buffer result,
ContentEncoding contentEncoding)
This method will be called after the
ContentEncoding has been
applied. |
void |
HttpProbe.Adapter.onContentEncodingParseResultEvent(Connection connection,
HttpHeader header,
Buffer result,
ContentEncoding contentEncoding)
This method will be called after the
ContentEncoding has been
applied. |
void |
HttpProbe.onContentEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
/**
Method will be called, when
ContentEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onContentEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
/**
Method will be called, when
ContentEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.onContentEncodingSerializeResultEvent(Connection connection,
HttpHeader header,
Buffer result,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onContentEncodingSerializeResultEvent(Connection connection,
HttpHeader header,
Buffer result,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.onDataReceivedEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer will come for processing to
the HttpCodecFilter (either request or response). |
void |
HttpProbe.Adapter.onDataReceivedEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer will come for processing to
the HttpCodecFilter (either request or response). |
void |
HttpProbe.onDataSentEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer , produced by the
HttpCodecFilter will be ready to go to the next
Filter in the chain and finally
written on wire. |
void |
HttpProbe.Adapter.onDataSentEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer , produced by the
HttpCodecFilter will be ready to go to the next
Filter in the chain and finally
written on wire. |
void |
HttpProbe.onHeaderSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer)
Method will be called, when HTTP message header gets serialized
(either request or response).
|
void |
HttpProbe.Adapter.onHeaderSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer)
Method will be called, when HTTP message header gets serialized
(either request or response).
|
protected boolean |
HttpClientFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx) |
protected boolean |
HttpServerFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx) |
protected abstract boolean |
HttpCodecFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx)
Callback invoked when the HTTP message header parsing is complete.
|
void |
HttpProbe.onTransferEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onTransferEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.onTransferEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onTransferEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
CookiesBuilder.ClientCookiesBuilder |
CookiesBuilder.ClientCookiesBuilder.parse(Buffer cookiesHeader) |
CookiesBuilder.ServerCookiesBuilder |
CookiesBuilder.ServerCookiesBuilder.parse(Buffer cookiesHeader) |
abstract E |
CookiesBuilder.AbstractCookiesBuilder.parse(Buffer cookiesHeader) |
CookiesBuilder.ClientCookiesBuilder |
CookiesBuilder.ClientCookiesBuilder.parse(Buffer cookiesHeader,
int position,
int limit) |
CookiesBuilder.ServerCookiesBuilder |
CookiesBuilder.ServerCookiesBuilder.parse(Buffer cookiesHeader,
int position,
int limit) |
abstract E |
CookiesBuilder.AbstractCookiesBuilder.parse(Buffer cookiesHeader,
int position,
int limit) |
protected static boolean |
HttpCodecFilter.parseHeaderFromBuffer(HttpHeader httpHeader,
MimeHeaders mimeHeaders,
HttpCodecFilter.HeaderParsingState parsingState,
Buffer input) |
protected static boolean |
HttpCodecFilter.parseHeaderName(HttpHeader httpHeader,
MimeHeaders mimeHeaders,
HttpCodecFilter.HeaderParsingState parsingState,
Buffer input) |
protected boolean |
HttpCodecFilter.parseHeadersFromBuffer(HttpHeader httpHeader,
MimeHeaders mimeHeaders,
HttpCodecFilter.HeaderParsingState parsingState,
Buffer input) |
protected static int |
HttpCodecFilter.parseHeaderValue(HttpHeader httpHeader,
HttpCodecFilter.HeaderParsingState parsingState,
Buffer input) |
ParsingResult |
FixedLengthTransferEncoding.parsePacket(FilterChainContext ctx,
HttpHeader httpPacket,
Buffer input)
Parse HTTP packet payload, represented by
Buffer using specific
transfer encoding. |
ParsingResult |
TransferEncoding.parsePacket(FilterChainContext ctx,
HttpHeader httpPacket,
Buffer buffer)
Parse HTTP packet payload, represented by
Buffer using specific
transfer encoding. |
ParsingResult |
ChunkedTransferEncoding.parsePacket(FilterChainContext ctx,
HttpHeader httpPacket,
Buffer buffer)
Parse HTTP packet payload, represented by
Buffer using specific
transfer encoding. |
protected void |
HttpContent.setContent(Buffer content) |
void |
HttpResponsePacket.setReasonPhrase(Buffer reason) |
static Protocol |
Protocol.valueOf(Buffer protocolBuffer,
int offset,
int len) |
Constructor and Description |
---|
HttpContent(HttpHeader httpHeader,
boolean isLast,
Buffer content) |
Modifier and Type | Method and Description |
---|---|
Buffer |
BinaryNIOInputSource.getBuffer()
Returns the the duplicate of the underlying
Buffer that backs this
InputSource . |
Buffer |
InputBuffer.getBuffer()
Returns the duplicate of the underlying
Buffer used to buffer
incoming request data. |
Buffer |
BinaryNIOInputSource.readBuffer()
Returns the underlying
Buffer that backs this
InputSource . |
Buffer |
InputBuffer.readBuffer() |
Buffer |
BinaryNIOInputSource.readBuffer(int size)
|
Buffer |
InputBuffer.readBuffer(int size) |
Modifier and Type | Method and Description |
---|---|
void |
InputBuffer.replayPayload(Buffer buffer) |
protected void |
InputBuffer.updateInputContentBuffer(Buffer buffer) |
void |
BinaryNIOOutputSink.write(Buffer buffer)
Writes the contents of the specified
Buffer . |
void |
OutputBuffer.writeBuffer(Buffer buffer)
Writes the contents of the specified
Buffer to the client. |
Modifier and Type | Method and Description |
---|---|
Buffer |
Request.getPostBody(int len)
Gets the POST body of this request.
|
Modifier and Type | Method and Description |
---|---|
void |
Request.replayPayload(Buffer buffer)
Replays request's payload by setting new payload
Buffer . |
Modifier and Type | Method and Description |
---|---|
protected void |
ServerInputBuffer.updateInputContentBuffer(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
BufferChunk.getBuffer() |
static Buffer |
HttpCodecUtils.getLongAsBuffer(MemoryManager memoryManager,
long length) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
Buffer buffer) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte value) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] array) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] tempBuffer,
DataChunk chunk) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] array,
int off,
int len) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] tempBuffer,
String s) |
static Buffer |
HttpCodecUtils.resizeBuffer(MemoryManager memoryManager,
Buffer buffer,
int grow) |
Modifier and Type | Method and Description |
---|---|
DataChunk |
MimeHeaders.addValue(Buffer buffer,
int startN,
int len)
Create a new named header using un-translated Buffer.
|
static int |
HttpCodecUtils.checkEOL(HttpCodecFilter.HeaderParsingState parsingState,
Buffer input) |
int |
UTF8Decoder.convert(Buffer buffer,
int srcOff,
char[] c,
int dstOff,
int length)
Converts the
Buffer to char[] using UTF8 encoding. |
static float |
HttpUtils.convertQValueToFloat(Buffer buffer,
int startIdx,
int stopIdx) |
static boolean |
BufferChunk.equals(byte[] c,
int cOff,
int cLen,
Buffer t,
int tOff,
int tLen) |
static boolean |
CookieUtils.equals(String s,
Buffer b,
int start,
int end) |
static boolean |
CookieUtils.equalsIgnoreCase(String s,
Buffer b,
int start,
int end) |
static boolean |
BufferChunk.equalsIgnoreCaseLowerCase(Buffer buffer,
int start,
int end,
byte[] cmpTo)
Compares the buffer chunk to the specified byte array representing
lower-case ASCII characters.
|
static boolean |
HttpCodecUtils.findEOL(HttpCodecFilter.HeaderParsingState state,
Buffer input) |
static int |
HttpCodecUtils.findSpace(Buffer input,
int offset,
int packetLimit) |
static int |
CookieUtils.getQuotedValueEndPosition(Buffer buffer,
int off,
int end)
Given a starting position after an initial quote character, this gets
the position of the end quote.
|
static int |
CookieUtils.getTokenEndPosition(Buffer buffer,
int off,
int end)
Given the starting position of a token, this gets the end of the
token, with no separator characters in between.
|
static int |
CookieUtils.getTokenEndPosition(Buffer buffer,
int off,
int end,
boolean parseAsVersion1) |
static int |
HttpCodecUtils.indexOf(Buffer input,
int offset,
byte b,
int packetLimit) |
static int |
BufferChunk.indexOf(Buffer buffer,
int off,
int end,
char qq) |
static int |
BufferChunk.indexOf(Buffer buffer,
int off,
int end,
CharSequence s) |
void |
RequestURIRef.init(Buffer input,
int start,
int end) |
static void |
Ascii.intToHexString(Buffer buffer,
int i) |
static void |
Ascii.intToUnsignedString(Buffer buffer,
int value,
int shift)
Convert the integer to an unsigned number.
|
static void |
HttpUtils.longToBuffer(long value,
Buffer buffer)
Converts the specified long as a string representation to the provided buffer.
|
static int |
CookieSerializerUtils.maybeQuote2(int version,
Buffer buf,
String value,
boolean versionOneStrictCompliance)
Quotes values using rules that vary depending on Cookie version.
|
static int |
CookieSerializerUtils.maybeQuote2(int version,
Buffer buf,
String value,
boolean allowVersionSwitch,
boolean versionOneStrictCompliance) |
static int |
CookieSerializerUtils.maybeQuote2(int version,
Buffer buf,
String value,
String literals,
boolean allowVersionSwitch,
boolean versionOneStrictCompliance) |
static void |
CookieParserUtils.parseClientCookies(Cookies cookies,
Buffer buffer,
int off,
int len)
Parses a cookie header after the initial "Cookie:"
[WS][$]token[WS]=[WS](token|QV)[;|,]
RFC 2965
JVK
|
static void |
CookieParserUtils.parseClientCookies(Cookies cookies,
Buffer buffer,
int off,
int len,
boolean versionOneStrictCompliance,
boolean rfc6265Enabled)
Parses a cookie header after the initial "Cookie:"
[WS][$]token[WS]=[WS](token|QV)[;|,]
RFC 2965
JVK
|
static int |
Ascii.parseInt(Buffer b,
int off,
int len)
Parses an unsigned int from the specified sub-array of bytes.
|
static long |
Ascii.parseLong(Buffer b,
int off,
int len)
Parses an unsigned long from the specified sub-array of bytes.
|
static void |
CookieParserUtils.parseServerCookies(Cookies cookies,
Buffer buffer,
int off,
int len,
boolean versionOneStrictCompliance,
boolean rfc6265Enabled) |
void |
Parameters.processParameters(Buffer buffer,
int start,
int len) |
void |
Parameters.processParameters(Buffer buffer,
int start,
int len,
Charset enc) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
Buffer buffer) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte value) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] array) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] tempBuffer,
DataChunk chunk) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] array,
int off,
int len) |
static Buffer |
HttpCodecUtils.put(MemoryManager memoryManager,
Buffer dstBuffer,
byte[] tempBuffer,
String s) |
static Buffer |
HttpCodecUtils.resizeBuffer(MemoryManager memoryManager,
Buffer buffer,
int grow) |
static void |
CookieSerializerUtils.serializeClientCookies(Buffer buf,
boolean versionOneStrictCompliance,
Cookie... cookies) |
static void |
CookieSerializerUtils.serializeClientCookies(Buffer buf,
Cookie... cookies) |
static void |
CookieSerializerUtils.serializeServerCookie(Buffer buf,
boolean versionOneStrictCompliance,
boolean alwaysAddExpires,
Cookie cookie) |
static void |
CookieSerializerUtils.serializeServerCookie(Buffer buf,
boolean versionOneStrictCompliance,
boolean alwaysAddExpires,
String name,
String value,
int version,
String path,
String domain,
String comment,
int maxAge,
boolean isSecure,
boolean isHttpOnly) |
static void |
CookieSerializerUtils.serializeServerCookie(Buffer buf,
Cookie cookie) |
void |
DataChunk.setBuffer(Buffer buffer) |
void |
BufferChunk.setBuffer(Buffer buffer) |
void |
DataChunk.setBuffer(Buffer buffer,
int position,
int limit) |
void |
BufferChunk.setBufferChunk(Buffer buffer,
int start,
int end) |
void |
BufferChunk.setBufferChunk(Buffer buffer,
int start,
int end,
int limit) |
static int |
HttpCodecUtils.skipSpaces(Buffer input,
int offset,
int packetLimit) |
static boolean |
BufferChunk.startsWith(Buffer buffer,
int start,
int end,
byte[] cmpTo) |
static int |
CookieParserUtils.unescapeDoubleQuotes(Buffer buffer,
int start,
int length)
Un-escapes any double quotes in the given cookie value.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMemoryManager<E extends Buffer>
A
MemoryManager abstraction to provide utilities that may be useful
across different MemoryManager implementations. |
interface |
MemoryManager<E extends Buffer>
MemoryManager, responsible for allocating and releasing memory,
required during application runtime.
|
Modifier and Type | Class and Description |
---|---|
class |
BuffersBuffer |
protected class |
ByteBufferManager.SmallByteBufferWrapper
ByteBufferWrapper implementation, which supports trimming. |
class |
ByteBufferWrapper
Buffer implementation, which uses the ByteBuffer underneath. |
class |
CompositeBuffer |
class |
HeapBuffer
Buffer implementation, which uses the ByteBuffer underneath. |
Modifier and Type | Field and Description |
---|---|
static Buffer |
Buffers.EMPTY_BUFFER |
Modifier and Type | Method and Description |
---|---|
Buffer |
PooledMemoryManager.allocate(int size)
For this implementation, this method simply calls through to
PooledMemoryManager.allocateAtLeast(int) ; |
Buffer |
PooledMemoryManager.allocateAtLeast(int size)
Allocates a buffer of at least the size requested.
|
static Buffer |
Buffers.appendBuffers(MemoryManager memoryManager,
Buffer buffer1,
Buffer buffer2)
Append two
Buffer s. |
static Buffer |
Buffers.appendBuffers(MemoryManager memoryManager,
Buffer buffer1,
Buffer buffer2,
boolean isCompositeBufferDisposable)
Append two
Buffer s. |
static Buffer |
Buffers.cloneBuffer(Buffer srcBuffer)
Clones the source
Buffer . |
static Buffer |
Buffers.cloneBuffer(Buffer srcBuffer,
int position,
int limit)
Clones the source
Buffer . |
Buffer |
ByteBufferWrapper.get(ByteBuffer dst) |
Buffer |
HeapBuffer.get(ByteBuffer dst) |
Buffer |
ByteBufferWrapper.get(ByteBuffer dst,
int position,
int length) |
Buffer |
HeapBuffer.get(ByteBuffer dst,
int position,
int length) |
Buffer |
BuffersBuffer.put(Buffer src,
int position,
int length) |
Buffer |
ByteBufferWrapper.put(ByteBuffer src) |
Buffer |
HeapBuffer.put(ByteBuffer src) |
Buffer |
ByteBufferWrapper.put(ByteBuffer src,
int position,
int length) |
Buffer |
HeapBuffer.put(ByteBuffer src,
int position,
int length) |
Buffer |
ByteBufferWrapper.put8BitString(String s) |
Buffer |
PooledMemoryManager.reallocate(Buffer oldBuffer,
int newSize)
Reallocates an existing buffer to at least the specified size.
|
Buffer |
BuffersBuffer.slice() |
Buffer |
BuffersBuffer.slice(int position,
int limit) |
Buffer |
BuffersBuffer.split(int splitPosition) |
Buffer |
ByteBufferWrapper.split(int splitPosition) |
Buffer |
HeapBuffer.split(int splitPosition)
Split up the buffer into two parts: [0..splitPosition) and [splitPosition, capacity).
|
Buffer[] |
BuffersBuffer.underlying() |
Buffer |
WrapperAware.wrap(byte[] data)
Returns
Buffer , which wraps the byte array. |
Buffer |
PooledMemoryManager.wrap(byte[] data) |
Buffer |
WrapperAware.wrap(byte[] data,
int offset,
int length)
Returns
Buffer , which wraps the part of byte array with
specific offset and length. |
Buffer |
PooledMemoryManager.wrap(byte[] data,
int offset,
int length) |
Buffer |
WrapperAware.wrap(ByteBuffer byteBuffer)
Returns
Buffer , which wraps the ByteBuffer . |
Buffer |
HeapMemoryManager.wrap(ByteBuffer byteBuffer)
Returns
Buffer , which wraps the ByteBuffer . |
Buffer |
PooledMemoryManager.wrap(ByteBuffer byteBuffer) |
static Buffer |
Buffers.wrap(MemoryManager memoryManager,
byte[] array)
Returns
Buffer , which wraps the byte array. |
static Buffer |
Buffers.wrap(MemoryManager memoryManager,
byte[] array,
int offset,
int length)
Returns
Buffer , which wraps the part of byte array with
specific offset and length. |
static Buffer |
Buffers.wrap(MemoryManager memoryManager,
ByteBuffer byteBuffer)
Returns
Buffer , which wraps the ByteBuffer . |
static Buffer |
Buffers.wrap(MemoryManager memoryManager,
String s)
|
static Buffer |
Buffers.wrap(MemoryManager memoryManager,
String s,
Charset charset)
|
Buffer |
WrapperAware.wrap(String s)
|
Buffer |
PooledMemoryManager.wrap(String s) |
Buffer |
WrapperAware.wrap(String s,
Charset charset)
|
Buffer |
PooledMemoryManager.wrap(String s,
Charset charset) |
Modifier and Type | Method and Description |
---|---|
static Appender<Buffer> |
Buffers.getBufferAppender(boolean isCompositeBufferDisposable)
|
Modifier and Type | Method and Description |
---|---|
BuffersBuffer |
BuffersBuffer.append(Buffer buffer) |
abstract CompositeBuffer |
CompositeBuffer.append(Buffer buffer) |
static Buffer |
Buffers.appendBuffers(MemoryManager memoryManager,
Buffer buffer1,
Buffer buffer2)
Append two
Buffer s. |
static Buffer |
Buffers.appendBuffers(MemoryManager memoryManager,
Buffer buffer1,
Buffer buffer2,
boolean isCompositeBufferDisposable)
Append two
Buffer s. |
static Buffer |
Buffers.cloneBuffer(Buffer srcBuffer)
Clones the source
Buffer . |
static Buffer |
Buffers.cloneBuffer(Buffer srcBuffer,
int position,
int limit)
Clones the source
Buffer . |
int |
BuffersBuffer.compareTo(Buffer that) |
int |
ByteBufferWrapper.compareTo(Buffer o) |
int |
HeapBuffer.compareTo(Buffer o) |
static BuffersBuffer |
BuffersBuffer.create(MemoryManager memoryManager,
Buffer... buffers) |
static BuffersBuffer |
BuffersBuffer.create(MemoryManager memoryManager,
Buffer[] buffers,
boolean isReadOnly) |
static void |
Buffers.fill(Buffer buffer,
byte b)
Fill the
Buffer with the specific byte value. |
static void |
Buffers.fill(Buffer buffer,
int position,
int limit,
byte b)
|
protected int |
BufferArray.getLimit(Buffer buffer) |
protected int |
BufferArray.getPosition(Buffer buffer) |
static CompositeBuffer |
CompositeBuffer.newBuffer(MemoryManager memoryManager,
Buffer... buffers) |
static CompositeBuffer |
CompositeBuffer.newBuffer(MemoryManager memoryManager,
Buffer[] buffers,
boolean isReadOnly) |
BuffersBuffer |
BuffersBuffer.prepend(Buffer buffer) |
ByteBufferWrapper |
ByteBufferWrapper.prepend(Buffer header) |
abstract CompositeBuffer |
CompositeBuffer.prepend(Buffer buffer) |
HeapBuffer |
HeapBuffer.prepend(Buffer header) |
BuffersBuffer |
BuffersBuffer.put(Buffer src) |
ByteBufferWrapper |
ByteBufferWrapper.put(Buffer src) |
HeapBuffer |
HeapBuffer.put(Buffer src) |
Buffer |
BuffersBuffer.put(Buffer src,
int position,
int length) |
ByteBufferWrapper |
ByteBufferWrapper.put(Buffer src,
int position,
int length) |
HeapBuffer |
HeapBuffer.put(Buffer src,
int position,
int length) |
static void |
Buffers.put(Buffer src,
int position,
int length,
Buffer dstBuffer) |
static long |
Buffers.readFromFileChannel(FileChannel fileChannel,
Buffer buffer)
Reads data from the
FileChannel into the Buffer . |
Buffer |
PooledMemoryManager.reallocate(Buffer oldBuffer,
int newSize)
Reallocates an existing buffer to at least the specified size.
|
void |
PooledMemoryManager.release(Buffer buffer)
Release
Buffer . |
boolean |
BuffersBuffer.replace(Buffer oldBuffer,
Buffer newBuffer) |
abstract boolean |
CompositeBuffer.replace(Buffer oldBuffer,
Buffer newBuffer)
Replace one internal
Buffer with another one. |
protected void |
BufferArray.setPositionLimit(Buffer buffer,
int position,
int limit) |
static void |
Buffers.setPositionLimit(Buffer buffer,
int position,
int limit) |
String |
Buffers.toStringContent(Buffer buffer,
int headBytesCount,
int tailBytesCount)
|
String |
Buffers.toStringContent(Buffer buffer,
int headBytesCount,
int tailBytesCount,
Charset charset)
|
static long |
Buffers.writeToFileChannel(FileChannel fileChannel,
Buffer buffer)
Writes data from the
Buffer into the FileChannel . |
Constructor and Description |
---|
BuffersBuffer(MemoryManager memoryManager,
Buffer[] buffers,
int buffersSize,
boolean isReadOnly) |
Modifier and Type | Method and Description |
---|---|
protected static void |
NIOConnection.notifyProbesRead(NIOConnection connection,
Buffer data,
int size)
Notify registered
ConnectionProbe s about the read event. |
protected static void |
NIOConnection.notifyProbesWrite(NIOConnection connection,
Buffer data,
long size)
Notify registered
ConnectionProbe s about the write event. |
void |
AbstractNIOAsyncQueueReader.read(Connection<SocketAddress> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
protected abstract int |
AbstractNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractNIOAsyncQueueReader.read(Connection<SocketAddress> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
protected abstract int |
AbstractNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
TemporarySelectorReader.acquireBuffer(Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
TemporarySelectorReader.read(Connection<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor) |
void |
TemporarySelectorReader.read(Connection<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor,
long timeout,
TimeUnit timeunit)
Method reads data to the message.
|
protected int |
TemporarySelectorReader.read0(NIOConnection connection,
ReadResult<Buffer,SocketAddress> currentResult,
Buffer buffer,
long timeout,
TimeUnit timeunit) |
protected abstract int |
TemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
void |
TemporarySelectorReader.read(Connection<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor) |
void |
TemporarySelectorReader.read(Connection<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor,
long timeout,
TimeUnit timeunit)
Method reads data to the message.
|
protected int |
TemporarySelectorReader.read0(NIOConnection connection,
ReadResult<Buffer,SocketAddress> currentResult,
Buffer buffer,
long timeout,
TimeUnit timeunit) |
protected abstract int |
TemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
static Buffer |
TCPNIOUtils.allocateAndReadBuffer(TCPNIOConnection connection) |
protected Buffer |
DefaultStreamWriter.Output.newBuffer(int size) |
Buffer |
TCPNIOTransport.read(Connection connection,
Buffer buffer) |
protected Buffer |
DefaultStreamWriter.Output.reallocateBuffer(Buffer oldBuffer,
int size) |
Modifier and Type | Method and Description |
---|---|
protected void |
TCPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
UDPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected GrizzlyFuture<Integer> |
DefaultStreamWriter.Output.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
protected void |
TCPNIOConnection.onRead(Buffer data,
int size)
Method will be called, when some data was read on the connection
|
protected void |
UDPNIOConnection.onRead(Buffer data,
int size)
Method will be called, when some data was read on the connection
|
protected void |
UDPNIOConnection.onWrite(Buffer data,
int size)
Method will be called, when some data was written on the connection
|
protected void |
TCPNIOConnection.onWrite(Buffer data,
long size)
Method will be called, when some data was written on the connection
|
Buffer |
TCPNIOTransport.read(Connection connection,
Buffer buffer) |
int |
UDPNIOTransport.read(UDPNIOConnection connection,
Buffer buffer) |
int |
UDPNIOTransport.read(UDPNIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
TCPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
UDPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
static int |
TCPNIOUtils.readBuffer(TCPNIOConnection connection,
Buffer buffer) |
protected int |
UDPNIOTemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
TCPNIOTemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
static int |
TCPNIOUtils.readSimpleBuffer(TCPNIOConnection connection,
Buffer buffer) |
protected Buffer |
DefaultStreamWriter.Output.reallocateBuffer(Buffer oldBuffer,
int size) |
static int |
TCPNIOUtils.writeSimpleBuffer(TCPNIOConnection connection,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
int |
UDPNIOTransport.read(UDPNIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
TCPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
UDPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
UDPNIOTemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
TCPNIOTemporarySelectorReader.readNow0(NIOConnection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
abstract Buffer |
Source.read(int length)
Returns the number of bytes to be written.
|
Modifier and Type | Method and Description |
---|---|
Source |
Source.SourceFactory.createBufferSource(Buffer buffer)
|
protected boolean |
SpdyHandlerFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx)
Callback invoked when the HTTP message header parsing is complete.
|
protected void |
SessionOutputSink.writeDataDownStream(SpdyStream spdyStream,
SpdyFrame headerFrame,
Buffer data,
CompletionHandler<WriteResult> completionHandler,
MessageCloner<Buffer> messageCloner,
boolean isLast) |
Modifier and Type | Method and Description |
---|---|
protected void |
SessionOutputSink.writeDataDownStream(SpdyStream spdyStream,
SpdyFrame headerFrame,
Buffer data,
CompletionHandler<WriteResult> completionHandler,
MessageCloner<Buffer> messageCloner,
boolean isLast) |
protected <K> void |
SessionOutputSink.writeDownStream(K anyMessage,
CompletionHandler<WriteResult> completionHandler,
MessageCloner<Buffer> messageCloner) |
Modifier and Type | Method and Description |
---|---|
Buffer |
SpdyInflaterOutputStream.checkpoint() |
Buffer |
SpdyDeflaterOutputStream.checkpoint() |
Modifier and Type | Method and Description |
---|---|
void |
SpdyDeflaterOutputStream.setInitialOutputBuffer(Buffer buffer) |
void |
SpdyInflaterOutputStream.write(Buffer buffer) |
void |
SpdyDeflaterOutputStream.write(Buffer buffer) |
Modifier and Type | Field and Description |
---|---|
protected Buffer |
SpdyHeader.buffer |
protected Buffer |
HeadersProviderFrame.compressedHeaders |
Modifier and Type | Method and Description |
---|---|
Buffer |
CompressedHeadersBuilder.build(Deflater deflater) |
Buffer |
HeadersProviderFrame.getCompressedHeaders() |
Buffer |
DataFrame.getData() |
Buffer |
SpdyHeader.getUnderlying() |
Buffer |
SynReplyFrame.toBuffer(MemoryManager memoryManager) |
abstract Buffer |
SpdyFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
SynStreamFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
ServiceFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
HeadersFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
PingFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
CredentialFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
RstStreamFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
WindowUpdateFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
DataFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
GoAwayFrame.toBuffer(MemoryManager memoryManager) |
Buffer |
SettingsFrame.toBuffer(MemoryManager memoryManager) |
Modifier and Type | Method and Description |
---|---|
T |
HeadersProviderFrame.HeadersProviderFrameBuilder.compressedHeaders(Buffer compressedHeaders)
Sets compressed headers buffer.
|
DataFrame.DataFrameBuilder |
DataFrame.DataFrameBuilder.data(Buffer data) |
static SpdyHeader |
SpdyHeader.wrap(Buffer buffer) |
static SpdyFrame |
SpdyFrame.wrap(Buffer buffer) |
Modifier and Type | Field and Description |
---|---|
protected static MessageCloner<Buffer> |
SSLBaseFilter.COPY_CLONER |
Modifier and Type | Method and Description |
---|---|
static Buffer |
SSLUtils.allocateInputBuffer(SSLConnectionContext sslCtx) |
static Buffer |
SSLUtils.allowDispose(Buffer buffer) |
protected Buffer |
SSLBaseFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer) |
protected Buffer |
SSLFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
Buffer tmpAppBuffer0) |
protected Buffer |
SSLBaseFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
Buffer tmpAppBuffer0) |
protected Buffer |
SSLBaseFilter.doHandshakeSync(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
long timeoutMillis) |
static Buffer |
SSLUtils.handshakeWrap(Connection connection,
SSLConnectionContext sslCtx,
Buffer netBuffer) |
protected Buffer |
SSLBaseFilter.wrapAll(FilterChainContext ctx,
SSLConnectionContext sslCtx) |
Modifier and Type | Method and Description |
---|---|
Transformer<Buffer,Buffer> |
SSLCodec.getDecoder() |
Transformer<Buffer,Buffer> |
SSLCodec.getDecoder() |
Transformer<Buffer,Buffer> |
SSLCodec.getEncoder() |
Transformer<Buffer,Buffer> |
SSLCodec.getEncoder() |
protected TransformationResult<Buffer,Buffer> |
SSLEncoderTransformer.transformImpl(AttributeStorage state,
Buffer originalMessage) |
protected TransformationResult<Buffer,Buffer> |
SSLEncoderTransformer.transformImpl(AttributeStorage state,
Buffer originalMessage) |
protected TransformationResult<Buffer,Buffer> |
SSLDecoderTransformer.transformImpl(AttributeStorage state,
Buffer originalMessage) |
protected TransformationResult<Buffer,Buffer> |
SSLDecoderTransformer.transformImpl(AttributeStorage state,
Buffer originalMessage) |
Modifier and Type | Method and Description |
---|---|
static Buffer |
SSLUtils.allowDispose(Buffer buffer) |
protected Buffer |
SSLBaseFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer) |
protected Buffer |
SSLFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
Buffer tmpAppBuffer0) |
protected Buffer |
SSLBaseFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
Buffer tmpAppBuffer0) |
protected Buffer |
SSLBaseFilter.doHandshakeSync(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
long timeoutMillis) |
static int |
SSLUtils.getSSLPacketSize(Buffer buf) |
static SSLEngineResult |
SSLUtils.handshakeUnwrap(SSLConnectionContext sslCtx,
Buffer inputBuffer,
Buffer tmpOutputBuffer) |
static Buffer |
SSLUtils.handshakeWrap(Connection connection,
SSLConnectionContext sslCtx,
Buffer netBuffer) |
boolean |
SSLEncoderTransformer.hasInputRemaining(AttributeStorage storage,
Buffer input) |
boolean |
SSLDecoderTransformer.hasInputRemaining(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
SSLEncoderTransformer.transformImpl(AttributeStorage state,
Buffer originalMessage) |
protected TransformationResult<Buffer,Buffer> |
SSLDecoderTransformer.transformImpl(AttributeStorage state,
Buffer originalMessage) |
Modifier and Type | Field and Description |
---|---|
protected Transformer<Buffer,Buffer> |
TransformerOutput.transformer |
protected Transformer<Buffer,Buffer> |
TransformerOutput.transformer |
protected Transformer<Buffer,Buffer> |
TransformerInput.transformer |
protected Transformer<Buffer,Buffer> |
TransformerInput.transformer |
Modifier and Type | Method and Description |
---|---|
Buffer |
Input.getBuffer()
Return the Input's
Buffer . |
Buffer |
BufferedInput.getBuffer() |
Buffer |
StreamOutput.getBuffer() |
Buffer |
Output.getBuffer()
Return the Input's
Buffer . |
Buffer |
StreamInput.getBuffer() |
Buffer |
BufferedOutput.getBuffer() |
Buffer |
StreamReader.getBufferWindow() |
Buffer |
AbstractStreamReader.getBufferWindow() |
protected Buffer |
TransformerOutput.newBuffer(int size) |
protected abstract Buffer |
BufferedOutput.newBuffer(int size) |
protected Buffer |
TransformerOutput.reallocateBuffer(Buffer oldBuffer,
int size) |
protected abstract Buffer |
BufferedOutput.reallocateBuffer(Buffer oldBuffer,
int size) |
Buffer |
Input.takeBuffer()
Takes the Input's
Buffer . |
Buffer |
BufferedInput.takeBuffer() |
Buffer |
StreamInput.takeBuffer() |
Buffer |
StreamReader.takeBufferWindow() |
Buffer |
AbstractStreamReader.takeBufferWindow() |
Modifier and Type | Method and Description |
---|---|
boolean |
BufferedInput.append(Buffer buffer) |
protected GrizzlyFuture<Integer> |
TransformerOutput.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
protected abstract GrizzlyFuture<Integer> |
BufferedOutput.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
boolean |
BufferedInput.prepend(Buffer buffer) |
void |
StreamReader.readBytes(Buffer buffer)
Fill the buffer with data from the stream (that is, copy data
from the stream to fill buffer from position to limit).
|
void |
AbstractStreamReader.readBytes(Buffer buffer)
Fill the buffer with data from the stream (that is, copy data
from the stream to fill buffer from position to limit).
|
protected Buffer |
TransformerOutput.reallocateBuffer(Buffer oldBuffer,
int size) |
protected abstract Buffer |
BufferedOutput.reallocateBuffer(Buffer oldBuffer,
int size) |
void |
StreamOutput.write(Buffer buffer) |
void |
Output.write(Buffer buffer) |
void |
BufferedOutput.write(Buffer bufferToWrite) |
void |
StreamWriter.writeBuffer(Buffer buffer)
Write the
Buffer to the StreamWriter. |
void |
AbstractStreamWriter.writeBuffer(Buffer b)
Write the
Buffer to the StreamWriter. |
Modifier and Type | Method and Description |
---|---|
<E> GrizzlyFuture<Stream> |
StreamWriter.encode(Transformer<E,Buffer> encoder,
E object) |
<E> GrizzlyFuture<Stream> |
AbstractStreamWriter.encode(Transformer<E,Buffer> encoder,
E object) |
<E> GrizzlyFuture<Stream> |
StreamWriter.encode(Transformer<E,Buffer> encoder,
E object,
CompletionHandler<Stream> completionHandler) |
<E> GrizzlyFuture<Stream> |
AbstractStreamWriter.encode(Transformer<E,Buffer> encoder,
E object,
CompletionHandler<Stream> completionHandler) |
Constructor and Description |
---|
DisposeBufferCompletionHandler(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
BufferOutputStream.allocateNewBuffer(MemoryManager memoryManager,
int size) |
Buffer |
BufferOutputStream.getBuffer()
Get the result
Buffer (not flipped). |
Modifier and Type | Method and Description |
---|---|
protected TransformationResult<Buffer,String> |
StringDecoder.parseWithLengthPrefix(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,String> |
StringDecoder.parseWithTerminatingSeq(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,String> |
StringDecoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
ChunkingFilter.ChunkingTransformer.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
ChunkingFilter.ChunkingTransformer.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<String,Buffer> |
StringEncoder.transformImpl(AttributeStorage storage,
String input) |
Modifier and Type | Method and Description |
---|---|
boolean |
StringDecoder.hasInputRemaining(AttributeStorage storage,
Buffer input) |
boolean |
ChunkingFilter.ChunkingTransformer.hasInputRemaining(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,String> |
StringDecoder.parseWithLengthPrefix(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,String> |
StringDecoder.parseWithTerminatingSeq(AttributeStorage storage,
Buffer input) |
void |
BufferOutputStream.setInitialOutputBuffer(Buffer initialBuffer) |
protected TransformationResult<Buffer,String> |
StringDecoder.transformImpl(AttributeStorage storage,
Buffer input) |
protected TransformationResult<Buffer,Buffer> |
ChunkingFilter.ChunkingTransformer.transformImpl(AttributeStorage storage,
Buffer input) |
Constructor and Description |
---|
BufferInputStream(Buffer buffer)
Create the
InputStream over Grizzly Buffer . |
BufferInputStream(Buffer buffer,
int position,
int limit)
Create the
InputStream over Grizzly Buffer . |
BufferOutputStream(MemoryManager mm,
Buffer buffer)
Creates the BufferOutputStream using passed
Buffer as initial. |
BufferOutputStream(MemoryManager mm,
Buffer buffer,
boolean reallocate)
Creates the BufferOutputStream using passed
Buffer as initial. |
Modifier and Type | Field and Description |
---|---|
Buffer |
WebSocketHolder.buffer |
Modifier and Type | Method and Description |
---|---|
Buffer |
ParseResult.getRemainder()
Get the parsing remainder
Buffer . |
Modifier and Type | Method and Description |
---|---|
static ParseResult |
ParseResult.create(boolean isComplete,
Buffer remainderBuffer)
Create a ParseResult object.
|
abstract DataFrame |
ProtocolHandler.parse(Buffer buffer) |
void |
Masker.setBuffer(Buffer buffer) |
DataFrame |
ProtocolHandler.unframe(Buffer buffer) |
Constructor and Description |
---|
Masker(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
DataFrame |
RFC6455Handler.parse(Buffer buffer) |
Copyright © 2015 Oracle Corporation. All rights reserved.