in airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.cpp [322:651]
uint32_t ProcessModel::read(::apache::thrift::protocol::TProtocol* iprot) {
apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
uint32_t xfer = 0;
std::string fname;
::apache::thrift::protocol::TType ftype;
int16_t fid;
xfer += iprot->readStructBegin(fname);
using ::apache::thrift::protocol::TProtocolException;
bool isset_processId = false;
bool isset_experimentId = false;
while (true)
{
xfer += iprot->readFieldBegin(fname, ftype, fid);
if (ftype == ::apache::thrift::protocol::T_STOP) {
break;
}
switch (fid)
{
case 1:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->processId);
isset_processId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->experimentId);
isset_experimentId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->creationTime);
this->__isset.creationTime = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->lastUpdateTime);
this->__isset.lastUpdateTime = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->processStatuses.clear();
uint32_t _size2;
::apache::thrift::protocol::TType _etype5;
xfer += iprot->readListBegin(_etype5, _size2);
this->processStatuses.resize(_size2);
uint32_t _i6;
for (_i6 = 0; _i6 < _size2; ++_i6)
{
xfer += this->processStatuses[_i6].read(iprot);
}
xfer += iprot->readListEnd();
}
this->__isset.processStatuses = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 6:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->processDetail);
this->__isset.processDetail = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 7:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->applicationInterfaceId);
this->__isset.applicationInterfaceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 8:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->applicationDeploymentId);
this->__isset.applicationDeploymentId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 9:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->computeResourceId);
this->__isset.computeResourceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 10:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->processInputs.clear();
uint32_t _size7;
::apache::thrift::protocol::TType _etype10;
xfer += iprot->readListBegin(_etype10, _size7);
this->processInputs.resize(_size7);
uint32_t _i11;
for (_i11 = 0; _i11 < _size7; ++_i11)
{
xfer += this->processInputs[_i11].read(iprot);
}
xfer += iprot->readListEnd();
}
this->__isset.processInputs = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 11:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->processOutputs.clear();
uint32_t _size12;
::apache::thrift::protocol::TType _etype15;
xfer += iprot->readListBegin(_etype15, _size12);
this->processOutputs.resize(_size12);
uint32_t _i16;
for (_i16 = 0; _i16 < _size12; ++_i16)
{
xfer += this->processOutputs[_i16].read(iprot);
}
xfer += iprot->readListEnd();
}
this->__isset.processOutputs = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 12:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->processResourceSchedule.read(iprot);
this->__isset.processResourceSchedule = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 13:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->tasks.clear();
uint32_t _size17;
::apache::thrift::protocol::TType _etype20;
xfer += iprot->readListBegin(_etype20, _size17);
this->tasks.resize(_size17);
uint32_t _i21;
for (_i21 = 0; _i21 < _size17; ++_i21)
{
xfer += this->tasks[_i21].read(iprot);
}
xfer += iprot->readListEnd();
}
this->__isset.tasks = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 14:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->taskDag);
this->__isset.taskDag = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 15:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->processErrors.clear();
uint32_t _size22;
::apache::thrift::protocol::TType _etype25;
xfer += iprot->readListBegin(_etype25, _size22);
this->processErrors.resize(_size22);
uint32_t _i26;
for (_i26 = 0; _i26 < _size22; ++_i26)
{
xfer += this->processErrors[_i26].read(iprot);
}
xfer += iprot->readListEnd();
}
this->__isset.processErrors = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 16:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->gatewayExecutionId);
this->__isset.gatewayExecutionId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 17:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->enableEmailNotification);
this->__isset.enableEmailNotification = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 18:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->emailAddresses.clear();
uint32_t _size27;
::apache::thrift::protocol::TType _etype30;
xfer += iprot->readListBegin(_etype30, _size27);
this->emailAddresses.resize(_size27);
uint32_t _i31;
for (_i31 = 0; _i31 < _size27; ++_i31)
{
xfer += iprot->readString(this->emailAddresses[_i31]);
}
xfer += iprot->readListEnd();
}
this->__isset.emailAddresses = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 19:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->storageResourceId);
this->__isset.storageResourceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 20:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->userDn);
this->__isset.userDn = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 21:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->generateCert);
this->__isset.generateCert = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 22:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->experimentDataDir);
this->__isset.experimentDataDir = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 23:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->userName);
this->__isset.userName = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 24:
if (ftype == ::apache::thrift::protocol::T_BOOL) {
xfer += iprot->readBool(this->useUserCRPref);
this->__isset.useUserCRPref = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 25:
if (ftype == ::apache::thrift::protocol::T_STRING) {
xfer += iprot->readString(this->groupResourceProfileId);
this->__isset.groupResourceProfileId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 26:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->processWorkflows.clear();
uint32_t _size32;
::apache::thrift::protocol::TType _etype35;
xfer += iprot->readListBegin(_etype35, _size32);
this->processWorkflows.resize(_size32);
uint32_t _i36;
for (_i36 = 0; _i36 < _size32; ++_i36)
{
xfer += this->processWorkflows[_i36].read(iprot);
}
xfer += iprot->readListEnd();
}
this->__isset.processWorkflows = true;
} else {
xfer += iprot->skip(ftype);
}
break;
default:
xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
}
xfer += iprot->readStructEnd();
if (!isset_processId)
throw TProtocolException(TProtocolException::INVALID_DATA);
if (!isset_experimentId)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}