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/JobStats.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobStats.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobStats.java deleted file mode 100644 index 1680cb2..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobStats.java +++ /dev/null @@ -1,760 +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 JobStats implements org.apache.thrift.TBase<JobStats, JobStats._Fields>, java.io.Serializable, Cloneable, Comparable<JobStats> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobStats"); - - private static final org.apache.thrift.protocol.TField ACTIVE_TASK_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("activeTaskCount", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField FINISHED_TASK_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("finishedTaskCount", org.apache.thrift.protocol.TType.I32, (short)2); - private static final org.apache.thrift.protocol.TField FAILED_TASK_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("failedTaskCount", org.apache.thrift.protocol.TType.I32, (short)3); - private static final org.apache.thrift.protocol.TField PENDING_TASK_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("pendingTaskCount", org.apache.thrift.protocol.TType.I32, (short)4); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobStatsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobStatsTupleSchemeFactory()); - } - - /** - * Number of tasks in active state for this job. - */ - public int activeTaskCount; // required - /** - * Number of tasks in finished state for this job. - */ - public int finishedTaskCount; // required - /** - * Number of failed tasks for this job. - */ - public int failedTaskCount; // required - /** - * Number of tasks in pending state for this job. - */ - public int pendingTaskCount; // 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 tasks in active state for this job. - */ - ACTIVE_TASK_COUNT((short)1, "activeTaskCount"), - /** - * Number of tasks in finished state for this job. - */ - FINISHED_TASK_COUNT((short)2, "finishedTaskCount"), - /** - * Number of failed tasks for this job. - */ - FAILED_TASK_COUNT((short)3, "failedTaskCount"), - /** - * Number of tasks in pending state for this job. - */ - PENDING_TASK_COUNT((short)4, "pendingTaskCount"); - - 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: // ACTIVE_TASK_COUNT - return ACTIVE_TASK_COUNT; - case 2: // FINISHED_TASK_COUNT - return FINISHED_TASK_COUNT; - case 3: // FAILED_TASK_COUNT - return FAILED_TASK_COUNT; - case 4: // PENDING_TASK_COUNT - return PENDING_TASK_COUNT; - 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 __ACTIVETASKCOUNT_ISSET_ID = 0; - private static final int __FINISHEDTASKCOUNT_ISSET_ID = 1; - private static final int __FAILEDTASKCOUNT_ISSET_ID = 2; - private static final int __PENDINGTASKCOUNT_ISSET_ID = 3; - 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.ACTIVE_TASK_COUNT, new org.apache.thrift.meta_data.FieldMetaData("activeTaskCount", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.FINISHED_TASK_COUNT, new org.apache.thrift.meta_data.FieldMetaData("finishedTaskCount", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.FAILED_TASK_COUNT, new org.apache.thrift.meta_data.FieldMetaData("failedTaskCount", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.PENDING_TASK_COUNT, new org.apache.thrift.meta_data.FieldMetaData("pendingTaskCount", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobStats.class, metaDataMap); - } - - public JobStats() { - } - - public JobStats( - int activeTaskCount, - int finishedTaskCount, - int failedTaskCount, - int pendingTaskCount) - { - this(); - this.activeTaskCount = activeTaskCount; - setActiveTaskCountIsSet(true); - this.finishedTaskCount = finishedTaskCount; - setFinishedTaskCountIsSet(true); - this.failedTaskCount = failedTaskCount; - setFailedTaskCountIsSet(true); - this.pendingTaskCount = pendingTaskCount; - setPendingTaskCountIsSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobStats(JobStats other) { - __isset_bitfield = other.__isset_bitfield; - this.activeTaskCount = other.activeTaskCount; - this.finishedTaskCount = other.finishedTaskCount; - this.failedTaskCount = other.failedTaskCount; - this.pendingTaskCount = other.pendingTaskCount; - } - - public JobStats deepCopy() { - return new JobStats(this); - } - - @Override - public void clear() { - setActiveTaskCountIsSet(false); - this.activeTaskCount = 0; - setFinishedTaskCountIsSet(false); - this.finishedTaskCount = 0; - setFailedTaskCountIsSet(false); - this.failedTaskCount = 0; - setPendingTaskCountIsSet(false); - this.pendingTaskCount = 0; - } - - /** - * Number of tasks in active state for this job. - */ - public int getActiveTaskCount() { - return this.activeTaskCount; - } - - /** - * Number of tasks in active state for this job. - */ - public JobStats setActiveTaskCount(int activeTaskCount) { - this.activeTaskCount = activeTaskCount; - setActiveTaskCountIsSet(true); - return this; - } - - public void unsetActiveTaskCount() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ACTIVETASKCOUNT_ISSET_ID); - } - - /** Returns true if field activeTaskCount is set (has been assigned a value) and false otherwise */ - public boolean isSetActiveTaskCount() { - return EncodingUtils.testBit(__isset_bitfield, __ACTIVETASKCOUNT_ISSET_ID); - } - - public void setActiveTaskCountIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ACTIVETASKCOUNT_ISSET_ID, value); - } - - /** - * Number of tasks in finished state for this job. - */ - public int getFinishedTaskCount() { - return this.finishedTaskCount; - } - - /** - * Number of tasks in finished state for this job. - */ - public JobStats setFinishedTaskCount(int finishedTaskCount) { - this.finishedTaskCount = finishedTaskCount; - setFinishedTaskCountIsSet(true); - return this; - } - - public void unsetFinishedTaskCount() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __FINISHEDTASKCOUNT_ISSET_ID); - } - - /** Returns true if field finishedTaskCount is set (has been assigned a value) and false otherwise */ - public boolean isSetFinishedTaskCount() { - return EncodingUtils.testBit(__isset_bitfield, __FINISHEDTASKCOUNT_ISSET_ID); - } - - public void setFinishedTaskCountIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __FINISHEDTASKCOUNT_ISSET_ID, value); - } - - /** - * Number of failed tasks for this job. - */ - public int getFailedTaskCount() { - return this.failedTaskCount; - } - - /** - * Number of failed tasks for this job. - */ - public JobStats setFailedTaskCount(int failedTaskCount) { - this.failedTaskCount = failedTaskCount; - setFailedTaskCountIsSet(true); - return this; - } - - public void unsetFailedTaskCount() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __FAILEDTASKCOUNT_ISSET_ID); - } - - /** Returns true if field failedTaskCount is set (has been assigned a value) and false otherwise */ - public boolean isSetFailedTaskCount() { - return EncodingUtils.testBit(__isset_bitfield, __FAILEDTASKCOUNT_ISSET_ID); - } - - public void setFailedTaskCountIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __FAILEDTASKCOUNT_ISSET_ID, value); - } - - /** - * Number of tasks in pending state for this job. - */ - public int getPendingTaskCount() { - return this.pendingTaskCount; - } - - /** - * Number of tasks in pending state for this job. - */ - public JobStats setPendingTaskCount(int pendingTaskCount) { - this.pendingTaskCount = pendingTaskCount; - setPendingTaskCountIsSet(true); - return this; - } - - public void unsetPendingTaskCount() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PENDINGTASKCOUNT_ISSET_ID); - } - - /** Returns true if field pendingTaskCount is set (has been assigned a value) and false otherwise */ - public boolean isSetPendingTaskCount() { - return EncodingUtils.testBit(__isset_bitfield, __PENDINGTASKCOUNT_ISSET_ID); - } - - public void setPendingTaskCountIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PENDINGTASKCOUNT_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case ACTIVE_TASK_COUNT: - if (value == null) { - unsetActiveTaskCount(); - } else { - setActiveTaskCount((Integer)value); - } - break; - - case FINISHED_TASK_COUNT: - if (value == null) { - unsetFinishedTaskCount(); - } else { - setFinishedTaskCount((Integer)value); - } - break; - - case FAILED_TASK_COUNT: - if (value == null) { - unsetFailedTaskCount(); - } else { - setFailedTaskCount((Integer)value); - } - break; - - case PENDING_TASK_COUNT: - if (value == null) { - unsetPendingTaskCount(); - } else { - setPendingTaskCount((Integer)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case ACTIVE_TASK_COUNT: - return getActiveTaskCount(); - - case FINISHED_TASK_COUNT: - return getFinishedTaskCount(); - - case FAILED_TASK_COUNT: - return getFailedTaskCount(); - - case PENDING_TASK_COUNT: - return getPendingTaskCount(); - - } - 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 ACTIVE_TASK_COUNT: - return isSetActiveTaskCount(); - case FINISHED_TASK_COUNT: - return isSetFinishedTaskCount(); - case FAILED_TASK_COUNT: - return isSetFailedTaskCount(); - case PENDING_TASK_COUNT: - return isSetPendingTaskCount(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobStats) - return this.equals((JobStats)that); - return false; - } - - public boolean equals(JobStats that) { - if (that == null) - return false; - - boolean this_present_activeTaskCount = true; - boolean that_present_activeTaskCount = true; - if (this_present_activeTaskCount || that_present_activeTaskCount) { - if (!(this_present_activeTaskCount && that_present_activeTaskCount)) - return false; - if (this.activeTaskCount != that.activeTaskCount) - return false; - } - - boolean this_present_finishedTaskCount = true; - boolean that_present_finishedTaskCount = true; - if (this_present_finishedTaskCount || that_present_finishedTaskCount) { - if (!(this_present_finishedTaskCount && that_present_finishedTaskCount)) - return false; - if (this.finishedTaskCount != that.finishedTaskCount) - return false; - } - - boolean this_present_failedTaskCount = true; - boolean that_present_failedTaskCount = true; - if (this_present_failedTaskCount || that_present_failedTaskCount) { - if (!(this_present_failedTaskCount && that_present_failedTaskCount)) - return false; - if (this.failedTaskCount != that.failedTaskCount) - return false; - } - - boolean this_present_pendingTaskCount = true; - boolean that_present_pendingTaskCount = true; - if (this_present_pendingTaskCount || that_present_pendingTaskCount) { - if (!(this_present_pendingTaskCount && that_present_pendingTaskCount)) - return false; - if (this.pendingTaskCount != that.pendingTaskCount) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_activeTaskCount = true; - list.add(present_activeTaskCount); - if (present_activeTaskCount) - list.add(activeTaskCount); - - boolean present_finishedTaskCount = true; - list.add(present_finishedTaskCount); - if (present_finishedTaskCount) - list.add(finishedTaskCount); - - boolean present_failedTaskCount = true; - list.add(present_failedTaskCount); - if (present_failedTaskCount) - list.add(failedTaskCount); - - boolean present_pendingTaskCount = true; - list.add(present_pendingTaskCount); - if (present_pendingTaskCount) - list.add(pendingTaskCount); - - return list.hashCode(); - } - - @Override - public int compareTo(JobStats other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetActiveTaskCount()).compareTo(other.isSetActiveTaskCount()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetActiveTaskCount()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.activeTaskCount, other.activeTaskCount); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetFinishedTaskCount()).compareTo(other.isSetFinishedTaskCount()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetFinishedTaskCount()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.finishedTaskCount, other.finishedTaskCount); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetFailedTaskCount()).compareTo(other.isSetFailedTaskCount()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetFailedTaskCount()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.failedTaskCount, other.failedTaskCount); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetPendingTaskCount()).compareTo(other.isSetPendingTaskCount()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetPendingTaskCount()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pendingTaskCount, other.pendingTaskCount); - 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("JobStats("); - boolean first = true; - - sb.append("activeTaskCount:"); - sb.append(this.activeTaskCount); - first = false; - if (!first) sb.append(", "); - sb.append("finishedTaskCount:"); - sb.append(this.finishedTaskCount); - first = false; - if (!first) sb.append(", "); - sb.append("failedTaskCount:"); - sb.append(this.failedTaskCount); - first = false; - if (!first) sb.append(", "); - sb.append("pendingTaskCount:"); - sb.append(this.pendingTaskCount); - 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 JobStatsStandardSchemeFactory implements SchemeFactory { - public JobStatsStandardScheme getScheme() { - return new JobStatsStandardScheme(); - } - } - - private static class JobStatsStandardScheme extends StandardScheme<JobStats> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobStats 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: // ACTIVE_TASK_COUNT - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.activeTaskCount = iprot.readI32(); - struct.setActiveTaskCountIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // FINISHED_TASK_COUNT - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.finishedTaskCount = iprot.readI32(); - struct.setFinishedTaskCountIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // FAILED_TASK_COUNT - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.failedTaskCount = iprot.readI32(); - struct.setFailedTaskCountIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // PENDING_TASK_COUNT - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.pendingTaskCount = iprot.readI32(); - struct.setPendingTaskCountIsSet(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, JobStats struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - oprot.writeFieldBegin(ACTIVE_TASK_COUNT_FIELD_DESC); - oprot.writeI32(struct.activeTaskCount); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(FINISHED_TASK_COUNT_FIELD_DESC); - oprot.writeI32(struct.finishedTaskCount); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(FAILED_TASK_COUNT_FIELD_DESC); - oprot.writeI32(struct.failedTaskCount); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(PENDING_TASK_COUNT_FIELD_DESC); - oprot.writeI32(struct.pendingTaskCount); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobStatsTupleSchemeFactory implements SchemeFactory { - public JobStatsTupleScheme getScheme() { - return new JobStatsTupleScheme(); - } - } - - private static class JobStatsTupleScheme extends TupleScheme<JobStats> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobStats struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetActiveTaskCount()) { - optionals.set(0); - } - if (struct.isSetFinishedTaskCount()) { - optionals.set(1); - } - if (struct.isSetFailedTaskCount()) { - optionals.set(2); - } - if (struct.isSetPendingTaskCount()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.isSetActiveTaskCount()) { - oprot.writeI32(struct.activeTaskCount); - } - if (struct.isSetFinishedTaskCount()) { - oprot.writeI32(struct.finishedTaskCount); - } - if (struct.isSetFailedTaskCount()) { - oprot.writeI32(struct.failedTaskCount); - } - if (struct.isSetPendingTaskCount()) { - oprot.writeI32(struct.pendingTaskCount); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobStats struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - struct.activeTaskCount = iprot.readI32(); - struct.setActiveTaskCountIsSet(true); - } - if (incoming.get(1)) { - struct.finishedTaskCount = iprot.readI32(); - struct.setFinishedTaskCountIsSet(true); - } - if (incoming.get(2)) { - struct.failedTaskCount = iprot.readI32(); - struct.setFailedTaskCountIsSet(true); - } - if (incoming.get(3)) { - struct.pendingTaskCount = iprot.readI32(); - struct.setPendingTaskCountIsSet(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/JobSummary.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobSummary.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobSummary.java deleted file mode 100644 index d249740..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobSummary.java +++ /dev/null @@ -1,649 +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 JobSummary implements org.apache.thrift.TBase<JobSummary, JobSummary._Fields>, java.io.Serializable, Cloneable, Comparable<JobSummary> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobSummary"); - - private static final org.apache.thrift.protocol.TField JOB_FIELD_DESC = new org.apache.thrift.protocol.TField("job", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("stats", org.apache.thrift.protocol.TType.STRUCT, (short)2); - private static final org.apache.thrift.protocol.TField NEXT_CRON_RUN_MS_FIELD_DESC = new org.apache.thrift.protocol.TField("nextCronRunMs", org.apache.thrift.protocol.TType.I64, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobSummaryStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobSummaryTupleSchemeFactory()); - } - - public JobConfiguration job; // required - public JobStats stats; // required - /** - * Timestamp of next cron run in ms since epoch, for a cron job - */ - public long nextCronRunMs; // 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 { - JOB((short)1, "job"), - STATS((short)2, "stats"), - /** - * Timestamp of next cron run in ms since epoch, for a cron job - */ - NEXT_CRON_RUN_MS((short)3, "nextCronRunMs"); - - 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: // JOB - return JOB; - case 2: // STATS - return STATS; - case 3: // NEXT_CRON_RUN_MS - return NEXT_CRON_RUN_MS; - 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 __NEXTCRONRUNMS_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.NEXT_CRON_RUN_MS}; - 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.JOB, new org.apache.thrift.meta_data.FieldMetaData("job", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobConfiguration.class))); - tmpMap.put(_Fields.STATS, new org.apache.thrift.meta_data.FieldMetaData("stats", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobStats.class))); - tmpMap.put(_Fields.NEXT_CRON_RUN_MS, new org.apache.thrift.meta_data.FieldMetaData("nextCronRunMs", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobSummary.class, metaDataMap); - } - - public JobSummary() { - } - - public JobSummary( - JobConfiguration job, - JobStats stats) - { - this(); - this.job = job; - this.stats = stats; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobSummary(JobSummary other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetJob()) { - this.job = new JobConfiguration(other.job); - } - if (other.isSetStats()) { - this.stats = new JobStats(other.stats); - } - this.nextCronRunMs = other.nextCronRunMs; - } - - public JobSummary deepCopy() { - return new JobSummary(this); - } - - @Override - public void clear() { - this.job = null; - this.stats = null; - setNextCronRunMsIsSet(false); - this.nextCronRunMs = 0; - } - - public JobConfiguration getJob() { - return this.job; - } - - public JobSummary setJob(JobConfiguration job) { - this.job = job; - return this; - } - - public void unsetJob() { - this.job = null; - } - - /** Returns true if field job is set (has been assigned a value) and false otherwise */ - public boolean isSetJob() { - return this.job != null; - } - - public void setJobIsSet(boolean value) { - if (!value) { - this.job = null; - } - } - - public JobStats getStats() { - return this.stats; - } - - public JobSummary setStats(JobStats stats) { - this.stats = stats; - return this; - } - - public void unsetStats() { - this.stats = null; - } - - /** Returns true if field stats is set (has been assigned a value) and false otherwise */ - public boolean isSetStats() { - return this.stats != null; - } - - public void setStatsIsSet(boolean value) { - if (!value) { - this.stats = null; - } - } - - /** - * Timestamp of next cron run in ms since epoch, for a cron job - */ - public long getNextCronRunMs() { - return this.nextCronRunMs; - } - - /** - * Timestamp of next cron run in ms since epoch, for a cron job - */ - public JobSummary setNextCronRunMs(long nextCronRunMs) { - this.nextCronRunMs = nextCronRunMs; - setNextCronRunMsIsSet(true); - return this; - } - - public void unsetNextCronRunMs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NEXTCRONRUNMS_ISSET_ID); - } - - /** Returns true if field nextCronRunMs is set (has been assigned a value) and false otherwise */ - public boolean isSetNextCronRunMs() { - return EncodingUtils.testBit(__isset_bitfield, __NEXTCRONRUNMS_ISSET_ID); - } - - public void setNextCronRunMsIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NEXTCRONRUNMS_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case JOB: - if (value == null) { - unsetJob(); - } else { - setJob((JobConfiguration)value); - } - break; - - case STATS: - if (value == null) { - unsetStats(); - } else { - setStats((JobStats)value); - } - break; - - case NEXT_CRON_RUN_MS: - if (value == null) { - unsetNextCronRunMs(); - } else { - setNextCronRunMs((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case JOB: - return getJob(); - - case STATS: - return getStats(); - - case NEXT_CRON_RUN_MS: - return getNextCronRunMs(); - - } - 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 JOB: - return isSetJob(); - case STATS: - return isSetStats(); - case NEXT_CRON_RUN_MS: - return isSetNextCronRunMs(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobSummary) - return this.equals((JobSummary)that); - return false; - } - - public boolean equals(JobSummary that) { - if (that == null) - return false; - - boolean this_present_job = true && this.isSetJob(); - boolean that_present_job = true && that.isSetJob(); - if (this_present_job || that_present_job) { - if (!(this_present_job && that_present_job)) - return false; - if (!this.job.equals(that.job)) - return false; - } - - boolean this_present_stats = true && this.isSetStats(); - boolean that_present_stats = true && that.isSetStats(); - if (this_present_stats || that_present_stats) { - if (!(this_present_stats && that_present_stats)) - return false; - if (!this.stats.equals(that.stats)) - return false; - } - - boolean this_present_nextCronRunMs = true && this.isSetNextCronRunMs(); - boolean that_present_nextCronRunMs = true && that.isSetNextCronRunMs(); - if (this_present_nextCronRunMs || that_present_nextCronRunMs) { - if (!(this_present_nextCronRunMs && that_present_nextCronRunMs)) - return false; - if (this.nextCronRunMs != that.nextCronRunMs) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_job = true && (isSetJob()); - list.add(present_job); - if (present_job) - list.add(job); - - boolean present_stats = true && (isSetStats()); - list.add(present_stats); - if (present_stats) - list.add(stats); - - boolean present_nextCronRunMs = true && (isSetNextCronRunMs()); - list.add(present_nextCronRunMs); - if (present_nextCronRunMs) - list.add(nextCronRunMs); - - return list.hashCode(); - } - - @Override - public int compareTo(JobSummary other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetJob()).compareTo(other.isSetJob()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetJob()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.job, other.job); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetStats()).compareTo(other.isSetStats()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetStats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stats, other.stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetNextCronRunMs()).compareTo(other.isSetNextCronRunMs()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetNextCronRunMs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nextCronRunMs, other.nextCronRunMs); - 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("JobSummary("); - boolean first = true; - - sb.append("job:"); - if (this.job == null) { - sb.append("null"); - } else { - sb.append(this.job); - } - first = false; - if (!first) sb.append(", "); - sb.append("stats:"); - if (this.stats == null) { - sb.append("null"); - } else { - sb.append(this.stats); - } - first = false; - if (isSetNextCronRunMs()) { - if (!first) sb.append(", "); - sb.append("nextCronRunMs:"); - sb.append(this.nextCronRunMs); - 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 (job != null) { - job.validate(); - } - if (stats != null) { - stats.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 { - // 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 JobSummaryStandardSchemeFactory implements SchemeFactory { - public JobSummaryStandardScheme getScheme() { - return new JobSummaryStandardScheme(); - } - } - - private static class JobSummaryStandardScheme extends StandardScheme<JobSummary> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobSummary 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: // JOB - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.job = new JobConfiguration(); - struct.job.read(iprot); - struct.setJobIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // STATS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.stats = new JobStats(); - struct.stats.read(iprot); - struct.setStatsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // NEXT_CRON_RUN_MS - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.nextCronRunMs = iprot.readI64(); - struct.setNextCronRunMsIsSet(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, JobSummary struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.job != null) { - oprot.writeFieldBegin(JOB_FIELD_DESC); - struct.job.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.stats != null) { - oprot.writeFieldBegin(STATS_FIELD_DESC); - struct.stats.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.isSetNextCronRunMs()) { - oprot.writeFieldBegin(NEXT_CRON_RUN_MS_FIELD_DESC); - oprot.writeI64(struct.nextCronRunMs); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobSummaryTupleSchemeFactory implements SchemeFactory { - public JobSummaryTupleScheme getScheme() { - return new JobSummaryTupleScheme(); - } - } - - private static class JobSummaryTupleScheme extends TupleScheme<JobSummary> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobSummary struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetJob()) { - optionals.set(0); - } - if (struct.isSetStats()) { - optionals.set(1); - } - if (struct.isSetNextCronRunMs()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetJob()) { - struct.job.write(oprot); - } - if (struct.isSetStats()) { - struct.stats.write(oprot); - } - if (struct.isSetNextCronRunMs()) { - oprot.writeI64(struct.nextCronRunMs); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobSummary struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.job = new JobConfiguration(); - struct.job.read(iprot); - struct.setJobIsSet(true); - } - if (incoming.get(1)) { - struct.stats = new JobStats(); - struct.stats.read(iprot); - struct.setStatsIsSet(true); - } - if (incoming.get(2)) { - struct.nextCronRunMs = iprot.readI64(); - struct.setNextCronRunMsIsSet(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/JobSummaryResult.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobSummaryResult.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobSummaryResult.java deleted file mode 100644 index 8de6fc1..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobSummaryResult.java +++ /dev/null @@ -1,471 +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 JobSummaryResult implements org.apache.thrift.TBase<JobSummaryResult, JobSummaryResult._Fields>, java.io.Serializable, Cloneable, Comparable<JobSummaryResult> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobSummaryResult"); - - private static final org.apache.thrift.protocol.TField SUMMARIES_FIELD_DESC = new org.apache.thrift.protocol.TField("summaries", org.apache.thrift.protocol.TType.SET, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobSummaryResultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobSummaryResultTupleSchemeFactory()); - } - - public Set<JobSummary> summaries; // 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 { - SUMMARIES((short)1, "summaries"); - - 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: // SUMMARIES - return SUMMARIES; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.SUMMARIES, new org.apache.thrift.meta_data.FieldMetaData("summaries", 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, JobSummary.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobSummaryResult.class, metaDataMap); - } - - public JobSummaryResult() { - } - - public JobSummaryResult( - Set<JobSummary> summaries) - { - this(); - this.summaries = summaries; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobSummaryResult(JobSummaryResult other) { - if (other.isSetSummaries()) { - Set<JobSummary> __this__summaries = new HashSet<JobSummary>(other.summaries.size()); - for (JobSummary other_element : other.summaries) { - __this__summaries.add(new JobSummary(other_element)); - } - this.summaries = __this__summaries; - } - } - - public JobSummaryResult deepCopy() { - return new JobSummaryResult(this); - } - - @Override - public void clear() { - this.summaries = null; - } - - public int getSummariesSize() { - return (this.summaries == null) ? 0 : this.summaries.size(); - } - - public java.util.Iterator<JobSummary> getSummariesIterator() { - return (this.summaries == null) ? null : this.summaries.iterator(); - } - - public void addToSummaries(JobSummary elem) { - if (this.summaries == null) { - this.summaries = new HashSet<JobSummary>(); - } - this.summaries.add(elem); - } - - public Set<JobSummary> getSummaries() { - return this.summaries; - } - - public JobSummaryResult setSummaries(Set<JobSummary> summaries) { - this.summaries = summaries; - return this; - } - - public void unsetSummaries() { - this.summaries = null; - } - - /** Returns true if field summaries is set (has been assigned a value) and false otherwise */ - public boolean isSetSummaries() { - return this.summaries != null; - } - - public void setSummariesIsSet(boolean value) { - if (!value) { - this.summaries = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case SUMMARIES: - if (value == null) { - unsetSummaries(); - } else { - setSummaries((Set<JobSummary>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case SUMMARIES: - return getSummaries(); - - } - 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 SUMMARIES: - return isSetSummaries(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobSummaryResult) - return this.equals((JobSummaryResult)that); - return false; - } - - public boolean equals(JobSummaryResult that) { - if (that == null) - return false; - - boolean this_present_summaries = true && this.isSetSummaries(); - boolean that_present_summaries = true && that.isSetSummaries(); - if (this_present_summaries || that_present_summaries) { - if (!(this_present_summaries && that_present_summaries)) - return false; - if (!this.summaries.equals(that.summaries)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_summaries = true && (isSetSummaries()); - list.add(present_summaries); - if (present_summaries) - list.add(summaries); - - return list.hashCode(); - } - - @Override - public int compareTo(JobSummaryResult other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetSummaries()).compareTo(other.isSetSummaries()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetSummaries()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.summaries, other.summaries); - 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("JobSummaryResult("); - boolean first = true; - - sb.append("summaries:"); - if (this.summaries == null) { - sb.append("null"); - } else { - sb.append(this.summaries); - } - 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 JobSummaryResultStandardSchemeFactory implements SchemeFactory { - public JobSummaryResultStandardScheme getScheme() { - return new JobSummaryResultStandardScheme(); - } - } - - private static class JobSummaryResultStandardScheme extends StandardScheme<JobSummaryResult> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobSummaryResult 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: // SUMMARIES - if (schemeField.type == org.apache.thrift.protocol.TType.SET) { - { - org.apache.thrift.protocol.TSet _set310 = iprot.readSetBegin(); - struct.summaries = new HashSet<JobSummary>(2*_set310.size); - JobSummary _elem311; - for (int _i312 = 0; _i312 < _set310.size; ++_i312) - { - _elem311 = new JobSummary(); - _elem311.read(iprot); - struct.summaries.add(_elem311); - } - iprot.readSetEnd(); - } - struct.setSummariesIsSet(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, JobSummaryResult struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.summaries != null) { - oprot.writeFieldBegin(SUMMARIES_FIELD_DESC); - { - oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.summaries.size())); - for (JobSummary _iter313 : struct.summaries) - { - _iter313.write(oprot); - } - oprot.writeSetEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobSummaryResultTupleSchemeFactory implements SchemeFactory { - public JobSummaryResultTupleScheme getScheme() { - return new JobSummaryResultTupleScheme(); - } - } - - private static class JobSummaryResultTupleScheme extends TupleScheme<JobSummaryResult> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobSummaryResult struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetSummaries()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetSummaries()) { - { - oprot.writeI32(struct.summaries.size()); - for (JobSummary _iter314 : struct.summaries) - { - _iter314.write(oprot); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobSummaryResult struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - { - org.apache.thrift.protocol.TSet _set315 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.summaries = new HashSet<JobSummary>(2*_set315.size); - JobSummary _elem316; - for (int _i317 = 0; _i317 < _set315.size; ++_i317) - { - _elem316 = new JobSummary(); - _elem316.read(iprot); - struct.summaries.add(_elem316); - } - } - struct.setSummariesIsSet(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/JobUpdate.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdate.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdate.java deleted file mode 100644 index 5209ce5..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdate.java +++ /dev/null @@ -1,559 +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"}) -/** - * Full definition of the job update. - */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") -public class JobUpdate implements org.apache.thrift.TBase<JobUpdate, JobUpdate._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdate> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdate"); - - private static final org.apache.thrift.protocol.TField SUMMARY_FIELD_DESC = new org.apache.thrift.protocol.TField("summary", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField INSTRUCTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("instructions", org.apache.thrift.protocol.TType.STRUCT, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new JobUpdateStandardSchemeFactory()); - schemes.put(TupleScheme.class, new JobUpdateTupleSchemeFactory()); - } - - /** - * Update summary. - */ - public JobUpdateSummary summary; // required - /** - * Update configuration. - */ - public JobUpdateInstructions instructions; // 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 summary. - */ - SUMMARY((short)1, "summary"), - /** - * Update configuration. - */ - INSTRUCTIONS((short)2, "instructions"); - - 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: // SUMMARY - return SUMMARY; - case 2: // INSTRUCTIONS - return INSTRUCTIONS; - 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.SUMMARY, new org.apache.thrift.meta_data.FieldMetaData("summary", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobUpdateSummary.class))); - tmpMap.put(_Fields.INSTRUCTIONS, new org.apache.thrift.meta_data.FieldMetaData("instructions", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobUpdateInstructions.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdate.class, metaDataMap); - } - - public JobUpdate() { - } - - public JobUpdate( - JobUpdateSummary summary, - JobUpdateInstructions instructions) - { - this(); - this.summary = summary; - this.instructions = instructions; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public JobUpdate(JobUpdate other) { - if (other.isSetSummary()) { - this.summary = new JobUpdateSummary(other.summary); - } - if (other.isSetInstructions()) { - this.instructions = new JobUpdateInstructions(other.instructions); - } - } - - public JobUpdate deepCopy() { - return new JobUpdate(this); - } - - @Override - public void clear() { - this.summary = null; - this.instructions = null; - } - - /** - * Update summary. - */ - public JobUpdateSummary getSummary() { - return this.summary; - } - - /** - * Update summary. - */ - public JobUpdate setSummary(JobUpdateSummary summary) { - this.summary = summary; - return this; - } - - public void unsetSummary() { - this.summary = null; - } - - /** Returns true if field summary is set (has been assigned a value) and false otherwise */ - public boolean isSetSummary() { - return this.summary != null; - } - - public void setSummaryIsSet(boolean value) { - if (!value) { - this.summary = null; - } - } - - /** - * Update configuration. - */ - public JobUpdateInstructions getInstructions() { - return this.instructions; - } - - /** - * Update configuration. - */ - public JobUpdate setInstructions(JobUpdateInstructions instructions) { - this.instructions = instructions; - return this; - } - - public void unsetInstructions() { - this.instructions = null; - } - - /** Returns true if field instructions is set (has been assigned a value) and false otherwise */ - public boolean isSetInstructions() { - return this.instructions != null; - } - - public void setInstructionsIsSet(boolean value) { - if (!value) { - this.instructions = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case SUMMARY: - if (value == null) { - unsetSummary(); - } else { - setSummary((JobUpdateSummary)value); - } - break; - - case INSTRUCTIONS: - if (value == null) { - unsetInstructions(); - } else { - setInstructions((JobUpdateInstructions)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case SUMMARY: - return getSummary(); - - case INSTRUCTIONS: - return getInstructions(); - - } - 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 SUMMARY: - return isSetSummary(); - case INSTRUCTIONS: - return isSetInstructions(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof JobUpdate) - return this.equals((JobUpdate)that); - return false; - } - - public boolean equals(JobUpdate that) { - if (that == null) - return false; - - boolean this_present_summary = true && this.isSetSummary(); - boolean that_present_summary = true && that.isSetSummary(); - if (this_present_summary || that_present_summary) { - if (!(this_present_summary && that_present_summary)) - return false; - if (!this.summary.equals(that.summary)) - return false; - } - - boolean this_present_instructions = true && this.isSetInstructions(); - boolean that_present_instructions = true && that.isSetInstructions(); - if (this_present_instructions || that_present_instructions) { - if (!(this_present_instructions && that_present_instructions)) - return false; - if (!this.instructions.equals(that.instructions)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_summary = true && (isSetSummary()); - list.add(present_summary); - if (present_summary) - list.add(summary); - - boolean present_instructions = true && (isSetInstructions()); - list.add(present_instructions); - if (present_instructions) - list.add(instructions); - - return list.hashCode(); - } - - @Override - public int compareTo(JobUpdate other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetSummary()).compareTo(other.isSetSummary()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetSummary()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.summary, other.summary); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetInstructions()).compareTo(other.isSetInstructions()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetInstructions()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.instructions, other.instructions); - 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("JobUpdate("); - boolean first = true; - - sb.append("summary:"); - if (this.summary == null) { - sb.append("null"); - } else { - sb.append(this.summary); - } - first = false; - if (!first) sb.append(", "); - sb.append("instructions:"); - if (this.instructions == null) { - sb.append("null"); - } else { - sb.append(this.instructions); - } - 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 (summary != null) { - summary.validate(); - } - if (instructions != null) { - instructions.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 JobUpdateStandardSchemeFactory implements SchemeFactory { - public JobUpdateStandardScheme getScheme() { - return new JobUpdateStandardScheme(); - } - } - - private static class JobUpdateStandardScheme extends StandardScheme<JobUpdate> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdate 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: // SUMMARY - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.summary = new JobUpdateSummary(); - struct.summary.read(iprot); - struct.setSummaryIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // INSTRUCTIONS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.instructions = new JobUpdateInstructions(); - struct.instructions.read(iprot); - struct.setInstructionsIsSet(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, JobUpdate struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.summary != null) { - oprot.writeFieldBegin(SUMMARY_FIELD_DESC); - struct.summary.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.instructions != null) { - oprot.writeFieldBegin(INSTRUCTIONS_FIELD_DESC); - struct.instructions.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class JobUpdateTupleSchemeFactory implements SchemeFactory { - public JobUpdateTupleScheme getScheme() { - return new JobUpdateTupleScheme(); - } - } - - private static class JobUpdateTupleScheme extends TupleScheme<JobUpdate> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdate struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetSummary()) { - optionals.set(0); - } - if (struct.isSetInstructions()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetSummary()) { - struct.summary.write(oprot); - } - if (struct.isSetInstructions()) { - struct.instructions.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdate struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); - if (incoming.get(0)) { - struct.summary = new JobUpdateSummary(); - struct.summary.read(iprot); - struct.setSummaryIsSet(true); - } - if (incoming.get(1)) { - struct.instructions = new JobUpdateInstructions(); - struct.instructions.read(iprot); - struct.setInstructionsIsSet(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/JobUpdateAction.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateAction.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateAction.java deleted file mode 100644 index c09c029..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateAction.java +++ /dev/null @@ -1,101 +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 java.util.Map; -import java.util.HashMap; -import org.apache.thrift.TEnum; - -/** - * Job update actions that can be applied to job instances. - */ -public enum JobUpdateAction implements org.apache.thrift.TEnum { - /** - * An instance was moved to the target state successfully, and declared healthy if the desired - * state did not involve deleting the instance. - */ - INSTANCE_UPDATED(1), - /** - * An instance was rolled back because the job update did not succeed. The instance was reverted - * to the original state prior to the job update, which means that the instance was removed if - * the update added instances to the job. - */ - INSTANCE_ROLLED_BACK(2), - /** - * An instance is being moved from the original state to the desired state. - */ - INSTANCE_UPDATING(3), - /** - * An instance is being moved from the desired state back to the original state, because the job - * update failed. - */ - INSTANCE_ROLLING_BACK(4), - /** - * An instance update was attempted but failed and was not rolled back. - */ - INSTANCE_UPDATE_FAILED(5), - /** - * An instance rollback was attempted but failed. - */ - INSTANCE_ROLLBACK_FAILED(6); - - private final int value; - - private JobUpdateAction(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 JobUpdateAction findByValue(int value) { - switch (value) { - case 1: - return INSTANCE_UPDATED; - case 2: - return INSTANCE_ROLLED_BACK; - case 3: - return INSTANCE_UPDATING; - case 4: - return INSTANCE_ROLLING_BACK; - case 5: - return INSTANCE_UPDATE_FAILED; - case 6: - return INSTANCE_ROLLBACK_FAILED; - default: - return null; - } - } -}
