Undertow 2.3.12.Final · io.undertow.protocols.http2.Http2Channel

Modifier and Type	Class and Description
private class	Http2Channel.Http2ControlMessageExceptionHandler
private static class	Http2Channel.StreamCache
private static class	Http2Channel.StreamCacheEntry
private static class	Http2Channel.StreamHolder

Field Summary

Modifier and Type	Field and Description
private final Map<AttachmentKey<?>, Object>	attachments
public static final HttpString	AUTHORITY
public static final String	CLEARTEXT_UPGRADE_STRING
pack-priv static final int	CONTINUATION_FLAG_END_HEADERS
private Http2HeadersParser	continuationParser
private final Map<Integer, Http2Channel.StreamHolder>	currentStreams
pack-priv static final int	DATA_FLAG_END_SEGMENT
pack-priv static final int	DATA_FLAG_END_STREAM
pack-priv static final int	DATA_FLAG_PADDED
private final HpackDecoder	decoder
public static final int	DEFAULT_INITIAL_WINDOW_SIZE
public static final int	DEFAULT_MAX_FRAME_SIZE
private final HpackEncoder	encoder
private final int	encoderHeaderTableSize
public static final int	ERROR_CANCEL
public static final int	ERROR_COMPRESSION_ERROR
public static final int	ERROR_CONNECT_ERROR
public static final int	ERROR_ENHANCE_YOUR_CALM
public static final int	ERROR_FLOW_CONTROL_ERROR
public static final int	ERROR_FRAME_SIZE_ERROR
public static final int	ERROR_INADEQUATE_SECURITY
public static final int	ERROR_INTERNAL_ERROR
public static final int	ERROR_NO_ERROR
public static final int	ERROR_PROTOCOL_ERROR
public static final int	ERROR_REFUSED_STREAM
public static final int	ERROR_SETTINGS_TIMEOUT
public static final int	ERROR_STREAM_CLOSED
public static final int	FLOW_CONTROL_MIN_WINDOW
private final Object	flowControlLock
pack-priv static final int	FRAME_TYPE_CONTINUATION
pack-priv static final int	FRAME_TYPE_DATA
pack-priv static final int	FRAME_TYPE_GOAWAY
pack-priv static final int	FRAME_TYPE_HEADERS
pack-priv static final int	FRAME_TYPE_PING
pack-priv static final int	FRAME_TYPE_PRIORITY
pack-priv static final int	FRAME_TYPE_PUSH_PROMISE
pack-priv static final int	FRAME_TYPE_RST_STREAM
pack-priv static final int	FRAME_TYPE_SETTINGS
pack-priv static final int	FRAME_TYPE_WINDOW_UPDATE
private Http2FrameHeaderParser	frameParser
pack-priv static final int	HEADERS_FLAG_END_HEADERS
pack-priv static final int	HEADERS_FLAG_END_SEGMENT
pack-priv static final int	HEADERS_FLAG_END_STREAM
pack-priv static final int	HEADERS_FLAG_PADDED
pack-priv static final int	HEADERS_FLAG_PRIORITY
private final int	initialReceiveWindowSize
private volatile int	initialSendWindowSize The initial window size for newly created channels, guarded by `flowControlLock`
private boolean	initialSettingsReceived
private boolean	initialSettingsSent We send the settings frame lazily, which is basically a big hack to work around broken IE support for push (it dies if you send a settings frame with push enabled).
private int	lastAssignedStreamOtherSide
private boolean	lastDataRead
private int	lastGoodStreamId
private long	lastRstFrameMillis
public static final int	MAX_FRAME_SIZE
private final int	maxHeaderListSize
private final int	maxHeaders
private final int	maxPadding
private final int	maxRstFramesPerWindow
public static final HttpString	METHOD
private final Random	paddingRandom
private final ParseTimeoutUpdater	parseTimeoutUpdater
public static final HttpString	PATH
private boolean	peerGoneAway
pack-priv static final int	PING_FLAG_ACK
pack-priv static final int	PING_FRAME_LENGTH
pack-priv static final byte[]	PREFACE_BYTES
private int	prefaceCount
private final String	protocol
private volatile boolean	pushEnabled
private volatile int	receiveConcurrentStreams
private static final AtomicIntegerFieldUpdater<Http2Channel>	receiveConcurrentStreamsAtomicUpdater
private int	receivedRstFramesPerWindow
private final int	receiveMaxConcurrentStreams
private final int	receiveMaxFrameSize
private volatile int	receiveWindowSize How much data we have told the remote endpoint we are prepared to accept, guarded by `flowControlLock`
private final long	rstFramesTimeWindow
public static final HttpString	SCHEME
private volatile int	sendConcurrentStreams
private static final AtomicIntegerFieldUpdater<Http2Channel>	sendConcurrentStreamsAtomicUpdater
private volatile int	sendMaxConcurrentStreams
private volatile int	sendMaxFrameSize
private volatile long	sendWindowSize How much data we can send to the remote endpoint, at the connection level, guarded by `flowControlLock`
private final Http2Channel.StreamCache	sentRstStreams
pack-priv static final int	SETTINGS_FLAG_ACK
public static final HttpString	STATUS
private static final int	STREAM_CACHE_EVICTION_TIME_MS
private int	streamIdCounter
private boolean	thisGoneAway
private int	unackedReceiveMaxFrameSize

Access	Constructor and Description
public	Http2Channel(StreamConnection connectedStreamChannel, String protocol, ByteBufferPool bufferPool, PooledByteBuffer data, boolean clientSide, boolean fromUpgrade, OptionMap settings)
public	Http2Channel(StreamConnection connectedStreamChannel, String protocol, ByteBufferPool bufferPool, PooledByteBuffer data, boolean clientSide, boolean fromUpgrade, boolean prefaceRequired, OptionMap settings)
public	Http2Channel(StreamConnection connectedStreamChannel, String protocol, ByteBufferPool bufferPool, PooledByteBuffer data, boolean clientSide, boolean fromUpgrade, boolean prefaceRequired, ByteBuffer initialOtherSideSettings, OptionMap settings)

Method Summary

Modifier and Type	Method and Description
public synchronized boolean	Returns: true if pushedStreamId can be added, false if invalid addPushPromiseStream(int The pushed stream returned by the server pushedStreamId) Adds a received pushed stream into the current streams for a client.
public <T> void	addToAttachmentList(AttachmentKey<AttachmentList<T>> the attachment key key, T the value to add value) Implements io.undertow.util.Attachable.addToAttachmentList. Add a value to a list-typed attachment key.
protected void	closeSubChannels() Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.closeSubChannels. Method that is called when the channel is being forcibly closed, and all sub stream sink/source channels should also be forcibly closed.
private void	closeSubChannels(Map<Integer, Http2Channel.StreamHolder> streams)
protected AbstractHttp2StreamSourceChannel	createChannel(FrameHeaderData The header data, as returned by `parseFrame(java.nio.ByteBuffer)` frameHeaderData, PooledByteBuffer Any additional data for the frame that has already been read. This may not be the complete frame contents frameData) Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.createChannel. Method that creates the actual stream source channel implementation that is in use.
protected AbstractHttp2StreamSourceChannel	createChannelImpl(FrameHeaderData frameHeaderData, PooledByteBuffer frameData)
public synchronized Http2HeadersStreamSinkChannel	createInitialUpgradeResponseStream() Creates a response stream to respond to the initial HTTP upgrade
public synchronized Http2HeadersStreamSinkChannel	createStream(HeaderMap requestHeaders) Creates a strema using a HEADERS frame
private void	flushChannel(StreamSinkChannel stream)
private void	flushChannelIgnoreFailure(StreamSinkChannel stream)
public <T> T	getAttachment(AttachmentKey<T> the attachment key key) Implements io.undertow.util.Attachable.getAttachment. Get an attachment value.
public <T> List<T>	getAttachmentList(AttachmentKey<? extends List<T>> the attachment key key) Implements io.undertow.util.Attachable.getAttachmentList. Gets a list attachment value.
pack-priv HpackDecoder	getDecoder()
pack-priv HpackEncoder	getEncoder()
public int	getHttp2Version()
pack-priv Http2StreamSourceChannel	getIncomingStream(int streamId)
public int	getInitialReceiveWindowSize()
public int	getInitialSendWindowSize()
private synchronized int	getLastAssignedStreamOtherSide()
private synchronized int	getLastGoodStreamId()
pack-priv int	getMaxHeaderListSize()
pack-priv int	getMaxHeaders()
pack-priv int	getPaddingBytes()
public String	getProtocol()
public String	getProtocolRequestId()
public int	getReceiveMaxConcurrentStreams()
public int	getReceiveMaxFrameSize()
protected Collection<AbstractFramedStreamSourceChannel<Http2Channel, AbstractHttp2StreamSourceChannel, AbstractHttp2StreamSinkChannel>>	getReceivers() Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.getReceivers.
public int	getSendMaxConcurrentStreams()
public int	getSendMaxFrameSize()
public SSLSession	getSslSession()
pack-priv int	Returns: The actual amount of bytes the sender can send grabFlowControlBytes(int The amount of bytes the sender is trying to send bytesToGrab) Try and decrement the send window by the given amount of bytes.
protected void	handleBrokenSinkChannel(Throwable e) Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.handleBrokenSinkChannel. Method that is invoked when then write side of a channel is broken.
protected void	handleBrokenSourceChannel(Throwable e) Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.handleBrokenSourceChannel. Method that is invoked when the read side of the channel is broken.
private Http2Channel.StreamHolder	handleRstStream(int streamId, boolean receivedRst)
public void	handleWindowUpdate(int streamId, int deltaWindowSize)
public boolean	isClient()
private synchronized boolean	isIdle(int streamNo)
protected boolean	isLastFrameReceived() Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.isLastFrameReceived. Returns true if the protocol specific final frame has been received.
protected boolean	isLastFrameSent() Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.isLastFrameSent.
public boolean	isPeerGoneAway()
public boolean	isPushEnabled()
public boolean	isThisGoneAway()
protected void	lastDataRead() Overrides io.undertow.server.protocol.framed.AbstractFramedChannel.lastDataRead. Method than is invoked when read() returns -1.
pack-priv synchronized void	notifyFlowControlAllowed()
protected FrameHeaderData	parseFrame(ByteBuffer The data that has been read from the channel data) Implements abstract io.undertow.server.protocol.framed.AbstractFramedChannel.parseFrame. Attempts to parse an incoming frame header from the data in the buffer.
private Http2FrameHeaderParser	parseFrameNoContinuation(ByteBuffer data)
public <T> T	putAttachment(AttachmentKey<T> the attachment key key, T the new value value) Implements io.undertow.util.Attachable.putAttachment. Set an attachment value.
pack-priv void	registerStreamSink(Http2HeadersStreamSinkChannel synResponse)
public <T> T	removeAttachment(AttachmentKey<T> the attachment key key) Implements io.undertow.util.Attachable.removeAttachment. Remove an attachment, returning its previous value.
pack-priv void	removeStreamSink(int streamId)
pack-priv Http2StreamSourceChannel	removeStreamSource(int streamId)
public void	sendGoAway(int status)
public void	sendGoAway(int status, final ChannelExceptionHandler<AbstractHttp2StreamSinkChannel> exceptionHandler)
public void	sendPing(byte[] data)
public void	sendPing(byte[] data, final ChannelExceptionHandler<AbstractHttp2StreamSinkChannel> exceptionHandler)
pack-priv void	sendPing(byte[] data, final ChannelExceptionHandler<AbstractHttp2StreamSinkChannel> exceptionHandler, boolean ack)
private void	sendPreface()
public synchronized Http2HeadersStreamSinkChannel	sendPushPromise(int associatedStreamId, HeaderMap requestHeaders, HeaderMap responseHeaders)
public void	sendRstStream(int streamId, int statusCode)
private void	sendSettings()
private void	sendSettingsAck()
public void	sendUpdateWindowSize(int streamId, int delta)
public void	setSendMaxConcurrentStreams(int sendMaxConcurrentStreams)
public void	updateReceiveFlowControlWindow(int read)
pack-priv boolean	updateSettings(List<Http2Setting> settings) Setting have been received from the client
private synchronized void	updateStreamIdsCountersInHeaders(int The received streamId for the client or the server streamNo) Updates the lastGoodStreamId (last request ID to send in goaway frames), and lastAssignedStreamOtherSide (the last received streamId from the other side to check if it's idle).

public Class Http2Channel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary