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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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)
-
-