summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-01-14 08:10:43 +0100
committerHarald Musum <musum@verizonmedia.com>2020-01-14 08:10:43 +0100
commit7f3ba63a648f35e0bf9246a1c36da29e840d1031 (patch)
tree02397bbcdda339037298139130c18827b2e0c378 /configserver
parent7250e7a5cfafaa8e52a56c7990437be740761093 (diff)
Make sure to shutdown executor
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java4
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java1
2 files changed, 5 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java
index 3034c7dfd53..cb4945bdab3 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java
@@ -195,6 +195,10 @@ public class FileServer {
return downloader;
}
+ public void close() {
+ downloader.close();
+ }
+
// Connection pool with all config servers except this one (might be an empty pool if there is only one config server)
private static ConnectionPool createConnectionPool(ConfigserverConfig configserverConfig) {
List<String> configServers = ConfigServerSpec.fromConfig(configserverConfig)
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
index 8ec0c71d7f2..851ad166c2d 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
@@ -202,6 +202,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
Thread.interrupted(); // Ignore and continue shutdown.
}
delayedConfigResponses.stop();
+ fileServer.close();
supervisor.transport().shutdown().join();
isRunning = false;
}