Return-Path: X-Original-To: apmail-curator-commits-archive@minotaur.apache.org Delivered-To: apmail-curator-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CB6BA101EE for ; Thu, 29 May 2014 20:54:22 +0000 (UTC) Received: (qmail 60542 invoked by uid 500); 29 May 2014 20:54:22 -0000 Delivered-To: apmail-curator-commits-archive@curator.apache.org Received: (qmail 60513 invoked by uid 500); 29 May 2014 20:54:22 -0000 Mailing-List: contact commits-help@curator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@curator.apache.org Delivered-To: mailing list commits@curator.apache.org Received: (qmail 60504 invoked by uid 99); 29 May 2014 20:54:22 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 29 May 2014 20:54:22 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 63CD850AD2; Thu, 29 May 2014 20:54:22 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: randgalt@apache.org To: commits@curator.apache.org Date: Thu, 29 May 2014 20:54:23 -0000 Message-Id: <2883139ff55846cfbdef0b0cad32de1d@git.apache.org> In-Reply-To: <1af54425e6a24e5696d569ab8229f499@git.apache.org> References: <1af54425e6a24e5696d569ab8229f499@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [2/7] some more leader methods - start of path children cache http://git-wip-us.apache.org/repos/asf/curator/blob/41ac42bb/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 38a29cc..aab8a8d 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 @@ -52,12 +52,18 @@ public class CuratorService { public ByteBuffer getData(CuratorProjection projection, GetDataSpec spec) throws org.apache.thrift.TException; + public List getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException; + + public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException; + public CuratorProjection newCuratorProjection(String connectionName) throws org.apache.thrift.TException; public Stat setData(CuratorProjection projection, SetDataSpec spec) throws org.apache.thrift.TException; public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws org.apache.thrift.TException; + public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException; + } public interface AsyncIface { @@ -78,12 +84,18 @@ public class CuratorService { public void getData(CuratorProjection projection, GetDataSpec spec, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void isLeader(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void newCuratorProjection(String connectionName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void setData(CuratorProjection projection, SetDataSpec spec, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + } public static class Client extends org.apache.thrift.TServiceClient implements Iface { @@ -292,6 +304,54 @@ public class CuratorService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getData failed: unknown result"); } + public List getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException + { + send_getLeaderParticipants(projection, leaderProjection); + return recv_getLeaderParticipants(); + } + + public void send_getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException + { + getLeaderParticipants_args args = new getLeaderParticipants_args(); + args.setProjection(projection); + args.setLeaderProjection(leaderProjection); + sendBase("getLeaderParticipants", args); + } + + public List recv_getLeaderParticipants() throws org.apache.thrift.TException + { + getLeaderParticipants_result result = new getLeaderParticipants_result(); + receiveBase(result, "getLeaderParticipants"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLeaderParticipants failed: unknown result"); + } + + public boolean isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException + { + send_isLeader(projection, leaderProjection); + return recv_isLeader(); + } + + public void send_isLeader(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException + { + isLeader_args args = new isLeader_args(); + args.setProjection(projection); + args.setLeaderProjection(leaderProjection); + sendBase("isLeader", args); + } + + public boolean recv_isLeader() throws org.apache.thrift.TException + { + isLeader_result result = new isLeader_result(); + receiveBase(result, "isLeader"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isLeader failed: unknown result"); + } + public CuratorProjection newCuratorProjection(String connectionName) throws org.apache.thrift.TException { send_newCuratorProjection(connectionName); @@ -365,6 +425,33 @@ public class CuratorService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startLeaderSelector failed: unknown result"); } + public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException + { + send_startPathChildrenCache(projection, path, cacheData, dataIsCompressed, startMode); + return recv_startPathChildrenCache(); + } + + public void send_startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException + { + startPathChildrenCache_args args = new startPathChildrenCache_args(); + args.setProjection(projection); + args.setPath(path); + args.setCacheData(cacheData); + args.setDataIsCompressed(dataIsCompressed); + args.setStartMode(startMode); + sendBase("startPathChildrenCache", args); + } + + public PathChildrenCacheProjection recv_startPathChildrenCache() throws org.apache.thrift.TException + { + startPathChildrenCache_result result = new startPathChildrenCache_result(); + receiveBase(result, "startPathChildrenCache"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startPathChildrenCache failed: unknown result"); + } + } public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { public static class Factory implements org.apache.thrift.async.TAsyncClientFactory { @@ -663,6 +750,76 @@ public class CuratorService { } } + public void getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getLeaderParticipants_call method_call = new getLeaderParticipants_call(projection, leaderProjection, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getLeaderParticipants_call extends org.apache.thrift.async.TAsyncMethodCall { + private CuratorProjection projection; + private LeaderProjection leaderProjection; + public getLeaderParticipants_call(CuratorProjection projection, LeaderProjection leaderProjection, 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.projection = projection; + this.leaderProjection = leaderProjection; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getLeaderParticipants", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getLeaderParticipants_args args = new getLeaderParticipants_args(); + args.setProjection(projection); + args.setLeaderProjection(leaderProjection); + args.write(prot); + prot.writeMessageEnd(); + } + + public List getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_getLeaderParticipants(); + } + } + + public void isLeader(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isLeader_call method_call = new isLeader_call(projection, leaderProjection, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isLeader_call extends org.apache.thrift.async.TAsyncMethodCall { + private CuratorProjection projection; + private LeaderProjection leaderProjection; + public isLeader_call(CuratorProjection projection, LeaderProjection leaderProjection, 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.projection = projection; + this.leaderProjection = leaderProjection; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isLeader", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isLeader_args args = new isLeader_args(); + args.setProjection(projection); + args.setLeaderProjection(leaderProjection); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isLeader(); + } + } + public void newCuratorProjection(String connectionName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); newCuratorProjection_call method_call = new newCuratorProjection_call(connectionName, resultHandler, this, ___protocolFactory, ___transport); @@ -771,6 +928,50 @@ public class CuratorService { } } + public void startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + startPathChildrenCache_call method_call = new startPathChildrenCache_call(projection, path, cacheData, dataIsCompressed, startMode, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class startPathChildrenCache_call extends org.apache.thrift.async.TAsyncMethodCall { + private CuratorProjection projection; + private String path; + private boolean cacheData; + private boolean dataIsCompressed; + private PathChildrenCacheStartMode startMode; + public startPathChildrenCache_call(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode, 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.projection = projection; + this.path = path; + this.cacheData = cacheData; + this.dataIsCompressed = dataIsCompressed; + this.startMode = startMode; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startPathChildrenCache", org.apache.thrift.protocol.TMessageType.CALL, 0)); + startPathChildrenCache_args args = new startPathChildrenCache_args(); + args.setProjection(projection); + args.setPath(path); + args.setCacheData(cacheData); + args.setDataIsCompressed(dataIsCompressed); + args.setStartMode(startMode); + args.write(prot); + prot.writeMessageEnd(); + } + + public PathChildrenCacheProjection getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_startPathChildrenCache(); + } + } + } public static class Processor extends org.apache.thrift.TBaseProcessor implements org.apache.thrift.TProcessor { @@ -792,9 +993,12 @@ public class CuratorService { processMap.put("exists", new exists()); processMap.put("getChildren", new getChildren()); processMap.put("getData", new getData()); + processMap.put("getLeaderParticipants", new getLeaderParticipants()); + processMap.put("isLeader", new isLeader()); processMap.put("newCuratorProjection", new newCuratorProjection()); processMap.put("setData", new setData()); processMap.put("startLeaderSelector", new startLeaderSelector()); + processMap.put("startPathChildrenCache", new startPathChildrenCache()); return processMap; } @@ -959,6 +1163,47 @@ public class CuratorService { } } + public static class getLeaderParticipants extends org.apache.thrift.ProcessFunction { + public getLeaderParticipants() { + super("getLeaderParticipants"); + } + + public getLeaderParticipants_args getEmptyArgsInstance() { + return new getLeaderParticipants_args(); + } + + protected boolean isOneway() { + return false; + } + + 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); + return result; + } + } + + public static class isLeader extends org.apache.thrift.ProcessFunction { + public isLeader() { + super("isLeader"); + } + + public isLeader_args getEmptyArgsInstance() { + return new isLeader_args(); + } + + protected boolean isOneway() { + return false; + } + + 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); + return result; + } + } + public static class newCuratorProjection extends org.apache.thrift.ProcessFunction { public newCuratorProjection() { super("newCuratorProjection"); @@ -1019,6 +1264,26 @@ public class CuratorService { } } + public static class startPathChildrenCache extends org.apache.thrift.ProcessFunction { + public startPathChildrenCache() { + super("startPathChildrenCache"); + } + + public startPathChildrenCache_args getEmptyArgsInstance() { + return new startPathChildrenCache_args(); + } + + protected boolean isOneway() { + return false; + } + + 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); + return result; + } + } + } public static class AsyncProcessor extends org.apache.thrift.TBaseAsyncProcessor { @@ -1040,9 +1305,12 @@ public class CuratorService { processMap.put("exists", new exists()); processMap.put("getChildren", new getChildren()); processMap.put("getData", new getData()); + processMap.put("getLeaderParticipants", new getLeaderParticipants()); + processMap.put("isLeader", new isLeader()); processMap.put("newCuratorProjection", new newCuratorProjection()); processMap.put("setData", new setData()); processMap.put("startLeaderSelector", new startLeaderSelector()); + processMap.put("startPathChildrenCache", new startPathChildrenCache()); return processMap; } @@ -1453,6 +1721,109 @@ public class CuratorService { } } + public static class getLeaderParticipants extends org.apache.thrift.AsyncProcessFunction> { + public getLeaderParticipants() { + super("getLeaderParticipants"); + } + + public getLeaderParticipants_args getEmptyArgsInstance() { + return new getLeaderParticipants_args(); + } + + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback>() { + public void onComplete(List o) { + getLeaderParticipants_result result = new getLeaderParticipants_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + getLeaderParticipants_result result = new getLeaderParticipants_result(); + { + 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()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, getLeaderParticipants_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.getLeaderParticipants(args.projection, args.leaderProjection,resultHandler); + } + } + + public static class isLeader extends org.apache.thrift.AsyncProcessFunction { + public isLeader() { + super("isLeader"); + } + + public isLeader_args getEmptyArgsInstance() { + return new isLeader_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Boolean o) { + isLeader_result result = new isLeader_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + isLeader_result result = new isLeader_result(); + { + 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()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, isLeader_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.isLeader(args.projection, args.leaderProjection,resultHandler); + } + } + public static class newCuratorProjection extends org.apache.thrift.AsyncProcessFunction { public newCuratorProjection() { super("newCuratorProjection"); @@ -1606,20 +1977,71 @@ public class CuratorService { } } - } - - public static class acquireLock_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("acquireLock_args"); - - 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 PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("path", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField MAX_WAIT_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxWaitMs", org.apache.thrift.protocol.TType.I32, (short)3); + public static class startPathChildrenCache extends org.apache.thrift.AsyncProcessFunction { + public startPathChildrenCache() { + super("startPathChildrenCache"); + } - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new acquireLock_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new acquireLock_argsTupleSchemeFactory()); - } + public startPathChildrenCache_args getEmptyArgsInstance() { + return new startPathChildrenCache_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(PathChildrenCacheProjection o) { + startPathChildrenCache_result result = new startPathChildrenCache_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + startPathChildrenCache_result result = new startPathChildrenCache_result(); + { + 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()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, startPathChildrenCache_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.startPathChildrenCache(args.projection, args.path, args.cacheData, args.dataIsCompressed, args.startMode,resultHandler); + } + } + + } + + public static class acquireLock_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("acquireLock_args"); + + 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 PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("path", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField MAX_WAIT_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxWaitMs", org.apache.thrift.protocol.TType.I32, (short)3); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new acquireLock_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new acquireLock_argsTupleSchemeFactory()); + } public CuratorProjection projection; // required public String path; // required @@ -7955,22 +8377,25 @@ public class CuratorService { } - public static class newCuratorProjection_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("newCuratorProjection_args"); + public static class getLeaderParticipants_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLeaderParticipants_args"); - private static final org.apache.thrift.protocol.TField CONNECTION_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("connectionName", org.apache.thrift.protocol.TType.STRING, (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 LEADER_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("leaderProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new newCuratorProjection_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new newCuratorProjection_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getLeaderParticipants_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getLeaderParticipants_argsTupleSchemeFactory()); } - public String connectionName; // required + public CuratorProjection projection; // required + public LeaderProjection leaderProjection; // 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 { - CONNECTION_NAME((short)1, "connectionName"); + PROJECTION((short)1, "projection"), + LEADER_PROJECTION((short)2, "leaderProjection"); private static final Map byName = new HashMap(); @@ -7985,8 +8410,10 @@ public class CuratorService { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 1: // CONNECTION_NAME - return CONNECTION_NAME; + case 1: // PROJECTION + return PROJECTION; + case 2: // LEADER_PROJECTION + return LEADER_PROJECTION; default: return null; } @@ -8030,71 +8457,111 @@ 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.CONNECTION_NAME, new org.apache.thrift.meta_data.FieldMetaData("connectionName", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + 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.LEADER_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("leaderProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, LeaderProjection.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(newCuratorProjection_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLeaderParticipants_args.class, metaDataMap); } - public newCuratorProjection_args() { + public getLeaderParticipants_args() { } - public newCuratorProjection_args( - String connectionName) + public getLeaderParticipants_args( + CuratorProjection projection, + LeaderProjection leaderProjection) { this(); - this.connectionName = connectionName; + this.projection = projection; + this.leaderProjection = leaderProjection; } /** * Performs a deep copy on other. */ - public newCuratorProjection_args(newCuratorProjection_args other) { - if (other.isSetConnectionName()) { - this.connectionName = other.connectionName; + public getLeaderParticipants_args(getLeaderParticipants_args other) { + if (other.isSetProjection()) { + this.projection = new CuratorProjection(other.projection); + } + if (other.isSetLeaderProjection()) { + this.leaderProjection = new LeaderProjection(other.leaderProjection); } } - public newCuratorProjection_args deepCopy() { - return new newCuratorProjection_args(this); + public getLeaderParticipants_args deepCopy() { + return new getLeaderParticipants_args(this); } @Override public void clear() { - this.connectionName = null; + this.projection = null; + this.leaderProjection = null; } - public String getConnectionName() { - return this.connectionName; + public CuratorProjection getProjection() { + return this.projection; } - public newCuratorProjection_args setConnectionName(String connectionName) { - this.connectionName = connectionName; + public getLeaderParticipants_args setProjection(CuratorProjection projection) { + this.projection = projection; return this; } - public void unsetConnectionName() { - this.connectionName = null; + public void unsetProjection() { + this.projection = null; } - /** Returns true if field connectionName is set (has been assigned a value) and false otherwise */ - public boolean isSetConnectionName() { - return this.connectionName != 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 setConnectionNameIsSet(boolean value) { + public void setProjectionIsSet(boolean value) { if (!value) { - this.connectionName = null; + this.projection = null; + } + } + + public LeaderProjection getLeaderProjection() { + return this.leaderProjection; + } + + public getLeaderParticipants_args setLeaderProjection(LeaderProjection leaderProjection) { + this.leaderProjection = leaderProjection; + return this; + } + + public void unsetLeaderProjection() { + this.leaderProjection = null; + } + + /** Returns true if field leaderProjection is set (has been assigned a value) and false otherwise */ + public boolean isSetLeaderProjection() { + return this.leaderProjection != null; + } + + public void setLeaderProjectionIsSet(boolean value) { + if (!value) { + this.leaderProjection = null; } } public void setFieldValue(_Fields field, Object value) { switch (field) { - case CONNECTION_NAME: + case PROJECTION: if (value == null) { - unsetConnectionName(); + unsetProjection(); } else { - setConnectionName((String)value); + setProjection((CuratorProjection)value); + } + break; + + case LEADER_PROJECTION: + if (value == null) { + unsetLeaderProjection(); + } else { + setLeaderProjection((LeaderProjection)value); } break; @@ -8103,8 +8570,11 @@ public class CuratorService { public Object getFieldValue(_Fields field) { switch (field) { - case CONNECTION_NAME: - return getConnectionName(); + case PROJECTION: + return getProjection(); + + case LEADER_PROJECTION: + return getLeaderProjection(); } throw new IllegalStateException(); @@ -8117,8 +8587,10 @@ public class CuratorService { } switch (field) { - case CONNECTION_NAME: - return isSetConnectionName(); + case PROJECTION: + return isSetProjection(); + case LEADER_PROJECTION: + return isSetLeaderProjection(); } throw new IllegalStateException(); } @@ -8127,21 +8599,30 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof newCuratorProjection_args) - return this.equals((newCuratorProjection_args)that); + if (that instanceof getLeaderParticipants_args) + return this.equals((getLeaderParticipants_args)that); return false; } - public boolean equals(newCuratorProjection_args that) { + public boolean equals(getLeaderParticipants_args that) { if (that == null) return false; - boolean this_present_connectionName = true && this.isSetConnectionName(); - boolean that_present_connectionName = true && that.isSetConnectionName(); - if (this_present_connectionName || that_present_connectionName) { - if (!(this_present_connectionName && that_present_connectionName)) + 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.connectionName.equals(that.connectionName)) + if (!this.projection.equals(that.projection)) + return false; + } + + boolean this_present_leaderProjection = true && this.isSetLeaderProjection(); + boolean that_present_leaderProjection = true && that.isSetLeaderProjection(); + if (this_present_leaderProjection || that_present_leaderProjection) { + if (!(this_present_leaderProjection && that_present_leaderProjection)) + return false; + if (!this.leaderProjection.equals(that.leaderProjection)) return false; } @@ -8154,19 +8635,29 @@ public class CuratorService { } @Override - public int compareTo(newCuratorProjection_args other) { + public int compareTo(getLeaderParticipants_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - lastComparison = Boolean.valueOf(isSetConnectionName()).compareTo(other.isSetConnectionName()); + lastComparison = Boolean.valueOf(isSetProjection()).compareTo(other.isSetProjection()); if (lastComparison != 0) { return lastComparison; } - if (isSetConnectionName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.connectionName, other.connectionName); + if (isSetProjection()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.projection, other.projection); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLeaderProjection()).compareTo(other.isSetLeaderProjection()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLeaderProjection()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.leaderProjection, other.leaderProjection); if (lastComparison != 0) { return lastComparison; } @@ -8188,14 +8679,22 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("newCuratorProjection_args("); + StringBuilder sb = new StringBuilder("getLeaderParticipants_args("); boolean first = true; - sb.append("connectionName:"); - if (this.connectionName == null) { + sb.append("projection:"); + if (this.projection == null) { sb.append("null"); } else { - sb.append(this.connectionName); + sb.append(this.projection); + } + first = false; + if (!first) sb.append(", "); + sb.append("leaderProjection:"); + if (this.leaderProjection == null) { + sb.append("null"); + } else { + sb.append(this.leaderProjection); } first = false; sb.append(")"); @@ -8205,6 +8704,12 @@ public class CuratorService { public void validate() throws org.apache.thrift.TException { // check for required fields // check for sub-struct validity + if (projection != null) { + projection.validate(); + } + if (leaderProjection != null) { + leaderProjection.validate(); + } } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { @@ -8223,15 +8728,15 @@ public class CuratorService { } } - private static class newCuratorProjection_argsStandardSchemeFactory implements SchemeFactory { - public newCuratorProjection_argsStandardScheme getScheme() { - return new newCuratorProjection_argsStandardScheme(); + private static class getLeaderParticipants_argsStandardSchemeFactory implements SchemeFactory { + public getLeaderParticipants_argsStandardScheme getScheme() { + return new getLeaderParticipants_argsStandardScheme(); } } - private static class newCuratorProjection_argsStandardScheme extends StandardScheme { + private static class getLeaderParticipants_argsStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, newCuratorProjection_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getLeaderParticipants_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -8241,10 +8746,20 @@ public class CuratorService { break; } switch (schemeField.id) { - case 1: // CONNECTION_NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.connectionName = iprot.readString(); - struct.setConnectionNameIsSet(true); + case 1: // PROJECTION + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.projection = new CuratorProjection(); + struct.projection.read(iprot); + struct.setProjectionIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // LEADER_PROJECTION + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.leaderProjection = new LeaderProjection(); + struct.leaderProjection.read(iprot); + struct.setLeaderProjectionIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -8260,13 +8775,18 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, newCuratorProjection_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getLeaderParticipants_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); - if (struct.connectionName != null) { - oprot.writeFieldBegin(CONNECTION_NAME_FIELD_DESC); - oprot.writeString(struct.connectionName); + if (struct.projection != null) { + oprot.writeFieldBegin(PROJECTION_FIELD_DESC); + struct.projection.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.leaderProjection != null) { + oprot.writeFieldBegin(LEADER_PROJECTION_FIELD_DESC); + struct.leaderProjection.write(oprot); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -8275,52 +8795,64 @@ public class CuratorService { } - private static class newCuratorProjection_argsTupleSchemeFactory implements SchemeFactory { - public newCuratorProjection_argsTupleScheme getScheme() { - return new newCuratorProjection_argsTupleScheme(); + private static class getLeaderParticipants_argsTupleSchemeFactory implements SchemeFactory { + public getLeaderParticipants_argsTupleScheme getScheme() { + return new getLeaderParticipants_argsTupleScheme(); } } - private static class newCuratorProjection_argsTupleScheme extends TupleScheme { + private static class getLeaderParticipants_argsTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); - if (struct.isSetConnectionName()) { + if (struct.isSetProjection()) { optionals.set(0); } - oprot.writeBitSet(optionals, 1); - if (struct.isSetConnectionName()) { - oprot.writeString(struct.connectionName); + if (struct.isSetLeaderProjection()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetProjection()) { + struct.projection.write(oprot); + } + if (struct.isSetLeaderProjection()) { + struct.leaderProjection.write(oprot); } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_args 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.connectionName = iprot.readString(); - struct.setConnectionNameIsSet(true); + struct.projection = new CuratorProjection(); + struct.projection.read(iprot); + struct.setProjectionIsSet(true); + } + if (incoming.get(1)) { + struct.leaderProjection = new LeaderProjection(); + struct.leaderProjection.read(iprot); + struct.setLeaderProjectionIsSet(true); } } } } - public static class newCuratorProjection_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("newCuratorProjection_result"); + public static class getLeaderParticipants_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getLeaderParticipants_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 SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new newCuratorProjection_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new newCuratorProjection_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getLeaderParticipants_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getLeaderParticipants_resultTupleSchemeFactory()); } - public CuratorProjection success; // required + public List success; // 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 { @@ -8385,16 +8917,17 @@ public class CuratorService { static { 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, CuratorProjection.class))); + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Participant.class)))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(newCuratorProjection_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getLeaderParticipants_result.class, metaDataMap); } - public newCuratorProjection_result() { + public getLeaderParticipants_result() { } - public newCuratorProjection_result( - CuratorProjection success) + public getLeaderParticipants_result( + List success) { this(); this.success = success; @@ -8403,14 +8936,18 @@ public class CuratorService { /** * Performs a deep copy on other. */ - public newCuratorProjection_result(newCuratorProjection_result other) { + public getLeaderParticipants_result(getLeaderParticipants_result other) { if (other.isSetSuccess()) { - this.success = new CuratorProjection(other.success); + List __this__success = new ArrayList(other.success.size()); + for (Participant other_element : other.success) { + __this__success.add(new Participant(other_element)); + } + this.success = __this__success; } } - public newCuratorProjection_result deepCopy() { - return new newCuratorProjection_result(this); + public getLeaderParticipants_result deepCopy() { + return new getLeaderParticipants_result(this); } @Override @@ -8418,11 +8955,26 @@ public class CuratorService { this.success = null; } - public CuratorProjection getSuccess() { + public int getSuccessSize() { + return (this.success == null) ? 0 : this.success.size(); + } + + public java.util.Iterator getSuccessIterator() { + return (this.success == null) ? null : this.success.iterator(); + } + + public void addToSuccess(Participant elem) { + if (this.success == null) { + this.success = new ArrayList(); + } + this.success.add(elem); + } + + public List getSuccess() { return this.success; } - public newCuratorProjection_result setSuccess(CuratorProjection success) { + public getLeaderParticipants_result setSuccess(List success) { this.success = success; return this; } @@ -8448,7 +9000,7 @@ public class CuratorService { if (value == null) { unsetSuccess(); } else { - setSuccess((CuratorProjection)value); + setSuccess((List)value); } break; @@ -8481,12 +9033,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof newCuratorProjection_result) - return this.equals((newCuratorProjection_result)that); + if (that instanceof getLeaderParticipants_result) + return this.equals((getLeaderParticipants_result)that); return false; } - public boolean equals(newCuratorProjection_result that) { + public boolean equals(getLeaderParticipants_result that) { if (that == null) return false; @@ -8508,7 +9060,7 @@ public class CuratorService { } @Override - public int compareTo(newCuratorProjection_result other) { + public int compareTo(getLeaderParticipants_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -8542,7 +9094,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("newCuratorProjection_result("); + StringBuilder sb = new StringBuilder("getLeaderParticipants_result("); boolean first = true; sb.append("success:"); @@ -8559,9 +9111,6 @@ public class CuratorService { public void validate() throws org.apache.thrift.TException { // check for required fields // check for sub-struct validity - if (success != null) { - success.validate(); - } } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { @@ -8580,15 +9129,15 @@ public class CuratorService { } } - private static class newCuratorProjection_resultStandardSchemeFactory implements SchemeFactory { - public newCuratorProjection_resultStandardScheme getScheme() { - return new newCuratorProjection_resultStandardScheme(); + private static class getLeaderParticipants_resultStandardSchemeFactory implements SchemeFactory { + public getLeaderParticipants_resultStandardScheme getScheme() { + return new getLeaderParticipants_resultStandardScheme(); } } - private static class newCuratorProjection_resultStandardScheme extends StandardScheme { + private static class getLeaderParticipants_resultStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, newCuratorProjection_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getLeaderParticipants_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -8599,9 +9148,19 @@ public class CuratorService { } switch (schemeField.id) { case 0: // SUCCESS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.success = new CuratorProjection(); - struct.success.read(iprot); + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list24 = iprot.readListBegin(); + struct.success = new ArrayList(_list24.size); + for (int _i25 = 0; _i25 < _list24.size; ++_i25) + { + Participant _elem26; + _elem26 = new Participant(); + _elem26.read(iprot); + struct.success.add(_elem26); + } + iprot.readListEnd(); + } struct.setSuccessIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -8618,13 +9177,20 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, newCuratorProjection_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getLeaderParticipants_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); if (struct.success != null) { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); - struct.success.write(oprot); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size())); + for (Participant _iter27 : struct.success) + { + _iter27.write(oprot); + } + oprot.writeListEnd(); + } oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -8633,16 +9199,16 @@ public class CuratorService { } - private static class newCuratorProjection_resultTupleSchemeFactory implements SchemeFactory { - public newCuratorProjection_resultTupleScheme getScheme() { - return new newCuratorProjection_resultTupleScheme(); + private static class getLeaderParticipants_resultTupleSchemeFactory implements SchemeFactory { + public getLeaderParticipants_resultTupleScheme getScheme() { + return new getLeaderParticipants_resultTupleScheme(); } } - private static class newCuratorProjection_resultTupleScheme extends TupleScheme { + private static class getLeaderParticipants_resultTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -8650,17 +9216,32 @@ public class CuratorService { } oprot.writeBitSet(optionals, 1); if (struct.isSetSuccess()) { - struct.success.write(oprot); + { + oprot.writeI32(struct.success.size()); + for (Participant _iter28 : struct.success) + { + _iter28.write(oprot); + } + } } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, newCuratorProjection_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getLeaderParticipants_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { - struct.success = new CuratorProjection(); - struct.success.read(iprot); + { + org.apache.thrift.protocol.TList _list29 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.success = new ArrayList(_list29.size); + for (int _i30 = 0; _i30 < _list29.size; ++_i30) + { + Participant _elem31; + _elem31 = new Participant(); + _elem31.read(iprot); + struct.success.add(_elem31); + } + } struct.setSuccessIsSet(true); } } @@ -8668,25 +9249,25 @@ public class CuratorService { } - public static class setData_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("setData_args"); + public static class isLeader_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isLeader_args"); 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 SPEC_FIELD_DESC = new org.apache.thrift.protocol.TField("spec", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField LEADER_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("leaderProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new setData_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new setData_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new isLeader_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new isLeader_argsTupleSchemeFactory()); } public CuratorProjection projection; // required - public SetDataSpec spec; // required + public LeaderProjection leaderProjection; // 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 { PROJECTION((short)1, "projection"), - SPEC((short)2, "spec"); + LEADER_PROJECTION((short)2, "leaderProjection"); private static final Map byName = new HashMap(); @@ -8703,8 +9284,8 @@ public class CuratorService { switch(fieldId) { case 1: // PROJECTION return PROJECTION; - case 2: // SPEC - return SPEC; + case 2: // LEADER_PROJECTION + return LEADER_PROJECTION; default: return null; } @@ -8750,51 +9331,51 @@ 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.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.SPEC, new org.apache.thrift.meta_data.FieldMetaData("spec", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SetDataSpec.class))); + tmpMap.put(_Fields.LEADER_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("leaderProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, LeaderProjection.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(setData_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_args.class, metaDataMap); } - public setData_args() { + public isLeader_args() { } - public setData_args( + public isLeader_args( CuratorProjection projection, - SetDataSpec spec) + LeaderProjection leaderProjection) { this(); this.projection = projection; - this.spec = spec; + this.leaderProjection = leaderProjection; } /** * Performs a deep copy on other. */ - public setData_args(setData_args other) { + public isLeader_args(isLeader_args other) { if (other.isSetProjection()) { this.projection = new CuratorProjection(other.projection); } - if (other.isSetSpec()) { - this.spec = new SetDataSpec(other.spec); + if (other.isSetLeaderProjection()) { + this.leaderProjection = new LeaderProjection(other.leaderProjection); } } - public setData_args deepCopy() { - return new setData_args(this); + public isLeader_args deepCopy() { + return new isLeader_args(this); } @Override public void clear() { this.projection = null; - this.spec = null; + this.leaderProjection = null; } public CuratorProjection getProjection() { return this.projection; } - public setData_args setProjection(CuratorProjection projection) { + public isLeader_args setProjection(CuratorProjection projection) { this.projection = projection; return this; } @@ -8814,27 +9395,27 @@ public class CuratorService { } } - public SetDataSpec getSpec() { - return this.spec; + public LeaderProjection getLeaderProjection() { + return this.leaderProjection; } - public setData_args setSpec(SetDataSpec spec) { - this.spec = spec; + public isLeader_args setLeaderProjection(LeaderProjection leaderProjection) { + this.leaderProjection = leaderProjection; return this; } - public void unsetSpec() { - this.spec = null; + public void unsetLeaderProjection() { + this.leaderProjection = null; } - /** Returns true if field spec is set (has been assigned a value) and false otherwise */ - public boolean isSetSpec() { - return this.spec != null; + /** Returns true if field leaderProjection is set (has been assigned a value) and false otherwise */ + public boolean isSetLeaderProjection() { + return this.leaderProjection != null; } - public void setSpecIsSet(boolean value) { + public void setLeaderProjectionIsSet(boolean value) { if (!value) { - this.spec = null; + this.leaderProjection = null; } } @@ -8848,11 +9429,11 @@ public class CuratorService { } break; - case SPEC: + case LEADER_PROJECTION: if (value == null) { - unsetSpec(); + unsetLeaderProjection(); } else { - setSpec((SetDataSpec)value); + setLeaderProjection((LeaderProjection)value); } break; @@ -8864,8 +9445,8 @@ public class CuratorService { case PROJECTION: return getProjection(); - case SPEC: - return getSpec(); + case LEADER_PROJECTION: + return getLeaderProjection(); } throw new IllegalStateException(); @@ -8880,8 +9461,8 @@ public class CuratorService { switch (field) { case PROJECTION: return isSetProjection(); - case SPEC: - return isSetSpec(); + case LEADER_PROJECTION: + return isSetLeaderProjection(); } throw new IllegalStateException(); } @@ -8890,12 +9471,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof setData_args) - return this.equals((setData_args)that); + if (that instanceof isLeader_args) + return this.equals((isLeader_args)that); return false; } - public boolean equals(setData_args that) { + public boolean equals(isLeader_args that) { if (that == null) return false; @@ -8908,12 +9489,12 @@ public class CuratorService { return false; } - boolean this_present_spec = true && this.isSetSpec(); - boolean that_present_spec = true && that.isSetSpec(); - if (this_present_spec || that_present_spec) { - if (!(this_present_spec && that_present_spec)) + boolean this_present_leaderProjection = true && this.isSetLeaderProjection(); + boolean that_present_leaderProjection = true && that.isSetLeaderProjection(); + if (this_present_leaderProjection || that_present_leaderProjection) { + if (!(this_present_leaderProjection && that_present_leaderProjection)) return false; - if (!this.spec.equals(that.spec)) + if (!this.leaderProjection.equals(that.leaderProjection)) return false; } @@ -8926,7 +9507,7 @@ public class CuratorService { } @Override - public int compareTo(setData_args other) { + public int compareTo(isLeader_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -8943,12 +9524,12 @@ public class CuratorService { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetSpec()).compareTo(other.isSetSpec()); + lastComparison = Boolean.valueOf(isSetLeaderProjection()).compareTo(other.isSetLeaderProjection()); if (lastComparison != 0) { return lastComparison; } - if (isSetSpec()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.spec, other.spec); + if (isSetLeaderProjection()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.leaderProjection, other.leaderProjection); if (lastComparison != 0) { return lastComparison; } @@ -8970,7 +9551,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("setData_args("); + StringBuilder sb = new StringBuilder("isLeader_args("); boolean first = true; sb.append("projection:"); @@ -8981,11 +9562,11 @@ public class CuratorService { } first = false; if (!first) sb.append(", "); - sb.append("spec:"); - if (this.spec == null) { + sb.append("leaderProjection:"); + if (this.leaderProjection == null) { sb.append("null"); } else { - sb.append(this.spec); + sb.append(this.leaderProjection); } first = false; sb.append(")"); @@ -8998,8 +9579,8 @@ public class CuratorService { if (projection != null) { projection.validate(); } - if (spec != null) { - spec.validate(); + if (leaderProjection != null) { + leaderProjection.validate(); } } @@ -9019,15 +9600,15 @@ public class CuratorService { } } - private static class setData_argsStandardSchemeFactory implements SchemeFactory { - public setData_argsStandardScheme getScheme() { - return new setData_argsStandardScheme(); + private static class isLeader_argsStandardSchemeFactory implements SchemeFactory { + public isLeader_argsStandardScheme getScheme() { + return new isLeader_argsStandardScheme(); } } - private static class setData_argsStandardScheme extends StandardScheme { + private static class isLeader_argsStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, setData_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, isLeader_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -9046,11 +9627,11 @@ public class CuratorService { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 2: // SPEC + case 2: // LEADER_PROJECTION if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.spec = new SetDataSpec(); - struct.spec.read(iprot); - struct.setSpecIsSet(true); + struct.leaderProjection = new LeaderProjection(); + struct.leaderProjection.read(iprot); + struct.setLeaderProjectionIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -9066,7 +9647,7 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, setData_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, isLeader_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -9075,9 +9656,9 @@ public class CuratorService { struct.projection.write(oprot); oprot.writeFieldEnd(); } - if (struct.spec != null) { - oprot.writeFieldBegin(SPEC_FIELD_DESC); - struct.spec.write(oprot); + if (struct.leaderProjection != null) { + oprot.writeFieldBegin(LEADER_PROJECTION_FIELD_DESC); + struct.leaderProjection.write(oprot); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -9086,35 +9667,35 @@ public class CuratorService { } - private static class setData_argsTupleSchemeFactory implements SchemeFactory { - public setData_argsTupleScheme getScheme() { - return new setData_argsTupleScheme(); + private static class isLeader_argsTupleSchemeFactory implements SchemeFactory { + public isLeader_argsTupleScheme getScheme() { + return new isLeader_argsTupleScheme(); } } - private static class setData_argsTupleScheme extends TupleScheme { + private static class isLeader_argsTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, setData_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetProjection()) { optionals.set(0); } - if (struct.isSetSpec()) { + if (struct.isSetLeaderProjection()) { optionals.set(1); } oprot.writeBitSet(optionals, 2); if (struct.isSetProjection()) { struct.projection.write(oprot); } - if (struct.isSetSpec()) { - struct.spec.write(oprot); + if (struct.isSetLeaderProjection()) { + struct.leaderProjection.write(oprot); } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, setData_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -9123,27 +9704,27 @@ public class CuratorService { struct.setProjectionIsSet(true); } if (incoming.get(1)) { - struct.spec = new SetDataSpec(); - struct.spec.read(iprot); - struct.setSpecIsSet(true); + struct.leaderProjection = new LeaderProjection(); + struct.leaderProjection.read(iprot); + struct.setLeaderProjectionIsSet(true); } } } } - public static class setData_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("setData_result"); + public static class isLeader_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isLeader_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 SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.BOOL, (short)0); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new setData_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new setData_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new isLeader_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new isLeader_resultTupleSchemeFactory()); } - public Stat success; // required + public boolean success; // 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 { @@ -9204,65 +9785,67 @@ public class CuratorService { } // isset id assignments + private static final int __SUCCESS_ISSET_ID = 0; + private byte __isset_bitfield = 0; 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.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, Stat.class))); + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(setData_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_result.class, metaDataMap); } - public setData_result() { + public isLeader_result() { } - public setData_result( - Stat success) + public isLeader_result( + boolean success) { this(); this.success = success; + setSuccessIsSet(true); } /** * Performs a deep copy on other. */ - public setData_result(setData_result other) { - if (other.isSetSuccess()) { - this.success = new Stat(other.success); - } + public isLeader_result(isLeader_result other) { + __isset_bitfield = other.__isset_bitfield; + this.success = other.success; } - public setData_result deepCopy() { - return new setData_result(this); + public isLeader_result deepCopy() { + return new isLeader_result(this); } @Override public void clear() { - this.success = null; + setSuccessIsSet(false); + this.success = false; } - public Stat getSuccess() { + public boolean isSuccess() { return this.success; } - public setData_result setSuccess(Stat success) { + public isLeader_result setSuccess(boolean success) { this.success = success; + setSuccessIsSet(true); return this; } public void unsetSuccess() { - this.success = null; + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID); } /** Returns true if field success is set (has been assigned a value) and false otherwise */ public boolean isSetSuccess() { - return this.success != null; + return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID); } public void setSuccessIsSet(boolean value) { - if (!value) { - this.success = null; - } + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value); } public void setFieldValue(_Fields field, Object value) { @@ -9271,7 +9854,7 @@ public class CuratorService { if (value == null) { unsetSuccess(); } else { - setSuccess((Stat)value); + setSuccess((Boolean)value); } break; @@ -9281,7 +9864,7 @@ public class CuratorService { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return getSuccess(); + return Boolean.valueOf(isSuccess()); } throw new IllegalStateException(); @@ -9304,21 +9887,21 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof setData_result) - return this.equals((setData_result)that); + if (that instanceof isLeader_result) + return this.equals((isLeader_result)that); return false; } - public boolean equals(setData_result that) { + public boolean equals(isLeader_result that) { if (that == null) return false; - boolean this_present_success = true && this.isSetSuccess(); - boolean that_present_success = true && that.isSetSuccess(); + boolean this_present_success = true; + boolean that_present_success = true; if (this_present_success || that_present_success) { if (!(this_present_success && that_present_success)) return false; - if (!this.success.equals(that.success)) + if (this.success != that.success) return false; } @@ -9331,7 +9914,7 @@ public class CuratorService { } @Override - public int compareTo(setData_result other) { + public int compareTo(isLeader_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -9365,15 +9948,11 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("setData_result("); + StringBuilder sb = new StringBuilder("isLeader_result("); boolean first = true; sb.append("success:"); - if (this.success == null) { - sb.append("null"); - } else { - sb.append(this.success); - } + sb.append(this.success); first = false; sb.append(")"); return sb.toString(); @@ -9382,9 +9961,6 @@ public class CuratorService { public void validate() throws org.apache.thrift.TException { // check for required fields // check for sub-struct validity - if (success != null) { - success.validate(); - } } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { @@ -9397,21 +9973,23 @@ public class CuratorService { private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); } catch (org.apache.thrift.TException te) { throw new java.io.IOException(te); } } - private static class setData_resultStandardSchemeFactory implements SchemeFactory { - public setData_resultStandardScheme getScheme() { - return new setData_resultStandardScheme(); + private static class isLeader_resultStandardSchemeFactory implements SchemeFactory { + public isLeader_resultStandardScheme getScheme() { + return new isLeader_resultStandardScheme(); } } - private static class setData_resultStandardScheme extends StandardScheme { + private static class isLeader_resultStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, setData_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, isLeader_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -9422,9 +10000,8 @@ public class CuratorService { } switch (schemeField.id) { case 0: // SUCCESS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.success = new Stat(); - struct.success.read(iprot); + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.success = iprot.readBool(); struct.setSuccessIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -9441,13 +10018,13 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, setData_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, isLeader_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); - if (struct.success != null) { + if (struct.isSetSuccess()) { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); - struct.success.write(oprot); + oprot.writeBool(struct.success); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -9456,16 +10033,16 @@ public class CuratorService { } - private static class setData_resultTupleSchemeFactory implements SchemeFactory { - public setData_resultTupleScheme getScheme() { - return new setData_resultTupleScheme(); + private static class isLeader_resultTupleSchemeFactory implements SchemeFactory { + public isLeader_resultTupleScheme getScheme() { + return new isLeader_resultTupleScheme(); } } - private static class setData_resultTupleScheme extends TupleScheme { + private static class isLeader_resultTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, setData_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -9473,17 +10050,16 @@ public class CuratorService { } oprot.writeBitSet(optionals, 1); if (struct.isSetSuccess()) { - struct.success.write(oprot); + oprot.write