in airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java [1789:2008]
public void read(org.apache.thrift.protocol.TProtocol iprot, ApplicationDeploymentDescription 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: // APP_DEPLOYMENT_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.appDeploymentId = iprot.readString();
struct.setAppDeploymentIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // APP_MODULE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.appModuleId = iprot.readString();
struct.setAppModuleIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // COMPUTE_HOST_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.computeHostId = iprot.readString();
struct.setComputeHostIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // EXECUTABLE_PATH
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.executablePath = iprot.readString();
struct.setExecutablePathIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // PARALLELISM
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.parallelism = org.apache.airavata.model.parallelism.ApplicationParallelismType.findByValue(iprot.readI32());
struct.setParallelismIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // APP_DEPLOYMENT_DESCRIPTION
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.appDeploymentDescription = iprot.readString();
struct.setAppDeploymentDescriptionIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // MODULE_LOAD_CMDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
struct.moduleLoadCmds = new java.util.ArrayList<CommandObject>(_list0.size);
@org.apache.thrift.annotation.Nullable CommandObject _elem1;
for (int _i2 = 0; _i2 < _list0.size; ++_i2)
{
_elem1 = new CommandObject();
_elem1.read(iprot);
struct.moduleLoadCmds.add(_elem1);
}
iprot.readListEnd();
}
struct.setModuleLoadCmdsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // LIB_PREPEND_PATHS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list3 = iprot.readListBegin();
struct.libPrependPaths = new java.util.ArrayList<SetEnvPaths>(_list3.size);
@org.apache.thrift.annotation.Nullable SetEnvPaths _elem4;
for (int _i5 = 0; _i5 < _list3.size; ++_i5)
{
_elem4 = new SetEnvPaths();
_elem4.read(iprot);
struct.libPrependPaths.add(_elem4);
}
iprot.readListEnd();
}
struct.setLibPrependPathsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // LIB_APPEND_PATHS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list6 = iprot.readListBegin();
struct.libAppendPaths = new java.util.ArrayList<SetEnvPaths>(_list6.size);
@org.apache.thrift.annotation.Nullable SetEnvPaths _elem7;
for (int _i8 = 0; _i8 < _list6.size; ++_i8)
{
_elem7 = new SetEnvPaths();
_elem7.read(iprot);
struct.libAppendPaths.add(_elem7);
}
iprot.readListEnd();
}
struct.setLibAppendPathsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // SET_ENVIRONMENT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list9 = iprot.readListBegin();
struct.setEnvironment = new java.util.ArrayList<SetEnvPaths>(_list9.size);
@org.apache.thrift.annotation.Nullable SetEnvPaths _elem10;
for (int _i11 = 0; _i11 < _list9.size; ++_i11)
{
_elem10 = new SetEnvPaths();
_elem10.read(iprot);
struct.setEnvironment.add(_elem10);
}
iprot.readListEnd();
}
struct.setSetEnvironmentIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // PRE_JOB_COMMANDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list12 = iprot.readListBegin();
struct.preJobCommands = new java.util.ArrayList<CommandObject>(_list12.size);
@org.apache.thrift.annotation.Nullable CommandObject _elem13;
for (int _i14 = 0; _i14 < _list12.size; ++_i14)
{
_elem13 = new CommandObject();
_elem13.read(iprot);
struct.preJobCommands.add(_elem13);
}
iprot.readListEnd();
}
struct.setPreJobCommandsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // POST_JOB_COMMANDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list15 = iprot.readListBegin();
struct.postJobCommands = new java.util.ArrayList<CommandObject>(_list15.size);
@org.apache.thrift.annotation.Nullable CommandObject _elem16;
for (int _i17 = 0; _i17 < _list15.size; ++_i17)
{
_elem16 = new CommandObject();
_elem16.read(iprot);
struct.postJobCommands.add(_elem16);
}
iprot.readListEnd();
}
struct.setPostJobCommandsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // DEFAULT_QUEUE_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.defaultQueueName = iprot.readString();
struct.setDefaultQueueNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // DEFAULT_NODE_COUNT
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.defaultNodeCount = iprot.readI32();
struct.setDefaultNodeCountIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // DEFAULT_CPUCOUNT
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.defaultCPUCount = iprot.readI32();
struct.setDefaultCPUCountIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 16: // DEFAULT_WALLTIME
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.defaultWalltime = iprot.readI32();
struct.setDefaultWalltimeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 17: // EDITABLE_BY_USER
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.editableByUser = iprot.readBool();
struct.setEditableByUserIsSet(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();
}