Timeout configuration

This change adds a couple more configuration options for controlling timeouts
in the network stack.

Author: nebhale

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/_DefaultConnectionContext.java

@@ -63,7 +63,9 @@ public HttpClient getHttpClient() {
             .rcvbuf(RECEIVE_BUFFER_SIZE);
 
         getProxyConfiguration().ifPresent(c -> options.proxy(ClientOptions.Proxy.HTTP, c.getHost(), c.getPort().orElse(null), c.getUsername().orElse(null), u -> c.getPassword().orElse(null)));
+        getSocketTimeout().ifPresent(options::timeout);
         getSslCertificateTruster().ifPresent(trustManager -> options.ssl().trustManager(new StaticTrustManagerFactory(trustManager)));
+        getSslHandshakeTimeout().ifPresent(options::sslHandshakeTimeout);
 
         return HttpClient.create(options);
     }
@@ -144,6 +146,11 @@ Mono<Map<String, String>> getInfo() {
      */
     abstract Optional<Boolean> getSkipSslValidation();
 
+    /**
+     * The {@code SO_TIMEOUT} value
+     */
+    abstract Optional<Duration> getSocketTimeout();
+
     @Value.Derived
     Optional<SslCertificateTruster> getSslCertificateTruster() {
         if (getSkipSslValidation().orElse(false)) {
@@ -153,6 +160,11 @@ Optional<SslCertificateTruster> getSslCertificateTruster() {
         }
     }
 
+    /**
+     * The timeout for the SSL handshake negotiation
+     */
+    abstract Optional<Duration> getSslHandshakeTimeout();
+
     private static UriComponents normalize(UriComponentsBuilder builder) {
         UriComponents components = builder.build();
 

integration-test/src/test/java/org/cloudfoundry/IntegrationTestConfiguration.java

@@ -46,6 +46,7 @@
 import reactor.core.publisher.Mono;
 
 import java.security.SecureRandom;
+import java.time.Duration;
 import java.util.Random;
 
 @Configuration
@@ -89,7 +90,8 @@ DefaultConnectionContext connectionContext(@Value("${test.apiHost}") String apiH
         DefaultConnectionContext.Builder connectionContext = DefaultConnectionContext.builder()
             .apiHost(apiHost)
             .problemHandler(new FailingDeserializationProblemHandler())  // Test-only problem handler
-            .skipSslValidation(skipSslValidation);
+            .skipSslValidation(skipSslValidation)
+            .sslHandshakeTimeout(Duration.ofSeconds(30));
 
         if (StringUtils.hasText(proxyHost)) {
             ProxyConfiguration.Builder proxyConfiguration = ProxyConfiguration.builder()