http://git-wip-us.apache.org/repos/asf/airavata/blob/25da582a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskModel.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskModel.java new file mode 100644 index 0000000..7ade811 --- /dev/null +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskModel.java @@ -0,0 +1,1441 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.task; + +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"}) +/** + * TaskModel: A structure holding the generic task details. + * + * taskDetail: + * A friendly description of the task, usally used to communicate information to users. + * + * subTaskModel: + * A generic byte object for the Task developer to store internal serialized data into registry catalogs. + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-2") +public class TaskModel implements org.apache.thrift.TBase<TaskModel, TaskModel._Fields>, java.io.Serializable, Cloneable, Comparable<TaskModel> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TaskModel"); + + private static final org.apache.thrift.protocol.TField TASK_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("taskId", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField TASK_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("taskType", org.apache.thrift.protocol.TType.I32, (short)2); + private static final org.apache.thrift.protocol.TField PARENT_PROCESS_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("parentProcessId", org.apache.thrift.protocol.TType.STRING, (short)3); + private static final org.apache.thrift.protocol.TField CREATION_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("creationTime", org.apache.thrift.protocol.TType.I64, (short)4); + private static final org.apache.thrift.protocol.TField LAST_UPDATE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("lastUpdateTime", org.apache.thrift.protocol.TType.I64, (short)5); + private static final org.apache.thrift.protocol.TField TASK_STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("taskStatus", org.apache.thrift.protocol.TType.STRUCT, (short)6); + private static final org.apache.thrift.protocol.TField TASK_DETAIL_FIELD_DESC = new org.apache.thrift.protocol.TField("taskDetail", org.apache.thrift.protocol.TType.STRING, (short)7); + private static final org.apache.thrift.protocol.TField SUB_TASK_MODEL_FIELD_DESC = new org.apache.thrift.protocol.TField("subTaskModel", org.apache.thrift.protocol.TType.STRING, (short)8); + private static final org.apache.thrift.protocol.TField TASK_ERROR_FIELD_DESC = new org.apache.thrift.protocol.TField("taskError", org.apache.thrift.protocol.TType.STRUCT, (short)9); + private static final org.apache.thrift.protocol.TField JOBS_FIELD_DESC = new org.apache.thrift.protocol.TField("jobs", org.apache.thrift.protocol.TType.LIST, (short)10); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TaskModelStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TaskModelTupleSchemeFactory()); + } + + public String taskId; // required + /** + * + * @see TaskTypes + */ + public TaskTypes taskType; // required + public String parentProcessId; // required + public long creationTime; // required + public long lastUpdateTime; // required + public org.apache.airavata.model.status.TaskStatus taskStatus; // required + public String taskDetail; // optional + public ByteBuffer subTaskModel; // optional + public org.apache.airavata.model.commons.ErrorModel taskError; // optional + public List<org.apache.airavata.model.job.JobModel> jobs; // 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 { + TASK_ID((short)1, "taskId"), + /** + * + * @see TaskTypes + */ + TASK_TYPE((short)2, "taskType"), + PARENT_PROCESS_ID((short)3, "parentProcessId"), + CREATION_TIME((short)4, "creationTime"), + LAST_UPDATE_TIME((short)5, "lastUpdateTime"), + TASK_STATUS((short)6, "taskStatus"), + TASK_DETAIL((short)7, "taskDetail"), + SUB_TASK_MODEL((short)8, "subTaskModel"), + TASK_ERROR((short)9, "taskError"), + JOBS((short)10, "jobs"); + + 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: // TASK_ID + return TASK_ID; + case 2: // TASK_TYPE + return TASK_TYPE; + case 3: // PARENT_PROCESS_ID + return PARENT_PROCESS_ID; + case 4: // CREATION_TIME + return CREATION_TIME; + case 5: // LAST_UPDATE_TIME + return LAST_UPDATE_TIME; + case 6: // TASK_STATUS + return TASK_STATUS; + case 7: // TASK_DETAIL + return TASK_DETAIL; + case 8: // SUB_TASK_MODEL + return SUB_TASK_MODEL; + case 9: // TASK_ERROR + return TASK_ERROR; + case 10: // JOBS + return JOBS; + 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 __CREATIONTIME_ISSET_ID = 0; + private static final int __LASTUPDATETIME_ISSET_ID = 1; + private byte __isset_bitfield = 0; + private static final _Fields optionals[] = {_Fields.TASK_DETAIL,_Fields.SUB_TASK_MODEL,_Fields.TASK_ERROR,_Fields.JOBS}; + 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.TASK_ID, new org.apache.thrift.meta_data.FieldMetaData("taskId", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.TASK_TYPE, new org.apache.thrift.meta_data.FieldMetaData("taskType", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TaskTypes.class))); + tmpMap.put(_Fields.PARENT_PROCESS_ID, new org.apache.thrift.meta_data.FieldMetaData("parentProcessId", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.CREATION_TIME, new org.apache.thrift.meta_data.FieldMetaData("creationTime", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.LAST_UPDATE_TIME, new org.apache.thrift.meta_data.FieldMetaData("lastUpdateTime", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.TASK_STATUS, new org.apache.thrift.meta_data.FieldMetaData("taskStatus", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.status.TaskStatus.class))); + tmpMap.put(_Fields.TASK_DETAIL, new org.apache.thrift.meta_data.FieldMetaData("taskDetail", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.SUB_TASK_MODEL, new org.apache.thrift.meta_data.FieldMetaData("subTaskModel", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); + tmpMap.put(_Fields.TASK_ERROR, new org.apache.thrift.meta_data.FieldMetaData("taskError", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.commons.ErrorModel.class))); + tmpMap.put(_Fields.JOBS, new org.apache.thrift.meta_data.FieldMetaData("jobs", org.apache.thrift.TFieldRequirementType.OPTIONAL, + 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, org.apache.airavata.model.job.JobModel.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TaskModel.class, metaDataMap); + } + + public TaskModel() { + this.taskId = "DO_NOT_SET_AT_CLIENTS"; + + } + + public TaskModel( + String taskId, + TaskTypes taskType, + String parentProcessId, + long creationTime, + long lastUpdateTime, + org.apache.airavata.model.status.TaskStatus taskStatus) + { + this(); + this.taskId = taskId; + this.taskType = taskType; + this.parentProcessId = parentProcessId; + this.creationTime = creationTime; + setCreationTimeIsSet(true); + this.lastUpdateTime = lastUpdateTime; + setLastUpdateTimeIsSet(true); + this.taskStatus = taskStatus; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public TaskModel(TaskModel other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetTaskId()) { + this.taskId = other.taskId; + } + if (other.isSetTaskType()) { + this.taskType = other.taskType; + } + if (other.isSetParentProcessId()) { + this.parentProcessId = other.parentProcessId; + } + this.creationTime = other.creationTime; + this.lastUpdateTime = other.lastUpdateTime; + if (other.isSetTaskStatus()) { + this.taskStatus = new org.apache.airavata.model.status.TaskStatus(other.taskStatus); + } + if (other.isSetTaskDetail()) { + this.taskDetail = other.taskDetail; + } + if (other.isSetSubTaskModel()) { + this.subTaskModel = org.apache.thrift.TBaseHelper.copyBinary(other.subTaskModel); + } + if (other.isSetTaskError()) { + this.taskError = new org.apache.airavata.model.commons.ErrorModel(other.taskError); + } + if (other.isSetJobs()) { + List<org.apache.airavata.model.job.JobModel> __this__jobs = new ArrayList<org.apache.airavata.model.job.JobModel>(other.jobs.size()); + for (org.apache.airavata.model.job.JobModel other_element : other.jobs) { + __this__jobs.add(new org.apache.airavata.model.job.JobModel(other_element)); + } + this.jobs = __this__jobs; + } + } + + public TaskModel deepCopy() { + return new TaskModel(this); + } + + @Override + public void clear() { + this.taskId = "DO_NOT_SET_AT_CLIENTS"; + + this.taskType = null; + this.parentProcessId = null; + setCreationTimeIsSet(false); + this.creationTime = 0; + setLastUpdateTimeIsSet(false); + this.lastUpdateTime = 0; + this.taskStatus = null; + this.taskDetail = null; + this.subTaskModel = null; + this.taskError = null; + this.jobs = null; + } + + public String getTaskId() { + return this.taskId; + } + + public TaskModel setTaskId(String taskId) { + this.taskId = taskId; + return this; + } + + public void unsetTaskId() { + this.taskId = null; + } + + /** Returns true if field taskId is set (has been assigned a value) and false otherwise */ + public boolean isSetTaskId() { + return this.taskId != null; + } + + public void setTaskIdIsSet(boolean value) { + if (!value) { + this.taskId = null; + } + } + + /** + * + * @see TaskTypes + */ + public TaskTypes getTaskType() { + return this.taskType; + } + + /** + * + * @see TaskTypes + */ + public TaskModel setTaskType(TaskTypes taskType) { + this.taskType = taskType; + return this; + } + + public void unsetTaskType() { + this.taskType = null; + } + + /** Returns true if field taskType is set (has been assigned a value) and false otherwise */ + public boolean isSetTaskType() { + return this.taskType != null; + } + + public void setTaskTypeIsSet(boolean value) { + if (!value) { + this.taskType = null; + } + } + + public String getParentProcessId() { + return this.parentProcessId; + } + + public TaskModel setParentProcessId(String parentProcessId) { + this.parentProcessId = parentProcessId; + return this; + } + + public void unsetParentProcessId() { + this.parentProcessId = null; + } + + /** Returns true if field parentProcessId is set (has been assigned a value) and false otherwise */ + public boolean isSetParentProcessId() { + return this.parentProcessId != null; + } + + public void setParentProcessIdIsSet(boolean value) { + if (!value) { + this.parentProcessId = null; + } + } + + public long getCreationTime() { + return this.creationTime; + } + + public TaskModel setCreationTime(long creationTime) { + this.creationTime = creationTime; + setCreationTimeIsSet(true); + return this; + } + + public void unsetCreationTime() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CREATIONTIME_ISSET_ID); + } + + /** Returns true if field creationTime is set (has been assigned a value) and false otherwise */ + public boolean isSetCreationTime() { + return EncodingUtils.testBit(__isset_bitfield, __CREATIONTIME_ISSET_ID); + } + + public void setCreationTimeIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CREATIONTIME_ISSET_ID, value); + } + + public long getLastUpdateTime() { + return this.lastUpdateTime; + } + + public TaskModel setLastUpdateTime(long lastUpdateTime) { + this.lastUpdateTime = lastUpdateTime; + setLastUpdateTimeIsSet(true); + return this; + } + + public void unsetLastUpdateTime() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LASTUPDATETIME_ISSET_ID); + } + + /** Returns true if field lastUpdateTime is set (has been assigned a value) and false otherwise */ + public boolean isSetLastUpdateTime() { + return EncodingUtils.testBit(__isset_bitfield, __LASTUPDATETIME_ISSET_ID); + } + + public void setLastUpdateTimeIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LASTUPDATETIME_ISSET_ID, value); + } + + public org.apache.airavata.model.status.TaskStatus getTaskStatus() { + return this.taskStatus; + } + + public TaskModel setTaskStatus(org.apache.airavata.model.status.TaskStatus taskStatus) { + this.taskStatus = taskStatus; + return this; + } + + public void unsetTaskStatus() { + this.taskStatus = null; + } + + /** Returns true if field taskStatus is set (has been assigned a value) and false otherwise */ + public boolean isSetTaskStatus() { + return this.taskStatus != null; + } + + public void setTaskStatusIsSet(boolean value) { + if (!value) { + this.taskStatus = null; + } + } + + public String getTaskDetail() { + return this.taskDetail; + } + + public TaskModel setTaskDetail(String taskDetail) { + this.taskDetail = taskDetail; + return this; + } + + public void unsetTaskDetail() { + this.taskDetail = null; + } + + /** Returns true if field taskDetail is set (has been assigned a value) and false otherwise */ + public boolean isSetTaskDetail() { + return this.taskDetail != null; + } + + public void setTaskDetailIsSet(boolean value) { + if (!value) { + this.taskDetail = null; + } + } + + public byte[] getSubTaskModel() { + setSubTaskModel(org.apache.thrift.TBaseHelper.rightSize(subTaskModel)); + return subTaskModel == null ? null : subTaskModel.array(); + } + + public ByteBuffer bufferForSubTaskModel() { + return org.apache.thrift.TBaseHelper.copyBinary(subTaskModel); + } + + public TaskModel setSubTaskModel(byte[] subTaskModel) { + this.subTaskModel = subTaskModel == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(subTaskModel, subTaskModel.length)); + return this; + } + + public TaskModel setSubTaskModel(ByteBuffer subTaskModel) { + this.subTaskModel = org.apache.thrift.TBaseHelper.copyBinary(subTaskModel); + return this; + } + + public void unsetSubTaskModel() { + this.subTaskModel = null; + } + + /** Returns true if field subTaskModel is set (has been assigned a value) and false otherwise */ + public boolean isSetSubTaskModel() { + return this.subTaskModel != null; + } + + public void setSubTaskModelIsSet(boolean value) { + if (!value) { + this.subTaskModel = null; + } + } + + public org.apache.airavata.model.commons.ErrorModel getTaskError() { + return this.taskError; + } + + public TaskModel setTaskError(org.apache.airavata.model.commons.ErrorModel taskError) { + this.taskError = taskError; + return this; + } + + public void unsetTaskError() { + this.taskError = null; + } + + /** Returns true if field taskError is set (has been assigned a value) and false otherwise */ + public boolean isSetTaskError() { + return this.taskError != null; + } + + public void setTaskErrorIsSet(boolean value) { + if (!value) { + this.taskError = null; + } + } + + public int getJobsSize() { + return (this.jobs == null) ? 0 : this.jobs.size(); + } + + public java.util.Iterator<org.apache.airavata.model.job.JobModel> getJobsIterator() { + return (this.jobs == null) ? null : this.jobs.iterator(); + } + + public void addToJobs(org.apache.airavata.model.job.JobModel elem) { + if (this.jobs == null) { + this.jobs = new ArrayList<org.apache.airavata.model.job.JobModel>(); + } + this.jobs.add(elem); + } + + public List<org.apache.airavata.model.job.JobModel> getJobs() { + return this.jobs; + } + + public TaskModel setJobs(List<org.apache.airavata.model.job.JobModel> jobs) { + this.jobs = jobs; + return this; + } + + public void unsetJobs() { + this.jobs = null; + } + + /** Returns true if field jobs is set (has been assigned a value) and false otherwise */ + public boolean isSetJobs() { + return this.jobs != null; + } + + public void setJobsIsSet(boolean value) { + if (!value) { + this.jobs = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TASK_ID: + if (value == null) { + unsetTaskId(); + } else { + setTaskId((String)value); + } + break; + + case TASK_TYPE: + if (value == null) { + unsetTaskType(); + } else { + setTaskType((TaskTypes)value); + } + break; + + case PARENT_PROCESS_ID: + if (value == null) { + unsetParentProcessId(); + } else { + setParentProcessId((String)value); + } + break; + + case CREATION_TIME: + if (value == null) { + unsetCreationTime(); + } else { + setCreationTime((Long)value); + } + break; + + case LAST_UPDATE_TIME: + if (value == null) { + unsetLastUpdateTime(); + } else { + setLastUpdateTime((Long)value); + } + break; + + case TASK_STATUS: + if (value == null) { + unsetTaskStatus(); + } else { + setTaskStatus((org.apache.airavata.model.status.TaskStatus)value); + } + break; + + case TASK_DETAIL: + if (value == null) { + unsetTaskDetail(); + } else { + setTaskDetail((String)value); + } + break; + + case SUB_TASK_MODEL: + if (value == null) { + unsetSubTaskModel(); + } else { + setSubTaskModel((ByteBuffer)value); + } + break; + + case TASK_ERROR: + if (value == null) { + unsetTaskError(); + } else { + setTaskError((org.apache.airavata.model.commons.ErrorModel)value); + } + break; + + case JOBS: + if (value == null) { + unsetJobs(); + } else { + setJobs((List<org.apache.airavata.model.job.JobModel>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TASK_ID: + return getTaskId(); + + case TASK_TYPE: + return getTaskType(); + + case PARENT_PROCESS_ID: + return getParentProcessId(); + + case CREATION_TIME: + return Long.valueOf(getCreationTime()); + + case LAST_UPDATE_TIME: + return Long.valueOf(getLastUpdateTime()); + + case TASK_STATUS: + return getTaskStatus(); + + case TASK_DETAIL: + return getTaskDetail(); + + case SUB_TASK_MODEL: + return getSubTaskModel(); + + case TASK_ERROR: + return getTaskError(); + + case JOBS: + return getJobs(); + + } + 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 TASK_ID: + return isSetTaskId(); + case TASK_TYPE: + return isSetTaskType(); + case PARENT_PROCESS_ID: + return isSetParentProcessId(); + case CREATION_TIME: + return isSetCreationTime(); + case LAST_UPDATE_TIME: + return isSetLastUpdateTime(); + case TASK_STATUS: + return isSetTaskStatus(); + case TASK_DETAIL: + return isSetTaskDetail(); + case SUB_TASK_MODEL: + return isSetSubTaskModel(); + case TASK_ERROR: + return isSetTaskError(); + case JOBS: + return isSetJobs(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TaskModel) + return this.equals((TaskModel)that); + return false; + } + + public boolean equals(TaskModel that) { + if (that == null) + return false; + + boolean this_present_taskId = true && this.isSetTaskId(); + boolean that_present_taskId = true && that.isSetTaskId(); + if (this_present_taskId || that_present_taskId) { + if (!(this_present_taskId && that_present_taskId)) + return false; + if (!this.taskId.equals(that.taskId)) + return false; + } + + boolean this_present_taskType = true && this.isSetTaskType(); + boolean that_present_taskType = true && that.isSetTaskType(); + if (this_present_taskType || that_present_taskType) { + if (!(this_present_taskType && that_present_taskType)) + return false; + if (!this.taskType.equals(that.taskType)) + return false; + } + + boolean this_present_parentProcessId = true && this.isSetParentProcessId(); + boolean that_present_parentProcessId = true && that.isSetParentProcessId(); + if (this_present_parentProcessId || that_present_parentProcessId) { + if (!(this_present_parentProcessId && that_present_parentProcessId)) + return false; + if (!this.parentProcessId.equals(that.parentProcessId)) + return false; + } + + boolean this_present_creationTime = true; + boolean that_present_creationTime = true; + if (this_present_creationTime || that_present_creationTime) { + if (!(this_present_creationTime && that_present_creationTime)) + return false; + if (this.creationTime != that.creationTime) + return false; + } + + boolean this_present_lastUpdateTime = true; + boolean that_present_lastUpdateTime = true; + if (this_present_lastUpdateTime || that_present_lastUpdateTime) { + if (!(this_present_lastUpdateTime && that_present_lastUpdateTime)) + return false; + if (this.lastUpdateTime != that.lastUpdateTime) + return false; + } + + boolean this_present_taskStatus = true && this.isSetTaskStatus(); + boolean that_present_taskStatus = true && that.isSetTaskStatus(); + if (this_present_taskStatus || that_present_taskStatus) { + if (!(this_present_taskStatus && that_present_taskStatus)) + return false; + if (!this.taskStatus.equals(that.taskStatus)) + return false; + } + + boolean this_present_taskDetail = true && this.isSetTaskDetail(); + boolean that_present_taskDetail = true && that.isSetTaskDetail(); + if (this_present_taskDetail || that_present_taskDetail) { + if (!(this_present_taskDetail && that_present_taskDetail)) + return false; + if (!this.taskDetail.equals(that.taskDetail)) + return false; + } + + boolean this_present_subTaskModel = true && this.isSetSubTaskModel(); + boolean that_present_subTaskModel = true && that.isSetSubTaskModel(); + if (this_present_subTaskModel || that_present_subTaskModel) { + if (!(this_present_subTaskModel && that_present_subTaskModel)) + return false; + if (!this.subTaskModel.equals(that.subTaskModel)) + return false; + } + + boolean this_present_taskError = true && this.isSetTaskError(); + boolean that_present_taskError = true && that.isSetTaskError(); + if (this_present_taskError || that_present_taskError) { + if (!(this_present_taskError && that_present_taskError)) + return false; + if (!this.taskError.equals(that.taskError)) + return false; + } + + boolean this_present_jobs = true && this.isSetJobs(); + boolean that_present_jobs = true && that.isSetJobs(); + if (this_present_jobs || that_present_jobs) { + if (!(this_present_jobs && that_present_jobs)) + return false; + if (!this.jobs.equals(that.jobs)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_taskId = true && (isSetTaskId()); + list.add(present_taskId); + if (present_taskId) + list.add(taskId); + + boolean present_taskType = true && (isSetTaskType()); + list.add(present_taskType); + if (present_taskType) + list.add(taskType.getValue()); + + boolean present_parentProcessId = true && (isSetParentProcessId()); + list.add(present_parentProcessId); + if (present_parentProcessId) + list.add(parentProcessId); + + boolean present_creationTime = true; + list.add(present_creationTime); + if (present_creationTime) + list.add(creationTime); + + boolean present_lastUpdateTime = true; + list.add(present_lastUpdateTime); + if (present_lastUpdateTime) + list.add(lastUpdateTime); + + boolean present_taskStatus = true && (isSetTaskStatus()); + list.add(present_taskStatus); + if (present_taskStatus) + list.add(taskStatus); + + boolean present_taskDetail = true && (isSetTaskDetail()); + list.add(present_taskDetail); + if (present_taskDetail) + list.add(taskDetail); + + boolean present_subTaskModel = true && (isSetSubTaskModel()); + list.add(present_subTaskModel); + if (present_subTaskModel) + list.add(subTaskModel); + + boolean present_taskError = true && (isSetTaskError()); + list.add(present_taskError); + if (present_taskError) + list.add(taskError); + + boolean present_jobs = true && (isSetJobs()); + list.add(present_jobs); + if (present_jobs) + list.add(jobs); + + return list.hashCode(); + } + + @Override + public int compareTo(TaskModel other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetTaskId()).compareTo(other.isSetTaskId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTaskId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskId, other.taskId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTaskType()).compareTo(other.isSetTaskType()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTaskType()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskType, other.taskType); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetParentProcessId()).compareTo(other.isSetParentProcessId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetParentProcessId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parentProcessId, other.parentProcessId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetCreationTime()).compareTo(other.isSetCreationTime()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCreationTime()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.creationTime, other.creationTime); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLastUpdateTime()).compareTo(other.isSetLastUpdateTime()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLastUpdateTime()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lastUpdateTime, other.lastUpdateTime); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTaskStatus()).compareTo(other.isSetTaskStatus()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTaskStatus()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskStatus, other.taskStatus); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTaskDetail()).compareTo(other.isSetTaskDetail()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTaskDetail()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskDetail, other.taskDetail); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSubTaskModel()).compareTo(other.isSetSubTaskModel()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSubTaskModel()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.subTaskModel, other.subTaskModel); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTaskError()).compareTo(other.isSetTaskError()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTaskError()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskError, other.taskError); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetJobs()).compareTo(other.isSetJobs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetJobs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobs, other.jobs); + 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("TaskModel("); + boolean first = true; + + sb.append("taskId:"); + if (this.taskId == null) { + sb.append("null"); + } else { + sb.append(this.taskId); + } + first = false; + if (!first) sb.append(", "); + sb.append("taskType:"); + if (this.taskType == null) { + sb.append("null"); + } else { + sb.append(this.taskType); + } + first = false; + if (!first) sb.append(", "); + sb.append("parentProcessId:"); + if (this.parentProcessId == null) { + sb.append("null"); + } else { + sb.append(this.parentProcessId); + } + first = false; + if (!first) sb.append(", "); + sb.append("creationTime:"); + sb.append(this.creationTime); + first = false; + if (!first) sb.append(", "); + sb.append("lastUpdateTime:"); + sb.append(this.lastUpdateTime); + first = false; + if (!first) sb.append(", "); + sb.append("taskStatus:"); + if (this.taskStatus == null) { + sb.append("null"); + } else { + sb.append(this.taskStatus); + } + first = false; + if (isSetTaskDetail()) { + if (!first) sb.append(", "); + sb.append("taskDetail:"); + if (this.taskDetail == null) { + sb.append("null"); + } else { + sb.append(this.taskDetail); + } + first = false; + } + if (isSetSubTaskModel()) { + if (!first) sb.append(", "); + sb.append("subTaskModel:"); + if (this.subTaskModel == null) { + sb.append("null"); + } else { + org.apache.thrift.TBaseHelper.toString(this.subTaskModel, sb); + } + first = false; + } + if (isSetTaskError()) { + if (!first) sb.append(", "); + sb.append("taskError:"); + if (this.taskError == null) { + sb.append("null"); + } else { + sb.append(this.taskError); + } + first = false; + } + if (isSetJobs()) { + if (!first) sb.append(", "); + sb.append("jobs:"); + if (this.jobs == null) { + sb.append("null"); + } else { + sb.append(this.jobs); + } + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (taskId == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'taskId' was not present! Struct: " + toString()); + } + if (taskType == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'taskType' was not present! Struct: " + toString()); + } + if (parentProcessId == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'parentProcessId' was not present! Struct: " + toString()); + } + // alas, we cannot check 'creationTime' because it's a primitive and you chose the non-beans generator. + // alas, we cannot check 'lastUpdateTime' because it's a primitive and you chose the non-beans generator. + if (taskStatus == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'taskStatus' was not present! Struct: " + toString()); + } + // check for sub-struct validity + if (taskStatus != null) { + taskStatus.validate(); + } + if (taskError != null) { + taskError.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 TaskModelStandardSchemeFactory implements SchemeFactory { + public TaskModelStandardScheme getScheme() { + return new TaskModelStandardScheme(); + } + } + + private static class TaskModelStandardScheme extends StandardScheme<TaskModel> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TaskModel 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: // TASK_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.taskId = iprot.readString(); + struct.setTaskIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TASK_TYPE + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.taskType = org.apache.airavata.model.task.TaskTypes.findByValue(iprot.readI32()); + struct.setTaskTypeIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // PARENT_PROCESS_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.parentProcessId = iprot.readString(); + struct.setParentProcessIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // CREATION_TIME + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.creationTime = iprot.readI64(); + struct.setCreationTimeIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // LAST_UPDATE_TIME + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.lastUpdateTime = iprot.readI64(); + struct.setLastUpdateTimeIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // TASK_STATUS + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.taskStatus = new org.apache.airavata.model.status.TaskStatus(); + struct.taskStatus.read(iprot); + struct.setTaskStatusIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 7: // TASK_DETAIL + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.taskDetail = iprot.readString(); + struct.setTaskDetailIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 8: // SUB_TASK_MODEL + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.subTaskModel = iprot.readBinary(); + struct.setSubTaskModelIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 9: // TASK_ERROR + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.taskError = new org.apache.airavata.model.commons.ErrorModel(); + struct.taskError.read(iprot); + struct.setTaskErrorIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 10: // JOBS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list0 = iprot.readListBegin(); + struct.jobs = new ArrayList<org.apache.airavata.model.job.JobModel>(_list0.size); + org.apache.airavata.model.job.JobModel _elem1; + for (int _i2 = 0; _i2 < _list0.size; ++_i2) + { + _elem1 = new org.apache.airavata.model.job.JobModel(); + _elem1.read(iprot); + struct.jobs.add(_elem1); + } + iprot.readListEnd(); + } + struct.setJobsIsSet(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 + if (!struct.isSetCreationTime()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'creationTime' was not found in serialized data! Struct: " + toString()); + } + if (!struct.isSetLastUpdateTime()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'lastUpdateTime' was not found in serialized data! Struct: " + toString()); + } + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, TaskModel struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.taskId != null) { + oprot.writeFieldBegin(TASK_ID_FIELD_DESC); + oprot.writeString(struct.taskId); + oprot.writeFieldEnd(); + } + if (struct.taskType != null) { + oprot.writeFieldBegin(TASK_TYPE_FIELD_DESC); + oprot.writeI32(struct.taskType.getValue()); + oprot.writeFieldEnd(); + } + if (struct.parentProcessId != null) { + oprot.writeFieldBegin(PARENT_PROCESS_ID_FIELD_DESC); + oprot.writeString(struct.parentProcessId); + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(CREATION_TIME_FIELD_DESC); + oprot.writeI64(struct.creationTime); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(LAST_UPDATE_TIME_FIELD_DESC); + oprot.writeI64(struct.lastUpdateTime); + oprot.writeFieldEnd(); + if (struct.taskStatus != null) { + oprot.writeFieldBegin(TASK_STATUS_FIELD_DESC); + struct.taskStatus.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.taskDetail != null) { + if (struct.isSetTaskDetail()) { + oprot.writeFieldBegin(TASK_DETAIL_FIELD_DESC); + oprot.writeString(struct.taskDetail); + oprot.writeFieldEnd(); + } + } + if (struct.subTaskModel != null) { + if (struct.isSetSubTaskModel()) { + oprot.writeFieldBegin(SUB_TASK_MODEL_FIELD_DESC); + oprot.writeBinary(struct.subTaskModel); + oprot.writeFieldEnd(); + } + } + if (struct.taskError != null) { + if (struct.isSetTaskError()) { + oprot.writeFieldBegin(TASK_ERROR_FIELD_DESC); + struct.taskError.write(oprot); + oprot.writeFieldEnd(); + } + } + if (struct.jobs != null) { + if (struct.isSetJobs()) { + oprot.writeFieldBegin(JOBS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.jobs.size())); + for (org.apache.airavata.model.job.JobModel _iter3 : struct.jobs) + { + _iter3.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TaskModelTupleSchemeFactory implements SchemeFactory { + public TaskModelTupleScheme getScheme() { + return new TaskModelTupleScheme(); + } + } + + private static class TaskModelTupleScheme extends TupleScheme<TaskModel> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TaskModel struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.taskId); + oprot.writeI32(struct.taskType.getValue()); + oprot.writeString(struct.parentProcessId); + oprot.writeI64(struct.creationTime); + oprot.writeI64(struct.lastUpdateTime); + struct.taskStatus.write(oprot); + BitSet optionals = new BitSet(); + if (struct.isSetTaskDetail()) { + optionals.set(0); + } + if (struct.isSetSubTaskModel()) { + optionals.set(1); + } + if (struct.isSetTaskError()) { + optionals.set(2); + } + if (struct.isSetJobs()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetTaskDetail()) { + oprot.writeString(struct.taskDetail); + } + if (struct.isSetSubTaskModel()) { + oprot.writeBinary(struct.subTaskModel); + } + if (struct.isSetTaskError()) { + struct.taskError.write(oprot); + } + if (struct.isSetJobs()) { + { + oprot.writeI32(struct.jobs.size()); + for (org.apache.airavata.model.job.JobModel _iter4 : struct.jobs) + { + _iter4.write(oprot); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TaskModel struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.taskId = iprot.readString(); + struct.setTaskIdIsSet(true); + struct.taskType = org.apache.airavata.model.task.TaskTypes.findByValue(iprot.readI32()); + struct.setTaskTypeIsSet(true); + struct.parentProcessId = iprot.readString(); + struct.setParentProcessIdIsSet(true); + struct.creationTime = iprot.readI64(); + struct.setCreationTimeIsSet(true); + struct.lastUpdateTime = iprot.readI64(); + struct.setLastUpdateTimeIsSet(true); + struct.taskStatus = new org.apache.airavata.model.status.TaskStatus(); + struct.taskStatus.read(iprot); + struct.setTaskStatusIsSet(true); + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.taskDetail = iprot.readString(); + struct.setTaskDetailIsSet(true); + } + if (incoming.get(1)) { + struct.subTaskModel = iprot.readBinary(); + struct.setSubTaskModelIsSet(true); + } + if (incoming.get(2)) { + struct.taskError = new org.apache.airavata.model.commons.ErrorModel(); + struct.taskError.read(iprot); + struct.setTaskErrorIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.thrift.protocol.TList _list5 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.jobs = new ArrayList<org.apache.airavata.model.job.JobModel>(_list5.size); + org.apache.airavata.model.job.JobModel _elem6; + for (int _i7 = 0; _i7 < _list5.size; ++_i7) + { + _elem6 = new org.apache.airavata.model.job.JobModel(); + _elem6.read(iprot); + struct.jobs.add(_elem6); + } + } + struct.setJobsIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/airavata/blob/25da582a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskTypes.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskTypes.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskTypes.java new file mode 100644 index 0000000..7852e6a --- /dev/null +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/task/TaskTypes.java @@ -0,0 +1,78 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.task; + + +import java.util.Map; +import java.util.HashMap; +import org.apache.thrift.TEnum; + +/** + * TaskTypes: An enumerated list of TaskTypes. Task being generic, the task type will provide the concrete interpretation. + * + */ +public enum TaskTypes implements org.apache.thrift.TEnum { + ENV_SETUP(0), + DATA_STAGING(1), + JOB_SUBMISSION(2), + ENV_CLEANUP(3), + MONITORING(4), + OUTPUT_FETCHING(5); + + private final int value; + + private TaskTypes(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 TaskTypes findByValue(int value) { + switch (value) { + case 0: + return ENV_SETUP; + case 1: + return DATA_STAGING; + case 2: + return JOB_SUBMISSION; + case 3: + return ENV_CLEANUP; + case 4: + return MONITORING; + case 5: + return OUTPUT_FETCHING; + default: + return null; + } + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/25da582a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/workspace/Gateway.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/workspace/Gateway.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/workspace/Gateway.java new file mode 100644 index 0000000..285afdc --- /dev/null +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/workspace/Gateway.java @@ -0,0 +1,733 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.airavata.model.workspace; + +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.2)", date = "2015-12-2") +public class Gateway implements org.apache.thrift.TBase<Gateway, Gateway._Fields>, java.io.Serializable, Cloneable, Comparable<Gateway> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Gateway"); + + private static final org.apache.thrift.protocol.TField GATEWAY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayId", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField GATEWAY_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayName", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField DOMAIN_FIELD_DESC = new org.apache.thrift.protocol.TField("domain", org.apache.thrift.protocol.TType.STRING, (short)3); + private static final org.apache.thrift.protocol.TField EMAIL_ADDRESS_FIELD_DESC = new org.apache.thrift.protocol.TField("emailAddress", 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 GatewayStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GatewayTupleSchemeFactory()); + } + + public String gatewayId; // required + public String gatewayName; // optional + public String domain; // optional + public String emailAddress; // 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 { + GATEWAY_ID((short)1, "gatewayId"), + GATEWAY_NAME((short)2, "gatewayName"), + DOMAIN((short)3, "domain"), + EMAIL_ADDRESS((short)4, "emailAddress"); + + 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: // GATEWAY_ID + return GATEWAY_ID; + case 2: // GATEWAY_NAME + return GATEWAY_NAME; + case 3: // DOMAIN + return DOMAIN; + case 4: // EMAIL_ADDRESS + return EMAIL_ADDRESS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final _Fields optionals[] = {_Fields.GATEWAY_NAME,_Fields.DOMAIN,_Fields.EMAIL_ADDRESS}; + 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.GATEWAY_ID, new org.apache.thrift.meta_data.FieldMetaData("gatewayId", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.GATEWAY_NAME, new org.apache.thrift.meta_data.FieldMetaData("gatewayName", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.DOMAIN, new org.apache.thrift.meta_data.FieldMetaData("domain", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.EMAIL_ADDRESS, new org.apache.thrift.meta_data.FieldMetaData("emailAddress", 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(Gateway.class, metaDataMap); + } + + public Gateway() { + } + + public Gateway( + String gatewayId) + { + this(); + this.gatewayId = gatewayId; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Gateway(Gateway other) { + if (other.isSetGatewayId()) { + this.gatewayId = other.gatewayId; + } + if (other.isSetGatewayName()) { + this.gatewayName = other.gatewayName; + } + if (other.isSetDomain()) { + this.domain = other.domain; + } + if (other.isSetEmailAddress()) { + this.emailAddress = other.emailAddress; + } + } + + public Gateway deepCopy() { + return new Gateway(this); + } + + @Override + public void clear() { + this.gatewayId = null; + this.gatewayName = null; + this.domain = null; + this.emailAddress = null; + } + + public String getGatewayId() { + return this.gatewayId; + } + + public Gateway setGatewayId(String gatewayId) { + this.gatewayId = gatewayId; + return this; + } + + public void unsetGatewayId() { + this.gatewayId = null; + } + + /** Returns true if field gatewayId is set (has been assigned a value) and false otherwise */ + public boolean isSetGatewayId() { + return this.gatewayId != null; + } + + public void setGatewayIdIsSet(boolean value) { + if (!value) { + this.gatewayId = null; + } + } + + public String getGatewayName() { + return this.gatewayName; + } + + public Gateway setGatewayName(String gatewayName) { + this.gatewayName = gatewayName; + return this; + } + + public void unsetGatewayName() { + this.gatewayName = null; + } + + /** Returns true if field gatewayName is set (has been assigned a value) and false otherwise */ + public boolean isSetGatewayName() { + return this.gatewayName != null; + } + + public void setGatewayNameIsSet(boolean value) { + if (!value) { + this.gatewayName = null; + } + } + + public String getDomain() { + return this.domain; + } + + public Gateway setDomain(String domain) { + this.domain = domain; + return this; + } + + public void unsetDomain() { + this.domain = null; + } + + /** Returns true if field domain is set (has been assigned a value) and false otherwise */ + public boolean isSetDomain() { + return this.domain != null; + } + + public void setDomainIsSet(boolean value) { + if (!value) { + this.domain = null; + } + } + + public String getEmailAddress() { + return this.emailAddress; + } + + public Gateway setEmailAddress(String emailAddress) { + this.emailAddress = emailAddress; + return this; + } + + public void unsetEmailAddress() { + this.emailAddress = null; + } + + /** Returns true if field emailAddress is set (has been assigned a value) and false otherwise */ + public boolean isSetEmailAddress() { + return this.emailAddress != null; + } + + public void setEmailAddressIsSet(boolean value) { + if (!value) { + this.emailAddress = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case GATEWAY_ID: + if (value == null) { + unsetGatewayId(); + } else { + setGatewayId((String)value); + } + break; + + case GATEWAY_NAME: + if (value == null) { + unsetGatewayName(); + } else { + setGatewayName((String)value); + } + break; + + case DOMAIN: + if (value == null) { + unsetDomain(); + } else { + setDomain((String)value); + } + break; + + case EMAIL_ADDRESS: + if (value == null) { + unsetEmailAddress(); + } else { + setEmailAddress((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case GATEWAY_ID: + return getGatewayId(); + + case GATEWAY_NAME: + return getGatewayName(); + + case DOMAIN: + return getDomain(); + + case EMAIL_ADDRESS: + return getEmailAddress(); + + } + 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 GATEWAY_ID: + return isSetGatewayId(); + case GATEWAY_NAME: + return isSetGatewayName(); + case DOMAIN: + return isSetDomain(); + case EMAIL_ADDRESS: + return isSetEmailAddress(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Gateway) + return this.equals((Gateway)that); + return false; + } + + public boolean equals(Gateway that) { + if (that == null) + return false; + + boolean this_present_gatewayId = true && this.isSetGatewayId(); + boolean that_present_gatewayId = true && that.isSetGatewayId(); + if (this_present_gatewayId || that_present_gatewayId) { + if (!(this_present_gatewayId && that_present_gatewayId)) + return false; + if (!this.gatewayId.equals(that.gatewayId)) + return false; + } + + boolean this_present_gatewayName = true && this.isSetGatewayName(); + boolean that_present_gatewayName = true && that.isSetGatewayName(); + if (this_present_gatewayName || that_present_gatewayName) { + if (!(this_present_gatewayName && that_present_gatewayName)) + return false; + if (!this.gatewayName.equals(that.gatewayName)) + return false; + } + + boolean this_present_domain = true && this.isSetDomain(); + boolean that_present_domain = true && that.isSetDomain(); + if (this_present_domain || that_present_domain) { + if (!(this_present_domain && that_present_domain)) + return false; + if (!this.domain.equals(that.domain)) + return false; + } + + boolean this_present_emailAddress = true && this.isSetEmailAddress(); + boolean that_present_emailAddress = true && that.isSetEmailAddress(); + if (this_present_emailAddress || that_present_emailAddress) { + if (!(this_present_emailAddress && that_present_emailAddress)) + return false; + if (!this.emailAddress.equals(that.emailAddress)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_gatewayId = true && (isSetGatewayId()); + list.add(present_gatewayId); + if (present_gatewayId) + list.add(gatewayId); + + boolean present_gatewayName = true && (isSetGatewayName()); + list.add(present_gatewayName); + if (present_gatewayName) + list.add(gatewayName); + + boolean present_domain = true && (isSetDomain()); + list.add(present_domain); + if (present_domain) + list.add(domain); + + boolean present_emailAddress = true && (isSetEmailAddress()); + list.add(present_emailAddress); + if (present_emailAddress) + list.add(emailAddress); + + return list.hashCode(); + } + + @Override + public int compareTo(Gateway other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetGatewayId()).compareTo(other.isSetGatewayId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetGatewayId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gatewayId, other.gatewayId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetGatewayName()).compareTo(other.isSetGatewayName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetGatewayName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gatewayName, other.gatewayName); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDomain()).compareTo(other.isSetDomain()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDomain()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.domain, other.domain); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetEmailAddress()).compareTo(other.isSetEmailAddress()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetEmailAddress()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.emailAddress, other.emailAddress); + 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("Gateway("); + boolean first = true; + + sb.append("gatewayId:"); + if (this.gatewayId == null) { + sb.append("null"); + } else { + sb.append(this.gatewayId); + } + first = false; + if (isSetGatewayName()) { + if (!first) sb.append(", "); + sb.append("gatewayName:"); + if (this.gatewayName == null) { + sb.append("null"); + } else { + sb.append(this.gatewayName); + } + first = false; + } + if (isSetDomain()) { + if (!first) sb.append(", "); + sb.append("domain:"); + if (this.domain == null) { + sb.append("null"); + } else { + sb.append(this.domain); + } + first = false; + } + if (isSetEmailAddress()) { + if (!first) sb.append(", "); + sb.append("emailAddress:"); + if (this.emailAddress == null) { + sb.append("null"); + } else { + sb.append(this.emailAddress); + } + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (gatewayId == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); + } + // 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 GatewayStandardSchemeFactory implements SchemeFactory { + public GatewayStandardScheme getScheme() { + return new GatewayStandardScheme(); + } + } + + private static class GatewayStandardScheme extends StandardScheme<Gateway> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, Gateway 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: // GATEWAY_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.gatewayId = iprot.readString(); + struct.setGatewayIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // GATEWAY_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.gatewayName = iprot.readString(); + struct.setGatewayNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // DOMAIN + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.domain = iprot.readString(); + struct.setDomainIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // EMAIL_ADDRESS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.emailAddress = iprot.readString(); + struct.setEmailAddressIsSet(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, Gateway struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.gatewayId != null) { + oprot.writeFieldBegin(GATEWAY_ID_FIELD_DESC); + oprot.writeString(struct.gatewayId); + oprot.writeFieldEnd(); + } + if (struct.gatewayName != null) { + if (struct.isSetGatewayName()) { + oprot.writeFieldBegin(GATEWAY_NAME_FIELD_DESC); + oprot.writeString(struct.gatewayName); + oprot.writeFieldEnd(); + } + } + if (struct.domain != null) { + if (struct.isSetDomain()) { + oprot.writeFieldBegin(DOMAIN_FIELD_DESC); + oprot.writeString(struct.domain); + oprot.writeFieldEnd(); + } + } + if (struct.emailAddress != null) { + if (struct.isSetEmailAddress()) { + oprot.writeFieldBegin(EMAIL_ADDRESS_FIELD_DESC); + oprot.writeString(struct.emailAddress); + oprot.writeFieldEnd(); + } + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GatewayTupleSchemeFactory implements SchemeFactory { + public GatewayTupleScheme getScheme() { + return new GatewayTupleScheme(); + } + } + + private static class GatewayTupleScheme extends TupleScheme<Gateway> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, Gateway struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.gatewayId); + BitSet optionals = new BitSet(); + if (struct.isSetGatewayName()) { + optionals.set(0); + } + if (struct.isSetDomain()) { + optionals.set(1); + } + if (struct.isSetEmailAddress()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetGatewayName()) { + oprot.writeString(struct.gatewayName); + } + if (struct.isSetDomain()) { + oprot.writeString(struct.domain); + } + if (struct.isSetEmailAddress()) { + oprot.writeString(struct.emailAddress); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, Gateway struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.gatewayId = iprot.readString(); + struct.setGatewayIdIsSet(true); + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + struct.gatewayName = iprot.readString(); + struct.setGatewayNameIsSet(true); + } + if (incoming.get(1)) { + struct.domain = iprot.readString(); + struct.setDomainIsSet(true); + } + if (incoming.get(2)) { + struct.emailAddress = iprot.readString(); + struct.setEmailAddressIsSet(true); + } + } + } + +} +
