diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-04-16 14:55:18 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-04-16 14:55:18 +0200 |
commit | dfa51e3fb3239f418608ec4b1e11a6da89e27ce9 (patch) | |
tree | 0016d7d3df3e0bfb35a1704a7ae42d81cddbdf58 /configserver | |
parent | 95162715532714931a379f35f29fba6836e57daa (diff) |
Use a short connection TTL to avoid many connections, instead of Connection: close
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/application/ConfigConvergenceChecker.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/application/ConfigConvergenceChecker.java b/configserver/src/main/java/com/yahoo/vespa/config/server/application/ConfigConvergenceChecker.java index c2342278236..2dd655c91d8 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/application/ConfigConvergenceChecker.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/application/ConfigConvergenceChecker.java @@ -23,6 +23,7 @@ import org.apache.hc.core5.http.HttpStatus; import org.apache.hc.core5.http2.HttpVersionPolicy; import org.apache.hc.core5.net.URIBuilder; import org.apache.hc.core5.reactor.IOReactorConfig; +import org.apache.hc.core5.util.TimeValue; import org.apache.hc.core5.util.Timeout; import java.io.IOException; @@ -152,7 +153,6 @@ public class ConfigConvergenceChecker extends AbstractComponent { /** Get service generation of service at given URL */ private CompletableFuture<Long> getServiceGeneration(CloseableHttpAsyncClient client, URI serviceUrl, Duration timeout) { SimpleHttpRequest request = SimpleHttpRequests.get(createApiUri(serviceUrl)); - request.setHeader("Connection", "close"); request.setConfig(createRequestConfig(timeout)); // Ignoring returned Future object as we want to use the more flexible CompletableFuture instead @@ -240,14 +240,13 @@ public class ConfigConvergenceChecker extends AbstractComponent { PoolingAsyncClientConnectionManagerBuilder.create() .setMaxConnTotal(100) .setMaxConnPerRoute(10) + .setConnectionTimeToLive(TimeValue.ofMilliseconds(1)) .setTlsStrategy(tlsStrategy) .build()) .setIOReactorConfig(IOReactorConfig.custom() .setSoTimeout(Timeout.ofSeconds(2)) .build()) .setUserAgent("config-convergence-checker") - .setConnectionReuseStrategy((request, response, context) -> false) // Disable connection reuse - .setVersionPolicy(HttpVersionPolicy.FORCE_HTTP_1) .build(); } |