diff options
author | Harald Musum <musum@yahooinc.com> | 2021-10-07 13:15:48 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2021-10-07 13:15:48 +0200 |
commit | 35cc39659cd8acefcee399a1fc2a5228dd38adc5 (patch) | |
tree | f740e3c2d2bc653f2dee1afd396a8b86d132cd1a /configserver | |
parent | 03224ae1749a058c88ee926738195ae0d3204322 (diff) |
Reuse supervisor when we have one
Remove unnecessary constructor
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 04be936029f..2d39c5549cc 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 @@ -50,7 +50,9 @@ public class FileDistributionUtil { .collect(Collectors.toList()); return configServers.size() > 0 - ? new JRTConnectionPool(new ConfigSourceSet(configServers), "filedistribution-jrt-pool") + ? new JRTConnectionPool(new ConfigSourceSet(configServers), + new Supervisor(new Transport("filedistribution-pool")) + .setDropEmptyBuffers(true)) : emptyConnectionPool(); } @@ -87,7 +89,7 @@ public class FileDistributionUtil { public Supervisor getSupervisor() { synchronized (this) { if (supervisor == null) { - supervisor = new Supervisor(new Transport("empty-connectionpool")); + supervisor = new Supervisor(new Transport("empty-connection-pool")).setDropEmptyBuffers(true); } } return supervisor; |