diff options
author | Martin Polden <mpolden@mpolden.no> | 2020-12-14 14:20:02 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2020-12-14 14:20:02 +0100 |
commit | b6b5bc787f40e5f631e39d7f6f01353f33301e29 (patch) | |
tree | d1e463a47398909a4a602a32d7157b9ff7201c35 /zookeeper-server/zookeeper-server-common/src | |
parent | 78a65b4948c0e4a4555103de90a1944ecd2b13a9 (diff) |
Log when triggering shutdown
Diffstat (limited to 'zookeeper-server/zookeeper-server-common/src')
-rw-r--r-- | zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/ZooKeeperRunner.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/ZooKeeperRunner.java b/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/ZooKeeperRunner.java index 5eeb31c31bb..016d97835ac 100644 --- a/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/ZooKeeperRunner.java +++ b/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/ZooKeeperRunner.java @@ -26,6 +26,7 @@ import static com.yahoo.vespa.zookeeper.Configurator.zookeeperServerHostnames; public class ZooKeeperRunner implements Runnable { private static final Logger log = java.util.logging.Logger.getLogger(ZooKeeperRunner.class.getName()); + private static final Duration shutdownTimeout = Duration.ofSeconds(10); private final ExecutorService executorService; private final ZookeeperServerConfig zookeeperServerConfig; @@ -40,10 +41,12 @@ public class ZooKeeperRunner implements Runnable { } void shutdown() { + log.log(Level.INFO, "Triggering shutdown"); executorService.shutdownNow(); + log.log(Level.INFO, "Shutdown triggered"); try { - if (!executorService.awaitTermination(10000, TimeUnit.MILLISECONDS)) { - log.log(Level.WARNING, "Failed to shut down within timeout"); + if (!executorService.awaitTermination(shutdownTimeout.toMillis(), TimeUnit.MILLISECONDS)) { + log.log(Level.WARNING, "Failed to shut down within " + shutdownTimeout); } } catch (InterruptedException e) { log.log(Level.INFO, "Interrupted waiting for executor to complete", e); |