summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorJon Marius Venstad <jonmv@users.noreply.github.com>2021-04-16 15:02:32 +0200
committerGitHub <noreply@github.com>2021-04-16 15:02:32 +0200
commit809bace3c5fd25e95e79fad7246aedf5bc4904c1 (patch)
treec31463b94cf6f5863b1d7fef23f9d1a08b5ebfed /configserver
parent4ffae015b9b714ad321677151ba7dfaa74e2e46b (diff)
parentdfa51e3fb3239f418608ec4b1e11a6da89e27ce9 (diff)
Merge pull request #17468 from vespa-engine/jonmv/short-conn-ttl-for-config-convergence-checker
Use a short connection TTL to avoid many connections, instead of Conn…
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();
}