diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-06-15 13:47:29 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-06-15 13:47:29 +0200 |
| commit | 4d9e59067045283489c8058ef070bc3baa0bc5c5 (patch) | |
| tree | 0fe77fa1fd5e68bbdcccd9f7fce300656a34e29f /configserver | |
| parent | a2b112e42e720167e16029d070f139bfc7207f32 (diff) | |
| parent | a2daf6e755be41f78e594be6a542a23ccacae6eb (diff) | |
Merge pull request #18257 from vespa-engine/hmusum/add-constructor-for-naming-JRTConnectionPool
Add constructor for naming JRTConnectionPool
Diffstat (limited to 'configserver')
| -rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java | 6 |
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) { |