You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2016/10/27 21:32:28 UTC
[35/53] airavata git commit: Adding aurora-client project
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateDiffResult.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateDiffResult.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateDiffResult.java
new file mode 100644
index 0000000..983d00a
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateDiffResult.java
@@ -0,0 +1,977 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+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 org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+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 javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class GetJobUpdateDiffResult implements org.apache.thrift.TBase<GetJobUpdateDiffResult, GetJobUpdateDiffResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetJobUpdateDiffResult> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetJobUpdateDiffResult");
+
+ private static final org.apache.thrift.protocol.TField ADD_FIELD_DESC = new org.apache.thrift.protocol.TField("add", org.apache.thrift.protocol.TType.SET, (short)1);
+ private static final org.apache.thrift.protocol.TField REMOVE_FIELD_DESC = new org.apache.thrift.protocol.TField("remove", org.apache.thrift.protocol.TType.SET, (short)2);
+ private static final org.apache.thrift.protocol.TField UPDATE_FIELD_DESC = new org.apache.thrift.protocol.TField("update", org.apache.thrift.protocol.TType.SET, (short)3);
+ private static final org.apache.thrift.protocol.TField UNCHANGED_FIELD_DESC = new org.apache.thrift.protocol.TField("unchanged", org.apache.thrift.protocol.TType.SET, (short)4);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetJobUpdateDiffResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetJobUpdateDiffResultTupleSchemeFactory());
+ }
+
+ /**
+ * Instance addition diff details.
+ */
+ public Set<ConfigGroup> add; // required
+ /**
+ * Instance removal diff details.
+ */
+ public Set<ConfigGroup> remove; // required
+ /**
+ * Instance update diff details.
+ */
+ public Set<ConfigGroup> update; // required
+ /**
+ * Instances unchanged by the update.
+ */
+ public Set<ConfigGroup> unchanged; // 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 {
+ /**
+ * Instance addition diff details.
+ */
+ ADD((short)1, "add"),
+ /**
+ * Instance removal diff details.
+ */
+ REMOVE((short)2, "remove"),
+ /**
+ * Instance update diff details.
+ */
+ UPDATE((short)3, "update"),
+ /**
+ * Instances unchanged by the update.
+ */
+ UNCHANGED((short)4, "unchanged");
+
+ 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: // ADD
+ return ADD;
+ case 2: // REMOVE
+ return REMOVE;
+ case 3: // UPDATE
+ return UPDATE;
+ case 4: // UNCHANGED
+ return UNCHANGED;
+ 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.ADD, new org.apache.thrift.meta_data.FieldMetaData("add", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ConfigGroup.class))));
+ tmpMap.put(_Fields.REMOVE, new org.apache.thrift.meta_data.FieldMetaData("remove", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ConfigGroup.class))));
+ tmpMap.put(_Fields.UPDATE, new org.apache.thrift.meta_data.FieldMetaData("update", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ConfigGroup.class))));
+ tmpMap.put(_Fields.UNCHANGED, new org.apache.thrift.meta_data.FieldMetaData("unchanged", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ConfigGroup.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetJobUpdateDiffResult.class, metaDataMap);
+ }
+
+ public GetJobUpdateDiffResult() {
+ }
+
+ public GetJobUpdateDiffResult(
+ Set<ConfigGroup> add,
+ Set<ConfigGroup> remove,
+ Set<ConfigGroup> update,
+ Set<ConfigGroup> unchanged)
+ {
+ this();
+ this.add = add;
+ this.remove = remove;
+ this.update = update;
+ this.unchanged = unchanged;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetJobUpdateDiffResult(GetJobUpdateDiffResult other) {
+ if (other.isSetAdd()) {
+ Set<ConfigGroup> __this__add = new HashSet<ConfigGroup>(other.add.size());
+ for (ConfigGroup other_element : other.add) {
+ __this__add.add(new ConfigGroup(other_element));
+ }
+ this.add = __this__add;
+ }
+ if (other.isSetRemove()) {
+ Set<ConfigGroup> __this__remove = new HashSet<ConfigGroup>(other.remove.size());
+ for (ConfigGroup other_element : other.remove) {
+ __this__remove.add(new ConfigGroup(other_element));
+ }
+ this.remove = __this__remove;
+ }
+ if (other.isSetUpdate()) {
+ Set<ConfigGroup> __this__update = new HashSet<ConfigGroup>(other.update.size());
+ for (ConfigGroup other_element : other.update) {
+ __this__update.add(new ConfigGroup(other_element));
+ }
+ this.update = __this__update;
+ }
+ if (other.isSetUnchanged()) {
+ Set<ConfigGroup> __this__unchanged = new HashSet<ConfigGroup>(other.unchanged.size());
+ for (ConfigGroup other_element : other.unchanged) {
+ __this__unchanged.add(new ConfigGroup(other_element));
+ }
+ this.unchanged = __this__unchanged;
+ }
+ }
+
+ public GetJobUpdateDiffResult deepCopy() {
+ return new GetJobUpdateDiffResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.add = null;
+ this.remove = null;
+ this.update = null;
+ this.unchanged = null;
+ }
+
+ public int getAddSize() {
+ return (this.add == null) ? 0 : this.add.size();
+ }
+
+ public java.util.Iterator<ConfigGroup> getAddIterator() {
+ return (this.add == null) ? null : this.add.iterator();
+ }
+
+ public void addToAdd(ConfigGroup elem) {
+ if (this.add == null) {
+ this.add = new HashSet<ConfigGroup>();
+ }
+ this.add.add(elem);
+ }
+
+ /**
+ * Instance addition diff details.
+ */
+ public Set<ConfigGroup> getAdd() {
+ return this.add;
+ }
+
+ /**
+ * Instance addition diff details.
+ */
+ public GetJobUpdateDiffResult setAdd(Set<ConfigGroup> add) {
+ this.add = add;
+ return this;
+ }
+
+ public void unsetAdd() {
+ this.add = null;
+ }
+
+ /** Returns true if field add is set (has been assigned a value) and false otherwise */
+ public boolean isSetAdd() {
+ return this.add != null;
+ }
+
+ public void setAddIsSet(boolean value) {
+ if (!value) {
+ this.add = null;
+ }
+ }
+
+ public int getRemoveSize() {
+ return (this.remove == null) ? 0 : this.remove.size();
+ }
+
+ public java.util.Iterator<ConfigGroup> getRemoveIterator() {
+ return (this.remove == null) ? null : this.remove.iterator();
+ }
+
+ public void addToRemove(ConfigGroup elem) {
+ if (this.remove == null) {
+ this.remove = new HashSet<ConfigGroup>();
+ }
+ this.remove.add(elem);
+ }
+
+ /**
+ * Instance removal diff details.
+ */
+ public Set<ConfigGroup> getRemove() {
+ return this.remove;
+ }
+
+ /**
+ * Instance removal diff details.
+ */
+ public GetJobUpdateDiffResult setRemove(Set<ConfigGroup> remove) {
+ this.remove = remove;
+ return this;
+ }
+
+ public void unsetRemove() {
+ this.remove = null;
+ }
+
+ /** Returns true if field remove is set (has been assigned a value) and false otherwise */
+ public boolean isSetRemove() {
+ return this.remove != null;
+ }
+
+ public void setRemoveIsSet(boolean value) {
+ if (!value) {
+ this.remove = null;
+ }
+ }
+
+ public int getUpdateSize() {
+ return (this.update == null) ? 0 : this.update.size();
+ }
+
+ public java.util.Iterator<ConfigGroup> getUpdateIterator() {
+ return (this.update == null) ? null : this.update.iterator();
+ }
+
+ public void addToUpdate(ConfigGroup elem) {
+ if (this.update == null) {
+ this.update = new HashSet<ConfigGroup>();
+ }
+ this.update.add(elem);
+ }
+
+ /**
+ * Instance update diff details.
+ */
+ public Set<ConfigGroup> getUpdate() {
+ return this.update;
+ }
+
+ /**
+ * Instance update diff details.
+ */
+ public GetJobUpdateDiffResult setUpdate(Set<ConfigGroup> update) {
+ this.update = update;
+ return this;
+ }
+
+ public void unsetUpdate() {
+ this.update = null;
+ }
+
+ /** Returns true if field update is set (has been assigned a value) and false otherwise */
+ public boolean isSetUpdate() {
+ return this.update != null;
+ }
+
+ public void setUpdateIsSet(boolean value) {
+ if (!value) {
+ this.update = null;
+ }
+ }
+
+ public int getUnchangedSize() {
+ return (this.unchanged == null) ? 0 : this.unchanged.size();
+ }
+
+ public java.util.Iterator<ConfigGroup> getUnchangedIterator() {
+ return (this.unchanged == null) ? null : this.unchanged.iterator();
+ }
+
+ public void addToUnchanged(ConfigGroup elem) {
+ if (this.unchanged == null) {
+ this.unchanged = new HashSet<ConfigGroup>();
+ }
+ this.unchanged.add(elem);
+ }
+
+ /**
+ * Instances unchanged by the update.
+ */
+ public Set<ConfigGroup> getUnchanged() {
+ return this.unchanged;
+ }
+
+ /**
+ * Instances unchanged by the update.
+ */
+ public GetJobUpdateDiffResult setUnchanged(Set<ConfigGroup> unchanged) {
+ this.unchanged = unchanged;
+ return this;
+ }
+
+ public void unsetUnchanged() {
+ this.unchanged = null;
+ }
+
+ /** Returns true if field unchanged is set (has been assigned a value) and false otherwise */
+ public boolean isSetUnchanged() {
+ return this.unchanged != null;
+ }
+
+ public void setUnchangedIsSet(boolean value) {
+ if (!value) {
+ this.unchanged = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case ADD:
+ if (value == null) {
+ unsetAdd();
+ } else {
+ setAdd((Set<ConfigGroup>)value);
+ }
+ break;
+
+ case REMOVE:
+ if (value == null) {
+ unsetRemove();
+ } else {
+ setRemove((Set<ConfigGroup>)value);
+ }
+ break;
+
+ case UPDATE:
+ if (value == null) {
+ unsetUpdate();
+ } else {
+ setUpdate((Set<ConfigGroup>)value);
+ }
+ break;
+
+ case UNCHANGED:
+ if (value == null) {
+ unsetUnchanged();
+ } else {
+ setUnchanged((Set<ConfigGroup>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case ADD:
+ return getAdd();
+
+ case REMOVE:
+ return getRemove();
+
+ case UPDATE:
+ return getUpdate();
+
+ case UNCHANGED:
+ return getUnchanged();
+
+ }
+ 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 ADD:
+ return isSetAdd();
+ case REMOVE:
+ return isSetRemove();
+ case UPDATE:
+ return isSetUpdate();
+ case UNCHANGED:
+ return isSetUnchanged();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetJobUpdateDiffResult)
+ return this.equals((GetJobUpdateDiffResult)that);
+ return false;
+ }
+
+ public boolean equals(GetJobUpdateDiffResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_add = true && this.isSetAdd();
+ boolean that_present_add = true && that.isSetAdd();
+ if (this_present_add || that_present_add) {
+ if (!(this_present_add && that_present_add))
+ return false;
+ if (!this.add.equals(that.add))
+ return false;
+ }
+
+ boolean this_present_remove = true && this.isSetRemove();
+ boolean that_present_remove = true && that.isSetRemove();
+ if (this_present_remove || that_present_remove) {
+ if (!(this_present_remove && that_present_remove))
+ return false;
+ if (!this.remove.equals(that.remove))
+ return false;
+ }
+
+ boolean this_present_update = true && this.isSetUpdate();
+ boolean that_present_update = true && that.isSetUpdate();
+ if (this_present_update || that_present_update) {
+ if (!(this_present_update && that_present_update))
+ return false;
+ if (!this.update.equals(that.update))
+ return false;
+ }
+
+ boolean this_present_unchanged = true && this.isSetUnchanged();
+ boolean that_present_unchanged = true && that.isSetUnchanged();
+ if (this_present_unchanged || that_present_unchanged) {
+ if (!(this_present_unchanged && that_present_unchanged))
+ return false;
+ if (!this.unchanged.equals(that.unchanged))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_add = true && (isSetAdd());
+ list.add(present_add);
+ if (present_add)
+ list.add(add);
+
+ boolean present_remove = true && (isSetRemove());
+ list.add(present_remove);
+ if (present_remove)
+ list.add(remove);
+
+ boolean present_update = true && (isSetUpdate());
+ list.add(present_update);
+ if (present_update)
+ list.add(update);
+
+ boolean present_unchanged = true && (isSetUnchanged());
+ list.add(present_unchanged);
+ if (present_unchanged)
+ list.add(unchanged);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetJobUpdateDiffResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetAdd()).compareTo(other.isSetAdd());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetAdd()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.add, other.add);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetRemove()).compareTo(other.isSetRemove());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetRemove()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.remove, other.remove);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetUpdate()).compareTo(other.isSetUpdate());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetUpdate()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.update, other.update);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetUnchanged()).compareTo(other.isSetUnchanged());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetUnchanged()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.unchanged, other.unchanged);
+ 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("GetJobUpdateDiffResult(");
+ boolean first = true;
+
+ sb.append("add:");
+ if (this.add == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.add);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("remove:");
+ if (this.remove == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.remove);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("update:");
+ if (this.update == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.update);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("unchanged:");
+ if (this.unchanged == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.unchanged);
+ }
+ 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 {
+ 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 GetJobUpdateDiffResultStandardSchemeFactory implements SchemeFactory {
+ public GetJobUpdateDiffResultStandardScheme getScheme() {
+ return new GetJobUpdateDiffResultStandardScheme();
+ }
+ }
+
+ private static class GetJobUpdateDiffResultStandardScheme extends StandardScheme<GetJobUpdateDiffResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetJobUpdateDiffResult 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: // ADD
+ if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+ {
+ org.apache.thrift.protocol.TSet _set342 = iprot.readSetBegin();
+ struct.add = new HashSet<ConfigGroup>(2*_set342.size);
+ ConfigGroup _elem343;
+ for (int _i344 = 0; _i344 < _set342.size; ++_i344)
+ {
+ _elem343 = new ConfigGroup();
+ _elem343.read(iprot);
+ struct.add.add(_elem343);
+ }
+ iprot.readSetEnd();
+ }
+ struct.setAddIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // REMOVE
+ if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+ {
+ org.apache.thrift.protocol.TSet _set345 = iprot.readSetBegin();
+ struct.remove = new HashSet<ConfigGroup>(2*_set345.size);
+ ConfigGroup _elem346;
+ for (int _i347 = 0; _i347 < _set345.size; ++_i347)
+ {
+ _elem346 = new ConfigGroup();
+ _elem346.read(iprot);
+ struct.remove.add(_elem346);
+ }
+ iprot.readSetEnd();
+ }
+ struct.setRemoveIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // UPDATE
+ if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+ {
+ org.apache.thrift.protocol.TSet _set348 = iprot.readSetBegin();
+ struct.update = new HashSet<ConfigGroup>(2*_set348.size);
+ ConfigGroup _elem349;
+ for (int _i350 = 0; _i350 < _set348.size; ++_i350)
+ {
+ _elem349 = new ConfigGroup();
+ _elem349.read(iprot);
+ struct.update.add(_elem349);
+ }
+ iprot.readSetEnd();
+ }
+ struct.setUpdateIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // UNCHANGED
+ if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+ {
+ org.apache.thrift.protocol.TSet _set351 = iprot.readSetBegin();
+ struct.unchanged = new HashSet<ConfigGroup>(2*_set351.size);
+ ConfigGroup _elem352;
+ for (int _i353 = 0; _i353 < _set351.size; ++_i353)
+ {
+ _elem352 = new ConfigGroup();
+ _elem352.read(iprot);
+ struct.unchanged.add(_elem352);
+ }
+ iprot.readSetEnd();
+ }
+ struct.setUnchangedIsSet(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();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, GetJobUpdateDiffResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.add != null) {
+ oprot.writeFieldBegin(ADD_FIELD_DESC);
+ {
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.add.size()));
+ for (ConfigGroup _iter354 : struct.add)
+ {
+ _iter354.write(oprot);
+ }
+ oprot.writeSetEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.remove != null) {
+ oprot.writeFieldBegin(REMOVE_FIELD_DESC);
+ {
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.remove.size()));
+ for (ConfigGroup _iter355 : struct.remove)
+ {
+ _iter355.write(oprot);
+ }
+ oprot.writeSetEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.update != null) {
+ oprot.writeFieldBegin(UPDATE_FIELD_DESC);
+ {
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.update.size()));
+ for (ConfigGroup _iter356 : struct.update)
+ {
+ _iter356.write(oprot);
+ }
+ oprot.writeSetEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.unchanged != null) {
+ oprot.writeFieldBegin(UNCHANGED_FIELD_DESC);
+ {
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.unchanged.size()));
+ for (ConfigGroup _iter357 : struct.unchanged)
+ {
+ _iter357.write(oprot);
+ }
+ oprot.writeSetEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetJobUpdateDiffResultTupleSchemeFactory implements SchemeFactory {
+ public GetJobUpdateDiffResultTupleScheme getScheme() {
+ return new GetJobUpdateDiffResultTupleScheme();
+ }
+ }
+
+ private static class GetJobUpdateDiffResultTupleScheme extends TupleScheme<GetJobUpdateDiffResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetJobUpdateDiffResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetAdd()) {
+ optionals.set(0);
+ }
+ if (struct.isSetRemove()) {
+ optionals.set(1);
+ }
+ if (struct.isSetUpdate()) {
+ optionals.set(2);
+ }
+ if (struct.isSetUnchanged()) {
+ optionals.set(3);
+ }
+ oprot.writeBitSet(optionals, 4);
+ if (struct.isSetAdd()) {
+ {
+ oprot.writeI32(struct.add.size());
+ for (ConfigGroup _iter358 : struct.add)
+ {
+ _iter358.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetRemove()) {
+ {
+ oprot.writeI32(struct.remove.size());
+ for (ConfigGroup _iter359 : struct.remove)
+ {
+ _iter359.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetUpdate()) {
+ {
+ oprot.writeI32(struct.update.size());
+ for (ConfigGroup _iter360 : struct.update)
+ {
+ _iter360.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetUnchanged()) {
+ {
+ oprot.writeI32(struct.unchanged.size());
+ for (ConfigGroup _iter361 : struct.unchanged)
+ {
+ _iter361.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetJobUpdateDiffResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(4);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TSet _set362 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.add = new HashSet<ConfigGroup>(2*_set362.size);
+ ConfigGroup _elem363;
+ for (int _i364 = 0; _i364 < _set362.size; ++_i364)
+ {
+ _elem363 = new ConfigGroup();
+ _elem363.read(iprot);
+ struct.add.add(_elem363);
+ }
+ }
+ struct.setAddIsSet(true);
+ }
+ if (incoming.get(1)) {
+ {
+ org.apache.thrift.protocol.TSet _set365 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.remove = new HashSet<ConfigGroup>(2*_set365.size);
+ ConfigGroup _elem366;
+ for (int _i367 = 0; _i367 < _set365.size; ++_i367)
+ {
+ _elem366 = new ConfigGroup();
+ _elem366.read(iprot);
+ struct.remove.add(_elem366);
+ }
+ }
+ struct.setRemoveIsSet(true);
+ }
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TSet _set368 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.update = new HashSet<ConfigGroup>(2*_set368.size);
+ ConfigGroup _elem369;
+ for (int _i370 = 0; _i370 < _set368.size; ++_i370)
+ {
+ _elem369 = new ConfigGroup();
+ _elem369.read(iprot);
+ struct.update.add(_elem369);
+ }
+ }
+ struct.setUpdateIsSet(true);
+ }
+ if (incoming.get(3)) {
+ {
+ org.apache.thrift.protocol.TSet _set371 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.unchanged = new HashSet<ConfigGroup>(2*_set371.size);
+ ConfigGroup _elem372;
+ for (int _i373 = 0; _i373 < _set371.size; ++_i373)
+ {
+ _elem372 = new ConfigGroup();
+ _elem372.read(iprot);
+ struct.unchanged.add(_elem372);
+ }
+ }
+ struct.setUnchangedIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateSummariesResult.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateSummariesResult.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateSummariesResult.java
new file mode 100644
index 0000000..6c67c5a
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobUpdateSummariesResult.java
@@ -0,0 +1,455 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+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 org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+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 javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+/**
+ * Result of the getJobUpdateSummaries call.
+ */
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class GetJobUpdateSummariesResult implements org.apache.thrift.TBase<GetJobUpdateSummariesResult, GetJobUpdateSummariesResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetJobUpdateSummariesResult> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetJobUpdateSummariesResult");
+
+ private static final org.apache.thrift.protocol.TField UPDATE_SUMMARIES_FIELD_DESC = new org.apache.thrift.protocol.TField("updateSummaries", org.apache.thrift.protocol.TType.LIST, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetJobUpdateSummariesResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetJobUpdateSummariesResultTupleSchemeFactory());
+ }
+
+ public List<JobUpdateSummary> updateSummaries; // 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 {
+ UPDATE_SUMMARIES((short)1, "updateSummaries");
+
+ 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: // UPDATE_SUMMARIES
+ return UPDATE_SUMMARIES;
+ 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.UPDATE_SUMMARIES, new org.apache.thrift.meta_data.FieldMetaData("updateSummaries", 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, JobUpdateSummary.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetJobUpdateSummariesResult.class, metaDataMap);
+ }
+
+ public GetJobUpdateSummariesResult() {
+ }
+
+ public GetJobUpdateSummariesResult(
+ List<JobUpdateSummary> updateSummaries)
+ {
+ this();
+ this.updateSummaries = updateSummaries;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetJobUpdateSummariesResult(GetJobUpdateSummariesResult other) {
+ if (other.isSetUpdateSummaries()) {
+ List<JobUpdateSummary> __this__updateSummaries = new ArrayList<JobUpdateSummary>(other.updateSummaries.size());
+ for (JobUpdateSummary other_element : other.updateSummaries) {
+ __this__updateSummaries.add(new JobUpdateSummary(other_element));
+ }
+ this.updateSummaries = __this__updateSummaries;
+ }
+ }
+
+ public GetJobUpdateSummariesResult deepCopy() {
+ return new GetJobUpdateSummariesResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.updateSummaries = null;
+ }
+
+ public int getUpdateSummariesSize() {
+ return (this.updateSummaries == null) ? 0 : this.updateSummaries.size();
+ }
+
+ public java.util.Iterator<JobUpdateSummary> getUpdateSummariesIterator() {
+ return (this.updateSummaries == null) ? null : this.updateSummaries.iterator();
+ }
+
+ public void addToUpdateSummaries(JobUpdateSummary elem) {
+ if (this.updateSummaries == null) {
+ this.updateSummaries = new ArrayList<JobUpdateSummary>();
+ }
+ this.updateSummaries.add(elem);
+ }
+
+ public List<JobUpdateSummary> getUpdateSummaries() {
+ return this.updateSummaries;
+ }
+
+ public GetJobUpdateSummariesResult setUpdateSummaries(List<JobUpdateSummary> updateSummaries) {
+ this.updateSummaries = updateSummaries;
+ return this;
+ }
+
+ public void unsetUpdateSummaries() {
+ this.updateSummaries = null;
+ }
+
+ /** Returns true if field updateSummaries is set (has been assigned a value) and false otherwise */
+ public boolean isSetUpdateSummaries() {
+ return this.updateSummaries != null;
+ }
+
+ public void setUpdateSummariesIsSet(boolean value) {
+ if (!value) {
+ this.updateSummaries = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case UPDATE_SUMMARIES:
+ if (value == null) {
+ unsetUpdateSummaries();
+ } else {
+ setUpdateSummaries((List<JobUpdateSummary>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case UPDATE_SUMMARIES:
+ return getUpdateSummaries();
+
+ }
+ 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 UPDATE_SUMMARIES:
+ return isSetUpdateSummaries();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetJobUpdateSummariesResult)
+ return this.equals((GetJobUpdateSummariesResult)that);
+ return false;
+ }
+
+ public boolean equals(GetJobUpdateSummariesResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_updateSummaries = true && this.isSetUpdateSummaries();
+ boolean that_present_updateSummaries = true && that.isSetUpdateSummaries();
+ if (this_present_updateSummaries || that_present_updateSummaries) {
+ if (!(this_present_updateSummaries && that_present_updateSummaries))
+ return false;
+ if (!this.updateSummaries.equals(that.updateSummaries))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_updateSummaries = true && (isSetUpdateSummaries());
+ list.add(present_updateSummaries);
+ if (present_updateSummaries)
+ list.add(updateSummaries);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetJobUpdateSummariesResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetUpdateSummaries()).compareTo(other.isSetUpdateSummaries());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetUpdateSummaries()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.updateSummaries, other.updateSummaries);
+ 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("GetJobUpdateSummariesResult(");
+ boolean first = true;
+
+ sb.append("updateSummaries:");
+ if (this.updateSummaries == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.updateSummaries);
+ }
+ 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 {
+ 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 GetJobUpdateSummariesResultStandardSchemeFactory implements SchemeFactory {
+ public GetJobUpdateSummariesResultStandardScheme getScheme() {
+ return new GetJobUpdateSummariesResultStandardScheme();
+ }
+ }
+
+ private static class GetJobUpdateSummariesResultStandardScheme extends StandardScheme<GetJobUpdateSummariesResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetJobUpdateSummariesResult 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: // UPDATE_SUMMARIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list326 = iprot.readListBegin();
+ struct.updateSummaries = new ArrayList<JobUpdateSummary>(_list326.size);
+ JobUpdateSummary _elem327;
+ for (int _i328 = 0; _i328 < _list326.size; ++_i328)
+ {
+ _elem327 = new JobUpdateSummary();
+ _elem327.read(iprot);
+ struct.updateSummaries.add(_elem327);
+ }
+ iprot.readListEnd();
+ }
+ struct.setUpdateSummariesIsSet(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();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, GetJobUpdateSummariesResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.updateSummaries != null) {
+ oprot.writeFieldBegin(UPDATE_SUMMARIES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.updateSummaries.size()));
+ for (JobUpdateSummary _iter329 : struct.updateSummaries)
+ {
+ _iter329.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetJobUpdateSummariesResultTupleSchemeFactory implements SchemeFactory {
+ public GetJobUpdateSummariesResultTupleScheme getScheme() {
+ return new GetJobUpdateSummariesResultTupleScheme();
+ }
+ }
+
+ private static class GetJobUpdateSummariesResultTupleScheme extends TupleScheme<GetJobUpdateSummariesResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetJobUpdateSummariesResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetUpdateSummaries()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetUpdateSummaries()) {
+ {
+ oprot.writeI32(struct.updateSummaries.size());
+ for (JobUpdateSummary _iter330 : struct.updateSummaries)
+ {
+ _iter330.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetJobUpdateSummariesResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list331 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.updateSummaries = new ArrayList<JobUpdateSummary>(_list331.size);
+ JobUpdateSummary _elem332;
+ for (int _i333 = 0; _i333 < _list331.size; ++_i333)
+ {
+ _elem332 = new JobUpdateSummary();
+ _elem332.read(iprot);
+ struct.updateSummaries.add(_elem332);
+ }
+ }
+ struct.setUpdateSummariesIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobsResult.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobsResult.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobsResult.java
new file mode 100644
index 0000000..5237a69
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetJobsResult.java
@@ -0,0 +1,452 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+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 org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+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 javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class GetJobsResult implements org.apache.thrift.TBase<GetJobsResult, GetJobsResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetJobsResult> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetJobsResult");
+
+ private static final org.apache.thrift.protocol.TField CONFIGS_FIELD_DESC = new org.apache.thrift.protocol.TField("configs", org.apache.thrift.protocol.TType.SET, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetJobsResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetJobsResultTupleSchemeFactory());
+ }
+
+ public Set<JobConfiguration> configs; // 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 {
+ CONFIGS((short)1, "configs");
+
+ 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: // CONFIGS
+ return CONFIGS;
+ 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.CONFIGS, new org.apache.thrift.meta_data.FieldMetaData("configs", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobConfiguration.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetJobsResult.class, metaDataMap);
+ }
+
+ public GetJobsResult() {
+ }
+
+ public GetJobsResult(
+ Set<JobConfiguration> configs)
+ {
+ this();
+ this.configs = configs;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetJobsResult(GetJobsResult other) {
+ if (other.isSetConfigs()) {
+ Set<JobConfiguration> __this__configs = new HashSet<JobConfiguration>(other.configs.size());
+ for (JobConfiguration other_element : other.configs) {
+ __this__configs.add(new JobConfiguration(other_element));
+ }
+ this.configs = __this__configs;
+ }
+ }
+
+ public GetJobsResult deepCopy() {
+ return new GetJobsResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.configs = null;
+ }
+
+ public int getConfigsSize() {
+ return (this.configs == null) ? 0 : this.configs.size();
+ }
+
+ public java.util.Iterator<JobConfiguration> getConfigsIterator() {
+ return (this.configs == null) ? null : this.configs.iterator();
+ }
+
+ public void addToConfigs(JobConfiguration elem) {
+ if (this.configs == null) {
+ this.configs = new HashSet<JobConfiguration>();
+ }
+ this.configs.add(elem);
+ }
+
+ public Set<JobConfiguration> getConfigs() {
+ return this.configs;
+ }
+
+ public GetJobsResult setConfigs(Set<JobConfiguration> configs) {
+ this.configs = configs;
+ return this;
+ }
+
+ public void unsetConfigs() {
+ this.configs = null;
+ }
+
+ /** Returns true if field configs is set (has been assigned a value) and false otherwise */
+ public boolean isSetConfigs() {
+ return this.configs != null;
+ }
+
+ public void setConfigsIsSet(boolean value) {
+ if (!value) {
+ this.configs = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case CONFIGS:
+ if (value == null) {
+ unsetConfigs();
+ } else {
+ setConfigs((Set<JobConfiguration>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case CONFIGS:
+ return getConfigs();
+
+ }
+ 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 CONFIGS:
+ return isSetConfigs();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetJobsResult)
+ return this.equals((GetJobsResult)that);
+ return false;
+ }
+
+ public boolean equals(GetJobsResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_configs = true && this.isSetConfigs();
+ boolean that_present_configs = true && that.isSetConfigs();
+ if (this_present_configs || that_present_configs) {
+ if (!(this_present_configs && that_present_configs))
+ return false;
+ if (!this.configs.equals(that.configs))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_configs = true && (isSetConfigs());
+ list.add(present_configs);
+ if (present_configs)
+ list.add(configs);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetJobsResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetConfigs()).compareTo(other.isSetConfigs());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetConfigs()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.configs, other.configs);
+ 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("GetJobsResult(");
+ boolean first = true;
+
+ sb.append("configs:");
+ if (this.configs == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.configs);
+ }
+ 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 {
+ 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 GetJobsResultStandardSchemeFactory implements SchemeFactory {
+ public GetJobsResultStandardScheme getScheme() {
+ return new GetJobsResultStandardScheme();
+ }
+ }
+
+ private static class GetJobsResultStandardScheme extends StandardScheme<GetJobsResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetJobsResult 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: // CONFIGS
+ if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+ {
+ org.apache.thrift.protocol.TSet _set134 = iprot.readSetBegin();
+ struct.configs = new HashSet<JobConfiguration>(2*_set134.size);
+ JobConfiguration _elem135;
+ for (int _i136 = 0; _i136 < _set134.size; ++_i136)
+ {
+ _elem135 = new JobConfiguration();
+ _elem135.read(iprot);
+ struct.configs.add(_elem135);
+ }
+ iprot.readSetEnd();
+ }
+ struct.setConfigsIsSet(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();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, GetJobsResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.configs != null) {
+ oprot.writeFieldBegin(CONFIGS_FIELD_DESC);
+ {
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.configs.size()));
+ for (JobConfiguration _iter137 : struct.configs)
+ {
+ _iter137.write(oprot);
+ }
+ oprot.writeSetEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetJobsResultTupleSchemeFactory implements SchemeFactory {
+ public GetJobsResultTupleScheme getScheme() {
+ return new GetJobsResultTupleScheme();
+ }
+ }
+
+ private static class GetJobsResultTupleScheme extends TupleScheme<GetJobsResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetJobsResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetConfigs()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetConfigs()) {
+ {
+ oprot.writeI32(struct.configs.size());
+ for (JobConfiguration _iter138 : struct.configs)
+ {
+ _iter138.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetJobsResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TSet _set139 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.configs = new HashSet<JobConfiguration>(2*_set139.size);
+ JobConfiguration _elem140;
+ for (int _i141 = 0; _i141 < _set139.size; ++_i141)
+ {
+ _elem140 = new JobConfiguration();
+ _elem140.read(iprot);
+ struct.configs.add(_elem140);
+ }
+ }
+ struct.setConfigsIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetPendingReasonResult.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetPendingReasonResult.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetPendingReasonResult.java
new file mode 100644
index 0000000..0459c80
--- /dev/null
+++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/GetPendingReasonResult.java
@@ -0,0 +1,452 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.airavata.cloud.aurora.client.sdk;
+
+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 org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+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 javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21")
+public class GetPendingReasonResult implements org.apache.thrift.TBase<GetPendingReasonResult, GetPendingReasonResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetPendingReasonResult> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPendingReasonResult");
+
+ private static final org.apache.thrift.protocol.TField REASONS_FIELD_DESC = new org.apache.thrift.protocol.TField("reasons", org.apache.thrift.protocol.TType.SET, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetPendingReasonResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetPendingReasonResultTupleSchemeFactory());
+ }
+
+ public Set<PendingReason> reasons; // 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 {
+ REASONS((short)1, "reasons");
+
+ 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: // REASONS
+ return REASONS;
+ 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.REASONS, new org.apache.thrift.meta_data.FieldMetaData("reasons", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PendingReason.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetPendingReasonResult.class, metaDataMap);
+ }
+
+ public GetPendingReasonResult() {
+ }
+
+ public GetPendingReasonResult(
+ Set<PendingReason> reasons)
+ {
+ this();
+ this.reasons = reasons;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetPendingReasonResult(GetPendingReasonResult other) {
+ if (other.isSetReasons()) {
+ Set<PendingReason> __this__reasons = new HashSet<PendingReason>(other.reasons.size());
+ for (PendingReason other_element : other.reasons) {
+ __this__reasons.add(new PendingReason(other_element));
+ }
+ this.reasons = __this__reasons;
+ }
+ }
+
+ public GetPendingReasonResult deepCopy() {
+ return new GetPendingReasonResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.reasons = null;
+ }
+
+ public int getReasonsSize() {
+ return (this.reasons == null) ? 0 : this.reasons.size();
+ }
+
+ public java.util.Iterator<PendingReason> getReasonsIterator() {
+ return (this.reasons == null) ? null : this.reasons.iterator();
+ }
+
+ public void addToReasons(PendingReason elem) {
+ if (this.reasons == null) {
+ this.reasons = new HashSet<PendingReason>();
+ }
+ this.reasons.add(elem);
+ }
+
+ public Set<PendingReason> getReasons() {
+ return this.reasons;
+ }
+
+ public GetPendingReasonResult setReasons(Set<PendingReason> reasons) {
+ this.reasons = reasons;
+ return this;
+ }
+
+ public void unsetReasons() {
+ this.reasons = null;
+ }
+
+ /** Returns true if field reasons is set (has been assigned a value) and false otherwise */
+ public boolean isSetReasons() {
+ return this.reasons != null;
+ }
+
+ public void setReasonsIsSet(boolean value) {
+ if (!value) {
+ this.reasons = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case REASONS:
+ if (value == null) {
+ unsetReasons();
+ } else {
+ setReasons((Set<PendingReason>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case REASONS:
+ return getReasons();
+
+ }
+ 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 REASONS:
+ return isSetReasons();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetPendingReasonResult)
+ return this.equals((GetPendingReasonResult)that);
+ return false;
+ }
+
+ public boolean equals(GetPendingReasonResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_reasons = true && this.isSetReasons();
+ boolean that_present_reasons = true && that.isSetReasons();
+ if (this_present_reasons || that_present_reasons) {
+ if (!(this_present_reasons && that_present_reasons))
+ return false;
+ if (!this.reasons.equals(that.reasons))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_reasons = true && (isSetReasons());
+ list.add(present_reasons);
+ if (present_reasons)
+ list.add(reasons);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetPendingReasonResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetReasons()).compareTo(other.isSetReasons());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReasons()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.reasons, other.reasons);
+ 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("GetPendingReasonResult(");
+ boolean first = true;
+
+ sb.append("reasons:");
+ if (this.reasons == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.reasons);
+ }
+ 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 {
+ 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 GetPendingReasonResultStandardSchemeFactory implements SchemeFactory {
+ public GetPendingReasonResultStandardScheme getScheme() {
+ return new GetPendingReasonResultStandardScheme();
+ }
+ }
+
+ private static class GetPendingReasonResultStandardScheme extends StandardScheme<GetPendingReasonResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetPendingReasonResult 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: // REASONS
+ if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
+ {
+ org.apache.thrift.protocol.TSet _set318 = iprot.readSetBegin();
+ struct.reasons = new HashSet<PendingReason>(2*_set318.size);
+ PendingReason _elem319;
+ for (int _i320 = 0; _i320 < _set318.size; ++_i320)
+ {
+ _elem319 = new PendingReason();
+ _elem319.read(iprot);
+ struct.reasons.add(_elem319);
+ }
+ iprot.readSetEnd();
+ }
+ struct.setReasonsIsSet(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();
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, GetPendingReasonResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.reasons != null) {
+ oprot.writeFieldBegin(REASONS_FIELD_DESC);
+ {
+ oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.reasons.size()));
+ for (PendingReason _iter321 : struct.reasons)
+ {
+ _iter321.write(oprot);
+ }
+ oprot.writeSetEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetPendingReasonResultTupleSchemeFactory implements SchemeFactory {
+ public GetPendingReasonResultTupleScheme getScheme() {
+ return new GetPendingReasonResultTupleScheme();
+ }
+ }
+
+ private static class GetPendingReasonResultTupleScheme extends TupleScheme<GetPendingReasonResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetPendingReasonResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetReasons()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetReasons()) {
+ {
+ oprot.writeI32(struct.reasons.size());
+ for (PendingReason _iter322 : struct.reasons)
+ {
+ _iter322.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetPendingReasonResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TSet _set323 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.reasons = new HashSet<PendingReason>(2*_set323.size);
+ PendingReason _elem324;
+ for (int _i325 = 0; _i325 < _set323.size; ++_i325)
+ {
+ _elem324 = new PendingReason();
+ _elem324.read(iprot);
+ struct.reasons.add(_elem324);
+ }
+ }
+ struct.setReasonsIsSet(true);
+ }
+ }
+ }
+
+}
+