< prev index next >

src/java.net.http/share/classes/jdk/internal/net/http/Http2ClientImpl.java

Print this page

        

*** 88,98 **** * 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) { URI uri = req.uri(); InetSocketAddress proxy = req.proxy(); String key = Http2Connection.keyFor(uri, proxy); synchronized (this) { --- 88,99 ---- * 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, ! Exchange<?> exchange) { URI uri = req.uri(); InetSocketAddress proxy = req.proxy(); String key = Http2Connection.keyFor(uri, proxy); synchronized (this) {
*** 121,131 **** if (debug.on()) debug.log("not found in connection pool"); return MinimalFuture.completedFuture(null); } } return Http2Connection ! .createAsync(req, this) .whenComplete((conn, t) -> { synchronized (Http2ClientImpl.this) { if (conn != null) { try { conn.reserveStream(true); --- 122,132 ---- if (debug.on()) debug.log("not found in connection pool"); return MinimalFuture.completedFuture(null); } } return Http2Connection ! .createAsync(req, this, exchange) .whenComplete((conn, t) -> { synchronized (Http2ClientImpl.this) { if (conn != null) { try { conn.reserveStream(true);
< prev index next >