Wrap ReadTimeoutException and WriteTimeoutException in ResponseHanlder and update logging level

Author: zoewangg

http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/NettyRequestExecutor.java

@@ -191,7 +191,7 @@ private URI endpoint() {
     }
 
     private void handleFailure(Supplier<String> msg, Throwable cause) {
-        log.error(msg.get(), cause);
+        log.debug(msg.get(), cause);
         cause = decorateException(cause);
         context.handler().onError(cause);
         executeFuture.completeExceptionally(cause);

http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ResponseHandler.java

@@ -34,6 +34,8 @@
 import io.netty.handler.codec.http.HttpResponse;
 import io.netty.handler.codec.http.HttpUtil;
 import io.netty.handler.codec.http.LastHttpContent;
+import io.netty.handler.timeout.ReadTimeoutException;
+import io.netty.handler.timeout.WriteTimeoutException;
 import io.netty.util.AttributeKey;
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -115,9 +117,10 @@ private static void finalizeRequest(RequestContext requestContext, ChannelHandle
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
         RequestContext requestContext = ctx.channel().attr(REQUEST_CONTEXT_KEY).get();
-        log.error("Exception processing request: {}", requestContext.executeRequest().request(), cause);
-        requestContext.handler().onError(cause);
-        executeFuture(ctx).completeExceptionally(cause);
+        log.debug("Exception processing request: {}", requestContext.executeRequest().request(), cause);
+        Throwable throwable = wrapException(cause);
+        requestContext.handler().onError(throwable);
+        executeFuture(ctx).completeExceptionally(throwable);
         runAndLogError("Could not release channel back to the pool", () -> closeAndRelease(ctx));
     }
 
@@ -355,4 +358,14 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpObject obj) throws Ex
             ctx.pipeline().remove(this);
         }
     }
+
+    private Throwable wrapException(Throwable originalCause) {
+        if (originalCause instanceof ReadTimeoutException) {
+            return new IOException("Read timed out", originalCause);
+        } else if (originalCause instanceof WriteTimeoutException) {
+            return new IOException("Write timed out", originalCause);
+        }
+
+        return originalCause;
+    }
 }