Dependencies
Declarations
-
org
-
apache
-
coyote
-
AbstractProcessor
- sm: StringManager
- hostNameC: char[]
- adapter: Adapter
- asyncStateMachine: AsyncStateMachine
- asyncTimeout: long
- asyncTimeoutGeneration: long
- request: Request
- response: Response
- socketWrapper: SocketWrapperBase<Object>
- sslSupport: SSLSupport
- errorState: ErrorState
- userDataHelper: UserDataHelper
- AbstractProcessor(Adapter): void
- AbstractProcessor(Adapter, Request, Response): void
- setErrorState(ErrorState, Throwable): void
- getErrorState(): ErrorState
- getRequest(): Request
- getAdapter(): Adapter
- setSocketWrapper(SocketWrapperBase<Object>): void
- getSocketWrapper(): SocketWrapperBase<Object>
- setSslSupport(SSLSupport): void
- execute(Runnable): void
- isAsync(): boolean
- asyncPostProcess(): SocketState
- dispatch(SocketEvent): SocketState
- parseHost(MessageBytes): void
- doTimeoutAsync(): void
- populateHost(): void
- populatePort(): void
- action(ActionCode, Object): void
- handleIOException(IOException): void
- dispatchNonBlockingRead(): void
- timeoutAsync(long): void
- checkAsyncTimeoutGeneration(): boolean
- setAsyncTimeout(long): void
- getAsyncTimeout(): long
- recycle(): void
- prepareResponse(): void
- finishResponse(): void
- ack(ContinueResponseTiming): void
- flush(): void
- available(boolean): int
- setRequestBody(ByteChunk): void
- setSwallowResponse(): void
- disableSwallowRequest(): void
- getPopulateRequestAttributesFromSocket(): boolean
- populateRequestAttributeRemoteHost(): void
- populateSslRequestAttributes(): void
- sslReHandShake(): void
- processSocketEvent(SocketEvent, boolean): void
- isReadyForRead(): boolean
- isRequestBodyFullyRead(): boolean
- registerReadInterest(): void
- isReadyForWrite(): boolean
- executeDispatches(): void
- getUpgradeToken(): UpgradeToken
- doHttpUpgrade(UpgradeToken): void
- getLeftoverInput(): ByteBuffer
- isUpgrade(): boolean
- isPushSupported(): boolean
- doPush(Request): void
- isTrailerFieldsReady(): boolean
- isTrailerFieldsSupported(): boolean
- getConnectionID(): Object
- getStreamID(): Object
- flushBufferedWrite(): boolean
- dispatchEndRequest(): SocketState
- logAccess(SocketWrapperBase<Object>): void
-
AbstractProcessorLight
- dispatches: Set<DispatchType>
- process(SocketWrapperBase<Object>, SocketEvent): SocketState
- checkForPipelinedData(SocketState, SocketWrapperBase<Object>): SocketState
- addDispatch(DispatchType): void
- getIteratorAndClearDispatches(): Iterator<DispatchType>
- clearDispatches(): void
- logAccess(SocketWrapperBase<Object>): void
- service(SocketWrapperBase<Object>): SocketState
- dispatch(SocketEvent): SocketState
- asyncPostProcess(): SocketState
- getLog(): Log
-
AbstractProtocol
- ConnectionHandler
- sm: StringManager
- nameCounter: AtomicInteger
- nameIndex: int
- endpoint: AbstractEndpoint<Object, Object>
- handler: Handler<Object>
- waitingProcessors: Set<Processor>
- timeoutFuture: ScheduledFuture<Object>
- monitorFuture: ScheduledFuture<Object>
- AbstractProtocol(AbstractEndpoint<Object, Object>): void
- setProperty(String, String): boolean
- getProperty(String): String
- rgOname: ObjectName
- getGlobalRequestProcessorMBeanName(): ObjectName
- adapter: Adapter
- setAdapter(Adapter): void
- getAdapter(): Adapter
- processorCache: int
- getProcessorCache(): int
- setProcessorCache(int): void
- clientCertProvider: String
- getClientCertProvider(): String
- getNameIndex(): int
- setClientCertProvider(String): void
- maxHeaderCount: int
- getMaxHeaderCount(): int
- setMaxHeaderCount(int): void
- isAprRequired(): boolean
- isSendfileSupported(): boolean
- getExecutor(): Executor
- setExecutor(Executor): void
- getUtilityExecutor(): ScheduledExecutorService
- setUtilityExecutor(ScheduledExecutorService): void
- getMaxThreads(): int
- setMaxThreads(int): void
- getMaxConnections(): int
- setMaxConnections(int): void
- getMinSpareThreads(): int
- setMinSpareThreads(int): void
- getThreadPriority(): int
- setThreadPriority(int): void
- getAcceptCount(): int
- setAcceptCount(int): void
- getTcpNoDelay(): boolean
- setTcpNoDelay(boolean): void
- getConnectionLinger(): int
- setConnectionLinger(int): void
- getKeepAliveTimeout(): int
- setKeepAliveTimeout(int): void
- getAddress(): InetAddress
- setAddress(InetAddress): void
- getPort(): int
- setPort(int): void
- getPortOffset(): int
- setPortOffset(int): void
- getPortWithOffset(): int
- getLocalPort(): int
- getConnectionTimeout(): int
- setConnectionTimeout(int): void
- getConnectionCount(): long
- setAcceptorThreadPriority(int): void
- getAcceptorThreadPriority(): int
- getName(): String
- getNameInternal(): String
- addWaitingProcessor(Processor): void
- removeWaitingProcessor(Processor): void
- getWaitingProcessorCount(): int
- getEndpoint(): AbstractEndpoint<Object, Object>
- getHandler(): Handler<Object>
- setHandler(Handler<Object>): void
- getLog(): Log
- getNamePrefix(): String
- getProtocolName(): String
- getNegotiatedProtocol(String): UpgradeProtocol
- getUpgradeProtocol(String): UpgradeProtocol
- createProcessor(): Processor
- createUpgradeProcessor(SocketWrapperBase<Object>, UpgradeToken): Processor
- domain: String
- oname: ObjectName
- mserver: MBeanServer
- getObjectName(): ObjectName
- getDomain(): String
- preRegister(MBeanServer, ObjectName): ObjectName
- postRegister(Boolean): void
- preDeregister(): void
- postDeregister(): void
- createObjectName(): ObjectName
- init(): void
- start(): void
- startAsyncTimeout(): void
- stopAsyncTimeout(): void
- pause(): void
- isPaused(): boolean
- resume(): void
- stop(): void
- destroy(): void
- closeServerSocketGraceful(): void
- awaitConnectionsClose(long): long
- logPortOffset(): void
- RecycledProcessors
-
ActionCode
- REQ_LOCAL_NAME_ATTRIBUTE: ActionCode
- ACK: ActionCode
- CLOSE: ActionCode
- COMMIT: ActionCode
- CLOSE_NOW: ActionCode
- CLIENT_FLUSH: ActionCode
- IS_ERROR: ActionCode
- IS_IO_ALLOWED: ActionCode
- DISABLE_SWALLOW_INPUT: ActionCode
- REQ_HOST_ATTRIBUTE: ActionCode
- REQ_HOST_ADDR_ATTRIBUTE: ActionCode
- REQ_SSL_ATTRIBUTE: ActionCode
- REQ_SSL_CERTIFICATE: ActionCode
- REQ_REMOTEPORT_ATTRIBUTE: ActionCode
- REQ_LOCALPORT_ATTRIBUTE: ActionCode
- REQ_LOCAL_ADDR_ATTRIBUTE: ActionCode
- REQ_SET_BODY_REPLAY: ActionCode
- AVAILABLE: ActionCode
- ASYNC_START: ActionCode
- ASYNC_DISPATCH: ActionCode
- ASYNC_DISPATCHED: ActionCode
- ASYNC_RUN: ActionCode
- ASYNC_COMPLETE: ActionCode
- ASYNC_TIMEOUT: ActionCode
- ASYNC_ERROR: ActionCode
- ASYNC_SETTIMEOUT: ActionCode
- ASYNC_IS_ASYNC: ActionCode
- ASYNC_IS_STARTED: ActionCode
- ASYNC_IS_COMPLETING: ActionCode
- ASYNC_IS_DISPATCHING: ActionCode
- ASYNC_IS_TIMINGOUT: ActionCode
- ASYNC_IS_ERROR: ActionCode
- ASYNC_POST_PROCESS: ActionCode
- UPGRADE: ActionCode
- NB_READ_INTEREST: ActionCode
- NB_WRITE_INTEREST: ActionCode
- REQUEST_BODY_FULLY_READ: ActionCode
- DISPATCH_READ: ActionCode
- DISPATCH_WRITE: ActionCode
- DISPATCH_EXECUTE: ActionCode
- IS_PUSH_SUPPORTED: ActionCode
- PUSH_REQUEST: ActionCode
- IS_TRAILER_FIELDS_READY: ActionCode
- IS_TRAILER_FIELDS_SUPPORTED: ActionCode
- CONNECTION_ID: ActionCode
- STREAM_ID: ActionCode
- ActionHook
- Adapter
- AsyncContextCallback
-
AsyncStateMachine
- AsyncState
- sm: StringManager
- state: AsyncState
- lastAsyncStart: long
- generation: AtomicLong
- asyncCtxt: AsyncContextCallback
- processor: AbstractProcessor
- AsyncStateMachine(AbstractProcessor): void
- isAsync(): boolean
- isAsyncDispatching(): boolean
- isAsyncStarted(): boolean
- isAsyncTimingOut(): boolean
- isAsyncError(): boolean
- isCompleting(): boolean
- getLastAsyncStart(): long
- getCurrentGeneration(): long
- asyncStart(AsyncContextCallback): void
- asyncOperation(): void
- asyncPostProcess(): SocketState
- asyncComplete(): boolean
- asyncTimeout(): boolean
- asyncDispatch(): boolean
- asyncDispatched(): void
- asyncError(): boolean
- asyncRun(Runnable): void
- isAvailable(): boolean
- recycle(): void
- clearNonBlockingListeners(): void
- CloseNowException
-
CompressionConfig
- log: Log
- sm: StringManager
- compressionLevel: int
- noCompressionUserAgents: Pattern
- compressibleMimeType: String
- compressibleMimeTypes: String[]
- compressionMinSize: int
- setCompression(String): void
- getCompression(): String
- getCompressionLevel(): int
- getNoCompressionUserAgents(): String
- getNoCompressionUserAgentsPattern(): Pattern
- setNoCompressionUserAgents(String): void
- getCompressibleMimeType(): String
- setCompressibleMimeType(String): void
- getCompressibleMimeTypes(): String[]
- getCompressionMinSize(): int
- setCompressionMinSize(int): void
- useCompression(Request, Response): boolean
- startsWithStringArray(String[], String): boolean
-
Constants
- DEFAULT_URI_CHARSET: Charset
- DEFAULT_BODY_CHARSET: Charset
- MAX_NOTES: int
- STAGE_NEW: int
- STAGE_PARSE: int
- STAGE_PREPARE: int
- STAGE_SERVICE: int
- STAGE_ENDINPUT: int
- STAGE_ENDOUTPUT: int
- STAGE_KEEPALIVE: int
- STAGE_ENDED: int
- DEFAULT_CONNECTION_LINGER: int
- DEFAULT_TCP_NO_DELAY: boolean
- IS_SECURITY_ENABLED: boolean
- SENDFILE_SUPPORTED_ATTR: String
- SENDFILE_FILENAME_ATTR: String
- SENDFILE_FILE_START_ATTR: String
- SENDFILE_FILE_END_ATTR: String
- REMOTE_ADDR_ATTRIBUTE: String
- ContainerThreadMarker
- ContinueResponseTiming
-
ErrorState
- NONE: ErrorState
- CLOSE_CLEAN: ErrorState
- CLOSE_NOW: ErrorState
- CLOSE_CONNECTION_NOW: ErrorState
- error: boolean
- severity: int
- ioAllowed: boolean
- connectionIoAllowed: boolean
- ErrorState(boolean, int, boolean, boolean): void
- isError(): boolean
- getMostSevere(ErrorState): ErrorState
- isIoAllowed(): boolean
- isConnectionIoAllowed(): boolean
- InputBuffer
- OutputBuffer
-
Processor
- process(SocketWrapperBase<Object>, SocketEvent): SocketState
- getUpgradeToken(): UpgradeToken
- isUpgrade(): boolean
- isAsync(): boolean
- timeoutAsync(long): void
- getRequest(): Request
- recycle(): void
- setSslSupport(SSLSupport): void
- getLeftoverInput(): ByteBuffer
- pause(): void
- checkAsyncTimeoutGeneration(): boolean
- ProtocolException
-
ProtocolHandler
- getAdapter(): Adapter
- setAdapter(Adapter): void
- getExecutor(): Executor
- setExecutor(Executor): void
- getUtilityExecutor(): ScheduledExecutorService
- setUtilityExecutor(ScheduledExecutorService): void
- init(): void
- start(): void
- pause(): void
- resume(): void
- stop(): void
- destroy(): void
- closeServerSocketGraceful(): void
- awaitConnectionsClose(long): long
- isAprRequired(): boolean
- isSendfileSupported(): boolean
- addSslHostConfig(SSLHostConfig): void
- findSslHostConfigs(): SSLHostConfig[]
- addUpgradeProtocol(UpgradeProtocol): void
- findUpgradeProtocols(): UpgradeProtocol[]
- getDesiredBufferSize(): int
- create(String): ProtocolHandler
-
Request
- methodMB: MessageBytes
- uriMB: MessageBytes
- decodedUriMB: MessageBytes
- sm: StringManager
- INITIAL_COOKIE_SIZE: int
- Request(): void
- serverPort: int
- serverNameMB: MessageBytes
- remotePort: int
- localPort: int
- schemeMB: MessageBytes
- queryMB: MessageBytes
- protoMB: MessageBytes
- remoteAddrMB: MessageBytes
- localNameMB: MessageBytes
- remoteHostMB: MessageBytes
- localAddrMB: MessageBytes
- headers: MimeHeaders
- trailerFields: Map<String, String>
- pathParameters: Map<String, String>
- notes: Object[]
- inputBuffer: InputBuffer
- urlDecoder: UDecoder
- contentLength: long
- contentTypeMB: MessageBytes
- charset: Charset
- characterEncoding: String
- expectation: boolean
- serverCookies: ServerCookies
- parameters: Parameters
- remoteUser: MessageBytes
- remoteUserNeedsAuthorization: boolean
- authType: MessageBytes
- attributes: HashMap<String, Object>
- response: Response
- hook: ActionHook
- bytesRead: long
- startTimeNanos: long
- available: int
- reqProcessorMX: RequestInfo
- sendfile: boolean
- listener: ReadListener
- getReadListener(): ReadListener
- setReadListener(ReadListener): void
- allDataReadEventSent: AtomicBoolean
- sendAllDataReadEvent(): boolean
- getMimeHeaders(): MimeHeaders
- isTrailerFieldsReady(): boolean
- getTrailerFields(): Map<String, String>
- getURLDecoder(): UDecoder
- scheme(): MessageBytes
- method(): MessageBytes
- requestURI(): MessageBytes
- decodedURI(): MessageBytes
- queryString(): MessageBytes
- protocol(): MessageBytes
- serverName(): MessageBytes
- getServerPort(): int
- setServerPort(int): void
- remoteAddr(): MessageBytes
- remoteHost(): MessageBytes
- localName(): MessageBytes
- localAddr(): MessageBytes
- getRemotePort(): int
- setRemotePort(int): void
- getLocalPort(): int
- setLocalPort(int): void
- getCharacterEncoding(): String
- getCharset(): Charset
- setCharset(Charset): void
- setContentLength(long): void
- getContentLength(): int
- getContentLengthLong(): long
- getContentType(): String
- setContentType(String): void
- contentType(): MessageBytes
- setContentType(MessageBytes): void
- getHeader(String): String
- setExpectation(boolean): void
- hasExpectation(): boolean
- getResponse(): Response
- setResponse(Response): void
- setHook(ActionHook): void
- action(ActionCode, Object): void
- getCookies(): ServerCookies
- getParameters(): Parameters
- addPathParameter(String, String): void
- getPathParameter(String): String
- setAttribute(String, Object): void
- getAttributes(): HashMap<String, Object>
- getAttribute(String): Object
- getRemoteUser(): MessageBytes
- getRemoteUserNeedsAuthorization(): boolean
- setRemoteUserNeedsAuthorization(boolean): void
- getAuthType(): MessageBytes
- getAvailable(): int
- setAvailable(int): void
- getSendfile(): boolean
- setSendfile(boolean): void
- isFinished(): boolean
- getSupportsRelativeRedirects(): boolean
- getInputBuffer(): InputBuffer
- setInputBuffer(InputBuffer): void
- doRead(ApplicationBufferHandler): int
- toString(): String
- getStartTime(): long
- setStartTime(long): void
- getStartTimeNanos(): long
- setStartTimeNanos(long): void
- setNote(int, Object): void
- getNote(int): Object
- recycle(): void
- updateCounters(): void
- getRequestProcessor(): RequestInfo
- getBytesRead(): long
- isProcessing(): boolean
- getCharsetFromContentType(String): String
-
RequestGroupInfo
- processors: List<RequestInfo>
- deadMaxTime: long
- deadProcessingTime: long
- deadRequestCount: int
- deadErrorCount: int
- deadBytesReceived: long
- deadBytesSent: long
- addRequestProcessor(RequestInfo): void
- removeRequestProcessor(RequestInfo): void
- getMaxTime(): long
- setMaxTime(long): void
- getProcessingTime(): long
- setProcessingTime(long): void
- getRequestCount(): int
- setRequestCount(int): void
- getErrorCount(): int
- setErrorCount(int): void
- getBytesReceived(): long
- setBytesReceived(long): void
- getBytesSent(): long
- setBytesSent(long): void
- resetCounters(): void
-
RequestInfo
- global: RequestGroupInfo
- RequestInfo(Request): void
- getGlobalProcessor(): RequestGroupInfo
- setGlobalProcessor(RequestGroupInfo): void
- req: Request
- stage: int
- workerThreadName: String
- rpName: ObjectName
- getMethod(): String
- getCurrentUri(): String
- getCurrentQueryString(): String
- getProtocol(): String
- getVirtualHost(): String
- getServerPort(): int
- getRemoteAddr(): String
- getRemoteAddrForwarded(): String
- getContentLength(): int
- getRequestBytesReceived(): long
- getRequestBytesSent(): long
- getRequestProcessingTime(): long
- bytesSent: long
- bytesReceived: long
- processingTime: long
- maxTime: long
- maxRequestUri: String
- requestCount: int
- errorCount: int
- lastRequestProcessingTime: long
- updateCounters(): void
- getStage(): int
- setStage(int): void
- getBytesSent(): long
- setBytesSent(long): void
- getBytesReceived(): long
- setBytesReceived(long): void
- getProcessingTime(): long
- setProcessingTime(long): void
- getMaxTime(): long
- setMaxTime(long): void
- getMaxRequestUri(): String
- setMaxRequestUri(String): void
- getRequestCount(): int
- setRequestCount(int): void
- getErrorCount(): int
- setErrorCount(int): void
- getWorkerThreadName(): String
- getRpName(): ObjectName
- getLastRequestProcessingTime(): long
- setWorkerThreadName(String): void
- setRpName(ObjectName): void
- setLastRequestProcessingTime(long): void
-
Response
- sm: StringManager
- log: Log
- DEFAULT_LOCALE: Locale
- status: int
- message: String
- headers: MimeHeaders
- trailerFieldsSupplier: Supplier<Map<String, String>>
- outputBuffer: OutputBuffer
- notes: Object[]
- committed: boolean
- hook: ActionHook
- contentType: String
- contentLanguage: String
- charset: Charset
- characterEncoding: String
- contentLength: long
- locale: Locale
- contentWritten: long
- commitTimeNanos: long
- errorException: Exception
- errorState: AtomicInteger
- req: Request
- getRequest(): Request
- setRequest(Request): void
- setOutputBuffer(OutputBuffer): void
- getMimeHeaders(): MimeHeaders
- setHook(ActionHook): void
- setNote(int, Object): void
- getNote(int): Object
- action(ActionCode, Object): void
- getStatus(): int
- setStatus(int): void
- getMessage(): String
- setMessage(String): void
- isCommitted(): boolean
- setCommitted(boolean): void
- getCommitTime(): long
- isReady(): boolean
- getCommitTimeNanos(): long
- setErrorException(Exception): void
- getErrorException(): Exception
- isExceptionPresent(): boolean
- setError(): boolean
- isError(): boolean
- isErrorReportRequired(): boolean
- setErrorReported(): boolean
- reset(): void
- containsHeader(String): boolean
- setHeader(String, String): void
- addHeader(String, String): void
- addHeader(String, String, Charset): void
- setTrailerFields(Supplier<Map<String, String>>): void
- getTrailerFields(): Supplier<Map<String, String>>
- checkSpecialHeader(String, String): boolean
- sendHeaders(): void
- getLocale(): Locale
- setLocale(Locale): void
- getContentLanguage(): String
- setCharacterEncoding(String): void
- getCharset(): Charset
- getCharacterEncoding(): String
- setContentType(String): void
- setContentTypeNoCharset(String): void
- getContentType(): String
- setContentLength(long): void
- getContentLength(): int
- getContentLengthLong(): long
- doWrite(ByteBuffer): void
- recycle(): void
- getContentWritten(): long
- getBytesWritten(boolean): long
- listener: WriteListener
- fireListener: boolean
- registeredForWrite: boolean
- nonBlockingStateLock: Object
- getWriteListener(): WriteListener
- setWriteListener(WriteListener): void
- checkRegisterForWrite(): boolean
- onWritePossible(): void
-
UpgradeProtocol
- getHttpUpgradeName(boolean): String
- getAlpnIdentifier(): byte[]
- getAlpnName(): String
- getProcessor(SocketWrapperBase<Object>, Adapter): Processor
- getInternalUpgradeHandler(SocketWrapperBase<Object>, Adapter, Request): InternalHttpUpgradeHandler
- accept(Request): boolean
- setHttp11Protocol(AbstractHttp11Protocol<Object>): void
- UpgradeToken
- ajp
- http11
-
http2
- AbstractNonZeroStream
- AbstractStream
- ByteUtil
- ConnectionException
- ConnectionSettingsBase
- ConnectionSettingsLocal
- ConnectionSettingsRemote
- Constants
- Flags
- FrameType
- HPackHuffman
- HeaderSink
- Hpack
- HpackDecoder
- HpackEncoder
- HpackException
- Http2AsyncParser
- Http2AsyncUpgradeHandler
- Http2Error
- Http2Exception
- Http2OutputBuffer
- Http2Parser
- Http2Protocol
- Http2UpgradeHandler
- RecycledStream
- SendfileData
- Setting
- Stream
- StreamException
- StreamProcessor
- StreamRunnable
- StreamStateMachine
- WindowAllocationManager
-
AbstractProcessor
- tomcat
-
coyote
-
apache