Create if pathes need to be created.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/c905ca6b Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/c905ca6b Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/c905ca6b Branch: refs/heads/0.1.5 Commit: c905ca6b51385ac19e273874f8e875b2575d5751 Parents: 8868e24 Author: Aaron McCurry <[email protected]> Authored: Tue Apr 30 22:42:27 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Tue Apr 30 22:42:27 2013 -0400 ---------------------------------------------------------------------- .../apache/blur/manager/indexserver/SafeMode.java | 3 +++ 1 files changed, 3 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/c905ca6b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/SafeMode.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/SafeMode.java b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/SafeMode.java index f5392ce..155722f 100644 --- a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/SafeMode.java +++ b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/SafeMode.java @@ -26,6 +26,7 @@ import java.util.concurrent.TimeUnit; import org.apache.blur.log.Log; import org.apache.blur.log.LogFactory; +import org.apache.blur.zookeeper.ZkUtils; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.WatchedEvent; @@ -71,6 +72,8 @@ public class SafeMode { this.waitTime = waitTimeUnit.toMillis(waitTime); this.duplicateNodeTimeout = duplicateNodeTimeoutTimeUnit.toNanos(duplicateNodeTimeout); this.nodePath = nodePath; + ZkUtils.mkNodesStr(zooKeeper, nodePath); + ZkUtils.mkNodesStr(zooKeeper, lockPath); } public void registerNode(String node, byte[] data) throws KeeperException, InterruptedException {
