< prev index next >
src/java.net.http/share/classes/jdk/internal/net/http/Http2ClientImpl.java
Print this page
@@ -88,11 +88,12 @@
* 1. completes with ALPN exception: h2 negotiate failed for first time. failure recorded.
* 2. completes with other exception: failure not recorded. Caller must handle
* 3. completes normally with null: no connection in cache for h2c or h2 failed previously
* 4. completes normally with connection: h2 or h2c connection in cache. Use it.
*/
- CompletableFuture<Http2Connection> getConnectionFor(HttpRequestImpl req) {
+ CompletableFuture<Http2Connection> getConnectionFor(HttpRequestImpl req,
+ Exchange<?> exchange) {
URI uri = req.uri();
InetSocketAddress proxy = req.proxy();
String key = Http2Connection.keyFor(uri, proxy);
synchronized (this) {
@@ -121,11 +122,11 @@
if (debug.on()) debug.log("not found in connection pool");
return MinimalFuture.completedFuture(null);
}
}
return Http2Connection
- .createAsync(req, this)
+ .createAsync(req, this, exchange)
.whenComplete((conn, t) -> {
synchronized (Http2ClientImpl.this) {
if (conn != null) {
try {
conn.reserveStream(true);
< prev index next >