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

Class DestinationConnectionPool

java.lang.Object

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

class DestinationConnectionPool
extends java.lang.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 ConnectorConfiguration	configuration
private DestinationConnectionPool.ConnectionCloseListener	connectionCloseListener
private int	connectionCounter
private java.util.Set<HttpConnection>	connections
private DestinationConnectionPool.ConnectionStateListener	connectionStateListener
private java.net.CookieManager	cookieManager
private java.util.Queue<HttpConnection>	idleConnections
private java.util.Queue<DestinationConnectionPool.RequestRecord>	pendingRequests
private java.util.Map<HttpConnection,DestinationConnectionPool.RequestRecord>	requestsInProgress
private java.util.concurrent.ScheduledExecutorService	scheduler

Constructor Summary

Constructors

Constructor	Description
DestinationConnectionPool(ConnectorConfiguration configuration, java.net.CookieManager cookieManager, java.util.concurrent.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(java.lang.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 java.lang.Object

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

Field Detail

configuration

private final ConnectorConfiguration configuration

idleConnections

private final java.util.Queue<HttpConnection> idleConnections

connections

private final java.util.Set<HttpConnection> connections

pendingRequests

private final java.util.Queue<DestinationConnectionPool.RequestRecord> pendingRequests

requestsInProgress

private final java.util.Map<HttpConnection,DestinationConnectionPool.RequestRecord> requestsInProgress

cookieManager

private final java.net.CookieManager cookieManager

scheduler

private final java.util.concurrent.ScheduledExecutorService scheduler

connectionStateListener

private final DestinationConnectionPool.ConnectionStateListener connectionStateListener

connectionCloseListener

private volatile DestinationConnectionPool.ConnectionCloseListener connectionCloseListener

connectionCounter

private int connectionCounter

closed

private boolean closed

Constructor Detail

DestinationConnectionPool

DestinationConnectionPool(ConnectorConfiguration configuration,
                          java.net.CookieManager cookieManager,
                          java.util.concurrent.ScheduledExecutorService scheduler)

Method Detail

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(java.lang.Throwable t)