pack-priv Class Http3PendingConnections

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.Http3PendingConnections

Imports

java.util.Map, .Optional, java.util.concurrent.ConcurrentHashMap, jdk.internal.net.http.AltServicesRegistry.AltService, .Http3ClientImpl.ConnectionRecovery, .Http3ClientImpl.PendingConnection, .Http3ClientImpl.StreamLimitReached, jdk.internal.net.http.common.Log

This class keeps track of pending HTTP/3 connections to avoid making two connections to the same server in parallel. Methods in this class are not atomic. Therefore, it is expected that they will be called while holding a lock in order to ensure atomicity.

Field Summary

Modifier and Type	Field and Description
private final Map<String, Http3ClientImpl.ConnectionRecovery>	pendingAdvertised
private final Map<String, Http3ClientImpl.ConnectionRecovery>	pendingUnadvertised

Constructor Summary

Access	Constructor and Description
pack-priv	Http3PendingConnections()

Method Summary

Modifier and Type	Method and Description
pack-priv Http3ClientImpl.PendingConnection	addPending(String key, HttpRequestImpl request, AltServicesRegistry.AltService altSvc, Exchange<?> exchange)
pack-priv Http3ClientImpl.ConnectionRecovery	lookupFor(String key, HttpRequestImpl request, HttpClientImpl client)
pack-priv Http3ClientImpl.ConnectionRecovery	removeCompleted(String connectionKey, Exchange<?> origExchange, Http3Connection conn)
pack-priv void	streamLimitReached(String key, Http3Connection connection)

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

Field Detail

pendingAdvertised	back to summary
private final Map<String, Http3ClientImpl.ConnectionRecovery> pendingAdvertised

pendingUnadvertised	back to summary
private final Map<String, Http3ClientImpl.ConnectionRecovery> pendingUnadvertised

Constructor Detail

Http3PendingConnections	back to summary
pack-priv Http3PendingConnections()

Method Detail

addPending	back to summary
pack-priv Http3ClientImpl.PendingConnection addPending(String key, HttpRequestImpl request, AltServicesRegistry.AltService altSvc, Exchange<?> exchange)

lookupFor	back to summary
pack-priv Http3ClientImpl.ConnectionRecovery lookupFor(String key, HttpRequestImpl request, HttpClientImpl client)

removeCompleted	back to summary
pack-priv Http3ClientImpl.ConnectionRecovery removeCompleted(String connectionKey, Exchange<?> origExchange, Http3Connection conn)

streamLimitReached	back to summary
pack-priv void streamLimitReached(String key, Http3Connection connection)