Modifier and Type	Class and Description
pack-priv static interface	Http3ClientImpl.ConnectionRecovery
pack-priv static record	Http3ClientImpl.PendingConnection
pack-priv static record	Http3ClientImpl.StreamLimitReached
pack-priv static record	Http3ClientImpl.Waiter

Modifier and Type	Field and Description
private static final List<QuicVersion>	availableQuicVersions
pack-priv final HttpClientImpl	client
private volatile boolean	closed
private final Http3ConnectionPool	connections
private final Logger	debug
private static final boolean	disableHostnameVerification
private final AtomicReference<Throwable>	errorRef
private final ReentrantLock	lock
private final Set<String>	noH3
private final Set<Http3Connection>	pendingClose
private final QuicClient	quicClient
private final Http3PendingConnections	reconnections

Access	Constructor and Description
pack-priv	Http3ClientImpl(HttpClientImpl client)

Method Summary

Modifier and Type	Method and Description
public void	abort(Throwable t)
pack-priv HttpClientImpl	client()
public void	close() Implements java.lang.AutoCloseable.close. Closes this resource, relinquishing any underlying resources.
private void	completeWaiter(Logger debug, Http3ClientImpl.Waiter pendingWaiter, Http3Connection r, Throwable t)
pack-priv void	connectionClosed(Http3Connection c)
private void	connectionCompleted(String connectionKey, Exchange<?> origExchange, Http3Connection conn, Throwable error)
private void	connectionCompleted0(String connectionKey, Exchange<?> origExchange, Http3Connection conn, Throwable error)
pack-priv String	connectionKey(HttpRequestImpl request)
pack-priv String	dbgString()
public Logger	debug()
private static String	describe(HttpRequestImpl request, long id)
private static String	describe(Exchange<?> exchange)
private static String	describeAltSvc(Http3ClientImpl.PendingConnection pendingConnection)
private static String	describePendingExchange(String prefix, Http3ClientImpl.PendingConnection pending)
pack-priv Http3Connection	findPooledConnectionFor(HttpRequestImpl request, Exchange<?> exchange)
pack-priv CompletableFuture<Http3Connection>	getConnectionFor(HttpRequestImpl request, Exchange<?> exchange)
pack-priv CompletableFuture<Http3Connection>	getConnectionFor(HttpRequestImpl request, Exchange<?> exchange, Http3ClientImpl.Waiter pendingWaiter)
public boolean	Returns: true if the given authority is believed to not support h3 hasNoH3(String the raw authority (host:port) rawAuthority) Tells whether the given authority has been marked as not supporting h3
private static String	label(Http3Connection conn)
pack-priv Optional<AltServicesRegistry.AltService>	lookupAltSvc(HttpRequestImpl request)
public boolean	Returns: true if there's no h3 endpoint already registered for the given uri. mayAttemptDirectConnection(HttpRequestImpl the request that may go through h3 request) A direct HTTP/3 attempt may be attempted if we don't have an AltService h3 endpoint recorded for it, and if the given request URI's raw authority hasn't been marked as not supporting HTTP/3, and if the request discovery config is not ALT_SVC.
public void	noH3(String the raw authority (host:port) rawAuthority) After an unsuccessful H3 direct connection attempt, mark the authority as not supporting h3.
pack-priv Http3Connection	offerConnection(Http3Connection c)
pack-priv QuicClient	quicClient()
pack-priv void	removeFromPool(Http3Connection c)
public void	stop()
public void	streamLimitReached(Http3Connection connection, HttpRequestImpl request)
private CompletableFuture<Http3Connection>	wrapForDebug(CompletableFuture<Http3Connection> h3Cf, Exchange<?> exchange, HttpRequestImpl request)

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

Field Detail

availableQuicVersions	back to summary
private static final List<QuicVersion> availableQuicVersions

client	back to summary
pack-priv final HttpClientImpl client

closed	back to summary
private volatile boolean closed

connections	back to summary
private final Http3ConnectionPool connections

debug	back to summary
private final Logger debug

disableHostnameVerification	back to summary
private static final boolean disableHostnameVerification

errorRef	back to summary
private final AtomicReference<Throwable> errorRef

lock	back to summary
private final ReentrantLock lock

noH3	back to summary
private final Set<String> noH3

pendingClose	back to summary
private final Set<Http3Connection> pendingClose

quicClient	back to summary
private final QuicClient quicClient

reconnections	back to summary
private final Http3PendingConnections reconnections

Constructor Detail

Http3ClientImpl	back to summary
pack-priv Http3ClientImpl(HttpClientImpl client)

Method Detail

abort	back to summary
public void abort(Throwable t)

client	back to summary
pack-priv HttpClientImpl client()

close back to summary

close	back to summary
public void close() Implements java.lang.AutoCloseable.close. Doc from java.lang.AutoCloseable.close. Closes this resource, relinquishing any underlying resources. This method is invoked automatically on objects managed by the `try`-with-resources statement. Annotations @Override

public void close()

Implements java.lang.AutoCloseable.close.

Doc from java.lang.AutoCloseable.close.

Closes this resource, relinquishing any underlying resources. This method is invoked automatically on objects managed by the try-with-resources statement.

Annotations

@Override

completeWaiter	back to summary
private void completeWaiter(Logger debug, Http3ClientImpl.Waiter pendingWaiter, Http3Connection r, Throwable t)

connectionClosed	back to summary
pack-priv void connectionClosed(Http3Connection c)

connectionCompleted	back to summary
private void connectionCompleted(String connectionKey, Exchange<?> origExchange, Http3Connection conn, Throwable error)

connectionCompleted0	back to summary
private void connectionCompleted0(String connectionKey, Exchange<?> origExchange, Http3Connection conn, Throwable error)

connectionKey	back to summary
pack-priv String connectionKey(HttpRequestImpl request)

dbgString	back to summary
pack-priv String dbgString()

debug	back to summary
public Logger debug()

describe	back to summary
private static String describe(HttpRequestImpl request, long id)

describe	back to summary
private static String describe(Exchange<?> exchange)

describeAltSvc	back to summary
private static String describeAltSvc(Http3ClientImpl.PendingConnection pendingConnection)

describePendingExchange	back to summary
private static String describePendingExchange(String prefix, Http3ClientImpl.PendingConnection pending)

findPooledConnectionFor	back to summary
pack-priv Http3Connection findPooledConnectionFor(HttpRequestImpl request, Exchange<?> exchange) throws IOException

getConnectionFor	back to summary
pack-priv CompletableFuture<Http3Connection> getConnectionFor(HttpRequestImpl request, Exchange<?> exchange)

getConnectionFor	back to summary
pack-priv CompletableFuture<Http3Connection> getConnectionFor(HttpRequestImpl request, Exchange<?> exchange, Http3ClientImpl.Waiter pendingWaiter)

hasNoH3	back to summary
public boolean hasNoH3(String rawAuthority) Tells whether the given authority has been marked as not supporting h3 Parameters rawAuthority:String the raw authority (host:port) Returns:boolean true if the given authority is believed to not support h3

hasNoH3

back to summary

public boolean hasNoH3(String rawAuthority)

Tells whether the given authority has been marked as not supporting h3

Parameters

rawAuthority:String: the raw authority (host:port)

Returns:boolean

true if the given authority is believed to not support h3

label	back to summary
private static String label(Http3Connection conn)

lookupAltSvc	back to summary
pack-priv Optional<AltServicesRegistry.AltService> lookupAltSvc(HttpRequestImpl request)

mayAttemptDirectConnection back to summary

mayAttemptDirectConnection	back to summary
public boolean mayAttemptDirectConnection(HttpRequestImpl request) A direct HTTP/3 attempt may be attempted if we don't have an AltService h3 endpoint recorded for it, and if the given request URI's raw authority hasn't been marked as not supporting HTTP/3, and if the request discovery config is not ALT_SVC. Note that a URI may be marked has not supporting H3 if it doesn't acknowledge the first initial quic packet in the time defined by `jdk.httpclient.http3.maxDirectConnectionTimeout`. Parameters request:HttpRequestImpl the request that may go through h3 Returns:boolean true if there's no h3 endpoint already registered for the given uri.

public boolean mayAttemptDirectConnection(HttpRequestImpl request)

A direct HTTP/3 attempt may be attempted if we don't have an AltService h3 endpoint recorded for it, and if the given request URI's raw authority hasn't been marked as not supporting HTTP/3, and if the request discovery config is not ALT_SVC. Note that a URI may be marked has not supporting H3 if it doesn't acknowledge the first initial quic packet in the time defined by jdk.httpclient.http3.maxDirectConnectionTimeout.

Parameters

request:HttpRequestImpl: the request that may go through h3

Returns:boolean

true if there's no h3 endpoint already registered for the given uri.

noH3	back to summary
public void noH3(String rawAuthority) After an unsuccessful H3 direct connection attempt, mark the authority as not supporting h3. Parameters rawAuthority:String the raw authority (host:port)

noH3

back to summary

public void noH3(String rawAuthority)

After an unsuccessful H3 direct connection attempt, mark the authority as not supporting h3.

Parameters

rawAuthority:String: the raw authority (host:port)

offerConnection	back to summary
pack-priv Http3Connection offerConnection(Http3Connection c)

quicClient	back to summary
pack-priv QuicClient quicClient()

removeFromPool	back to summary
pack-priv void removeFromPool(Http3Connection c)

stop	back to summary
public void stop()

streamLimitReached	back to summary
public void streamLimitReached(Http3Connection connection, HttpRequestImpl request)

wrapForDebug	back to summary
private CompletableFuture<Http3Connection> wrapForDebug(CompletableFuture<Http3Connection> h3Cf, Exchange<?> exchange, HttpRequestImpl request)

jdk.internal.net.http back to summary

pack-priv sealed Interface Http3ClientImpl.ConnectionRecovery

Known Direct Implementers: jdk.internal.net.http.Http3ClientImpl.PendingConnection, jdk.internal.net.http.Http3ClientImpl.StreamLimitReached

jdk.internal.net.http back to summary

pack-priv final Record Http3ClientImpl.PendingConnection

Class Inheritance

extends Record
implements ConnectionRecovery

java.lang.Object
java.lang.Record
jdk.internal.net.http.Http3ClientImpl.PendingConnection

All Implemented Interfaces

jdk.internal.net.http.Http3ClientImpl.ConnectionRecovery

Record Components

altSvc:AltServicesRegistry.AltService
exchange:Exchange<?>
waiters:ConcurrentLinkedQueue<Http3ClientImpl.Waiter>

Field Summary

Modifier and Type	Field and Description
private final AltServicesRegistry.AltService	altSvc Record Component accessed by altSvc().
private final Exchange<?>	exchange Record Component accessed by exchange().
private final ConcurrentLinkedQueue<Http3ClientImpl.Waiter>	waiters Record Component accessed by waiters().

Constructor Summary

Access	Constructor and Description
pack-priv	PendingConnection(AltServicesRegistry.AltService altSvc, Exchange<?> exchange, ConcurrentLinkedQueue<Http3ClientImpl.Waiter> waiters)
pack-priv	PendingConnection(AltServicesRegistry.AltService altSvc, Exchange<?> exchange)

Method Summary

Modifier and Type	Method and Description
public AltServicesRegistry.AltService	altSvc() Record Component getter of altSvc.
public final boolean	equals(Object o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public Exchange<?>	exchange() Record Component getter of exchange.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.
public ConcurrentLinkedQueue<Http3ClientImpl.Waiter>	waiters() Record Component getter of waiters.

Field Detail

altSvc	back to summary
private final AltServicesRegistry.AltService altSvc Record Component accessed by altSvc().

exchange	back to summary
private final Exchange<?> exchange Record Component accessed by exchange().

waiters	back to summary
private final ConcurrentLinkedQueue<Http3ClientImpl.Waiter> waiters Record Component accessed by waiters().

Constructor Detail

PendingConnection	back to summary
pack-priv PendingConnection(AltServicesRegistry.AltService altSvc, Exchange<?> exchange, ConcurrentLinkedQueue<Http3ClientImpl.Waiter> waiters)

PendingConnection	back to summary
pack-priv PendingConnection(AltServicesRegistry.AltService altSvc, Exchange<?> exchange)

Method Detail

altSvc	back to summary
public AltServicesRegistry.AltService altSvc() Record Component getter of altSvc.

equals back to summary

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

Indicates whether some other object is "equal to" this one. In addition to the general contract of Object.equals, record classes must further obey the invariant that when a record instance is "copied" by passing the result of the record component accessor methods to the canonical constructor, as follows:

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

exchange	back to summary
public Exchange<?> exchange() Record Component getter of exchange.

hashCode back to summary

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

Returns a hash code value for the record. Obeys the general contract of Object.hashCode. For records, hashing behavior is constrained by the refined contract of Record.equals, so that any two records created from the same components must have the same hash code.

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

Returns a string representation of the record. In accordance with the general contract of Object#toString(), the toString method returns a string that "textually represents" this record. The result should be a concise but informative representation that is easy for a person to read.

In addition to this general contract, record classes must further participate in the invariant that any two records which are equal must produce equal strings. This invariant is necessarily relaxed in the rare case where corresponding equal component values might fail to produce equal strings for themselves.

waiters	back to summary
public ConcurrentLinkedQueue<Http3ClientImpl.Waiter> waiters() Record Component getter of waiters.

jdk.internal.net.http back to summary

pack-priv final Record Http3ClientImpl.StreamLimitReached

Class Inheritance

extends Record
implements ConnectionRecovery

java.lang.Object
java.lang.Record
jdk.internal.net.http.Http3ClientImpl.StreamLimitReached

All Implemented Interfaces

jdk.internal.net.http.Http3ClientImpl.ConnectionRecovery

Record Components

connection:Http3Connection

Field Summary

Modifier and Type	Field and Description
private final Http3Connection	connection Record Component accessed by connection().

Constructor Summary

Access	Constructor and Description
pack-priv	StreamLimitReached(Http3Connection connection)

Method Summary

Modifier and Type	Method and Description
public Http3Connection	connection() Record Component getter of connection.
public final boolean	equals(Object o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.

Field Detail

connection	back to summary
private final Http3Connection connection Record Component accessed by connection().

Constructor Detail

StreamLimitReached	back to summary
pack-priv StreamLimitReached(Http3Connection connection)

Method Detail

connection	back to summary
public Http3Connection connection() Record Component getter of connection.

equals back to summary

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

hashCode back to summary

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

jdk.internal.net.http back to summary

pack-priv final Record Http3ClientImpl.Waiter

Class Inheritance

extends Record

java.lang.Object
java.lang.Record
jdk.internal.net.http.Http3ClientImpl.Waiter

Record Components

cf:MinimalFuture<Http3Connection>
request:HttpRequestImpl
exchange:Exchange<?>

Field Summary

Modifier and Type	Field and Description
private final MinimalFuture<Http3Connection>	cf Record Component accessed by cf().
private final Exchange<?>	exchange Record Component accessed by exchange().
private final HttpRequestImpl	request Record Component accessed by request().

Constructor Summary

Access	Constructor and Description
pack-priv	Waiter(MinimalFuture<Http3Connection> cf, HttpRequestImpl request, Exchange<?> exchange)

Method Summary

Modifier and Type	Method and Description
public MinimalFuture<Http3Connection>	cf() Record Component getter of cf.
pack-priv void	complete(Http3Connection conn, Throwable error)
public final boolean	equals(Object o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public Exchange<?>	exchange() Record Component getter of exchange.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
pack-priv static Http3ClientImpl.Waiter	of(HttpRequestImpl request, Exchange<?> exchange)
public HttpRequestImpl	request() Record Component getter of request.
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.

Field Detail

cf	back to summary
private final MinimalFuture<Http3Connection> cf Record Component accessed by cf().

exchange	back to summary
private final Exchange<?> exchange Record Component accessed by exchange().

request	back to summary
private final HttpRequestImpl request Record Component accessed by request().

Constructor Detail

Waiter	back to summary
pack-priv Waiter(MinimalFuture<Http3Connection> cf, HttpRequestImpl request, Exchange<?> exchange)

Method Detail

cf	back to summary
public MinimalFuture<Http3Connection> cf() Record Component getter of cf.

complete	back to summary
pack-priv void complete(Http3Connection conn, Throwable error)

equals back to summary

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

exchange	back to summary
public Exchange<?> exchange() Record Component getter of exchange.

hashCode back to summary

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

of	back to summary
pack-priv static Http3ClientImpl.Waiter of(HttpRequestImpl request, Exchange<?> exchange)

request	back to summary
public HttpRequestImpl request() Record Component getter of request.

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

pack-priv final Class Http3ClientImpl

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv sealed Interface Http3ClientImpl.ConnectionRecovery

pack-priv final Record Http3ClientImpl.PendingConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Record Http3ClientImpl.StreamLimitReached

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Record Http3ClientImpl.Waiter

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail