Modifier and Type	Class and Description
pack-priv static class	ConnectionPool.CacheKey Entries in connection pool are keyed by destination address and/or proxy address: case 1: plain TCP not via proxy (destination IP only) case 2: plain TCP via proxy (proxy only) case 3: SSL not via proxy (destination IP+hostname only) case 4: SSL over tunnel (destination IP+hostname and proxy)
private class	ConnectionPool.CleanupTrigger An object that subscribes to the flow while the connection is in the pool.
pack-priv static class	ConnectionPool.ExpiryEntry
private static class	ConnectionPool.ExpiryList Manages a LinkedList of sorted ExpiryEntry.

Modifier and Type	Field and Description
private final String	dbgTag
pack-priv final Logger	debug
private final ConnectionPool.ExpiryList	expiryList
pack-priv static final long	MAX_POOL_SIZE
private final HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>>	plainPool
private final HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>>	sslPool
private final ReentrantLock	stateLock
pack-priv volatile boolean	stopped
private final TimeLine	timeSource

Access	Constructor and Description
pack-priv	ConnectionPool(long clientId)
pack-priv	ConnectionPool(long clientId, TimeLine timeSource)
private	ConnectionPool(String tag, TimeLine timeSource) There should be one of these per HttpClient.

Modifier and Type	Method and Description
pack-priv static ConnectionPool.CacheKey	cacheKey(boolean secure, InetSocketAddress destination, InetSocketAddress proxy)
pack-priv void	cleanup(HttpConnection c, long pendingData, Throwable error)
private void	close(HttpConnection c)
pack-priv boolean	contains(HttpConnection c)
private boolean	contains0(HttpConnection c)
pack-priv final String	dbgString()
private HttpConnection	findConnection(ConnectionPool.CacheKey key, HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> pool)
pack-priv HttpConnection	getConnection(boolean secure, InetSocketAddress addr, InetSocketAddress proxy)
private HttpConnection	getConnection0(boolean secure, InetSocketAddress addr, InetSocketAddress proxy)
pack-priv long	Returns: the delay in milliseconds in which the next connection will expire. purgeExpiredConnectionsAndReturnNextDeadline() Purge expired connection and return the number of milliseconds in which the next connection is scheduled to expire.
pack-priv long	purgeExpiredConnectionsAndReturnNextDeadline(Deadline now)
private void	putConnection(HttpConnection c, HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> pool)
private ConnectionPool.CleanupTrigger	registerCleanupTrigger(HttpConnection conn)
private boolean	removeFromPool(HttpConnection c, HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> pool)
private boolean	removeFromPool(HttpConnection c)
pack-priv void	returnToPool(HttpConnection conn) Returns the connection to the pool.
pack-priv void	returnToPool(HttpConnection conn, Deadline now, long keepAlive)
pack-priv void	start()
pack-priv void	stop()

dbgTag	back to summary
private final String dbgTag

debug	back to summary
pack-priv final Logger debug

expiryList	back to summary
private final ConnectionPool.ExpiryList expiryList

MAX_POOL_SIZE	back to summary
pack-priv static final long MAX_POOL_SIZE

plainPool	back to summary
private final HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> plainPool

sslPool	back to summary
private final HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> sslPool

stateLock	back to summary
private final ReentrantLock stateLock

stopped	back to summary
pack-priv volatile boolean stopped

timeSource	back to summary
private final TimeLine timeSource

ConnectionPool	back to summary
pack-priv ConnectionPool(long clientId)

ConnectionPool	back to summary
pack-priv ConnectionPool(long clientId, TimeLine timeSource)

ConnectionPool	back to summary
private ConnectionPool(String tag, TimeLine timeSource) There should be one of these per HttpClient.

Method Detail

cacheKey	back to summary
pack-priv static ConnectionPool.CacheKey cacheKey(boolean secure, InetSocketAddress destination, InetSocketAddress proxy)

cleanup	back to summary
pack-priv void cleanup(HttpConnection c, long pendingData, Throwable error)

close	back to summary
private void close(HttpConnection c)

contains	back to summary
pack-priv boolean contains(HttpConnection c)

contains0	back to summary
private boolean contains0(HttpConnection c)

dbgString	back to summary
pack-priv final String dbgString()

findConnection	back to summary
private HttpConnection findConnection(ConnectionPool.CacheKey key, HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> pool)

getConnection	back to summary
pack-priv HttpConnection getConnection(boolean secure, InetSocketAddress addr, InetSocketAddress proxy)

getConnection0	back to summary
private HttpConnection getConnection0(boolean secure, InetSocketAddress addr, InetSocketAddress proxy)

purgeExpiredConnectionsAndReturnNextDeadline	back to summary
pack-priv long purgeExpiredConnectionsAndReturnNextDeadline() Purge expired connection and return the number of milliseconds in which the next connection is scheduled to expire. If no connections are scheduled to be purged return 0. Returns:long the delay in milliseconds in which the next connection will expire.

purgeExpiredConnectionsAndReturnNextDeadline

back to summary

pack-priv long purgeExpiredConnectionsAndReturnNextDeadline()

Purge expired connection and return the number of milliseconds in which the next connection is scheduled to expire. If no connections are scheduled to be purged return 0.

Returns:long: the delay in milliseconds in which the next connection will expire.

purgeExpiredConnectionsAndReturnNextDeadline	back to summary
pack-priv long purgeExpiredConnectionsAndReturnNextDeadline(Deadline now)

putConnection	back to summary
private void putConnection(HttpConnection c, HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> pool)

registerCleanupTrigger	back to summary
private ConnectionPool.CleanupTrigger registerCleanupTrigger(HttpConnection conn)

removeFromPool	back to summary
private boolean removeFromPool(HttpConnection c, HashMap<ConnectionPool.CacheKey, LinkedList<HttpConnection>> pool)

removeFromPool	back to summary
private boolean removeFromPool(HttpConnection c)

returnToPool	back to summary
pack-priv void returnToPool(HttpConnection conn) Returns the connection to the pool.

returnToPool	back to summary
pack-priv void returnToPool(HttpConnection conn, Deadline now, long keepAlive)

start	back to summary
pack-priv void start()

stop	back to summary
pack-priv void stop()

jdk.internal.net.http back to summary

pack-priv Class ConnectionPool.CacheKey

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.ConnectionPool.CacheKey

Entries in connection pool are keyed by destination address and/or proxy address: case 1: plain TCP not via proxy (destination IP only) case 2: plain TCP via proxy (proxy only) case 3: SSL not via proxy (destination IP+hostname only) case 4: SSL over tunnel (destination IP+hostname and proxy)

Field Summary

Modifier and Type	Field and Description
pack-priv final InetSocketAddress	destination
pack-priv final InetSocketAddress	proxy
pack-priv final boolean	secure

Constructor Summary

Access	Constructor and Description
private	CacheKey(boolean secure, InetSocketAddress destination, InetSocketAddress proxy)

Method Summary

Modifier and Type	Method and Description
public boolean	equals(Object obj) Overrides java.lang.Object.equals. Indicates whether some other object is "equal to" this one.
public int	hashCode() Overrides java.lang.Object.hashCode. Returns a hash code value for this object.

Inherited from java.lang.Object:: clone finalize getClass notify notifyAll toString wait wait wait

Field Detail

destination	back to summary
pack-priv final InetSocketAddress destination

proxy	back to summary
pack-priv final InetSocketAddress proxy

secure	back to summary
pack-priv final boolean secure

Constructor Detail

CacheKey	back to summary
private CacheKey(boolean secure, InetSocketAddress destination, InetSocketAddress proxy)

Method Detail

equals back to summary

equals	back to summary
public boolean equals(Object obj) Overrides java.lang.Object.equals. Doc from java.lang.Object.equals. Indicates whether some other object is "equal to" this one. The `equals` method implements an equivalence relation on non-null object references: It is reflexive: for any non-null reference value `x`, `x.equals(x)` should return `true`. It is symmetric: for any non-null reference values `x` and `y`, `x.equals(y)` should return `true` if and only if `y.equals(x)` returns `true`. It is transitive: for any non-null reference values `x`, `y`, and `z`, if `x.equals(y)` returns `true` and `y.equals(z)` returns `true`, then `x.equals(z)` should return `true`. It is consistent: for any non-null reference values `x` and `y`, multiple invocations of `x.equals(y)` consistently return `true` or consistently return `false`, provided no information used in `equals` comparisons on the objects is modified. For any non-null reference value `x`, `x.equals(null)` should return `false`. An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes. Annotations @Override

public boolean equals(Object obj)

Overrides java.lang.Object.equals.

Doc from java.lang.Object.equals.

Indicates whether some other object is "equal to" this one.

The equals method implements an equivalence relation on non-null object references:

It is reflexive: for any non-null reference value x, x.equals(x) should return true.
It is symmetric: for any non-null reference values x and y, x.equals(y) should return true if and only if y.equals(x) returns true.
It is transitive: for any non-null reference values x, y, and z, if x.equals(y) returns true and y.equals(z) returns true, then x.equals(z) should return true.
It is consistent: for any non-null reference values x and y, multiple invocations of x.equals(y) consistently return true or consistently return false, provided no information used in equals comparisons on the objects is modified.
For any non-null reference value x, x.equals(null) should return false.

An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes.

Annotations

@Override

hashCode back to summary

hashCode	back to summary
public int hashCode() Overrides java.lang.Object.hashCode. Doc from java.lang.Object.hashCode. Returns a hash code value for this object. This method is supported for the benefit of hash tables such as those provided by `java.util.HashMap`. The general contract of `hashCode` is: Whenever it is invoked on the same object more than once during an execution of a Java application, the `hashCode` method must consistently return the same integer, provided no information used in `equals` comparisons on the object is modified. This integer need not remain consistent from one execution of an application to another execution of the same application. If two objects are equal according to the `equals` method, then calling the `hashCode` method on each of the two objects must produce the same integer result. It is not required that if two objects are unequal according to the `equals` method, then calling the `hashCode` method on each of the two objects must produce distinct integer results. However, the programmer should be aware that producing distinct integer results for unequal objects may improve the performance of hash tables. Annotations @Override

public int hashCode()

Overrides java.lang.Object.hashCode.

Doc from java.lang.Object.hashCode.

Returns a hash code value for this object. This method is supported for the benefit of hash tables such as those provided by java.util.HashMap.

The general contract of hashCode is:

Whenever it is invoked on the same object more than once during an execution of a Java application, the hashCode method must consistently return the same integer, provided no information used in equals comparisons on the object is modified. This integer need not remain consistent from one execution of an application to another execution of the same application.
If two objects are equal according to the equals method, then calling the hashCode method on each of the two objects must produce the same integer result.
It is not required that if two objects are unequal according to the equals method, then calling the hashCode method on each of the two objects must produce distinct integer results. However, the programmer should be aware that producing distinct integer results for unequal objects may improve the performance of hash tables.

Annotations

@Override

jdk.internal.net.http back to summary

private final Class ConnectionPool.CleanupTrigger

Class Inheritance

extends Object
implements TubeSubscriber, TubePublisher, Subscription

java.lang.Object
jdk.internal.net.http.ConnectionPool.CleanupTrigger

All Implemented Interfaces

java.util.concurrent.Flow.Subscription, jdk.internal.net.http.common.FlowTube.TubePublisher, java.util.concurrent.Flow.Publisher, jdk.internal.net.http.common.FlowTube.TubeSubscriber, java.util.concurrent.Flow.Subscriber

An object that subscribes to the flow while the connection is in the pool. Anything that comes in will cause the connection to be closed and removed from the pool.

Field Summary

Modifier and Type	Field and Description
private final HttpConnection	connection
private volatile boolean	done
private volatile boolean	dropped

Constructor Summary

Access	Constructor and Description
public	CleanupTrigger(HttpConnection connection)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements java.util.concurrent.Flow.Subscription.cancel. Causes the Subscriber to (eventually) stop receiving messages.
public void	dropSubscription() Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription. Called when the flow is connected again, and the subscription is handed over to a new subscriber.
public boolean	isDone()
public void	onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
public void	onError(Throwable error) Implements java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
public void	onNext(List<ByteBuffer> item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.
public void	request(long n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.
public void	subscribe(Flow.Subscriber<? super List<ByteBuffer>> subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
private void	triggerCleanup(long pendingData, Throwable error)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

connection	back to summary
private final HttpConnection connection

done	back to summary
private volatile boolean done

dropped	back to summary
private volatile boolean dropped

Constructor Detail

CleanupTrigger	back to summary
public CleanupTrigger(HttpConnection connection)

Method Detail

cancel back to summary

public void cancel()

Implements java.util.concurrent.Flow.Subscription.cancel.

Doc from java.util.concurrent.Flow.Subscription.cancel.

Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive an onComplete or onError signal.

Annotations

@Override

dropSubscription back to summary

public void dropSubscription()

Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription.

Doc from jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription.

Called when the flow is connected again, and the subscription is handed over to a new subscriber. Once dropSubscription() is called, the TubeSubscriber should stop calling any method on its subscription.

Annotations

@Override

isDone	back to summary
public boolean isDone()

onComplete

back to summary

public void onComplete()

Implements java.util.concurrent.Flow.Subscriber.onComplete.

Doc from java.util.concurrent.Flow.Subscriber.onComplete.

Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined.

Annotations

@Override

onError

back to summary

public void onError(Throwable error)

Implements java.util.concurrent.Flow.Subscriber.onError.

Doc from java.util.concurrent.Flow.Subscriber.onError.

Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined.

Annotations

@Override

onNext

back to summary

public void onNext(List<ByteBuffer> item)

Implements java.util.concurrent.Flow.Subscriber.onNext.

Doc from java.util.concurrent.Flow.Subscriber.onNext.

Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.

Annotations

@Override

onSubscribe back to summary

public void onSubscribe(Flow.Subscription subscription)

Implements java.util.concurrent.Flow.Subscriber.onSubscribe.

Doc from java.util.concurrent.Flow.Subscriber.onSubscribe.

Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled.

Typically, implementations of this method invoke subscription.request to enable receiving items.

Annotations

@Override

request back to summary

public void request(long n)

Implements java.util.concurrent.Flow.Subscription.request.

Doc from java.util.concurrent.Flow.Subscription.request.

Adds the given number n of items to the current unfulfilled demand for this subscription. If n is less than or equal to zero, the Subscriber will receive an onError signal with an IllegalArgumentException argument. Otherwise, the Subscriber will receive up to n additional onNext invocations (or fewer if terminated).

Annotations

@Override

subscribe back to summary

public void subscribe(Flow.Subscriber<? super List<ByteBuffer>> subscriber)

Implements java.util.concurrent.Flow.Publisher.subscribe.

Doc from java.util.concurrent.Flow.Publisher.subscribe.

Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's onError method is invoked with an IllegalStateException. Otherwise, the Subscriber's onSubscribe method is invoked with a new Subscription. Subscribers may enable receiving items by invoking the request method of this Subscription, and may unsubscribe by invoking its cancel method.

Annotations

@Override

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations

@Override

triggerCleanup	back to summary
private void triggerCleanup(long pendingData, Throwable error)

jdk.internal.net.http back to summary

pack-priv final Class ConnectionPool.ExpiryEntry

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.ConnectionPool.ExpiryEntry

Field Summary

Modifier and Type	Field and Description
pack-priv final HttpConnection	connection
pack-priv final Deadline	expiry

Constructor Summary

Access	Constructor and Description
pack-priv	ExpiryEntry(HttpConnection connection, Deadline expiry)

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

connection	back to summary
pack-priv final HttpConnection connection

expiry	back to summary
pack-priv final Deadline expiry

Constructor Detail

ExpiryEntry	back to summary
pack-priv ExpiryEntry(HttpConnection connection, Deadline expiry)

jdk.internal.net.http back to summary

private final Class ConnectionPool.ExpiryList

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.ConnectionPool.ExpiryList

Manages a LinkedList of sorted ExpiryEntry. The entry with the closer deadline is at the tail of the list, and the entry with the farther deadline is at the head. In the most common situation, new elements will need to be added at the head (or close to it), and expired elements will need to be purged from the tail.

Field Summary

Modifier and Type	Field and Description
private final LinkedList<ConnectionPool.ExpiryEntry>	list
private volatile boolean	mayContainEntries
private final TimeLine	timeSource

Constructor Summary

Access	Constructor and Description
pack-priv	ExpiryList(TimeLine timeSource)

Method Summary

Modifier and Type	Method and Description
pack-priv void	add(HttpConnection conn)
pack-priv void	add(HttpConnection conn, Deadline now, long keepAlive)
pack-priv void	clear()
pack-priv Optional<Deadline>	nextExpiryDeadline()
pack-priv boolean	purgeMaybeRequired()
pack-priv List<HttpConnection>	purgeUntil(Deadline now)
pack-priv void	remove(HttpConnection c)
pack-priv HttpConnection	removeOldest()
pack-priv int	size()
pack-priv Stream<ConnectionPool.ExpiryEntry>	stream()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

list	back to summary
private final LinkedList<ConnectionPool.ExpiryEntry> list

mayContainEntries	back to summary
private volatile boolean mayContainEntries

timeSource	back to summary
private final TimeLine timeSource

Constructor Detail

ExpiryList	back to summary
pack-priv ExpiryList(TimeLine timeSource)

Method Detail

add	back to summary
pack-priv void add(HttpConnection conn)

add	back to summary
pack-priv void add(HttpConnection conn, Deadline now, long keepAlive)

clear	back to summary
pack-priv void clear()

nextExpiryDeadline	back to summary
pack-priv Optional<Deadline> nextExpiryDeadline()

purgeMaybeRequired	back to summary
pack-priv boolean purgeMaybeRequired()

purgeUntil	back to summary
pack-priv List<HttpConnection> purgeUntil(Deadline now)

remove	back to summary
pack-priv void remove(HttpConnection c)

removeOldest	back to summary
pack-priv HttpConnection removeOldest()

size	back to summary
pack-priv int size()

stream	back to summary
pack-priv Stream<ConnectionPool.ExpiryEntry> stream()

pack-priv final Class ConnectionPool

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class ConnectionPool.CacheKey

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class ConnectionPool.CleanupTrigger

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ConnectionPool.ExpiryEntry

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private final Class ConnectionPool.ExpiryList

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail