in airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/process/ProcessModel.java [2491:2793]
public void read(org.apache.thrift.protocol.TProtocol iprot, ProcessModel 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: // PROCESS_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.processId = iprot.readString();
struct.setProcessIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // EXPERIMENT_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.experimentId = iprot.readString();
struct.setExperimentIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // 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 4: // 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 5: // PROCESS_STATUSES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
struct.processStatuses = new java.util.ArrayList<org.apache.airavata.model.status.ProcessStatus>(_list0.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.status.ProcessStatus _elem1;
for (int _i2 = 0; _i2 < _list0.size; ++_i2)
{
_elem1 = new org.apache.airavata.model.status.ProcessStatus();
_elem1.read(iprot);
struct.processStatuses.add(_elem1);
}
iprot.readListEnd();
}
struct.setProcessStatusesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // PROCESS_DETAIL
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.processDetail = iprot.readString();
struct.setProcessDetailIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // APPLICATION_INTERFACE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.applicationInterfaceId = iprot.readString();
struct.setApplicationInterfaceIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // APPLICATION_DEPLOYMENT_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.applicationDeploymentId = iprot.readString();
struct.setApplicationDeploymentIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // COMPUTE_RESOURCE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.computeResourceId = iprot.readString();
struct.setComputeResourceIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // PROCESS_INPUTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list3 = iprot.readListBegin();
struct.processInputs = new java.util.ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(_list3.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.application.io.InputDataObjectType _elem4;
for (int _i5 = 0; _i5 < _list3.size; ++_i5)
{
_elem4 = new org.apache.airavata.model.application.io.InputDataObjectType();
_elem4.read(iprot);
struct.processInputs.add(_elem4);
}
iprot.readListEnd();
}
struct.setProcessInputsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // PROCESS_OUTPUTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list6 = iprot.readListBegin();
struct.processOutputs = new java.util.ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(_list6.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.application.io.OutputDataObjectType _elem7;
for (int _i8 = 0; _i8 < _list6.size; ++_i8)
{
_elem7 = new org.apache.airavata.model.application.io.OutputDataObjectType();
_elem7.read(iprot);
struct.processOutputs.add(_elem7);
}
iprot.readListEnd();
}
struct.setProcessOutputsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // PROCESS_RESOURCE_SCHEDULE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.processResourceSchedule = new org.apache.airavata.model.scheduling.ComputationalResourceSchedulingModel();
struct.processResourceSchedule.read(iprot);
struct.setProcessResourceScheduleIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // TASKS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list9 = iprot.readListBegin();
struct.tasks = new java.util.ArrayList<org.apache.airavata.model.task.TaskModel>(_list9.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.task.TaskModel _elem10;
for (int _i11 = 0; _i11 < _list9.size; ++_i11)
{
_elem10 = new org.apache.airavata.model.task.TaskModel();
_elem10.read(iprot);
struct.tasks.add(_elem10);
}
iprot.readListEnd();
}
struct.setTasksIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // TASK_DAG
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.taskDag = iprot.readString();
struct.setTaskDagIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // PROCESS_ERRORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list12 = iprot.readListBegin();
struct.processErrors = new java.util.ArrayList<org.apache.airavata.model.commons.ErrorModel>(_list12.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.commons.ErrorModel _elem13;
for (int _i14 = 0; _i14 < _list12.size; ++_i14)
{
_elem13 = new org.apache.airavata.model.commons.ErrorModel();
_elem13.read(iprot);
struct.processErrors.add(_elem13);
}
iprot.readListEnd();
}
struct.setProcessErrorsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 16: // GATEWAY_EXECUTION_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.gatewayExecutionId = iprot.readString();
struct.setGatewayExecutionIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 17: // ENABLE_EMAIL_NOTIFICATION
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.enableEmailNotification = iprot.readBool();
struct.setEnableEmailNotificationIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 18: // EMAIL_ADDRESSES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list15 = iprot.readListBegin();
struct.emailAddresses = new java.util.ArrayList<java.lang.String>(_list15.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem16;
for (int _i17 = 0; _i17 < _list15.size; ++_i17)
{
_elem16 = iprot.readString();
struct.emailAddresses.add(_elem16);
}
iprot.readListEnd();
}
struct.setEmailAddressesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 19: // STORAGE_RESOURCE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.storageResourceId = iprot.readString();
struct.setStorageResourceIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 20: // USER_DN
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.userDn = iprot.readString();
struct.setUserDnIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 21: // GENERATE_CERT
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.generateCert = iprot.readBool();
struct.setGenerateCertIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 22: // EXPERIMENT_DATA_DIR
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.experimentDataDir = iprot.readString();
struct.setExperimentDataDirIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 23: // USER_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.userName = iprot.readString();
struct.setUserNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 24: // USE_USER_CRPREF
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.useUserCRPref = iprot.readBool();
struct.setUseUserCRPrefIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 25: // GROUP_RESOURCE_PROFILE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.groupResourceProfileId = iprot.readString();
struct.setGroupResourceProfileIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 26: // PROCESS_WORKFLOWS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list18 = iprot.readListBegin();
struct.processWorkflows = new java.util.ArrayList<ProcessWorkflow>(_list18.size);
@org.apache.thrift.annotation.Nullable ProcessWorkflow _elem19;
for (int _i20 = 0; _i20 < _list18.size; ++_i20)
{
_elem19 = new ProcessWorkflow();
_elem19.read(iprot);
struct.processWorkflows.add(_elem19);
}
iprot.readListEnd();
}
struct.setProcessWorkflowsIsSet(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();
struct.validate();
}