http://git-wip-us.apache.org/repos/asf/airavata/blob/ede66edf/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp index e1c3da2..063c4c6 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp @@ -7747,6 +7747,239 @@ uint32_t Airavata_updateApplicationModule_presult::read(::apache::thrift::protoc return xfer; } +uint32_t Airavata_getAllModules_args::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + xfer += iprot->skip(ftype); + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getAllModules_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getAllModules_args"); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getAllModules_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getAllModules_pargs"); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getAllModules_result::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->success.clear(); + uint32_t _size159; + ::apache::thrift::protocol::TType _etype162; + xfer += iprot->readListBegin(_etype162, _size159); + this->success.resize(_size159); + uint32_t _i163; + for (_i163 = 0; _i163 < _size159; ++_i163) + { + xfer += this->success[_i163].read(iprot); + } + xfer += iprot->readListEnd(); + } + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getAllModules_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getAllModules_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); + std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter164; + for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164) + { + xfer += (*_iter164).write(oprot); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getAllModules_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + (*(this->success)).clear(); + uint32_t _size165; + ::apache::thrift::protocol::TType _etype168; + xfer += iprot->readListBegin(_etype168, _size165); + (*(this->success)).resize(_size165); + uint32_t _i169; + for (_i169 = 0; _i169 < _size165; ++_i169) + { + xfer += (*(this->success))[_i169].read(iprot); + } + xfer += iprot->readListEnd(); + } + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + uint32_t Airavata_deleteApplicationModule_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -8984,14 +9217,14 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size159; - ::apache::thrift::protocol::TType _etype162; - xfer += iprot->readListBegin(_etype162, _size159); - this->success.resize(_size159); - uint32_t _i163; - for (_i163 = 0; _i163 < _size159; ++_i163) + uint32_t _size170; + ::apache::thrift::protocol::TType _etype173; + xfer += iprot->readListBegin(_etype173, _size170); + this->success.resize(_size170); + uint32_t _i174; + for (_i174 = 0; _i174 < _size170; ++_i174) { - xfer += iprot->readString(this->success[_i163]); + xfer += iprot->readString(this->success[_i174]); } xfer += iprot->readListEnd(); } @@ -9046,10 +9279,10 @@ uint32_t Airavata_getAppModuleDeployedResources_result::write(::apache::thrift:: xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::vector<std::string> ::const_iterator _iter164; - for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164) + std::vector<std::string> ::const_iterator _iter175; + for (_iter175 = this->success.begin(); _iter175 != this->success.end(); ++_iter175) { - xfer += oprot->writeString((*_iter164)); + xfer += oprot->writeString((*_iter175)); } xfer += oprot->writeListEnd(); } @@ -9096,14 +9329,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift:: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size165; - ::apache::thrift::protocol::TType _etype168; - xfer += iprot->readListBegin(_etype168, _size165); - (*(this->success)).resize(_size165); - uint32_t _i169; - for (_i169 = 0; _i169 < _size165; ++_i169) + uint32_t _size176; + ::apache::thrift::protocol::TType _etype179; + xfer += iprot->readListBegin(_etype179, _size176); + (*(this->success)).resize(_size176); + uint32_t _i180; + for (_i180 = 0; _i180 < _size176; ++_i180) { - xfer += iprot->readString((*(this->success))[_i169]); + xfer += iprot->readString((*(this->success))[_i180]); } xfer += iprot->readListEnd(); } @@ -10136,17 +10369,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift: if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size170; - ::apache::thrift::protocol::TType _ktype171; - ::apache::thrift::protocol::TType _vtype172; - xfer += iprot->readMapBegin(_ktype171, _vtype172, _size170); - uint32_t _i174; - for (_i174 = 0; _i174 < _size170; ++_i174) + uint32_t _size181; + ::apache::thrift::protocol::TType _ktype182; + ::apache::thrift::protocol::TType _vtype183; + xfer += iprot->readMapBegin(_ktype182, _vtype183, _size181); + uint32_t _i185; + for (_i185 = 0; _i185 < _size181; ++_i185) { - std::string _key175; - xfer += iprot->readString(_key175); - std::string& _val176 = this->success[_key175]; - xfer += iprot->readString(_val176); + std::string _key186; + xfer += iprot->readString(_key186); + std::string& _val187 = this->success[_key186]; + xfer += iprot->readString(_val187); } xfer += iprot->readMapEnd(); } @@ -10201,11 +10434,11 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::write(::apache::thrift xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::map<std::string, std::string> ::const_iterator _iter177; - for (_iter177 = this->success.begin(); _iter177 != this->success.end(); ++_iter177) + std::map<std::string, std::string> ::const_iterator _iter188; + for (_iter188 = this->success.begin(); _iter188 != this->success.end(); ++_iter188) { - xfer += oprot->writeString(_iter177->first); - xfer += oprot->writeString(_iter177->second); + xfer += oprot->writeString(_iter188->first); + xfer += oprot->writeString(_iter188->second); } xfer += oprot->writeMapEnd(); } @@ -10252,17 +10485,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size178; - ::apache::thrift::protocol::TType _ktype179; - ::apache::thrift::protocol::TType _vtype180; - xfer += iprot->readMapBegin(_ktype179, _vtype180, _size178); - uint32_t _i182; - for (_i182 = 0; _i182 < _size178; ++_i182) + uint32_t _size189; + ::apache::thrift::protocol::TType _ktype190; + ::apache::thrift::protocol::TType _vtype191; + xfer += iprot->readMapBegin(_ktype190, _vtype191, _size189); + uint32_t _i193; + for (_i193 = 0; _i193 < _size189; ++_i193) { - std::string _key183; - xfer += iprot->readString(_key183); - std::string& _val184 = (*(this->success))[_key183]; - xfer += iprot->readString(_val184); + std::string _key194; + xfer += iprot->readString(_key194); + std::string& _val195 = (*(this->success))[_key194]; + xfer += iprot->readString(_val195); } xfer += iprot->readMapEnd(); } @@ -10376,14 +10609,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size185; - ::apache::thrift::protocol::TType _etype188; - xfer += iprot->readListBegin(_etype188, _size185); - this->success.resize(_size185); - uint32_t _i189; - for (_i189 = 0; _i189 < _size185; ++_i189) + uint32_t _size196; + ::apache::thrift::protocol::TType _etype199; + xfer += iprot->readListBegin(_etype199, _size196); + this->success.resize(_size196); + uint32_t _i200; + for (_i200 = 0; _i200 < _size196; ++_i200) { - xfer += this->success[_i189].read(iprot); + xfer += this->success[_i200].read(iprot); } xfer += iprot->readListEnd(); } @@ -10438,10 +10671,10 @@ uint32_t Airavata_getAllApplicationInterfaces_result::write(::apache::thrift::pr xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter190; - for (_iter190 = this->success.begin(); _iter190 != this->success.end(); ++_iter190) + std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter201; + for (_iter201 = this->success.begin(); _iter201 != this->success.end(); ++_iter201) { - xfer += (*_iter190).write(oprot); + xfer += (*_iter201).write(oprot); } xfer += oprot->writeListEnd(); } @@ -10488,14 +10721,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size191; - ::apache::thrift::protocol::TType _etype194; - xfer += iprot->readListBegin(_etype194, _size191); - (*(this->success)).resize(_size191); - uint32_t _i195; - for (_i195 = 0; _i195 < _size191; ++_i195) + uint32_t _size202; + ::apache::thrift::protocol::TType _etype205; + xfer += iprot->readListBegin(_etype205, _size202); + (*(this->success)).resize(_size202); + uint32_t _i206; + for (_i206 = 0; _i206 < _size202; ++_i206) { - xfer += (*(this->success))[_i195].read(iprot); + xfer += (*(this->success))[_i206].read(iprot); } xfer += iprot->readListEnd(); } @@ -10633,14 +10866,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol:: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size196; - ::apache::thrift::protocol::TType _etype199; - xfer += iprot->readListBegin(_etype199, _size196); - this->success.resize(_size196); - uint32_t _i200; - for (_i200 = 0; _i200 < _size196; ++_i200) + uint32_t _size207; + ::apache::thrift::protocol::TType _etype210; + xfer += iprot->readListBegin(_etype210, _size207); + this->success.resize(_size207); + uint32_t _i211; + for (_i211 = 0; _i211 < _size207; ++_i211) { - xfer += this->success[_i200].read(iprot); + xfer += this->success[_i211].read(iprot); } xfer += iprot->readListEnd(); } @@ -10695,10 +10928,10 @@ uint32_t Airavata_getApplicationInputs_result::write(::apache::thrift::protocol: xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter201; - for (_iter201 = this->success.begin(); _iter201 != this->success.end(); ++_iter201) + std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter212; + for (_iter212 = this->success.begin(); _iter212 != this->success.end(); ++_iter212) { - xfer += (*_iter201).write(oprot); + xfer += (*_iter212).write(oprot); } xfer += oprot->writeListEnd(); } @@ -10745,14 +10978,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size202; - ::apache::thrift::protocol::TType _etype205; - xfer += iprot->readListBegin(_etype205, _size202); - (*(this->success)).resize(_size202); - uint32_t _i206; - for (_i206 = 0; _i206 < _size202; ++_i206) + uint32_t _size213; + ::apache::thrift::protocol::TType _etype216; + xfer += iprot->readListBegin(_etype216, _size213); + (*(this->success)).resize(_size213); + uint32_t _i217; + for (_i217 = 0; _i217 < _size213; ++_i217) { - xfer += (*(this->success))[_i206].read(iprot); + xfer += (*(this->success))[_i217].read(iprot); } xfer += iprot->readListEnd(); } @@ -10890,14 +11123,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size207; - ::apache::thrift::protocol::TType _etype210; - xfer += iprot->readListBegin(_etype210, _size207); - this->success.resize(_size207); - uint32_t _i211; - for (_i211 = 0; _i211 < _size207; ++_i211) + uint32_t _size218; + ::apache::thrift::protocol::TType _etype221; + xfer += iprot->readListBegin(_etype221, _size218); + this->success.resize(_size218); + uint32_t _i222; + for (_i222 = 0; _i222 < _size218; ++_i222) { - xfer += this->success[_i211].read(iprot); + xfer += this->success[_i222].read(iprot); } xfer += iprot->readListEnd(); } @@ -10952,10 +11185,10 @@ uint32_t Airavata_getApplicationOutputs_result::write(::apache::thrift::protocol xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter212; - for (_iter212 = this->success.begin(); _iter212 != this->success.end(); ++_iter212) + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter223; + for (_iter223 = this->success.begin(); _iter223 != this->success.end(); ++_iter223) { - xfer += (*_iter212).write(oprot); + xfer += (*_iter223).write(oprot); } xfer += oprot->writeListEnd(); } @@ -11002,14 +11235,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size213; - ::apache::thrift::protocol::TType _etype216; - xfer += iprot->readListBegin(_etype216, _size213); - (*(this->success)).resize(_size213); - uint32_t _i217; - for (_i217 = 0; _i217 < _size213; ++_i217) + uint32_t _size224; + ::apache::thrift::protocol::TType _etype227; + xfer += iprot->readListBegin(_etype227, _size224); + (*(this->success)).resize(_size224); + uint32_t _i228; + for (_i228 = 0; _i228 < _size224; ++_i228) { - xfer += (*(this->success))[_i217].read(iprot); + xfer += (*(this->success))[_i228].read(iprot); } xfer += iprot->readListEnd(); } @@ -11147,17 +11380,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size218; - ::apache::thrift::protocol::TType _ktype219; - ::apache::thrift::protocol::TType _vtype220; - xfer += iprot->readMapBegin(_ktype219, _vtype220, _size218); - uint32_t _i222; - for (_i222 = 0; _i222 < _size218; ++_i222) + uint32_t _size229; + ::apache::thrift::protocol::TType _ktype230; + ::apache::thrift::protocol::TType _vtype231; + xfer += iprot->readMapBegin(_ktype230, _vtype231, _size229); + uint32_t _i233; + for (_i233 = 0; _i233 < _size229; ++_i233) { - std::string _key223; - xfer += iprot->readString(_key223); - std::string& _val224 = this->success[_key223]; - xfer += iprot->readString(_val224); + std::string _key234; + xfer += iprot->readString(_key234); + std::string& _val235 = this->success[_key234]; + xfer += iprot->readString(_val235); } xfer += iprot->readMapEnd(); } @@ -11212,11 +11445,11 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::write(::apach xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::map<std::string, std::string> ::const_iterator _iter225; - for (_iter225 = this->success.begin(); _iter225 != this->success.end(); ++_iter225) + std::map<std::string, std::string> ::const_iterator _iter236; + for (_iter236 = this->success.begin(); _iter236 != this->success.end(); ++_iter236) { - xfer += oprot->writeString(_iter225->first); - xfer += oprot->writeString(_iter225->second); + xfer += oprot->writeString(_iter236->first); + xfer += oprot->writeString(_iter236->second); } xfer += oprot->writeMapEnd(); } @@ -11263,17 +11496,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size226; - ::apache::thrift::protocol::TType _ktype227; - ::apache::thrift::protocol::TType _vtype228; - xfer += iprot->readMapBegin(_ktype227, _vtype228, _size226); - uint32_t _i230; - for (_i230 = 0; _i230 < _size226; ++_i230) + uint32_t _size237; + ::apache::thrift::protocol::TType _ktype238; + ::apache::thrift::protocol::TType _vtype239; + xfer += iprot->readMapBegin(_ktype238, _vtype239, _size237); + uint32_t _i241; + for (_i241 = 0; _i241 < _size237; ++_i241) { - std::string _key231; - xfer += iprot->readString(_key231); - std::string& _val232 = (*(this->success))[_key231]; - xfer += iprot->readString(_val232); + std::string _key242; + xfer += iprot->readString(_key242); + std::string& _val243 = (*(this->success))[_key242]; + xfer += iprot->readString(_val243); } xfer += iprot->readMapEnd(); } @@ -11837,17 +12070,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size233; - ::apache::thrift::protocol::TType _ktype234; - ::apache::thrift::protocol::TType _vtype235; - xfer += iprot->readMapBegin(_ktype234, _vtype235, _size233); - uint32_t _i237; - for (_i237 = 0; _i237 < _size233; ++_i237) + uint32_t _size244; + ::apache::thrift::protocol::TType _ktype245; + ::apache::thrift::protocol::TType _vtype246; + xfer += iprot->readMapBegin(_ktype245, _vtype246, _size244); + uint32_t _i248; + for (_i248 = 0; _i248 < _size244; ++_i248) { - std::string _key238; - xfer += iprot->readString(_key238); - std::string& _val239 = this->success[_key238]; - xfer += iprot->readString(_val239); + std::string _key249; + xfer += iprot->readString(_key249); + std::string& _val250 = this->success[_key249]; + xfer += iprot->readString(_val250); } xfer += iprot->readMapEnd(); } @@ -11902,11 +12135,11 @@ uint32_t Airavata_getAllComputeResourceNames_result::write(::apache::thrift::pro xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::map<std::string, std::string> ::const_iterator _iter240; - for (_iter240 = this->success.begin(); _iter240 != this->success.end(); ++_iter240) + std::map<std::string, std::string> ::const_iterator _iter251; + for (_iter251 = this->success.begin(); _iter251 != this->success.end(); ++_iter251) { - xfer += oprot->writeString(_iter240->first); - xfer += oprot->writeString(_iter240->second); + xfer += oprot->writeString(_iter251->first); + xfer += oprot->writeString(_iter251->second); } xfer += oprot->writeMapEnd(); } @@ -11953,17 +12186,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size241; - ::apache::thrift::protocol::TType _ktype242; - ::apache::thrift::protocol::TType _vtype243; - xfer += iprot->readMapBegin(_ktype242, _vtype243, _size241); - uint32_t _i245; - for (_i245 = 0; _i245 < _size241; ++_i245) + uint32_t _size252; + ::apache::thrift::protocol::TType _ktype253; + ::apache::thrift::protocol::TType _vtype254; + xfer += iprot->readMapBegin(_ktype253, _vtype254, _size252); + uint32_t _i256; + for (_i256 = 0; _i256 < _size252; ++_i256) { - std::string _key246; - xfer += iprot->readString(_key246); - std::string& _val247 = (*(this->success))[_key246]; - xfer += iprot->readString(_val247); + std::string _key257; + xfer += iprot->readString(_key257); + std::string& _val258 = (*(this->success))[_key257]; + xfer += iprot->readString(_val258); } xfer += iprot->readMapEnd(); } @@ -17870,17 +18103,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_MAP) { { this->jobSubmissionPriorityMap.clear(); - uint32_t _size248; - ::apache::thrift::protocol::TType _ktype249; - ::apache::thrift::protocol::TType _vtype250; - xfer += iprot->readMapBegin(_ktype249, _vtype250, _size248); - uint32_t _i252; - for (_i252 = 0; _i252 < _size248; ++_i252) + uint32_t _size259; + ::apache::thrift::protocol::TType _ktype260; + ::apache::thrift::protocol::TType _vtype261; + xfer += iprot->readMapBegin(_ktype260, _vtype261, _size259); + uint32_t _i263; + for (_i263 = 0; _i263 < _size259; ++_i263) { - std::string _key253; - xfer += iprot->readString(_key253); - int32_t& _val254 = this->jobSubmissionPriorityMap[_key253]; - xfer += iprot->readI32(_val254); + std::string _key264; + xfer += iprot->readString(_key264); + int32_t& _val265 = this->jobSubmissionPriorityMap[_key264]; + xfer += iprot->readI32(_val265); } xfer += iprot->readMapEnd(); } @@ -17910,11 +18143,11 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::write(::apache::thrift::pr xfer += oprot->writeFieldBegin("jobSubmissionPriorityMap", ::apache::thrift::protocol::T_MAP, 1); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->jobSubmissionPriorityMap.size())); - std::map<std::string, int32_t> ::const_iterator _iter255; - for (_iter255 = this->jobSubmissionPriorityMap.begin(); _iter255 != this->jobSubmissionPriorityMap.end(); ++_iter255) + std::map<std::string, int32_t> ::const_iterator _iter266; + for (_iter266 = this->jobSubmissionPriorityMap.begin(); _iter266 != this->jobSubmissionPriorityMap.end(); ++_iter266) { - xfer += oprot->writeString(_iter255->first); - xfer += oprot->writeI32(_iter255->second); + xfer += oprot->writeString(_iter266->first); + xfer += oprot->writeI32(_iter266->second); } xfer += oprot->writeMapEnd(); } @@ -17932,11 +18165,11 @@ uint32_t Airavata_changeJobSubmissionPriorities_pargs::write(::apache::thrift::p xfer += oprot->writeFieldBegin("jobSubmissionPriorityMap", ::apache::thrift::protocol::T_MAP, 1); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>((*(this->jobSubmissionPriorityMap)).size())); - std::map<std::string, int32_t> ::const_iterator _iter256; - for (_iter256 = (*(this->jobSubmissionPriorityMap)).begin(); _iter256 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter256) + std::map<std::string, int32_t> ::const_iterator _iter267; + for (_iter267 = (*(this->jobSubmissionPriorityMap)).begin(); _iter267 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter267) { - xfer += oprot->writeString(_iter256->first); - xfer += oprot->writeI32(_iter256->second); + xfer += oprot->writeString(_iter267->first); + xfer += oprot->writeI32(_iter267->second); } xfer += oprot->writeMapEnd(); } @@ -18128,17 +18361,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->dataMovementPriorityMap.clear(); - uint32_t _size257; - ::apache::thrift::protocol::TType _ktype258; - ::apache::thrift::protocol::TType _vtype259; - xfer += iprot->readMapBegin(_ktype258, _vtype259, _size257); - uint32_t _i261; - for (_i261 = 0; _i261 < _size257; ++_i261) + uint32_t _size268; + ::apache::thrift::protocol::TType _ktype269; + ::apache::thrift::protocol::TType _vtype270; + xfer += iprot->readMapBegin(_ktype269, _vtype270, _size268); + uint32_t _i272; + for (_i272 = 0; _i272 < _size268; ++_i272) { - std::string _key262; - xfer += iprot->readString(_key262); - int32_t& _val263 = this->dataMovementPriorityMap[_key262]; - xfer += iprot->readI32(_val263); + std::string _key273; + xfer += iprot->readString(_key273); + int32_t& _val274 = this->dataMovementPriorityMap[_key273]; + xfer += iprot->readI32(_val274); } xfer += iprot->readMapEnd(); } @@ -18168,11 +18401,11 @@ uint32_t Airavata_changeDataMovementPriorities_args::write(::apache::thrift::pro xfer += oprot->writeFieldBegin("dataMovementPriorityMap", ::apache::thrift::protocol::T_MAP, 1); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->dataMovementPriorityMap.size())); - std::map<std::string, int32_t> ::const_iterator _iter264; - for (_iter264 = this->dataMovementPriorityMap.begin(); _iter264 != this->dataMovementPriorityMap.end(); ++_iter264) + std::map<std::string, int32_t> ::const_iterator _iter275; + for (_iter275 = this->dataMovementPriorityMap.begin(); _iter275 != this->dataMovementPriorityMap.end(); ++_iter275) { - xfer += oprot->writeString(_iter264->first); - xfer += oprot->writeI32(_iter264->second); + xfer += oprot->writeString(_iter275->first); + xfer += oprot->writeI32(_iter275->second); } xfer += oprot->writeMapEnd(); } @@ -18190,11 +18423,11 @@ uint32_t Airavata_changeDataMovementPriorities_pargs::write(::apache::thrift::pr xfer += oprot->writeFieldBegin("dataMovementPriorityMap", ::apache::thrift::protocol::T_MAP, 1); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>((*(this->dataMovementPriorityMap)).size())); - std::map<std::string, int32_t> ::const_iterator _iter265; - for (_iter265 = (*(this->dataMovementPriorityMap)).begin(); _iter265 != (*(this->dataMovementPriorityMap)).end(); ++_iter265) + std::map<std::string, int32_t> ::const_iterator _iter276; + for (_iter276 = (*(this->dataMovementPriorityMap)).begin(); _iter276 != (*(this->dataMovementPriorityMap)).end(); ++_iter276) { - xfer += oprot->writeString(_iter265->first); - xfer += oprot->writeI32(_iter265->second); + xfer += oprot->writeString(_iter276->first); + xfer += oprot->writeI32(_iter276->second); } xfer += oprot->writeMapEnd(); } @@ -21531,14 +21764,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size266; - ::apache::thrift::protocol::TType _etype269; - xfer += iprot->readListBegin(_etype269, _size266); - this->success.resize(_size266); - uint32_t _i270; - for (_i270 = 0; _i270 < _size266; ++_i270) + uint32_t _size277; + ::apache::thrift::protocol::TType _etype280; + xfer += iprot->readListBegin(_etype280, _size277); + this->success.resize(_size277); + uint32_t _i281; + for (_i281 = 0; _i281 < _size277; ++_i281) { - xfer += this->success[_i270].read(iprot); + xfer += this->success[_i281].read(iprot); } xfer += iprot->readListEnd(); } @@ -21593,10 +21826,10 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::write(::apache xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter271; - for (_iter271 = this->success.begin(); _iter271 != this->success.end(); ++_iter271) + std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter282; + for (_iter282 = this->success.begin(); _iter282 != this->success.end(); ++_iter282) { - xfer += (*_iter271).write(oprot); + xfer += (*_iter282).write(oprot); } xfer += oprot->writeListEnd(); } @@ -21643,14 +21876,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size272; - ::apache::thrift::protocol::TType _etype275; - xfer += iprot->readListBegin(_etype275, _size272); - (*(this->success)).resize(_size272); - uint32_t _i276; - for (_i276 = 0; _i276 < _size272; ++_i276) + uint32_t _size283; + ::apache::thrift::protocol::TType _etype286; + xfer += iprot->readListBegin(_etype286, _size283); + (*(this->success)).resize(_size283); + uint32_t _i287; + for (_i287 = 0; _i287 < _size283; ++_i287) { - xfer += (*(this->success))[_i276].read(iprot); + xfer += (*(this->success))[_i287].read(iprot); } xfer += iprot->readListEnd(); } @@ -22202,153 +22435,2258 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache: return xfer; } -void AiravataClient::getAPIVersion(std::string& _return) -{ - send_getAPIVersion(); - recv_getAPIVersion(_return); -} - -void AiravataClient::send_getAPIVersion() -{ - int32_t cseqid = 0; - oprot_->writeMessageBegin("getAPIVersion", ::apache::thrift::protocol::T_CALL, cseqid); +uint32_t Airavata_getAllWorkflows_args::read(::apache::thrift::protocol::TProtocol* iprot) { - Airavata_getAPIVersion_pargs args; - args.write(oprot_); + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); -} + xfer += iprot->readStructBegin(fname); -void AiravataClient::recv_getAPIVersion(std::string& _return) -{ + using ::apache::thrift::protocol::TProtocolException; - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - iprot_->readMessageBegin(fname, mtype, rseqid); - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("getAPIVersion") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + xfer += iprot->skip(ftype); + xfer += iprot->readFieldEnd(); } - Airavata_getAPIVersion_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - if (result.__isset.success) { - // _return pointer has now been filled - return; - } - if (result.__isset.ire) { - throw result.ire; - } - if (result.__isset.ace) { - throw result.ace; - } - if (result.__isset.ase) { - throw result.ase; - } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAPIVersion failed: unknown result"); -} + xfer += iprot->readStructEnd(); -void AiravataClient::createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project) -{ - send_createProject(project); - recv_createProject(_return); + return xfer; } -void AiravataClient::send_createProject(const ::apache::airavata::model::workspace::Project& project) -{ - int32_t cseqid = 0; - oprot_->writeMessageBegin("createProject", ::apache::thrift::protocol::T_CALL, cseqid); +uint32_t Airavata_getAllWorkflows_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_args"); - Airavata_createProject_pargs args; - args.project = &project; - args.write(oprot_); + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); +uint32_t Airavata_getAllWorkflows_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_pargs"); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; } -void AiravataClient::recv_createProject(std::string& _return) -{ +uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProtocol* iprot) { - int32_t rseqid = 0; + uint32_t xfer = 0; std::string fname; - ::apache::thrift::protocol::TMessageType mtype; + ::apache::thrift::protocol::TType ftype; + int16_t fid; - iprot_->readMessageBegin(fname, mtype, rseqid); - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("createProject") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - Airavata_createProject_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); + xfer += iprot->readStructBegin(fname); - if (result.__isset.success) { - // _return pointer has now been filled - return; - } - if (result.__isset.ire) { - throw result.ire; - } - if (result.__isset.ace) { - throw result.ace; - } - if (result.__isset.ase) { - throw result.ase; + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->success.clear(); + uint32_t _size288; + ::apache::thrift::protocol::TType _etype291; + xfer += iprot->readListBegin(_etype291, _size288); + this->success.resize(_size288); + uint32_t _i292; + for (_i292 = 0; _i292 < _size288; ++_i292) + { + xfer += iprot->readString(this->success[_i292]); + } + xfer += iprot->readListEnd(); + } + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "createProject failed: unknown result"); -} -void AiravataClient::updateProject(const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) -{ - send_updateProject(projectId, updatedProject); - recv_updateProject(); + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getAllWorkflows_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); + std::vector<std::string> ::const_iterator _iter293; + for (_iter293 = this->success.begin(); _iter293 != this->success.end(); ++_iter293) + { + xfer += oprot->writeString((*_iter293)); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + (*(this->success)).clear(); + uint32_t _size294; + ::apache::thrift::protocol::TType _etype297; + xfer += iprot->readListBegin(_etype297, _size294); + (*(this->success)).resize(_size294); + uint32_t _i298; + for (_i298 = 0; _i298 < _size294; ++_i298) + { + xfer += iprot->readString((*(this->success))[_i298]); + } + xfer += iprot->readListEnd(); + } + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getWorkflow_args::read(::apache::thrift::protocol::TProtocol* 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_workflowTemplateId = 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->workflowTemplateId); + isset_workflowTemplateId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_workflowTemplateId) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_getWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getWorkflow_args"); + + xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->workflowTemplateId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getWorkflow_pargs"); + + xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->workflowTemplateId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getWorkflow_result::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getWorkflow_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); + xfer += this->success.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getWorkflow_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_deleteWorkflow_args::read(::apache::thrift::protocol::TProtocol* 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_workflowTemplateId = 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->workflowTemplateId); + isset_workflowTemplateId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_workflowTemplateId) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_deleteWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_deleteWorkflow_args"); + + xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->workflowTemplateId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_deleteWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_deleteWorkflow_pargs"); + + xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->workflowTemplateId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_deleteWorkflow_result::read(::apache::thrift::protocol::TProtocol* 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; + + + 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_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_deleteWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_deleteWorkflow_result"); + + if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_deleteWorkflow_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + 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_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_registerWorkflow_args::read(::apache::thrift::protocol::TProtocol* 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_workflow = 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_STRUCT) { + xfer += this->workflow.read(iprot); + isset_workflow = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_workflow) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_registerWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_registerWorkflow_args"); + + xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->workflow.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_registerWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_registerWorkflow_pargs"); + + xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += (*(this->workflow)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_registerWorkflow_result::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->success); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_registerWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_registerWorkflow_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); + xfer += oprot->writeString(this->success); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_registerWorkflow_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString((*(this->success))); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_updateWorkflow_args::read(::apache::thrift::protocol::TProtocol* 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_workflowTemplateId = false; + bool isset_workflow = 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->workflowTemplateId); + isset_workflowTemplateId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->workflow.read(iprot); + isset_workflow = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_workflowTemplateId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_workflow) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_updateWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_updateWorkflow_args"); + + xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->workflowTemplateId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->workflow.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_updateWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_updateWorkflow_pargs"); + + xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->workflowTemplateId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->workflow)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_updateWorkflow_result::read(::apache::thrift::protocol::TProtocol* 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; + + + 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_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_updateWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_updateWorkflow_result"); + + if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_updateWorkflow_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + 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_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getWorkflowTemplateId_args::read(::apache::thrift::protocol::TProtocol* 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_workflowName = 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->workflowName); + isset_workflowName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_workflowName) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_getWorkflowTemplateId_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getWorkflowTemplateId_args"); + + xfer += oprot->writeFieldBegin("workflowName", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->workflowName); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getWorkflowTemplateId_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getWorkflowTemplateId_pargs"); + + xfer += oprot->writeFieldBegin("workflowName", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->workflowName))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getWorkflowTemplateId_result::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->success); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getWorkflowTemplateId_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getWorkflowTemplateId_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); + xfer += oprot->writeString(this->success); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getWorkflowTemplateId_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString((*(this->success))); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_isWorkflowExistWithName_args::read(::apache::thrift::protocol::TProtocol* 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_workflowName = 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->workflowName); + isset_workflowName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_workflowName) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_isWorkflowExistWithName_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_isWorkflowExistWithName_args"); + + xfer += oprot->writeFieldBegin("workflowName", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->workflowName); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_isWorkflowExistWithName_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_isWorkflowExistWithName_pargs"); + + xfer += oprot->writeFieldBegin("workflowName", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->workflowName))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_isWorkflowExistWithName_result::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_isWorkflowExistWithName_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_isWorkflowExistWithName_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); + xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_isWorkflowExistWithName_presult::read(::apache::thrift::protocol::TProtocol* 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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +void AiravataClient::getAPIVersion(std::string& _return) +{ + send_getAPIVersion(); + recv_getAPIVersion(_return); +} + +void AiravataClient::send_getAPIVersion() +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getAPIVersion", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_getAPIVersion_pargs args; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_getAPIVersion(std::string& _return) +{ + + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; + + iprot_->readMessageBegin(fname, mtype, rseqid); + if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { + ::apache::thrift::TApplicationException x; + x.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("getAPIVersion") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getAPIVersion_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + ipr
<TRUNCATED>
