diff options
author | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2017-05-09 14:39:44 +0200 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2017-05-09 14:39:44 +0200 |
commit | db2d47878aab343b20f17c3464fbdfabc2433388 (patch) | |
tree | 7274fbaa3c85dd90ee4250dc5025dd2615bce203 /clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java | |
parent | e8eaefebe609ff18f99b4f4ff5edb151549cc1ba (diff) |
Log ZooKeeper cluster state version reads and writes with INFO level
Diffstat (limited to 'clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java')
-rw-r--r-- | clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java index 05cc3c20e76..015aff41d17 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/database/ZooKeeperDatabase.java @@ -185,7 +185,7 @@ public class ZooKeeperDatabase extends Database { public boolean storeLatestSystemStateVersion(int version) throws InterruptedException { byte data[] = Integer.toString(version).getBytes(utf8); try{ - log.log(LogLevel.DEBUG, "Fleetcontroller " + nodeIndex + ": Setting new latest cluster state version " + version); + log.log(LogLevel.INFO, String.format("Fleetcontroller %d: Storing new cluster state version in ZooKeeper: %d", nodeIndex, version)); session.setData(zooKeeperRoot + "latestversion", data, -1); return true; } catch (InterruptedException e) { @@ -205,7 +205,9 @@ public class ZooKeeperDatabase extends Database { try{ log.log(LogLevel.DEBUG, "Fleetcontroller " + nodeIndex + ": Fetching latest cluster state at '" + zooKeeperRoot + "latestversion'"); byte[] data = session.getData(zooKeeperRoot + "latestversion", false, stat); - return Integer.valueOf(new String(data, utf8)); + final Integer versionNumber = Integer.valueOf(new String(data, utf8)); + log.log(LogLevel.INFO, String.format("Fleetcontroller %d: Read cluster state version %d from ZooKeeper", nodeIndex, versionNumber)); + return versionNumber; } catch (InterruptedException e) { throw (InterruptedException) new InterruptedException("Interrupted").initCause(e); } catch (Exception e) { |