Class DestinationConnectionPool

java.lang.Object

org.glassfish.jersey.jdk.connector.internal.DestinationConnectionPool

class DestinationConnectionPool
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	DestinationConnectionPool.ConnectionCloseListener
private class	DestinationConnectionPool.ConnectionStateListener
(package private) static class	DestinationConnectionPool.DestinationKey
private static class	DestinationConnectionPool.RequestRecord

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private final ConnectorConfiguration	configuration
private DestinationConnectionPool.ConnectionCloseListener	connectionCloseListener
private int	connectionCounter
private final Set<HttpConnection>	connections
private final DestinationConnectionPool.ConnectionStateListener	connectionStateListener
private final CookieManager	cookieManager
private final Queue<HttpConnection>	idleConnections
private final Queue<DestinationConnectionPool.RequestRecord>	pendingRequests
private final Map<HttpConnection, DestinationConnectionPool.RequestRecord>	requestsInProgress
private final ScheduledExecutorService	scheduler

Constructor Summary

Constructors

Constructor	Description
DestinationConnectionPool(ConnectorConfiguration configuration, CookieManager cookieManager, ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method	Description
private void	cleanClosedConnection(HttpConnection connection)
(package private) void	close()
private DestinationConnectionPool.RequestRecord	getRequest(HttpConnection connection)
private void	handleIllegalStateTransition(HttpConnection.State oldState, HttpConnection.State newState)
private void	processPendingRequests()
private void	processPendingRequests(HttpConnection connection)
private void	removeAllPendingWithError(Throwable t)
private DestinationConnectionPool.RequestRecord	removeRequest(HttpConnection connection)
(package private) void	send(HttpRequest httpRequest, CompletionHandler<HttpResponse> completionHandler)
(package private) void	setConnectionCloseListener(DestinationConnectionPool.ConnectionCloseListener connectionCloseListener)

Methods inherited from class Object

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

Field Details

configuration

private final ConnectorConfiguration configuration

idleConnections

private final Queue<HttpConnection> idleConnections

connections

private final Set<HttpConnection> connections

pendingRequests

private final Queue<DestinationConnectionPool.RequestRecord> pendingRequests

requestsInProgress

private final Map<HttpConnection, DestinationConnectionPool.RequestRecord> requestsInProgress

cookieManager

private final CookieManager cookieManager

scheduler

private final ScheduledExecutorService scheduler

connectionStateListener

private final DestinationConnectionPool.ConnectionStateListener connectionStateListener

connectionCloseListener

private volatile DestinationConnectionPool.ConnectionCloseListener connectionCloseListener

connectionCounter

private int connectionCounter

closed

private boolean closed

Constructor Details

DestinationConnectionPool

DestinationConnectionPool(ConnectorConfiguration configuration,
 CookieManager cookieManager,
 ScheduledExecutorService scheduler)

Method Details

setConnectionCloseListener

void setConnectionCloseListener(DestinationConnectionPool.ConnectionCloseListener connectionCloseListener)

send

void send(HttpRequest httpRequest,
 CompletionHandler<HttpResponse> completionHandler)

processPendingRequests

private void processPendingRequests(HttpConnection connection)

processPendingRequests

private void processPendingRequests()

close

void close()

getRequest

private DestinationConnectionPool.RequestRecord getRequest(HttpConnection connection)

removeRequest

private DestinationConnectionPool.RequestRecord removeRequest(HttpConnection connection)

cleanClosedConnection

private void cleanClosedConnection(HttpConnection connection)

handleIllegalStateTransition

private void handleIllegalStateTransition(HttpConnection.State oldState,
 HttpConnection.State newState)

removeAllPendingWithError

private void removeAllPendingWithError(Throwable t)