You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/11/19 18:43:21 UTC
[07/12] git commit: ACCUMULO-1889 mark ZKI as closed once close() is
called.
ACCUMULO-1889 mark ZKI as closed once close() is called.
Once a given ZKI has .close() called, mark that instance closed regardless of outstanding client count.
Signed-off-by: Eric Newton <er...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/ada41803
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/ada41803
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/ada41803
Branch: refs/heads/1.5.1-SNAPSHOT
Commit: ada4180379d46297c1531cf8065de5030d12953d
Parents: d8b4ba9
Author: Sean Busbey <bu...@clouderagovt.com>
Authored: Wed Nov 13 10:58:15 2013 -0600
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 19 12:30:24 2013 -0500
----------------------------------------------------------------------
.../java/org/apache/accumulo/core/client/ZooKeeperInstance.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/ada41803/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
----------------------------------------------------------------------
diff --git a/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java b/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
index 1dae711..069d217 100644
--- a/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
+++ b/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
@@ -306,8 +306,8 @@ public class ZooKeeperInstance implements Instance {
clientInstances.incrementAndGet();
throw new AccumuloException("Issues closing ZooKeeper.");
}
- closed = true;
}
+ closed = true;
}
@Override