Bind response first byte timeout for ConnectionManager (#872)

Author: waahm7

crt/aws-c-auth

@@ -6,11 +6,7 @@
 
 import java.net.URI;
 import java.nio.charset.Charset;
-import java.util.Queue;
 import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ConcurrentLinkedQueue;
-
-import software.amazon.awssdk.crt.CRT;
 import software.amazon.awssdk.crt.CrtResource;
 import software.amazon.awssdk.crt.CrtRuntimeException;
 import software.amazon.awssdk.crt.io.ClientBootstrap;
@@ -138,7 +134,8 @@ private HttpClientConnectionManager(HttpClientConnectionManagerOptions options)
                                             monitoringFailureIntervalInSeconds,
                                             expectedHttpVersion.getValue(),
                                             options.getMaxPendingConnectionAcquisitions(),
-                                            options.getConnectionAcquisitionTimeoutInMilliseconds()));
+                                            options.getConnectionAcquisitionTimeoutInMilliseconds(),
+                                            options.getResponseFirstByteTimeoutInMilliseconds()));
 
         /* we don't need to add a reference to socketOptions since it's copied during connection manager construction */
          addReferenceTo(clientBootstrap);
@@ -271,7 +268,8 @@ private static native long httpClientConnectionManagerNew(HttpClientConnectionMa
                                                         int monitoringFailureIntervalInSeconds,
                                                         int expectedProtocol,
                                                         long maxPendingConnectionAcquisitions,
-                                                        long connectionAcquisitionTimeoutInMilliseconds) throws CrtRuntimeException;
+                                                        long connectionAcquisitionTimeoutInMilliseconds,
+                                                        long responseFirstByteTimeoutInMilliseconds) throws CrtRuntimeException;
 
     private static native void httpClientConnectionManagerRelease(long conn_manager) throws CrtRuntimeException;
 

crt/aws-c-cal

@@ -4,11 +4,11 @@
  */
 package software.amazon.awssdk.crt.http;
 
-import java.net.URI;
 import software.amazon.awssdk.crt.io.ClientBootstrap;
 import software.amazon.awssdk.crt.io.SocketOptions;
 import software.amazon.awssdk.crt.io.TlsConnectionOptions;
 import software.amazon.awssdk.crt.io.TlsContext;
+import java.net.URI;
 
 /**
  * Contains all the configuration options for a HttpConnectionPoolManager instance
@@ -35,6 +35,7 @@ public class HttpClientConnectionManagerOptions {
     private HttpVersion expectedHttpVersion = HttpVersion.HTTP_1_1;
     private long connectionAcquisitionTimeoutInMilliseconds;
     private long maxPendingConnectionAcquisitions;
+    private long responseFirstByteTimeoutInMilliseconds;
 
 	private static final String HTTP = "http";
     private static final String HTTPS = "https";
@@ -350,6 +351,27 @@ public HttpClientConnectionManagerOptions withMonitoringOptions(HttpMonitoringOp
      */
     public HttpMonitoringOptions getMonitoringOptions() { return monitoringOptions; }
 
+    /**
+     * @return the response first byte timeout in milliseconds 
+     */
+    public long getResponseFirstByteTimeoutInMilliseconds() {
+        return responseFirstByteTimeoutInMilliseconds;
+    }
+
+    /**
+     * Sets the responseFirstByteTimeoutInMilliseconds.
+     * After a request is fully sent, if the server does not begin responding within N milliseconds,
+     * then fail with AWS_ERROR_HTTP_RESPONSE_FIRST_BYTE_TIMEOUT.
+     *
+     * @param responseFirstByteTimeoutInMilliseconds first byte timeout in milliseconds
+     * @return this
+     */
+    public HttpClientConnectionManagerOptions withResponseFirstByteTimeoutInMilliseconds(long responseFirstByteTimeoutInMilliseconds) {
+        this.responseFirstByteTimeoutInMilliseconds = responseFirstByteTimeoutInMilliseconds;
+        return this;
+    }
+
+
     /**
      * Validate the connection manager options are valid to use. Throw exceptions if not.
      */

crt/aws-c-common

@@ -117,7 +117,8 @@ JNIEXPORT jlong JNICALL Java_software_amazon_awssdk_crt_http_HttpClientConnectio
     jint jni_monitoring_failure_interval_in_seconds,
     jint jni_expected_protocol_version,
     jlong jni_max_pending_connection_acquisitions,
-    jlong jni_connection_acquisition_timeout_ms) {
+    jlong jni_connection_acquisition_timeout_ms,
+    jlong jni_response_first_byte_timeout_ms) {
 
     (void)jni_class;
     (void)jni_expected_protocol_version;
@@ -191,6 +192,7 @@ JNIEXPORT jlong JNICALL Java_software_amazon_awssdk_crt_http_HttpClientConnectio
     manager_options.max_connection_idle_in_milliseconds = jni_max_connection_idle_in_milliseconds;
     manager_options.max_pending_connection_acquisitions = jni_max_pending_connection_acquisitions;
     manager_options.connection_acquisition_timeout_ms = jni_connection_acquisition_timeout_ms;
+    manager_options.response_first_byte_timeout_ms = jni_response_first_byte_timeout_ms;
 
     struct aws_http_connection_monitoring_options monitoring_options;
     AWS_ZERO_STRUCT(monitoring_options);