Class HttpChannelOverHttp

java.lang.Object

org.eclipse.jetty.server.HttpChannel

org.eclipse.jetty.server.HttpChannelOverHttp

All Implemented Interfaces:

Runnable, HttpParser.ComplianceHandler, HttpParser.HttpHandler, HttpParser.RequestHandler, HttpOutput.Interceptor

public class HttpChannelOverHttp
extends HttpChannel
implements HttpParser.RequestHandler, HttpParser.ComplianceHandler

An HttpChannel customized to be transported over the HTTP/1 protocol

Nested Class Summary

Nested classes/interfaces inherited from class HttpChannel

HttpChannel.Dispatchable, HttpChannel.Listener, HttpChannel.TransientListeners

Field Summary

Fields

Modifier and Type	Field	Description
private List<String>	_complianceViolations
private HttpField	_connection
private boolean	_delayedForContent
private boolean	_expect100Continue
private boolean	_expect102Processing
private final HttpFields	_fields
private final HttpConnection	_httpConnection
private final MetaData.Request	_metadata
private HttpFields	_trailers
private boolean	_unknownExpectation
private HttpField	_upgrade
private static final Logger	LOG
private static final HttpField	PREAMBLE_UPGRADE_H2C

Fields inherited from class HttpChannel

NOOP_LISTENER

Constructor Summary

Constructors

Constructor	Description
HttpChannelOverHttp(HttpConnection httpConnection, Connector connector, HttpConfiguration config, EndPoint endPoint, HttpTransport transport)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable failure)	If a write or similar operation to this channel fails, then this method should be called.
void	badMessage(BadMessageException failure)	Called to signal that a bad HTTP message has been received.
boolean	content(ByteBuffer content)
boolean	contentComplete()
void	continue100(int available)	If the associated response has the Expect header set to 100 Continue, then accessing the input stream indicates that the handler/servlet is ready for the request body and thus a 100 Continue response is sent.
void	earlyEOF()	Called to signal that an EOF was received unexpectedly during the parsing of an HTTP message
int	getHeaderCacheSize()
protected void	handleException(Throwable x)	Sends an error 500, performing a special logic to detect whether the request is suspended, to avoid concurrent writes from the application.
boolean	headerComplete()
boolean	isExpecting100Continue()
boolean	isExpecting102Processing()
boolean	messageComplete()
protected HttpInput	newHttpInput(HttpChannelState state)
void	onAsyncWaitForContent()
void	onBlockWaitForContent()
void	onBlockWaitForContentFailure(Throwable failure)
void	onComplianceViolation(HttpCompliance compliance, HttpComplianceSection violation, String reason)
(package private) boolean	onIdleTimeout(Throwable timeout)
void	parsedHeader(HttpField field)	This is the method called by parser when an HTTP Header name and value is found
void	parsedTrailer(HttpField field)	This is the method called by parser when an HTTP Trailer name and value is found
void	recycle()
boolean	startRequest(String method, String requestTarget, HttpVersion version)	This is the method called by parser when the HTTP request line is parsed
private boolean	upgrade()	Attempts to perform an HTTP/1.1 upgrade.

Methods inherited from class HttpChannel

addListener, addRequestLog, commit, ensureConsumeAllOrNotPersistent, execute, formatAddrOrHost, getByteBufferPool, getBytesWritten, getCommittedMetaData, getConnection, getConnector, getEndPoint, getHttpConfiguration, getHttpTransport, getIdleTimeout, getLocalAddress, getLocalName, getLocalPort, getNextInterceptor, getRemoteAddress, getRequest, getRequestLog, getRequests, getResponse, getScheduler, getServer, getServerAuthority, getState, getTransientListeners, handle, isCommitted, isOptimizedForDirectBuffers, isPersistent, isRequestCompleted, isResponseCompleted, isSendError, newHttpOutput, onBadMessage, onCompleted, onContent, onContentComplete, onEarlyEOF, onRequest, onRequestComplete, onTrailers, removeListener, resetBuffer, run, sendResponse, sendResponse, sendResponseAndComplete, setIdleTimeout, setRequestLog, toString, unwrap, useDirectBuffers, write

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface HttpParser.ComplianceHandler

onComplianceViolation

Methods inherited from interface HttpParser.HttpHandler

badMessage

Field Details

LOG

private static final Logger LOG

PREAMBLE_UPGRADE_H2C

private static final HttpField PREAMBLE_UPGRADE_H2C

_fields

private final HttpFields _fields

_metadata

private final MetaData.Request _metadata

_httpConnection

private final HttpConnection _httpConnection

_connection

private HttpField _connection

_upgrade

private HttpField _upgrade

_delayedForContent

private boolean _delayedForContent

_unknownExpectation

private boolean _unknownExpectation

_expect100Continue

private boolean _expect100Continue

_expect102Processing

private boolean _expect102Processing

_complianceViolations

private List<String> _complianceViolations

_trailers

private HttpFields _trailers

Constructor Details

HttpChannelOverHttp

public HttpChannelOverHttp(HttpConnection httpConnection,
 Connector connector,
 HttpConfiguration config,
 EndPoint endPoint,
 HttpTransport transport)

Method Details

newHttpInput

protected HttpInput newHttpInput(HttpChannelState state)

Overrides:

newHttpInput in class HttpChannel

recycle

public void recycle()

Overrides:

recycle in class HttpChannel

isExpecting100Continue

public boolean isExpecting100Continue()

Overrides:

isExpecting100Continue in class HttpChannel

isExpecting102Processing

public boolean isExpecting102Processing()

Overrides:

isExpecting102Processing in class HttpChannel

startRequest

public boolean startRequest(String method,
 String requestTarget,
 HttpVersion version)

Description copied from interface: HttpParser.RequestHandler

This is the method called by parser when the HTTP request line is parsed

Specified by:

startRequest in interface HttpParser.RequestHandler

Parameters:

method - The method

requestTarget - The raw bytes of the URI. These are copied into a ByteBuffer that will not be changed until this parser is reset and reused.

version - the http version in use

Returns:

true if handling parsing should return.

parsedHeader

public void parsedHeader(HttpField field)

Description copied from interface: HttpParser.HttpHandler

This is the method called by parser when an HTTP Header name and value is found

Specified by:

parsedHeader in interface HttpParser.HttpHandler

Parameters:

field - The field parsed

parsedTrailer

public void parsedTrailer(HttpField field)

Description copied from interface: HttpParser.HttpHandler

This is the method called by parser when an HTTP Trailer name and value is found

Specified by:

parsedTrailer in interface HttpParser.HttpHandler

Parameters:

field - The field parsed

continue100

public void continue100(int available)
                 throws IOException

If the associated response has the Expect header set to 100 Continue, then accessing the input stream indicates that the handler/servlet is ready for the request body and thus a 100 Continue response is sent.

Overrides:

continue100 in class HttpChannel

Parameters:

available - estimate of the number of bytes that are available

Throws:

IOException - if the InputStream cannot be created

earlyEOF

public void earlyEOF()

Description copied from interface: HttpParser.HttpHandler

Called to signal that an EOF was received unexpectedly during the parsing of an HTTP message

Specified by:

earlyEOF in interface HttpParser.HttpHandler

content

public boolean content(ByteBuffer content)

Specified by:

content in interface HttpParser.HttpHandler

onAsyncWaitForContent

public void onAsyncWaitForContent()

Overrides:

onAsyncWaitForContent in class HttpChannel

onBlockWaitForContent

public void onBlockWaitForContent()

Overrides:

onBlockWaitForContent in class HttpChannel

onBlockWaitForContentFailure

public void onBlockWaitForContentFailure(Throwable failure)

Overrides:

onBlockWaitForContentFailure in class HttpChannel

badMessage

public void badMessage(BadMessageException failure)

Description copied from interface: HttpParser.HttpHandler

Called to signal that a bad HTTP message has been received.

Specified by:

badMessage in interface HttpParser.HttpHandler

Parameters:

failure - the failure with the bad message information

headerComplete

public boolean headerComplete()

Specified by:

headerComplete in interface HttpParser.HttpHandler

onIdleTimeout

boolean onIdleTimeout(Throwable timeout)

upgrade

private boolean upgrade()
                 throws BadMessageException

Attempts to perform an HTTP/1.1 upgrade.

The upgrade looks up a ConnectionFactory.Upgrading from the connector matching the protocol specified in the Upgrade header.

The upgrade may succeed, be ignored (which can allow a later handler to implement) or fail with a BadMessageException.

Returns:

true if the upgrade was performed, false if it was ignored

Throws:

BadMessageException - if the upgrade failed

handleException

protected void handleException(Throwable x)

Description copied from class: HttpChannel

Sends an error 500, performing a special logic to detect whether the request is suspended, to avoid concurrent writes from the application.

It may happen that the application suspends, and then throws an exception, while an application spawned thread writes the response content; in such case, we attempt to commit the error directly bypassing the ErrorHandler mechanisms and the response OutputStream.

Overrides:

handleException in class HttpChannel

Parameters:

x - the Throwable that caused the problem

abort

public void abort(Throwable failure)

Description copied from class: HttpChannel

If a write or similar operation to this channel fails, then this method should be called.

The standard implementation calls HttpTransport.abort(Throwable).

Overrides:

abort in class HttpChannel

Parameters:

failure - the failure that caused the abort.

contentComplete

public boolean contentComplete()

Specified by:

contentComplete in interface HttpParser.HttpHandler

messageComplete

public boolean messageComplete()

Specified by:

messageComplete in interface HttpParser.HttpHandler

getHeaderCacheSize

public int getHeaderCacheSize()

Specified by:

getHeaderCacheSize in interface HttpParser.HttpHandler

Returns:

the size in bytes of the per parser header cache

onComplianceViolation

public void onComplianceViolation(HttpCompliance compliance,
 HttpComplianceSection violation,
 String reason)

Specified by:

onComplianceViolation in interface HttpParser.ComplianceHandler