(package private) static Http2Stream.State |
DefaultHttp2Connection.activeState(int streamId,
Http2Stream.State initialState,
boolean isLocal,
boolean halfClosed) |
|
(package private) void |
DefaultHttp2FrameReader.HeadersBlockBuilder.addFragment(ByteBuf fragment,
int len,
ByteBufAllocator alloc,
boolean endOfHeaders) |
Adds a fragment to the block.
|
static void |
HttpConversionUtil.addHttp2ToHttpHeaders(int streamId,
Http2Headers inputHeaders,
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 |
DefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx) |
|
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.channelHandlerContext(ChannelHandlerContext ctx) |
|
void |
Http2FlowController.channelHandlerContext(ChannelHandlerContext ctx) |
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.channelWritabilityChange() |
|
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.channelWritabilityChange() |
Called when the writability of the underlying channel changes.
|
void |
DefaultHttp2RemoteFlowController.channelWritabilityChanged() |
|
void |
Http2RemoteFlowController.channelWritabilityChanged() |
|
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) |
|
private void |
DefaultHttp2Connection.closeStreamsGreaterThanLastKnownStreamId(int lastKnownStream,
DefaultHttp2Connection.DefaultEndpoint<?> endpoint) |
|
private boolean |
DefaultHttp2LocalFlowController.consumeAllBytes(DefaultHttp2LocalFlowController.FlowState state,
int numBytes) |
|
boolean |
DefaultHttp2LocalFlowController.AutoRefillState.consumeBytes(int numBytes) |
|
boolean |
DefaultHttp2LocalFlowController.consumeBytes(Http2Stream stream,
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.
|
boolean |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.consumeBytes(Http2Stream stream,
int numBytes) |
|
(package private) int |
DelegatingDecompressorFrameListener.Http2Decompressor.consumeBytes(int streamId,
int decompressedBytes) |
|
(package private) boolean |
Http2FrameCodec.consumeBytes(int streamId,
int bytes) |
|
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.
|
DefaultHttp2Connection.DefaultStream |
DefaultHttp2Connection.DefaultEndpoint.createStream(int streamId,
boolean halfClosed) |
|
Http2Stream |
Http2Connection.Endpoint.createStream(int streamId,
boolean halfClosed) |
Creates a stream initiated by this endpoint.
|
(package private) void |
HpackDecoder.decode(int streamId,
ByteBuf in,
Http2Headers headers,
boolean validateHeaders) |
Decode the header block into header fields.
|
private void |
HpackDecoder.decode(ByteBuf in,
HpackDecoder.Http2HeadersSink sink) |
|
AsciiString |
HpackHuffmanDecoder.decode(ByteBuf buf,
int length) |
Decompresses the given Huffman coded string literal.
|
private void |
HpackDecoder.decodeDynamicTableSizeUpdates(ByteBuf in) |
|
void |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
|
void |
DefaultHttp2ConnectionDecoder.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) |
|
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) |
|
(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 |
UniformStreamByteDistributor.distribute(int maxBytes,
StreamByteDistributor.Writer writer) |
|
boolean |
WeightedFairQueueByteDistributor.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 |
DefaultHttp2HeadersEncoder.encodeHeaders(int streamId,
Http2Headers headers,
ByteBuf buffer) |
|
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.
|
private void |
HpackEncoder.encodeHeadersEnforceMaxHeaderListSize(int streamId,
ByteBuf out,
Http2Headers headers,
Http2HeadersEncoder.SensitivityDetector sensitivityDetector) |
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.enqueueFrame(DefaultHttp2RemoteFlowController.FlowState state,
Http2RemoteFlowController.FlowControlled frame) |
|
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.enqueueFrame(DefaultHttp2RemoteFlowController.FlowState state,
Http2RemoteFlowController.FlowControlled frame) |
Add a frame to be sent via flow control.
|
(package private) void |
HpackDecoder.Http2HeadersSink.finish() |
|
private void |
Http2MultiplexHandler.fireExceptionCaughtForActiveStream(java.lang.Throwable cause) |
|
Http2Stream |
DefaultHttp2Connection.ActiveStreams.forEachActiveStream(Http2StreamVisitor visitor) |
|
Http2Stream |
DefaultHttp2Connection.forEachActiveStream(Http2StreamVisitor visitor) |
|
protected void |
Http2ChannelDuplexHandler.forEachActiveStream(Http2FrameStreamVisitor streamVisitor) |
Allows to iterate over all currently active streams.
|
Http2Stream |
Http2Connection.forEachActiveStream(Http2StreamVisitor visitor) |
Provide a means of iterating over the collection of active streams.
|
(package private) void |
Http2FrameCodec.forEachActiveStream(Http2FrameStreamVisitor streamVisitor) |
Iterates over all active HTTP/2 streams.
|
private HpackHeaderField |
HpackDecoder.getIndexedHeader(int index) |
|
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.
|
void |
DefaultHttp2Connection.goAwayReceived(int lastKnownStream,
long errorCode,
ByteBuf debugData) |
|
void |
Http2Connection.goAwayReceived(int lastKnownStream,
long errorCode,
ByteBuf message) |
Indicates that a GOAWAY was received from the remote endpoint and sets the last known stream.
|
boolean |
DefaultHttp2Connection.goAwaySent(int lastKnownStream,
long errorCode,
ByteBuf debugData) |
|
boolean |
Http2Connection.goAwaySent(int lastKnownStream,
long errorCode,
ByteBuf message) |
Updates the local state of this Http2Connection as a result of a GOAWAY to send to the remote
endpoint.
|
(package private) static void |
InboundHttpToHttp2Adapter.handle(ChannelHandlerContext ctx,
Http2Connection connection,
Http2FrameListener listener,
FullHttpMessage message) |
|
static void |
Http2CodecUtil.headerListSizeExceeded(int streamId,
long maxHeaderListSize,
boolean onDecode) |
|
static void |
Http2CodecUtil.headerListSizeExceeded(long maxHeaderListSize) |
|
(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.
|
private void |
Http2FrameCodec.increaseInitialConnectionWindow(int deltaBytes) |
|
(package private) void |
DefaultHttp2ConnectionDecoder.ContentLength.increaseReceivedBytes(boolean server,
int streamId,
int bytes,
boolean isEnd) |
|
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.
|
void |
DefaultHttp2LocalFlowController.incrementWindowSize(Http2Stream stream,
int delta) |
|
void |
DefaultHttp2RemoteFlowController.incrementWindowSize(Http2Stream stream,
int delta) |
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.incrementWindowSize(DefaultHttp2RemoteFlowController.FlowState state,
int delta) |
|
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.incrementWindowSize(DefaultHttp2RemoteFlowController.FlowState state,
int delta) |
Increment the window size for a particular stream.
|
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.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 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 |
DefaultHttp2RemoteFlowController.initialWindowSize(int newWindowSize) |
|
(package private) void |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.initialWindowSize(int newWindowSize) |
|
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.initialWindowSize(int newWindowSize) |
|
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.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.
|
void |
DefaultHttp2FrameReader.maxFrameSize(int max) |
|
void |
DefaultHttp2FrameWriter.maxFrameSize(int max) |
|
void |
Http2FrameSizePolicy.maxFrameSize(int max) |
Sets the maximum allowed frame size.
|
void |
DefaultHttp2HeadersDecoder.maxHeaderListSize(long max,
long goAwayMax) |
|
void |
DefaultHttp2HeadersEncoder.maxHeaderListSize(long max) |
|
void |
Http2HeadersDecoder.Configuration.maxHeaderListSize(long max,
long goAwayMax) |
Configure the maximum allowed size in bytes of each set of headers.
|
void |
Http2HeadersEncoder.Configuration.maxHeaderListSize(long max) |
|
void |
DefaultHttp2HeadersDecoder.maxHeaderTableSize(long max) |
|
void |
DefaultHttp2HeadersEncoder.maxHeaderTableSize(long max) |
|
void |
Http2HeadersDecoder.Configuration.maxHeaderTableSize(long max) |
|
void |
Http2HeadersEncoder.Configuration.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 .
|
private FullHttpMessage |
Http2StreamFrameToHttpObjectCodec.newFullMessage(int id,
Http2Headers headers,
ByteBufAllocator alloc) |
|
private HttpMessage |
Http2StreamFrameToHttpObjectCodec.newMessage(int id,
Http2Headers headers) |
|
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.newMessage(Http2Stream stream,
Http2Headers headers,
boolean validateHttpHeaders,
ByteBufAllocator alloc) |
|
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 |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
|
int |
Http2EmptyDataFrameListener.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 |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
|
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
Handles an inbound DATA frame.
|
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
|
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
|
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 |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
|
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
|
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
Handles an inbound GO_AWAY frame.
|
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
|
(package private) void |
DefaultHttp2ConnectionDecoder.onGoAwayRead0(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
|
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
|
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 padding,
boolean endOfStream) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.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 padding,
boolean endStream) |
|
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
|
void |
Http2EmptyDataFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
|
void |
Http2EmptyDataFrameListener.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 padding,
boolean endStream) |
|
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
|
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
|
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
|
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
Handles an inbound HEADERS frame.
|
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 |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
|
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
|
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
|
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
|
void |
Http2ConnectionHandler.onHttpClientUpgrade() |
Handles the client-side (cleartext) upgrade from HTTP to HTTP/2.
|
void |
Http2MultiplexCodec.onHttpClientUpgrade() |
Deprecated.
|
void |
Http2ConnectionHandler.onHttpServerUpgrade(Http2Settings settings) |
Handles the server-side (cleartext) upgrade from HTTP to HTTP/2.
|
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingAckRead(ChannelHandlerContext ctx,
long data) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingAckRead(ChannelHandlerContext ctx,
long data) |
|
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
long data) |
|
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx,
long data) |
|
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
long data) |
Handles an inbound PING acknowledgment.
|
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
long data) |
|
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingRead(ChannelHandlerContext ctx,
long data) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingRead(ChannelHandlerContext ctx,
long data) |
|
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
long data) |
|
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
long data) |
|
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
long data) |
Handles an inbound PING frame.
|
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
long data) |
|
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 |
Http2EventAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
|
void |
Http2FrameAdapter.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 |
Http2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
|
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 |
Http2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
|
void |
Http2FrameAdapter.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 |
Http2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
|
void |
InboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
|
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
Http2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
Handles an inbound RST_STREAM frame.
|
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
Http2MaxRstFrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
|
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsAckRead(ChannelHandlerContext ctx) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsAckRead(ChannelHandlerContext ctx) |
|
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
|
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
|
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx) |
Handles an inbound SETTINGS acknowledgment frame.
|
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
|
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
|
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
|
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
|
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
Handles an inbound SETTINGS frame.
|
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
|
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
|
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 |
Http2EventAdapter.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 |
DefaultHttp2ConnectionDecoder.FrameReadListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
|
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
|
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
|
void |
Http2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
|
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
Handles an inbound WINDOW_UPDATE frame.
|
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
|
Http2Stream |
DefaultHttp2Connection.DefaultStream.open(boolean halfClosed) |
|
Http2Stream |
Http2Stream.open(boolean halfClosed) |
|
static HttpResponseStatus |
HttpConversionUtil.parseStatus(java.lang.CharSequence status) |
|
private boolean |
DefaultHttp2FrameReader.preProcessFrame(ByteBuf in) |
|
(package private) abstract void |
DefaultHttp2FrameReader.HeadersContinuation.processFragment(boolean endOfHeaders,
ByteBuf fragment,
int len,
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.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 |
DefaultHttp2FrameReader.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 |
Http2InboundFrameLogger.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
|
private void |
DefaultHttp2FrameReader.readGoAwayFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
|
private void |
DefaultHttp2FrameReader.readHeadersFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
|
private AsciiString |
HpackDecoder.readName(int index) |
|
private void |
DefaultHttp2FrameReader.readPingFrame(ChannelHandlerContext ctx,
long data,
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 AsciiString |
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.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 |
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 |
DecoratingHttp2ConnectionEncoder.remoteSettings(Http2Settings settings) |
|
void |
DefaultHttp2ConnectionEncoder.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) |
|
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) |
|
(package private) void |
HpackDecoder.setMaxHeaderListSize(long maxHeaderListSize) |
|
void |
HpackEncoder.setMaxHeaderListSize(long maxHeaderListSize) |
|
(package private) void |
HpackDecoder.setMaxHeaderTableSize(long maxHeaderTableSize) |
Set the maximum table size.
|
void |
HpackEncoder.setMaxHeaderTableSize(ByteBuf out,
long maxHeaderTableSize) |
Set the maximum table size.
|
private boolean |
DefaultHttp2ConnectionDecoder.FrameReadListener.shouldIgnoreHeadersOrDataFrame(ChannelHandlerContext ctx,
int streamId,
Http2Stream stream,
boolean endOfStream,
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 FullHttpRequest |
HttpConversionUtil.toFullHttpRequest(int streamId,
Http2Headers http2Headers,
ByteBuf content,
boolean validateHttpHeaders) |
Create a new object to contain the request data
|
static FullHttpResponse |
HttpConversionUtil.toFullHttpResponse(int streamId,
Http2Headers http2Headers,
ByteBufAllocator alloc,
boolean validateHttpHeaders) |
Create a new object to contain the response data
|
static FullHttpResponse |
HttpConversionUtil.toFullHttpResponse(int streamId,
Http2Headers http2Headers,
ByteBuf content,
boolean validateHttpHeaders) |
Create a new object to contain the response data
|
static HttpRequest |
HttpConversionUtil.toHttpRequest(int streamId,
Http2Headers http2Headers,
boolean validateHttpHeaders) |
Create a new object to contain the request data.
|
static HttpResponse |
HttpConversionUtil.toHttpResponse(int streamId,
Http2Headers http2Headers,
boolean validateHttpHeaders) |
Create a new object to contain the response data.
|
(package private) void |
HttpConversionUtil.Http2ToHttpHeaderTranslator.translateHeaders(java.lang.Iterable<java.util.Map.Entry<java.lang.CharSequence,java.lang.CharSequence>> inputHeaders) |
|
private void |
Http2FrameCodec.tryExpandConnectionFlowControlWindow(Http2Connection connection) |
|
private static HpackDecoder.HeaderType |
HpackDecoder.validateHeader(int streamId,
AsciiString name,
java.lang.CharSequence value,
HpackDecoder.HeaderType previousHeaderType) |
|
private void |
DefaultHttp2FrameReader.verifyAssociatedWithAStream() |
|
private void |
DefaultHttp2ConnectionDecoder.verifyContentLength(Http2Stream stream,
int data,
boolean isEnd) |
|
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.verifyFrameState() |
|
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.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,
boolean endOfStream,
java.lang.String frameName) |
|
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 |
DefaultHttp2RemoteFlowController.ListenerWritabilityMonitor.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 |
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.
|
(package private) void |
WeightedFairQueueByteDistributor.State.write(int numBytes,
StreamByteDistributor.Writer writer) |
|
(package private) void |
DefaultHttp2RemoteFlowController.WritabilityMonitor.writePendingBytes() |
|
void |
DefaultHttp2RemoteFlowController.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.
|