You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ra...@apache.org on 2014/06/07 20:19:13 UTC
[15/50] [abbrv] initial stab at exception support
http://git-wip-us.apache.org/repos/asf/curator/blob/c6229cf2/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
----------------------------------------------------------------------
diff --git a/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java b/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
index ecc0457..e944176 100644
--- a/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
+++ b/curator-x-rpc/src/test/java/org/apache/curator/generated/CuratorService.java
@@ -36,47 +36,47 @@ public class CuratorService {
public interface Iface {
- public LockProjection acquireLock(CuratorProjection projection, String path, int maxWaitMs) throws org.apache.thrift.TException;
+ public LockProjection acquireLock(CuratorProjection projection, String path, int maxWaitMs) throws CuratorException, org.apache.thrift.TException;
public void closeCuratorProjection(CuratorProjection projection) throws org.apache.thrift.TException;
- public boolean closeGenericProjection(CuratorProjection curatorProjection, String id) throws org.apache.thrift.TException;
+ public boolean closeGenericProjection(CuratorProjection projection, String id) throws CuratorException, org.apache.thrift.TException;
- public OptionalPath createNode(CuratorProjection projection, CreateSpec spec) throws org.apache.thrift.TException;
+ public OptionalPath createNode(CuratorProjection projection, CreateSpec spec) throws CuratorException, org.apache.thrift.TException;
- public void deleteNode(CuratorProjection projection, DeleteSpec spec) throws org.apache.thrift.TException;
+ public void deleteNode(CuratorProjection projection, DeleteSpec spec) throws CuratorException, org.apache.thrift.TException;
- public OptionalStat exists(CuratorProjection projection, ExistsSpec spec) throws org.apache.thrift.TException;
+ public OptionalStat exists(CuratorProjection projection, ExistsSpec spec) throws CuratorException, org.apache.thrift.TException;
- public OptionalChildrenList getChildren(CuratorProjection projection, GetChildrenSpec spec) throws org.apache.thrift.TException;
+ public OptionalChildrenList getChildren(CuratorProjection projection, GetChildrenSpec spec) throws CuratorException, org.apache.thrift.TException;
- public ByteBuffer getData(CuratorProjection projection, GetDataSpec spec) throws org.apache.thrift.TException;
+ public ByteBuffer getData(CuratorProjection projection, GetDataSpec spec) throws CuratorException, org.apache.thrift.TException;
- public List<Participant> getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException;
+ public List<Participant> getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws CuratorException, org.apache.thrift.TException;
- public ChildData getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection) throws org.apache.thrift.TException;
+ public ChildData getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection) throws CuratorException, org.apache.thrift.TException;
- public List<ChildData> getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection) throws org.apache.thrift.TException;
+ public List<ChildData> getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection) throws CuratorException, org.apache.thrift.TException;
- public ChildData getPathChildrenCacheDataForPath(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, String path) throws org.apache.thrift.TException;
+ public ChildData getPathChildrenCacheDataForPath(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, String path) throws CuratorException, org.apache.thrift.TException;
- public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException;
+ public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws CuratorException, org.apache.thrift.TException;
public CuratorProjection newCuratorProjection(String connectionName) throws org.apache.thrift.TException;
public void pingCuratorProjection(CuratorProjection projection) throws org.apache.thrift.TException;
- public Stat setData(CuratorProjection projection, SetDataSpec spec) throws org.apache.thrift.TException;
+ public Stat setData(CuratorProjection projection, SetDataSpec spec) throws CuratorException, org.apache.thrift.TException;
- public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws org.apache.thrift.TException;
+ public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws CuratorException, org.apache.thrift.TException;
- public NodeCacheProjection startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial) throws org.apache.thrift.TException;
+ public NodeCacheProjection startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial) throws CuratorException, org.apache.thrift.TException;
- public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException;
+ public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws CuratorException, org.apache.thrift.TException;
- public PersistentEphemeralNodeProjection startPersistentEphemeralNode(CuratorProjection projection, String path, ByteBuffer data, PersistentEphemeralNodeMode mode) throws org.apache.thrift.TException;
+ public PersistentEphemeralNodeProjection startPersistentEphemeralNode(CuratorProjection projection, String path, ByteBuffer data, PersistentEphemeralNodeMode mode) throws CuratorException, org.apache.thrift.TException;
- public List<LeaseProjection> startSemaphore(CuratorProjection projection, String path, int acquireQty, int maxWaitMs, int maxLeases) throws org.apache.thrift.TException;
+ public List<LeaseProjection> startSemaphore(CuratorProjection projection, String path, int acquireQty, int maxWaitMs, int maxLeases) throws CuratorException, org.apache.thrift.TException;
}
@@ -86,7 +86,7 @@ public class CuratorService {
public void closeCuratorProjection(CuratorProjection projection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void closeGenericProjection(CuratorProjection curatorProjection, String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void closeGenericProjection(CuratorProjection projection, String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void createNode(CuratorProjection projection, CreateSpec spec, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -146,7 +146,7 @@ public class CuratorService {
super(iprot, oprot);
}
- public LockProjection acquireLock(CuratorProjection projection, String path, int maxWaitMs) throws org.apache.thrift.TException
+ public LockProjection acquireLock(CuratorProjection projection, String path, int maxWaitMs) throws CuratorException, org.apache.thrift.TException
{
send_acquireLock(projection, path, maxWaitMs);
return recv_acquireLock();
@@ -161,13 +161,16 @@ public class CuratorService {
sendBase("acquireLock", args);
}
- public LockProjection recv_acquireLock() throws org.apache.thrift.TException
+ public LockProjection recv_acquireLock() throws CuratorException, org.apache.thrift.TException
{
acquireLock_result result = new acquireLock_result();
receiveBase(result, "acquireLock");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "acquireLock failed: unknown result");
}
@@ -183,31 +186,34 @@ public class CuratorService {
sendBase("closeCuratorProjection", args);
}
- public boolean closeGenericProjection(CuratorProjection curatorProjection, String id) throws org.apache.thrift.TException
+ public boolean closeGenericProjection(CuratorProjection projection, String id) throws CuratorException, org.apache.thrift.TException
{
- send_closeGenericProjection(curatorProjection, id);
+ send_closeGenericProjection(projection, id);
return recv_closeGenericProjection();
}
- public void send_closeGenericProjection(CuratorProjection curatorProjection, String id) throws org.apache.thrift.TException
+ public void send_closeGenericProjection(CuratorProjection projection, String id) throws org.apache.thrift.TException
{
closeGenericProjection_args args = new closeGenericProjection_args();
- args.setCuratorProjection(curatorProjection);
+ args.setProjection(projection);
args.setId(id);
sendBase("closeGenericProjection", args);
}
- public boolean recv_closeGenericProjection() throws org.apache.thrift.TException
+ public boolean recv_closeGenericProjection() throws CuratorException, org.apache.thrift.TException
{
closeGenericProjection_result result = new closeGenericProjection_result();
receiveBase(result, "closeGenericProjection");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "closeGenericProjection failed: unknown result");
}
- public OptionalPath createNode(CuratorProjection projection, CreateSpec spec) throws org.apache.thrift.TException
+ public OptionalPath createNode(CuratorProjection projection, CreateSpec spec) throws CuratorException, org.apache.thrift.TException
{
send_createNode(projection, spec);
return recv_createNode();
@@ -221,17 +227,20 @@ public class CuratorService {
sendBase("createNode", args);
}
- public OptionalPath recv_createNode() throws org.apache.thrift.TException
+ public OptionalPath recv_createNode() throws CuratorException, org.apache.thrift.TException
{
createNode_result result = new createNode_result();
receiveBase(result, "createNode");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "createNode failed: unknown result");
}
- public void deleteNode(CuratorProjection projection, DeleteSpec spec) throws org.apache.thrift.TException
+ public void deleteNode(CuratorProjection projection, DeleteSpec spec) throws CuratorException, org.apache.thrift.TException
{
send_deleteNode(projection, spec);
recv_deleteNode();
@@ -245,14 +254,17 @@ public class CuratorService {
sendBase("deleteNode", args);
}
- public void recv_deleteNode() throws org.apache.thrift.TException
+ public void recv_deleteNode() throws CuratorException, org.apache.thrift.TException
{
deleteNode_result result = new deleteNode_result();
receiveBase(result, "deleteNode");
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
return;
}
- public OptionalStat exists(CuratorProjection projection, ExistsSpec spec) throws org.apache.thrift.TException
+ public OptionalStat exists(CuratorProjection projection, ExistsSpec spec) throws CuratorException, org.apache.thrift.TException
{
send_exists(projection, spec);
return recv_exists();
@@ -266,17 +278,20 @@ public class CuratorService {
sendBase("exists", args);
}
- public OptionalStat recv_exists() throws org.apache.thrift.TException
+ public OptionalStat recv_exists() throws CuratorException, org.apache.thrift.TException
{
exists_result result = new exists_result();
receiveBase(result, "exists");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "exists failed: unknown result");
}
- public OptionalChildrenList getChildren(CuratorProjection projection, GetChildrenSpec spec) throws org.apache.thrift.TException
+ public OptionalChildrenList getChildren(CuratorProjection projection, GetChildrenSpec spec) throws CuratorException, org.apache.thrift.TException
{
send_getChildren(projection, spec);
return recv_getChildren();
@@ -290,17 +305,20 @@ public class CuratorService {
sendBase("getChildren", args);
}
- public OptionalChildrenList recv_getChildren() throws org.apache.thrift.TException
+ public OptionalChildrenList recv_getChildren() throws CuratorException, org.apache.thrift.TException
{
getChildren_result result = new getChildren_result();
receiveBase(result, "getChildren");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getChildren failed: unknown result");
}
- public ByteBuffer getData(CuratorProjection projection, GetDataSpec spec) throws org.apache.thrift.TException
+ public ByteBuffer getData(CuratorProjection projection, GetDataSpec spec) throws CuratorException, org.apache.thrift.TException
{
send_getData(projection, spec);
return recv_getData();
@@ -314,17 +332,20 @@ public class CuratorService {
sendBase("getData", args);
}
- public ByteBuffer recv_getData() throws org.apache.thrift.TException
+ public ByteBuffer recv_getData() throws CuratorException, org.apache.thrift.TException
{
getData_result result = new getData_result();
receiveBase(result, "getData");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getData failed: unknown result");
}
- public List<Participant> getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException
+ public List<Participant> getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws CuratorException, org.apache.thrift.TException
{
send_getLeaderParticipants(projection, leaderProjection);
return recv_getLeaderParticipants();
@@ -338,17 +359,20 @@ public class CuratorService {
sendBase("getLeaderParticipants", args);
}
- public List<Participant> recv_getLeaderParticipants() throws org.apache.thrift.TException
+ public List<Participant> recv_getLeaderParticipants() throws CuratorException, org.apache.thrift.TException
{
getLeaderParticipants_result result = new getLeaderParticipants_result();
receiveBase(result, "getLeaderParticipants");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLeaderParticipants failed: unknown result");
}
- public ChildData getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection) throws org.apache.thrift.TException
+ public ChildData getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection) throws CuratorException, org.apache.thrift.TException
{
send_getNodeCacheData(projection, cacheProjection);
return recv_getNodeCacheData();
@@ -362,17 +386,20 @@ public class CuratorService {
sendBase("getNodeCacheData", args);
}
- public ChildData recv_getNodeCacheData() throws org.apache.thrift.TException
+ public ChildData recv_getNodeCacheData() throws CuratorException, org.apache.thrift.TException
{
getNodeCacheData_result result = new getNodeCacheData_result();
receiveBase(result, "getNodeCacheData");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNodeCacheData failed: unknown result");
}
- public List<ChildData> getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection) throws org.apache.thrift.TException
+ public List<ChildData> getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection) throws CuratorException, org.apache.thrift.TException
{
send_getPathChildrenCacheData(projection, cacheProjection);
return recv_getPathChildrenCacheData();
@@ -386,17 +413,20 @@ public class CuratorService {
sendBase("getPathChildrenCacheData", args);
}
- public List<ChildData> recv_getPathChildrenCacheData() throws org.apache.thrift.TException
+ public List<ChildData> recv_getPathChildrenCacheData() throws CuratorException, org.apache.thrift.TException
{
getPathChildrenCacheData_result result = new getPathChildrenCacheData_result();
receiveBase(result, "getPathChildrenCacheData");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPathChildrenCacheData failed: unknown result");
}
- public ChildData getPathChildrenCacheDataForPath(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, String path) throws org.apache.thrift.TException
+ public ChildData getPathChildrenCacheDataForPath(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, String path) throws CuratorException, org.apache.thrift.TException
{
send_getPathChildrenCacheDataForPath(projection, cacheProjection, path);
return recv_getPathChildrenCacheDataForPath();
@@ -411,17 +441,20 @@ public class CuratorService {
sendBase("getPathChildrenCacheDataForPath", args);
}
- public ChildData recv_getPathChildrenCacheDataForPath() throws org.apache.thrift.TException
+ public ChildData recv_getPathChildrenCacheDataForPath() throws CuratorException, org.apache.thrift.TException
{
getPathChildrenCacheDataForPath_result result = new getPathChildrenCacheDataForPath_result();
receiveBase(result, "getPathChildrenCacheDataForPath");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPathChildrenCacheDataForPath failed: unknown result");
}
- public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException
+ public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws CuratorException, org.apache.thrift.TException
{
send_isLeader(projection, leaderProjection);
return recv_isLeader();
@@ -435,13 +468,16 @@ public class CuratorService {
sendBase("isLeader", args);
}
- public boolean recv_isLeader() throws org.apache.thrift.TException
+ public boolean recv_isLeader() throws CuratorException, org.apache.thrift.TException
{
isLeader_result result = new isLeader_result();
receiveBase(result, "isLeader");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isLeader failed: unknown result");
}
@@ -480,7 +516,7 @@ public class CuratorService {
sendBase("pingCuratorProjection", args);
}
- public Stat setData(CuratorProjection projection, SetDataSpec spec) throws org.apache.thrift.TException
+ public Stat setData(CuratorProjection projection, SetDataSpec spec) throws CuratorException, org.apache.thrift.TException
{
send_setData(projection, spec);
return recv_setData();
@@ -494,17 +530,20 @@ public class CuratorService {
sendBase("setData", args);
}
- public Stat recv_setData() throws org.apache.thrift.TException
+ public Stat recv_setData() throws CuratorException, org.apache.thrift.TException
{
setData_result result = new setData_result();
receiveBase(result, "setData");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "setData failed: unknown result");
}
- public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws org.apache.thrift.TException
+ public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws CuratorException, org.apache.thrift.TException
{
send_startLeaderSelector(projection, path, participantId, waitForLeadershipMs);
return recv_startLeaderSelector();
@@ -520,17 +559,20 @@ public class CuratorService {
sendBase("startLeaderSelector", args);
}
- public LeaderResult recv_startLeaderSelector() throws org.apache.thrift.TException
+ public LeaderResult recv_startLeaderSelector() throws CuratorException, org.apache.thrift.TException
{
startLeaderSelector_result result = new startLeaderSelector_result();
receiveBase(result, "startLeaderSelector");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startLeaderSelector failed: unknown result");
}
- public NodeCacheProjection startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial) throws org.apache.thrift.TException
+ public NodeCacheProjection startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial) throws CuratorException, org.apache.thrift.TException
{
send_startNodeCache(projection, path, dataIsCompressed, buildInitial);
return recv_startNodeCache();
@@ -546,17 +588,20 @@ public class CuratorService {
sendBase("startNodeCache", args);
}
- public NodeCacheProjection recv_startNodeCache() throws org.apache.thrift.TException
+ public NodeCacheProjection recv_startNodeCache() throws CuratorException, org.apache.thrift.TException
{
startNodeCache_result result = new startNodeCache_result();
receiveBase(result, "startNodeCache");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startNodeCache failed: unknown result");
}
- public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException
+ public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws CuratorException, org.apache.thrift.TException
{
send_startPathChildrenCache(projection, path, cacheData, dataIsCompressed, startMode);
return recv_startPathChildrenCache();
@@ -573,17 +618,20 @@ public class CuratorService {
sendBase("startPathChildrenCache", args);
}
- public PathChildrenCacheProjection recv_startPathChildrenCache() throws org.apache.thrift.TException
+ public PathChildrenCacheProjection recv_startPathChildrenCache() throws CuratorException, org.apache.thrift.TException
{
startPathChildrenCache_result result = new startPathChildrenCache_result();
receiveBase(result, "startPathChildrenCache");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startPathChildrenCache failed: unknown result");
}
- public PersistentEphemeralNodeProjection startPersistentEphemeralNode(CuratorProjection projection, String path, ByteBuffer data, PersistentEphemeralNodeMode mode) throws org.apache.thrift.TException
+ public PersistentEphemeralNodeProjection startPersistentEphemeralNode(CuratorProjection projection, String path, ByteBuffer data, PersistentEphemeralNodeMode mode) throws CuratorException, org.apache.thrift.TException
{
send_startPersistentEphemeralNode(projection, path, data, mode);
return recv_startPersistentEphemeralNode();
@@ -599,17 +647,20 @@ public class CuratorService {
sendBase("startPersistentEphemeralNode", args);
}
- public PersistentEphemeralNodeProjection recv_startPersistentEphemeralNode() throws org.apache.thrift.TException
+ public PersistentEphemeralNodeProjection recv_startPersistentEphemeralNode() throws CuratorException, org.apache.thrift.TException
{
startPersistentEphemeralNode_result result = new startPersistentEphemeralNode_result();
receiveBase(result, "startPersistentEphemeralNode");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startPersistentEphemeralNode failed: unknown result");
}
- public List<LeaseProjection> startSemaphore(CuratorProjection projection, String path, int acquireQty, int maxWaitMs, int maxLeases) throws org.apache.thrift.TException
+ public List<LeaseProjection> startSemaphore(CuratorProjection projection, String path, int acquireQty, int maxWaitMs, int maxLeases) throws CuratorException, org.apache.thrift.TException
{
send_startSemaphore(projection, path, acquireQty, maxWaitMs, maxLeases);
return recv_startSemaphore();
@@ -626,13 +677,16 @@ public class CuratorService {
sendBase("startSemaphore", args);
}
- public List<LeaseProjection> recv_startSemaphore() throws org.apache.thrift.TException
+ public List<LeaseProjection> recv_startSemaphore() throws CuratorException, org.apache.thrift.TException
{
startSemaphore_result result = new startSemaphore_result();
receiveBase(result, "startSemaphore");
if (result.isSetSuccess()) {
return result.success;
}
+ if (result.ex1 != null) {
+ throw result.ex1;
+ }
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startSemaphore failed: unknown result");
}
@@ -682,7 +736,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public LockProjection getResult() throws org.apache.thrift.TException {
+ public LockProjection getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -723,32 +777,32 @@ public class CuratorService {
}
}
- public void closeGenericProjection(CuratorProjection curatorProjection, String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void closeGenericProjection(CuratorProjection projection, String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- closeGenericProjection_call method_call = new closeGenericProjection_call(curatorProjection, id, resultHandler, this, ___protocolFactory, ___transport);
+ closeGenericProjection_call method_call = new closeGenericProjection_call(projection, id, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class closeGenericProjection_call extends org.apache.thrift.async.TAsyncMethodCall {
- private CuratorProjection curatorProjection;
+ private CuratorProjection projection;
private String id;
- public closeGenericProjection_call(CuratorProjection curatorProjection, String id, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public closeGenericProjection_call(CuratorProjection projection, String id, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
- this.curatorProjection = curatorProjection;
+ this.projection = projection;
this.id = id;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeGenericProjection", org.apache.thrift.protocol.TMessageType.CALL, 0));
closeGenericProjection_args args = new closeGenericProjection_args();
- args.setCuratorProjection(curatorProjection);
+ args.setProjection(projection);
args.setId(id);
args.write(prot);
prot.writeMessageEnd();
}
- public boolean getResult() throws org.apache.thrift.TException {
+ public boolean getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -783,7 +837,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public OptionalPath getResult() throws org.apache.thrift.TException {
+ public OptionalPath getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -818,7 +872,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.thrift.TException {
+ public void getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -853,7 +907,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public OptionalStat getResult() throws org.apache.thrift.TException {
+ public OptionalStat getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -888,7 +942,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public OptionalChildrenList getResult() throws org.apache.thrift.TException {
+ public OptionalChildrenList getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -923,7 +977,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public ByteBuffer getResult() throws org.apache.thrift.TException {
+ public ByteBuffer getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -958,7 +1012,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public List<Participant> getResult() throws org.apache.thrift.TException {
+ public List<Participant> getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -993,7 +1047,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public ChildData getResult() throws org.apache.thrift.TException {
+ public ChildData getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1028,7 +1082,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public List<ChildData> getResult() throws org.apache.thrift.TException {
+ public List<ChildData> getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1066,7 +1120,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public ChildData getResult() throws org.apache.thrift.TException {
+ public ChildData getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1101,7 +1155,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public boolean getResult() throws org.apache.thrift.TException {
+ public boolean getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1199,7 +1253,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public Stat getResult() throws org.apache.thrift.TException {
+ public Stat getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1240,7 +1294,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public LeaderResult getResult() throws org.apache.thrift.TException {
+ public LeaderResult getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1281,7 +1335,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public NodeCacheProjection getResult() throws org.apache.thrift.TException {
+ public NodeCacheProjection getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1325,7 +1379,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public PathChildrenCacheProjection getResult() throws org.apache.thrift.TException {
+ public PathChildrenCacheProjection getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1366,7 +1420,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public PersistentEphemeralNodeProjection getResult() throws org.apache.thrift.TException {
+ public PersistentEphemeralNodeProjection getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1410,7 +1464,7 @@ public class CuratorService {
prot.writeMessageEnd();
}
- public List<LeaseProjection> getResult() throws org.apache.thrift.TException {
+ public List<LeaseProjection> getResult() throws CuratorException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
@@ -1472,7 +1526,11 @@ public class CuratorService {
public acquireLock_result getResult(I iface, acquireLock_args args) throws org.apache.thrift.TException {
acquireLock_result result = new acquireLock_result();
- result.success = iface.acquireLock(args.projection, args.path, args.maxWaitMs);
+ try {
+ result.success = iface.acquireLock(args.projection, args.path, args.maxWaitMs);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1511,8 +1569,12 @@ public class CuratorService {
public closeGenericProjection_result getResult(I iface, closeGenericProjection_args args) throws org.apache.thrift.TException {
closeGenericProjection_result result = new closeGenericProjection_result();
- result.success = iface.closeGenericProjection(args.curatorProjection, args.id);
- result.setSuccessIsSet(true);
+ try {
+ result.success = iface.closeGenericProjection(args.projection, args.id);
+ result.setSuccessIsSet(true);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1532,7 +1594,11 @@ public class CuratorService {
public createNode_result getResult(I iface, createNode_args args) throws org.apache.thrift.TException {
createNode_result result = new createNode_result();
- result.success = iface.createNode(args.projection, args.spec);
+ try {
+ result.success = iface.createNode(args.projection, args.spec);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1552,7 +1618,11 @@ public class CuratorService {
public deleteNode_result getResult(I iface, deleteNode_args args) throws org.apache.thrift.TException {
deleteNode_result result = new deleteNode_result();
- iface.deleteNode(args.projection, args.spec);
+ try {
+ iface.deleteNode(args.projection, args.spec);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1572,7 +1642,11 @@ public class CuratorService {
public exists_result getResult(I iface, exists_args args) throws org.apache.thrift.TException {
exists_result result = new exists_result();
- result.success = iface.exists(args.projection, args.spec);
+ try {
+ result.success = iface.exists(args.projection, args.spec);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1592,7 +1666,11 @@ public class CuratorService {
public getChildren_result getResult(I iface, getChildren_args args) throws org.apache.thrift.TException {
getChildren_result result = new getChildren_result();
- result.success = iface.getChildren(args.projection, args.spec);
+ try {
+ result.success = iface.getChildren(args.projection, args.spec);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1612,7 +1690,11 @@ public class CuratorService {
public getData_result getResult(I iface, getData_args args) throws org.apache.thrift.TException {
getData_result result = new getData_result();
- result.success = iface.getData(args.projection, args.spec);
+ try {
+ result.success = iface.getData(args.projection, args.spec);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1632,7 +1714,11 @@ public class CuratorService {
public getLeaderParticipants_result getResult(I iface, getLeaderParticipants_args args) throws org.apache.thrift.TException {
getLeaderParticipants_result result = new getLeaderParticipants_result();
- result.success = iface.getLeaderParticipants(args.projection, args.leaderProjection);
+ try {
+ result.success = iface.getLeaderParticipants(args.projection, args.leaderProjection);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1652,7 +1738,11 @@ public class CuratorService {
public getNodeCacheData_result getResult(I iface, getNodeCacheData_args args) throws org.apache.thrift.TException {
getNodeCacheData_result result = new getNodeCacheData_result();
- result.success = iface.getNodeCacheData(args.projection, args.cacheProjection);
+ try {
+ result.success = iface.getNodeCacheData(args.projection, args.cacheProjection);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1672,7 +1762,11 @@ public class CuratorService {
public getPathChildrenCacheData_result getResult(I iface, getPathChildrenCacheData_args args) throws org.apache.thrift.TException {
getPathChildrenCacheData_result result = new getPathChildrenCacheData_result();
- result.success = iface.getPathChildrenCacheData(args.projection, args.cacheProjection);
+ try {
+ result.success = iface.getPathChildrenCacheData(args.projection, args.cacheProjection);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1692,7 +1786,11 @@ public class CuratorService {
public getPathChildrenCacheDataForPath_result getResult(I iface, getPathChildrenCacheDataForPath_args args) throws org.apache.thrift.TException {
getPathChildrenCacheDataForPath_result result = new getPathChildrenCacheDataForPath_result();
- result.success = iface.getPathChildrenCacheDataForPath(args.projection, args.cacheProjection, args.path);
+ try {
+ result.success = iface.getPathChildrenCacheDataForPath(args.projection, args.cacheProjection, args.path);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1712,8 +1810,12 @@ public class CuratorService {
public isLeader_result getResult(I iface, isLeader_args args) throws org.apache.thrift.TException {
isLeader_result result = new isLeader_result();
- result.success = iface.isLeader(args.projection, args.leaderProjection);
- result.setSuccessIsSet(true);
+ try {
+ result.success = iface.isLeader(args.projection, args.leaderProjection);
+ result.setSuccessIsSet(true);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1772,7 +1874,11 @@ public class CuratorService {
public setData_result getResult(I iface, setData_args args) throws org.apache.thrift.TException {
setData_result result = new setData_result();
- result.success = iface.setData(args.projection, args.spec);
+ try {
+ result.success = iface.setData(args.projection, args.spec);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1792,7 +1898,11 @@ public class CuratorService {
public startLeaderSelector_result getResult(I iface, startLeaderSelector_args args) throws org.apache.thrift.TException {
startLeaderSelector_result result = new startLeaderSelector_result();
- result.success = iface.startLeaderSelector(args.projection, args.path, args.participantId, args.waitForLeadershipMs);
+ try {
+ result.success = iface.startLeaderSelector(args.projection, args.path, args.participantId, args.waitForLeadershipMs);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1812,7 +1922,11 @@ public class CuratorService {
public startNodeCache_result getResult(I iface, startNodeCache_args args) throws org.apache.thrift.TException {
startNodeCache_result result = new startNodeCache_result();
- result.success = iface.startNodeCache(args.projection, args.path, args.dataIsCompressed, args.buildInitial);
+ try {
+ result.success = iface.startNodeCache(args.projection, args.path, args.dataIsCompressed, args.buildInitial);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1832,7 +1946,11 @@ public class CuratorService {
public startPathChildrenCache_result getResult(I iface, startPathChildrenCache_args args) throws org.apache.thrift.TException {
startPathChildrenCache_result result = new startPathChildrenCache_result();
- result.success = iface.startPathChildrenCache(args.projection, args.path, args.cacheData, args.dataIsCompressed, args.startMode);
+ try {
+ result.success = iface.startPathChildrenCache(args.projection, args.path, args.cacheData, args.dataIsCompressed, args.startMode);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1852,7 +1970,11 @@ public class CuratorService {
public startPersistentEphemeralNode_result getResult(I iface, startPersistentEphemeralNode_args args) throws org.apache.thrift.TException {
startPersistentEphemeralNode_result result = new startPersistentEphemeralNode_result();
- result.success = iface.startPersistentEphemeralNode(args.projection, args.path, args.data, args.mode);
+ try {
+ result.success = iface.startPersistentEphemeralNode(args.projection, args.path, args.data, args.mode);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1872,7 +1994,11 @@ public class CuratorService {
public startSemaphore_result getResult(I iface, startSemaphore_args args) throws org.apache.thrift.TException {
startSemaphore_result result = new startSemaphore_result();
- result.success = iface.startSemaphore(args.projection, args.path, args.acquireQty, args.maxWaitMs, args.maxLeases);
+ try {
+ result.success = iface.startSemaphore(args.projection, args.path, args.acquireQty, args.maxWaitMs, args.maxLeases);
+ } catch (CuratorException ex1) {
+ result.ex1 = ex1;
+ }
return result;
}
}
@@ -1941,6 +2067,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
acquireLock_result result = new acquireLock_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2021,6 +2153,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
closeGenericProjection_result result = new closeGenericProjection_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2041,7 +2179,7 @@ public class CuratorService {
}
public void start(I iface, closeGenericProjection_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.closeGenericProjection(args.curatorProjection, args.id,resultHandler);
+ iface.closeGenericProjection(args.projection, args.id,resultHandler);
}
}
@@ -2072,6 +2210,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
createNode_result result = new createNode_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2122,6 +2266,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
deleteNode_result result = new deleteNode_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2173,6 +2323,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
exists_result result = new exists_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2224,6 +2380,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
getChildren_result result = new getChildren_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2275,6 +2437,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
getData_result result = new getData_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2326,6 +2494,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
getLeaderParticipants_result result = new getLeaderParticipants_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2377,6 +2551,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
getNodeCacheData_result result = new getNodeCacheData_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2428,6 +2608,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
getPathChildrenCacheData_result result = new getPathChildrenCacheData_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2479,6 +2665,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
getPathChildrenCacheDataForPath_result result = new getPathChildrenCacheDataForPath_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2531,6 +2723,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
isLeader_result result = new isLeader_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2661,6 +2859,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
setData_result result = new setData_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2712,6 +2916,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
startLeaderSelector_result result = new startLeaderSelector_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2763,6 +2973,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
startNodeCache_result result = new startNodeCache_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2814,6 +3030,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
startPathChildrenCache_result result = new startPathChildrenCache_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2865,6 +3087,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
startPersistentEphemeralNode_result result = new startPersistentEphemeralNode_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -2916,6 +3144,12 @@ public class CuratorService {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
startSemaphore_result result = new startSemaphore_result();
+ if (e instanceof CuratorException) {
+ result.ex1 = (CuratorException) e;
+ result.setEx1IsSet(true);
+ msg = result;
+ }
+ else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@@ -3503,6 +3737,7 @@ public class CuratorService {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("acquireLock_result");
private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
+ private static final org.apache.thrift.protocol.TField EX1_FIELD_DESC = new org.apache.thrift.protocol.TField("ex1", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -3511,10 +3746,12 @@ public class CuratorService {
}
public LockProjection success; // required
+ public CuratorException ex1; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- SUCCESS((short)0, "success");
+ SUCCESS((short)0, "success"),
+ EX1((short)1, "ex1");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -3531,6 +3768,8 @@ public class CuratorService {
switch(fieldId) {
case 0: // SUCCESS
return SUCCESS;
+ case 1: // EX1
+ return EX1;
default:
return null;
}
@@ -3576,6 +3815,8 @@ public class CuratorService {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, LockProjection.class)));
+ tmpMap.put(_Fields.EX1, new org.apache.thrift.meta_data.FieldMetaData("ex1", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(acquireLock_result.class, metaDataMap);
}
@@ -3584,10 +3825,12 @@ public class CuratorService {
}
public acquireLock_result(
- LockProjection success)
+ LockProjection success,
+ CuratorException ex1)
{
this();
this.success = success;
+ this.ex1 = ex1;
}
/**
@@ -3597,6 +3840,9 @@ public class CuratorService {
if (other.isSetSuccess()) {
this.success = new LockProjection(other.success);
}
+ if (other.isSetEx1()) {
+ this.ex1 = new CuratorException(other.ex1);
+ }
}
public acquireLock_result deepCopy() {
@@ -3606,6 +3852,7 @@ public class CuratorService {
@Override
public void clear() {
this.success = null;
+ this.ex1 = null;
}
public LockProjection getSuccess() {
@@ -3632,6 +3879,30 @@ public class CuratorService {
}
}
+ public CuratorException getEx1() {
+ return this.ex1;
+ }
+
+ public acquireLock_result setEx1(CuratorException ex1) {
+ this.ex1 = ex1;
+ return this;
+ }
+
+ public void unsetEx1() {
+ this.ex1 = null;
+ }
+
+ /** Returns true if field ex1 is set (has been assigned a value) and false otherwise */
+ public boolean isSetEx1() {
+ return this.ex1 != null;
+ }
+
+ public void setEx1IsSet(boolean value) {
+ if (!value) {
+ this.ex1 = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case SUCCESS:
@@ -3642,6 +3913,14 @@ public class CuratorService {
}
break;
+ case EX1:
+ if (value == null) {
+ unsetEx1();
+ } else {
+ setEx1((CuratorException)value);
+ }
+ break;
+
}
}
@@ -3650,6 +3929,9 @@ public class CuratorService {
case SUCCESS:
return getSuccess();
+ case EX1:
+ return getEx1();
+
}
throw new IllegalStateException();
}
@@ -3663,6 +3945,8 @@ public class CuratorService {
switch (field) {
case SUCCESS:
return isSetSuccess();
+ case EX1:
+ return isSetEx1();
}
throw new IllegalStateException();
}
@@ -3689,6 +3973,15 @@ public class CuratorService {
return false;
}
+ boolean this_present_ex1 = true && this.isSetEx1();
+ boolean that_present_ex1 = true && that.isSetEx1();
+ if (this_present_ex1 || that_present_ex1) {
+ if (!(this_present_ex1 && that_present_ex1))
+ return false;
+ if (!this.ex1.equals(that.ex1))
+ return false;
+ }
+
return true;
}
@@ -3715,6 +4008,16 @@ public class CuratorService {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetEx1()).compareTo(other.isSetEx1());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEx1()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ex1, other.ex1);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -3742,6 +4045,14 @@ public class CuratorService {
sb.append(this.success);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("ex1:");
+ if (this.ex1 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.ex1);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -3797,6 +4108,15 @@ public class CuratorService {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 1: // EX1
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.ex1 = new CuratorException();
+ struct.ex1.read(iprot);
+ struct.setEx1IsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -3817,6 +4137,11 @@ public class CuratorService {
struct.success.write(oprot);
oprot.writeFieldEnd();
}
+ if (struct.ex1 != null) {
+ oprot.writeFieldBegin(EX1_FIELD_DESC);
+ struct.ex1.write(oprot);
+ oprot.writeFieldEnd();
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -3838,21 +4163,32 @@ public class CuratorService {
if (struct.isSetSuccess()) {
optionals.set(0);
}
- oprot.writeBitSet(optionals, 1);
+ if (struct.isSetEx1()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
if (struct.isSetSuccess()) {
struct.success.write(oprot);
}
+ if (struct.isSetEx1()) {
+ struct.ex1.write(oprot);
+ }
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, acquireLock_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
+ BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.success = new LockProjection();
struct.success.read(iprot);
struct.setSuccessIsSet(true);
}
+ if (incoming.get(1)) {
+ struct.ex1 = new CuratorException();
+ struct.ex1.read(iprot);
+ struct.setEx1IsSet(true);
+ }
}
}
@@ -4220,7 +4556,7 @@ public class CuratorService {
public static class closeGenericProjection_args implements org.apache.thrift.TBase<closeGenericProjection_args, closeGenericProjection_args._Fields>, java.io.Serializable, Cloneable, Comparable<closeGenericProjection_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("closeGenericProjection_args");
- private static final org.apache.thrift.protocol.TField CURATOR_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("curatorProjection", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("projection", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
@@ -4229,12 +4565,12 @@ public class CuratorService {
schemes.put(TupleScheme.class, new closeGenericProjection_argsTupleSchemeFactory());
}
- public CuratorProjection curatorProjection; // required
+ public CuratorProjection projection; // required
public String id; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- CURATOR_PROJECTION((short)1, "curatorProjection"),
+ PROJECTION((short)1, "projection"),
ID((short)2, "id");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -4250,8 +4586,8 @@ public class CuratorService {
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 1: // CURATOR_PROJECTION
- return CURATOR_PROJECTION;
+ case 1: // PROJECTION
+ return PROJECTION;
case 2: // ID
return ID;
default:
@@ -4297,7 +4633,7 @@ public class CuratorService {
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.CURATOR_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("curatorProjection", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("projection", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CuratorProjection.class)));
tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
@@ -4309,11 +4645,11 @@ public class CuratorService {
}
public closeGenericProjection_args(
- CuratorProjection curatorProjection,
+ CuratorProjection projection,
String id)
{
this();
- this.curatorProjection = curatorProjection;
+ this.projection = projection;
this.id = id;
}
@@ -4321,8 +4657,8 @@ public class CuratorService {
* Performs a deep copy on <i>other</i>.
*/
public closeGenericProjection_args(closeGenericProjection_args other) {
- if (other.isSetCuratorProjection()) {
- this.curatorProjection = new CuratorProjection(other.curatorProjection);
+ if (other.isSetProjection()) {
+ this.projection = new CuratorProjection(other.projection);
}
if (other.isSetId()) {
this.id = other.id;
@@ -4335,31 +4671,31 @@ public class CuratorService {
@Override
public void clear() {
- this.curatorProjection = null;
+ this.projection = null;
this.id = null;
}
- public CuratorProjection getCuratorProjection() {
- return this.curatorProjection;
+ public CuratorProjection getProjection() {
+ return this.projection;
}
- public closeGenericProjection_args setCuratorProjection(CuratorProjection curatorProjection) {
- this.curatorProjection = curatorProjection;
+ public closeGenericProjection_args setProjection(CuratorProjection projection) {
+ this.projection = projection;
return this;
}
- public void unsetCuratorProjection() {
- this.curatorProjection = null;
+ public void unsetProjection() {
+ this.projection = null;
}
- /** Returns true if field curatorProjection is set (has been assigned a value) and false otherwise */
- public boolean isSetCuratorProjection() {
- return this.curatorProjection != null;
+ /** Returns true if field projection is set (has been assigned a value) and false otherwise */
+ public boolean isSetProjection() {
+ return this.projection != null;
}
- public void setCuratorProjectionIsSet(boolean value) {
+ public void setProjectionIsSet(boolean value) {
if (!value) {
- this.curatorProjection = null;
+ this.projection = null;
}
}
@@ -4389,11 +4725,11 @@ public class CuratorService {
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case CURATOR_PROJECTION:
+ case PROJECTION:
if (value == null) {
- unsetCuratorProjection();
+ unsetProjection();
} else {
- setCuratorProjection((CuratorProjection)value);
+ setProjection((CuratorProjection)value);
}
break;
@@ -4410,8 +4746,8 @@ public class CuratorService {
public Object getFieldValue(_Fields field) {
switch (field) {
- case CURATOR_PROJECTION:
- return getCuratorProjection();
+ case PROJECTION:
+ return getProjection();
case ID:
return getId();
@@ -4427,8 +4763,8 @@ public class CuratorService {
}
switch (field) {
- case CURATOR_PROJECTION:
- return isSetCuratorProjection();
+ case PROJECTION:
+ return isSetProjection();
case ID:
return isSetId();
}
@@ -4448,12 +4784,12 @@ public class CuratorService {
if (that == null)
return false;
- boolean this_present_curatorProjection = true && this.isSetCuratorProjection();
- boolean that_present_curatorProjection = true && that.isSetCuratorProjection();
- if (this_present_curatorProjection || that_present_curatorProjection) {
- if (!(this_present_curatorProjection && that_present_curatorProjection))
+ boolean this_present_projection = true && this.isSetProjection();
+ boolean that_present_projection = true && that.isSetProjection();
+ if (this_present_projection || that_present_projection) {
+ if (!(this_present_projection && that_present_projection))
return false;
- if (!this.curatorProjection.equals(that.curatorProjection))
+ if (!this.projection.equals(that.projection))
return false;
}
@@ -4482,12 +4818,12 @@ public class CuratorService {
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetCuratorProjection()).compareTo(other.isSetCuratorProjection());
+ lastComparison = Boolean.valueOf(isSetProjection()).compareTo(other.isSetProjection());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetCuratorProjection()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.curatorProjection, other.curatorProjection);
+ if (isSetProjection()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.projection, other.projection);
if (lastComparison != 0) {
return lastComparison;
}
@@ -4522,11 +4858,11 @@ public class CuratorService {
StringBuilder sb = new StringBuilder("closeGenericProjection_args(");
boolean first = true;
- sb.append("curatorProjection:");
- if (this.curatorProjection == null) {
+ sb.append("projection:");
+ if (this.projection == null) {
sb.append("null");
} else {
- sb.append(this.curatorProjection);
+ sb.append(this.projection);
}
first = false;
if (!first) sb.append(", ");
@@ -4544,8 +4880,8 @@ public class CuratorService {
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
- if (curatorProjection != null) {
- curatorProjection.validate();
+ if (projection != null) {
+ projection.validate();
}
}
@@ -4583,11 +4919,11 @@ public class CuratorService {
break;
}
switch (schemeField.id) {
- case 1: // CURATOR_PROJECTION
+ case 1: // PROJECTION
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.curatorProjection = new CuratorProjection();
- struct.curatorProjection.read(iprot);
- struct.setCuratorProjectionIsSet(true);
+ struct.projection = new CuratorProjection();
+ struct.projection.read(iprot);
+ struct.setProjectionIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -4615,9 +4951,9 @@ public class CuratorService {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- if (struct.curatorProjection != null) {
- oprot.writeFieldBegin(CURATOR_PROJECTION_FIELD_DESC);
- struct.curatorProjection.write(oprot);
+ if (struct.projection != null) {
+ oprot.writeFieldBegin(PROJECTION_FIELD_DESC);
+ struct.projection.write(oprot);
oprot.writeFieldEnd();
}
if (struct.id != null) {
@@ -4643,15 +4979,15 @@ public class CuratorService {
public void write(org.apache.thrift.protocol.TProtocol prot, closeGenericProjection_args struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
- if (struct.isSetCuratorProjection()) {
+ if (struct.isSetProjection()) {
optionals.set(0);
}
if (struct.isSetId()) {
optionals.set(1);
}
oprot.writeBitSet(optionals, 2);
- if (struct.isSetCuratorProjection()) {
- struct.curatorProjection.write(oprot);
+ if (struct.isSetProjection()) {
+ struct.projection.write(oprot);
}
if (struct.isSetId()) {
oprot.writeString(struct.id);
@@ -4663,9 +4999,9 @@ public class CuratorService {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
- struct.curatorProjection = new CuratorProjection();
- struct.curatorProjection.read(iprot);
- struct.setCuratorProjectionIsSet(true);
+ struct.projection = new CuratorProjection();
+ struct.projection.read(iprot);
+ struct.setProjectionIsSet(true);
}
if (incoming.get(1)) {
struct.id = iprot.readString();
@@ -4680,6 +5016,7 @@ public class CuratorService {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("closeGenericProjection_result");
private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.BOOL, (short)0);
+ private static final org.apache.thrift.protocol.TField EX1_FIELD_DESC = new org.apache.thrift.protocol.TField("ex1", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -4688,10 +5025,12 @@ public class CuratorService {
}
public boolean success; // required
+ public CuratorException ex1; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- SUCCESS((short)0, "success");
+ SUCCESS((short)0, "success"),
+ EX1((short)1, "ex1");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -4708,6 +5047,8 @@ public class CuratorService {
switch(fieldId) {
case 0: // SUCCESS
return SUCCESS;
+ case 1: // EX1
+ return EX1;
default:
return null;
}
@@ -4755,6 +5096,8 @@ public class CuratorService {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.EX1, new org.apache.thrift.meta_data.FieldMetaData("ex1", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(closeGenericProjection_result.class, metaDataMap);
}
@@ -4763,11 +5106,13 @@ public class CuratorService {
}
public closeGenericProjection_result(
- boolean success)
+ boolean success,
+ CuratorException ex1)
{
this();
this.success = success;
setSuccessIsSet(true);
+ this.ex1 = ex1;
}
/**
@@ -4776,6 +5121,9 @@ public class CuratorService {
public closeGenericProjection_result(closeGenericProjection_result other) {
__isset_bitfield = other.__isset_bitfield;
this.success = other.success;
+ if (other.isSetEx1()) {
+ this.ex1 = new CuratorException(other.ex1);
+ }
}
public closeGenericProjection_result deepCopy() {
@@ -4786,6 +5134,7 @@ public class CuratorService {
public void clear() {
setSuccessIsSet(false);
this.success = false;
+ this.ex1 = null;
}
public boolean isSuccess() {
@@ -4811,6 +5160,30 @@ public class CuratorService {
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
}
+ public CuratorException getEx1() {
+ return this.ex1;
+ }
+
+ public closeGenericProjection_result setEx1(CuratorException ex1) {
+ this.ex1 = ex1;
+ return this;
+ }
+
+ public void unsetEx1() {
+ this.ex1 = null;
+ }
+
+ /** Returns true if field ex1 is set (has been assigned a value) and false otherwise */
+ public boolean isSetEx1() {
+ return this.ex1 != null;
+ }
+
+ public void setEx1IsSet(boolean value) {
+ if (!value) {
+ this.ex1 = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case SUCCESS:
@@ -4821,6 +5194,14 @@ public class CuratorService {
}
break;
+ case EX1:
+ if (value == null) {
+ unsetEx1();
+ } else {
+ setEx1((CuratorException)value);
+ }
+ break;
+
}
}
@@ -4829,6 +5210,9 @@ public class CuratorService {
case SUCCESS:
return Boolean.valueOf(isSuccess());
+ case EX1:
+ return getEx1();
+
}
throw new IllegalStateException();
}
@@ -4842,6 +5226,8 @@ public class CuratorService {
switch (field) {
case SUCCESS:
return isSetSuccess();
+ case EX1:
+ return isSetEx1();
}
throw new IllegalStateException();
}
@@ -4868,6 +5254,15 @@ public class CuratorService {
return false;
}
+ boolean this_present_ex1 = true && this.isSetEx1();
+ boolean that_present_ex1 = true && that.isSetEx1();
+ if (this_present_ex1 || that_present_ex1) {
+ if (!(this_present_ex1 && that_present_ex1))
+ return false;
+ if (!this.ex1.equals(that.ex1))
+ return false;
+ }
+
return true;
}
@@ -4894,6 +5289,16 @@ public class CuratorService {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetEx1()).compareTo(other.isSetEx1());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEx1()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ex1, other.ex1);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -4917,6 +5322,14 @@ public class CuratorService {
sb.append("success:");
sb.append(this.success);
first = false;
+ if (!first) sb.append(", ");
+ sb.append("ex1:");
+ if (this.ex1 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.ex1);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -4970,6 +5383,15 @@ public class CuratorService {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 1: // EX1
+ if (schemeField.type == org.apache.thr
<TRUNCATED>