HttpConnection

java.lang.Object
- org.eclipse.jetty.io.AbstractConnection
- - org.eclipse.jetty.server.HttpConnection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable, Connection, Connection.UpgradeFrom, WriteFlusher.Listener, HttpTransport
```
public class HttpConnection
extends AbstractConnection
implements java.lang.Runnable, HttpTransport, Connection.UpgradeFrom, WriteFlusher.Listener
```
A Connection that handles the HTTP protocol.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`private class`	`HttpConnection.AsyncReadCallback`
`private class`	`HttpConnection.BlockingReadCallback`
`private class`	`HttpConnection.Content`
`private class`	`HttpConnection.SendCallback`

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
`private static java.lang.ThreadLocal<HttpConnection>`	`__currentConnection`
`private HttpConnection.AsyncReadCallback`	`_asyncReadCallback`
`private HttpConnection.BlockingReadCallback`	`_blockingReadCallback`
`private ByteBufferPool`	`_bufferPool`
`private HttpChannelOverHttp`	`_channel`
`private java.nio.ByteBuffer`	`_chunk`
`private HttpConfiguration`	`_config`
`private Connector`	`_connector`
`private java.util.concurrent.atomic.AtomicInteger`	`_contentBufferReferences`
`private HttpGenerator`	`_generator`
`private HttpInput`	`_input`
`private HttpParser`	`_parser`
`private boolean`	`_recordHttpComplianceViolations`
`private java.nio.ByteBuffer`	`_requestBuffer`
`private HttpConnection.SendCallback`	`_sendCallback`
`private java.util.concurrent.atomic.LongAdder`	`bytesIn`
`private java.util.concurrent.atomic.LongAdder`	`bytesOut`
`private static boolean`	`CHUNK_BUFFER_DIRECT`
`static HttpField`	`CONNECTION_CLOSE`
`private static boolean`	`HEADER_BUFFER_DIRECT`
`private static Logger`	`LOG`
`private static boolean`	`REQUEST_BUFFER_DIRECT`
`static java.lang.String`	`UPGRADE_CONNECTION_ATTRIBUTE`

Constructor Summary

Constructors
Constructor and Description
`HttpConnection(HttpConfiguration config, Connector connector, EndPoint endPoint, HttpCompliance compliance, boolean recordComplianceViolations)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`abort(java.lang.Throwable failure)` Aborts this transport.
`void`	`asyncReadFillInterested()`
`void`	`blockingReadFailure(java.lang.Throwable e)`
`void`	`blockingReadFillInterested()`
`protected boolean`	`fillAndParseForContent()` Fill and parse data looking for content
`private int`	`fillRequestBuffer()`
`long`	`getBytesIn()`
`long`	`getBytesOut()`
`Connector`	`getConnector()`
`static HttpConnection`	`getCurrentConnection()` Get the current connection that this thread is dispatched to.
`HttpGenerator`	`getGenerator()`
`HttpChannel`	`getHttpChannel()`
`HttpConfiguration`	`getHttpConfiguration()`
`long`	`getMessagesIn()`
`long`	`getMessagesOut()`
`HttpParser`	`getParser()`
`java.nio.ByteBuffer`	`getRequestBuffer()`
`Server`	`getServer()`
`boolean`	`isOptimizedForDirectBuffers()` Is the underlying transport optimized for DirectBuffer usage
`boolean`	`isPushSupported()`
`boolean`	`isRecordHttpComplianceViolations()`
`boolean`	`isRequestBufferEmpty()`
`(package private) HttpInput.Content`	`newContent(java.nio.ByteBuffer c)`
`protected HttpChannelOverHttp`	`newHttpChannel()`
`protected HttpGenerator`	`newHttpGenerator()`
`protected HttpParser`	`newHttpParser(HttpCompliance compliance)`
`protected HttpParser.RequestHandler`	`newRequestHandler()`
`void`	`onClose()` Callback method invoked when this connection is closed.
`void`	`onCompleted()` Called to indicated the end of the current request/response cycle (which may be some time after the last content is sent).
`void`	`onFillable()` Callback method invoked when the endpoint is ready to be read.
`protected void`	`onFillInterestedFailed(java.lang.Throwable cause)` Callback method invoked when the endpoint failed to be ready to be read.
`void`	`onFlushed(long bytes)` Invoked when a `WriteFlusher` flushed bytes in a non-blocking way, as part of a - possibly larger - write.
`void`	`onOpen()` Callback method invoked when this connection is opened.
`protected boolean`	`onReadTimeout(java.lang.Throwable timeout)` Callback method invoked when the endpoint failed to be ready to be read after a timeout
`java.nio.ByteBuffer`	`onUpgradeFrom()` Takes the input buffer from the connection on upgrade.
`private boolean`	`parseRequestBuffer()`
`void`	`push(MetaData.Request request)`
`(package private) void`	`releaseRequestBuffer()`
`void`	`run()`
`void`	`send(MetaData.Response info, boolean head, java.nio.ByteBuffer content, boolean lastContent, Callback callback)` Asynchronous call to send a response (or part) over the transport
`protected static HttpConnection`	`setCurrentConnection(HttpConnection connection)`
`java.lang.String`	`toConnectionString()`

Methods inherited from class org.eclipse.jetty.io.AbstractConnection
addListener, close, failedCallback, fillInterested, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, isFillInterested, onIdleExpired, removeListener, setInputBufferSize, toString, tryFillInterested, tryFillInterested

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - LOG
```
private static final Logger LOG
```
  - CONNECTION_CLOSE
```
public static final HttpField CONNECTION_CLOSE
```
  - UPGRADE_CONNECTION_ATTRIBUTE
```
public static final java.lang.String UPGRADE_CONNECTION_ATTRIBUTE
```
    See Also:
    
    Constant Field Values
  - REQUEST_BUFFER_DIRECT
```
private static final boolean REQUEST_BUFFER_DIRECT
```
    See Also:
    
    Constant Field Values
  - HEADER_BUFFER_DIRECT
```
private static final boolean HEADER_BUFFER_DIRECT
```
    See Also:
    
    Constant Field Values
  - CHUNK_BUFFER_DIRECT
```
private static final boolean CHUNK_BUFFER_DIRECT
```
    See Also:
    
    Constant Field Values
  - __currentConnection
```
private static final java.lang.ThreadLocal<HttpConnection> __currentConnection
```
  - _config
```
private final HttpConfiguration _config
```
  - _connector
```
private final Connector _connector
```
  - _bufferPool
```
private final ByteBufferPool _bufferPool
```
  - _input
```
private final HttpInput _input
```
  - _generator
```
private final HttpGenerator _generator
```
  - _channel
```
private final HttpChannelOverHttp _channel
```
  - _parser
```
private final HttpParser _parser
```
  - _contentBufferReferences
```
private final java.util.concurrent.atomic.AtomicInteger _contentBufferReferences
```
  - _requestBuffer
```
private volatile java.nio.ByteBuffer _requestBuffer
```
  - _chunk
```
private volatile java.nio.ByteBuffer _chunk
```
  - _blockingReadCallback
```
private final HttpConnection.BlockingReadCallback _blockingReadCallback
```
  - _asyncReadCallback
```
private final HttpConnection.AsyncReadCallback _asyncReadCallback
```
  - _sendCallback
```
private final HttpConnection.SendCallback _sendCallback
```
  - _recordHttpComplianceViolations
```
private final boolean _recordHttpComplianceViolations
```
  - bytesIn
```
private final java.util.concurrent.atomic.LongAdder bytesIn
```
  - bytesOut
```
private final java.util.concurrent.atomic.LongAdder bytesOut
```
- Constructor Detail
  - HttpConnection
```
public HttpConnection(HttpConfiguration config,
                      Connector connector,
                      EndPoint endPoint,
                      HttpCompliance compliance,
                      boolean recordComplianceViolations)
```
- 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()
```
  - isRecordHttpComplianceViolations
```
public boolean isRecordHttpComplianceViolations()
```
  - newHttpGenerator
```
protected HttpGenerator newHttpGenerator()
```
  - newHttpChannel
```
protected HttpChannelOverHttp newHttpChannel()
```
  - newHttpParser
```
protected HttpParser newHttpParser(HttpCompliance compliance)
```
  - newRequestHandler
```
protected HttpParser.RequestHandler newRequestHandler()
```
  - getServer
```
public Server getServer()
```
  - getConnector
```
public Connector getConnector()
```
  - getHttpChannel
```
public HttpChannel getHttpChannel()
```
  - getParser
```
public HttpParser getParser()
```
  - getGenerator
```
public HttpGenerator getGenerator()
```
  - isOptimizedForDirectBuffers
```
public boolean isOptimizedForDirectBuffers()
```
    Description copied from interface: HttpTransport
    
    Is the underlying transport optimized for DirectBuffer usage
    
    Specified by:
    
    isOptimizedForDirectBuffers in interface HttpTransport
    
    Returns:
    
    True if direct buffers can be used optimally.
  - getMessagesIn
```
public long getMessagesIn()
```
    Specified by:
    
    getMessagesIn in interface Connection
    
    Overrides:
    
    getMessagesIn in class AbstractConnection
  - getMessagesOut
```
public long getMessagesOut()
```
    Specified by:
    
    getMessagesOut in interface Connection
    
    Overrides:
    
    getMessagesOut in class AbstractConnection
  - onUpgradeFrom
```
public java.nio.ByteBuffer onUpgradeFrom()
```
    Description copied from interface: Connection.UpgradeFrom
    
    Takes 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.
  - onFlushed
```
public void onFlushed(long bytes)
               throws java.io.IOException
```
    Description copied from interface: WriteFlusher.Listener
    
    Invoked when a WriteFlusher flushed bytes in a non-blocking way, as part of a - possibly larger - write.
    
    This method may be invoked multiple times, for example when writing a large buffer: a first flush of bytes, then the connection became TCP congested, and a subsequent flush of bytes when the connection became writable again.
    
    This method is never invoked concurrently, but may be invoked by different threads, so implementations may not rely on thread-local variables.
    
    Implementations may throw an IOException to signal that the write should fail, for example if the implementation enforces a minimum data rate.
    
    Specified by:
    
    onFlushed in interface WriteFlusher.Listener
    
    Parameters:
    
    bytes - the number of bytes flushed
    
    Throws:
    
    java.io.IOException - if the write should fail
  - releaseRequestBuffer
```
void releaseRequestBuffer()
```
  - getRequestBuffer
```
public java.nio.ByteBuffer getRequestBuffer()
```
  - isRequestBufferEmpty
```
public boolean isRequestBufferEmpty()
```
  - onFillable
```
public void onFillable()
```
    Description copied from class: AbstractConnection
    
    Callback method invoked when the endpoint is ready to be read.
    
    Specified by:
    
    onFillable in class AbstractConnection
    
    See Also:
    
    AbstractConnection.fillInterested()
  - fillAndParseForContent
```
protected boolean fillAndParseForContent()
```
    Fill and parse data looking for content
    
    Returns:
    
    true if an HttpParser.RequestHandler method was called and it returned true;
  - fillRequestBuffer
```
private int fillRequestBuffer()
```
  - parseRequestBuffer
```
private boolean parseRequestBuffer()
```
  - onCompleted
```
public void onCompleted()
```
    Description copied from interface: HttpTransport
    
    Called to indicated the end of the current request/response cycle (which may be some time after the last content is sent).
    
    Specified by:
    
    onCompleted in interface HttpTransport
  - onReadTimeout
```
protected boolean onReadTimeout(java.lang.Throwable timeout)
```
    Description copied from class: AbstractConnection
    
    Callback method invoked when the endpoint failed to be ready to be read after a timeout
    
    Overrides:
    
    onReadTimeout in class AbstractConnection
    
    Parameters:
    
    timeout - the cause of the read timeout
    
    Returns:
    
    true to signal that the endpoint must be closed, false to keep the endpoint open
  - onFillInterestedFailed
```
protected void onFillInterestedFailed(java.lang.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()
```
    Description copied from interface: Connection
    
    Callback method invoked when this connection is opened.
    
    Creators of the connection implementation are responsible for calling this method.
    
    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 java.lang.Runnable
  - send
```
public void send(MetaData.Response info,
                 boolean head,
                 java.nio.ByteBuffer content,
                 boolean lastContent,
                 Callback callback)
```
    Description copied from interface: HttpTransport
    
    Asynchronous call to send a response (or part) over the transport
    
    Specified by:
    
    send in interface HttpTransport
    
    Parameters:
    
    info - The header info to send, or null if just sending more data. The first call to send for a response must have a non null info.
    
    head - True if the response if for a HEAD request (and the data should not be sent).
    
    content - A buffer of content to be sent.
    
    lastContent - True if the content is the last content for the current response.
    
    callback - The Callback instance that success or failure of the send is notified on
  - newContent
```
HttpInput.Content newContent(java.nio.ByteBuffer c)
```
  - abort
```
public void abort(java.lang.Throwable failure)
```
    Description copied from interface: HttpTransport
    
    Aborts this transport.
    This method should terminate the transport in a way that can indicate an abnormal response to the client, for example by abruptly close the connection.
    This method is called when an error response needs to be sent, but the response is already committed, or when a write failure is detected. If abort is called, HttpTransport.onCompleted() is not called
    
    Specified by:
    
    abort in interface HttpTransport
    
    Parameters:
    
    failure - the failure that caused the abort.
  - isPushSupported
```
public boolean isPushSupported()
```
    Specified by:
    
    isPushSupported in interface HttpTransport
    
    Returns:
    
    true if responses can be pushed over this transport
  - push
```
public void push(MetaData.Request request)
```
    Specified by:
    
    push in interface HttpTransport
    
    Parameters:
    
    request - A request to use as the basis for generating a pushed response.
  - asyncReadFillInterested
```
public void asyncReadFillInterested()
```
  - blockingReadFillInterested
```
public void blockingReadFillInterested()
```
  - blockingReadFailure
```
public void blockingReadFailure(java.lang.Throwable e)
```
  - getBytesIn
```
public long getBytesIn()
```
    Specified by:
    
    getBytesIn in interface Connection
    
    Overrides:
    
    getBytesIn in class AbstractConnection
  - getBytesOut
```
public long getBytesOut()
```
    Specified by:
    
    getBytesOut in interface Connection
    
    Overrides:
    
    getBytesOut in class AbstractConnection
  - toConnectionString
```
public java.lang.String toConnectionString()
```
    Overrides:
    
    toConnectionString in class AbstractConnection

Class HttpConnection

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

LOG

CONNECTION_CLOSE

UPGRADE_CONNECTION_ATTRIBUTE

REQUEST_BUFFER_DIRECT

HEADER_BUFFER_DIRECT

CHUNK_BUFFER_DIRECT

__currentConnection

_config

_connector

_bufferPool

_input

_generator

_channel

_parser

_contentBufferReferences

_requestBuffer

_chunk

_blockingReadCallback

_asyncReadCallback

_sendCallback

_recordHttpComplianceViolations

bytesIn

bytesOut

Constructor Detail

HttpConnection

Method Detail

getCurrentConnection

setCurrentConnection

getHttpConfiguration

isRecordHttpComplianceViolations

newHttpGenerator

newHttpChannel

newHttpParser

newRequestHandler

getServer

getConnector

getHttpChannel

getParser

getGenerator

isOptimizedForDirectBuffers

getMessagesIn

getMessagesOut

onUpgradeFrom

onFlushed

releaseRequestBuffer

getRequestBuffer

isRequestBufferEmpty

onFillable

fillAndParseForContent

fillRequestBuffer

parseRequestBuffer

onCompleted

onReadTimeout

onFillInterestedFailed

onOpen

onClose

run

send

newContent

abort

isPushSupported

push

asyncReadFillInterested

blockingReadFillInterested

blockingReadFailure

getBytesIn

getBytesOut

toConnectionString