Add logs

Author: arturobernalg

httpclient5/src/main/java/org/apache/hc/client5/http/impl/async/AsyncConnectExec.java

@@ -255,6 +255,9 @@ public void completed(final AsyncExecRuntime execRuntime) {
                                 asyncExecCallback.failed(new HttpException("Proxy chains are not supported"));
                                 return;
                             }
+                            if (LOG.isDebugEnabled()) {
+                                LOG.debug("{} H2 tunnel to target already established by connection pool", exchangeId);
+                            }
                             tracker.tunnelTarget(false);
                             if (route.isLayered()) {
                                 tracker.layerProtocol(route.isSecure());

httpclient5/src/main/java/org/apache/hc/client5/http/impl/async/InternalH2ConnPool.java

@@ -70,6 +70,8 @@
 import org.apache.hc.core5.reactor.ssl.TransportSecurityLayer;
 import org.apache.hc.core5.util.TimeValue;
 import org.apache.hc.core5.util.Timeout;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 class InternalH2ConnPool implements ModalCloseable {
 
@@ -176,6 +178,7 @@ public void setValidateAfterInactivity(final TimeValue timeValue) {
 
     static class SessionPool extends AbstractIOSessionPool<HttpRoute> {
 
+        private static final Logger LOG = LoggerFactory.getLogger(InternalH2ConnPool.class);
         private static final int MAX_TUNNEL_AUTH_ATTEMPTS = 3;
 
         private final ConnectionInitiator connectionInitiator;
@@ -284,6 +287,9 @@ private void completeConnection(
             }
             final NamedEndpoint targetEndpoint = route.getTargetName() != null ? route.getTargetName() : route.getTargetHost();
             final HttpHost proxy = route.getProxyHost();
+            if (LOG.isDebugEnabled()) {
+                LOG.debug("{} establishing H2 tunnel to {} via {}", ioSession.getId(), targetEndpoint, proxy);
+            }
             if (proxy != null && proxyHttpProcessor != null && proxyAuthStrategy != null && authenticator != null) {
                 establishTunnelWithAuth(route, ioSession, targetEndpoint, proxy, connectTimeout, callback);
             } else {
@@ -375,6 +381,10 @@ public void failed(final Exception ex) {
                                 proxyHttpProcessor.process(response, null, tunnelContext);
                                 final boolean retry = needAuthentication(proxyAuthExchange, proxy, response, tunnelContext);
                                 if (retry) {
+                                    if (LOG.isDebugEnabled()) {
+                                        LOG.debug("{} tunnel auth challenge from {}; attempt {}/{}",
+                                                ioSession.getId(), proxy, attemptCount, MAX_TUNNEL_AUTH_ATTEMPTS);
+                                    }
                                     establishTunnelWithAuthAttempt(
                                             route,
                                             ioSession,
@@ -388,8 +398,6 @@ public void failed(final Exception ex) {
                                 } else {
                                     callback.failed(ex);
                                 }
-                            } catch (final AuthenticationException | MalformedChallengeException authEx) {
-                                callback.failed(authEx);
                             } catch (final Exception ioEx) {
                                 callback.failed(ioEx);
                             }