Package | Description |
---|---|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
Modifier and Type | Class and Description |
---|---|
static class |
Http2Exception.ClosedStreamCreationException
Used when a stream creation attempt fails but may be because the stream was previously closed.
|
static class |
Http2Exception.CompositeStreamException
Provides the ability to handle multiple stream exceptions with one throw statement.
|
static class |
Http2Exception.HeaderListSizeException |
static class |
Http2Exception.StreamException
Represents an exception that can be isolated to a single stream (as opposed to the entire connection).
|
class |
Http2NoMoreStreamIdsException
This exception is thrown when there are no more stream IDs available for the current connection
|
static class |
StreamBufferingEncoder.Http2ChannelClosedException
Thrown if buffered streams are terminated due to this encoder being closed.
|
static class |
StreamBufferingEncoder.Http2GoAwayException
Thrown by
StreamBufferingEncoder if buffered streams are terminated due to
receipt of a GOAWAY . |
Modifier and Type | Field and Description |
---|---|
private static Http2Exception |
HpackDecoder.DECODE_ILLEGAL_INDEX_VALUE |
private static Http2Exception |
HpackDecoder.DECODE_ULE_128_DECOMPRESSION_EXCEPTION |
private static Http2Exception |
HpackDecoder.DECODE_ULE_128_TO_INT_DECOMPRESSION_EXCEPTION |
private static Http2Exception |
HpackDecoder.DECODE_ULE_128_TO_LONG_DECOMPRESSION_EXCEPTION |
private static Http2Exception |
HpackHuffmanDecoder.EOS_DECODED |
private static Http2Exception |
HpackDecoder.INDEX_HEADER_ILLEGAL_INDEX_VALUE |
private static Http2Exception |
HpackDecoder.INVALID_MAX_DYNAMIC_TABLE_SIZE |
private static Http2Exception |
HpackHuffmanDecoder.INVALID_PADDING |
private static Http2Exception |
HpackDecoder.MAX_DYNAMIC_TABLE_SIZE_CHANGE_REQUIRED |
private static Http2Exception |
HpackDecoder.READ_NAME_ILLEGAL_INDEX_VALUE |
Modifier and Type | Method and Description |
---|---|
static Http2Exception |
Http2Exception.closedStreamError(Http2Error error,
java.lang.String fmt,
java.lang.Object... args)
Use if an error has occurred which can not be isolated to a single stream, but instead applies
to the entire connection.
|
static Http2Exception |
Http2Exception.connectionError(Http2Error error,
java.lang.String fmt,
java.lang.Object... args)
Use if an error has occurred which can not be isolated to a single stream, but instead applies
to the entire connection.
|
static Http2Exception |
Http2Exception.connectionError(Http2Error error,
java.lang.Throwable cause,
java.lang.String fmt,
java.lang.Object... args)
Use if an error has occurred which can not be isolated to a single stream, but instead applies
to the entire connection.
|
static Http2Exception |
Http2CodecUtil.getEmbeddedHttp2Exception(java.lang.Throwable cause)
Iteratively looks through the causality chain for the given exception and returns the first
Http2Exception or null if none. |
static Http2Exception |
Http2Exception.headerListSizeError(int id,
Http2Error error,
boolean onDecode,
java.lang.String fmt,
java.lang.Object... args)
A specific stream error resulting from failing to decode headers that exceeds the max header size list.
|
static Http2Exception |
Http2Exception.streamError(int id,
Http2Error error,
java.lang.String fmt,
java.lang.Object... args)
Use if an error which can be isolated to a single stream has occurred.
|
static Http2Exception |
Http2Exception.streamError(int id,
Http2Error error,
java.lang.Throwable cause,
java.lang.String fmt,
java.lang.Object... args)
Use if an error which can be isolated to a single stream has occurred.
|
Modifier and Type | Method and Description |
---|---|
private ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
Http2Exception cause)
Close the remote endpoint with with a
GO_AWAY frame. |
static boolean |
Http2Exception.isStreamError(Http2Exception e)
Check if an exception is isolated to a single stream or the entire connection.
|
protected void |
Http2ConnectionHandler.onConnectionError(ChannelHandlerContext ctx,
java.lang.Throwable cause,
Http2Exception http2Ex)
Handler for a connection error.
|
static int |
Http2Exception.streamId(Http2Exception e)
Get the stream id associated with an exception.
|
private void |
DefaultHttp2RemoteFlowController.FlowState.writeError(Http2RemoteFlowController.FlowControlled frame,
Http2Exception cause)
Discards this
FlowControlled , writing an error. |
Modifier and Type | Method and Description |
---|---|
(package private) static Http2Stream.State |
DefaultHttp2Connection.activeState(int streamId,
Http2Stream.State initialState,
boolean isLocal,
boolean halfClosed) |
(package private) void |
DefaultHttp2FrameReader.HeadersBlockBuilder.addFragment(ByteBuf fragment,
ByteBufAllocator alloc,
boolean endOfHeaders)
Adds a fragment to the block.
|
private long |
HpackDecoder.addHeader(int streamId,
Http2Headers headers,
java.lang.CharSequence name,
java.lang.CharSequence value,
long headersLength) |
static void |
HttpConversionUtil.addHttp2ToHttpHeaders(int streamId,
Http2Headers sourceHeaders,
FullHttpMessage destinationMessage,
boolean addToTrailer)
Translate and add HTTP/2 headers to HTTP/1.x headers.
|
static void |
HttpConversionUtil.addHttp2ToHttpHeaders(int streamId,
Http2Headers inputHeaders,
HttpHeaders outputHeaders,
HttpVersion httpVersion,
boolean isTrailer,
boolean isRequest)
Translate and add HTTP/2 headers to HTTP/1.x headers.
|
private void |
DefaultHttp2ConnectionDecoder.FrameReadListener.applyLocalSettings(Http2Settings settings)
Applies settings sent from the local endpoint.
|
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.channelHandlerContext(ChannelHandlerContext ctx) |
void |
DefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
Http2FlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.channelWritabilityChange()
Called when the writability of the underlying channel changes.
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.channelWritabilityChange() |
void |
DefaultHttp2RemoteFlowController.channelWritabilityChanged() |
void |
Http2RemoteFlowController.channelWritabilityChanged()
Notification that the writability of
Http2RemoteFlowController.channelHandlerContext() has changed. |
private void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.checkAllWritabilityChanged() |
private void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.checkConnectionThenStreamWritabilityChanged(DefaultHttp2RemoteFlowController.FlowState state) |
private void |
DefaultHttp2Connection.DefaultEndpoint.checkNewStreamAllowed(int streamId,
Http2Stream.State state) |
private void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.checkStateWritability(DefaultHttp2RemoteFlowController.FlowState state) |
boolean |
DefaultHttp2LocalFlowController.consumeBytes(Http2Stream stream,
int numBytes) |
boolean |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.consumeBytes(Http2Stream stream,
int numBytes) |
boolean |
Http2LocalFlowController.consumeBytes(Http2Stream stream,
int numBytes)
Indicates that the application has consumed a number of bytes for the given stream and is therefore ready to
receive more data from the remote endpoint.
|
boolean |
DefaultHttp2LocalFlowController.AutoRefillState.consumeBytes(int numBytes) |
boolean |
DefaultHttp2LocalFlowController.DefaultState.consumeBytes(int numBytes) |
boolean |
DefaultHttp2LocalFlowController.FlowState.consumeBytes(int numBytes)
Indicates that the application has consumed
numBytes from the connection or stream and is
ready to receive more data. |
(package private) int |
DelegatingDecompressorFrameListener.Http2Decompressor.consumeBytes(int streamId,
int decompressedBytes)
Determines the ratio between
numBytes and DelegatingDecompressorFrameListener.Http2Decompressor.decompressed . |
DefaultHttp2Connection.DefaultStream |
DefaultHttp2Connection.DefaultEndpoint.createStream(int streamId,
boolean halfClosed) |
Http2Stream |
Http2Connection.Endpoint.createStream(int streamId,
boolean halfClosed)
Creates a stream initiated by this endpoint.
|
AsciiString |
HpackHuffmanDecoder.decode(ByteBuf buf,
int length)
Decompresses the given Huffman coded string literal.
|
void |
HpackDecoder.decode(int streamId,
ByteBuf in,
Http2Headers headers)
Decode the header block into header fields.
|
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called by the
Http2ConnectionHandler to decode the next frame from the input buffer. |
Http2Headers |
DefaultHttp2HeadersDecoder.decodeHeaders(int streamId,
ByteBuf headerBlock) |
Http2Headers |
Http2HeadersDecoder.decodeHeaders(int streamId,
ByteBuf headerBlock)
Decodes the given headers block and returns the headers.
|
private Http2Settings |
Http2ServerUpgradeCodec.decodeSettings(ChannelHandlerContext ctx,
ByteBuf frame)
Decodes the settings frame and returns the settings.
|
private Http2Settings |
Http2ServerUpgradeCodec.decodeSettingsHeader(ChannelHandlerContext ctx,
java.lang.CharSequence settingsHeader)
Decodes the settings header and returns a
Http2Settings object. |
(package private) static int |
HpackDecoder.decodeULE128(ByteBuf in,
int result)
Unsigned Little Endian Base 128 Variable-Length Integer Encoding
|
(package private) static long |
HpackDecoder.decodeULE128(ByteBuf in,
long result)
Unsigned Little Endian Base 128 Variable-Length Integer Encoding
|
boolean |
StreamByteDistributor.distribute(int maxBytes,
StreamByteDistributor.Writer writer)
Distributes up to
maxBytes to those streams containing streamable bytes and
iterates across those streams to write the appropriate bytes. |
boolean |
WeightedFairQueueByteDistributor.distribute(int maxBytes,
StreamByteDistributor.Writer writer) |
boolean |
UniformStreamByteDistributor.distribute(int maxBytes,
StreamByteDistributor.Writer writer) |
private int |
WeightedFairQueueByteDistributor.distribute(int maxBytes,
StreamByteDistributor.Writer writer,
WeightedFairQueueByteDistributor.State state) |
private int |
WeightedFairQueueByteDistributor.distributeToChildren(int maxBytes,
StreamByteDistributor.Writer writer,
WeightedFairQueueByteDistributor.State state)
It is a pre-condition that
state.poll() returns a non-null value. |
void |
HpackEncoder.encodeHeaders(int streamId,
ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector)
Encode the header field into the header block.
|
void |
Http2HeadersEncoder.encodeHeaders(int streamId,
Http2Headers headers,
ByteBuf buffer)
Encodes the given headers and writes the output headers block to the given output buffer.
|
void |
DefaultHttp2HeadersEncoder.encodeHeaders(int streamId,
Http2Headers headers,
ByteBuf buffer) |
private void |
HpackEncoder.encodeHeadersEnforceMaxHeaderListSize(int streamId,
ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector) |
private void |
HpackEncoder.encodeHeadersIgnoreMaxHeaderListSize(ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector) |
(package private) AsciiString |
HpackHuffmanDecoder.DecoderProcessor.end() |
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.enqueueFrame(DefaultHttp2RemoteFlowController.FlowState state,
Http2RemoteFlowController.FlowControlled frame)
Add a frame to be sent via flow control.
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.enqueueFrame(DefaultHttp2RemoteFlowController.FlowState state,
Http2RemoteFlowController.FlowControlled frame) |
void |
Http2ConnectionHandler.flush(ChannelHandlerContext ctx) |
Http2Stream |
DefaultHttp2Connection.forEachActiveStream(Http2StreamVisitor visitor) |
Http2Stream |
DefaultHttp2Connection.ActiveStreams.forEachActiveStream(Http2StreamVisitor visitor) |
Http2Stream |
Http2Connection.forEachActiveStream(Http2StreamVisitor visitor)
Provide a means of iterating over the collection of active streams.
|
protected java.lang.CharSequence |
CompressorHttp2ConnectionEncoder.getTargetContentEncoding(java.lang.CharSequence contentEncoding)
Returns the expected content encoding of the decoded content.
|
protected java.lang.CharSequence |
DelegatingDecompressorFrameListener.getTargetContentEncoding(java.lang.CharSequence contentEncoding)
Returns the expected content encoding of the decoded content.
|
static void |
Http2CodecUtil.headerListSizeExceeded(int streamId,
long maxHeaderListSize,
boolean onDecode)
Results in a RST_STREAM being sent for
streamId due to violating
SETTINGS_MAX_HEADER_LIST_SIZE. |
static void |
Http2CodecUtil.headerListSizeExceeded(long maxHeaderListSize)
Results in a GO_AWAY being sent due to violating
SETTINGS_MAX_HEADER_LIST_SIZE in an unrecoverable
manner.
|
(package private) Http2Headers |
DefaultHttp2FrameReader.HeadersBlockBuilder.headers()
Builds the headers from the completed headers block.
|
private void |
DefaultHttp2FrameReader.HeadersBlockBuilder.headerSizeExceeded()
The local header size maximum has been exceeded while accumulating bytes.
|
void |
DefaultHttp2LocalFlowController.DefaultState.incrementFlowControlWindows(int delta) |
void |
DefaultHttp2LocalFlowController.FlowState.incrementFlowControlWindows(int delta)
Increment the windows which are used to determine many bytes have been processed.
|
(package private) int |
DefaultHttp2RemoteFlowController.FlowState.incrementStreamWindow(int delta)
Increments the flow control window for this stream by the given delta and returns the new value.
|
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.incrementWindowSize(DefaultHttp2RemoteFlowController.FlowState state,
int delta)
Increment the window size for a particular stream.
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.incrementWindowSize(DefaultHttp2RemoteFlowController.FlowState state,
int delta) |
void |
DefaultHttp2LocalFlowController.incrementWindowSize(Http2Stream stream,
int delta) |
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.incrementWindowSize(Http2Stream stream,
int delta) |
void |
DefaultHttp2RemoteFlowController.incrementWindowSize(Http2Stream stream,
int delta) |
void |
Http2FlowController.incrementWindowSize(Http2Stream stream,
int delta)
Increments the size of the stream's flow control window by the given delta.
|
private long |
HpackDecoder.indexHeader(int streamId,
int index,
Http2Headers headers,
long headersLength) |
private void |
DelegatingDecompressorFrameListener.initDecompressor(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
boolean endOfStream)
Checks if a new decompressor object is needed for the stream identified by
streamId . |
void |
DefaultHttp2LocalFlowController.initialWindowSize(int newWindowSize) |
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.initialWindowSize(int newWindowSize) |
void |
DefaultHttp2RemoteFlowController.initialWindowSize(int newWindowSize) |
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.initialWindowSize(int newWindowSize) |
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.initialWindowSize(int newWindowSize) |
void |
Http2FlowController.initialWindowSize(int newWindowSize)
Sets the connection-wide initial flow control window and updates all stream windows (but not the connection
stream window) by the delta.
|
private long |
HpackDecoder.insertHeader(int streamId,
Http2Headers headers,
java.lang.CharSequence name,
java.lang.CharSequence value,
HpackUtil.IndexType indexType,
long headerSize) |
void |
DefaultHttp2FrameWriter.maxFrameSize(int max) |
void |
Http2FrameSizePolicy.maxFrameSize(int max)
Sets the maximum allowed frame size.
|
void |
DefaultHttp2FrameReader.maxFrameSize(int max) |
void |
Http2HeadersEncoder.Configuration.maxHeaderListSize(long max)
Represents the value for
SETTINGS_MAX_HEADER_LIST_SIZE.
|
void |
DefaultHttp2HeadersEncoder.maxHeaderListSize(long max) |
void |
DefaultHttp2HeadersDecoder.maxHeaderListSize(long max,
long goAwayMax) |
void |
Http2HeadersDecoder.Configuration.maxHeaderListSize(long max,
long goAwayMax)
Configure the maximum allowed size in bytes of each set of headers.
|
void |
DefaultHttp2HeadersDecoder.maxHeaderTableSize(long max) |
void |
Http2HeadersDecoder.Configuration.maxHeaderTableSize(long max)
Represents the value for
SETTINGS_HEADER_TABLE_SIZE.
|
void |
Http2HeadersEncoder.Configuration.maxHeaderTableSize(long max)
Represents the value for
SETTINGS_HEADER_TABLE_SIZE.
|
void |
DefaultHttp2HeadersEncoder.maxHeaderTableSize(long max) |
private EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newCompressor(ChannelHandlerContext ctx,
Http2Headers headers,
boolean endOfStream)
Checks if a new compressor object is needed for the stream identified by
streamId . |
protected EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newContentCompressor(ChannelHandlerContext ctx,
java.lang.CharSequence contentEncoding)
Returns a new
EmbeddedChannel that encodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected EmbeddedChannel |
DelegatingDecompressorFrameListener.newContentDecompressor(ChannelHandlerContext ctx,
java.lang.CharSequence contentEncoding)
Returns a new
EmbeddedChannel that decodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.newMessage(Http2Stream stream,
Http2Headers headers,
boolean validateHttpHeaders,
ByteBufAllocator alloc)
Create a new
FullHttpMessage based upon the current connection parameters |
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2EventAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DefaultHttp2ConnectionDecoder.FrameReadListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream)
Handles an inbound
DATA frame. |
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData)
Handles an inbound
GO_AWAY frame. |
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
(package private) void |
DefaultHttp2ConnectionDecoder.onGoAwayRead0(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream)
Handles an inbound
HEADERS frame. |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream)
Handles an inbound
HEADERS frame with priority information specified. |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2ConnectionHandler.onHttpClientUpgrade()
Handles the client-side (cleartext) upgrade from HTTP to HTTP/2.
|
void |
Http2ConnectionHandler.onHttpServerUpgrade(Http2Settings settings)
Handles the server-side (cleartext) upgrade from HTTP to HTTP/2.
|
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING acknowledgment. |
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING frame. |
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive)
Handles an inbound
PRIORITY frame. |
void |
Http2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
InboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding)
Handles an inbound
PUSH_PROMISE frame. |
void |
Http2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode)
Handles an inbound
RST_STREAM frame. |
void |
Http2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx)
Handles an inbound
SETTINGS acknowledgment frame. |
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings)
Handles an inbound
SETTINGS frame. |
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload)
Handler for a frame not defined by the HTTP/2 spec.
|
void |
Http2FrameListenerDecorator.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
(package private) void |
DefaultHttp2ConnectionDecoder.onUnknownFrame0(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement)
Handles an inbound
WINDOW_UPDATE frame. |
void |
Http2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
Http2Stream |
DefaultHttp2Connection.DefaultStream.open(boolean halfClosed) |
Http2Stream |
Http2Stream.open(boolean halfClosed)
Opens this stream, making it available via
Http2Connection.forEachActiveStream(Http2StreamVisitor) and
transition state to:
Http2Stream.State.OPEN if Http2Stream.state() is Http2Stream.State.IDLE and halfClosed is false .
Http2Stream.State.HALF_CLOSED_LOCAL if Http2Stream.state() is Http2Stream.State.IDLE and halfClosed
is true and the stream is local.
Http2Stream.State.HALF_CLOSED_REMOTE if Http2Stream.state() is Http2Stream.State.IDLE and halfClosed
is true and the stream is remote.
Http2Stream.State.RESERVED_LOCAL if Http2Stream.state() is Http2Stream.State.HALF_CLOSED_REMOTE .
Http2Stream.State.RESERVED_REMOTE if Http2Stream.state() is Http2Stream.State.HALF_CLOSED_LOCAL .
|
static HttpResponseStatus |
HttpConversionUtil.parseStatus(java.lang.CharSequence status)
Apply HTTP/2 rules while translating status code to
HttpResponseStatus |
boolean |
HpackHuffmanDecoder.DecoderProcessor.process(byte value) |
(package private) abstract void |
DefaultHttp2FrameReader.HeadersContinuation.processFragment(boolean endOfHeaders,
ByteBuf fragment,
Http2FrameListener listener)
Processes the next fragment for the current header block.
|
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx,
Http2Stream stream,
Http2Headers headers,
boolean endOfStream,
boolean allowAppend,
boolean appendToTrailer)
Provides translation between HTTP/2 and HTTP header objects while ensuring the stream
is in a valid state for additional headers.
|
private void |
DefaultHttp2FrameReader.processHeaderState(ByteBuf in) |
private void |
DefaultHttp2FrameReader.processPayloadState(ChannelHandlerContext ctx,
ByteBuf in,
Http2FrameListener listener) |
private boolean |
Http2ConnectionHandler.PrefaceDecoder.readClientPrefaceString(ByteBuf in)
Decodes the client connection preface string from the input buffer.
|
private void |
DefaultHttp2FrameReader.readContinuationFrame(ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readDataFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
void |
Http2InboundFrameLogger.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
void |
Http2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener)
Attempts to read the next frame from the input buffer.
|
void |
DefaultHttp2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
private static void |
DefaultHttp2FrameReader.readGoAwayFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readHeadersFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private java.lang.CharSequence |
HpackDecoder.readName(int index) |
private void |
DefaultHttp2FrameReader.readPingFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPriorityFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPushPromiseFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readRstStreamFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readSettingsFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private java.lang.CharSequence |
HpackDecoder.readStringLiteral(ByteBuf in,
int length,
boolean huffmanEncoded) |
private void |
DefaultHttp2FrameReader.readUnknownFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readWindowUpdateFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
void |
DefaultHttp2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.receiveFlowControlledFrame(Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream)
Receives an inbound
DATA frame from the remote endpoint and applies flow control policies to it for both
the stream as well as the connection. |
void |
DefaultHttp2LocalFlowController.AutoRefillState.receiveFlowControlledFrame(int dataLength) |
void |
DefaultHttp2LocalFlowController.DefaultState.receiveFlowControlledFrame(int dataLength) |
void |
DefaultHttp2LocalFlowController.FlowState.receiveFlowControlledFrame(int dataLength)
A flow control event has occurred and we should decrement the amount of available bytes for this stream.
|
void |
DecoratingHttp2ConnectionEncoder.remoteSettings(Http2Settings settings) |
void |
Http2ConnectionEncoder.remoteSettings(Http2Settings settings)
Sets the settings for the remote endpoint of the HTTP/2 connection.
|
void |
StreamBufferingEncoder.remoteSettings(Http2Settings settings) |
void |
DefaultHttp2ConnectionEncoder.remoteSettings(Http2Settings settings) |
DefaultHttp2Connection.DefaultStream |
DefaultHttp2Connection.DefaultEndpoint.reservePushStream(int streamId,
Http2Stream parent) |
Http2Stream |
Http2Connection.Endpoint.reservePushStream(int streamId,
Http2Stream parent)
Creates a push stream in the reserved state for this endpoint and notifies all listeners.
|
private void |
DefaultHttp2LocalFlowController.DefaultState.returnProcessedBytes(int delta) |
private void |
HpackDecoder.setDynamicTableSize(long dynamicTableSize) |
void |
HpackEncoder.setMaxHeaderListSize(long maxHeaderListSize) |
void |
HpackDecoder.setMaxHeaderListSize(long maxHeaderListSize,
long maxHeaderListSizeGoAway) |
void |
HpackEncoder.setMaxHeaderTableSize(ByteBuf out,
long maxHeaderTableSize)
Set the maximum table size.
|
void |
HpackDecoder.setMaxHeaderTableSize(long maxHeaderTableSize)
Set the maximum table size.
|
private boolean |
DefaultHttp2ConnectionDecoder.FrameReadListener.shouldIgnoreHeadersOrDataFrame(ChannelHandlerContext ctx,
int streamId,
Http2Stream stream,
java.lang.String frameName)
Helper method to determine if a frame that has the semantics of headers or data should be ignored for the
stream (which may be null ) associated with streamId . |
static FullHttpRequest |
HttpConversionUtil.toFullHttpRequest(int streamId,
Http2Headers http2Headers,
ByteBufAllocator alloc,
boolean validateHttpHeaders)
Create a new object to contain the request data
|
static HttpRequest |
HttpConversionUtil.toHttpRequest(int streamId,
Http2Headers http2Headers,
boolean validateHttpHeaders)
Create a new object to contain the request data.
|
static FullHttpResponse |
HttpConversionUtil.toHttpResponse(int streamId,
Http2Headers http2Headers,
ByteBufAllocator alloc,
boolean validateHttpHeaders)
Create a new object to contain the response data
|
void |
HttpConversionUtil.Http2ToHttpHeaderTranslator.translate(java.util.Map.Entry<java.lang.CharSequence,java.lang.CharSequence> entry) |
private void |
DefaultHttp2FrameReader.verifyAssociatedWithAStream() |
private void |
DefaultHttp2FrameReader.verifyContinuationFrame() |
private void |
DefaultHttp2FrameReader.verifyDataFrame() |
private boolean |
Http2ConnectionHandler.PrefaceDecoder.verifyFirstFrameIsSettings(ByteBuf in)
Peeks at that the next frame in the buffer and verifies that it is a non-ack
SETTINGS frame. |
private void |
DefaultHttp2FrameReader.verifyGoAwayFrame() |
private void |
DefaultHttp2FrameReader.verifyHeadersFrame() |
private void |
DefaultHttp2FrameReader.verifyNotProcessingHeaders()
Verify that current state is not processing on header block
|
private void |
DefaultHttp2FrameReader.verifyPadding(int padding) |
private void |
DefaultHttp2FrameReader.verifyPayloadLength(int payloadLength) |
private void |
DefaultHttp2FrameReader.verifyPingFrame() |
private void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.verifyPrefaceReceived()
Verifies that the HTTP/2 connection preface has been received from the remote endpoint.
|
private void |
DefaultHttp2FrameReader.verifyPriorityFrame() |
private void |
DefaultHttp2FrameReader.verifyPushPromiseFrame() |
private void |
DefaultHttp2FrameReader.verifyRstStreamFrame() |
private void |
DefaultHttp2FrameReader.verifySettingsFrame() |
private void |
DefaultHttp2ConnectionDecoder.FrameReadListener.verifyStreamMayHaveExisted(int streamId) |
private static void |
DefaultHttp2FrameReader.verifyStreamOrConnectionId(int streamId,
java.lang.String argumentName) |
private void |
DefaultHttp2FrameReader.verifyUnknownFrame() |
private void |
DefaultHttp2FrameReader.verifyWindowUpdateFrame() |
boolean |
DefaultHttp2LocalFlowController.WindowUpdateVisitor.visit(Http2Stream stream) |
boolean |
Http2StreamVisitor.visit(Http2Stream stream) |
float |
DefaultHttp2LocalFlowController.windowUpdateRatio(Http2Stream stream)
The window update ratio is used to determine when a window update must be sent.
|
void |
DefaultHttp2LocalFlowController.windowUpdateRatio(Http2Stream stream,
float ratio)
The window update ratio is used to determine when a window update must be sent.
|
(package private) void |
WeightedFairQueueByteDistributor.State.write(int numBytes,
StreamByteDistributor.Writer writer) |
(package private) void |
UniformStreamByteDistributor.State.write(int numBytes,
StreamByteDistributor.Writer writer)
Write any allocated bytes for the given stream and updates the streamable bytes,
assuming all of the bytes will be written.
|
void |
DefaultHttp2RemoteFlowController.writePendingBytes() |
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.writePendingBytes() |
void |
Http2RemoteFlowController.writePendingBytes()
Write all data pending in the flow controller up to the flow-control limits.
|
private void |
DefaultHttp2LocalFlowController.DefaultState.writeWindowUpdate()
Called to perform a window update for this stream (or connection).
|
boolean |
DefaultHttp2LocalFlowController.DefaultState.writeWindowUpdateIfNeeded() |
boolean |
DefaultHttp2LocalFlowController.FlowState.writeWindowUpdateIfNeeded()
Updates the flow control window for this stream if it is appropriate.
|