Dependencies
Declarations
-
org
-
glassfish
-
grizzly
-
http2
-
AggrCompletionHandler
-
AlpnClientNegotiatorImpl
-
AlpnNegotiatorBase
-
AlpnServerNegotiatorImpl
-
AlpnSupport
-
BundleQueue
-
DecoderUtils
-
LOGGER: Logger
-
INVALID_CHARACTER_MESSAGE: String
-
decodeRequestHeaders(Http2Session, HttpRequestPacket, Map<String, String>): void
-
decodeResponseHeaders(Http2Session, HttpResponsePacket, Map<String, String>): void
-
decodeTrailerHeaders(Http2Session, HttpHeader, Map<String, String>): void
-
processServiceRequestHeader(HttpRequestPacket, Set<String>, String, String): void
-
processServiceResponseHeader(HttpResponsePacket, String, String): void
-
processNormalHeader(HttpHeader, String, String): void
-
finalizeKnownHeader(HttpHeader, String, String): void
-
validateHeaderCharacters(CharSequence, CharSequence): void
-
ensureRange(CharSequence): int
-
DefaultInputBuffer
-
DefaultOutputSink
-
LOGGER: Logger
-
MAX_OUTPUT_QUEUE_SIZE: int
-
ZERO_QUEUE_RECORD_SIZE: int
-
TERMINATING_QUEUE_RECORD: OutputQueueRecord
-
outputQueue: TaskQueue<OutputQueueRecord>
-
availStreamWindowSize: AtomicInteger
-
isLastFrameQueued: boolean
-
terminationFlag: Termination
-
http2Session: Http2Session
-
stream: Http2Stream
-
unflushedWritesCounter: AtomicInteger
-
flushHandlersSync: Object
-
flushHandlersQueue: BundleQueue<CompletionHandler<Http2Stream>>
-
DefaultOutputSink(Http2Stream): void
-
canWrite(): boolean
-
notifyWritePossible(WriteHandler): void
-
assertReady(): void
-
onPeerWindowUpdate(int): void
-
writeDownStream(HttpPacket, FilterChainContext, CompletionHandler<WriteResult>, MessageCloner<Buffer>): void
-
flush(CompletionHandler<Http2Stream>): void
-
checkOutputWindow(long): int
-
splitOutputBufferIfNeeded(Buffer, int): Buffer
-
flushToConnectionOutputSink(List<Http2Frame>, Buffer, CompletionHandler<WriteResult>, MessageCloner<Buffer>, boolean): void
-
close(): void
-
terminate(Termination): void
-
isClosed(): boolean
-
getUnflushedWritesCount(): int
-
isTerminated(): boolean
-
writeEmptyFin(): void
-
isWantToWrite(): boolean
-
addOutputQueueRecord(OutputQueueRecord): void
-
reserveWriteQueueSpace(int): int
-
releaseWriteQueueSpace(int, boolean, boolean): void
-
sendTrailers(CompletionHandler<WriteResult>, MessageCloner<Buffer>, HttpTrailer): void
-
OutputQueueRecord
-
FlushCompletionHandler
-
EncoderDecoderUtilsBase
-
EncoderUtils
-
HTTP: String
-
HTTPS: String
-
encodeResponseHeaders(Http2Session, HttpResponsePacket, Map<String, String>): Buffer
-
encodeRequestHeaders(Http2Session, HttpRequestPacket, Map<String, String>): Buffer
-
encodeTrailerHeaders(Http2Session, MimeHeaders, Map<String, String>): Buffer
-
encodeUserHeaders(MimeHeaders, HeadersEncoder, Map<String, String>): void
-
nameToLowerCaseByteArray(DataChunk): byte[]
-
nameToLowerCase(DataChunk): String
-
valueToByteArray(DataChunk, byte[], int): int
-
valueToByteArray(DataChunk): byte[]
-
HeaderDecodingException
-
HeadersDecoder
-
HeadersEncoder
-
Http2AddOn
-
Http2BaseFilter
-
LOGGER: Logger
-
HTTP2_CLEAR: String
-
HTTP2_PUSH_ENABLED: String
-
PRI_PAYLOAD: byte[]
-
FIXED_LENGTH_ENCODING: TransferEncoding
-
frameCodec: Http2FrameCodec
-
configuration: Http2Configuration
-
threadPool: ExecutorService
-
localMaxFramePayloadSize: int
-
Http2BaseFilter(Http2Configuration): void
-
getLocalMaxFramePayloadSize(): int
-
setLocalMaxFramePayloadSize(int): void
-
getConfiguration(): Http2Configuration
-
processFrames(FilterChainContext, Http2Session, List<Http2Frame>): boolean
-
checkRequestHeadersOnUpgrade(HttpRequestPacket): boolean
-
checkResponseHeadersOnUpgrade(HttpResponsePacket): boolean
-
getHttp2UpgradeSettings(HttpRequestPacket): SettingsFrame
-
isHttp2UpgradingVersion(HttpHeader): boolean
-
onHttpPacketParsed(HttpHeader, FilterChainContext): boolean
-
onHttpHeaderParsed(HttpHeader, Buffer, FilterChainContext): boolean
-
onInitialLineParsed(HttpHeader, FilterChainContext): void
-
onInitialLineEncoded(HttpHeader, FilterChainContext): void
-
onHttpHeadersParsed(HttpHeader, FilterChainContext): void
-
onHttpHeadersEncoded(HttpHeader, FilterChainContext): void
-
onHttpContentParsed(HttpContent, FilterChainContext): void
-
onHttpContentEncoded(HttpContent, FilterChainContext): void
-
onHttpHeaderError(HttpHeader, FilterChainContext, Throwable): void
-
onHttpContentError(HttpHeader, FilterChainContext, Throwable): void
-
processInFrame(Http2Session, FilterChainContext, Http2Frame): void
-
processPriorityFrame(Http2Frame): void
-
processWindowUpdateFrame(Http2Session, Http2Frame): void
-
processGoAwayFrame(Http2Session, Http2Frame): void
-
processSettingsFrame(Http2Session, FilterChainContext, Http2Frame): void
-
applySettings(Http2Session, SettingsFrame): void
-
processPingFrame(Http2Session, Http2Frame): void
-
processRstStreamFrame(Http2Session, Http2Frame): void
-
processHeadersFrame(Http2Session, FilterChainContext, Http2Frame): void
-
processCompleteHeader(Http2Session, FilterChainContext, HeaderBlockHead): void
-
handleWrite(FilterChainContext): NextAction
-
processOutgoingHttpHeader(FilterChainContext, Http2Session, HttpHeader, HttpPacket): void
-
prepareOutgoingRequest(HttpRequestPacket): void
-
handleEvent(FilterChainContext, FilterChainEvent): NextAction
-
checkIfHttp2StreamChain(FilterChainContext): boolean
-
createHttp2Session(Connection, boolean): Http2Session
-
onPrefaceReceived(Http2Session): void
-
sendUpstream(Http2Session, Http2Stream, HttpContent): void
-
prepareIncomingRequest(Http2Stream, Http2Request): void
-
sendRstStream(FilterChainContext, Http2Session, int, ErrorCode): void
-
obtainHttp2Session(FilterChainContext, boolean): Http2Session
-
obtainHttp2Session(Http2State, FilterChainContext, boolean): Http2Session
-
sendSettingsAck(Http2Session, FilterChainContext): void
-
processDataFrame(Http2Session, FilterChainContext, Http2Frame): void
-
ignoreFrameForStreamId(Http2Session, int): boolean
-
Http2ClientFilter
-
defaultClientAlpnNegotiator: AlpnClientNegotiatorImpl
-
isNeverForceUpgrade: boolean
-
sendPushRequestUpstream: boolean
-
defaultHttp2Upgrade: HeaderValue
-
connectionUpgradeHeaderValue: HeaderValue
-
Http2ClientFilter(Http2Configuration): void
-
isNeverForceUpgrade(): boolean
-
setNeverForceUpgrade(boolean): void
-
isSendPushRequestUpstream(): boolean
-
setSendPushRequestUpstream(boolean): void
-
handleConnect(FilterChainContext): NextAction
-
handleRead(FilterChainContext): NextAction
-
handleWrite(FilterChainContext): NextAction
-
handleEvent(FilterChainContext, FilterChainEvent): NextAction
-
processOutgoingHttpHeader(FilterChainContext, Http2Session, HttpHeader, HttpPacket): void
-
processOutgoingRequestForNewStream(FilterChainContext, Http2Session, HttpRequestPacket, HttpPacket): void
-
createClientHttp2Session(Connection): Http2Session
-
tryHttpUpgrade(FilterChainContext, Http2State, HttpRequestPacket, HttpResponsePacket): boolean
-
tryInsertHttpUpgradeHeaders(Connection, Object): boolean
-
processCompleteHeader(Http2Session, FilterChainContext, HeaderBlockHead): void
-
processInResponse(Http2Session, FilterChainContext, HeadersFrame): void
-
processInPushPromise(Http2Session, FilterChainContext, PushPromiseFrame): void
-
prepareSettings(Http2Session): SettingsFrameBuilder
-
checkIfLastHttp11Chunk(FilterChainContext, Http2State, Object): void
-
Http2Configuration
-
Http2FrameCodec
-
Http2Header
-
Http2Packet
-
Http2Request
-
Http2Response
-
Http2ServerFilter
-
LOGGER: Logger
-
CIPHER_SUITE_BLACK_LIST: String[]
-
static class initializer
-
allowPayloadForUndefinedHttpMethods: boolean
-
CIPHER_CHECKED: Attribute<Connection>
-
shuttingDown: AtomicBoolean
-
activeConnections: Collection<Connection>
-
Http2ServerFilter(Http2Configuration): void
-
isAllowPayloadForUndefinedHttpMethods(): boolean
-
setAllowPayloadForUndefinedHttpMethods(boolean): void
-
handleAccept(FilterChainContext): NextAction
-
handleClose(FilterChainContext): NextAction
-
handleRead(FilterChainContext): NextAction
-
handleEvent(FilterChainContext, FilterChainEvent): NextAction
-
onPrefaceReceived(Http2Session): void
-
doDirectUpgrade(FilterChainContext): Http2State
-
shuttingDown(): Collection<Connection>
-
tryHttpUpgrade(FilterChainContext, HttpRequestPacket, boolean): boolean
-
checkHttpMethodOnUpgrade(HttpRequestPacket): boolean
-
checkPRI(HttpRequestPacket, HttpContent): boolean
-
processCompleteHeader(Http2Session, FilterChainContext, HeaderBlockHead): void
-
processInRequest(Http2Session, FilterChainContext, HeadersFrame): void
-
processOutgoingHttpHeader(FilterChainContext, Http2Session, HttpHeader, HttpPacket): void
-
$2
-
submit(Connection, Runnable): void
-
prepareOutgoingResponse(HttpResponsePacket): void
-
enableOpReadNow(FilterChainContext): void
-
Http2Session
-
LOGGER: Logger
-
isServer: boolean
-
connection: Connection<Object>
-
http2State: Http2State
-
headersDecoder: HeadersDecoder
-
headersEncoder: HeadersEncoder
-
deflaterLock: ReentrantLock
-
lastPeerStreamId: int
-
lastLocalStreamId: int
-
pushEnabled: boolean
-
newClientStreamLock: ReentrantLock
-
http2StreamChain: FilterChain
-
htt2SessionChain: FilterChain
-
concurrentStreamCountUpdater: AtomicIntegerFieldUpdater<Http2Session>
-
concurrentStreamsCount: int
-
streamsMap: TreeMap<Integer, Http2Stream>
-
streamsToFlushInput: List<Http2Stream>
-
tmpHeaderFramesList: List<Http2Frame>
-
sessionLock: Object
-
closeFlag: CloseType
-
peerStreamWindowSize: int
-
localStreamWindowSize: int
-
localConnectionWindowSize: int
-
maxHeaderListSize: int
-
localMaxConcurrentStreams: int
-
peerMaxConcurrentStreams: int
-
outputSink: Http2SessionOutputSink
-
http2Configuration: Http2Configuration
-
streamsHighWaterMark: int
-
checkCount: int
-
goingAwayLastStreamId: int
-
sessionClosed: FutureImpl<Http2Session>
-
isPrefaceReceived: boolean
-
isPrefaceSent: boolean
-
get(Connection): Http2Session
-
bind(Connection, Http2Session): void
-
addressHolder: Holder<Object>
-
handlerFilter: Http2BaseFilter
-
localMaxFramePayloadSize: int
-
peerMaxFramePayloadSize: int
-
isFirstInFrame: boolean
-
sslFilter: SSLBaseFilter
-
unackedReadBytes: AtomicInteger
-
Http2Session(Connection<Object>, boolean, Http2BaseFilter): void
-
newOutputSink(): Http2SessionOutputSink
-
getSpecDefaultFramePayloadSize(): int
-
getSpecMinFramePayloadSize(): int
-
getSpecMaxFramePayloadSize(): int
-
getDefaultConnectionWindowSize(): int
-
getDefaultStreamWindowSize(): int
-
getDefaultMaxConcurrentStreams(): int
-
getMaxHeaderListSize(): int
-
setMaxHeaderListSize(int): void
-
getFrameSize(Buffer): int
-
parseHttp2FrameHeader(Buffer): Http2Frame
-
newStream(HttpRequestPacket, int, int, boolean, int): Http2Stream
-
newUpgradeStream(HttpRequestPacket, int): Http2Stream
-
checkFrameSequenceSemantics(Http2Frame): void
-
onOversizedFrame(Buffer): void
-
isParsingHeaders(): boolean
-
getLocalMaxFramePayloadSize(): int
-
getPeerMaxFramePayloadSize(): int
-
setPeerMaxFramePayloadSize(int): void
-
getLocalStreamWindowSize(): int
-
setLocalStreamWindowSize(int): void
-
getPeerStreamWindowSize(): int
-
setPeerStreamWindowSize(int): void
-
getLocalConnectionWindowSize(): int
-
setLocalConnectionWindowSize(int): void
-
getAvailablePeerConnectionWindowSize(): int
-
getLocalMaxConcurrentStreams(): int
-
setLocalMaxConcurrentStreams(int): void
-
getPeerMaxConcurrentStreams(): int
-
setPeerMaxConcurrentStreams(int): void
-
isPushEnabled(): boolean
-
setPushEnabled(boolean): void
-
getNextLocalStreamId(): int
-
getConnection(): Connection
-
getMemoryManager(): MemoryManager
-
isServer(): boolean
-
isLocallyInitiatedStream(int): boolean
-
getHttp2State(): Http2State
-
isHttp2InputEnabled(): boolean
-
isHttp2OutputEnabled(): boolean
-
getStream(int): Http2Stream
-
getOutputSink(): Http2SessionOutputSink
-
terminateGracefully(): FutureImpl<Http2Session>
-
terminate(ErrorCode, String): void
-
sendGoAwayAndClose(Http2Frame): void
-
setGoAwayLocally(ErrorCode, String, boolean): GoAwayFrame
-
pruneStreams(): void
-
setGoAwayByPeer(int): void
-
isGoingAway(): boolean
-
getGoingAwayLastStreamId(): int
-
sendWindowUpdate(int, int): void
-
sendPreface(): void
-
sendServerPreface(): void
-
sendClientPreface(): void
-
getHeadersDecoder(): HeadersDecoder
-
getDeflaterLock(): ReentrantLock
-
getHeadersEncoder(): HeadersEncoder
-
encodeHttpHeaderAsHeaderFrames(FilterChainContext, HttpHeader, int, boolean, List<Http2Frame>, Map<String, String>): List<Http2Frame>
-
encodeTrailersAsHeaderFrames(int, List<Http2Frame>, MimeHeaders, Map<String, String>): List<Http2Frame>
-
encodeHttpRequestAsPushPromiseFrames(FilterChainContext, HttpRequestPacket, int, int, List<Http2Frame>, Map<String, String>): List<Http2Frame>
-
bufferToHeaderFrames(int, Buffer, boolean, List<Http2Frame>): List<Http2Frame>
-
bufferToPushPromiseFrames(int, int, Buffer, List<Http2Frame>): List<Http2Frame>
-
completeHeadersProviderFrameSerialization(HeaderBlockFragmentBuilder, int, Buffer, List<Http2Frame>): List<Http2Frame>
-
getNewClientStreamLock(): ReentrantLock
-
acceptStream(HttpRequestPacket, int, int, boolean, int): Http2Stream
-
openStream(HttpRequestPacket, int, int, boolean, int): Http2Stream
-
acceptUpgradeStream(HttpRequestPacket, int, boolean): Http2Stream
-
openUpgradeStream(HttpRequestPacket, int): Http2Stream
-
setupFilterChains(FilterChainContext, boolean): void
-
getHttp2SessionChain(): FilterChain
-
deregisterStream(): void
-
isClosed(): boolean
-
sendMessageUpstreamWithParseNotify(Http2Stream, HttpContent): void
-
sendMessageUpstream(Http2Stream, HttpPacket): void
-
sendMessageUpstream(Http2Stream, HttpPacket, FilterChainContext): void
-
prepareSettings(): SettingsFrameBuilder
-
ackConsumedData(int): void
-
ackConsumedData(Http2Stream, int): void
-
registerStream(int, Http2Stream): void
-
registerUpgradeStream(Http2Stream): void
-
incStreamCount(): void
-
decStreamCount(): void
-
ConnectionCloseListener
-
Http2SessionException
-
Http2SessionOutputSink
-
Http2State
-
Http2Stream
-
State
-
LOGGER: Logger
-
HTTP2_STREAM_ATTRIBUTE: String
-
HTTP2_PARENT_STREAM_ATTRIBUTE: String
-
UPGRADE_STREAM_ID: int
-
HTTP_RQST_HTTP2_STREAM_ATTR: Attribute<Http2Stream>
-
state: State
-
request: HttpRequestPacket
-
streamId: int
-
parentStreamId: int
-
priority: int
-
exclusive: boolean
-
http2Session: Http2Session
-
attributes: AttributeHolder
-
inputBuffer: StreamInputBuffer
-
outputSink: StreamOutputSink
-
unackedReadBytesUpdater: AtomicIntegerFieldUpdater<Http2Stream>
-
unackedReadBytes: int
-
closeReasonUpdater: AtomicReferenceFieldUpdater<Http2Stream, CloseReason>
-
closeReason: CloseReason
-
closeFuture: GrizzlyFuture<CloseReason>
-
closeListeners: Queue<CloseListener>
-
completeFinalizationCounterUpdater: AtomicIntegerFieldUpdater<Http2Stream>
-
completeFinalizationCounter: int
-
isProcessingComplete: boolean
-
inboundHeaderFramesCounter: int
-
getStreamFor(HttpHeader): Http2Stream
-
Http2Stream(Http2Session, HttpRequestPacket, int, int, boolean, int): void
-
Http2Stream(Http2Session, HttpRequestPacket, int): void
-
getHttp2Session(): Http2Session
-
getPeerWindowSize(): int
-
getLocalWindowSize(): int
-
getUnflushedWritesCount(): int
-
getRequest(): HttpRequestPacket
-
getResponse(): HttpResponsePacket
-
isPushEnabled(): boolean
-
getId(): int
-
getParentStreamId(): int
-
getPriority(): int
-
isPushStream(): boolean
-
isLocallyInitiatedStream(): boolean
-
isOpen(): boolean
-
assertOpen(): void
-
getAttributes(): AttributeHolder
-
canWrite(int): boolean
-
canWrite(): boolean
-
notifyCanWrite(WriteHandler, int): void
-
notifyCanWrite(WriteHandler): void
-
getOutputSink(): StreamOutputSink
-
terminate(): GrizzlyFuture<Closeable>
-
terminateSilently(): void
-
terminateWithReason(IOException): void
-
close(): GrizzlyFuture<Closeable>
-
closeSilently(): void
-
close(CompletionHandler<Closeable>): void
-
closeWithReason(IOException): void
-
onReset(): void
-
close0(CompletionHandler<Closeable>, CloseType, IOException, boolean): void
-
closedRemotely(): void
-
resetRemotely(): void
-
onProcessingComplete(): void
-
addCloseListener(CloseListener): void
-
removeCloseListener(CloseListener): boolean
-
closeFuture(): GrizzlyFuture<CloseReason>
-
onInputClosed(): void
-
onOutputClosed(): void
-
getInboundHeaderFramesCounter(): int
-
onRcvHeaders(boolean): void
-
onSndHeaders(boolean): void
-
cachedInputBuffer: Buffer
-
cachedIsLast: boolean
-
assertCanAcceptData(boolean): IOException
-
assertCanAcceptHeader(boolean): IOException
-
offerInputData(Buffer, boolean): void
-
flushInputData(): void
-
pollInputData(): HttpContent
-
closeStream(): void
-
getInputHttpHeader(): HttpHeader
-
getOutputHttpHeader(): HttpHeader
-
notifyCloseListeners(): void
-
getState(): State
-
isClosed(): boolean
-
isIdle(): boolean
-
canSendFrames(): boolean
-
canReceiveFrames(): boolean
-
onSendPushPromise(): void
-
onReceivePushPromise(): void
-
onSendHeaders(): void
-
onReceiveHeaders(): void
-
onSendEndOfStream(): void
-
onReceiveEndOfStream(): void
-
Http2StreamException
-
NetLogger
-
LOGGER: Logger
-
LEVEL: Level
-
CLOSE_FMT: String
-
DATA: String
-
DATA_FMT: String
-
CONTINUATION: String
-
CONTINUATION_FMT: String
-
GOAWAY: String
-
GOAWAY_FMT: String
-
HEADERS: String
-
HEADERS_FMT: String
-
OPEN_FMT: String
-
PING: String
-
PING_FMT: String
-
PRIORITY: String
-
PRIORITY_FMT: String
-
PUSH_PROMISE: String
-
PUSH_PROMISE_FMT: String
-
RST: String
-
RST_FMT: String
-
SETTINGS: String
-
SETTINGS_FMT: String
-
UNKNOWN: String
-
UNKNOWN_FMT: String
-
WINDOW_UPDATE: String
-
WINDOW_UPDATE_FMT: String
-
NOT_AVAILABLE: String
-
Context
-
isActive(): boolean
-
log(Context, Http2Session, Http2Frame): void
-
log(Context, Http2Session, ContinuationFrame): void
-
log(Context, Http2Session, DataFrame): void
-
log(Context, Http2Session, GoAwayFrame): void
-
log(Context, Http2Session, HeadersFrame, Map<String, String>): void
-
log(Context, Http2Session, PingFrame): void
-
log(Context, Http2Session, PriorityFrame): void
-
log(Context, Http2Session, PushPromiseFrame, Map<String, String>): void
-
log(Context, Http2Session, RstStreamFrame): void
-
log(Context, Http2Session, SettingsFrame): void
-
log(Context, Http2Session, WindowUpdateFrame): void
-
log(Context, Http2Session, UnknownFrame): void
-
logClose(Http2Session): void
-
logOpen(Http2Session): void
-
logSessionEvent(String, Http2Session): void
-
toJSON(Map<String, String>): StringBuilder
-
validateParams(Context, Http2Session, Http2Frame): void
-
escape(String): String
-
Node
-
Source
-
StreamInputBuffer
-
StreamOutputSink
-
Termination
-
UpgradeInputBuffer
-
UpgradeOutputSink
-
frames
-
hpack
-
utils
Java files
Class files