http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateDetails.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateDetails.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateDetails.java deleted file mode 100644 index 7cb0a0c..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateDetails.java +++ /dev/null @@ -1,776 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * 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 JobUpdateDetails implements org.apache.thrift.TBase<JobUpdateDetails, JobUpdateDetails._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdateDetails> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdateDetails"); - - private static final org.apache.thrift.protocol.TField UPDATE_FIELD_DESC = new org.apache.thrift.protocol.TField("update", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField UPDATE_EVENTS_FIELD_DESC = new org.apache.thrift.protocol.TField("updateEvents", org.apache.thrift.protocol.TType.LIST, (short)2); - private static final org.apache.thrift.protocol.TField INSTANCE_EVENTS_FIELD_DESC = new org.apache.thrift.protocol.TField("instanceEvents", org.apache.thrift.protocol.TType.LIST, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobUpdateDetailsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobUpdateDetailsTupleSchemeFactory()); - } - - /** - * Update definition. - */ - public JobUpdate update; // required - /** - * History for this update. - */ - public List<JobUpdateEvent> updateEvents; // required - /** - * History for the individual instances updated. - */ - public List<JobInstanceUpdateEvent> instanceEvents; // 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 definition. - */ - UPDATE((short)1, "update"), - /** - * History for this update. - */ - UPDATE_EVENTS((short)2, "updateEvents"), - /** - * History for the individual instances updated. - */ - INSTANCE_EVENTS((short)3, "instanceEvents"); - - 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 - return UPDATE; - case 2: // UPDATE_EVENTS - return UPDATE_EVENTS; - case 3: // INSTANCE_EVENTS - return INSTANCE_EVENTS; - 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, new org.apache.thrift.meta_data.FieldMetaData("update", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobUpdate.class))); - tmpMap.put(_Fields.UPDATE_EVENTS, new org.apache.thrift.meta_data.FieldMetaData("updateEvents", 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, JobUpdateEvent.class)))); - tmpMap.put(_Fields.INSTANCE_EVENTS, new org.apache.thrift.meta_data.FieldMetaData("instanceEvents", 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, JobInstanceUpdateEvent.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdateDetails.class, metaDataMap); - } - - public JobUpdateDetails() { - } - - public JobUpdateDetails( - JobUpdate update, - List<JobUpdateEvent> updateEvents, - List<JobInstanceUpdateEvent> instanceEvents) - { - this(); - this.update = update; - this.updateEvents = updateEvents; - this.instanceEvents = instanceEvents; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobUpdateDetails(JobUpdateDetails other) { - if (other.isSetUpdate()) { - this.update = new JobUpdate(other.update); - } - if (other.isSetUpdateEvents()) { - List<JobUpdateEvent> __this__updateEvents = new ArrayList<JobUpdateEvent>(other.updateEvents.size()); - for (JobUpdateEvent other_element : other.updateEvents) { - __this__updateEvents.add(new JobUpdateEvent(other_element)); - } - this.updateEvents = __this__updateEvents; - } - if (other.isSetInstanceEvents()) { - List<JobInstanceUpdateEvent> __this__instanceEvents = new ArrayList<JobInstanceUpdateEvent>(other.instanceEvents.size()); - for (JobInstanceUpdateEvent other_element : other.instanceEvents) { - __this__instanceEvents.add(new JobInstanceUpdateEvent(other_element)); - } - this.instanceEvents = __this__instanceEvents; - } - } - - public JobUpdateDetails deepCopy() { - return new JobUpdateDetails(this); - } - - @Override - public void clear() { - this.update = null; - this.updateEvents = null; - this.instanceEvents = null; - } - - /** - * Update definition. - */ - public JobUpdate getUpdate() { - return this.update; - } - - /** - * Update definition. - */ - public JobUpdateDetails setUpdate(JobUpdate 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 getUpdateEventsSize() { - return (this.updateEvents == null) ? 0 : this.updateEvents.size(); - } - - public java.util.Iterator<JobUpdateEvent> getUpdateEventsIterator() { - return (this.updateEvents == null) ? null : this.updateEvents.iterator(); - } - - public void addToUpdateEvents(JobUpdateEvent elem) { - if (this.updateEvents == null) { - this.updateEvents = new ArrayList<JobUpdateEvent>(); - } - this.updateEvents.add(elem); - } - - /** - * History for this update. - */ - public List<JobUpdateEvent> getUpdateEvents() { - return this.updateEvents; - } - - /** - * History for this update. - */ - public JobUpdateDetails setUpdateEvents(List<JobUpdateEvent> updateEvents) { - this.updateEvents = updateEvents; - return this; - } - - public void unsetUpdateEvents() { - this.updateEvents = null; - } - - /** Returns true if field updateEvents is set (has been assigned a value) and false otherwise */ - public boolean isSetUpdateEvents() { - return this.updateEvents != null; - } - - public void setUpdateEventsIsSet(boolean value) { - if (!value) { - this.updateEvents = null; - } - } - - public int getInstanceEventsSize() { - return (this.instanceEvents == null) ? 0 : this.instanceEvents.size(); - } - - public java.util.Iterator<JobInstanceUpdateEvent> getInstanceEventsIterator() { - return (this.instanceEvents == null) ? null : this.instanceEvents.iterator(); - } - - public void addToInstanceEvents(JobInstanceUpdateEvent elem) { - if (this.instanceEvents == null) { - this.instanceEvents = new ArrayList<JobInstanceUpdateEvent>(); - } - this.instanceEvents.add(elem); - } - - /** - * History for the individual instances updated. - */ - public List<JobInstanceUpdateEvent> getInstanceEvents() { - return this.instanceEvents; - } - - /** - * History for the individual instances updated. - */ - public JobUpdateDetails setInstanceEvents(List<JobInstanceUpdateEvent> instanceEvents) { - this.instanceEvents = instanceEvents; - return this; - } - - public void unsetInstanceEvents() { - this.instanceEvents = null; - } - - /** Returns true if field instanceEvents is set (has been assigned a value) and false otherwise */ - public boolean isSetInstanceEvents() { - return this.instanceEvents != null; - } - - public void setInstanceEventsIsSet(boolean value) { - if (!value) { - this.instanceEvents = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case UPDATE: - if (value == null) { - unsetUpdate(); - } else { - setUpdate((JobUpdate)value); - } - break; - - case UPDATE_EVENTS: - if (value == null) { - unsetUpdateEvents(); - } else { - setUpdateEvents((List<JobUpdateEvent>)value); - } - break; - - case INSTANCE_EVENTS: - if (value == null) { - unsetInstanceEvents(); - } else { - setInstanceEvents((List<JobInstanceUpdateEvent>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case UPDATE: - return getUpdate(); - - case UPDATE_EVENTS: - return getUpdateEvents(); - - case INSTANCE_EVENTS: - return getInstanceEvents(); - - } - 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: - return isSetUpdate(); - case UPDATE_EVENTS: - return isSetUpdateEvents(); - case INSTANCE_EVENTS: - return isSetInstanceEvents(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobUpdateDetails) - return this.equals((JobUpdateDetails)that); - return false; - } - - public boolean equals(JobUpdateDetails that) { - if (that == null) - 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_updateEvents = true && this.isSetUpdateEvents(); - boolean that_present_updateEvents = true && that.isSetUpdateEvents(); - if (this_present_updateEvents || that_present_updateEvents) { - if (!(this_present_updateEvents && that_present_updateEvents)) - return false; - if (!this.updateEvents.equals(that.updateEvents)) - return false; - } - - boolean this_present_instanceEvents = true && this.isSetInstanceEvents(); - boolean that_present_instanceEvents = true && that.isSetInstanceEvents(); - if (this_present_instanceEvents || that_present_instanceEvents) { - if (!(this_present_instanceEvents && that_present_instanceEvents)) - return false; - if (!this.instanceEvents.equals(that.instanceEvents)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_update = true && (isSetUpdate()); - list.add(present_update); - if (present_update) - list.add(update); - - boolean present_updateEvents = true && (isSetUpdateEvents()); - list.add(present_updateEvents); - if (present_updateEvents) - list.add(updateEvents); - - boolean present_instanceEvents = true && (isSetInstanceEvents()); - list.add(present_instanceEvents); - if (present_instanceEvents) - list.add(instanceEvents); - - return list.hashCode(); - } - - @Override - public int compareTo(JobUpdateDetails other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - 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(isSetUpdateEvents()).compareTo(other.isSetUpdateEvents()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUpdateEvents()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.updateEvents, other.updateEvents); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetInstanceEvents()).compareTo(other.isSetInstanceEvents()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetInstanceEvents()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.instanceEvents, other.instanceEvents); - 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("JobUpdateDetails("); - boolean first = true; - - sb.append("update:"); - if (this.update == null) { - sb.append("null"); - } else { - sb.append(this.update); - } - first = false; - if (!first) sb.append(", "); - sb.append("updateEvents:"); - if (this.updateEvents == null) { - sb.append("null"); - } else { - sb.append(this.updateEvents); - } - first = false; - if (!first) sb.append(", "); - sb.append("instanceEvents:"); - if (this.instanceEvents == null) { - sb.append("null"); - } else { - sb.append(this.instanceEvents); - } - 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 (update != null) { - update.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 JobUpdateDetailsStandardSchemeFactory implements SchemeFactory { - public JobUpdateDetailsStandardScheme getScheme() { - return new JobUpdateDetailsStandardScheme(); - } - } - - private static class JobUpdateDetailsStandardScheme extends StandardScheme<JobUpdateDetails> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdateDetails 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 - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.update = new JobUpdate(); - struct.update.read(iprot); - struct.setUpdateIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // UPDATE_EVENTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list222 = iprot.readListBegin(); - struct.updateEvents = new ArrayList<JobUpdateEvent>(_list222.size); - JobUpdateEvent _elem223; - for (int _i224 = 0; _i224 < _list222.size; ++_i224) - { - _elem223 = new JobUpdateEvent(); - _elem223.read(iprot); - struct.updateEvents.add(_elem223); - } - iprot.readListEnd(); - } - struct.setUpdateEventsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // INSTANCE_EVENTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list225 = iprot.readListBegin(); - struct.instanceEvents = new ArrayList<JobInstanceUpdateEvent>(_list225.size); - JobInstanceUpdateEvent _elem226; - for (int _i227 = 0; _i227 < _list225.size; ++_i227) - { - _elem226 = new JobInstanceUpdateEvent(); - _elem226.read(iprot); - struct.instanceEvents.add(_elem226); - } - iprot.readListEnd(); - } - struct.setInstanceEventsIsSet(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, JobUpdateDetails struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.update != null) { - oprot.writeFieldBegin(UPDATE_FIELD_DESC); - struct.update.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.updateEvents != null) { - oprot.writeFieldBegin(UPDATE_EVENTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.updateEvents.size())); - for (JobUpdateEvent _iter228 : struct.updateEvents) - { - _iter228.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.instanceEvents != null) { - oprot.writeFieldBegin(INSTANCE_EVENTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.instanceEvents.size())); - for (JobInstanceUpdateEvent _iter229 : struct.instanceEvents) - { - _iter229.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobUpdateDetailsTupleSchemeFactory implements SchemeFactory { - public JobUpdateDetailsTupleScheme getScheme() { - return new JobUpdateDetailsTupleScheme(); - } - } - - private static class JobUpdateDetailsTupleScheme extends TupleScheme<JobUpdateDetails> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdateDetails struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetUpdate()) { - optionals.set(0); - } - if (struct.isSetUpdateEvents()) { - optionals.set(1); - } - if (struct.isSetInstanceEvents()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetUpdate()) { - struct.update.write(oprot); - } - if (struct.isSetUpdateEvents()) { - { - oprot.writeI32(struct.updateEvents.size()); - for (JobUpdateEvent _iter230 : struct.updateEvents) - { - _iter230.write(oprot); - } - } - } - if (struct.isSetInstanceEvents()) { - { - oprot.writeI32(struct.instanceEvents.size()); - for (JobInstanceUpdateEvent _iter231 : struct.instanceEvents) - { - _iter231.write(oprot); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdateDetails struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.update = new JobUpdate(); - struct.update.read(iprot); - struct.setUpdateIsSet(true); - } - if (incoming.get(1)) { - { - org.apache.thrift.protocol.TList _list232 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.updateEvents = new ArrayList<JobUpdateEvent>(_list232.size); - JobUpdateEvent _elem233; - for (int _i234 = 0; _i234 < _list232.size; ++_i234) - { - _elem233 = new JobUpdateEvent(); - _elem233.read(iprot); - struct.updateEvents.add(_elem233); - } - } - struct.setUpdateEventsIsSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TList _list235 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.instanceEvents = new ArrayList<JobInstanceUpdateEvent>(_list235.size); - JobInstanceUpdateEvent _elem236; - for (int _i237 = 0; _i237 < _list235.size; ++_i237) - { - _elem236 = new JobInstanceUpdateEvent(); - _elem236.read(iprot); - struct.instanceEvents.add(_elem236); - } - } - struct.setInstanceEventsIsSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateEvent.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateEvent.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateEvent.java deleted file mode 100644 index d41ecb4..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateEvent.java +++ /dev/null @@ -1,798 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * 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"}) -/** - * Event marking a state transition in job update lifecycle. - */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") -public class JobUpdateEvent implements org.apache.thrift.TBase<JobUpdateEvent, JobUpdateEvent._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdateEvent> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdateEvent"); - - private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField TIMESTAMP_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("timestampMs", org.apache.thrift.protocol.TType.I64, (short)2); - private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)3); - 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)4); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobUpdateEventStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobUpdateEventTupleSchemeFactory()); - } - - /** - * Update status. - * - * @see JobUpdateStatus - */ - public JobUpdateStatus status; // required - /** - * Epoch timestamp in milliseconds. - */ - public long timestampMs; // required - /** - * User who performed this event (if user-initiated). - */ - public String user; // optional - /** - * Message from the user (for user-initiated transitions) or the scheduler about why the state was - * changed. - */ - public String message; // optional - - /** 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 status. - * - * @see JobUpdateStatus - */ - STATUS((short)1, "status"), - /** - * Epoch timestamp in milliseconds. - */ - TIMESTAMP_MS((short)2, "timestampMs"), - /** - * User who performed this event (if user-initiated). - */ - USER((short)3, "user"), - /** - * Message from the user (for user-initiated transitions) or the scheduler about why the state was - * changed. - */ - MESSAGE((short)4, "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: // STATUS - return STATUS; - case 2: // TIMESTAMP_MS - return TIMESTAMP_MS; - case 3: // USER - return USER; - case 4: // 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 - private static final int __TIMESTAMPMS_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.USER,_Fields.MESSAGE}; - 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.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, JobUpdateStatus.class))); - tmpMap.put(_Fields.TIMESTAMP_MS, new org.apache.thrift.meta_data.FieldMetaData("timestampMs", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdateEvent.class, metaDataMap); - } - - public JobUpdateEvent() { - } - - public JobUpdateEvent( - JobUpdateStatus status, - long timestampMs) - { - this(); - this.status = status; - this.timestampMs = timestampMs; - setTimestampMsIsSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobUpdateEvent(JobUpdateEvent other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetStatus()) { - this.status = other.status; - } - this.timestampMs = other.timestampMs; - if (other.isSetUser()) { - this.user = other.user; - } - if (other.isSetMessage()) { - this.message = other.message; - } - } - - public JobUpdateEvent deepCopy() { - return new JobUpdateEvent(this); - } - - @Override - public void clear() { - this.status = null; - setTimestampMsIsSet(false); - this.timestampMs = 0; - this.user = null; - this.message = null; - } - - /** - * Update status. - * - * @see JobUpdateStatus - */ - public JobUpdateStatus getStatus() { - return this.status; - } - - /** - * Update status. - * - * @see JobUpdateStatus - */ - public JobUpdateEvent setStatus(JobUpdateStatus status) { - this.status = status; - return this; - } - - public void unsetStatus() { - this.status = null; - } - - /** Returns true if field status is set (has been assigned a value) and false otherwise */ - public boolean isSetStatus() { - return this.status != null; - } - - public void setStatusIsSet(boolean value) { - if (!value) { - this.status = null; - } - } - - /** - * Epoch timestamp in milliseconds. - */ - public long getTimestampMs() { - return this.timestampMs; - } - - /** - * Epoch timestamp in milliseconds. - */ - public JobUpdateEvent setTimestampMs(long timestampMs) { - this.timestampMs = timestampMs; - setTimestampMsIsSet(true); - return this; - } - - public void unsetTimestampMs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMPMS_ISSET_ID); - } - - /** Returns true if field timestampMs is set (has been assigned a value) and false otherwise */ - public boolean isSetTimestampMs() { - return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMPMS_ISSET_ID); - } - - public void setTimestampMsIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMPMS_ISSET_ID, value); - } - - /** - * User who performed this event (if user-initiated). - */ - public String getUser() { - return this.user; - } - - /** - * User who performed this event (if user-initiated). - */ - public JobUpdateEvent setUser(String user) { - this.user = user; - return this; - } - - public void unsetUser() { - this.user = null; - } - - /** Returns true if field user is set (has been assigned a value) and false otherwise */ - public boolean isSetUser() { - return this.user != null; - } - - public void setUserIsSet(boolean value) { - if (!value) { - this.user = null; - } - } - - /** - * Message from the user (for user-initiated transitions) or the scheduler about why the state was - * changed. - */ - public String getMessage() { - return this.message; - } - - /** - * Message from the user (for user-initiated transitions) or the scheduler about why the state was - * changed. - */ - public JobUpdateEvent 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 STATUS: - if (value == null) { - unsetStatus(); - } else { - setStatus((JobUpdateStatus)value); - } - break; - - case TIMESTAMP_MS: - if (value == null) { - unsetTimestampMs(); - } else { - setTimestampMs((Long)value); - } - break; - - case USER: - if (value == null) { - unsetUser(); - } else { - setUser((String)value); - } - break; - - case MESSAGE: - if (value == null) { - unsetMessage(); - } else { - setMessage((String)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case STATUS: - return getStatus(); - - case TIMESTAMP_MS: - return getTimestampMs(); - - case USER: - return getUser(); - - 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 STATUS: - return isSetStatus(); - case TIMESTAMP_MS: - return isSetTimestampMs(); - case USER: - return isSetUser(); - case MESSAGE: - return isSetMessage(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobUpdateEvent) - return this.equals((JobUpdateEvent)that); - return false; - } - - public boolean equals(JobUpdateEvent that) { - if (that == null) - return false; - - boolean this_present_status = true && this.isSetStatus(); - boolean that_present_status = true && that.isSetStatus(); - if (this_present_status || that_present_status) { - if (!(this_present_status && that_present_status)) - return false; - if (!this.status.equals(that.status)) - return false; - } - - boolean this_present_timestampMs = true; - boolean that_present_timestampMs = true; - if (this_present_timestampMs || that_present_timestampMs) { - if (!(this_present_timestampMs && that_present_timestampMs)) - return false; - if (this.timestampMs != that.timestampMs) - return false; - } - - boolean this_present_user = true && this.isSetUser(); - boolean that_present_user = true && that.isSetUser(); - if (this_present_user || that_present_user) { - if (!(this_present_user && that_present_user)) - return false; - if (!this.user.equals(that.user)) - 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_status = true && (isSetStatus()); - list.add(present_status); - if (present_status) - list.add(status.getValue()); - - boolean present_timestampMs = true; - list.add(present_timestampMs); - if (present_timestampMs) - list.add(timestampMs); - - boolean present_user = true && (isSetUser()); - list.add(present_user); - if (present_user) - list.add(user); - - boolean present_message = true && (isSetMessage()); - list.add(present_message); - if (present_message) - list.add(message); - - return list.hashCode(); - } - - @Override - public int compareTo(JobUpdateEvent other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetStatus()).compareTo(other.isSetStatus()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetStatus()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.status, other.status); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetTimestampMs()).compareTo(other.isSetTimestampMs()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTimestampMs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestampMs, other.timestampMs); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetUser()).compareTo(other.isSetUser()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUser()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, other.user); - if (lastComparison != 0) { - return lastComparison; - } - } - 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("JobUpdateEvent("); - boolean first = true; - - sb.append("status:"); - if (this.status == null) { - sb.append("null"); - } else { - sb.append(this.status); - } - first = false; - if (!first) sb.append(", "); - sb.append("timestampMs:"); - sb.append(this.timestampMs); - first = false; - if (isSetUser()) { - if (!first) sb.append(", "); - sb.append("user:"); - if (this.user == null) { - sb.append("null"); - } else { - sb.append(this.user); - } - first = false; - } - if (isSetMessage()) { - if (!first) sb.append(", "); - 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 { - // 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 JobUpdateEventStandardSchemeFactory implements SchemeFactory { - public JobUpdateEventStandardScheme getScheme() { - return new JobUpdateEventStandardScheme(); - } - } - - private static class JobUpdateEventStandardScheme extends StandardScheme<JobUpdateEvent> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdateEvent 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: // STATUS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.status = org.apache.airavata.cloud.aurora.client.sdk.JobUpdateStatus.findByValue(iprot.readI32()); - struct.setStatusIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // TIMESTAMP_MS - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.timestampMs = iprot.readI64(); - struct.setTimestampMsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // USER - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.user = iprot.readString(); - struct.setUserIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // 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, JobUpdateEvent struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.status != null) { - oprot.writeFieldBegin(STATUS_FIELD_DESC); - oprot.writeI32(struct.status.getValue()); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(TIMESTAMP_MS_FIELD_DESC); - oprot.writeI64(struct.timestampMs); - oprot.writeFieldEnd(); - if (struct.user != null) { - if (struct.isSetUser()) { - oprot.writeFieldBegin(USER_FIELD_DESC); - oprot.writeString(struct.user); - oprot.writeFieldEnd(); - } - } - if (struct.message != null) { - if (struct.isSetMessage()) { - oprot.writeFieldBegin(MESSAGE_FIELD_DESC); - oprot.writeString(struct.message); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobUpdateEventTupleSchemeFactory implements SchemeFactory { - public JobUpdateEventTupleScheme getScheme() { - return new JobUpdateEventTupleScheme(); - } - } - - private static class JobUpdateEventTupleScheme extends TupleScheme<JobUpdateEvent> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdateEvent struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetStatus()) { - optionals.set(0); - } - if (struct.isSetTimestampMs()) { - optionals.set(1); - } - if (struct.isSetUser()) { - optionals.set(2); - } - if (struct.isSetMessage()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.isSetStatus()) { - oprot.writeI32(struct.status.getValue()); - } - if (struct.isSetTimestampMs()) { - oprot.writeI64(struct.timestampMs); - } - if (struct.isSetUser()) { - oprot.writeString(struct.user); - } - if (struct.isSetMessage()) { - oprot.writeString(struct.message); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdateEvent struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - struct.status = org.apache.airavata.cloud.aurora.client.sdk.JobUpdateStatus.findByValue(iprot.readI32()); - struct.setStatusIsSet(true); - } - if (incoming.get(1)) { - struct.timestampMs = iprot.readI64(); - struct.setTimestampMsIsSet(true); - } - if (incoming.get(2)) { - struct.user = iprot.readString(); - struct.setUserIsSet(true); - } - if (incoming.get(3)) { - struct.message = iprot.readString(); - struct.setMessageIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java deleted file mode 100644 index b7bc393..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java +++ /dev/null @@ -1,730 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * 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"}) -/** - * Update configuration and setting details. - */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") -public class JobUpdateInstructions implements org.apache.thrift.TBase<JobUpdateInstructions, JobUpdateInstructions._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdateInstructions> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdateInstructions"); - - private static final org.apache.thrift.protocol.TField INITIAL_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("initialState", org.apache.thrift.protocol.TType.SET, (short)1); - private static final org.apache.thrift.protocol.TField DESIRED_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("desiredState", org.apache.thrift.protocol.TType.STRUCT, (short)2); - private static final org.apache.thrift.protocol.TField SETTINGS_FIELD_DESC = new org.apache.thrift.protocol.TField("settings", org.apache.thrift.protocol.TType.STRUCT, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobUpdateInstructionsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobUpdateInstructionsTupleSchemeFactory()); - } - - /** - * Actual InstanceId -> TaskConfig mapping when the update was requested. - */ - public Set<InstanceTaskConfig> initialState; // required - /** - * Desired configuration when the update completes. - */ - public InstanceTaskConfig desiredState; // required - /** - * Update specific settings. - */ - public JobUpdateSettings settings; // 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 { - /** - * Actual InstanceId -> TaskConfig mapping when the update was requested. - */ - INITIAL_STATE((short)1, "initialState"), - /** - * Desired configuration when the update completes. - */ - DESIRED_STATE((short)2, "desiredState"), - /** - * Update specific settings. - */ - SETTINGS((short)3, "settings"); - - 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: // INITIAL_STATE - return INITIAL_STATE; - case 2: // DESIRED_STATE - return DESIRED_STATE; - case 3: // SETTINGS - return SETTINGS; - 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.INITIAL_STATE, new org.apache.thrift.meta_data.FieldMetaData("initialState", 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, InstanceTaskConfig.class)))); - tmpMap.put(_Fields.DESIRED_STATE, new org.apache.thrift.meta_data.FieldMetaData("desiredState", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, InstanceTaskConfig.class))); - tmpMap.put(_Fields.SETTINGS, new org.apache.thrift.meta_data.FieldMetaData("settings", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobUpdateSettings.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdateInstructions.class, metaDataMap); - } - - public JobUpdateInstructions() { - } - - public JobUpdateInstructions( - Set<InstanceTaskConfig> initialState, - InstanceTaskConfig desiredState, - JobUpdateSettings settings) - { - this(); - this.initialState = initialState; - this.desiredState = desiredState; - this.settings = settings; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobUpdateInstructions(JobUpdateInstructions other) { - if (other.isSetInitialState()) { - Set<InstanceTaskConfig> __this__initialState = new HashSet<InstanceTaskConfig>(other.initialState.size()); - for (InstanceTaskConfig other_element : other.initialState) { - __this__initialState.add(new InstanceTaskConfig(other_element)); - } - this.initialState = __this__initialState; - } - if (other.isSetDesiredState()) { - this.desiredState = new InstanceTaskConfig(other.desiredState); - } - if (other.isSetSettings()) { - this.settings = new JobUpdateSettings(other.settings); - } - } - - public JobUpdateInstructions deepCopy() { - return new JobUpdateInstructions(this); - } - - @Override - public void clear() { - this.initialState = null; - this.desiredState = null; - this.settings = null; - } - - public int getInitialStateSize() { - return (this.initialState == null) ? 0 : this.initialState.size(); - } - - public java.util.Iterator<InstanceTaskConfig> getInitialStateIterator() { - return (this.initialState == null) ? null : this.initialState.iterator(); - } - - public void addToInitialState(InstanceTaskConfig elem) { - if (this.initialState == null) { - this.initialState = new HashSet<InstanceTaskConfig>(); - } - this.initialState.add(elem); - } - - /** - * Actual InstanceId -> TaskConfig mapping when the update was requested. - */ - public Set<InstanceTaskConfig> getInitialState() { - return this.initialState; - } - - /** - * Actual InstanceId -> TaskConfig mapping when the update was requested. - */ - public JobUpdateInstructions setInitialState(Set<InstanceTaskConfig> initialState) { - this.initialState = initialState; - return this; - } - - public void unsetInitialState() { - this.initialState = null; - } - - /** Returns true if field initialState is set (has been assigned a value) and false otherwise */ - public boolean isSetInitialState() { - return this.initialState != null; - } - - public void setInitialStateIsSet(boolean value) { - if (!value) { - this.initialState = null; - } - } - - /** - * Desired configuration when the update completes. - */ - public InstanceTaskConfig getDesiredState() { - return this.desiredState; - } - - /** - * Desired configuration when the update completes. - */ - public JobUpdateInstructions setDesiredState(InstanceTaskConfig desiredState) { - this.desiredState = desiredState; - return this; - } - - public void unsetDesiredState() { - this.desiredState = null; - } - - /** Returns true if field desiredState is set (has been assigned a value) and false otherwise */ - public boolean isSetDesiredState() { - return this.desiredState != null; - } - - public void setDesiredStateIsSet(boolean value) { - if (!value) { - this.desiredState = null; - } - } - - /** - * Update specific settings. - */ - public JobUpdateSettings getSettings() { - return this.settings; - } - - /** - * Update specific settings. - */ - public JobUpdateInstructions setSettings(JobUpdateSettings settings) { - this.settings = settings; - return this; - } - - public void unsetSettings() { - this.settings = null; - } - - /** Returns true if field settings is set (has been assigned a value) and false otherwise */ - public boolean isSetSettings() { - return this.settings != null; - } - - public void setSettingsIsSet(boolean value) { - if (!value) { - this.settings = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case INITIAL_STATE: - if (value == null) { - unsetInitialState(); - } else { - setInitialState((Set<InstanceTaskConfig>)value); - } - break; - - case DESIRED_STATE: - if (value == null) { - unsetDesiredState(); - } else { - setDesiredState((InstanceTaskConfig)value); - } - break; - - case SETTINGS: - if (value == null) { - unsetSettings(); - } else { - setSettings((JobUpdateSettings)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case INITIAL_STATE: - return getInitialState(); - - case DESIRED_STATE: - return getDesiredState(); - - case SETTINGS: - return getSettings(); - - } - 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 INITIAL_STATE: - return isSetInitialState(); - case DESIRED_STATE: - return isSetDesiredState(); - case SETTINGS: - return isSetSettings(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobUpdateInstructions) - return this.equals((JobUpdateInstructions)that); - return false; - } - - public boolean equals(JobUpdateInstructions that) { - if (that == null) - return false; - - boolean this_present_initialState = true && this.isSetInitialState(); - boolean that_present_initialState = true && that.isSetInitialState(); - if (this_present_initialState || that_present_initialState) { - if (!(this_present_initialState && that_present_initialState)) - return false; - if (!this.initialState.equals(that.initialState)) - return false; - } - - boolean this_present_desiredState = true && this.isSetDesiredState(); - boolean that_present_desiredState = true && that.isSetDesiredState(); - if (this_present_desiredState || that_present_desiredState) { - if (!(this_present_desiredState && that_present_desiredState)) - return false; - if (!this.desiredState.equals(that.desiredState)) - return false; - } - - boolean this_present_settings = true && this.isSetSettings(); - boolean that_present_settings = true && that.isSetSettings(); - if (this_present_settings || that_present_settings) { - if (!(this_present_settings && that_present_settings)) - return false; - if (!this.settings.equals(that.settings)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_initialState = true && (isSetInitialState()); - list.add(present_initialState); - if (present_initialState) - list.add(initialState); - - boolean present_desiredState = true && (isSetDesiredState()); - list.add(present_desiredState); - if (present_desiredState) - list.add(desiredState); - - boolean present_settings = true && (isSetSettings()); - list.add(present_settings); - if (present_settings) - list.add(settings); - - return list.hashCode(); - } - - @Override - public int compareTo(JobUpdateInstructions other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetInitialState()).compareTo(other.isSetInitialState()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetInitialState()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.initialState, other.initialState); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetDesiredState()).compareTo(other.isSetDesiredState()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetDesiredState()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.desiredState, other.desiredState); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetSettings()).compareTo(other.isSetSettings()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetSettings()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.settings, other.settings); - 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("JobUpdateInstructions("); - boolean first = true; - - sb.append("initialState:"); - if (this.initialState == null) { - sb.append("null"); - } else { - sb.append(this.initialState); - } - first = false; - if (!first) sb.append(", "); - sb.append("desiredState:"); - if (this.desiredState == null) { - sb.append("null"); - } else { - sb.append(this.desiredState); - } - first = false; - if (!first) sb.append(", "); - sb.append("settings:"); - if (this.settings == null) { - sb.append("null"); - } else { - sb.append(this.settings); - } - 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 (desiredState != null) { - desiredState.validate(); - } - if (settings != null) { - settings.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 JobUpdateInstructionsStandardSchemeFactory implements SchemeFactory { - public JobUpdateInstructionsStandardScheme getScheme() { - return new JobUpdateInstructionsStandardScheme(); - } - } - - private static class JobUpdateInstructionsStandardScheme extends StandardScheme<JobUpdateInstructions> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdateInstructions 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: // INITIAL_STATE - if (schemeField.type == org.apache.thrift.protocol.TType.SET) { - { - org.apache.thrift.protocol.TSet _set214 = iprot.readSetBegin(); - struct.initialState = new HashSet<InstanceTaskConfig>(2*_set214.size); - InstanceTaskConfig _elem215; - for (int _i216 = 0; _i216 < _set214.size; ++_i216) - { - _elem215 = new InstanceTaskConfig(); - _elem215.read(iprot); - struct.initialState.add(_elem215); - } - iprot.readSetEnd(); - } - struct.setInitialStateIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // DESIRED_STATE - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.desiredState = new InstanceTaskConfig(); - struct.desiredState.read(iprot); - struct.setDesiredStateIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // SETTINGS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.settings = new JobUpdateSettings(); - struct.settings.read(iprot); - struct.setSettingsIsSet(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, JobUpdateInstructions struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.initialState != null) { - oprot.writeFieldBegin(INITIAL_STATE_FIELD_DESC); - { - oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.initialState.size())); - for (InstanceTaskConfig _iter217 : struct.initialState) - { - _iter217.write(oprot); - } - oprot.writeSetEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.desiredState != null) { - oprot.writeFieldBegin(DESIRED_STATE_FIELD_DESC); - struct.desiredState.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.settings != null) { - oprot.writeFieldBegin(SETTINGS_FIELD_DESC); - struct.settings.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobUpdateInstructionsTupleSchemeFactory implements SchemeFactory { - public JobUpdateInstructionsTupleScheme getScheme() { - return new JobUpdateInstructionsTupleScheme(); - } - } - - private static class JobUpdateInstructionsTupleScheme extends TupleScheme<JobUpdateInstructions> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdateInstructions struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetInitialState()) { - optionals.set(0); - } - if (struct.isSetDesiredState()) { - optionals.set(1); - } - if (struct.isSetSettings()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetInitialState()) { - { - oprot.writeI32(struct.initialState.size()); - for (InstanceTaskConfig _iter218 : struct.initialState) - { - _iter218.write(oprot); - } - } - } - if (struct.isSetDesiredState()) { - struct.desiredState.write(oprot); - } - if (struct.isSetSettings()) { - struct.settings.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdateInstructions struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - { - org.apache.thrift.protocol.TSet _set219 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.initialState = new HashSet<InstanceTaskConfig>(2*_set219.size); - InstanceTaskConfig _elem220; - for (int _i221 = 0; _i221 < _set219.size; ++_i221) - { - _elem220 = new InstanceTaskConfig(); - _elem220.read(iprot); - struct.initialState.add(_elem220); - } - } - struct.setInitialStateIsSet(true); - } - if (incoming.get(1)) { - struct.desiredState = new InstanceTaskConfig(); - struct.desiredState.read(iprot); - struct.setDesiredStateIsSet(true); - } - if (incoming.get(2)) { - struct.settings = new JobUpdateSettings(); - struct.settings.read(iprot); - struct.setSettingsIsSet(true); - } - } - } - -} -
