src/java.net.http/share/classes/jdk/internal/net/http/MultiExchange.java
branchhttp-client-branch
changeset 56437 f8b3f053cfbb
parent 56417 312811f70c43
child 56451 9585061fdb04
--- a/src/java.net.http/share/classes/jdk/internal/net/http/MultiExchange.java	Mon Apr 16 13:57:06 2018 +0100
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/MultiExchange.java	Mon Apr 16 16:44:12 2018 +0100
@@ -44,6 +44,7 @@
 import java.net.http.HttpResponse.PushPromiseHandler;
 import java.net.http.HttpTimeoutException;
 import jdk.internal.net.http.common.Log;
+import jdk.internal.net.http.common.Logger;
 import jdk.internal.net.http.common.MinimalFuture;
 import jdk.internal.net.http.common.ConnectionExpiredException;
 import jdk.internal.net.http.common.Utils;
@@ -60,9 +61,8 @@
  */
 class MultiExchange<T> {
 
-    static final boolean DEBUG = Utils.DEBUG; // Revisit: temporary dev flag.
-    static final System.Logger DEBUG_LOGGER =
-            Utils.getDebugLogger("MultiExchange"::toString, DEBUG);
+    static final Logger debug =
+            Utils.getDebugLogger("MultiExchange"::toString, Utils.DEBUG);
 
     private final HttpRequest userRequest; // the user request
     private final HttpRequestImpl request; // a copy of the user request
@@ -339,9 +339,8 @@
             // allow the retry mechanism to do its work
             retryCause = cause;
             if (!expiredOnce) {
-                DEBUG_LOGGER.log(Level.DEBUG,
-                    "ConnectionExpiredException (async): retrying...",
-                    t);
+                if (debug.on())
+                    debug.log("ConnectionExpiredException (async): retrying...", t);
                 expiredOnce = true;
                 // The connection was abruptly closed.
                 // We return null to retry the same request a second time.
@@ -351,9 +350,8 @@
                 previousreq = currentreq;
                 return null;
             } else {
-                DEBUG_LOGGER.log(Level.DEBUG,
-                    "ConnectionExpiredException (async): already retried once.",
-                    t);
+                if (debug.on())
+                    debug.log("ConnectionExpiredException (async): already retried once.", t);
                 if (t.getCause() != null) t = t.getCause();
             }
         }
@@ -366,9 +364,9 @@
         }
         @Override
         public void handle() {
-            DEBUG_LOGGER.log(Level.DEBUG,
-                    "Cancelling MultiExchange due to timeout for request %s",
-                     request);
+            if (debug.on())
+                debug.log("Cancelling MultiExchange due to timeout for request %s",
+                          request);
             cancel(new HttpTimeoutException("request timed out"));
         }
     }