Top Inners Fields Constructors Methods
org.apache.hc.core5.http2.impl.nio

pack-priv abstract Class AbstractH2StreamMultiplexer

extends Object
implements Identifiable, HttpConnection
Class Inheritance
All Implemented Interfaces
org.apache.hc.core5.http.HttpConnection, org.apache.hc.core5.http.SocketModalCloseable, org.apache.hc.core5.io.ModalCloseable, java.io.Closeable, java.lang.AutoCloseable, org.apache.hc.core5.util.Identifiable
Known Direct Subclasses
org.apache.hc.core5.http2.impl.nio.ClientH2StreamMultiplexer, org.apache.hc.core5.http2.impl.nio.ServerH2StreamMultiplexer
Imports
java.io.IOException, java.net.SocketAddress, java.nio.BufferOverflowException, .ByteBuffer, java.nio.channels.SelectionKey, java.nio.charset.CharacterCodingException, java.util.Deque, .Iterator, .List, .Map, .Queue, java.util.concurrent.ConcurrentHashMap, .ConcurrentLinkedDeque, .ConcurrentLinkedQueue, java.util.concurrent.atomic.AtomicInteger, javax.net.ssl.SSLSession, org.apache.hc.core5.concurrent.CancellableDependency, org.apache.hc.core5.http.ConnectionClosedException, .EndpointDetails, .Header, .HttpConnection, .HttpException, .HttpStreamResetException, .HttpVersion, .ProtocolException, .ProtocolVersion, .RequestNotExecutedException, org.apache.hc.core5.http.config.CharCodingConfig, org.apache.hc.core5.http.impl.BasicEndpointDetails, .BasicHttpConnectionMetrics, .CharCodingSupport, org.apache.hc.core5.http.nio.AsyncPushConsumer, .AsyncPushProducer, .HandlerFactory, org.apache.hc.core5.http.nio.command.ExecutableCommand, .ShutdownCommand, org.apache.hc.core5.http.protocol.HttpCoreContext, .HttpProcessor, org.apache.hc.core5.http2.H2ConnectionException, .H2Error, .H2StreamResetException, org.apache.hc.core5.http2.config.H2Config, .H2Param, .H2Setting, org.apache.hc.core5.http2.frame.FrameFactory, .FrameFlag, .FrameType, .RawFrame, .StreamIdGenerator, org.apache.hc.core5.http2.hpack.HPackDecoder, .HPackEncoder, org.apache.hc.core5.http2.impl.BasicH2TransportMetrics, org.apache.hc.core5.http2.nio.AsyncPingHandler, org.apache.hc.core5.http2.nio.command.PingCommand, org.apache.hc.core5.io.CloseMode, org.apache.hc.core5.reactor.Command, .ProtocolIOSession, org.apache.hc.core5.reactor.ssl.TlsDetails, org.apache.hc.core5.util.Args, .ByteArrayBuffer, .Identifiable, .Timeout

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static enum
AbstractH2StreamMultiplexer.ConnectionHandshake

private static class
AbstractH2StreamMultiplexer.Continuation

pack-priv static class
AbstractH2StreamMultiplexer.H2Stream

private class
AbstractH2StreamMultiplexer.H2StreamChannelImpl

pack-priv static enum
AbstractH2StreamMultiplexer.SettingsHandshake

Field Summary

Modifier and TypeField and Description
private static final long
CONNECTION_WINDOW_LOW_MARK

private final AtomicInteger
connInputWindow

private final BasicHttpConnectionMetrics
connMetrics

private final AtomicInteger
connOutputWindow

private AbstractH2StreamMultiplexer.ConnectionHandshake
connState

private AbstractH2StreamMultiplexer.Continuation
continuation

private EndpointDetails
endpointDetails

private final FrameFactory
frameFactory

private boolean
goAwayReceived

private final HPackDecoder
hPackDecoder

private final HPackEncoder
hPackEncoder

private final HttpProcessor
httpProcessor

private final StreamIdGenerator
idGenerator

private int
initInputWinSize

private int
initOutputWinSize

private final FrameInputBuffer
inputBuffer

private final BasicH2TransportMetrics
inputMetrics

private final ProtocolIOSession
ioSession

private final AtomicInteger
lastStreamId

private static final long
LINGER_TIME

private final H2Config
localConfig

private AbstractH2StreamMultiplexer.SettingsHandshake
localSettingState

private int
lowMark

private final FrameOutputBuffer
outputBuffer

private final BasicH2TransportMetrics
outputMetrics

private final Deque<RawFrame>
outputQueue

private final AtomicInteger
outputRequests

private final Queue<AsyncPingHandler>
pingHandlers

private int
processedRemoteStreamId

private volatile H2Config
remoteConfig

private AbstractH2StreamMultiplexer.SettingsHandshake
remoteSettingState

private final H2StreamListener
streamListener

private final Map<Integer, AbstractH2StreamMultiplexer.H2Stream>
streamMap

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractH2StreamMultiplexer(final ProtocolIOSession ioSession, final FrameFactory frameFactory, final StreamIdGenerator idGenerator, final HttpProcessor httpProcessor, final CharCodingConfig charCodingConfig, final H2Config h2Config, final H2StreamListener streamListener)

Method Summary

Modifier and TypeMethod and Description
pack-priv abstract void
acceptHeaderFrame()

pack-priv abstract void
acceptPushFrame()

pack-priv abstract void
acceptPushRequest()

pack-priv void
appendState(final StringBuilder buf)

private void
applyLocalSettings()

private void
applyRemoteSettings(final H2Config config)

public void
close()

Implements org.apache.hc.core5.http.HttpConnection.close.

Closes this connection gracefully.
public void
close(final CloseMode
How to close the receiver.
closeMode)

Implements org.apache.hc.core5.io.ModalCloseable.close.

Closes this process or endpoint and releases any system resources associated with it.
private void
commitFrame(final RawFrame frame)

private void
commitFrameInternal(final RawFrame frame)

private void
commitHeaders(final int streamId, final List<? extends Header> headers, final boolean endStream)

private void
commitPushPromise(final int streamId, final int promisedStreamId, final List<Header> headers)

private void
consumeContinuationFrame(final RawFrame frame, final AbstractH2StreamMultiplexer.H2Stream stream)

private void
consumeDataFrame(final RawFrame frame, final AbstractH2StreamMultiplexer.H2Stream stream)

private void
consumeFrame(final RawFrame frame)

private void
consumeHeaderFrame(final RawFrame frame, final AbstractH2StreamMultiplexer.H2Stream stream)

private void
consumePushPromiseFrame(final RawFrame frame, final ByteBuffer payload, final AbstractH2StreamMultiplexer.H2Stream promisedStream)

private void
consumeSettingsFrame(final ByteBuffer payload)

pack-priv abstract H2StreamHandler
createLocallyInitiatedStream(ExecutableCommand command, H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics)

pack-priv abstract H2StreamHandler
createRemotelyInitiatedStream(H2StreamChannel channel, HttpProcessor httpProcessor, BasicHttpConnectionMetrics connMetrics, HandlerFactory<AsyncPushConsumer> pushHandlerFactory)

pack-priv List<Header>
decodeHeaders(final ByteBuffer payload)

private int
generateStreamId()

public EndpointDetails
getEndpointDetails()

Implements org.apache.hc.core5.http.HttpConnection.getEndpointDetails.

Returns this connection's endpoint details.
public String
getId()

Implements org.apache.hc.core5.util.Identifiable.getId.

public SocketAddress
getLocalAddress()

Implements org.apache.hc.core5.http.HttpConnection.getLocalAddress.

Returns this connection's local address or null if it is not bound yet.
public ProtocolVersion
getProtocolVersion()

Implements org.apache.hc.core5.http.HttpConnection.getProtocolVersion.

Returns this connection's protocol version or null if unknown.
public SocketAddress
getRemoteAddress()

Implements org.apache.hc.core5.http.HttpConnection.getRemoteAddress.

Returns this connection's remote address or null if it is not connected yet or unconnected.
public Timeout
getSocketTimeout()

Implements org.apache.hc.core5.http.SocketModalCloseable.getSocketTimeout.

Returns the socket timeout value.
public SSLSession
getSSLSession()

Implements org.apache.hc.core5.http.HttpConnection.getSSLSession.

Returns this connection's SSL session or null if TLS has not been activated.
private AbstractH2StreamMultiplexer.H2Stream
getValidStream(final int streamId)

private void
incrementInputCapacity(final int streamId, final AtomicInteger inputWindow, final int inputCapacity)

public boolean
isOpen()

Implements org.apache.hc.core5.http.HttpConnection.isOpen.

Checks if this connection is open.
private void
maximizeConnWindow(final int connWinSize)

public final void
onConnect()

public final void
onDisconnect()

public final void
onException(final Exception cause)

public final void
onInput(final ByteBuffer src)

public final void
onOutput()

public final void
onTimeout(final Timeout timeout)

private void
processPendingCommands()

private void
produceOutput()

private void
requestSessionOutput()

public void
setSocketTimeout(final Timeout
timeout value
timeout)

Implements org.apache.hc.core5.http.SocketModalCloseable.setSocketTimeout.

Sets the socket timeout value.
private int
streamData(final int streamId, final AtomicInteger streamOutputWindow, final ByteBuffer payload)

private void
streamDataFrame(final int streamId, final AtomicInteger streamOutputWindow, final ByteBuffer payload, final int chunk)

private int
updateInputWindow(final int streamId, final AtomicInteger window, final int delta)

private void
updateLastStreamId(final int streamId)

private int
updateOutputWindow(final int streamId, final AtomicInteger window, final int delta)

private int
updateWindow(final AtomicInteger window, final int delta)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait