< 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 >