Additional logging for GOAWAY

Should help during debugging and troubleshooting.

Author: dagnir

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

@@ -316,7 +316,7 @@ private Future<Void> closeAndReleaseParent(Channel parentChannel, Throwable caus
     }
 
     public void handleGoAway(Channel parentChannel, int lastStreamId, GoAwayException exception) {
-        log.debug(() -> "Received GOAWAY on " + parentChannel + " with lastStreamId of " + lastStreamId);
+        log.warn(() -> "Received GOAWAY on " + parentChannel + " with lastStreamId of " + lastStreamId);
         try {
             MultiplexedChannelRecord multiplexedChannel = parentChannel.attr(MULTIPLEXED_CHANNEL).get();
 

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

@@ -61,6 +61,7 @@ public class MultiplexedChannelRecord {
     // Only write in the connection.eventLoop()
     private volatile RecordState state = RecordState.OPEN;
 
+    private volatile int lastStreamId;
 
     MultiplexedChannelRecord(Channel connection, long maxConcurrencyPerConnection, Duration allowedIdleConnectionTime) {
         this.connection = connection;
@@ -81,7 +82,15 @@ boolean acquireStream(Promise<Channel> promise) {
     private void acquireClaimedStream(Promise<Channel> promise) {
         doInEventLoop(connection.eventLoop(), () -> {
             if (state != RecordState.OPEN) {
-                String message = "Connection received GOAWAY or was closed while acquiring new stream.";
+                String message;
+                // GOAWAY
+                if (state == RecordState.CLOSED_TO_NEW) {
+                    message = String.format("Connection %s received GOAWAY with Last Stream ID %d. Unable to open new "
+                                            + "streams on this connection.", connection, lastStreamId);
+                } else {
+                    message = String.format("Connection %s was closed while acquiring new stream.", connection);
+                }
+                log.warn(() -> message);
                 promise.setFailure(new IllegalStateException(message));
                 return;
             }
@@ -145,6 +154,8 @@ private void releaseClaim() {
      */
     void handleGoAway(int lastStreamId, GoAwayException exception) {
         doInEventLoop(connection.eventLoop(), () -> {
+            this.lastStreamId = lastStreamId;
+
             if (state == RecordState.CLOSED) {
                 return;
             }