http://git-wip-us.apache.org/repos/asf/incubator-sentry/blob/2e509e4b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java ---------------------------------------------------------------------- diff --git a/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java new file mode 100644 index 0000000..663fe4e --- /dev/null +++ b/sentry-hdfs/sentry-hdfs-common/src/gen/thrift/gen-javabean/org/apache/sentry/hdfs/service/thrift/SentryHDFSService.java @@ -0,0 +1,3483 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.sentry.hdfs.service.thrift; + +import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class SentryHDFSService { + + public interface Iface { + + public void handle_hms_notification(TPathsUpdate pathsUpdate) throws org.apache.thrift.TException; + + public long check_hms_seq_num(long pathSeqNum) throws org.apache.thrift.TException; + + public TAuthzUpdateResponse get_all_authz_updates_from(long permSeqNum, long pathSeqNum) throws org.apache.thrift.TException; + + public Map<String,List<String>> get_all_related_paths(String path, boolean exactMatch) throws org.apache.thrift.TException; + + } + + public interface AsyncIface { + + public void handle_hms_notification(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.handle_hms_notification_call> resultHandler) throws org.apache.thrift.TException; + + public void check_hms_seq_num(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.check_hms_seq_num_call> resultHandler) throws org.apache.thrift.TException; + + public void get_all_authz_updates_from(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_all_authz_updates_from_call> resultHandler) throws org.apache.thrift.TException; + + public void get_all_related_paths(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_all_related_paths_call> resultHandler) throws org.apache.thrift.TException; + + } + + public static class Client extends org.apache.thrift.TServiceClient implements Iface { + public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { + public Factory() {} + public Client getClient(org.apache.thrift.protocol.TProtocol prot) { + return new Client(prot); + } + public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { + return new Client(iprot, oprot); + } + } + + public Client(org.apache.thrift.protocol.TProtocol prot) + { + super(prot, prot); + } + + public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { + super(iprot, oprot); + } + + public void handle_hms_notification(TPathsUpdate pathsUpdate) throws org.apache.thrift.TException + { + send_handle_hms_notification(pathsUpdate); + recv_handle_hms_notification(); + } + + public void send_handle_hms_notification(TPathsUpdate pathsUpdate) throws org.apache.thrift.TException + { + handle_hms_notification_args args = new handle_hms_notification_args(); + args.setPathsUpdate(pathsUpdate); + sendBase("handle_hms_notification", args); + } + + public void recv_handle_hms_notification() throws org.apache.thrift.TException + { + handle_hms_notification_result result = new handle_hms_notification_result(); + receiveBase(result, "handle_hms_notification"); + return; + } + + public long check_hms_seq_num(long pathSeqNum) throws org.apache.thrift.TException + { + send_check_hms_seq_num(pathSeqNum); + return recv_check_hms_seq_num(); + } + + public void send_check_hms_seq_num(long pathSeqNum) throws org.apache.thrift.TException + { + check_hms_seq_num_args args = new check_hms_seq_num_args(); + args.setPathSeqNum(pathSeqNum); + sendBase("check_hms_seq_num", args); + } + + public long recv_check_hms_seq_num() throws org.apache.thrift.TException + { + check_hms_seq_num_result result = new check_hms_seq_num_result(); + receiveBase(result, "check_hms_seq_num"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "check_hms_seq_num failed: unknown result"); + } + + public TAuthzUpdateResponse get_all_authz_updates_from(long permSeqNum, long pathSeqNum) throws org.apache.thrift.TException + { + send_get_all_authz_updates_from(permSeqNum, pathSeqNum); + return recv_get_all_authz_updates_from(); + } + + public void send_get_all_authz_updates_from(long permSeqNum, long pathSeqNum) throws org.apache.thrift.TException + { + get_all_authz_updates_from_args args = new get_all_authz_updates_from_args(); + args.setPermSeqNum(permSeqNum); + args.setPathSeqNum(pathSeqNum); + sendBase("get_all_authz_updates_from", args); + } + + public TAuthzUpdateResponse recv_get_all_authz_updates_from() throws org.apache.thrift.TException + { + get_all_authz_updates_from_result result = new get_all_authz_updates_from_result(); + receiveBase(result, "get_all_authz_updates_from"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_all_authz_updates_from failed: unknown result"); + } + + public Map<String,List<String>> get_all_related_paths(String path, boolean exactMatch) throws org.apache.thrift.TException + { + send_get_all_related_paths(path, exactMatch); + return recv_get_all_related_paths(); + } + + public void send_get_all_related_paths(String path, boolean exactMatch) throws org.apache.thrift.TException + { + get_all_related_paths_args args = new get_all_related_paths_args(); + args.setPath(path); + args.setExactMatch(exactMatch); + sendBase("get_all_related_paths", args); + } + + public Map<String,List<String>> recv_get_all_related_paths() throws org.apache.thrift.TException + { + get_all_related_paths_result result = new get_all_related_paths_result(); + receiveBase(result, "get_all_related_paths"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_all_related_paths 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<AsyncClient> { + private org.apache.thrift.async.TAsyncClientManager clientManager; + private org.apache.thrift.protocol.TProtocolFactory protocolFactory; + public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { + this.clientManager = clientManager; + this.protocolFactory = protocolFactory; + } + public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { + return new AsyncClient(protocolFactory, clientManager, transport); + } + } + + public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { + super(protocolFactory, clientManager, transport); + } + + public void handle_hms_notification(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback<handle_hms_notification_call> resultHandler) throws org.apache.thrift.TException { + checkReady(); + handle_hms_notification_call method_call = new handle_hms_notification_call(pathsUpdate, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class handle_hms_notification_call extends org.apache.thrift.async.TAsyncMethodCall { + private TPathsUpdate pathsUpdate; + public handle_hms_notification_call(TPathsUpdate pathsUpdate, org.apache.thrift.async.AsyncMethodCallback<handle_hms_notification_call> 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.pathsUpdate = pathsUpdate; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("handle_hms_notification", org.apache.thrift.protocol.TMessageType.CALL, 0)); + handle_hms_notification_args args = new handle_hms_notification_args(); + args.setPathsUpdate(pathsUpdate); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_handle_hms_notification(); + } + } + + public void check_hms_seq_num(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<check_hms_seq_num_call> resultHandler) throws org.apache.thrift.TException { + checkReady(); + check_hms_seq_num_call method_call = new check_hms_seq_num_call(pathSeqNum, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class check_hms_seq_num_call extends org.apache.thrift.async.TAsyncMethodCall { + private long pathSeqNum; + public check_hms_seq_num_call(long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<check_hms_seq_num_call> 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.pathSeqNum = pathSeqNum; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("check_hms_seq_num", org.apache.thrift.protocol.TMessageType.CALL, 0)); + check_hms_seq_num_args args = new check_hms_seq_num_args(); + args.setPathSeqNum(pathSeqNum); + args.write(prot); + prot.writeMessageEnd(); + } + + public long 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_check_hms_seq_num(); + } + } + + public void get_all_authz_updates_from(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<get_all_authz_updates_from_call> resultHandler) throws org.apache.thrift.TException { + checkReady(); + get_all_authz_updates_from_call method_call = new get_all_authz_updates_from_call(permSeqNum, pathSeqNum, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class get_all_authz_updates_from_call extends org.apache.thrift.async.TAsyncMethodCall { + private long permSeqNum; + private long pathSeqNum; + public get_all_authz_updates_from_call(long permSeqNum, long pathSeqNum, org.apache.thrift.async.AsyncMethodCallback<get_all_authz_updates_from_call> 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.permSeqNum = permSeqNum; + this.pathSeqNum = pathSeqNum; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_all_authz_updates_from", org.apache.thrift.protocol.TMessageType.CALL, 0)); + get_all_authz_updates_from_args args = new get_all_authz_updates_from_args(); + args.setPermSeqNum(permSeqNum); + args.setPathSeqNum(pathSeqNum); + args.write(prot); + prot.writeMessageEnd(); + } + + public TAuthzUpdateResponse 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_get_all_authz_updates_from(); + } + } + + public void get_all_related_paths(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback<get_all_related_paths_call> resultHandler) throws org.apache.thrift.TException { + checkReady(); + get_all_related_paths_call method_call = new get_all_related_paths_call(path, exactMatch, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class get_all_related_paths_call extends org.apache.thrift.async.TAsyncMethodCall { + private String path; + private boolean exactMatch; + public get_all_related_paths_call(String path, boolean exactMatch, org.apache.thrift.async.AsyncMethodCallback<get_all_related_paths_call> 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.path = path; + this.exactMatch = exactMatch; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_all_related_paths", org.apache.thrift.protocol.TMessageType.CALL, 0)); + get_all_related_paths_args args = new get_all_related_paths_args(); + args.setPath(path); + args.setExactMatch(exactMatch); + args.write(prot); + prot.writeMessageEnd(); + } + + public Map<String,List<String>> 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_get_all_related_paths(); + } + } + + } + + public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { + private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); + public Processor(I iface) { + super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); + } + + protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { + super(iface, getProcessMap(processMap)); + } + + private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { + processMap.put("handle_hms_notification", new handle_hms_notification()); + processMap.put("check_hms_seq_num", new check_hms_seq_num()); + processMap.put("get_all_authz_updates_from", new get_all_authz_updates_from()); + processMap.put("get_all_related_paths", new get_all_related_paths()); + return processMap; + } + + public static class handle_hms_notification<I extends Iface> extends org.apache.thrift.ProcessFunction<I, handle_hms_notification_args> { + public handle_hms_notification() { + super("handle_hms_notification"); + } + + public handle_hms_notification_args getEmptyArgsInstance() { + return new handle_hms_notification_args(); + } + + protected boolean isOneway() { + return false; + } + + public handle_hms_notification_result getResult(I iface, handle_hms_notification_args args) throws org.apache.thrift.TException { + handle_hms_notification_result result = new handle_hms_notification_result(); + iface.handle_hms_notification(args.pathsUpdate); + return result; + } + } + + public static class check_hms_seq_num<I extends Iface> extends org.apache.thrift.ProcessFunction<I, check_hms_seq_num_args> { + public check_hms_seq_num() { + super("check_hms_seq_num"); + } + + public check_hms_seq_num_args getEmptyArgsInstance() { + return new check_hms_seq_num_args(); + } + + protected boolean isOneway() { + return false; + } + + public check_hms_seq_num_result getResult(I iface, check_hms_seq_num_args args) throws org.apache.thrift.TException { + check_hms_seq_num_result result = new check_hms_seq_num_result(); + result.success = iface.check_hms_seq_num(args.pathSeqNum); + result.setSuccessIsSet(true); + return result; + } + } + + public static class get_all_authz_updates_from<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_all_authz_updates_from_args> { + public get_all_authz_updates_from() { + super("get_all_authz_updates_from"); + } + + public get_all_authz_updates_from_args getEmptyArgsInstance() { + return new get_all_authz_updates_from_args(); + } + + protected boolean isOneway() { + return false; + } + + public get_all_authz_updates_from_result getResult(I iface, get_all_authz_updates_from_args args) throws org.apache.thrift.TException { + get_all_authz_updates_from_result result = new get_all_authz_updates_from_result(); + result.success = iface.get_all_authz_updates_from(args.permSeqNum, args.pathSeqNum); + return result; + } + } + + public static class get_all_related_paths<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_all_related_paths_args> { + public get_all_related_paths() { + super("get_all_related_paths"); + } + + public get_all_related_paths_args getEmptyArgsInstance() { + return new get_all_related_paths_args(); + } + + protected boolean isOneway() { + return false; + } + + public get_all_related_paths_result getResult(I iface, get_all_related_paths_args args) throws org.apache.thrift.TException { + get_all_related_paths_result result = new get_all_related_paths_result(); + result.success = iface.get_all_related_paths(args.path, args.exactMatch); + return result; + } + } + + } + + public static class handle_hms_notification_args implements org.apache.thrift.TBase<handle_hms_notification_args, handle_hms_notification_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("handle_hms_notification_args"); + + private static final org.apache.thrift.protocol.TField PATHS_UPDATE_FIELD_DESC = new org.apache.thrift.protocol.TField("pathsUpdate", org.apache.thrift.protocol.TType.STRUCT, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new handle_hms_notification_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new handle_hms_notification_argsTupleSchemeFactory()); + } + + private TPathsUpdate pathsUpdate; // 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 { + PATHS_UPDATE((short)1, "pathsUpdate"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // PATHS_UPDATE + return PATHS_UPDATE; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + 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.PATHS_UPDATE, new org.apache.thrift.meta_data.FieldMetaData("pathsUpdate", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TPathsUpdate.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(handle_hms_notification_args.class, metaDataMap); + } + + public handle_hms_notification_args() { + } + + public handle_hms_notification_args( + TPathsUpdate pathsUpdate) + { + this(); + this.pathsUpdate = pathsUpdate; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public handle_hms_notification_args(handle_hms_notification_args other) { + if (other.isSetPathsUpdate()) { + this.pathsUpdate = new TPathsUpdate(other.pathsUpdate); + } + } + + public handle_hms_notification_args deepCopy() { + return new handle_hms_notification_args(this); + } + + @Override + public void clear() { + this.pathsUpdate = null; + } + + public TPathsUpdate getPathsUpdate() { + return this.pathsUpdate; + } + + public void setPathsUpdate(TPathsUpdate pathsUpdate) { + this.pathsUpdate = pathsUpdate; + } + + public void unsetPathsUpdate() { + this.pathsUpdate = null; + } + + /** Returns true if field pathsUpdate is set (has been assigned a value) and false otherwise */ + public boolean isSetPathsUpdate() { + return this.pathsUpdate != null; + } + + public void setPathsUpdateIsSet(boolean value) { + if (!value) { + this.pathsUpdate = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case PATHS_UPDATE: + if (value == null) { + unsetPathsUpdate(); + } else { + setPathsUpdate((TPathsUpdate)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PATHS_UPDATE: + return getPathsUpdate(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case PATHS_UPDATE: + return isSetPathsUpdate(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof handle_hms_notification_args) + return this.equals((handle_hms_notification_args)that); + return false; + } + + public boolean equals(handle_hms_notification_args that) { + if (that == null) + return false; + + boolean this_present_pathsUpdate = true && this.isSetPathsUpdate(); + boolean that_present_pathsUpdate = true && that.isSetPathsUpdate(); + if (this_present_pathsUpdate || that_present_pathsUpdate) { + if (!(this_present_pathsUpdate && that_present_pathsUpdate)) + return false; + if (!this.pathsUpdate.equals(that.pathsUpdate)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_pathsUpdate = true && (isSetPathsUpdate()); + builder.append(present_pathsUpdate); + if (present_pathsUpdate) + builder.append(pathsUpdate); + + return builder.toHashCode(); + } + + public int compareTo(handle_hms_notification_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + handle_hms_notification_args typedOther = (handle_hms_notification_args)other; + + lastComparison = Boolean.valueOf(isSetPathsUpdate()).compareTo(typedOther.isSetPathsUpdate()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPathsUpdate()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathsUpdate, typedOther.pathsUpdate); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("handle_hms_notification_args("); + boolean first = true; + + sb.append("pathsUpdate:"); + if (this.pathsUpdate == null) { + sb.append("null"); + } else { + sb.append(this.pathsUpdate); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (pathsUpdate != null) { + pathsUpdate.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + 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 handle_hms_notification_argsStandardSchemeFactory implements SchemeFactory { + public handle_hms_notification_argsStandardScheme getScheme() { + return new handle_hms_notification_argsStandardScheme(); + } + } + + private static class handle_hms_notification_argsStandardScheme extends StandardScheme<handle_hms_notification_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, handle_hms_notification_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // PATHS_UPDATE + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.pathsUpdate = new TPathsUpdate(); + struct.pathsUpdate.read(iprot); + struct.setPathsUpdateIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, handle_hms_notification_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.pathsUpdate != null) { + oprot.writeFieldBegin(PATHS_UPDATE_FIELD_DESC); + struct.pathsUpdate.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class handle_hms_notification_argsTupleSchemeFactory implements SchemeFactory { + public handle_hms_notification_argsTupleScheme getScheme() { + return new handle_hms_notification_argsTupleScheme(); + } + } + + private static class handle_hms_notification_argsTupleScheme extends TupleScheme<handle_hms_notification_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, handle_hms_notification_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetPathsUpdate()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetPathsUpdate()) { + struct.pathsUpdate.write(oprot); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, handle_hms_notification_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.pathsUpdate = new TPathsUpdate(); + struct.pathsUpdate.read(iprot); + struct.setPathsUpdateIsSet(true); + } + } + } + + } + + public static class handle_hms_notification_result implements org.apache.thrift.TBase<handle_hms_notification_result, handle_hms_notification_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("handle_hms_notification_result"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new handle_hms_notification_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new handle_hms_notification_resultTupleSchemeFactory()); + } + + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { +; + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + 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); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(handle_hms_notification_result.class, metaDataMap); + } + + public handle_hms_notification_result() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public handle_hms_notification_result(handle_hms_notification_result other) { + } + + public handle_hms_notification_result deepCopy() { + return new handle_hms_notification_result(this); + } + + @Override + public void clear() { + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof handle_hms_notification_result) + return this.equals((handle_hms_notification_result)that); + return false; + } + + public boolean equals(handle_hms_notification_result that) { + if (that == null) + return false; + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + return builder.toHashCode(); + } + + public int compareTo(handle_hms_notification_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + handle_hms_notification_result typedOther = (handle_hms_notification_result)other; + + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("handle_hms_notification_result("); + boolean first = true; + + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + 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 handle_hms_notification_resultStandardSchemeFactory implements SchemeFactory { + public handle_hms_notification_resultStandardScheme getScheme() { + return new handle_hms_notification_resultStandardScheme(); + } + } + + private static class handle_hms_notification_resultStandardScheme extends StandardScheme<handle_hms_notification_result> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, handle_hms_notification_result struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, handle_hms_notification_result struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class handle_hms_notification_resultTupleSchemeFactory implements SchemeFactory { + public handle_hms_notification_resultTupleScheme getScheme() { + return new handle_hms_notification_resultTupleScheme(); + } + } + + private static class handle_hms_notification_resultTupleScheme extends TupleScheme<handle_hms_notification_result> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, handle_hms_notification_result struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, handle_hms_notification_result struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + + } + + public static class check_hms_seq_num_args implements org.apache.thrift.TBase<check_hms_seq_num_args, check_hms_seq_num_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("check_hms_seq_num_args"); + + private static final org.apache.thrift.protocol.TField PATH_SEQ_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("pathSeqNum", org.apache.thrift.protocol.TType.I64, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new check_hms_seq_num_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new check_hms_seq_num_argsTupleSchemeFactory()); + } + + private long pathSeqNum; // 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 { + PATH_SEQ_NUM((short)1, "pathSeqNum"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // PATH_SEQ_NUM + return PATH_SEQ_NUM; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __PATHSEQNUM_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.PATH_SEQ_NUM, new org.apache.thrift.meta_data.FieldMetaData("pathSeqNum", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(check_hms_seq_num_args.class, metaDataMap); + } + + public check_hms_seq_num_args() { + } + + public check_hms_seq_num_args( + long pathSeqNum) + { + this(); + this.pathSeqNum = pathSeqNum; + setPathSeqNumIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public check_hms_seq_num_args(check_hms_seq_num_args other) { + __isset_bitfield = other.__isset_bitfield; + this.pathSeqNum = other.pathSeqNum; + } + + public check_hms_seq_num_args deepCopy() { + return new check_hms_seq_num_args(this); + } + + @Override + public void clear() { + setPathSeqNumIsSet(false); + this.pathSeqNum = 0; + } + + public long getPathSeqNum() { + return this.pathSeqNum; + } + + public void setPathSeqNum(long pathSeqNum) { + this.pathSeqNum = pathSeqNum; + setPathSeqNumIsSet(true); + } + + public void unsetPathSeqNum() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PATHSEQNUM_ISSET_ID); + } + + /** Returns true if field pathSeqNum is set (has been assigned a value) and false otherwise */ + public boolean isSetPathSeqNum() { + return EncodingUtils.testBit(__isset_bitfield, __PATHSEQNUM_ISSET_ID); + } + + public void setPathSeqNumIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PATHSEQNUM_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case PATH_SEQ_NUM: + if (value == null) { + unsetPathSeqNum(); + } else { + setPathSeqNum((Long)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PATH_SEQ_NUM: + return Long.valueOf(getPathSeqNum()); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case PATH_SEQ_NUM: + return isSetPathSeqNum(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof check_hms_seq_num_args) + return this.equals((check_hms_seq_num_args)that); + return false; + } + + public boolean equals(check_hms_seq_num_args that) { + if (that == null) + return false; + + boolean this_present_pathSeqNum = true; + boolean that_present_pathSeqNum = true; + if (this_present_pathSeqNum || that_present_pathSeqNum) { + if (!(this_present_pathSeqNum && that_present_pathSeqNum)) + return false; + if (this.pathSeqNum != that.pathSeqNum) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_pathSeqNum = true; + builder.append(present_pathSeqNum); + if (present_pathSeqNum) + builder.append(pathSeqNum); + + return builder.toHashCode(); + } + + public int compareTo(check_hms_seq_num_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + check_hms_seq_num_args typedOther = (check_hms_seq_num_args)other; + + lastComparison = Boolean.valueOf(isSetPathSeqNum()).compareTo(typedOther.isSetPathSeqNum()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPathSeqNum()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathSeqNum, typedOther.pathSeqNum); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("check_hms_seq_num_args("); + boolean first = true; + + sb.append("pathSeqNum:"); + sb.append(this.pathSeqNum); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + 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 check_hms_seq_num_argsStandardSchemeFactory implements SchemeFactory { + public check_hms_seq_num_argsStandardScheme getScheme() { + return new check_hms_seq_num_argsStandardScheme(); + } + } + + private static class check_hms_seq_num_argsStandardScheme extends StandardScheme<check_hms_seq_num_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, check_hms_seq_num_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // PATH_SEQ_NUM + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.pathSeqNum = iprot.readI64(); + struct.setPathSeqNumIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, check_hms_seq_num_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(PATH_SEQ_NUM_FIELD_DESC); + oprot.writeI64(struct.pathSeqNum); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class check_hms_seq_num_argsTupleSchemeFactory implements SchemeFactory { + public check_hms_seq_num_argsTupleScheme getScheme() { + return new check_hms_seq_num_argsTupleScheme(); + } + } + + private static class check_hms_seq_num_argsTupleScheme extends TupleScheme<check_hms_seq_num_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, check_hms_seq_num_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetPathSeqNum()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetPathSeqNum()) { + oprot.writeI64(struct.pathSeqNum); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, check_hms_seq_num_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.pathSeqNum = iprot.readI64(); + struct.setPathSeqNumIsSet(true); + } + } + } + + } + + public static class check_hms_seq_num_result implements org.apache.thrift.TBase<check_hms_seq_num_result, check_hms_seq_num_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("check_hms_seq_num_result"); + + private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.I64, (short)0); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new check_hms_seq_num_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new check_hms_seq_num_resultTupleSchemeFactory()); + } + + private long 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 { + SUCCESS((short)0, "success"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 0: // SUCCESS + return SUCCESS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // 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.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(check_hms_seq_num_result.class, metaDataMap); + } + + public check_hms_seq_num_result() { + } + + public check_hms_seq_num_result( + long success) + { + this(); + this.success = success; + setSuccessIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public check_hms_seq_num_result(check_hms_seq_num_result other) { + __isset_bitfield = other.__isset_bitfield; + this.success = other.success; + } + + public check_hms_seq_num_result deepCopy() { + return new check_hms_seq_num_result(this); + } + + @Override + public void clear() { + setSuccessIsSet(false); + this.success = 0; + } + + public long getSuccess() { + return this.success; + } + + public void setSuccess(long success) { + this.success = success; + setSuccessIsSet(true); + } + + public void unsetSuccess() { + __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 EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID); + } + + public void setSuccessIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((Long)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SUCCESS: + return Long.valueOf(getSuccess()); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case SUCCESS: + return isSetSuccess(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof check_hms_seq_num_result) + return this.equals((check_hms_seq_num_result)that); + return false; + } + + public boolean equals(check_hms_seq_num_result that) { + if (that == null) + return false; + + 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 != that.success) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_success = true; + builder.append(present_success); + if (present_success) + builder.append(success); + + return builder.toHashCode(); + } + + public int compareTo(check_hms_seq_num_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + check_hms_seq_num_result typedOther = (check_hms_seq_num_result)other; + + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSuccess()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("check_hms_seq_num_result("); + boolean first = true; + + sb.append("success:"); + sb.append(this.success); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + 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 check_hms_seq_num_resultStandardSchemeFactory implements SchemeFactory { + public check_hms_seq_num_resultStandardScheme getScheme() { + return new check_hms_seq_num_resultStandardScheme(); + } + } + + private static class check_hms_seq_num_resultStandardScheme extends StandardScheme<check_hms_seq_num_result> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, check_hms_seq_num_result struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 0: // SUCCESS + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.success = iprot.readI64(); + struct.setSuccessIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, check_hms_seq_num_result struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.isSetSuccess()) { + oprot.writeFieldBegin(SUCCESS_FIELD_DESC); + oprot.writeI64(struct.success); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class check_hms_seq_num_resultTupleSchemeFactory implements SchemeFactory { + public check_hms_seq_num_resultTupleScheme getScheme() { + return new check_hms_seq_num_resultTupleScheme(); + } + } + + private static class check_hms_seq_num_resultTupleScheme extends TupleScheme<check_hms_seq_num_result> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, check_hms_seq_num_result struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSuccess()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetSuccess()) { + oprot.writeI64(struct.success); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, check_hms_seq_num_result struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.success = iprot.readI64(); + struct.setSuccessIsSet(true); + } + } + } + + } + + public static class get_all_authz_updates_from_args implements org.apache.thrift.TBase<get_all_authz_updates_from_args, get_all_authz_updates_from_args._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_all_authz_updates_from_args"); + + private static final org.apache.thrift.protocol.TField PERM_SEQ_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("permSeqNum", org.apache.thrift.protocol.TType.I64, (short)1); + private static final org.apache.thrift.protocol.TField PATH_SEQ_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("pathSeqNum", org.apache.thrift.protocol.TType.I64, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new get_all_authz_updates_from_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_all_authz_updates_from_argsTupleSchemeFactory()); + } + + private long permSeqNum; // required + private long pathSeqNum; // 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 { + PERM_SEQ_NUM((short)1, "permSeqNum"), + PATH_SEQ_NUM((short)2, "pathSeqNum"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // PERM_SEQ_NUM + return PERM_SEQ_NUM; + case 2: // PATH_SEQ_NUM + return PATH_SEQ_NUM; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __PERMSEQNUM_ISSET_ID = 0; + private static final int __PATHSEQNUM_ISSET_ID = 1; + 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.PERM_SEQ_NUM, new org.apache.thrift.meta_data.FieldMetaData("permSeqNum", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.PATH_SEQ_NUM, new org.apache.thrift.meta_data.FieldMetaData("pathSeqNum", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_all_authz_updates_from_args.class, metaDataMap); + } + + public get_all_authz_updates_from_args() { + } + + public get_all_authz_updates_from_args( + long permSeqNum, + long pathSeqNum) + { + this(); + this.permSeqNum = permSeqNum; + setPermSeqNumIsSet(true); + this.pathSeqNum = pathSeqNum; + setPathSeqNumIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public get_all_authz_updates_from_args(get_all_authz_updates_from_args other) { + __isset_bitfield = other.__isset_bitfield; + this.permSeqNum = other.permSeqNum; + this.pathSeqNum = other.pathSeqNum; + } + + public get_all_authz_updates_from_args deepCopy() { + return new get_all_authz_updates_from_args(this); + } + + @Override + public void clear() { + setPermSeqNumIsSet(false); + this.permSeqNum = 0; + setPathSeqNumIsSet(false); + this.pathSeqNum = 0; + } + + public long getPermSeqNum() { + return this.permSeqNum; + } + + public void setPermSeqNum(long permSeqNum) { + this.permSeqNum = permSeqNum; + setPermSeqNumIsSet(true); + } + + public void unsetPermSeqNum() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PERMSEQNUM_ISSET_ID); + } + + /** Returns true if field permSeqNum is set (has been assigned a value) and false otherwise */ + public boolean isSetPermSeqNum() { + return EncodingUtils.testBit(__isset_bitfield, __PERMSEQNUM_ISSET_ID); + } + + public void setPermSeqNumIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PERMSEQNUM_ISSET_ID, value); + } + + public long getPathSeqNum() { + return this.pathSeqNum; + } + + public void setPathSeqNum(long pathSeqNum) { + this.pathSeqNum = pathSeqNum; + setPathSeqNumIsSet(true); + } + + public void unsetPathSeqNum() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PATHSEQNUM_ISSET_ID); + } + + /** Returns true if field pathSeqNum is set (has been assigned a value) and false otherwise */ + public boolean isSetPathSeqNum() { + return EncodingUtils.testBit(__isset_bitfield, __PATHSEQNUM_ISSET_ID); + } + + public void setPathSeqNumIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PATHSEQNUM_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case PERM_SEQ_NUM: + if (value == null) { + unsetPermSeqNum(); + } else { + setPermSeqNum((Long)value); + } + break; + + case PATH_SEQ_NUM: + if (value == null) { + unsetPathSeqNum(); + } else { + setPathSeqNum((Long)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PERM_SEQ_NUM: + return Long.valueOf(getPermSeqNum()); + + case PATH_SEQ_NUM: + return Long.valueOf(getPathSeqNum()); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case PERM_SEQ_NUM: + return isSetPermSeqNum(); + case PATH_SEQ_NUM: + return isSetPathSeqNum(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof get_all_authz_updates_from_args) + return this.equals((get_all_authz_updates_from_args)that); + return false; + } + + public boolean equals(get_all_authz_updates_from_args that) { + if (that == null) + return false; + + boolean this_present_permSeqNum = true; + boolean that_present_permSeqNum = true; + if (this_present_permSeqNum || that_present_permSeqNum) { + if (!(this_present_permSeqNum && that_present_permSeqNum)) + return false; + if (this.permSeqNum != that.permSeqNum) + return false; + } + + boolean this_present_pathSeqNum = true; + boolean that_present_pathSeqNum = true; + if (this_present_pathSeqNum || that_present_pathSeqNum) { + if (!(this_present_pathSeqNum && that_present_pathSeqNum)) + return false; + if (this.pathSeqNum != that.pathSeqNum) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_permSeqNum = true; + builder.append(present_permSeqNum); + if (present_permSeqNum) + builder.append(permSeqNum); + + boolean present_pathSeqNum = true; + builder.append(present_pathSeqNum); + if (present_pathSeqNum) + builder.append(pathSeqNum); + + return builder.toHashCode(); + } + + public int compareTo(get_all_authz_updates_from_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + get_all_authz_updates_from_args typedOther = (get_all_authz_updates_from_args)other; + + lastComparison = Boolean.valueOf(isSetPermSeqNum()).compareTo(typedOther.isSetPermSeqNum()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPermSeqNum()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.permSeqNum, typedOther.permSeqNum); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetPathSeqNum()).compareTo(typedOther.isSetPathSeqNum()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPathSeqNum()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pathSeqNum, typedOther.pathSeqNum); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("get_all_authz_updates_from_args("); + boolean first = true; + + sb.append("permSeqNum:"); + sb.append(this.permSeqNum); + first = false; + if (!first) sb.append(", "); + sb.append("pathSeqNum:"); + sb.append(this.pathSeqNum); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + 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 get_all_authz_updates_from_argsStandardSchemeFactory implements SchemeFactory { + public get_all_authz_updates_from_argsStandardScheme getScheme() { + return new get_all_authz_updates_from_argsStandardScheme(); + } + } + + private static class get_all_authz_updates_from_argsStandardScheme extends StandardScheme<get_all_authz_updates_from_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, get_all_authz_updates_from_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // PERM_SEQ_NUM + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.permSeqNum = iprot.readI64(); + struct.setPermSeqNumIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // PATH_SEQ_NUM + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.pathSeqNum = iprot.readI64(); + struct.setPathSeqNumIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, get_all_authz_updates_from_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(PERM_SEQ_NUM_FIELD_DESC); + oprot.writeI64(struct.permSeqNum); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(PATH_SEQ_NUM_FIELD_DESC); + oprot.writeI64(struct.pathSeqNum); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class get_all_authz_updates_from_argsTupleSchemeFactory implements SchemeFactory { + public get_all_authz_updates_from_argsTupleScheme getScheme() { + return new get_all_authz_updates_from_argsTupleScheme(); + } + } + + private static class get_all_authz_updates_from_argsTupleScheme extends TupleScheme<get_all_authz_updates_from_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, get_all_authz_updates_from_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetPermSeqNum()) { + optionals.set(0); + } + if (struct.isSetPathSeqNum()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetPermSeqNum()) { + oprot.writeI64(struct.permSeqNum); + } + if (struct.isSetPathSeqNum()) { + oprot.writeI64(struct.pathSeqNum); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, get_all_authz_updates_from_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.permSeqNum = iprot.readI64(); + struct.setPermSeqNumIsSet(true); + } + if (incoming.get(1)) { + struct.pathSeqNum = iprot.readI64(); + struct.setPathSeqNumIsSet(true); + } + } + } + + } + + public static class get_all_authz_updates_from_result implements org.apache.thrift.TBase<get_all_authz_updates_from_result, get_all_authz_updates_from_result._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_all_authz_updates_from_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 Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new get_all_authz_updates_from_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_all_authz_updates_from_resultTupleSchemeFactory()); + } + + private TAuthzUpdateResponse 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 { + SUCCESS((short)0, "success"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 0: // SUCCESS + return SUCCESS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + 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, TAuthzUpdateResponse.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_all_authz_updates_from_result.class, metaDataMap); + } + + public get_all_authz_updates_from_result() { + } + + public get_all_authz_updates_from_result( + TAuthzUpdateResponse success) + { + this(); + this.success = success; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public get_all_authz_updates_from_result(get_all_authz_updates_from_result other) { + if (other.isSetSuccess()) { + this.success = new TAuthzUpdateResponse(other.success); + } + } + + public get_all_authz_updates_from_result deepCopy() { + return new get_all_authz_updates_from_result(this); + } + + @Override + public void clear() { + this.success = null; + } + + public TAuthzUpdateResponse getSuccess() { + return this.success; + } + + public void setSuccess(TAuthzUpdateResponse success) { + this.success = success; + } + + public void unsetSuccess() { + this.success = null; + } + + /** Returns true if field success is set (has been assigned a value) and false otherwise */ + public boolean isSetSuccess() { + return this.success != null; + } + + public void setSuccessIsSet(boolean value) { + if (!value) { + this.success = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((TAuthzUpdateResponse)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SUCCESS: + return getSuccess(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case SUCCESS: + return isSetSuccess(); + } + throw new IllegalStateExcepti
<TRUNCATED>
