org.eclipse.jetty.server

Class HttpConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.server.HttpConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, Connection, Connection.UpgradeFrom, HttpTransport

Direct Known Subclasses:

ProxyHTTPSPDYConnection

public class HttpConnection
extends AbstractConnection
implements Runnable, HttpTransport, Connection.UpgradeFrom

A Connection that handles the HTTP protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	HttpConnection.HttpChannelOverHttp

Nested classes/interfaces inherited from class org.eclipse.jetty.io.AbstractConnection

AbstractConnection.FillingInterestedCallback, AbstractConnection.NestedState, AbstractConnection.State

Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Field Summary

Fields

Modifier and Type	Field and Description
static String	UPGRADE_CONNECTION_ATTRIBUTE

Fields inherited from class org.eclipse.jetty.io.AbstractConnection

EXECUTE_ONFILLABLE, FILL_INTERESTED, FILLING, FILLING_FILL_INTERESTED, IDLE, REFILLING

Constructor Summary

Constructors

Constructor and Description
HttpConnection(HttpConfiguration config, Connector connector, EndPoint endPoint)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort() Abort transport.
void	completed()
Connector	getConnector()
static HttpConnection	getCurrentConnection() Get the current connection that this thread is dispatched to.
HttpChannel<?>	getHttpChannel()
HttpConfiguration	getHttpConfiguration()
int	getMessagesIn()
int	getMessagesOut()
HttpParser	getParser()
ByteBuffer	getRequestBuffer()
Server	getServer()
protected HttpConnection.HttpChannelOverHttp	newHttpChannel(HttpInput<ByteBuffer> httpInput)
protected HttpGenerator	newHttpGenerator()
protected HttpInput<ByteBuffer>	newHttpInput()
protected HttpParser	newHttpParser()
protected HttpParser.RequestHandler<ByteBuffer>	newRequestHandler()
void	onClose() Callback method invoked when this Connection is closed.
void	onFillable() Parses and handles HTTP messages.
protected void	onFillInterestedFailed(Throwable cause) Callback method invoked when the endpoint failed to be ready to be read.
void	onOpen()
ByteBuffer	onUpgradeFrom() Take the input buffer from the connection on upgrade.
protected void	parseContent() Fill and parse data looking for content
void	run()
void	send(ByteBuffer content, boolean lastContent, Callback callback)
void	send(HttpGenerator.ResponseInfo info, ByteBuffer content, boolean lastContent, Callback callback)
protected static HttpConnection	setCurrentConnection(HttpConnection connection)
String	toString()

Methods inherited from class org.eclipse.jetty.io.AbstractConnection

addListener, close, failedCallback, fillInterested, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, next, onReadTimeout, setInputBufferSize

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.io.Connection

addListener, close, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint

Field Detail

UPGRADE_CONNECTION_ATTRIBUTE

public static final String UPGRADE_CONNECTION_ATTRIBUTE

See Also:

Constant Field Values

Constructor Detail

HttpConnection

public HttpConnection(HttpConfiguration config,
              Connector connector,
              EndPoint endPoint)

Method Detail

getCurrentConnection

public static HttpConnection getCurrentConnection()

Get the current connection that this thread is dispatched to. Note that a thread may be processing a request asynchronously and thus not be dispatched to the connection.

Returns:

the current HttpConnection or null

See Also:

for a more general way to access the HttpConnection

setCurrentConnection

protected static HttpConnection setCurrentConnection(HttpConnection connection)

getHttpConfiguration

public HttpConfiguration getHttpConfiguration()

newHttpGenerator

protected HttpGenerator newHttpGenerator()

newHttpInput

protected HttpInput<ByteBuffer> newHttpInput()

newHttpChannel

protected HttpConnection.HttpChannelOverHttp newHttpChannel(HttpInput<ByteBuffer> httpInput)

newHttpParser

protected HttpParser newHttpParser()

newRequestHandler

protected HttpParser.RequestHandler<ByteBuffer> newRequestHandler()

getServer

public Server getServer()

getConnector

public Connector getConnector()

getHttpChannel

public HttpChannel<?> getHttpChannel()

getParser

public HttpParser getParser()

getMessagesIn

public int getMessagesIn()

Specified by:

getMessagesIn in interface Connection

Overrides:

getMessagesIn in class AbstractConnection

getMessagesOut

public int getMessagesOut()

Specified by:

getMessagesOut in interface Connection

Overrides:

getMessagesOut in class AbstractConnection

onUpgradeFrom

public ByteBuffer onUpgradeFrom()

Description copied from interface: Connection.UpgradeFrom

Take the input buffer from the connection on upgrade.

This method is used to take any unconsumed input from a connection during an upgrade.

Specified by:

onUpgradeFrom in interface Connection.UpgradeFrom

Returns:

A buffer of unconsumed input. The caller must return the buffer to the bufferpool when consumed and this connection must not.

getRequestBuffer

public ByteBuffer getRequestBuffer()

onFillable

public void onFillable()

Parses and handles HTTP messages.

This method is called when this Connection is ready to read bytes from the EndPoint. However, it can also be called if there is unconsumed data in the _requestBuffer, as a result of resuming a suspended request when there is a pipelined request already read into the buffer.

This method fills bytes and parses them until either: EOF is filled; 0 bytes are filled; the HttpChannel finishes handling; or the connection has changed.

Specified by:

onFillable in class AbstractConnection

See Also:

AbstractConnection.fillInterested()

parseContent

protected void parseContent()
                     throws IOException

Fill and parse data looking for content

Throws:

IOException

completed

public void completed()

Specified by:

completed in interface HttpTransport

onFillInterestedFailed

protected void onFillInterestedFailed(Throwable cause)

Description copied from class: AbstractConnection

Callback method invoked when the endpoint failed to be ready to be read.

Overrides:

onFillInterestedFailed in class AbstractConnection

Parameters:

cause - the exception that caused the failure

onOpen

public void onOpen()

Specified by:

onOpen in interface Connection

Overrides:

onOpen in class AbstractConnection

onClose

public void onClose()

Description copied from interface: Connection

Callback method invoked when this Connection is closed.

Creators of the connection implementation are responsible for calling this method.

Specified by:

onClose in interface Connection

Overrides:

onClose in class AbstractConnection

run

public void run()

Specified by:

run in interface Runnable

send

public void send(HttpGenerator.ResponseInfo info,
        ByteBuffer content,
        boolean lastContent,
        Callback callback)

Specified by:

send in interface HttpTransport

send

public void send(ByteBuffer content,
        boolean lastContent,
        Callback callback)

Specified by:

send in interface HttpTransport

abort

public void abort()

Description copied from interface: HttpTransport

Abort transport. This is called when an error response needs to be sent, but the response is already committed. Abort to should terminate the transport in a way that can indicate abnormal response to the client.

Specified by:

abort in interface HttpTransport

toString

public String toString()

Overrides:

toString in class AbstractConnection