Github user Randgalt commented on a diff in the pull request:
https://github.com/apache/curator/pull/243#discussion_r155051103
--- 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);
--- End diff --
The leader latch code will create the path for you - there's no need for
this.
---
