Top Description Inners Fields Constructors Methods
org.eclipse.jetty.server.internal

public Class HttpChannelState

extends Object
implements HttpChannel, Components
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.server.Components, org.eclipse.jetty.server.HttpChannel, org.eclipse.jetty.util.thread.Invocable
Imports
java.io.IOException, java.nio.ByteBuffer, java.nio.channels.WritePendingException, java.util.ArrayList, .HashMap, .List, .Objects, java.util.concurrent.CompletableFuture, .TimeoutException, java.util.concurrent.atomic.LongAdder, java.util.function.Consumer, .Function, .Predicate, .Supplier, org.eclipse.jetty.http.BadMessageException, .ComplianceViolation, .HttpField, .HttpFields, .HttpHeader, .HttpMethod, .HttpScheme, .HttpStatus, .HttpURI, .HttpVersion, .MetaData, .MultiPartFormData.Parts, .Trailers, .UriCompliance, org.eclipse.jetty.io.ByteBufferPool, .Content, org.eclipse.jetty.server.Components, .ConnectionMetaData, .Context, .Handler, .HttpChannel, .HttpConfiguration, .HttpStream, .Request, .RequestLog, .Response, .Server, .Session, .TunnelSupport, org.eclipse.jetty.util.Attributes, .BufferUtil, .Callback, .ExceptionUtil, .NanoTime, org.eclipse.jetty.util.thread.AutoLock, .Invocable, .Scheduler, .SerializedInvoker, .ThreadPool, org.slf4j.Logger, .LoggerFactory
A Channel represents a sequence of request cycles from the same connection with only a single request cycle may be active at once for each channel.

Many methods return Runnables to indicate that further work is needed. These can be given to an ExecutionStrategy instead of calling known methods like HttpChannel.handle().

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
HttpChannelState.ChannelCallback

public static class
HttpChannelState.ChannelRequest

public static class
HttpChannelState.ChannelResponse

The Channel's implementation of the Response API.

private static class
HttpChannelState.ErrorCallback

Used as the Response and Callback when writing the error response from HttpChannelState.ChannelCallback#failed(Throwable).

private static class
HttpChannelState.ErrorResponse

Used as the Response when writing the error response from HttpChannelState.ChannelCallback#failed(Throwable).

private class
HttpChannelState.HandlerInvoker

private class
HttpChannelState.HttpChannelSerializedInvoker

private static class
HttpChannelState.InitializedCompositeComplianceViolationListener

A Listener that represents multiple user ComplianceViolation.Listener instances

private static class
HttpChannelState.InterimCallback

private static enum
HttpChannelState.StreamSendState

The state of the written response

Field Summary

Modifier and TypeField and Description
private Attributes
_cache

private boolean
_callbackCompleted

private Throwable
_callbackFailure

private long
_committedContentLength

private ComplianceViolation.Listener
_complianceViolationListener

private final ConnectionMetaData
_connectionMetaData

private boolean
_expects100Continue

private boolean
_handled

private final HttpChannelState.HandlerInvoker
_handlerInvoker

private Thread
_handling

private final AutoLock
_lock

private long
_oldIdleTimeout

private Runnable
_onContentAvailable

private Consumer<Throwable>
_onFailure

private Predicate<TimeoutException>
_onIdleTimeout

private Content.Chunk
_readFailure

private final SerializedInvoker
_readInvoker

private HttpChannelState.ChannelRequest
_request

private HttpChannelState.ChannelResponse
_response

private final ResponseHttpFields
_responseHeaders

private HttpStream
_stream

private HttpChannelState.StreamSendState
_streamSendState

private final SerializedInvoker
_writeInvoker

private static final Logger
LOG

private static final Throwable
NOTHING_TO_SEND

private static final HttpField
POWERED_BY

private static final HttpField
SERVER_VERSION

Constructor Summary

AccessConstructor and Description
public
HttpChannelState(ConnectionMetaData connectionMetaData)

Method Summary

Modifier and TypeMethod and Description
public void
addHttpStreamWrapper(Function<HttpStream, HttpStream> onStreamEvent)

public ByteBufferPool
getByteBufferPool()

Implements org.eclipse.jetty.server.Components.getByteBufferPool.

public Attributes
getCache()

Implements org.eclipse.jetty.server.Components.getCache.

A Map which can be used as a cache for object (e.g. Cookie cache).
public ComplianceViolation.Listener
getComplianceViolationListener()

Implements org.eclipse.jetty.server.HttpChannel.getComplianceViolationListener.

public ConnectionMetaData
getConnectionMetaData()

Implements org.eclipse.jetty.server.HttpChannel.getConnectionMetaData.

public HttpConfiguration
getHttpConfiguration()

public HttpStream
getHttpStream()

public Invocable.InvocationType
getInvocationType()

Overrides default org.eclipse.jetty.util.thread.Invocable.getInvocationType.

public Request
getRequest()

Implements org.eclipse.jetty.server.HttpChannel.getRequest.

Returns the Request object, if available.

public Response
getResponse()

public Scheduler
getScheduler()

Implements org.eclipse.jetty.server.Components.getScheduler.

public Server
getServer()

public ThreadPool
getThreadPool()

Implements org.eclipse.jetty.server.Components.getThreadPool.

public void
initialize()

Implements org.eclipse.jetty.server.HttpChannel.initialize.

Initialize the HttpChannel when a new cycle of request handling begins.
public boolean
isRequestHandled()

Implements org.eclipse.jetty.server.HttpChannel.isRequestHandled.

private boolean
lockedIsLastStreamSendCompleted()

private boolean
lockedLastStreamSend()

private Throwable
lockedStreamSend(boolean last, long length)

private void
lockedStreamSendCompleted(boolean success)

public Runnable
onContentAvailable()

Implements org.eclipse.jetty.server.HttpChannel.onContentAvailable.

HttpStream invokes this method when more HTTP request content is available.

public Runnable
onFailure(Throwable
the failure cause.
x)

Implements org.eclipse.jetty.server.HttpChannel.onFailure.

Notifies this HttpChannel that an asynchronous failure happened.

public Runnable
onIdleTimeout(TimeoutException
the timeout.
t)

Implements org.eclipse.jetty.server.HttpChannel.onIdleTimeout.

Notifies this HttpChannel that an idle timeout happened.

public Runnable

Returns:

A Runnable that will call Handler#handle(Request, Response, Callback). Unlike all other Runnables returned by HttpChannel methods, this runnable should not be mutually excluded or serialized. Specifically other Runnables returned by methods on this class can be run concurrently with the Runnable returned from this method.
onRequest(MetaData.Request
The request metadata to handle.
request)

Implements org.eclipse.jetty.server.HttpChannel.onRequest.

Start request handling by returning a Runnable that will call Handler#handle(Request, Response, Callback).
public void
recycle()

Implements org.eclipse.jetty.server.HttpChannel.recycle.

Recycle the HttpChannel, so that a new cycle of calling setHttpStream(HttpStream), onRequest(MetaData.Request) etc. may be performed on the channel.
private void
resetResponse()

public void
setHttpStream(HttpStream
the HttpStream to associate to this channel.
stream)

Implements org.eclipse.jetty.server.HttpChannel.setHttpStream.

Set the HttpStream to associate to this channel..
public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait