Set maxConcurrentStreams on HTTP/2 stream manager so that the MAX_CON…

http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/AwsCrtHttpClient.java

@@ -58,7 +58,9 @@ public final class AwsCrtHttpClient extends AwsCrtHttpClientBase implements SdkH
     private AwsCrtHttpClient(DefaultBuilder builder, AttributeMap config) {
         super(builder, config);
         if (this.protocol == Protocol.HTTP2) {
-            throw new UnsupportedOperationException("HTTP/2 is not supported in sync client. Use AwsCrtAsyncHttpClient instead.");
+            throw new UnsupportedOperationException(
+                "HTTP/2 is not supported for sync HTTP clients. Either use HTTP/1.1 (the default) or use an async "
+                + "HTTP client (e.g., AwsCrtAsyncHttpClient).");
         }
     }
 

http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/AwsCrtHttpClientBase.java

@@ -69,9 +69,9 @@
     private final HttpProxyOptions proxyOptions;
     private final HttpMonitoringOptions monitoringOptions;
     private final long maxConnectionIdleInMilliseconds;
-    private final int maxConnectionsPerEndpoint;
+    private final int maxStreamsPerEndpoint;
     private final long connectionAcquisitionTimeout;
     private final TlsContextOptions tlsContextOptions;
     private boolean isClosed = false;
 
     AwsCrtHttpClientBase(AwsCrtClientBuilderBase builder, AttributeMap config) {
@@ -95,7 +95,7 @@
         this.tlsContext = registerOwnedResource(clientTlsContext);
         this.readBufferSize = builder.getReadBufferSizeInBytes() == null ?
                               DEFAULT_STREAM_WINDOW_SIZE : builder.getReadBufferSizeInBytes();
-        this.maxConnectionsPerEndpoint = config.get(SdkHttpConfigurationOption.MAX_CONNECTIONS);
+        this.maxStreamsPerEndpoint = config.get(SdkHttpConfigurationOption.MAX_CONNECTIONS);
         this.monitoringOptions = resolveHttpMonitoringOptions(builder.getConnectionHealthConfiguration()).orElse(null);
         this.maxConnectionIdleInMilliseconds = config.get(SdkHttpConfigurationOption.CONNECTION_MAX_IDLE_TIMEOUT).toMillis();
         this.connectionAcquisitionTimeout = config.get(SdkHttpConfigurationOption.CONNECTION_ACQUIRE_TIMEOUT).toMillis();
@@ -121,7 +121,7 @@
     }
 
     private HttpStreamManager createConnectionPool(URI uri) {
-        log.debug(() -> "Creating ConnectionPool for: URI:" + uri + ", MaxConns: " + maxConnectionsPerEndpoint);
+        log.debug(() -> "Creating ConnectionPool for: URI:" + uri + ", MaxConns: " + maxStreamsPerEndpoint+ ", MaxStreams: " + maxStreamsPerEndpoint);
 
         boolean isHttps = "https".equalsIgnoreCase(uri.getScheme());
         TlsContext poolTlsContext = isHttps ? tlsContext : null;
@@ -132,7 +132,7 @@
                 .withTlsContext(poolTlsContext)
                 .withUri(uri)
                 .withWindowSize(readBufferSize)
-                .withMaxConnections(maxConnectionsPerEndpoint)
+                .withMaxConnections(maxStreamsPerEndpoint)
                 .withManualWindowManagement(true)
                 .withProxyOptions(proxyOptions)
                 .withMonitoringOptions(monitoringOptions)
@@ -144,6 +144,7 @@
 
         if (protocol == Protocol.HTTP2) {
             Http2StreamManagerOptions h2Options = new Http2StreamManagerOptions()
+                .withMaxConcurrentStreams(maxStreamsPerEndpoint)
                 .withConnectionManagerOptions(h1Options);
 
             if (!isHttps) {
@@ -180,7 +181,7 @@
                 throw new IllegalStateException("Client is closed. No more requests can be made with this client.");
             }
 
             HttpStreamManager connPool = connectionPools.computeIfAbsent(uri, this::createConnectionPool);
             return connPool;
         }
     }

http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/internal/CrtUtils.java

@@ -28,8 +28,8 @@
 import java.util.concurrent.CompletionException;
 import javax.net.ssl.SSLHandshakeException;
 import software.amazon.awssdk.annotations.SdkInternalApi;
+import software.amazon.awssdk.crt.CRT;
 import software.amazon.awssdk.crt.CrtRuntimeException;
-import software.amazon.awssdk.crt.http.HttpClientConnection;
 import software.amazon.awssdk.crt.http.HttpException;
 import software.amazon.awssdk.crt.http.HttpManagerMetrics;
 import software.amazon.awssdk.crt.http.HttpStreamManager;
@@ -50,10 +50,7 @@ private CrtUtils() {
     public static Throwable wrapWithIoExceptionIfRetryable(HttpException httpException) {
         Throwable toThrow = httpException;
 
-        // TODO: switch to Crt.awsIsTransientError once https://github.com/awslabs/aws-crt-java/pull/972 is merged
-        if (HttpClientConnection.isErrorRetryable(httpException)) {
-            // IOExceptions get retried, and if the CRT says this error is retryable,
-            // it's semantically an IOException anyway.
+        if (CRT.awsIsTransientError(httpException.getErrorCode())) {
             toThrow = new IOException(httpException);
         }
         return toThrow;
@@ -70,8 +67,7 @@ public static Throwable wrapCrtException(Throwable throwable) {
             if (httpErrorCode == CRT_TLS_NEGOTIATION_ERROR_CODE) {
                 return new SSLHandshakeException(httpException.getMessage());
             }
-            // TODO: check with CRT team, could CRT_SOCKET_TIMEOUT be thrown
-            //  from processes other than tcp connect?
+
             if (httpErrorCode == CRT_SOCKET_TIMEOUT) {
                 return new ConnectException(httpException.getMessage());
             }

http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/H2ErrorTest.java

@@ -55,6 +55,7 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import software.amazon.awssdk.crt.http.HttpException;
 import software.amazon.awssdk.http.Protocol;
 import software.amazon.awssdk.http.async.SdkAsyncHttpClient;
 import software.amazon.awssdk.utils.AttributeMap;
@@ -62,11 +63,11 @@
 /**
  * Tests HTTP/2 error scenarios: RST_STREAM and GOAWAY frames.
  */
 public class H2ErrorTest {
     private SdkAsyncHttpClient client;
 
     @BeforeEach
     public void setup() {
         client = AwsCrtAsyncHttpClient.builder()
                                       .buildWithDefaults(AttributeMap.builder()
                                                                      .put(TRUST_ALL_CERTIFICATES, true)
@@ -75,21 +76,21 @@
     }
 
     @AfterEach
     public void teardown() {
         if (client != null) {
             client.close();
         }
     }
 
     @Test
-    public void serverSendsRstStream_shouldThrowIOException() throws Exception {
+    public void serverSendsRstStream_shouldNotThrowIOException() throws Exception {
         H2ErrorServer server = new H2ErrorServer(ErrorType.RST_STREAM);
         server.init();
         try {
             CompletableFuture<?> request = sendGetRequest(server.port(), client);
             assertThatThrownBy(request::join)
                 .isInstanceOf(CompletionException.class)
-                .hasCauseInstanceOf(IOException.class)
+                .hasCauseInstanceOf(HttpException.class)
                 .hasMessageContaining("RST_STREAM");
         } finally {
             server.shutdown();
@@ -97,7 +98,7 @@
     }
 
     @Test
     public void tcpConnectFailure_shouldThrowIOException() throws Exception {
         int unusedPort;
         try (ServerSocket ss = new ServerSocket(0)) {
             unusedPort = ss.getLocalPort();
@@ -111,7 +112,7 @@
     }
 
     @Test
     public void serverSendsGoAway_shouldThrowIOException() throws Exception {
         H2ErrorServer server = new H2ErrorServer(ErrorType.GOAWAY);
         server.init();
         try {

pom.xml

@@ -130,7 +130,7 @@
         <rxjava3.version>3.1.5</rxjava3.version>
         <commons-codec.verion>1.17.1</commons-codec.verion>
         <jmh.version>1.37</jmh.version>
-        <awscrt.version>0.43.5</awscrt.version>
+        <awscrt.version>0.43.9</awscrt.version>
 
         <!--Test dependencies -->
         <junit5.version>5.10.3</junit5.version>