org.eclipse.jetty.server

Class HttpConnection.HttpChannelOverHttp

java.lang.Object

org.eclipse.jetty.server.HttpChannel<ByteBuffer>

org.eclipse.jetty.server.HttpConnection.HttpChannelOverHttp

All Implemented Interfaces:

Runnable, HttpParser.HttpHandler<ByteBuffer>, HttpParser.ProxyHandler, HttpParser.RequestHandler<ByteBuffer>

Enclosing class:

HttpConnection

protected class HttpConnection.HttpChannelOverHttp
extends HttpChannel<ByteBuffer>

Constructor Summary

Constructors

Constructor and Description
HttpConnection.HttpChannelOverHttp(Connector connector, HttpConfiguration config, EndPoint endPoint, HttpTransport transport, HttpInput<ByteBuffer> input)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort() If a write or similar to this channel fails this method should be called.
void	badMessage(int status, String reason) Called to signal that a bad HTTP message has been received.
boolean	content(ByteBuffer item)
void	earlyEOF() Called to signal that an EOF was received unexpectedly during the parsing of a HTTP message
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	messageComplete()

Methods inherited from class org.eclipse.jetty.server.HttpChannel

continue100, execute, getByteBufferPool, getConnector, getCurrentHttpChannel, getEndPoint, getHeaderCacheSize, getHttpConfiguration, getHttpTransport, getHttpVersion, getIdleTimeout, getLocalAddress, getRemoteAddress, getRequest, getRequests, getResponse, getScheduler, getServer, getState, handle, isCommitted, isExpecting100Continue, isExpecting102Processing, parsedHeader, parsedHostHeader, proxied, reset, run, sendResponse, sendResponse, setCurrentHttpChannel, setIdleTimeout, startRequest, toString, useDirectBuffers, write

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpConnection.HttpChannelOverHttp

public HttpConnection.HttpChannelOverHttp(Connector connector,
                                  HttpConfiguration config,
                                  EndPoint endPoint,
                                  HttpTransport transport,
                                  HttpInput<ByteBuffer> input)

Method Detail

earlyEOF

public void earlyEOF()

Description copied from interface: HttpParser.HttpHandler

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

Specified by:

earlyEOF in interface HttpParser.HttpHandler<ByteBuffer>

Overrides:

earlyEOF in class HttpChannel<ByteBuffer>

content

public boolean content(ByteBuffer item)

Specified by:

content in interface HttpParser.HttpHandler<ByteBuffer>

Overrides:

content in class HttpChannel<ByteBuffer>

badMessage

public void badMessage(int status,
              String reason)

Description copied from interface: HttpParser.HttpHandler

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

Specified by:

badMessage in interface HttpParser.HttpHandler<ByteBuffer>

Overrides:

badMessage in class HttpChannel<ByteBuffer>

Parameters:

status - The bad status to send

reason - The textual reason for badness

headerComplete

public boolean headerComplete()

Specified by:

headerComplete in interface HttpParser.HttpHandler<ByteBuffer>

Overrides:

headerComplete in class HttpChannel<ByteBuffer>

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<ByteBuffer>

Parameters:

x - the Throwable that caused the problem

abort

public void abort()

Description copied from class: HttpChannel

If a write or similar to this channel fails this method should be called. The standard implementation is to call HttpTransport.abort()

Overrides:

abort in class HttpChannel<ByteBuffer>

messageComplete

public boolean messageComplete()

Specified by:

messageComplete in interface HttpParser.HttpHandler<ByteBuffer>

Overrides:

messageComplete in class HttpChannel<ByteBuffer>