diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-01-20 14:35:26 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-01-20 14:35:26 +0100 |
commit | 60b6253e5096eef77bad716b8f1f3864fdf46c67 (patch) | |
tree | 41b057413b5eb135995f0a2907c2b00a7e683d0d /zkfacade | |
parent | 0c6b28ef310bb5714b8c2ba10651ae87068e9b59 (diff) |
Log curator state changes SUSPENDED, RECONNECTED and LOST
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java index d6be27a0919..d1246699ebc 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java @@ -34,6 +34,7 @@ import java.util.List; import java.util.Optional; import java.util.concurrent.ExecutorService; import java.util.function.Function; +import java.util.logging.Logger; /** * Curator interface for Vespa. @@ -47,6 +48,8 @@ import java.util.function.Function; */ public class Curator implements AutoCloseable { + private static final Logger logger = Logger.getLogger(Curator.class.getName()); + private static final int ZK_SESSION_TIMEOUT = 30000; private static final int ZK_CONNECTION_TIMEOUT = 30000; @@ -201,7 +204,11 @@ public class Curator implements AutoCloseable { // To avoid getting warning in log, see ticket 6389740 private void addFakeListener() { curatorFramework.getConnectionStateListenable().addListener((curatorFramework, connectionState) -> { - // empty, not needed now + switch (connectionState) { + case SUSPENDED: logger.info("ZK connection state change: SUSPENDED"); break; + case RECONNECTED: logger.info("ZK connection state change: RECONNECTED"); break; + case LOST: logger.warning("ZK connection state change: LOST"); break; + } }); } |