Searched refs:recoverableZooKeeper (Results 1 – 1 of 1) sorted by relevance
78 private RecoverableZooKeeper recoverableZooKeeper; field in ZooKeeperWatcher264 List<String> children = recoverableZooKeeper.getChildren(znode, false); in setZnodeAclsRecursive()271 recoverableZooKeeper.setAcl(znode, acls, -1); in setZnodeAclsRecursive()572 return recoverableZooKeeper; in getRecoverableZooKeeper()576 recoverableZooKeeper.reconnectAfterExpiration(); in reconnectAfterExpiration()674 if (this.recoverableZooKeeper != null) break; in connectionEvent()677 if (this.recoverableZooKeeper == null) { in connectionEvent()684 Long.toHexString(this.recoverableZooKeeper.getSessionId()); in connectionEvent()727 this.recoverableZooKeeper.sync(path, null, null); in sync()771 if (recoverableZooKeeper != null) { in close()[all …]