summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2021-10-07 13:15:48 +0200
committerHarald Musum <musum@yahooinc.com>2021-10-07 13:15:48 +0200
commit35cc39659cd8acefcee399a1fc2a5228dd38adc5 (patch)
treef740e3c2d2bc653f2dee1afd396a8b86d132cd1a /configserver
parent03224ae1749a058c88ee926738195ae0d3204322 (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.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 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;