aboutsummaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-04-16 14:55:18 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-04-16 14:55:18 +0200
commitdfa51e3fb3239f418608ec4b1e11a6da89e27ce9 (patch)
tree0016d7d3df3e0bfb35a1704a7ae42d81cddbdf58 /configserver
parent95162715532714931a379f35f29fba6836e57daa (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.java5
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();
}