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/Resource.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java new file mode 100644 index 0000000..3e8319d --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Resource.java @@ -0,0 +1,542 @@ +/** + * 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"}) +/** + * Describes resource value required to run a task. + */ +public class Resource extends org.apache.thrift.TUnion<Resource, Resource._Fields> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Resource"); + private static final org.apache.thrift.protocol.TField NUM_CPUS_FIELD_DESC = new org.apache.thrift.protocol.TField("numCpus", org.apache.thrift.protocol.TType.DOUBLE, (short)1); + private static final org.apache.thrift.protocol.TField RAM_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("ramMb", org.apache.thrift.protocol.TType.I64, (short)2); + private static final org.apache.thrift.protocol.TField DISK_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("diskMb", org.apache.thrift.protocol.TType.I64, (short)3); + private static final org.apache.thrift.protocol.TField NAMED_PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("namedPort", org.apache.thrift.protocol.TType.STRING, (short)4); + private static final org.apache.thrift.protocol.TField NUM_GPUS_FIELD_DESC = new org.apache.thrift.protocol.TField("numGpus", org.apache.thrift.protocol.TType.I64, (short)5); + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + NUM_CPUS((short)1, "numCpus"), + RAM_MB((short)2, "ramMb"), + DISK_MB((short)3, "diskMb"), + NAMED_PORT((short)4, "namedPort"), + NUM_GPUS((short)5, "numGpus"); + + 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: // NUM_CPUS + return NUM_CPUS; + case 2: // RAM_MB + return RAM_MB; + case 3: // DISK_MB + return DISK_MB; + case 4: // NAMED_PORT + return NAMED_PORT; + case 5: // NUM_GPUS + return NUM_GPUS; + 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); + tmpMap.put(_Fields.NUM_CPUS, new org.apache.thrift.meta_data.FieldMetaData("numCpus", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); + tmpMap.put(_Fields.RAM_MB, new org.apache.thrift.meta_data.FieldMetaData("ramMb", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.DISK_MB, new org.apache.thrift.meta_data.FieldMetaData("diskMb", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.NAMED_PORT, new org.apache.thrift.meta_data.FieldMetaData("namedPort", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.NUM_GPUS, new org.apache.thrift.meta_data.FieldMetaData("numGpus", 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(Resource.class, metaDataMap); + } + + public Resource() { + super(); + } + + public Resource(_Fields setField, Object value) { + super(setField, value); + } + + public Resource(Resource other) { + super(other); + } + public Resource deepCopy() { + return new Resource(this); + } + + public static Resource numCpus(double value) { + Resource x = new Resource(); + x.setNumCpus(value); + return x; + } + + public static Resource ramMb(long value) { + Resource x = new Resource(); + x.setRamMb(value); + return x; + } + + public static Resource diskMb(long value) { + Resource x = new Resource(); + x.setDiskMb(value); + return x; + } + + public static Resource namedPort(String value) { + Resource x = new Resource(); + x.setNamedPort(value); + return x; + } + + public static Resource numGpus(long value) { + Resource x = new Resource(); + x.setNumGpus(value); + return x; + } + + + @Override + protected void checkType(_Fields setField, Object value) throws ClassCastException { + switch (setField) { + case NUM_CPUS: + if (value instanceof Double) { + break; + } + throw new ClassCastException("Was expecting value of type Double for field 'numCpus', but got " + value.getClass().getSimpleName()); + case RAM_MB: + if (value instanceof Long) { + break; + } + throw new ClassCastException("Was expecting value of type Long for field 'ramMb', but got " + value.getClass().getSimpleName()); + case DISK_MB: + if (value instanceof Long) { + break; + } + throw new ClassCastException("Was expecting value of type Long for field 'diskMb', but got " + value.getClass().getSimpleName()); + case NAMED_PORT: + if (value instanceof String) { + break; + } + throw new ClassCastException("Was expecting value of type String for field 'namedPort', but got " + value.getClass().getSimpleName()); + case NUM_GPUS: + if (value instanceof Long) { + break; + } + throw new ClassCastException("Was expecting value of type Long for field 'numGpus', but got " + value.getClass().getSimpleName()); + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException { + _Fields setField = _Fields.findByThriftId(field.id); + if (setField != null) { + switch (setField) { + case NUM_CPUS: + if (field.type == NUM_CPUS_FIELD_DESC.type) { + Double numCpus; + numCpus = iprot.readDouble(); + return numCpus; + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case RAM_MB: + if (field.type == RAM_MB_FIELD_DESC.type) { + Long ramMb; + ramMb = iprot.readI64(); + return ramMb; + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case DISK_MB: + if (field.type == DISK_MB_FIELD_DESC.type) { + Long diskMb; + diskMb = iprot.readI64(); + return diskMb; + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case NAMED_PORT: + if (field.type == NAMED_PORT_FIELD_DESC.type) { + String namedPort; + namedPort = iprot.readString(); + return namedPort; + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case NUM_GPUS: + if (field.type == NUM_GPUS_FIELD_DESC.type) { + Long numGpus; + numGpus = iprot.readI64(); + return numGpus; + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + } + + @Override + protected void standardSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + switch (setField_) { + case NUM_CPUS: + Double numCpus = (Double)value_; + oprot.writeDouble(numCpus); + return; + case RAM_MB: + Long ramMb = (Long)value_; + oprot.writeI64(ramMb); + return; + case DISK_MB: + Long diskMb = (Long)value_; + oprot.writeI64(diskMb); + return; + case NAMED_PORT: + String namedPort = (String)value_; + oprot.writeString(namedPort); + return; + case NUM_GPUS: + Long numGpus = (Long)value_; + oprot.writeI64(numGpus); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException { + _Fields setField = _Fields.findByThriftId(fieldID); + if (setField != null) { + switch (setField) { + case NUM_CPUS: + Double numCpus; + numCpus = iprot.readDouble(); + return numCpus; + case RAM_MB: + Long ramMb; + ramMb = iprot.readI64(); + return ramMb; + case DISK_MB: + Long diskMb; + diskMb = iprot.readI64(); + return diskMb; + case NAMED_PORT: + String namedPort; + namedPort = iprot.readString(); + return namedPort; + case NUM_GPUS: + Long numGpus; + numGpus = iprot.readI64(); + return numGpus; + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + throw new TProtocolException("Couldn't find a field with field id " + fieldID); + } + } + + @Override + protected void tupleSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + switch (setField_) { + case NUM_CPUS: + Double numCpus = (Double)value_; + oprot.writeDouble(numCpus); + return; + case RAM_MB: + Long ramMb = (Long)value_; + oprot.writeI64(ramMb); + return; + case DISK_MB: + Long diskMb = (Long)value_; + oprot.writeI64(diskMb); + return; + case NAMED_PORT: + String namedPort = (String)value_; + oprot.writeString(namedPort); + return; + case NUM_GPUS: + Long numGpus = (Long)value_; + oprot.writeI64(numGpus); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected org.apache.thrift.protocol.TField getFieldDesc(_Fields setField) { + switch (setField) { + case NUM_CPUS: + return NUM_CPUS_FIELD_DESC; + case RAM_MB: + return RAM_MB_FIELD_DESC; + case DISK_MB: + return DISK_MB_FIELD_DESC; + case NAMED_PORT: + return NAMED_PORT_FIELD_DESC; + case NUM_GPUS: + return NUM_GPUS_FIELD_DESC; + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected org.apache.thrift.protocol.TStruct getStructDesc() { + return STRUCT_DESC; + } + + @Override + protected _Fields enumForId(short id) { + return _Fields.findByThriftIdOrThrow(id); + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + + public double getNumCpus() { + if (getSetField() == _Fields.NUM_CPUS) { + return (Double)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'numCpus' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setNumCpus(double value) { + setField_ = _Fields.NUM_CPUS; + value_ = value; + } + + public long getRamMb() { + if (getSetField() == _Fields.RAM_MB) { + return (Long)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'ramMb' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setRamMb(long value) { + setField_ = _Fields.RAM_MB; + value_ = value; + } + + public long getDiskMb() { + if (getSetField() == _Fields.DISK_MB) { + return (Long)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'diskMb' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setDiskMb(long value) { + setField_ = _Fields.DISK_MB; + value_ = value; + } + + public String getNamedPort() { + if (getSetField() == _Fields.NAMED_PORT) { + return (String)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'namedPort' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setNamedPort(String value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.NAMED_PORT; + value_ = value; + } + + public long getNumGpus() { + if (getSetField() == _Fields.NUM_GPUS) { + return (Long)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'numGpus' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setNumGpus(long value) { + setField_ = _Fields.NUM_GPUS; + value_ = value; + } + + public boolean isSetNumCpus() { + return setField_ == _Fields.NUM_CPUS; + } + + + public boolean isSetRamMb() { + return setField_ == _Fields.RAM_MB; + } + + + public boolean isSetDiskMb() { + return setField_ == _Fields.DISK_MB; + } + + + public boolean isSetNamedPort() { + return setField_ == _Fields.NAMED_PORT; + } + + + public boolean isSetNumGpus() { + return setField_ == _Fields.NUM_GPUS; + } + + + public boolean equals(Object other) { + if (other instanceof Resource) { + return equals((Resource)other); + } else { + return false; + } + } + + public boolean equals(Resource other) { + return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue()); + } + + @Override + public int compareTo(Resource other) { + int lastComparison = org.apache.thrift.TBaseHelper.compareTo(getSetField(), other.getSetField()); + if (lastComparison == 0) { + return org.apache.thrift.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue()); + } + return lastComparison; + } + + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + list.add(this.getClass().getName()); + org.apache.thrift.TFieldIdEnum setField = getSetField(); + if (setField != null) { + list.add(setField.getThriftFieldId()); + Object value = getFieldValue(); + if (value instanceof org.apache.thrift.TEnum) { + list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue()); + } else { + list.add(value); + } + } + return list.hashCode(); + } + 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); + } + } + + +}
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/ResourceAggregate.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java new file mode 100644 index 0000000..d288c1c --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResourceAggregate.java @@ -0,0 +1,801 @@ +/** + * 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 ResourceAggregate implements org.apache.thrift.TBase<ResourceAggregate, ResourceAggregate._Fields>, java.io.Serializable, Cloneable, Comparable<ResourceAggregate> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ResourceAggregate"); + + private static final org.apache.thrift.protocol.TField NUM_CPUS_FIELD_DESC = new org.apache.thrift.protocol.TField("numCpus", org.apache.thrift.protocol.TType.DOUBLE, (short)1); + private static final org.apache.thrift.protocol.TField RAM_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("ramMb", org.apache.thrift.protocol.TType.I64, (short)2); + private static final org.apache.thrift.protocol.TField DISK_MB_FIELD_DESC = new org.apache.thrift.protocol.TField("diskMb", org.apache.thrift.protocol.TType.I64, (short)3); + private static final org.apache.thrift.protocol.TField RESOURCES_FIELD_DESC = new org.apache.thrift.protocol.TField("resources", 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 ResourceAggregateStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ResourceAggregateTupleSchemeFactory()); + } + + /** + * Number of CPU cores allotted. + */ + public double numCpus; // required + /** + * Megabytes of RAM allotted. + */ + public long ramMb; // required + /** + * Megabytes of disk space allotted. + */ + public long diskMb; // required + /** + * Aggregated resource values. + */ + public Set<Resource> resources; // 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 { + /** + * Number of CPU cores allotted. + */ + NUM_CPUS((short)1, "numCpus"), + /** + * Megabytes of RAM allotted. + */ + RAM_MB((short)2, "ramMb"), + /** + * Megabytes of disk space allotted. + */ + DISK_MB((short)3, "diskMb"), + /** + * Aggregated resource values. + */ + RESOURCES((short)4, "resources"); + + 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: // NUM_CPUS + return NUM_CPUS; + case 2: // RAM_MB + return RAM_MB; + case 3: // DISK_MB + return DISK_MB; + case 4: // RESOURCES + return RESOURCES; + 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 __NUMCPUS_ISSET_ID = 0; + private static final int __RAMMB_ISSET_ID = 1; + private static final int __DISKMB_ISSET_ID = 2; + 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.NUM_CPUS, new org.apache.thrift.meta_data.FieldMetaData("numCpus", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); + tmpMap.put(_Fields.RAM_MB, new org.apache.thrift.meta_data.FieldMetaData("ramMb", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.DISK_MB, new org.apache.thrift.meta_data.FieldMetaData("diskMb", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.RESOURCES, new org.apache.thrift.meta_data.FieldMetaData("resources", 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, Resource.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ResourceAggregate.class, metaDataMap); + } + + public ResourceAggregate() { + } + + public ResourceAggregate( + double numCpus, + long ramMb, + long diskMb, + Set<Resource> resources) + { + this(); + this.numCpus = numCpus; + setNumCpusIsSet(true); + this.ramMb = ramMb; + setRamMbIsSet(true); + this.diskMb = diskMb; + setDiskMbIsSet(true); + this.resources = resources; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public ResourceAggregate(ResourceAggregate other) { + __isset_bitfield = other.__isset_bitfield; + this.numCpus = other.numCpus; + this.ramMb = other.ramMb; + this.diskMb = other.diskMb; + if (other.isSetResources()) { + Set<Resource> __this__resources = new HashSet<Resource>(other.resources.size()); + for (Resource other_element : other.resources) { + __this__resources.add(new Resource(other_element)); + } + this.resources = __this__resources; + } + } + + public ResourceAggregate deepCopy() { + return new ResourceAggregate(this); + } + + @Override + public void clear() { + setNumCpusIsSet(false); + this.numCpus = 0.0; + setRamMbIsSet(false); + this.ramMb = 0; + setDiskMbIsSet(false); + this.diskMb = 0; + this.resources = null; + } + + /** + * Number of CPU cores allotted. + */ + public double getNumCpus() { + return this.numCpus; + } + + /** + * Number of CPU cores allotted. + */ + public ResourceAggregate setNumCpus(double numCpus) { + this.numCpus = numCpus; + setNumCpusIsSet(true); + return this; + } + + public void unsetNumCpus() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMCPUS_ISSET_ID); + } + + /** Returns true if field numCpus is set (has been assigned a value) and false otherwise */ + public boolean isSetNumCpus() { + return EncodingUtils.testBit(__isset_bitfield, __NUMCPUS_ISSET_ID); + } + + public void setNumCpusIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMCPUS_ISSET_ID, value); + } + + /** + * Megabytes of RAM allotted. + */ + public long getRamMb() { + return this.ramMb; + } + + /** + * Megabytes of RAM allotted. + */ + public ResourceAggregate setRamMb(long ramMb) { + this.ramMb = ramMb; + setRamMbIsSet(true); + return this; + } + + public void unsetRamMb() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __RAMMB_ISSET_ID); + } + + /** Returns true if field ramMb is set (has been assigned a value) and false otherwise */ + public boolean isSetRamMb() { + return EncodingUtils.testBit(__isset_bitfield, __RAMMB_ISSET_ID); + } + + public void setRamMbIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __RAMMB_ISSET_ID, value); + } + + /** + * Megabytes of disk space allotted. + */ + public long getDiskMb() { + return this.diskMb; + } + + /** + * Megabytes of disk space allotted. + */ + public ResourceAggregate setDiskMb(long diskMb) { + this.diskMb = diskMb; + setDiskMbIsSet(true); + return this; + } + + public void unsetDiskMb() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __DISKMB_ISSET_ID); + } + + /** Returns true if field diskMb is set (has been assigned a value) and false otherwise */ + public boolean isSetDiskMb() { + return EncodingUtils.testBit(__isset_bitfield, __DISKMB_ISSET_ID); + } + + public void setDiskMbIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __DISKMB_ISSET_ID, value); + } + + public int getResourcesSize() { + return (this.resources == null) ? 0 : this.resources.size(); + } + + public java.util.Iterator<Resource> getResourcesIterator() { + return (this.resources == null) ? null : this.resources.iterator(); + } + + public void addToResources(Resource elem) { + if (this.resources == null) { + this.resources = new HashSet<Resource>(); + } + this.resources.add(elem); + } + + /** + * Aggregated resource values. + */ + public Set<Resource> getResources() { + return this.resources; + } + + /** + * Aggregated resource values. + */ + public ResourceAggregate setResources(Set<Resource> resources) { + this.resources = resources; + return this; + } + + public void unsetResources() { + this.resources = null; + } + + /** Returns true if field resources is set (has been assigned a value) and false otherwise */ + public boolean isSetResources() { + return this.resources != null; + } + + public void setResourcesIsSet(boolean value) { + if (!value) { + this.resources = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case NUM_CPUS: + if (value == null) { + unsetNumCpus(); + } else { + setNumCpus((Double)value); + } + break; + + case RAM_MB: + if (value == null) { + unsetRamMb(); + } else { + setRamMb((Long)value); + } + break; + + case DISK_MB: + if (value == null) { + unsetDiskMb(); + } else { + setDiskMb((Long)value); + } + break; + + case RESOURCES: + if (value == null) { + unsetResources(); + } else { + setResources((Set<Resource>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case NUM_CPUS: + return getNumCpus(); + + case RAM_MB: + return getRamMb(); + + case DISK_MB: + return getDiskMb(); + + case RESOURCES: + return getResources(); + + } + 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 NUM_CPUS: + return isSetNumCpus(); + case RAM_MB: + return isSetRamMb(); + case DISK_MB: + return isSetDiskMb(); + case RESOURCES: + return isSetResources(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof ResourceAggregate) + return this.equals((ResourceAggregate)that); + return false; + } + + public boolean equals(ResourceAggregate that) { + if (that == null) + return false; + + boolean this_present_numCpus = true; + boolean that_present_numCpus = true; + if (this_present_numCpus || that_present_numCpus) { + if (!(this_present_numCpus && that_present_numCpus)) + return false; + if (this.numCpus != that.numCpus) + return false; + } + + boolean this_present_ramMb = true; + boolean that_present_ramMb = true; + if (this_present_ramMb || that_present_ramMb) { + if (!(this_present_ramMb && that_present_ramMb)) + return false; + if (this.ramMb != that.ramMb) + return false; + } + + boolean this_present_diskMb = true; + boolean that_present_diskMb = true; + if (this_present_diskMb || that_present_diskMb) { + if (!(this_present_diskMb && that_present_diskMb)) + return false; + if (this.diskMb != that.diskMb) + return false; + } + + boolean this_present_resources = true && this.isSetResources(); + boolean that_present_resources = true && that.isSetResources(); + if (this_present_resources || that_present_resources) { + if (!(this_present_resources && that_present_resources)) + return false; + if (!this.resources.equals(that.resources)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_numCpus = true; + list.add(present_numCpus); + if (present_numCpus) + list.add(numCpus); + + boolean present_ramMb = true; + list.add(present_ramMb); + if (present_ramMb) + list.add(ramMb); + + boolean present_diskMb = true; + list.add(present_diskMb); + if (present_diskMb) + list.add(diskMb); + + boolean present_resources = true && (isSetResources()); + list.add(present_resources); + if (present_resources) + list.add(resources); + + return list.hashCode(); + } + + @Override + public int compareTo(ResourceAggregate other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetNumCpus()).compareTo(other.isSetNumCpus()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNumCpus()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numCpus, other.numCpus); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRamMb()).compareTo(other.isSetRamMb()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRamMb()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ramMb, other.ramMb); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDiskMb()).compareTo(other.isSetDiskMb()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDiskMb()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.diskMb, other.diskMb); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetResources()).compareTo(other.isSetResources()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetResources()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resources, other.resources); + 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("ResourceAggregate("); + boolean first = true; + + sb.append("numCpus:"); + sb.append(this.numCpus); + first = false; + if (!first) sb.append(", "); + sb.append("ramMb:"); + sb.append(this.ramMb); + first = false; + if (!first) sb.append(", "); + sb.append("diskMb:"); + sb.append(this.diskMb); + first = false; + if (!first) sb.append(", "); + sb.append("resources:"); + if (this.resources == null) { + sb.append("null"); + } else { + sb.append(this.resources); + } + 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 ResourceAggregateStandardSchemeFactory implements SchemeFactory { + public ResourceAggregateStandardScheme getScheme() { + return new ResourceAggregateStandardScheme(); + } + } + + private static class ResourceAggregateStandardScheme extends StandardScheme<ResourceAggregate> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, ResourceAggregate 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: // NUM_CPUS + if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) { + struct.numCpus = iprot.readDouble(); + struct.setNumCpusIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // RAM_MB + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.ramMb = iprot.readI64(); + struct.setRamMbIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // DISK_MB + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.diskMb = iprot.readI64(); + struct.setDiskMbIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // RESOURCES + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set84 = iprot.readSetBegin(); + struct.resources = new HashSet<Resource>(2*_set84.size); + Resource _elem85; + for (int _i86 = 0; _i86 < _set84.size; ++_i86) + { + _elem85 = new Resource(); + _elem85.read(iprot); + struct.resources.add(_elem85); + } + iprot.readSetEnd(); + } + struct.setResourcesIsSet(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, ResourceAggregate struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(NUM_CPUS_FIELD_DESC); + oprot.writeDouble(struct.numCpus); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(RAM_MB_FIELD_DESC); + oprot.writeI64(struct.ramMb); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(DISK_MB_FIELD_DESC); + oprot.writeI64(struct.diskMb); + oprot.writeFieldEnd(); + if (struct.resources != null) { + oprot.writeFieldBegin(RESOURCES_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.resources.size())); + for (Resource _iter87 : struct.resources) + { + _iter87.write(oprot); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ResourceAggregateTupleSchemeFactory implements SchemeFactory { + public ResourceAggregateTupleScheme getScheme() { + return new ResourceAggregateTupleScheme(); + } + } + + private static class ResourceAggregateTupleScheme extends TupleScheme<ResourceAggregate> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, ResourceAggregate struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetNumCpus()) { + optionals.set(0); + } + if (struct.isSetRamMb()) { + optionals.set(1); + } + if (struct.isSetDiskMb()) { + optionals.set(2); + } + if (struct.isSetResources()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetNumCpus()) { + oprot.writeDouble(struct.numCpus); + } + if (struct.isSetRamMb()) { + oprot.writeI64(struct.ramMb); + } + if (struct.isSetDiskMb()) { + oprot.writeI64(struct.diskMb); + } + if (struct.isSetResources()) { + { + oprot.writeI32(struct.resources.size()); + for (Resource _iter88 : struct.resources) + { + _iter88.write(oprot); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, ResourceAggregate struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.numCpus = iprot.readDouble(); + struct.setNumCpusIsSet(true); + } + if (incoming.get(1)) { + struct.ramMb = iprot.readI64(); + struct.setRamMbIsSet(true); + } + if (incoming.get(2)) { + struct.diskMb = iprot.readI64(); + struct.setDiskMbIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.thrift.protocol.TSet _set89 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.resources = new HashSet<Resource>(2*_set89.size); + Resource _elem90; + for (int _i91 = 0; _i91 < _set89.size; ++_i91) + { + _elem90 = new Resource(); + _elem90.read(iprot); + struct.resources.add(_elem90); + } + } + struct.setResourcesIsSet(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/Response.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java new file mode 100644 index 0000000..3f974c0 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/Response.java @@ -0,0 +1,821 @@ +/** + * 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 Response implements org.apache.thrift.TBase<Response, Response._Fields>, java.io.Serializable, Cloneable, Comparable<Response> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Response"); + + private static final org.apache.thrift.protocol.TField RESPONSE_CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("responseCode", org.apache.thrift.protocol.TType.I32, (short)1); + private static final org.apache.thrift.protocol.TField SERVER_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("serverInfo", org.apache.thrift.protocol.TType.STRUCT, (short)5); + private static final org.apache.thrift.protocol.TField RESULT_FIELD_DESC = new org.apache.thrift.protocol.TField("result", org.apache.thrift.protocol.TType.STRUCT, (short)3); + private static final org.apache.thrift.protocol.TField DETAILS_FIELD_DESC = new org.apache.thrift.protocol.TField("details", org.apache.thrift.protocol.TType.LIST, (short)6); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ResponseStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ResponseTupleSchemeFactory()); + } + + /** + * + * @see ResponseCode + */ + public ResponseCode responseCode; // required + public ServerInfo serverInfo; // required + /** + * Payload from the invoked RPC. + */ + public Result result; // optional + /** + * Messages from the server relevant to the request, such as warnings or use of deprecated + * features. + */ + public List<ResponseDetail> details; // 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 { + /** + * + * @see ResponseCode + */ + RESPONSE_CODE((short)1, "responseCode"), + SERVER_INFO((short)5, "serverInfo"), + /** + * Payload from the invoked RPC. + */ + RESULT((short)3, "result"), + /** + * Messages from the server relevant to the request, such as warnings or use of deprecated + * features. + */ + DETAILS((short)6, "details"); + + 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: // RESPONSE_CODE + return RESPONSE_CODE; + case 5: // SERVER_INFO + return SERVER_INFO; + case 3: // RESULT + return RESULT; + case 6: // DETAILS + return DETAILS; + 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 _Fields optionals[] = {_Fields.RESULT}; + 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.RESPONSE_CODE, new org.apache.thrift.meta_data.FieldMetaData("responseCode", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ResponseCode.class))); + tmpMap.put(_Fields.SERVER_INFO, new org.apache.thrift.meta_data.FieldMetaData("serverInfo", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ServerInfo.class))); + tmpMap.put(_Fields.RESULT, new org.apache.thrift.meta_data.FieldMetaData("result", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Result.class))); + tmpMap.put(_Fields.DETAILS, new org.apache.thrift.meta_data.FieldMetaData("details", 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, ResponseDetail.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Response.class, metaDataMap); + } + + public Response() { + } + + public Response( + ResponseCode responseCode, + ServerInfo serverInfo, + List<ResponseDetail> details) + { + this(); + this.responseCode = responseCode; + this.serverInfo = serverInfo; + this.details = details; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Response(Response other) { + if (other.isSetResponseCode()) { + this.responseCode = other.responseCode; + } + if (other.isSetServerInfo()) { + this.serverInfo = new ServerInfo(other.serverInfo); + } + if (other.isSetResult()) { + this.result = new Result(other.result); + } + if (other.isSetDetails()) { + List<ResponseDetail> __this__details = new ArrayList<ResponseDetail>(other.details.size()); + for (ResponseDetail other_element : other.details) { + __this__details.add(new ResponseDetail(other_element)); + } + this.details = __this__details; + } + } + + public Response deepCopy() { + return new Response(this); + } + + @Override + public void clear() { + this.responseCode = null; + this.serverInfo = null; + this.result = null; + this.details = null; + } + + /** + * + * @see ResponseCode + */ + public ResponseCode getResponseCode() { + return this.responseCode; + } + + /** + * + * @see ResponseCode + */ + public Response setResponseCode(ResponseCode responseCode) { + this.responseCode = responseCode; + return this; + } + + public void unsetResponseCode() { + this.responseCode = null; + } + + /** Returns true if field responseCode is set (has been assigned a value) and false otherwise */ + public boolean isSetResponseCode() { + return this.responseCode != null; + } + + public void setResponseCodeIsSet(boolean value) { + if (!value) { + this.responseCode = null; + } + } + + public ServerInfo getServerInfo() { + return this.serverInfo; + } + + public Response setServerInfo(ServerInfo serverInfo) { + this.serverInfo = serverInfo; + return this; + } + + public void unsetServerInfo() { + this.serverInfo = null; + } + + /** Returns true if field serverInfo is set (has been assigned a value) and false otherwise */ + public boolean isSetServerInfo() { + return this.serverInfo != null; + } + + public void setServerInfoIsSet(boolean value) { + if (!value) { + this.serverInfo = null; + } + } + + /** + * Payload from the invoked RPC. + */ + public Result getResult() { + return this.result; + } + + /** + * Payload from the invoked RPC. + */ + public Response setResult(Result result) { + this.result = result; + return this; + } + + public void unsetResult() { + this.result = null; + } + + /** Returns true if field result is set (has been assigned a value) and false otherwise */ + public boolean isSetResult() { + return this.result != null; + } + + public void setResultIsSet(boolean value) { + if (!value) { + this.result = null; + } + } + + public int getDetailsSize() { + return (this.details == null) ? 0 : this.details.size(); + } + + public java.util.Iterator<ResponseDetail> getDetailsIterator() { + return (this.details == null) ? null : this.details.iterator(); + } + + public void addToDetails(ResponseDetail elem) { + if (this.details == null) { + this.details = new ArrayList<ResponseDetail>(); + } + this.details.add(elem); + } + + /** + * Messages from the server relevant to the request, such as warnings or use of deprecated + * features. + */ + public List<ResponseDetail> getDetails() { + return this.details; + } + + /** + * Messages from the server relevant to the request, such as warnings or use of deprecated + * features. + */ + public Response setDetails(List<ResponseDetail> details) { + this.details = details; + return this; + } + + public void unsetDetails() { + this.details = null; + } + + /** Returns true if field details is set (has been assigned a value) and false otherwise */ + public boolean isSetDetails() { + return this.details != null; + } + + public void setDetailsIsSet(boolean value) { + if (!value) { + this.details = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case RESPONSE_CODE: + if (value == null) { + unsetResponseCode(); + } else { + setResponseCode((ResponseCode)value); + } + break; + + case SERVER_INFO: + if (value == null) { + unsetServerInfo(); + } else { + setServerInfo((ServerInfo)value); + } + break; + + case RESULT: + if (value == null) { + unsetResult(); + } else { + setResult((Result)value); + } + break; + + case DETAILS: + if (value == null) { + unsetDetails(); + } else { + setDetails((List<ResponseDetail>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case RESPONSE_CODE: + return getResponseCode(); + + case SERVER_INFO: + return getServerInfo(); + + case RESULT: + return getResult(); + + case DETAILS: + return getDetails(); + + } + 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 RESPONSE_CODE: + return isSetResponseCode(); + case SERVER_INFO: + return isSetServerInfo(); + case RESULT: + return isSetResult(); + case DETAILS: + return isSetDetails(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Response) + return this.equals((Response)that); + return false; + } + + public boolean equals(Response that) { + if (that == null) + return false; + + boolean this_present_responseCode = true && this.isSetResponseCode(); + boolean that_present_responseCode = true && that.isSetResponseCode(); + if (this_present_responseCode || that_present_responseCode) { + if (!(this_present_responseCode && that_present_responseCode)) + return false; + if (!this.responseCode.equals(that.responseCode)) + return false; + } + + boolean this_present_serverInfo = true && this.isSetServerInfo(); + boolean that_present_serverInfo = true && that.isSetServerInfo(); + if (this_present_serverInfo || that_present_serverInfo) { + if (!(this_present_serverInfo && that_present_serverInfo)) + return false; + if (!this.serverInfo.equals(that.serverInfo)) + return false; + } + + boolean this_present_result = true && this.isSetResult(); + boolean that_present_result = true && that.isSetResult(); + if (this_present_result || that_present_result) { + if (!(this_present_result && that_present_result)) + return false; + if (!this.result.equals(that.result)) + return false; + } + + boolean this_present_details = true && this.isSetDetails(); + boolean that_present_details = true && that.isSetDetails(); + if (this_present_details || that_present_details) { + if (!(this_present_details && that_present_details)) + return false; + if (!this.details.equals(that.details)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_responseCode = true && (isSetResponseCode()); + list.add(present_responseCode); + if (present_responseCode) + list.add(responseCode.getValue()); + + boolean present_serverInfo = true && (isSetServerInfo()); + list.add(present_serverInfo); + if (present_serverInfo) + list.add(serverInfo); + + boolean present_result = true && (isSetResult()); + list.add(present_result); + if (present_result) + list.add(result); + + boolean present_details = true && (isSetDetails()); + list.add(present_details); + if (present_details) + list.add(details); + + return list.hashCode(); + } + + @Override + public int compareTo(Response other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetResponseCode()).compareTo(other.isSetResponseCode()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetResponseCode()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.responseCode, other.responseCode); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetServerInfo()).compareTo(other.isSetServerInfo()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetServerInfo()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.serverInfo, other.serverInfo); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetResult()).compareTo(other.isSetResult()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetResult()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.result, other.result); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDetails()).compareTo(other.isSetDetails()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDetails()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.details, other.details); + 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("Response("); + boolean first = true; + + sb.append("responseCode:"); + if (this.responseCode == null) { + sb.append("null"); + } else { + sb.append(this.responseCode); + } + first = false; + if (!first) sb.append(", "); + sb.append("serverInfo:"); + if (this.serverInfo == null) { + sb.append("null"); + } else { + sb.append(this.serverInfo); + } + first = false; + if (isSetResult()) { + if (!first) sb.append(", "); + sb.append("result:"); + if (this.result == null) { + sb.append("null"); + } else { + sb.append(this.result); + } + first = false; + } + if (!first) sb.append(", "); + sb.append("details:"); + if (this.details == null) { + sb.append("null"); + } else { + sb.append(this.details); + } + 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 (serverInfo != null) { + serverInfo.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 ResponseStandardSchemeFactory implements SchemeFactory { + public ResponseStandardScheme getScheme() { + return new ResponseStandardScheme(); + } + } + + private static class ResponseStandardScheme extends StandardScheme<Response> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, Response 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: // RESPONSE_CODE + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.responseCode = org.apache.airavata.cloud.aurora.client.sdk.ResponseCode.findByValue(iprot.readI32()); + struct.setResponseCodeIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // SERVER_INFO + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.serverInfo = new ServerInfo(); + struct.serverInfo.read(iprot); + struct.setServerInfoIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // RESULT + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.result = new Result(); + struct.result.read(iprot); + struct.setResultIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // DETAILS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list392 = iprot.readListBegin(); + struct.details = new ArrayList<ResponseDetail>(_list392.size); + ResponseDetail _elem393; + for (int _i394 = 0; _i394 < _list392.size; ++_i394) + { + _elem393 = new ResponseDetail(); + _elem393.read(iprot); + struct.details.add(_elem393); + } + iprot.readListEnd(); + } + struct.setDetailsIsSet(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, Response struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.responseCode != null) { + oprot.writeFieldBegin(RESPONSE_CODE_FIELD_DESC); + oprot.writeI32(struct.responseCode.getValue()); + oprot.writeFieldEnd(); + } + if (struct.result != null) { + if (struct.isSetResult()) { + oprot.writeFieldBegin(RESULT_FIELD_DESC); + struct.result.write(oprot); + oprot.writeFieldEnd(); + } + } + if (struct.serverInfo != null) { + oprot.writeFieldBegin(SERVER_INFO_FIELD_DESC); + struct.serverInfo.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.details != null) { + oprot.writeFieldBegin(DETAILS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.details.size())); + for (ResponseDetail _iter395 : struct.details) + { + _iter395.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ResponseTupleSchemeFactory implements SchemeFactory { + public ResponseTupleScheme getScheme() { + return new ResponseTupleScheme(); + } + } + + private static class ResponseTupleScheme extends TupleScheme<Response> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, Response struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetResponseCode()) { + optionals.set(0); + } + if (struct.isSetServerInfo()) { + optionals.set(1); + } + if (struct.isSetResult()) { + optionals.set(2); + } + if (struct.isSetDetails()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetResponseCode()) { + oprot.writeI32(struct.responseCode.getValue()); + } + if (struct.isSetServerInfo()) { + struct.serverInfo.write(oprot); + } + if (struct.isSetResult()) { + struct.result.write(oprot); + } + if (struct.isSetDetails()) { + { + oprot.writeI32(struct.details.size()); + for (ResponseDetail _iter396 : struct.details) + { + _iter396.write(oprot); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, Response struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.responseCode = org.apache.airavata.cloud.aurora.client.sdk.ResponseCode.findByValue(iprot.readI32()); + struct.setResponseCodeIsSet(true); + } + if (incoming.get(1)) { + struct.serverInfo = new ServerInfo(); + struct.serverInfo.read(iprot); + struct.setServerInfoIsSet(true); + } + if (incoming.get(2)) { + struct.result = new Result(); + struct.result.read(iprot); + struct.setResultIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.thrift.protocol.TList _list397 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.details = new ArrayList<ResponseDetail>(_list397.size); + ResponseDetail _elem398; + for (int _i399 = 0; _i399 < _list397.size; ++_i399) + { + _elem398 = new ResponseDetail(); + _elem398.read(iprot); + struct.details.add(_elem398); + } + } + struct.setDetailsIsSet(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/ResponseCode.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java new file mode 100644 index 0000000..afee9e3 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseCode.java @@ -0,0 +1,66 @@ +/** + * 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 java.util.Map; +import java.util.HashMap; +import org.apache.thrift.TEnum; + +public enum ResponseCode implements org.apache.thrift.TEnum { + INVALID_REQUEST(0), + OK(1), + ERROR(2), + WARNING(3), + AUTH_FAILED(4), + /** + * Raised when a Lock-protected operation failed due to lock validation. + */ + LOCK_ERROR(5), + /** + * Raised when a scheduler is transiently unavailable and later retry is recommended. + */ + ERROR_TRANSIENT(6); + + private final int value; + + private ResponseCode(int value) { + this.value = value; + } + + /** + * Get the integer value of this enum value, as defined in the Thrift IDL. + */ + public int getValue() { + return value; + } + + /** + * Find a the enum type by its integer value, as defined in the Thrift IDL. + * @return null if the value is not found. + */ + public static ResponseCode findByValue(int value) { + switch (value) { + case 0: + return INVALID_REQUEST; + case 1: + return OK; + case 2: + return ERROR; + case 3: + return WARNING; + case 4: + return AUTH_FAILED; + case 5: + return LOCK_ERROR; + case 6: + return ERROR_TRANSIENT; + default: + return null; + } + } +} 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/ResponseDetail.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java new file mode 100644 index 0000000..43ec385 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ResponseDetail.java @@ -0,0 +1,398 @@ +/** + * 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 ResponseDetail implements org.apache.thrift.TBase<ResponseDetail, ResponseDetail._Fields>, java.io.Serializable, Cloneable, Comparable<ResponseDetail> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ResponseDetail"); + + private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ResponseDetailStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ResponseDetailTupleSchemeFactory()); + } + + public String message; // 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 { + MESSAGE((short)1, "message"); + + 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: // MESSAGE + return MESSAGE; + 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.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ResponseDetail.class, metaDataMap); + } + + public ResponseDetail() { + } + + public ResponseDetail( + String message) + { + this(); + this.message = message; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public ResponseDetail(ResponseDetail other) { + if (other.isSetMessage()) { + this.message = other.message; + } + } + + public ResponseDetail deepCopy() { + return new ResponseDetail(this); + } + + @Override + public void clear() { + this.message = null; + } + + public String getMessage() { + return this.message; + } + + public ResponseDetail setMessage(String message) { + this.message = message; + return this; + } + + public void unsetMessage() { + this.message = null; + } + + /** Returns true if field message is set (has been assigned a value) and false otherwise */ + public boolean isSetMessage() { + return this.message != null; + } + + public void setMessageIsSet(boolean value) { + if (!value) { + this.message = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case MESSAGE: + if (value == null) { + unsetMessage(); + } else { + setMessage((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case MESSAGE: + return getMessage(); + + } + 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 MESSAGE: + return isSetMessage(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof ResponseDetail) + return this.equals((ResponseDetail)that); + return false; + } + + public boolean equals(ResponseDetail that) { + if (that == null) + return false; + + boolean this_present_message = true && this.isSetMessage(); + boolean that_present_message = true && that.isSetMessage(); + if (this_present_message || that_present_message) { + if (!(this_present_message && that_present_message)) + return false; + if (!this.message.equals(that.message)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_message = true && (isSetMessage()); + list.add(present_message); + if (present_message) + list.add(message); + + return list.hashCode(); + } + + @Override + public int compareTo(ResponseDetail other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetMessage()).compareTo(other.isSetMessage()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetMessage()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, other.message); + 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("ResponseDetail("); + boolean first = true; + + sb.append("message:"); + if (this.message == null) { + sb.append("null"); + } else { + sb.append(this.message); + } + 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 ResponseDetailStandardSchemeFactory implements SchemeFactory { + public ResponseDetailStandardScheme getScheme() { + return new ResponseDetailStandardScheme(); + } + } + + private static class ResponseDetailStandardScheme extends StandardScheme<ResponseDetail> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, ResponseDetail 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: // MESSAGE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.message = iprot.readString(); + struct.setMessageIsSet(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, ResponseDetail struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.message != null) { + oprot.writeFieldBegin(MESSAGE_FIELD_DESC); + oprot.writeString(struct.message); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ResponseDetailTupleSchemeFactory implements SchemeFactory { + public ResponseDetailTupleScheme getScheme() { + return new ResponseDetailTupleScheme(); + } + } + + private static class ResponseDetailTupleScheme extends TupleScheme<ResponseDetail> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, ResponseDetail struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetMessage()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetMessage()) { + oprot.writeString(struct.message); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, ResponseDetail struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.message = iprot.readString(); + struct.setMessageIsSet(true); + } + } + } + +} +
