| Modifier and Type | Class and Description |
|---|---|
| private class | HttpServerFilter.
The |
| Modifier and Type | Field and Description |
|---|---|
| private final AtomicInteger | activeRequestsCounter
The number of requests, which are currently in process. |
| private final ServerFilterConfiguration | config
Server configuration |
| private final HttpServerFilter. | flushResponseHandler
The |
| private volatile HttpHandler | |
| private final Attribute | httpRequestInProgress
Attribute, which holds the current HTTP Request in progress associated with an HttpContext |
| private static final Logger | |
| protected final DefaultMonitoringConfig | monitoringConfig
Web server probes |
| private AtomicReference | shutdownCompletionFuture
CompletionHandler to be notified, when shutdown could be gracefully completed |
| private AtomicBoolean | shuttingDown
The flag, which indicates if the server is currently in the shutdown phase |
| private final DelayedExecutor. | suspendedResponseQueue
Delay queue to control suspended request/response processing timeouts |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| private NextAction | afterService(final FilterChainContext ctx, final Connection<L> connection, final Request request, final Response response)
|
| private boolean | checkMaxPostSize(final long requestContentLength)
Returns: true if request content-length doesn't exceed the max post size limit, or false otherwise |
| protected Object | |
| public void | exceptionOccurred(final FilterChainContext
event processing ctx, final Throwable FilterChainContexterror, which occurred during FilterChain execution error)Overrides org. Implements org. Override the default implementation to notify the |
| public ServerFilterConfiguration | |
| protected String | |
| public HttpHandler | |
| public MonitoringConfig | getMonitoringConfig()
Implements org. Return the object associated |
| public NextAction | handleEvent(final FilterChainContext ctx, final FilterChainEvent event)
Overrides org. Implements org. Handle custom event associated with the |
| public NextAction | handleRead(final FilterChainContext ctx)
Overrides org. Implements org. Execute a unit of processing work to be performed, when channel will become available for reading. |
| private void | onRequestCompleteAndResponseFlushed()
Will be called, once HTTP request processing is complete and response is flushed. |
| protected void | |
| public void |
| activeRequestsCounter | back to summary |
|---|---|
| private final AtomicInteger activeRequestsCounter The number of requests, which are currently in process. | |
| config | back to summary |
|---|---|
| private final ServerFilterConfiguration config Server configuration | |
| flushResponseHandler | back to summary |
|---|---|
| private final HttpServerFilter. The | |
| httpHandler | back to summary |
|---|---|
| private volatile HttpHandler httpHandler Root | |
| httpRequestInProgress | back to summary |
|---|---|
| private final Attribute<Request> httpRequestInProgress Attribute, which holds the current HTTP Request in progress associated with an HttpContext | |
| LOGGER | back to summary |
|---|---|
| private static final Logger LOGGER | |
| monitoringConfig | back to summary |
|---|---|
| protected final DefaultMonitoringConfig<HttpServerProbe> monitoringConfig Web server probes | |
| shutdownCompletionFuture | back to summary |
|---|---|
| private AtomicReference<FutureImpl<HttpServerFilter>> shutdownCompletionFuture CompletionHandler to be notified, when shutdown could be gracefully completed | |
| shuttingDown | back to summary |
|---|---|
| private AtomicBoolean shuttingDown The flag, which indicates if the server is currently in the shutdown phase | |
| suspendedResponseQueue | back to summary |
|---|---|
| private final DelayedExecutor. Delay queue to control suspended request/response processing timeouts | |
| HttpServerFilter | back to summary |
|---|---|
| public HttpServerFilter(final ServerFilterConfiguration config, final DelayedExecutor delayedExecutor) | |
| afterService | back to summary |
|---|---|
| private NextAction afterService(final FilterChainContext ctx, final Connection<L> connection, final Request request, final Response response) throws IOException | |
| checkMaxPostSize | back to summary |
|---|---|
private boolean checkMaxPostSize(final long requestContentLength)
| |
| createJmxManagementObject | back to summary |
|---|---|
| protected Object createJmxManagementObject() | |
| exceptionOccurred | back to summary |
|---|---|
| public void exceptionOccurred(final FilterChainContext ctx, final Throwable error) Overrides org. Implements org. Override the default implementation to notify the
| |
| getConfiguration | back to summary |
|---|---|
| public ServerFilterConfiguration getConfiguration() | |
| getFullServerName | back to summary |
|---|---|
| protected String getFullServerName() | |
| getHttpHandler | back to summary |
|---|---|
public HttpHandler getHttpHandler()
| |
| getMonitoringConfig | back to summary |
|---|---|
| public MonitoringConfig Implements org. Doc from org. Return the object associated
| |
| handleEvent | back to summary |
|---|---|
| public NextAction handleEvent(final FilterChainContext ctx, final FilterChainEvent event) throws IOException Overrides org. Implements org. Doc from org. Handle custom event associated with the
| |
| handleRead | back to summary |
|---|---|
| public NextAction handleRead(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Doc from org. Execute a unit of processing work to be performed, when channel will become available for reading. This
| |
| onRequestCompleteAndResponseFlushed | back to summary |
|---|---|
| private void onRequestCompleteAndResponseFlushed() Will be called, once HTTP request processing is complete and response is flushed. | |
| onTraceRequest | back to summary |
|---|---|
| protected void onTraceRequest(final Request request, final Response response) throws IOException | |
| setHttpHandler | back to summary |
|---|---|
| public void setHttpHandler(final HttpHandler httpHandler) | |
CompletionHandler to be used to make sure the response data have been flushed.
| Modifier and Type | Field and Description |
|---|---|
| private final FilterChainEvent |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | cancelled()
Overrides org. Implements org. The operation was cancelled. |
| public void | completed(final Object result)
Overrides org. Implements org. The operation was completed. |
| public void | failed(final Throwable throwable)
Overrides org. Implements org. The operation was failed. |
| public void | onAfterService(final Request request)
Implements org. The method will be called once the |
| event | back to summary |
|---|---|
| private final FilterChainEvent event | |
| FlushResponseHandler | back to summary |
|---|---|
| private FlushResponseHandler() | |
| cancelled | back to summary |
|---|---|
| public void cancelled() Overrides org. Implements org. Doc from org. The operation was cancelled.
| |
| completed | back to summary |
|---|---|
| public void completed(final Object result) Overrides org. Implements org. Doc from org. The operation was completed.
| |
| failed | back to summary |
|---|---|
| public void failed(final Throwable throwable) Overrides org. Implements org. Doc from org. The operation was failed.
| |
| onAfterService | back to summary |
|---|---|
| public void onAfterService(final Request request) Implements org. Doc from org. The method will be called once the
| |