Top Inners Fields Constructors Methods
org.apache.coyote.http2

pack-priv Class Stream

extends AbstractNonZeroStream
implements HeaderEmitter
Class Inheritance
All Implemented Interfaces
org.apache.coyote.http2.HpackDecoder.HeaderEmitter
Imports
java.io.IOException, .StringReader, java.nio.ByteBuffer, java.nio.charset.StandardCharsets, java.security.AccessController, .PrivilegedActionException, .PrivilegedExceptionAction, java.util.Collections, .HashSet, .Locale, .Map, .Set, java.util.concurrent.locks.Lock, .ReentrantLock, java.util.function.Supplier, org.apache.coyote.ActionCode, .CloseNowException, .InputBuffer, .Request, .Response, org.apache.coyote.http11.HttpOutputBuffer, .OutputFilter, org.apache.coyote.http11.filters.SavedRequestInputFilter, .VoidOutputFilter, org.apache.coyote.http2.HpackDecoder.HeaderEmitter, org.apache.juli.logging.Log, .LogFactory, org.apache.tomcat.util.buf.ByteChunk, .MessageBytes, org.apache.tomcat.util.http.MimeHeaders, org.apache.tomcat.util.http.parser.Host, .Priority, org.apache.tomcat.util.net.ApplicationBufferHandler, .WriteBuffer, org.apache.tomcat.util.res.StringManager

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
Stream.PrivilegedPush

pack-priv class
Stream.SavedRequestStreamInputBuffer

pack-priv class
Stream.StandardStreamInputBuffer

pack-priv abstract class
Stream.StreamInputBuffer

pack-priv class
Stream.StreamOutputBuffer

Field Summary

Modifier and TypeField and Description
private static final MimeHeaders
ACK_HEADERS

private final WindowAllocationManager
allocationManager

private volatile long
contentLengthReceived

private volatile StringBuilder
cookieHeader

private final Request
coyoteRequest

private final Response
coyoteResponse

private final Http2UpgradeHandler
handler

private static final int
HEADER_STATE_PSEUDO

private static final int
HEADER_STATE_REGULAR

private static final int
HEADER_STATE_START

private static final int
HEADER_STATE_TRAILER

private StreamException
headerException

private int
headerState

private volatile boolean
hostHeaderSeen

private final Http2OutputBuffer
http2OutputBuffer

private static final Set<String>
HTTP_CONNECTION_SPECIFIC_HEADERS

private static final Integer
HTTP_UPGRADE_STREAM

private volatile boolean
incremental

private final Stream.StreamInputBuffer
inputBuffer

private static final Log
log

Hides org.apache.coyote.http2.AbstractStream.log.

private int
pendingWindowUpdateForStream

private Object
pendingWindowUpdateForStreamLock

private static final StringManager
sm

Hides org.apache.coyote.http2.AbstractStream.sm.

private final Stream.StreamOutputBuffer
streamOutputBuffer

private volatile int
urgency

Inherited from org.apache.coyote.http2.AbstractNonZeroStream:
stateZERO_LENGTH_BYTEBUFFER

Constructor Summary

AccessConstructor and Description
pack-priv
Stream(Integer identifier, Http2UpgradeHandler handler)

pack-priv
Stream(Integer identifier, Http2UpgradeHandler handler, Request coyoteRequest)

Method Summary

Modifier and TypeMethod and Description
pack-priv final void
addOutputFilter(OutputFilter filter)

pack-priv final void
cancelAllocationRequests()

pack-priv final boolean
canWrite()

pack-priv final void
close(Http2Exception http2Exception)

pack-priv final void
closeIfIdle()

private void
compareAuthority(String value)

pack-priv void
configureVoidOutputFilter()

pack-priv void
doStreamCancel(String msg, Http2Error error)

public final void
emitHeader(String
Header name
name, String
Header value
value)

Implements org.apache.coyote.http2.HpackDecoder.HeaderEmitter.emitHeader.

Pass a single header to the recipient.

pack-priv final boolean
flush(boolean block)

pack-priv final String
getConnectionId()

Implements abstract org.apache.coyote.http2.AbstractStream.getConnectionId.

pack-priv final Request
getCoyoteRequest()

pack-priv final Response
getCoyoteResponse()

public boolean
getIncremental()

pack-priv final Stream.StreamInputBuffer
getInputBuffer()

pack-priv final ByteBuffer
getInputByteBuffer()

Implements abstract org.apache.coyote.http2.AbstractNonZeroStream.getInputByteBuffer.

Obtain the ByteBuffer to store DATA frame payload data for this stream that has been received from the client.

pack-priv final HttpOutputBuffer
getOutputBuffer()

pack-priv StreamException
getResetException()

public int
getUrgency()

pack-priv int
getWindowUpdateSizeToWrite(int increment)

pack-priv final void
incrementWindowSize(int
The amount by which the window size should be increased
windowSizeIncrement)

Overrides org.apache.coyote.http2.AbstractStream.incrementWindowSize.

Increment window size.

pack-priv final boolean
isActive()

pack-priv final boolean
isContentLengthInconsistent()

pack-priv final boolean
isInputFinished()

pack-priv final boolean
isPushSupported()

pack-priv final boolean
isReadyForWrite()

pack-priv boolean
isTrailerFieldsReady()

pack-priv boolean
isTrailerFieldsSupported()

pack-priv void
notifyConnection()

private void
parseAuthority(String value, boolean host)

private void
prepareRequest()

pack-priv final void
push(Request request)

private static void
push(final Http2UpgradeHandler handler, final Request request, final Stream stream)

pack-priv final void
receivedData(int payloadSize)

Implements abstract org.apache.coyote.http2.AbstractNonZeroStream.receivedData.

pack-priv final boolean
receivedEndOfHeaders()

pack-priv final void
receivedEndOfStream()

pack-priv final void
receivedStartOfHeaders(boolean headersEndStream)

pack-priv final void
receiveReset(long errorCode)

pack-priv final void
recycle()

pack-priv final int
reserveWindowSize(int reservation, boolean block)

pack-priv final void
sentEndOfStream()

pack-priv final void
sentHeaders()

pack-priv final void
sentPushPromise()

public void
setHeaderException(StreamException
The exception to use when resetting the stream
streamException)

Implements org.apache.coyote.http2.HpackDecoder.HeaderEmitter.setHeaderException.

Inform the recipient of the headers that a stream error needs to be triggered using the given message when validateHeaders() is called.

public void
setIncremental(boolean incremental)

public void
setUrgency(int urgency)

public void
validateHeaders()

Implements org.apache.coyote.http2.HpackDecoder.HeaderEmitter.validateHeaders.

Are the headers pass to the recipient so far valid?

pack-priv void
waitForConnectionAllocation(long timeout)

pack-priv void
waitForConnectionAllocationNonBlocking()

pack-priv final void
writeAck()

pack-priv final void
writeHeaders()

pack-priv final void
writeTrailers()

Inherited from org.apache.coyote.http2.AbstractNonZeroStream:
checkStateisClosedFinal