Class DestinationConnectionPool
java.lang.Object
org.glassfish.jersey.jdk.connector.internal.DestinationConnectionPool
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static interface
private class
(package private) static class
private static class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private final ConnectorConfiguration
private int
private final Set
<HttpConnection> private final DestinationConnectionPool.ConnectionStateListener
private final CookieManager
private final Queue
<HttpConnection> private final Queue
<DestinationConnectionPool.RequestRecord> private final Map
<HttpConnection, DestinationConnectionPool.RequestRecord> private final ScheduledExecutorService
-
Constructor Summary
ConstructorsConstructorDescriptionDestinationConnectionPool
(ConnectorConfiguration configuration, CookieManager cookieManager, ScheduledExecutorService scheduler) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
cleanClosedConnection
(HttpConnection connection) (package private) void
close()
getRequest
(HttpConnection connection) private void
handleIllegalStateTransition
(HttpConnection.State oldState, HttpConnection.State newState) private void
private void
processPendingRequests
(HttpConnection connection) private void
removeRequest
(HttpConnection connection) (package private) void
send
(HttpRequest httpRequest, CompletionHandler<HttpResponse> completionHandler) (package private) void
setConnectionCloseListener
(DestinationConnectionPool.ConnectionCloseListener connectionCloseListener)
-
Field Details
-
configuration
-
idleConnections
-
connections
-
pendingRequests
-
requestsInProgress
-
cookieManager
-
scheduler
-
connectionStateListener
-
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
-
processPendingRequests
-
processPendingRequests
private void processPendingRequests() -
close
void close() -
getRequest
-
removeRequest
-
cleanClosedConnection
-
handleIllegalStateTransition
private void handleIllegalStateTransition(HttpConnection.State oldState, HttpConnection.State newState) -
removeAllPendingWithError
-