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 612AD10362 for ; Thu, 29 May 2014 21:17:52 +0000 (UTC) Received: (qmail 20569 invoked by uid 500); 29 May 2014 21:17:52 -0000 Delivered-To: apmail-curator-commits-archive@curator.apache.org Received: (qmail 20495 invoked by uid 500); 29 May 2014 21:17:52 -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 20474 invoked by uid 99); 29 May 2014 21:17:52 -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 21:17:52 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 0681B50E68; Thu, 29 May 2014 21:17:52 +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 21:17:52 -0000 Message-Id: <75e2eabe97c04d06bb7d29c910252528@git.apache.org> In-Reply-To: <63c852e3b36e4b009481eb4cda02f58f@git.apache.org> References: <63c852e3b36e4b009481eb4cda02f58f@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [2/3] node cache support http://git-wip-us.apache.org/repos/asf/curator/blob/985c9ed0/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 8936004..da9ae2c 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 @@ -54,6 +54,8 @@ public class CuratorService { public List getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection) throws org.apache.thrift.TException; + public ChildData getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection) throws org.apache.thrift.TException; + public List getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection) throws org.apache.thrift.TException; public ChildData getPathChildrenCacheDataForPath(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, String path) throws org.apache.thrift.TException; @@ -66,6 +68,8 @@ public class CuratorService { public LeaderResult startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs) throws org.apache.thrift.TException; + public NodeCacheProjection startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial) throws org.apache.thrift.TException; + public PathChildrenCacheProjection startPathChildrenCache(CuratorProjection projection, String path, boolean cacheData, boolean dataIsCompressed, PathChildrenCacheStartMode startMode) throws org.apache.thrift.TException; } @@ -90,6 +94,8 @@ public class CuratorService { public void getLeaderParticipants(CuratorProjection projection, LeaderProjection leaderProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getPathChildrenCacheDataForPath(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -102,6 +108,8 @@ public class CuratorService { public void startLeaderSelector(CuratorProjection projection, String path, String participantId, int waitForLeadershipMs, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial, 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; } @@ -336,6 +344,30 @@ public class CuratorService { 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 + { + send_getNodeCacheData(projection, cacheProjection); + return recv_getNodeCacheData(); + } + + public void send_getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection) throws org.apache.thrift.TException + { + getNodeCacheData_args args = new getNodeCacheData_args(); + args.setProjection(projection); + args.setCacheProjection(cacheProjection); + sendBase("getNodeCacheData", args); + } + + public ChildData recv_getNodeCacheData() throws org.apache.thrift.TException + { + getNodeCacheData_result result = new getNodeCacheData_result(); + receiveBase(result, "getNodeCacheData"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNodeCacheData failed: unknown result"); + } + public List getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection) throws org.apache.thrift.TException { send_getPathChildrenCacheData(projection, cacheProjection); @@ -482,6 +514,32 @@ public class CuratorService { 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 + { + send_startNodeCache(projection, path, dataIsCompressed, buildInitial); + return recv_startNodeCache(); + } + + public void send_startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial) throws org.apache.thrift.TException + { + startNodeCache_args args = new startNodeCache_args(); + args.setProjection(projection); + args.setPath(path); + args.setDataIsCompressed(dataIsCompressed); + args.setBuildInitial(buildInitial); + sendBase("startNodeCache", args); + } + + public NodeCacheProjection recv_startNodeCache() throws org.apache.thrift.TException + { + startNodeCache_result result = new startNodeCache_result(); + receiveBase(result, "startNodeCache"); + if (result.isSetSuccess()) { + return result.success; + } + 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 { send_startPathChildrenCache(projection, path, cacheData, dataIsCompressed, startMode); @@ -842,6 +900,41 @@ public class CuratorService { } } + public void getNodeCacheData(CuratorProjection projection, NodeCacheProjection cacheProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getNodeCacheData_call method_call = new getNodeCacheData_call(projection, cacheProjection, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getNodeCacheData_call extends org.apache.thrift.async.TAsyncMethodCall { + private CuratorProjection projection; + private NodeCacheProjection cacheProjection; + public getNodeCacheData_call(CuratorProjection projection, NodeCacheProjection cacheProjection, 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.cacheProjection = cacheProjection; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getNodeCacheData", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getNodeCacheData_args args = new getNodeCacheData_args(); + args.setProjection(projection); + args.setCacheProjection(cacheProjection); + args.write(prot); + prot.writeMessageEnd(); + } + + public ChildData 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_getNodeCacheData(); + } + } + public void getPathChildrenCacheData(CuratorProjection projection, PathChildrenCacheProjection cacheProjection, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getPathChildrenCacheData_call method_call = new getPathChildrenCacheData_call(projection, cacheProjection, resultHandler, this, ___protocolFactory, ___transport); @@ -1058,6 +1151,47 @@ public class CuratorService { } } + public void startNodeCache(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + startNodeCache_call method_call = new startNodeCache_call(projection, path, dataIsCompressed, buildInitial, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class startNodeCache_call extends org.apache.thrift.async.TAsyncMethodCall { + private CuratorProjection projection; + private String path; + private boolean dataIsCompressed; + private boolean buildInitial; + public startNodeCache_call(CuratorProjection projection, String path, boolean dataIsCompressed, boolean buildInitial, 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.dataIsCompressed = dataIsCompressed; + this.buildInitial = buildInitial; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startNodeCache", org.apache.thrift.protocol.TMessageType.CALL, 0)); + startNodeCache_args args = new startNodeCache_args(); + args.setProjection(projection); + args.setPath(path); + args.setDataIsCompressed(dataIsCompressed); + args.setBuildInitial(buildInitial); + args.write(prot); + prot.writeMessageEnd(); + } + + public NodeCacheProjection 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_startNodeCache(); + } + } + 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); @@ -1124,12 +1258,14 @@ public class CuratorService { processMap.put("getChildren", new getChildren()); processMap.put("getData", new getData()); processMap.put("getLeaderParticipants", new getLeaderParticipants()); + processMap.put("getNodeCacheData", new getNodeCacheData()); processMap.put("getPathChildrenCacheData", new getPathChildrenCacheData()); processMap.put("getPathChildrenCacheDataForPath", new getPathChildrenCacheDataForPath()); processMap.put("isLeader", new isLeader()); processMap.put("newCuratorProjection", new newCuratorProjection()); processMap.put("setData", new setData()); processMap.put("startLeaderSelector", new startLeaderSelector()); + processMap.put("startNodeCache", new startNodeCache()); processMap.put("startPathChildrenCache", new startPathChildrenCache()); return processMap; } @@ -1315,6 +1451,26 @@ public class CuratorService { } } + public static class getNodeCacheData extends org.apache.thrift.ProcessFunction { + public getNodeCacheData() { + super("getNodeCacheData"); + } + + public getNodeCacheData_args getEmptyArgsInstance() { + return new getNodeCacheData_args(); + } + + protected boolean isOneway() { + return false; + } + + 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); + return result; + } + } + public static class getPathChildrenCacheData extends org.apache.thrift.ProcessFunction { public getPathChildrenCacheData() { super("getPathChildrenCacheData"); @@ -1436,6 +1592,26 @@ public class CuratorService { } } + public static class startNodeCache extends org.apache.thrift.ProcessFunction { + public startNodeCache() { + super("startNodeCache"); + } + + public startNodeCache_args getEmptyArgsInstance() { + return new startNodeCache_args(); + } + + protected boolean isOneway() { + return false; + } + + 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); + return result; + } + } + public static class startPathChildrenCache extends org.apache.thrift.ProcessFunction { public startPathChildrenCache() { super("startPathChildrenCache"); @@ -1478,12 +1654,14 @@ public class CuratorService { processMap.put("getChildren", new getChildren()); processMap.put("getData", new getData()); processMap.put("getLeaderParticipants", new getLeaderParticipants()); + processMap.put("getNodeCacheData", new getNodeCacheData()); processMap.put("getPathChildrenCacheData", new getPathChildrenCacheData()); processMap.put("getPathChildrenCacheDataForPath", new getPathChildrenCacheDataForPath()); processMap.put("isLeader", new isLeader()); processMap.put("newCuratorProjection", new newCuratorProjection()); processMap.put("setData", new setData()); processMap.put("startLeaderSelector", new startLeaderSelector()); + processMap.put("startNodeCache", new startNodeCache()); processMap.put("startPathChildrenCache", new startPathChildrenCache()); return processMap; } @@ -1946,6 +2124,57 @@ public class CuratorService { } } + public static class getNodeCacheData extends org.apache.thrift.AsyncProcessFunction { + public getNodeCacheData() { + super("getNodeCacheData"); + } + + public getNodeCacheData_args getEmptyArgsInstance() { + return new getNodeCacheData_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(ChildData o) { + getNodeCacheData_result result = new getNodeCacheData_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; + getNodeCacheData_result result = new getNodeCacheData_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, getNodeCacheData_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getNodeCacheData(args.projection, args.cacheProjection,resultHandler); + } + } + public static class getPathChildrenCacheData extends org.apache.thrift.AsyncProcessFunction> { public getPathChildrenCacheData() { super("getPathChildrenCacheData"); @@ -2253,6 +2482,57 @@ public class CuratorService { } } + public static class startNodeCache extends org.apache.thrift.AsyncProcessFunction { + public startNodeCache() { + super("startNodeCache"); + } + + public startNodeCache_args getEmptyArgsInstance() { + return new startNodeCache_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(NodeCacheProjection o) { + startNodeCache_result result = new startNodeCache_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; + startNodeCache_result result = new startNodeCache_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, startNodeCache_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.startNodeCache(args.projection, args.path, args.dataIsCompressed, args.buildInitial,resultHandler); + } + } + public static class startPathChildrenCache extends org.apache.thrift.AsyncProcessFunction { public startPathChildrenCache() { super("startPathChildrenCache"); @@ -9525,20 +9805,20 @@ public class CuratorService { } - public static class getPathChildrenCacheData_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("getPathChildrenCacheData_args"); + public static class getNodeCacheData_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("getNodeCacheData_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 CACHE_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("cacheProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getPathChildrenCacheData_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getPathChildrenCacheData_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getNodeCacheData_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getNodeCacheData_argsTupleSchemeFactory()); } public CuratorProjection projection; // required - public PathChildrenCacheProjection cacheProjection; // required + public NodeCacheProjection cacheProjection; // 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 { @@ -9608,17 +9888,17 @@ public class CuratorService { 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.CACHE_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("cacheProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PathChildrenCacheProjection.class))); + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NodeCacheProjection.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheData_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getNodeCacheData_args.class, metaDataMap); } - public getPathChildrenCacheData_args() { + public getNodeCacheData_args() { } - public getPathChildrenCacheData_args( + public getNodeCacheData_args( CuratorProjection projection, - PathChildrenCacheProjection cacheProjection) + NodeCacheProjection cacheProjection) { this(); this.projection = projection; @@ -9628,17 +9908,17 @@ public class CuratorService { /** * Performs a deep copy on other. */ - public getPathChildrenCacheData_args(getPathChildrenCacheData_args other) { + public getNodeCacheData_args(getNodeCacheData_args other) { if (other.isSetProjection()) { this.projection = new CuratorProjection(other.projection); } if (other.isSetCacheProjection()) { - this.cacheProjection = new PathChildrenCacheProjection(other.cacheProjection); + this.cacheProjection = new NodeCacheProjection(other.cacheProjection); } } - public getPathChildrenCacheData_args deepCopy() { - return new getPathChildrenCacheData_args(this); + public getNodeCacheData_args deepCopy() { + return new getNodeCacheData_args(this); } @Override @@ -9651,7 +9931,7 @@ public class CuratorService { return this.projection; } - public getPathChildrenCacheData_args setProjection(CuratorProjection projection) { + public getNodeCacheData_args setProjection(CuratorProjection projection) { this.projection = projection; return this; } @@ -9671,11 +9951,11 @@ public class CuratorService { } } - public PathChildrenCacheProjection getCacheProjection() { + public NodeCacheProjection getCacheProjection() { return this.cacheProjection; } - public getPathChildrenCacheData_args setCacheProjection(PathChildrenCacheProjection cacheProjection) { + public getNodeCacheData_args setCacheProjection(NodeCacheProjection cacheProjection) { this.cacheProjection = cacheProjection; return this; } @@ -9709,7 +9989,7 @@ public class CuratorService { if (value == null) { unsetCacheProjection(); } else { - setCacheProjection((PathChildrenCacheProjection)value); + setCacheProjection((NodeCacheProjection)value); } break; @@ -9747,12 +10027,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getPathChildrenCacheData_args) - return this.equals((getPathChildrenCacheData_args)that); + if (that instanceof getNodeCacheData_args) + return this.equals((getNodeCacheData_args)that); return false; } - public boolean equals(getPathChildrenCacheData_args that) { + public boolean equals(getNodeCacheData_args that) { if (that == null) return false; @@ -9783,7 +10063,7 @@ public class CuratorService { } @Override - public int compareTo(getPathChildrenCacheData_args other) { + public int compareTo(getNodeCacheData_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -9827,7 +10107,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getPathChildrenCacheData_args("); + StringBuilder sb = new StringBuilder("getNodeCacheData_args("); boolean first = true; sb.append("projection:"); @@ -9876,15 +10156,15 @@ public class CuratorService { } } - private static class getPathChildrenCacheData_argsStandardSchemeFactory implements SchemeFactory { - public getPathChildrenCacheData_argsStandardScheme getScheme() { - return new getPathChildrenCacheData_argsStandardScheme(); + private static class getNodeCacheData_argsStandardSchemeFactory implements SchemeFactory { + public getNodeCacheData_argsStandardScheme getScheme() { + return new getNodeCacheData_argsStandardScheme(); } } - private static class getPathChildrenCacheData_argsStandardScheme extends StandardScheme { + private static class getNodeCacheData_argsStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getNodeCacheData_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -9905,7 +10185,7 @@ public class CuratorService { break; case 2: // CACHE_PROJECTION if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.cacheProjection = new PathChildrenCacheProjection(); + struct.cacheProjection = new NodeCacheProjection(); struct.cacheProjection.read(iprot); struct.setCacheProjectionIsSet(true); } else { @@ -9923,7 +10203,7 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getNodeCacheData_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -9943,16 +10223,16 @@ public class CuratorService { } - private static class getPathChildrenCacheData_argsTupleSchemeFactory implements SchemeFactory { - public getPathChildrenCacheData_argsTupleScheme getScheme() { - return new getPathChildrenCacheData_argsTupleScheme(); + private static class getNodeCacheData_argsTupleSchemeFactory implements SchemeFactory { + public getNodeCacheData_argsTupleScheme getScheme() { + return new getNodeCacheData_argsTupleScheme(); } } - private static class getPathChildrenCacheData_argsTupleScheme extends TupleScheme { + private static class getNodeCacheData_argsTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getNodeCacheData_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetProjection()) { @@ -9971,7 +10251,7 @@ public class CuratorService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getNodeCacheData_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -9980,7 +10260,7 @@ public class CuratorService { struct.setProjectionIsSet(true); } if (incoming.get(1)) { - struct.cacheProjection = new PathChildrenCacheProjection(); + struct.cacheProjection = new NodeCacheProjection(); struct.cacheProjection.read(iprot); struct.setCacheProjectionIsSet(true); } @@ -9989,18 +10269,18 @@ public class CuratorService { } - public static class getPathChildrenCacheData_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("getPathChildrenCacheData_result"); + public static class getNodeCacheData_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("getNodeCacheData_result"); - 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 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 Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getPathChildrenCacheData_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getPathChildrenCacheData_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getNodeCacheData_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getNodeCacheData_resultTupleSchemeFactory()); } - public List success; // required + public ChildData 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 { @@ -10065,17 +10345,16 @@ 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.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ChildData.class)))); + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ChildData.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheData_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getNodeCacheData_result.class, metaDataMap); } - public getPathChildrenCacheData_result() { + public getNodeCacheData_result() { } - public getPathChildrenCacheData_result( - List success) + public getNodeCacheData_result( + ChildData success) { this(); this.success = success; @@ -10084,18 +10363,14 @@ public class CuratorService { /** * Performs a deep copy on other. */ - public getPathChildrenCacheData_result(getPathChildrenCacheData_result other) { + public getNodeCacheData_result(getNodeCacheData_result other) { if (other.isSetSuccess()) { - List __this__success = new ArrayList(other.success.size()); - for (ChildData other_element : other.success) { - __this__success.add(new ChildData(other_element)); - } - this.success = __this__success; + this.success = new ChildData(other.success); } } - public getPathChildrenCacheData_result deepCopy() { - return new getPathChildrenCacheData_result(this); + public getNodeCacheData_result deepCopy() { + return new getNodeCacheData_result(this); } @Override @@ -10103,26 +10378,11 @@ public class CuratorService { this.success = null; } - 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(ChildData elem) { - if (this.success == null) { - this.success = new ArrayList(); - } - this.success.add(elem); - } - - public List getSuccess() { + public ChildData getSuccess() { return this.success; } - public getPathChildrenCacheData_result setSuccess(List success) { + public getNodeCacheData_result setSuccess(ChildData success) { this.success = success; return this; } @@ -10148,7 +10408,7 @@ public class CuratorService { if (value == null) { unsetSuccess(); } else { - setSuccess((List)value); + setSuccess((ChildData)value); } break; @@ -10181,12 +10441,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getPathChildrenCacheData_result) - return this.equals((getPathChildrenCacheData_result)that); + if (that instanceof getNodeCacheData_result) + return this.equals((getNodeCacheData_result)that); return false; } - public boolean equals(getPathChildrenCacheData_result that) { + public boolean equals(getNodeCacheData_result that) { if (that == null) return false; @@ -10208,7 +10468,7 @@ public class CuratorService { } @Override - public int compareTo(getPathChildrenCacheData_result other) { + public int compareTo(getNodeCacheData_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -10242,7 +10502,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getPathChildrenCacheData_result("); + StringBuilder sb = new StringBuilder("getNodeCacheData_result("); boolean first = true; sb.append("success:"); @@ -10259,6 +10519,9 @@ 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 { @@ -10277,15 +10540,15 @@ public class CuratorService { } } - private static class getPathChildrenCacheData_resultStandardSchemeFactory implements SchemeFactory { - public getPathChildrenCacheData_resultStandardScheme getScheme() { - return new getPathChildrenCacheData_resultStandardScheme(); + private static class getNodeCacheData_resultStandardSchemeFactory implements SchemeFactory { + public getNodeCacheData_resultStandardScheme getScheme() { + return new getNodeCacheData_resultStandardScheme(); } } - private static class getPathChildrenCacheData_resultStandardScheme extends StandardScheme { + private static class getNodeCacheData_resultStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getNodeCacheData_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -10296,19 +10559,9 @@ public class CuratorService { } switch (schemeField.id) { case 0: // SUCCESS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list32 = iprot.readListBegin(); - struct.success = new ArrayList(_list32.size); - for (int _i33 = 0; _i33 < _list32.size; ++_i33) - { - ChildData _elem34; - _elem34 = new ChildData(); - _elem34.read(iprot); - struct.success.add(_elem34); - } - iprot.readListEnd(); - } + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.success = new ChildData(); + struct.success.read(iprot); struct.setSuccessIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -10325,20 +10578,13 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getNodeCacheData_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); if (struct.success != null) { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size())); - for (ChildData _iter35 : struct.success) - { - _iter35.write(oprot); - } - oprot.writeListEnd(); - } + struct.success.write(oprot); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -10347,16 +10593,16 @@ public class CuratorService { } - private static class getPathChildrenCacheData_resultTupleSchemeFactory implements SchemeFactory { - public getPathChildrenCacheData_resultTupleScheme getScheme() { - return new getPathChildrenCacheData_resultTupleScheme(); + private static class getNodeCacheData_resultTupleSchemeFactory implements SchemeFactory { + public getNodeCacheData_resultTupleScheme getScheme() { + return new getNodeCacheData_resultTupleScheme(); } } - private static class getPathChildrenCacheData_resultTupleScheme extends TupleScheme { + private static class getNodeCacheData_resultTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getNodeCacheData_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -10364,32 +10610,17 @@ public class CuratorService { } oprot.writeBitSet(optionals, 1); if (struct.isSetSuccess()) { - { - oprot.writeI32(struct.success.size()); - for (ChildData _iter36 : struct.success) - { - _iter36.write(oprot); - } - } + struct.success.write(oprot); } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getNodeCacheData_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { - { - org.apache.thrift.protocol.TList _list37 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.success = new ArrayList(_list37.size); - for (int _i38 = 0; _i38 < _list37.size; ++_i38) - { - ChildData _elem39; - _elem39 = new ChildData(); - _elem39.read(iprot); - struct.success.add(_elem39); - } - } + struct.success = new ChildData(); + struct.success.read(iprot); struct.setSuccessIsSet(true); } } @@ -10397,28 +10628,25 @@ public class CuratorService { } - public static class getPathChildrenCacheDataForPath_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("getPathChildrenCacheDataForPath_args"); + public static class getPathChildrenCacheData_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("getPathChildrenCacheData_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 CACHE_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("cacheProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2); - 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)3); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getPathChildrenCacheDataForPath_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getPathChildrenCacheDataForPath_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getPathChildrenCacheData_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getPathChildrenCacheData_argsTupleSchemeFactory()); } public CuratorProjection projection; // required public PathChildrenCacheProjection cacheProjection; // required - public String path; // 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"), - CACHE_PROJECTION((short)2, "cacheProjection"), - PATH((short)3, "path"); + CACHE_PROJECTION((short)2, "cacheProjection"); private static final Map byName = new HashMap(); @@ -10437,8 +10665,6 @@ public class CuratorService { return PROJECTION; case 2: // CACHE_PROJECTION return CACHE_PROJECTION; - case 3: // PATH - return PATH; default: return null; } @@ -10486,57 +10712,49 @@ public class CuratorService { new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CuratorProjection.class))); tmpMap.put(_Fields.CACHE_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("cacheProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PathChildrenCacheProjection.class))); - tmpMap.put(_Fields.PATH, new org.apache.thrift.meta_data.FieldMetaData("path", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheDataForPath_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheData_args.class, metaDataMap); } - public getPathChildrenCacheDataForPath_args() { + public getPathChildrenCacheData_args() { } - public getPathChildrenCacheDataForPath_args( + public getPathChildrenCacheData_args( CuratorProjection projection, - PathChildrenCacheProjection cacheProjection, - String path) + PathChildrenCacheProjection cacheProjection) { this(); this.projection = projection; this.cacheProjection = cacheProjection; - this.path = path; } /** * Performs a deep copy on other. */ - public getPathChildrenCacheDataForPath_args(getPathChildrenCacheDataForPath_args other) { + public getPathChildrenCacheData_args(getPathChildrenCacheData_args other) { if (other.isSetProjection()) { this.projection = new CuratorProjection(other.projection); } if (other.isSetCacheProjection()) { this.cacheProjection = new PathChildrenCacheProjection(other.cacheProjection); } - if (other.isSetPath()) { - this.path = other.path; - } } - public getPathChildrenCacheDataForPath_args deepCopy() { - return new getPathChildrenCacheDataForPath_args(this); + public getPathChildrenCacheData_args deepCopy() { + return new getPathChildrenCacheData_args(this); } @Override public void clear() { this.projection = null; this.cacheProjection = null; - this.path = null; } public CuratorProjection getProjection() { return this.projection; } - public getPathChildrenCacheDataForPath_args setProjection(CuratorProjection projection) { + public getPathChildrenCacheData_args setProjection(CuratorProjection projection) { this.projection = projection; return this; } @@ -10560,7 +10778,7 @@ public class CuratorService { return this.cacheProjection; } - public getPathChildrenCacheDataForPath_args setCacheProjection(PathChildrenCacheProjection cacheProjection) { + public getPathChildrenCacheData_args setCacheProjection(PathChildrenCacheProjection cacheProjection) { this.cacheProjection = cacheProjection; return this; } @@ -10580,30 +10798,6 @@ public class CuratorService { } } - public String getPath() { - return this.path; - } - - public getPathChildrenCacheDataForPath_args setPath(String path) { - this.path = path; - return this; - } - - public void unsetPath() { - this.path = null; - } - - /** Returns true if field path is set (has been assigned a value) and false otherwise */ - public boolean isSetPath() { - return this.path != null; - } - - public void setPathIsSet(boolean value) { - if (!value) { - this.path = null; - } - } - public void setFieldValue(_Fields field, Object value) { switch (field) { case PROJECTION: @@ -10622,14 +10816,6 @@ public class CuratorService { } break; - case PATH: - if (value == null) { - unsetPath(); - } else { - setPath((String)value); - } - break; - } } @@ -10641,9 +10827,6 @@ public class CuratorService { case CACHE_PROJECTION: return getCacheProjection(); - case PATH: - return getPath(); - } throw new IllegalStateException(); } @@ -10659,8 +10842,6 @@ public class CuratorService { return isSetProjection(); case CACHE_PROJECTION: return isSetCacheProjection(); - case PATH: - return isSetPath(); } throw new IllegalStateException(); } @@ -10669,12 +10850,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getPathChildrenCacheDataForPath_args) - return this.equals((getPathChildrenCacheDataForPath_args)that); + if (that instanceof getPathChildrenCacheData_args) + return this.equals((getPathChildrenCacheData_args)that); return false; } - public boolean equals(getPathChildrenCacheDataForPath_args that) { + public boolean equals(getPathChildrenCacheData_args that) { if (that == null) return false; @@ -10696,15 +10877,6 @@ public class CuratorService { return false; } - boolean this_present_path = true && this.isSetPath(); - boolean that_present_path = true && that.isSetPath(); - if (this_present_path || that_present_path) { - if (!(this_present_path && that_present_path)) - return false; - if (!this.path.equals(that.path)) - return false; - } - return true; } @@ -10714,7 +10886,7 @@ public class CuratorService { } @Override - public int compareTo(getPathChildrenCacheDataForPath_args other) { + public int compareTo(getPathChildrenCacheData_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -10741,16 +10913,6 @@ public class CuratorService { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetPath()).compareTo(other.isSetPath()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetPath()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.path, other.path); - if (lastComparison != 0) { - return lastComparison; - } - } return 0; } @@ -10768,7 +10930,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getPathChildrenCacheDataForPath_args("); + StringBuilder sb = new StringBuilder("getPathChildrenCacheData_args("); boolean first = true; sb.append("projection:"); @@ -10786,14 +10948,6 @@ public class CuratorService { sb.append(this.cacheProjection); } first = false; - if (!first) sb.append(", "); - sb.append("path:"); - if (this.path == null) { - sb.append("null"); - } else { - sb.append(this.path); - } - first = false; sb.append(")"); return sb.toString(); } @@ -10825,15 +10979,15 @@ public class CuratorService { } } - private static class getPathChildrenCacheDataForPath_argsStandardSchemeFactory implements SchemeFactory { - public getPathChildrenCacheDataForPath_argsStandardScheme getScheme() { - return new getPathChildrenCacheDataForPath_argsStandardScheme(); + private static class getPathChildrenCacheData_argsStandardSchemeFactory implements SchemeFactory { + public getPathChildrenCacheData_argsStandardScheme getScheme() { + return new getPathChildrenCacheData_argsStandardScheme(); } } - private static class getPathChildrenCacheDataForPath_argsStandardScheme extends StandardScheme { + private static class getPathChildrenCacheData_argsStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getPathChildrenCacheDataForPath_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -10861,14 +11015,6 @@ public class CuratorService { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 3: // PATH - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.path = iprot.readString(); - struct.setPathIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -10880,7 +11026,7 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getPathChildrenCacheDataForPath_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -10894,27 +11040,22 @@ public class CuratorService { struct.cacheProjection.write(oprot); oprot.writeFieldEnd(); } - if (struct.path != null) { - oprot.writeFieldBegin(PATH_FIELD_DESC); - oprot.writeString(struct.path); - oprot.writeFieldEnd(); - } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class getPathChildrenCacheDataForPath_argsTupleSchemeFactory implements SchemeFactory { - public getPathChildrenCacheDataForPath_argsTupleScheme getScheme() { - return new getPathChildrenCacheDataForPath_argsTupleScheme(); + private static class getPathChildrenCacheData_argsTupleSchemeFactory implements SchemeFactory { + public getPathChildrenCacheData_argsTupleScheme getScheme() { + return new getPathChildrenCacheData_argsTupleScheme(); } } - private static class getPathChildrenCacheDataForPath_argsTupleScheme extends TupleScheme { + private static class getPathChildrenCacheData_argsTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheDataForPath_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetProjection()) { @@ -10923,25 +11064,19 @@ public class CuratorService { if (struct.isSetCacheProjection()) { optionals.set(1); } - if (struct.isSetPath()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); + oprot.writeBitSet(optionals, 2); if (struct.isSetProjection()) { struct.projection.write(oprot); } if (struct.isSetCacheProjection()) { struct.cacheProjection.write(oprot); } - if (struct.isSetPath()) { - oprot.writeString(struct.path); - } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheDataForPath_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); + BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { struct.projection = new CuratorProjection(); struct.projection.read(iprot); @@ -10952,27 +11087,23 @@ public class CuratorService { struct.cacheProjection.read(iprot); struct.setCacheProjectionIsSet(true); } - if (incoming.get(2)) { - struct.path = iprot.readString(); - struct.setPathIsSet(true); - } } } } - public static class getPathChildrenCacheDataForPath_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("getPathChildrenCacheDataForPath_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); + public static class getPathChildrenCacheData_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("getPathChildrenCacheData_result"); + + 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 getPathChildrenCacheDataForPath_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getPathChildrenCacheDataForPath_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getPathChildrenCacheData_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getPathChildrenCacheData_resultTupleSchemeFactory()); } - public ChildData 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 { @@ -11037,16 +11168,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, ChildData.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, ChildData.class)))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheDataForPath_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheData_result.class, metaDataMap); } - public getPathChildrenCacheDataForPath_result() { + public getPathChildrenCacheData_result() { } - public getPathChildrenCacheDataForPath_result( - ChildData success) + public getPathChildrenCacheData_result( + List success) { this(); this.success = success; @@ -11055,14 +11187,18 @@ public class CuratorService { /** * Performs a deep copy on other. */ - public getPathChildrenCacheDataForPath_result(getPathChildrenCacheDataForPath_result other) { + public getPathChildrenCacheData_result(getPathChildrenCacheData_result other) { if (other.isSetSuccess()) { - this.success = new ChildData(other.success); + List __this__success = new ArrayList(other.success.size()); + for (ChildData other_element : other.success) { + __this__success.add(new ChildData(other_element)); + } + this.success = __this__success; } } - public getPathChildrenCacheDataForPath_result deepCopy() { - return new getPathChildrenCacheDataForPath_result(this); + public getPathChildrenCacheData_result deepCopy() { + return new getPathChildrenCacheData_result(this); } @Override @@ -11070,11 +11206,26 @@ public class CuratorService { this.success = null; } - public ChildData 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(ChildData elem) { + if (this.success == null) { + this.success = new ArrayList(); + } + this.success.add(elem); + } + + public List getSuccess() { return this.success; } - public getPathChildrenCacheDataForPath_result setSuccess(ChildData success) { + public getPathChildrenCacheData_result setSuccess(List success) { this.success = success; return this; } @@ -11100,7 +11251,7 @@ public class CuratorService { if (value == null) { unsetSuccess(); } else { - setSuccess((ChildData)value); + setSuccess((List)value); } break; @@ -11133,12 +11284,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getPathChildrenCacheDataForPath_result) - return this.equals((getPathChildrenCacheDataForPath_result)that); + if (that instanceof getPathChildrenCacheData_result) + return this.equals((getPathChildrenCacheData_result)that); return false; } - public boolean equals(getPathChildrenCacheDataForPath_result that) { + public boolean equals(getPathChildrenCacheData_result that) { if (that == null) return false; @@ -11160,7 +11311,7 @@ public class CuratorService { } @Override - public int compareTo(getPathChildrenCacheDataForPath_result other) { + public int compareTo(getPathChildrenCacheData_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -11194,7 +11345,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("getPathChildrenCacheDataForPath_result("); + StringBuilder sb = new StringBuilder("getPathChildrenCacheData_result("); boolean first = true; sb.append("success:"); @@ -11211,9 +11362,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 { @@ -11232,15 +11380,15 @@ public class CuratorService { } } - private static class getPathChildrenCacheDataForPath_resultStandardSchemeFactory implements SchemeFactory { - public getPathChildrenCacheDataForPath_resultStandardScheme getScheme() { - return new getPathChildrenCacheDataForPath_resultStandardScheme(); + private static class getPathChildrenCacheData_resultStandardSchemeFactory implements SchemeFactory { + public getPathChildrenCacheData_resultStandardScheme getScheme() { + return new getPathChildrenCacheData_resultStandardScheme(); } } - private static class getPathChildrenCacheDataForPath_resultStandardScheme extends StandardScheme { + private static class getPathChildrenCacheData_resultStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getPathChildrenCacheDataForPath_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -11251,9 +11399,19 @@ public class CuratorService { } switch (schemeField.id) { case 0: // SUCCESS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.success = new ChildData(); - struct.success.read(iprot); + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list32 = iprot.readListBegin(); + struct.success = new ArrayList(_list32.size); + for (int _i33 = 0; _i33 < _list32.size; ++_i33) + { + ChildData _elem34; + _elem34 = new ChildData(); + _elem34.read(iprot); + struct.success.add(_elem34); + } + iprot.readListEnd(); + } struct.setSuccessIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -11270,13 +11428,20 @@ public class CuratorService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getPathChildrenCacheDataForPath_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getPathChildrenCacheData_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 (ChildData _iter35 : struct.success) + { + _iter35.write(oprot); + } + oprot.writeListEnd(); + } oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -11285,16 +11450,16 @@ public class CuratorService { } - private static class getPathChildrenCacheDataForPath_resultTupleSchemeFactory implements SchemeFactory { - public getPathChildrenCacheDataForPath_resultTupleScheme getScheme() { - return new getPathChildrenCacheDataForPath_resultTupleScheme(); + private static class getPathChildrenCacheData_resultTupleSchemeFactory implements SchemeFactory { + public getPathChildrenCacheData_resultTupleScheme getScheme() { + return new getPathChildrenCacheData_resultTupleScheme(); } } - private static class getPathChildrenCacheDataForPath_resultTupleScheme extends TupleScheme { + private static class getPathChildrenCacheData_resultTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheDataForPath_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -11302,17 +11467,32 @@ public class CuratorService { } oprot.writeBitSet(optionals, 1); if (struct.isSetSuccess()) { - struct.success.write(oprot); + { + oprot.writeI32(struct.success.size()); + for (ChildData _iter36 : struct.success) + { + _iter36.write(oprot); + } + } } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheDataForPath_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getPathChildrenCacheData_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { - struct.success = new ChildData(); - struct.success.read(iprot); + { + org.apache.thrift.protocol.TList _list37 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.success = new ArrayList(_list37.size); + for (int _i38 = 0; _i38 < _list37.size; ++_i38) + { + ChildData _elem39; + _elem39 = new ChildData(); + _elem39.read(iprot); + struct.success.add(_elem39); + } + } struct.setSuccessIsSet(true); } } @@ -11320,25 +11500,28 @@ public class CuratorService { } - 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"); + public static class getPathChildrenCacheDataForPath_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("getPathChildrenCacheDataForPath_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 LEADER_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("leaderProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField CACHE_PROJECTION_FIELD_DESC = new org.apache.thrift.protocol.TField("cacheProjection", org.apache.thrift.protocol.TType.STRUCT, (short)2); + 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)3); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new isLeader_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new isLeader_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getPathChildrenCacheDataForPath_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getPathChildrenCacheDataForPath_argsTupleSchemeFactory()); } public CuratorProjection projection; // required - public LeaderProjection leaderProjection; // required + public PathChildrenCacheProjection cacheProjection; // required + public String path; // 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"), - LEADER_PROJECTION((short)2, "leaderProjection"); + CACHE_PROJECTION((short)2, "cacheProjection"), + PATH((short)3, "path"); private static final Map byName = new HashMap(); @@ -11355,8 +11538,10 @@ public class CuratorService { switch(fieldId) { case 1: // PROJECTION return PROJECTION; - case 2: // LEADER_PROJECTION - return LEADER_PROJECTION; + case 2: // CACHE_PROJECTION + return CACHE_PROJECTION; + case 3: // PATH + return PATH; default: return null; } @@ -11402,51 +11587,59 @@ 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.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))); + tmpMap.put(_Fields.CACHE_PROJECTION, new org.apache.thrift.meta_data.FieldMetaData("cacheProjection", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PathChildrenCacheProjection.class))); + tmpMap.put(_Fields.PATH, new org.apache.thrift.meta_data.FieldMetaData("path", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getPathChildrenCacheDataForPath_args.class, metaDataMap); } - public isLeader_args() { + public getPathChildrenCacheDataForPath_args() { } - public isLeader_args( + public getPathChildrenCacheDataForPath_args( CuratorProjection projection, - LeaderProjection leaderProjection) + PathChildrenCacheProjection cacheProjection, + String path) { this(); this.projection = projection; - this.leaderProjection = leaderProjection; + this.cacheProjection = cacheProjection; + this.path = path; } /** * Performs a deep copy on other. */ - public isLeader_args(isLeader_args other) { + public getPathChildrenCacheDataForPath_args(getPathChildrenCacheDataForPath_args other) { if (other.isSetProjection()) { this.projection = new CuratorProjection(other.projection); } - if (other.isSetLeaderProjection()) { - this.leaderProjection = new LeaderProjection(other.leaderProjection); + if (other.isSetCacheProjection()) { + this.cacheProjection = new PathChildrenCacheProjection(other.cacheProjection); + } + if (other.isSetPath()) { + this.path = other.path; } } - public isLeader_args deepCopy() { - return new isLeader_args(this); + public getPathChildrenCacheDataForPath_args deepCopy() { + return new getPathChildrenCacheDataForPath_args(this); } @Override public void clear() { this.projection = null; - this.leaderProjection = null; + this.cacheProjection = null; + this.path = null; } public CuratorProjection getProjection() { return this.projection; } - public isLeader_args setProjection(CuratorProjection projection) { + public getPathChildrenCacheDataForPath_args setProjection(CuratorProjection projection) { this.projection = projection; return this; } @@ -11466,27 +11659,51 @@ public class CuratorService { } } - public LeaderProjection getLeaderProjection() { - return this.leaderProjection; + public PathChildrenCacheProjection getCacheProjection() { + return this.cacheProjection; } - public isLeader_args setLeaderProjection(LeaderProjection leaderProjection) { - this.leaderProjection = leaderProjection; + public getPathChildrenCacheDataForPath_args setCacheProjection(PathChildrenCacheProjection cacheProjection) { + this.cacheProjection = cacheProjection; return this; } - public void unsetLeaderProjection() { - this.leaderProjection = null; + public void unsetCacheProjection() { + this.cacheProjection = null; } - /** Returns true if field leaderProjection is set (has been assigned a value) and false otherwise */ - public boolean isSetLeaderProjection() { - return this.leaderProjection != null; + /** Returns true if field cacheProjection is set (has been assigned a value) and false otherwise */ + public boolean isSetCacheProjection() { + return this.cacheProjection != null; } - public void setLeaderProjectionIsSet(boolean value) { + public void setCacheProjectionIsSet(boolean value) { if (!value) { - this.leaderProjection = null; + this.cacheProjection = null; + } + } + + public String getPath() { + return this.path; + } + + public getPathChildrenCacheDataForPath_args setPath(String path) { + this.path = path; + return this; + } + + public void unsetPath() { + this.path = null; + } + + /** Returns true if field path is set (has been assigned a value) and false otherwise */ + public boolean isSetPath() { + return this.path != null; + } + + public void setPathIsSet(boolean value) { + if (!value) { + this.path = null; } } @@ -11500,24 +11717,35 @@ public class CuratorService { } break; - case LEADER_PROJECTION: + case CACHE_PROJECTION: if (value == null) { - unsetLeaderProjection(); + unsetCacheProjection(); } else { - setLeaderProjection((LeaderProjection)value); + setCacheProjection((PathChildrenCacheProjection)value); } break; - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case PROJECTION: - return getProjection(); + case PATH: + if (value == null) { + unsetPath(); + } else { + setPath((String)value); + } + break; - case LEADER_PROJECTION: - return getLeaderProjection(); + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PROJECTION: + return getProjection(); + + case CACHE_PROJECTION: + return getCacheProjection(); + + case PATH: + return getPath(); } throw new IllegalStateException(); @@ -11532,8 +11760,10 @@ public class CuratorService { switch (field) { case PROJECTION: return isSetProjection(); - case LEADER_PROJECTION: - return isSetLeaderProjection(); + case CACHE_PROJECTION: + return isSetCacheProjection(); + case PATH: + return isSetPath(); } throw new IllegalStateException(); } @@ -11542,12 +11772,12 @@ public class CuratorService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof isLeader_args) - return this.equals((isLeader_args)that); + if (that instanceof getPathChildrenCacheDataForPath_args) + return this.equals((getPathChildrenCacheDataForPath_args)that); return false; } - public boolean equals(isLeader_args that) { + public boolean equals(getPathChildrenCacheDataForPath_args that) { if (that == null) return false; @@ -11560,12 +11790,21 @@ public class CuratorService { 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)) + boolean this_present_cacheProjection = true && this.isSetCacheProjection(); + boolean that_present_cacheProjection = true && that.isSetCacheProjection(); + if (this_present_cacheProjection || that_present_cacheProjection) { + if (!(this_present_cacheProjection && that_present_cacheProjection)) return false; - if (!this.leaderProjection.equals(that.leaderProjection)) + if (!this.cacheProjection.equals(that.cacheProjection)) + return false; + } + + boolean this_present_path = true && this.isSetPath(); + boolean that_present_path = true && that.isSetPath(); + if (this_present_path || that_present_path) { + if (!(this_present_path && that_present_path)) + return false; + if (!this.path.equals(that.path)) return false; } @@ -11578,7 +11817,7 @@ public class CuratorService { } @Override - public int compareTo(isLeader_args other) { + public int compareTo(getPathChildrenCacheDataForPath_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -11595,12 +11834,22 @@ public class CuratorService { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetLeaderProjection()).compareTo(other.isSetLeaderProjection()); + lastComparison = Boolean.valueOf(isSetCacheProjection()).compareTo(other.isSetCacheProjection()); if (lastComparison != 0) { return lastComparison; } - if (isSetLeaderProjection()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.leaderProjection, other.leaderProjection); + if (isSetCacheProjection()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cacheProjection, other.cacheProjection); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetPath()).compareTo(other.isSetPath()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPath()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.path, other.path); if (lastComparison != 0) { return lastComparison; } @@ -11622,7 +11871,7 @@ public class CuratorService { @Override public String toString() { - StringBuilder sb = new StringBuilder("isLeader_args("); + StringBuilder sb = new StringBuilder("getPathChildrenCacheDataForPath_args("); boolean first = true; sb.append("projection:"); @@ -11633,11 +11882,19 @@ public class CuratorService { } first = false; if (!first) sb.append(", "); - sb.append("leaderProjection:"); - if (this.leaderProjection == null) { + sb.append("cacheProjection:"); + if (this.cacheProjection == null) { sb.append("null"); } else { - sb.append(this.leaderProjection); + sb.append(this.cacheProjection); + } + first = false; + if (!first) sb.append(", "); + sb.append("path:"); + if (this.path == null) { + sb.append("null"); + } else { + sb.append(this.path); } first = false; sb.append(")"); @@ -11650,8 +11907,8 @@ public class CuratorService { if (projection != null) { projection.validate(); } - if (leaderProjection != null) { - leaderProjection.validate(); + if (cacheProjection != null) { + cacheProjection.validate(); } } @@ -11671,15 +11928,15 @@ public class CuratorService { } } - private static class isLeader_argsStandardSchemeFactory implements SchemeFactory { - public isLeader_argsStandardScheme getScheme() { - return new isLeader_argsStandardScheme(); + private static class g