aboutsummaryrefslogtreecommitdiffstats
path: root/zkfacade
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-01-05 08:48:34 +0100
committerGitHub <noreply@github.com>2021-01-05 08:48:34 +0100
commitcc213410eb0c563247204e069bac3daa73f9c64e (patch)
tree15965855b60b503c8df7f486881b45adbda23e21 /zkfacade
parentaee8169ff21a049570b7423e100949d97d1c202a (diff)
Revert "Reapply "Upgrade to Curator 4""
Diffstat (limited to 'zkfacade')
-rw-r--r--zkfacade/pom.xml1
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java2
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java312
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/api/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/api/transaction/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/listen/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/recipes/atomic/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/recipes/barriers/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/recipes/cache/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/recipes/locks/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/framework/state/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/package-info.java2
-rw-r--r--zkfacade/src/main/java/org/apache/curator/retry/package-info.java2
14 files changed, 69 insertions, 268 deletions
diff --git a/zkfacade/pom.xml b/zkfacade/pom.xml
index 1c63513a04f..70079e53c78 100644
--- a/zkfacade/pom.xml
+++ b/zkfacade/pom.xml
@@ -54,7 +54,6 @@
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-test</artifactId>
- <version>4.2.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
index 90eec5760fc..30c4c624def 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
@@ -235,7 +235,7 @@ public class Curator implements VespaCurator, AutoCloseable {
*/
public void createAtomically(Path... paths) {
try {
- @SuppressWarnings("deprecation") CuratorTransaction transaction = framework().inTransaction();
+ CuratorTransaction transaction = framework().inTransaction();
for (Path path : paths) {
if ( ! exists(path)) {
transaction = transaction.create().forPath(path.getAbsolute(), new byte[0]).and();
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java
index 85d14ffbb05..9a845e56bfd 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java
@@ -11,40 +11,31 @@ import com.yahoo.vespa.curator.Curator;
import com.yahoo.vespa.curator.recipes.CuratorLockException;
import org.apache.curator.CuratorZookeeperClient;
import org.apache.curator.framework.CuratorFramework;
-import org.apache.curator.framework.WatcherRemoveCuratorFramework;
import org.apache.curator.framework.api.ACLBackgroundPathAndBytesable;
import org.apache.curator.framework.api.ACLCreateModeBackgroundPathAndBytesable;
import org.apache.curator.framework.api.ACLCreateModePathAndBytesable;
-import org.apache.curator.framework.api.ACLCreateModeStatBackgroundPathAndBytesable;
import org.apache.curator.framework.api.ACLPathAndBytesable;
-import org.apache.curator.framework.api.ACLableExistBuilderMain;
import org.apache.curator.framework.api.BackgroundCallback;
import org.apache.curator.framework.api.BackgroundPathAndBytesable;
import org.apache.curator.framework.api.BackgroundPathable;
import org.apache.curator.framework.api.BackgroundVersionable;
import org.apache.curator.framework.api.ChildrenDeletable;
-import org.apache.curator.framework.api.CreateBackgroundModeStatACLable;
+import org.apache.curator.framework.api.CreateBackgroundModeACLable;
import org.apache.curator.framework.api.CreateBuilder;
-import org.apache.curator.framework.api.CreateBuilder2;
-import org.apache.curator.framework.api.CreateBuilderMain;
-import org.apache.curator.framework.api.CreateProtectACLCreateModePathAndBytesable;
import org.apache.curator.framework.api.CuratorListener;
import org.apache.curator.framework.api.CuratorWatcher;
import org.apache.curator.framework.api.DeleteBuilder;
-import org.apache.curator.framework.api.DeleteBuilderMain;
import org.apache.curator.framework.api.ErrorListenerPathAndBytesable;
import org.apache.curator.framework.api.ErrorListenerPathable;
import org.apache.curator.framework.api.ExistsBuilder;
+import org.apache.curator.framework.api.ExistsBuilderMain;
import org.apache.curator.framework.api.GetACLBuilder;
import org.apache.curator.framework.api.GetChildrenBuilder;
-import org.apache.curator.framework.api.GetConfigBuilder;
import org.apache.curator.framework.api.GetDataBuilder;
import org.apache.curator.framework.api.GetDataWatchBackgroundStatable;
import org.apache.curator.framework.api.PathAndBytesable;
import org.apache.curator.framework.api.Pathable;
-import org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable;
-import org.apache.curator.framework.api.ReconfigBuilder;
-import org.apache.curator.framework.api.RemoveWatchesBuilder;
+import org.apache.curator.framework.api.ProtectACLCreateModePathAndBytesable;
import org.apache.curator.framework.api.SetACLBuilder;
import org.apache.curator.framework.api.SetDataBackgroundVersionable;
import org.apache.curator.framework.api.SetDataBuilder;
@@ -53,16 +44,13 @@ import org.apache.curator.framework.api.UnhandledErrorListener;
import org.apache.curator.framework.api.VersionPathAndBytesable;
import org.apache.curator.framework.api.WatchPathable;
import org.apache.curator.framework.api.Watchable;
-import org.apache.curator.framework.api.transaction.CuratorMultiTransaction;
import org.apache.curator.framework.api.transaction.CuratorTransaction;
import org.apache.curator.framework.api.transaction.CuratorTransactionBridge;
import org.apache.curator.framework.api.transaction.CuratorTransactionFinal;
import org.apache.curator.framework.api.transaction.CuratorTransactionResult;
import org.apache.curator.framework.api.transaction.TransactionCheckBuilder;
import org.apache.curator.framework.api.transaction.TransactionCreateBuilder;
-import org.apache.curator.framework.api.transaction.TransactionCreateBuilder2;
import org.apache.curator.framework.api.transaction.TransactionDeleteBuilder;
-import org.apache.curator.framework.api.transaction.TransactionOp;
import org.apache.curator.framework.api.transaction.TransactionSetDataBuilder;
import org.apache.curator.framework.imps.CuratorFrameworkState;
import org.apache.curator.framework.listen.Listenable;
@@ -75,8 +63,6 @@ import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
import org.apache.curator.framework.recipes.locks.InterProcessLock;
import org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex;
-import org.apache.curator.framework.schema.SchemaSet;
-import org.apache.curator.framework.state.ConnectionStateErrorPolicy;
import org.apache.curator.framework.state.ConnectionStateListener;
import org.apache.curator.retry.RetryForever;
import org.apache.curator.utils.EnsurePath;
@@ -85,7 +71,6 @@ import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Stat;
-import org.apache.zookeeper.server.quorum.flexible.QuorumVerifier;
import java.nio.file.Paths;
import java.time.Duration;
@@ -97,7 +82,6 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
-import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
@@ -200,57 +184,12 @@ public class MockCuratorFramework implements CuratorFramework {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
-
- @Override
- public ReconfigBuilder reconfig() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public GetConfigBuilder getConfig() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
@Override
public CuratorTransaction inTransaction() {
return new MockCuratorTransactionFinal();
}
@Override
- public CuratorMultiTransaction transaction() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public TransactionOp transactionOp() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public RemoveWatchesBuilder watches() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework() {
- class MockWatcherRemoveCuratorFramework extends MockCuratorFramework implements WatcherRemoveCuratorFramework {
-
- public MockWatcherRemoveCuratorFramework(boolean stableOrdering, boolean shouldTimeoutOnEnter) {
- super(stableOrdering, shouldTimeoutOnEnter);
- }
-
- @Override
- public void removeWatchers() {}
- }
- return new MockWatcherRemoveCuratorFramework(true, false);
- }
-
- @Override
- public ConnectionStateErrorPolicy getConnectionStateErrorPolicy() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public QuorumVerifier getCurrentConfig() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public SchemaSet getSchemaSet() { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
- public boolean isZk34CompatibilityMode() { return false; }
-
- @Override
- public CompletableFuture<Void> runSafe(Runnable runnable) { throw new UnsupportedOperationException("Not implemented in MockCurator"); }
-
- @Override
@Deprecated
public void sync(String path, Object backgroundContextObject) {
throw new UnsupportedOperationException("Not implemented in MockCurator");
@@ -325,7 +264,7 @@ public class MockCuratorFramework implements CuratorFramework {
// ----- Factory methods for mocks */
public InterProcessLock createMutex(String path) {
- return new MockLock(path);
+ return new MockCuratorFramework.MockLock(path);
}
public MockAtomicCounter createAtomicCounter(String path) {
@@ -333,7 +272,7 @@ public class MockCuratorFramework implements CuratorFramework {
}
public Curator.CompletionWaiter createCompletionWaiter() {
- return new MockCompletionWaiter();
+ return new MockCuratorFramework.MockCompletionWaiter();
}
public Curator.DirectoryCache createDirectoryCache(String path) {
@@ -458,7 +397,7 @@ public class MockCuratorFramework implements CuratorFramework {
}
} else if (c > '\u0000' && c < '\u001f' || c > '\u007f' && c < '\u009F'
|| c > '\ud800' && c < '\uf8ff' || c > '\ufff0' && c < '\uffff') {
- reason = "invalid character @" + i;
+ reason = "invalid charater @" + i;
break;
}
}
@@ -767,106 +706,68 @@ public class MockCuratorFramework implements CuratorFramework {
}
-
// ----- The rest of this file is adapting the Curator (non-recipe) API to the -----
// ----- file system methods above. -----
// ----- There's nothing to see unless you are interested in an illustration of -----
// ----- the folly of fluent API's or, more generally, mankind. -----
- private abstract static class MockProtectACLCreateModeStatPathAndBytesable<String>
- implements ProtectACLCreateModeStatPathAndBytesable<String> {
- public BackgroundPathAndBytesable<String> withACL(List<ACL> list) {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
+ private abstract static class MockBackgroundACLPathAndBytesableBuilder<T> implements PathAndBytesable<T>, ProtectACLCreateModePathAndBytesable<T> {
- public BackgroundPathAndBytesable<String> withACL(List<ACL> list, boolean b) {
+ public BackgroundPathAndBytesable<T> withACL(List<ACL> list) {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
- public ProtectACLCreateModeStatPathAndBytesable<String> withMode(CreateMode createMode) {
+ public ACLBackgroundPathAndBytesable<T> withMode(CreateMode createMode) {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
@Override
- public ACLCreateModeBackgroundPathAndBytesable<java.lang.String> withProtection() {
- return null;
- }
-
- @Override
- public ErrorListenerPathAndBytesable<String> inBackground() {
- return null;
- }
-
- @Override
- public ErrorListenerPathAndBytesable<String> inBackground(Object o) {
- return null;
- }
-
- @Override
- public ErrorListenerPathAndBytesable<String> inBackground(BackgroundCallback backgroundCallback) {
- return null;
- }
-
- @Override
- public ErrorListenerPathAndBytesable<String> inBackground(BackgroundCallback backgroundCallback, Object o) {
- return null;
- }
-
- @Override
- public ErrorListenerPathAndBytesable<String> inBackground(BackgroundCallback backgroundCallback, Executor executor) {
- return null;
+ public ACLCreateModeBackgroundPathAndBytesable<String> withProtection() {
+ throw new UnsupportedOperationException("Not implemented in MockCurator");
}
- @Override
- public ErrorListenerPathAndBytesable<String> inBackground(BackgroundCallback backgroundCallback, Object o, Executor executor) {
- return null;
+ public T forPath(String s, byte[] bytes) throws Exception {
+ throw new UnsupportedOperationException("Not implemented in MockCurator");
}
- @Override
- public ACLBackgroundPathAndBytesable<String> storingStatIn(Stat stat) {
- return null;
+ public T forPath(String s) throws Exception {
+ throw new UnsupportedOperationException("Not implemented in MockCurator");
}
}
- private class MockCreateBuilder implements CreateBuilder {
+ private class MockCreateBuilder extends MockBackgroundACLPathAndBytesableBuilder<String> implements CreateBuilder {
private boolean createParents = false;
private CreateMode createMode = CreateMode.PERSISTENT;
@Override
- public ProtectACLCreateModeStatPathAndBytesable<String> creatingParentsIfNeeded() {
+ public ProtectACLCreateModePathAndBytesable<String> creatingParentsIfNeeded() {
createParents = true;
- return new MockProtectACLCreateModeStatPathAndBytesable<>() {
-
- @Override
- public String forPath(String s, byte[] bytes) throws Exception {
- return createNode(s, bytes, createParents, createMode, fileSystem.root(), listeners);
- }
-
- @Override
- public String forPath(String s) throws Exception {
- return createNode(s, new byte[0], createParents, createMode, fileSystem.root(), listeners);
- }
-
- };
+ return this;
}
@Override
- public ProtectACLCreateModeStatPathAndBytesable<String> creatingParentContainersIfNeeded() {
- return new MockProtectACLCreateModeStatPathAndBytesable<>() {
+ public ACLCreateModeBackgroundPathAndBytesable<String> withProtection() {
+ // Protection against the server crashing after creating the file but before returning to the client.
+ // Not relevant for an in-memory mock, obviously
+ return this;
+ }
- @Override
- public String forPath(String s, byte[] bytes) throws Exception {
- return createNode(s, bytes, createParents, createMode, fileSystem.root(), listeners);
- }
+ public ACLBackgroundPathAndBytesable<String> withMode(CreateMode createMode) {
+ this.createMode = createMode;
+ return this;
+ }
- @Override
- public String forPath(String s) throws Exception {
- return createNode(s, new byte[0], createParents, createMode, fileSystem.root(), listeners);
- }
+ @Override
+ public CreateBackgroundModeACLable compressed() {
+ throw new UnsupportedOperationException("Not implemented in MockCurator");
+ }
- };
+ @Override
+ public ProtectACLCreateModePathAndBytesable<String> creatingParentContainersIfNeeded() {
+ // TODO: Add proper support for container nodes, see https://issues.apache.org/jira/browse/ZOOKEEPER-2163.
+ return creatingParentsIfNeeded();
}
@Override
@@ -875,11 +776,6 @@ public class MockCuratorFramework implements CuratorFramework {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
- @Override
- public ACLCreateModeStatBackgroundPathAndBytesable<String> withProtection() {
- return null;
- }
-
public String forPath(String s) throws Exception {
return createNode(s, new byte[0], createParents, createMode, fileSystem.root(), listeners);
}
@@ -917,47 +813,6 @@ public class MockCuratorFramework implements CuratorFramework {
public ErrorListenerPathAndBytesable<String> inBackground(BackgroundCallback backgroundCallback, Object o, Executor executor) {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
-
- @Override
- public CreateBuilderMain withTtl(long l) {
- return null;
- }
-
- @Override
- public CreateBuilder2 orSetData() {
- return null;
- }
-
- @Override
- public CreateBuilder2 orSetData(int i) {
- return null;
- }
-
- @Override
- public CreateBackgroundModeStatACLable compressed() {
- return null;
- }
-
- @Override
- public CreateProtectACLCreateModePathAndBytesable<String> storingStatIn(Stat stat) {
- return null;
- }
-
- @Override
- public BackgroundPathAndBytesable<String> withACL(List<ACL> list) {
- return null;
- }
-
- @Override
- public ACLBackgroundPathAndBytesable<String> withMode(CreateMode createMode) {
- this.createMode = createMode;
- return this;
- }
-
- @Override
- public BackgroundPathAndBytesable<String> withACL(List<ACL> list, boolean b) {
- return null;
- }
}
private static class MockBackgroundPathableBuilder<T> implements BackgroundPathable<T>, Watchable<BackgroundPathable<T>> {
@@ -1030,7 +885,7 @@ public class MockCuratorFramework implements CuratorFramework {
private class MockExistsBuilder extends MockBackgroundPathableBuilder<Stat> implements ExistsBuilder {
@Override
- public Stat forPath(String path) throws Exception {
+ public Stat forPath(String path) {
try {
MemoryFileSystem.Node node = getNode(path, fileSystem.root());
Stat stat = new Stat();
@@ -1043,12 +898,7 @@ public class MockCuratorFramework implements CuratorFramework {
}
@Override
- public ACLableExistBuilderMain creatingParentsIfNeeded() {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
-
- @Override
- public ACLableExistBuilderMain creatingParentContainersIfNeeded() {
+ public ExistsBuilderMain creatingParentContainersIfNeeded() {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
}
@@ -1078,10 +928,6 @@ public class MockCuratorFramework implements CuratorFramework {
return null;
}
- @Override
- public DeleteBuilderMain quietly() {
- return this;
- }
}
private class MockGetDataBuilder extends MockBackgroundPathableBuilder<byte[]> implements GetDataBuilder {
@@ -1091,48 +937,18 @@ public class MockCuratorFramework implements CuratorFramework {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
- public byte[] forPath(String path) throws Exception {
- return getData(path, fileSystem.root());
- }
-
@Override
- public ErrorListenerPathable<byte[]> inBackground() {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
-
- @Override
- public ErrorListenerPathable<byte[]> inBackground(Object o) {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
-
- @Override
- public ErrorListenerPathable<byte[]> inBackground(BackgroundCallback backgroundCallback) {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
-
- @Override
- public ErrorListenerPathable<byte[]> inBackground(BackgroundCallback backgroundCallback, Object o) {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
-
- @Override
- public ErrorListenerPathable<byte[]> inBackground(BackgroundCallback backgroundCallback, Executor executor) {
+ public WatchPathable<byte[]> storingStatIn(Stat stat) {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
- @Override
- public ErrorListenerPathable<byte[]> inBackground(BackgroundCallback backgroundCallback, Object o, Executor executor) {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
+ public byte[] forPath(String path) throws Exception {
+ return getData(path, fileSystem.root());
}
- @Override
- public WatchPathable<byte[]> storingStatIn(Stat stat) {
- throw new UnsupportedOperationException("Not implemented in MockCurator");
- }
}
- // extends MockBackgroundACLPathAndBytesableBuilder<Stat>
- private class MockSetDataBuilder implements SetDataBuilder {
+ private class MockSetDataBuilder extends MockBackgroundACLPathAndBytesableBuilder<Stat> implements SetDataBuilder {
@Override
public SetDataBackgroundVersionable compressed() {
@@ -1151,11 +967,6 @@ public class MockCuratorFramework implements CuratorFramework {
}
@Override
- public Stat forPath(String s) throws Exception {
- return null;
- }
-
- @Override
public ErrorListenerPathAndBytesable<Stat> inBackground() {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
@@ -1206,18 +1017,18 @@ public class MockCuratorFramework implements CuratorFramework {
private class MockCuratorTransactionFinal implements CuratorTransactionFinal {
/** The new directory root in which the transactional changes are made */
- private MemoryFileSystem.Node newRoot;
+ private final MemoryFileSystem.Node newRoot;
private boolean committed = false;
- private final DelayedListener delayedListener = new DelayedListener();
+ private final MockCuratorTransactionFinal.DelayedListener delayedListener = new MockCuratorTransactionFinal.DelayedListener();
public MockCuratorTransactionFinal() {
newRoot = fileSystem.root().clone();
}
@Override
- public Collection<CuratorTransactionResult> commit() throws Exception {
+ public Collection<CuratorTransactionResult> commit() {
fileSystem.replaceRoot(newRoot);
committed = true;
delayedListener.commit();
@@ -1227,19 +1038,19 @@ public class MockCuratorFramework implements CuratorFramework {
@Override
public TransactionCreateBuilder create() {
ensureNotCommitted();
- return new MockTransactionCreateBuilder();
+ return new MockCuratorTransactionFinal.MockTransactionCreateBuilder();
}
@Override
public TransactionDeleteBuilder delete() {
ensureNotCommitted();
- return new MockTransactionDeleteBuilder();
+ return new MockCuratorTransactionFinal.MockTransactionDeleteBuilder();
}
@Override
public TransactionSetDataBuilder setData() {
ensureNotCommitted();
- return new MockTransactionSetDataBuilder();
+ return new MockCuratorTransactionFinal.MockTransactionSetDataBuilder();
}
@Override
@@ -1257,6 +1068,11 @@ public class MockCuratorFramework implements CuratorFramework {
private CreateMode createMode = CreateMode.PERSISTENT;
@Override
+ public PathAndBytesable<CuratorTransactionBridge> withACL(List<ACL> list) {
+ throw new UnsupportedOperationException("Not implemented in MockCurator");
+ }
+
+ @Override
public ACLCreateModePathAndBytesable<CuratorTransactionBridge> compressed() {
throw new UnsupportedOperationException("Not implemented in MockCurator");
}
@@ -1270,29 +1086,15 @@ public class MockCuratorFramework implements CuratorFramework {
@Override
public CuratorTransactionBridge forPath(String s, byte[] bytes) throws Exception {
createNode(s, bytes, false, createMode, newRoot, delayedListener);
- return new MockCuratorTransactionBridge();
+ return new MockCuratorTransactionFinal.MockCuratorTransactionBridge();
}
@Override
public CuratorTransactionBridge forPath(String s) throws Exception {
createNode(s, new byte[0], false, createMode, newRoot, delayedListener);
- return new MockCuratorTransactionBridge();
+ return new MockCuratorTransactionFinal.MockCuratorTransactionBridge();
}
- @Override
- public TransactionCreateBuilder2 withTtl(long l) {
- return this;
- }
-
- @Override
- public Object withACL(List list, boolean b) {
- return this;
- }
-
- @Override
- public Object withACL(List list) {
- return this;
- }
}
private class MockTransactionDeleteBuilder implements TransactionDeleteBuilder {
@@ -1305,7 +1107,7 @@ public class MockCuratorFramework implements CuratorFramework {
@Override
public CuratorTransactionBridge forPath(String path) throws Exception {
deleteNode(path, false, newRoot, delayedListener);
- return new MockCuratorTransactionBridge();
+ return new MockCuratorTransactionFinal.MockCuratorTransactionBridge();
}
}
@@ -1325,13 +1127,13 @@ public class MockCuratorFramework implements CuratorFramework {
@Override
public CuratorTransactionBridge forPath(String s, byte[] bytes) throws Exception {
MockCuratorFramework.this.setData(s, bytes, newRoot, delayedListener);
- return new MockCuratorTransactionBridge();
+ return new MockCuratorTransactionFinal.MockCuratorTransactionBridge();
}
@Override
public CuratorTransactionBridge forPath(String s) throws Exception {
MockCuratorFramework.this.setData(s, new byte[0], newRoot, delayedListener);
- return new MockCuratorTransactionBridge();
+ return new MockCuratorTransactionFinal.MockCuratorTransactionBridge();
}
}
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/api/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/api/package-info.java
index e3da4ab3efa..be9e84013c1 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/api/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/api/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.api;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/api/transaction/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/api/transaction/package-info.java
index 94f8b12894e..be3ece0357b 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/api/transaction/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/api/transaction/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.api.transaction;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/listen/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/listen/package-info.java
index 71ee8ccfff0..79c67cedf75 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/listen/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/listen/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.listen;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/package-info.java
index 2999456bc9d..3e3b8433556 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/recipes/atomic/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/recipes/atomic/package-info.java
index dd1dd7a1899..a607d5dcda5 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/recipes/atomic/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/recipes/atomic/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.recipes.atomic;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/recipes/barriers/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/recipes/barriers/package-info.java
index 4e2aea367de..2db4beef75f 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/recipes/barriers/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/recipes/barriers/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.recipes.barriers;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/recipes/cache/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/recipes/cache/package-info.java
index ad6913d6381..0465bbf2039 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/recipes/cache/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/recipes/cache/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.recipes.cache;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/recipes/locks/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/recipes/locks/package-info.java
index 4307c09e30a..63b067bcffc 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/recipes/locks/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/recipes/locks/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.recipes.locks;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/framework/state/package-info.java b/zkfacade/src/main/java/org/apache/curator/framework/state/package-info.java
index 4a10e20318d..eec4f00ddb4 100644
--- a/zkfacade/src/main/java/org/apache/curator/framework/state/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/framework/state/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.framework.state;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/package-info.java b/zkfacade/src/main/java/org/apache/curator/package-info.java
index 232a5fd46f3..120aa4558d2 100644
--- a/zkfacade/src/main/java/org/apache/curator/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;
diff --git a/zkfacade/src/main/java/org/apache/curator/retry/package-info.java b/zkfacade/src/main/java/org/apache/curator/retry/package-info.java
index f45a0d927a5..98130481c4c 100644
--- a/zkfacade/src/main/java/org/apache/curator/retry/package-info.java
+++ b/zkfacade/src/main/java/org/apache/curator/retry/package-info.java
@@ -1,5 +1,5 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage(version = @Version(major = 4, minor = 3, micro = 0))
+@ExportPackage(version = @Version(major = 2, minor = 13, micro = 0))
package org.apache.curator.retry;
import com.yahoo.osgi.annotation.ExportPackage;
import com.yahoo.osgi.annotation.Version;