Package org.glassfish.jersey.jdk.connector.internal

Class HttpConnection

java.lang.Object

org.glassfish.jersey.jdk.connector.internal.HttpConnection

class HttpConnection
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	HttpConnection.ConnectionFilter
(package private) static enum	HttpConnection.State
(package private) static interface	HttpConnection.StateChangeListener

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectorConfiguration	configuration
private Future<?>	connectTimeout
private final CookieManager	cookieManager
private Throwable	error
private final Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>	filterChain
private HttpRequest	httpRequest
private HttpResponse	httResponse
private Future<?>	idleTimeout
private static final int	INPUT_BUFFER_SIZE	Input buffer that is used by TransportFilter when SSL is not turned on.
private static final Logger	LOGGER
private boolean	persistentConnection
private Future<?>	responseTimeout
private final ScheduledExecutorService	scheduler
private static final int	SSL_INPUT_BUFFER_SIZE	Input buffer that is used by TransportFilter when SSL is turned on.
(package private) HttpConnection.State	state
private final HttpConnection.StateChangeListener	stateListener
private final URI	uri

Constructor Summary

Constructors

Constructor	Description
HttpConnection(URI uri, CookieManager cookieManager, ConnectorConfiguration configuration, ScheduledExecutorService scheduler, HttpConnection.StateChangeListener stateListener)

Method Summary

Modifier and Type	Method	Description
private void	addRequestHeaders()
private void	cancelAllTimeouts()
private void	cancelConnectTimeout()
private void	cancelIdleTimeout()
private void	cancelResponseTimeout()
private void	changeState(HttpConnection.State newState)
private void	changeStateToIdle()
(package private) void	close()
(package private) void	connect()
protected Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>	createFilterChain(URI uri, ConnectorConfiguration configuration)
(package private) Throwable	getError()
(package private) HttpResponse	getHttResponse()
private void	handleError(Throwable t)
private void	handleHeaderSent()
private void	handleResponseRead()
private void	processResponseHeaders(HttpResponse response)
private void	scheduleConnectTimeout()
private void	scheduleIdleTimeout()
private void	scheduleResponseTimeout()
(package private) void	send(HttpRequest httpRequest)

Methods inherited from class java.lang.Object

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

Field Details

SSL_INPUT_BUFFER_SIZE

private static final int SSL_INPUT_BUFFER_SIZE

Input buffer that is used by TransportFilter when SSL is turned on. The size cannot be smaller than a maximal size of a SSL packet, which is 16kB for payload + header, because SslFilter does not have its own buffer for buffering incoming data and therefore the entire SSL packet must fit into SslFilter input buffer.

See Also:

• Constant Field Values

INPUT_BUFFER_SIZE

private static final int INPUT_BUFFER_SIZE

Input buffer that is used by TransportFilter when SSL is not turned on.

See Also:

• Constant Field Values

LOGGER

private static final Logger LOGGER

filterChain

private final Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse> filterChain

cookieManager

private final CookieManager cookieManager

uri

private final URI uri

stateListener

private final HttpConnection.StateChangeListener stateListener

scheduler

private final ScheduledExecutorService scheduler

configuration

private final ConnectorConfiguration configuration

httpRequest

private HttpRequest httpRequest

httResponse

private HttpResponse httResponse

error

private Throwable error

state

volatile HttpConnection.State state

persistentConnection

private boolean persistentConnection

responseTimeout

private Future<?> responseTimeout

idleTimeout

private Future<?> idleTimeout

connectTimeout

private Future<?> connectTimeout

Constructor Details

HttpConnection

HttpConnection(URI uri,
 CookieManager cookieManager,
 ConnectorConfiguration configuration,
 ScheduledExecutorService scheduler,
 HttpConnection.StateChangeListener stateListener)

Method Details

connect

void connect()

send

void send(HttpRequest httpRequest)

close

void close()

handleHeaderSent

private void handleHeaderSent()

addRequestHeaders

private void addRequestHeaders()

processResponseHeaders

private void processResponseHeaders(HttpResponse response)
                             throws IOException

Throws:

IOException

createFilterChain

protected Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse> createFilterChain(URI uri,
 ConnectorConfiguration configuration)

changeState

private void changeState(HttpConnection.State newState)

scheduleResponseTimeout

private void scheduleResponseTimeout()

cancelResponseTimeout

private void cancelResponseTimeout()

scheduleConnectTimeout

private void scheduleConnectTimeout()

cancelConnectTimeout

private void cancelConnectTimeout()

scheduleIdleTimeout

private void scheduleIdleTimeout()

cancelIdleTimeout

private void cancelIdleTimeout()

cancelAllTimeouts

private void cancelAllTimeouts()

handleError

private void handleError(Throwable t)

changeStateToIdle

private void changeStateToIdle()

getError

Throwable getError()

getHttResponse

HttpResponse getHttResponse()

handleResponseRead

private void handleResponseRead()