summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-06-15 08:46:59 +0200
committerHarald Musum <musum@verizonmedia.com>2021-06-15 08:46:59 +0200
commit109dd89384b9db3c4bc4bc2a6e325456bc6f853b (patch)
treed7fe4dcb2b66f24a63386aa8cd1b43dc6418d0b2 /configserver
parent5667784f2fca043d79863160946dce85832890b6 (diff)
Add constructor for naming JRTConnectionPool
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java6
1 files changed, 4 insertions, 2 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java
index 33cd425d6aa..cfe7349a1c6 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java
@@ -40,7 +40,7 @@ public class FileDistributionUtil {
/**
* Returns a connection pool with all config servers except this one, or an empty pool if there
- * is only one config server.
+ * is only one config server (no point in trying to download from yourself).
*/
public static ConnectionPool createConnectionPool(ConfigserverConfig configserverConfig) {
List<String> configServers = ConfigServerSpec.fromConfig(configserverConfig)
@@ -49,7 +49,9 @@ public class FileDistributionUtil {
.map(spec -> "tcp/" + spec.getHostName() + ":" + spec.getConfigServerPort())
.collect(Collectors.toList());
- return configServers.size() > 0 ? new JRTConnectionPool(new ConfigSourceSet(configServers)) : emptyConnectionPool();
+ return configServers.size() > 0
+ ? new JRTConnectionPool(new ConfigSourceSet(configServers), "filedistribution-jrt-pool-")
+ : emptyConnectionPool();
}
public static boolean fileReferenceExistsOnDisk(File downloadDirectory, FileReference applicationPackageReference) {