https://projects.eclipse.org/projects/ee4j.grizzly/grizzly-http2: Grizzly Bill of Materials (BOM)
(Oracle Corporation)
- Jeanfrancois Arcand (Async IO)
- Justin Lee
- Marc Arens (Open Xchange)
- Matt Swift
-
org
-
glassfish
-
grizzly
-
http2
-
UpgradeOutputSink
-
isClosed: boolean
-
connection: Http2Session
-
UpgradeOutputSink(Http2Session): void
-
canWrite(): boolean
-
notifyWritePossible(WriteHandler): void
-
onPeerWindowUpdate(int): void
-
writeDownStream(HttpPacket, FilterChainContext, CompletionHandler<WriteResult>, MessageCloner<Buffer>): void
-
flush(CompletionHandler<Http2Stream>): void
-
getUnflushedWritesCount(): int
-
close(): void
-
terminate(Termination): void
-
isClosed(): boolean
-
-
UpgradeInputBuffer
-
Termination
-
IN_FIN_TERMINATION: Termination
-
OUT_FIN_TERMINATION: Termination
-
CLOSED_BY_PEER_STRING: String
-
LOCAL_CLOSE_TERMINATION: Termination
-
PEER_CLOSE_TERMINATION: Termination
-
RESET_TERMINATION: Termination
-
UNEXPECTED_FRAME_TERMINATION: Termination
-
FRAME_TOO_LARGE_TERMINATION: Termination
-
HTTP2_PUSH_ENABLED: String
-
TerminationType
-
type: TerminationType
-
description: String
-
sessionClosed: boolean
-
Termination(TerminationType, String, boolean): void
-
getType(): TerminationType
-
getDescription(): String
-
isSessionClosed(): boolean
-
doTask(): void
-
-
StreamOutputSink
-
canWrite(): boolean
-
notifyWritePossible(WriteHandler): void
-
onPeerWindowUpdate(int): void
-
writeDownStream(HttpPacket, FilterChainContext, CompletionHandler<WriteResult>, MessageCloner<Buffer>): void
-
flush(CompletionHandler<Http2Stream>): void
-
getUnflushedWritesCount(): int
-
close(): void
-
terminate(Termination): void
-
isClosed(): boolean
-
-
StreamInputBuffer
-
Source
-
Node
-
lock: ReentrantReadWriteLock
-
readLock: ReadLock
-
writeLock: WriteLock
-
id: int
-
next: Node
-
prev: Node
-
parent: Node
-
firstChild: Node
-
exclusive: boolean
-
Node(int): void
-
exclusive(): void
-
addSibling(Node): void
-
addChild(Node): void
-
addChild(Node, boolean): void
-
detach(int): Node
-
remove(int): Node
-
find(int): Node
-
isFirstSibling(): boolean
-
isLastSibling(): boolean
-
hasSiblings(): boolean
-
remove(int, boolean): Node
-
-
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
-
-
Http2StreamException
-
streamId: int
-
errorCode: ErrorCode
-
Http2StreamException(int, ErrorCode): void
-
Http2StreamException(int, ErrorCode, String): void
-
Http2StreamException(int, ErrorCode, Throwable): void
-
Http2StreamException(int, ErrorCode, String, Throwable): void
-
getStreamId(): int
-
getErrorCode(): ErrorCode
-
toString(): String
-
-
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
-
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
-
onReset(): void
-
-
Http2State
-
http2State: Attribute<Http2State>
-
listeners: List<ReadyListener>
-
get(Connection): Http2State
-
isHttp2(Connection): boolean
-
obtain(Connection): Http2State
-
create(Connection): Http2State
-
remove(Connection): void
-
status: AtomicReference<Status>
-
frameParsingState: FrameParsingState
-
http2Session: Http2Session
-
isClientHttpUpgradeRequestFinished: boolean
-
isClientPrefaceSent: boolean
-
Status
-
Http2State(): void
-
getStatus(): Status
-
isNeverHttp2(): boolean
-
setNeverHttp2(): void
-
isHttp2(): boolean
-
isReady(): boolean
-
addReadyListener(ReadyListener[]): void
-
setOpen(): void
-
isHttpUpgradePhase(): boolean
-
finishHttpUpgradePhase(): void
-
setDirectUpgradePhase(): void
-
getFrameParsingState(): FrameParsingState
-
getHttp2Session(): Http2Session
-
setHttp2Session(Http2Session): void
-
onClientHttpUpgradeRequestFinished(): void
-
tryLockClientPreface(): boolean
-
notifyReadyListeners(): void
-
ReadyListener
-
-
Http2SessionOutputSink
-
http2Session: Http2Session
-
LOGGER: Logger
-
LOGGER_LEVEL: Level
-
MAX_FRAME_PAYLOAD_SIZE: int
-
MAX_OUTPUT_QUEUE_SIZE: int
-
outputQueue: TaskQueue<OutputQueueRecord>
-
availConnectionWindowSize: AtomicInteger
-
tmpFramesList: List<Http2Frame>
-
writerLock: AtomicBoolean
-
Http2SessionOutputSink(Http2Session): void
-
frameCodec(): Http2FrameCodec
-
writeDownStream(Http2Frame): void
-
writeDownStream(List<Http2Frame>): void
-
writeDownStream(Object, CompletionHandler<WriteResult>, MessageCloner<Buffer>): void
-
getAvailablePeerConnectionWindowSize(): int
-
canWrite(): boolean
-
notifyCanWrite(WriteHandler): void
-
onPeerWindowUpdate(int): void
-
writeDataDownStream(Http2Stream, List<Http2Frame>, Buffer, CompletionHandler<WriteResult>, MessageCloner<Buffer>, boolean): void
-
flushOutputQueue(): void
-
close(): void
-
OutputQueueRecord
-
-
Http2SessionException
-
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
-
prepareSettings(): SettingsFrameBuilder
-
ackConsumedData(int): void
-
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
-
ackConsumedData(Http2Stream, int): void
-
registerStream(int, Http2Stream): void
-
registerUpgradeStream(Http2Stream): void
-
incStreamCount(): void
-
decStreamCount(): void
-
ConnectionCloseListener
-
-
Http2ServerFilter
-
setAllowPayloadForUndefinedHttpMethods(boolean): void
-
LOGGER: Logger
-
CIPHER_SUITE_BLACK_LIST: String[]
-
static class initializer
-
allowPayloadForUndefinedHttpMethods: boolean
-
CIPHER_CHECKED: Attribute<Connection>
-
activeConnections: Collection<Connection>
-
shuttingDown: AtomicBoolean
-
Http2ServerFilter(Http2Configuration): void
-
isAllowPayloadForUndefinedHttpMethods(): boolean
-
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
-
-
Http2Response
-
CACHE_IDX: CachedTypeIndex<Http2ResponseRecyclable>
-
create(): Http2Response
-
contentTypeParsed: boolean
-
getProcessingState(): ProcessingState
-
getHttp2Stream(): Http2Stream
-
getCharacterEncoding(): String
-
setCharacterEncoding(String): void
-
getContentType(): String
-
parseContentTypeHeader(): void
-
setExpectContent(boolean): void
-
reset(): void
-
Http2ResponseRecyclable
-
-
Http2Request
-
getHttp2Stream(): Http2Stream
-
CACHE_IDX: CachedTypeIndex<Http2Request>
-
create(): Http2Request
-
processingState: ProcessingState
-
response: Http2Response
-
contentTypeParsed: boolean
-
Http2Request(): void
-
getProcessingState(): ProcessingState
-
init(): Http2Request
-
getCharacterEncoding(): String
-
setCharacterEncoding(String): void
-
getContentType(): String
-
parseContentTypeHeader(): void
-
getAttribute(String): Object
-
reset(): void
-
recycle(): void
-
setExpectContent(boolean): void
-
requiresAcknowledgement(boolean): void
-
-
Http2Packet
-
Http2Header
-
Http2FrameCodec
-
parse(Http2Session, FrameParsingState, Buffer): List<Http2Frame>
-
serializeAndRecycle(Http2Session, Http2Frame): Buffer
-
serializeAndRecycle(Http2Session, List<Http2Frame>): Buffer
-
parseFrame(Http2Session, FrameParsingState, Buffer): ParsingResult
-
skip(FrameParsingState, Buffer): boolean
-
FrameParsingState
-
ParsingResult
-
-
Http2Configuration
-
DEFAULT_MAX_HEADER_LIST_SIZE: int
-
DEFAULT_STREAMS_HIGH_WATER_MARK: float
-
DEFAULT_STREAMS_CLEAN_PERCENTAGE: float
-
DEFAULT_CLEAN_FREQUENCY_CHECK: int
-
maxConcurrentStreams: int
-
initialWindowSize: int
-
maxFramePayloadSize: int
-
maxHeaderListSize: int
-
streamsHighWaterMark: float
-
cleanPercentage: float
-
cleanFrequencyCheck: int
-
disableCipherCheck: boolean
-
priorKnowledge: boolean
-
pushEnabled: boolean
-
executorService: ExecutorService
-
threadPoolConfig: ThreadPoolConfig
-
Http2Configuration(Http2ConfigurationBuilder): void
-
builder(): Http2ConfigurationBuilder
-
getMaxConcurrentStreams(): int
-
setMaxConcurrentStreams(int): void
-
getInitialWindowSize(): int
-
setInitialWindowSize(int): void
-
getMaxFramePayloadSize(): int
-
setMaxFramePayloadSize(int): void
-
getMaxHeaderListSize(): int
-
setMaxHeaderListSize(int): void
-
isDisableCipherCheck(): boolean
-
setDisableCipherCheck(boolean): void
-
isPriorKnowledge(): boolean
-
setPriorKnowledge(boolean): void
-
isPushEnabled(): boolean
-
setPushEnabled(boolean): void
-
getStreamsHighWaterMark(): float
-
setStreamsHighWaterMark(float): void
-
getCleanPercentage(): float
-
setCleanPercentage(float): void
-
getCleanFrequencyCheck(): int
-
setCleanFrequencyCheck(int): void
-
getThreadPoolConfig(): ThreadPoolConfig
-
getExecutorService(): ExecutorService
-
Http2ConfigurationBuilder
-
-
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
-
-
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
-
-
Http2AddOn
-
HeadersEncoder
-
DEFAULT_BUFFER_SIZE_PROP_NAME: String
-
DEFAULT_BUFFER_SIZE_STRING: String
-
DEFAULT_BUFFER_SIZE: int
-
hpackEncoder: Encoder
-
memoryManager: MemoryManager
-
buffer: CompositeBuffer
-
HeadersEncoder(MemoryManager, int): void
-
encodeHeader(String, String, Map<String, String>): void
-
flushHeaders(): Buffer
-
init(): void
-
-
HeadersDecoder
-
hpackDecoder: Decoder
-
memoryManager: MemoryManager
-
maxHeaderSize: int
-
currentHeaderSize: int
-
firstHeaderFrame: HeaderBlockHead
-
inBuffer: Buffer
-
HeadersDecoder(MemoryManager, int, int): void
-
append(Buffer): boolean
-
decode(DecodingCallback): void
-
finishHeader(): HeaderBlockHead
-
setFirstHeaderFrame(HeaderBlockHead): void
-
isProcessingHeaders(): boolean
-
-
HeaderDecodingException
-
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[]
-
-
EncoderDecoderUtilsBase
-
DefaultOutputSink
-
isLastFrameQueued: boolean
-
LOGGER: Logger
-
MAX_OUTPUT_QUEUE_SIZE: int
-
ZERO_QUEUE_RECORD_SIZE: int
-
TERMINATING_QUEUE_RECORD: OutputQueueRecord
-
outputQueue: TaskQueue<OutputQueueRecord>
-
availStreamWindowSize: AtomicInteger
-
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
-
-
DefaultInputBuffer
-
LOGGER: Logger
-
NULL_CONTENT_LENGTH: long
-
inputQueueSizeUpdater: AtomicIntegerFieldUpdater<DefaultInputBuffer>
-
inputQueueSize: int
-
inputQueue: BlockingQueue<InputElement>
-
inputClosed: AtomicBoolean
-
closeFlagUpdater: AtomicReferenceFieldUpdater<DefaultInputBuffer, Termination>
-
closeFlag: Termination
-
terminateSync: Object
-
stream: Http2Stream
-
http2Session: Http2Session
-
expectInputSwitchSync: Object
-
expectInputSwitch: boolean
-
remainingContentLength: long
-
DefaultInputBuffer(Http2Stream): void
-
onReadEventComplete(): void
-
offer(Buffer, boolean): boolean
-
offer0(InputElement): void
-
passPayloadUpstream(InputElement, int): void
-
poll(): HttpContent
-
poll0(): Buffer
-
close(Termination): void
-
terminate(Termination): void
-
isClosed(): boolean
-
checkEOF(InputElement): void
-
checkContentLength(int): boolean
-
switchOffExpectInput(): boolean
-
switchOffExpectInputIfQueueNotEmpty(): int
-
switchOnExpectInput(): void
-
buildHttpContent(Buffer): HttpContent
-
buildBrokenHttpContent(Throwable): HttpContent
-
bufSz(Buffer): int
-
InputElement
-
-
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
-
-
BundleQueue
-
AlpnSupport
-
LOGGER: Logger
-
SSL_TO_CONNECTION_MAP: Map<SSLEngine, Connection>
-
INSTANCE: AlpnSupport
-
static class initializer
-
isEnabled(): boolean
-
getInstance(): AlpnSupport
-
getConnection(SSLEngine): Connection
-
setConnection(SSLEngine, Connection): void
-
serverSideLock: ReadWriteLock
-
clientSideLock: ReadWriteLock
-
handshakeListener: HandshakeListener
-
AlpnSupport(): void
-
configure(SSLBaseFilter): void
-
-
AlpnServerNegotiatorImpl
-
AlpnNegotiatorBase
-
AlpnClientNegotiatorImpl
-
AggrCompletionHandler
-
frames
-
hpack
-
utils
-
-
-
-
Missing a library or version you want to see? Open an issue!
Icon set and themes from IntelliJ Community