Github user Randgalt commented on a diff in the pull request:
https://github.com/apache/curator/pull/243#discussion_r155049498
--- Diff:
curator-recipes/src/test/java/org/apache/curator/framework/recipes/leader/testing/DummyLeaderLatch.java
---
@@ -0,0 +1,189 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.curator.framework.recipes.leader.testing;
+
+import static
org.apache.curator.framework.recipes.leader.LeaderLatch.CloseMode.NOTIFY_LEADER;
+
+import java.io.IOException;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import javax.xml.ws.Holder;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.leader.LeaderLatch;
+import org.apache.curator.framework.recipes.leader.LeaderLatchListener;
+import org.apache.curator.framework.recipes.leader.Participant;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.apache.curator.test.Timing;
+import org.apache.zookeeper.KeeperException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DummyLeaderLatch implements LeaderLatchListener{
+
+ public static class History{
+ private String id;
+ private boolean leader;
+
+ private History(String id, boolean leader){
+ this.id = id;
+ this.leader = leader;
+ }
+
+ public String getId(){
+ return id;
+ }
+
+ public boolean isLeader(){
+ return leader;
+ }
+
+ @Override
+ public String toString(){
+ return id + ": " + (leader ? "toLeader" : "notLeader");
+ }
+ }
+
+ private static final RetryPolicy RETRY_POLICY = new
ExponentialBackoffRetry(100, 3);
+ private static final String LATCH_PATH =
"/leader/dummy/leaderLatch";
+ private static final Logger LOGGER =
LoggerFactory.getLogger(DummyLeaderLatch.class);
+ private static LinkedList<History> history = new LinkedList<>();
+
+
+ private final LeaderLatch leaderLatch;
+ private final CuratorFramework curatorFramework;
+ private final AtomicBoolean leader = new AtomicBoolean(false);
+
+ public DummyLeaderLatch(final String connectionString,
+ final int
sessionTimeoutMs,
+ final int
connectionTimeoutMs,
+ final String
instanceId){
+
+ curatorFramework = CuratorFrameworkFactory.builder()
+ .retryPolicy(RETRY_POLICY)
+ .connectString(connectionString)
+ .sessionTimeoutMs(sessionTimeoutMs)
+ .connectionTimeoutMs(connectionTimeoutMs)
+ .build();
+ leaderLatch = new LeaderLatch(curatorFramework, LATCH_PATH,
instanceId, NOTIFY_LEADER);
+ leaderLatch.addListener(this);
+ }
+
+ public void start() throws Exception {
+ curatorFramework.start();
+ curatorFramework.blockUntilConnected();
+ createPath(LATCH_PATH);
+ leaderLatch.start();
+ }
+
+ /**
+ * Starts the service and waits until the latch already has a leader
that may be a different node.
+ */
+ public void startAndAwaitElection() throws Exception {
+ start();
+ existsLeader();
+ }
+
+ public void awaitElection() throws Exception {
+ while (!existsLeader()) {
+ Thread.sleep(100L);
+ }
+ }
+
+ public void awaitLeadershipLost() throws Exception {
+ while (existsLeader()) {
+ Thread.sleep(100L);
+ }
+ }
+
+ private boolean existsLeader() throws Exception {
+ for (Participant participant : leaderLatch.getParticipants()) {
+ if (participant.isLeader()) {
+ return true;
+ }
+ }
+ return false;
+ }
+
+
+ public void stop() throws IOException {
+ leaderLatch.close();
+ curatorFramework.close();
+ }
+
+ @Override
+ public void isLeader() {
+ synchronized (this){
+ leader.set(true);
+ history.add( new History(leaderLatch.getId(), true));
+ }
+ }
+
+ @Override
+ public void notLeader() {
+ synchronized (this){
+ leader.set(false);
+ history.add( new History(leaderLatch.getId(), false));
+ }
+ }
+
+ public boolean isLeaderAccordingToEvents(){
+ return leader.get();
+ }
+
+ public boolean isLeaderAccordingToLatch(){
+ return leaderLatch.hasLeadership();
+ }
+
+ public static List<History> getEventHistory(){
+ return history;
+ }
+
+ public static void resetHistory(){
+ history = new LinkedList<>();
+ }
+
+ /**
+ * Synchronously creates all nodes in a path in ZooKeeper if they don't
exist.
+ * <p>
+ * All API calls provided by Curator for path creation with parents do
async
+ *
+ * @param path the path
+ */
+ private void createPath(final String path) throws Exception {
+ final String[] split = path.split("/");
--- End diff --
why don't you use `create().creatingParentsIfNeeded()`?
---
