Grizzly NIO 5.0.2 · org.glassfish.grizzly.http2.Http2Session

Modifier and Type	Class and Description
private class	Http2Session.ConnectionCloseListener

Modifier and Type	Field and Description
private final Holder<?>	addressHolder
private int	checkCount
private volatile CloseType	closeFlag References Deprecated `CloseType` is deprecated or references (maybe indirectly) at least one deprecated element.
private final AtomicInteger	concurrentStreamsCount
private final Connection<?>	connection
private final ReentrantLock	deflaterLock
private int	goingAwayLastStreamId
pack-priv final Http2BaseFilter	handlerFilter
private HeadersDecoder	headersDecoder
private HeadersEncoder	headersEncoder
private volatile FilterChain	htt2SessionChain
private final Http2Configuration	http2Configuration
pack-priv Http2State	http2State
private volatile FilterChain	http2StreamChain
private boolean	isFirstInFrame
private volatile boolean	isPrefaceReceived
private volatile boolean	isPrefaceSent
private final boolean	isServer
private int	lastLocalStreamId
pack-priv int	lastPeerStreamId
private volatile int	localConnectionWindowSize
private volatile int	localMaxConcurrentStreams
private final int	localMaxFramePayloadSize
private volatile int	localStreamWindowSize
private static final Logger	LOGGER
private volatile int	maxHeaderListSize
private final ReentrantLock	newClientStreamLock
private final Http2SessionOutputSink	outputSink
private int	peerMaxConcurrentStreams
private int	peerMaxFramePayloadSize
private int	peerStreamWindowSize
private boolean	pushEnabled
private FutureImpl<Http2Session>	sessionClosed
private final Object	sessionLock
private volatile SSLBaseFilter	sslFilter
private volatile int	streamsHighWaterMark
private final TreeMap<Integer, Http2Stream>	streamsMap
pack-priv final List<Http2Stream>	streamsToFlushInput
protected final List<Http2Frame>	tmpHeaderFramesList
private final AtomicInteger	unackedReadBytes

Access	Constructor and Description
public	Http2Session(final Connection<?> connection, final boolean isServer, final Http2BaseFilter handlerFilter)

Method Summary

Modifier and Type	Method and Description
pack-priv Http2Stream	acceptStream(final HttpRequestPacket request, final int streamId, final int parentStreamId, final boolean exclusive, final int priority)
public Http2Stream	Returns: a new `Http2Stream` for this request acceptUpgradeStream(final HttpRequestPacket the request that initiated the upgrade request, final int the stream priority priority, final boolean is more content expected? fin) The method is called to create an `Http2Stream` initiated via HTTP/1.1 Upgrade mechanism.
pack-priv void	ackConsumedData(final int size, in bytes, of the data being acknowledged sz) Acknowledge that certain amount of data has been read.
pack-priv void	ackConsumedData(final Http2Stream the stream that data is being ack'd on. stream, final int size, in bytes, of the data being acknowledged sz) Acknowledge that certain amount of data has been read.
pack-priv static void	bind(final Connection<L> connection, final Http2Session http2Session)
private List<Http2Frame>	Returns: the result `List` with the frames bufferToHeaderFrames(final int the stream associated with the headers. streamId, final Buffer a `Buffer` containing compressed headers compressedHeaders, final boolean will any additional data be sent after these headers? isEos, final List<Http2Frame> the `List` to which `Http2Frame`s will be added toList) Encodes a compressed header buffer as a `HeadersFrame` and a sequence of 0 or more `ContinuationFrame`s.
private List<Http2Frame>	Returns: the result `List` with the frames bufferToPushPromiseFrames(final int the stream associated with these headers streamId, final int the stream of the push promise promisedStreamId, final Buffer the compressed headers to be sent compressedHeaders, final List<Http2Frame> the `List` to which `Http2Frame`s will be added toList) Encodes a compressed header buffer as a `PushPromiseFrame` and a sequence of 0 or more `ContinuationFrame`s.
protected void	checkFrameSequenceSemantics(final Http2Frame frame)
private List<Http2Frame>	Returns: the result `List` with the frames completeHeadersProviderFrameSerialization(final HeaderBlockFragment.HeaderBlockFragmentBuilder<T extends HeaderBlockFragment.HeaderBlockFragmentBuilder> builder, final int the stream associated with this `HeaderBlockFragment` streamId, final Buffer the `Buffer` containing the compressed headers compressedHeaders, List<Http2Frame> the `List` to which `Http2Frame`s will be added toList) Completes the `HeaderBlockFragment` sequence serialization.
private void	decStreamCount()
pack-priv void	deregisterStream() Called from `Http2Stream` once stream is completely closed.
protected List<Http2Frame>	Returns: the HTTP2 header frames sequence encodeHttpHeaderAsHeaderFrames(final FilterChainContext the current `FilterChainContext` ctx, final HttpHeader the `HttpHeader` to encode httpHeader, final int the stream associated with this request streamId, final boolean is this the last frame? isLast, final List<Http2Frame> the target `List`, to which the frames will be serialized toList, final Map<String, String> capture) Encodes the `HttpHeader` and locks the compression lock.
protected List<Http2Frame>	Returns: the HTTP2 push promise frames sequence encodeHttpRequestAsPushPromiseFrames(final FilterChainContext the current `FilterChainContext` ctx, final HttpRequestPacket the `HttpRequestPacket` to encode. httpRequest, final int the stream associated with this request. streamId, final int the push promise stream ID. promisedStreamId, final List<Http2Frame> the target `List`, to which the frames will be serialized toList, final Map<String, String> capture) Encodes the `HttpRequestPacket` as a `PushPromiseFrame` and locks the compression lock.
protected List<Http2Frame>	Returns: the HTTP2 header frames sequence encodeInterimResponseAsHeaderFrames(final FilterChainContext the current `FilterChainContext` ctx, final HttpResponsePacket the `HttpResponsePacket` whose interim status and headers are to be encoded response, final int the stream associated with this response streamId, final List<Http2Frame> the target `List`, to which the frames will be serialized toList, final Map<String, String> optional map collecting the encoded headers for logging capture) Encodes an informational (1xx) interim response, such as `103 Early Hints`, as HTTP/2 HEADERS frames.
protected List<Http2Frame>	Returns: the HTTP2 header frames sequence encodeTrailersAsHeaderFrames(final int the stream associated with this request streamId, final List<Http2Frame> the target `List`, to which the frames will be serialized. toList, final MimeHeaders a `MimeHeaders` of headers to be transmitted as trailers. trailerHeaders, final Map<String, String> capture) Encodes the `Map` of header values into header frames to be sent as trailer headers.
public static Http2Session	get(final Connection<L> connection)
public int	getAvailablePeerConnectionWindowSize()
public Connection<L>	getConnection()
public int	getDefaultConnectionWindowSize()
public int	getDefaultMaxConcurrentStreams()
public int	getDefaultStreamWindowSize()
pack-priv ReentrantLock	getDeflaterLock()
protected int	Returns: the total frame size (including header size), or `-1` if the buffer doesn't contain enough bytes to read the size getFrameSize(final Buffer the buffer containing the frame data buffer) Returns the total frame size (including header size), or `-1` if the buffer doesn't contain enough bytes to read the size.
public int	getGoingAwayLastStreamId()
pack-priv HeadersDecoder	getHeadersDecoder()
pack-priv HeadersEncoder	getHeadersEncoder()
pack-priv FilterChain	getHttp2SessionChain()
pack-priv Http2State	getHttp2State()
public int	getLocalConnectionWindowSize()
public int	getLocalMaxConcurrentStreams() Returns: the maximum number of concurrent streams allowed for this session by our side.
public final int	getLocalMaxFramePayloadSize() Returns: The max `payload` size to be accepted by this side
public int	getLocalStreamWindowSize()
public int	getMaxHeaderListSize() Returns: the maximum size, in bytes, of header list.
public MemoryManager<E extends Buffer>	getMemoryManager()
public ReentrantLock	Returns: the `ReentrantLock` getNewClientStreamLock() The `ReentrantLock`, which assures that requests assigned to newly allocated stream IDs will be sent to the server in their order.
public int	getNextLocalStreamId()
protected Http2SessionOutputSink	getOutputSink()
public int	getPeerMaxConcurrentStreams() Returns: the maximum number of concurrent streams allowed for this session by peer.
public int	getPeerMaxFramePayloadSize() Returns: The max `payload` size to be accepted by the peer
public int	getPeerStreamWindowSize()
protected int	getSpecDefaultFramePayloadSize()
protected int	getSpecMaxFramePayloadSize()
protected int	getSpecMinFramePayloadSize()
public Http2Stream	getStream(final int streamId)
private void	incStreamCount()
private boolean	isClosed()
pack-priv boolean	isGoingAway()
pack-priv boolean	isHttp2InputEnabled()
pack-priv boolean	isHttp2OutputEnabled()
public boolean	isLocallyInitiatedStream(final int streamId)
pack-priv boolean	isParsingHeaders()
public boolean	isPushEnabled() Returns: `true` if push is enabled for this `Http2Session`, otherwise returns `false`.
public boolean	isServer()
protected Http2SessionOutputSink	newOutputSink()
protected Http2Stream	newStream(final HttpRequestPacket request, final int streamId, final int refStreamId, final boolean exclusive, final int priority)
protected Http2Stream	newUpgradeStream(final HttpRequestPacket request, final int priority)
protected void	onOversizedFrame(final Buffer buffer)
public Http2Stream	Returns: a new `Http2Stream` for this request openStream(final HttpRequestPacket the request that initiated the stream request, final int the ID of this new stream streamId, final int the parent stream parentStreamId, final boolean exclusive, final int the priority of this stream priority) Method is not thread-safe, it is expected that it will be called within `getNewClientStreamLock()` lock scope.
public Http2Stream	Returns: a new `Http2Stream` for this request openUpgradeStream(final HttpRequestPacket the request that initiated the upgrade request, final int the priority of the stream priority) The method is called on the client side, when the server confirms HTTP/1.1 -> HTTP/2.0 upgrade with '101' response.
public Http2Frame	parseHttp2FrameHeader(final Buffer buffer)
protected SettingsFrame.SettingsFrameBuilder	prepareSettings()
private void	pruneStreams()
pack-priv void	registerStream(final int streamId, final Http2Stream stream)
private void	registerUpgradeStream(final Http2Stream stream)
protected void	sendClientPreface()
private void	sendGoAwayAndClose(final Http2Frame frame)
pack-priv void	sendMessageUpstream(final Http2Stream stream, final HttpPacket message)
private void	sendMessageUpstream(final Http2Stream stream, final HttpPacket message, final FilterChainContext upstreamContext)
pack-priv void	sendMessageUpstreamWithParseNotify(final Http2Stream stream, final HttpContent httpContent)
pack-priv void	sendPreface()
protected void	sendServerPreface()
protected void	sendWindowUpdate(final int streamId, final int delta)
pack-priv void	setGoAwayByPeer(final int lastStreamId) Method is called, when GOAWAY is initiated by peer
private GoAwayFrame	setGoAwayLocally(final ErrorCode errorCode, final String detail, final boolean graceful)
public void	setLocalConnectionWindowSize(final int localConnectionWindowSize)
public void	setLocalMaxConcurrentStreams(int max number of streams locally allowed localMaxConcurrentStreams) Sets the default maximum number of concurrent streams allowed for this session by our side.
public void	setLocalStreamWindowSize(int localStreamWindowSize)
public void	setMaxHeaderListSize(int size, in bytes, of the header list. maxHeaderListSize) Set the maximum size, in bytes, of the header list.
pack-priv void	setPeerMaxConcurrentStreams(int peerMaxConcurrentStreams) Sets the default maximum number of concurrent streams allowed for this session by peer.
protected void	setPeerMaxFramePayloadSize(final int max payload size accepted by the peer. peerMaxFramePayloadSize) Sets the max `payload` size to be accepted by the peer.
pack-priv void	setPeerStreamWindowSize(final int peerStreamWindowSize)
public void	setPushEnabled(final boolean flag toggling push support. pushEnabled) Configure whether or not push is enabled on this `Http2Session`.
pack-priv void	setupFilterChains(final FilterChainContext the current `FilterChainContext` context, final boolean flag denoting the direction of the chain isUpStream) Initializes HTTP2 communication (if not initialized before) by forming HTTP2 connection and stream `FilterChain`s.
pack-priv void	terminate(final ErrorCode an RFC 7540 error code. errorCode, final String optional details. detail) Terminate the HTTP2 session sending a GOAWAY frame using the specified error code and optional detail.
pack-priv FutureImpl<Http2Session>	terminateGracefully() TODO

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

public Class Http2Session

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary