http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/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 446900c..15015ba 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 @@ -7092,6 +7092,283 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol: return xfer; } +uint32_t Airavata_getIntermediateOutputs_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_airavataExperimentId = 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->airavataExperimentId); + isset_airavataExperimentId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_airavataExperimentId) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_getIntermediateOutputs_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getIntermediateOutputs_args"); + + xfer += oprot->writeFieldBegin("airavataExperimentId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->airavataExperimentId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getIntermediateOutputs_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getIntermediateOutputs_pargs"); + + xfer += oprot->writeFieldBegin("airavataExperimentId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->airavataExperimentId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getIntermediateOutputs_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 _size133; + ::apache::thrift::protocol::TType _etype136; + xfer += iprot->readListBegin(_etype136, _size133); + this->success.resize(_size133); + uint32_t _i137; + for (_i137 = 0; _i137 < _size133; ++_i137) + { + xfer += this->success[_i137].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->enf.read(iprot); + this->__isset.enf = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + 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_getIntermediateOutputs_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getIntermediateOutputs_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::appinterface::OutputDataObjectType> ::const_iterator _iter138; + for (_iter138 = this->success.begin(); _iter138 != this->success.end(); ++_iter138) + { + xfer += (*_iter138).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.enf) { + xfer += oprot->writeFieldBegin("enf", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->enf.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getIntermediateOutputs_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 _size139; + ::apache::thrift::protocol::TType _etype142; + xfer += iprot->readListBegin(_etype142, _size139); + (*(this->success)).resize(_size139); + uint32_t _i143; + for (_i143 = 0; _i143 < _size139; ++_i143) + { + xfer += (*(this->success))[_i143].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->enf.read(iprot); + this->__isset.enf = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + 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_getJobStatuses_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -7185,17 +7462,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size133; - ::apache::thrift::protocol::TType _ktype134; - ::apache::thrift::protocol::TType _vtype135; - xfer += iprot->readMapBegin(_ktype134, _vtype135, _size133); - uint32_t _i137; - for (_i137 = 0; _i137 < _size133; ++_i137) + uint32_t _size144; + ::apache::thrift::protocol::TType _ktype145; + ::apache::thrift::protocol::TType _vtype146; + xfer += iprot->readMapBegin(_ktype145, _vtype146, _size144); + uint32_t _i148; + for (_i148 = 0; _i148 < _size144; ++_i148) { - std::string _key138; - xfer += iprot->readString(_key138); - ::apache::airavata::model::workspace::experiment::JobStatus& _val139 = this->success[_key138]; - xfer += _val139.read(iprot); + std::string _key149; + xfer += iprot->readString(_key149); + ::apache::airavata::model::workspace::experiment::JobStatus& _val150 = this->success[_key149]; + xfer += _val150.read(iprot); } xfer += iprot->readMapEnd(); } @@ -7258,11 +7535,11 @@ uint32_t Airavata_getJobStatuses_result::write(::apache::thrift::protocol::TProt xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter140; - for (_iter140 = this->success.begin(); _iter140 != this->success.end(); ++_iter140) + std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter151; + for (_iter151 = this->success.begin(); _iter151 != this->success.end(); ++_iter151) { - xfer += oprot->writeString(_iter140->first); - xfer += _iter140->second.write(oprot); + xfer += oprot->writeString(_iter151->first); + xfer += _iter151->second.write(oprot); } xfer += oprot->writeMapEnd(); } @@ -7313,17 +7590,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size141; - ::apache::thrift::protocol::TType _ktype142; - ::apache::thrift::protocol::TType _vtype143; - xfer += iprot->readMapBegin(_ktype142, _vtype143, _size141); - uint32_t _i145; - for (_i145 = 0; _i145 < _size141; ++_i145) + uint32_t _size152; + ::apache::thrift::protocol::TType _ktype153; + ::apache::thrift::protocol::TType _vtype154; + xfer += iprot->readMapBegin(_ktype153, _vtype154, _size152); + uint32_t _i156; + for (_i156 = 0; _i156 < _size152; ++_i156) { - std::string _key146; - xfer += iprot->readString(_key146); - ::apache::airavata::model::workspace::experiment::JobStatus& _val147 = (*(this->success))[_key146]; - xfer += _val147.read(iprot); + std::string _key157; + xfer += iprot->readString(_key157); + ::apache::airavata::model::workspace::experiment::JobStatus& _val158 = (*(this->success))[_key157]; + xfer += _val158.read(iprot); } xfer += iprot->readMapEnd(); } @@ -7469,14 +7746,14 @@ uint32_t Airavata_getJobDetails_result::read(::apache::thrift::protocol::TProtoc if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size148; - ::apache::thrift::protocol::TType _etype151; - xfer += iprot->readListBegin(_etype151, _size148); - this->success.resize(_size148); - uint32_t _i152; - for (_i152 = 0; _i152 < _size148; ++_i152) + 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[_i152].read(iprot); + xfer += this->success[_i163].read(iprot); } xfer += iprot->readListEnd(); } @@ -7539,10 +7816,10 @@ uint32_t Airavata_getJobDetails_result::write(::apache::thrift::protocol::TProto 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::workspace::experiment::JobDetails> ::const_iterator _iter153; - for (_iter153 = this->success.begin(); _iter153 != this->success.end(); ++_iter153) + std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> ::const_iterator _iter164; + for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164) { - xfer += (*_iter153).write(oprot); + xfer += (*_iter164).write(oprot); } xfer += oprot->writeListEnd(); } @@ -7593,14 +7870,14 @@ uint32_t Airavata_getJobDetails_presult::read(::apache::thrift::protocol::TProto if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size154; - ::apache::thrift::protocol::TType _etype157; - xfer += iprot->readListBegin(_etype157, _size154); - (*(this->success)).resize(_size154); - uint32_t _i158; - for (_i158 = 0; _i158 < _size154; ++_i158) + 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))[_i158].read(iprot); + xfer += (*(this->success))[_i169].read(iprot); } xfer += iprot->readListEnd(); } @@ -7746,14 +8023,14 @@ uint32_t Airavata_getDataTransferDetails_result::read(::apache::thrift::protocol 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 += this->success[_i163].read(iprot); + xfer += this->success[_i174].read(iprot); } xfer += iprot->readListEnd(); } @@ -7816,10 +8093,10 @@ uint32_t Airavata_getDataTransferDetails_result::write(::apache::thrift::protoco 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::workspace::experiment::DataTransferDetails> ::const_iterator _iter164; - for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164) + std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> ::const_iterator _iter175; + for (_iter175 = this->success.begin(); _iter175 != this->success.end(); ++_iter175) { - xfer += (*_iter164).write(oprot); + xfer += (*_iter175).write(oprot); } xfer += oprot->writeListEnd(); } @@ -7870,14 +8147,14 @@ uint32_t Airavata_getDataTransferDetails_presult::read(::apache::thrift::protoco 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 += (*(this->success))[_i169].read(iprot); + xfer += (*(this->success))[_i180].read(iprot); } xfer += iprot->readListEnd(); } @@ -9173,14 +9450,14 @@ uint32_t Airavata_getAllAppModules_result::read(::apache::thrift::protocol::TPro if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - 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) + uint32_t _size181; + ::apache::thrift::protocol::TType _etype184; + xfer += iprot->readListBegin(_etype184, _size181); + this->success.resize(_size181); + uint32_t _i185; + for (_i185 = 0; _i185 < _size181; ++_i185) { - xfer += this->success[_i174].read(iprot); + xfer += this->success[_i185].read(iprot); } xfer += iprot->readListEnd(); } @@ -9235,10 +9512,10 @@ uint32_t Airavata_getAllAppModules_result::write(::apache::thrift::protocol::TPr 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 _iter175; - for (_iter175 = this->success.begin(); _iter175 != this->success.end(); ++_iter175) + std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter186; + for (_iter186 = this->success.begin(); _iter186 != this->success.end(); ++_iter186) { - xfer += (*_iter175).write(oprot); + xfer += (*_iter186).write(oprot); } xfer += oprot->writeListEnd(); } @@ -9285,14 +9562,14 @@ uint32_t Airavata_getAllAppModules_presult::read(::apache::thrift::protocol::TPr if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - 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) + uint32_t _size187; + ::apache::thrift::protocol::TType _etype190; + xfer += iprot->readListBegin(_etype190, _size187); + (*(this->success)).resize(_size187); + uint32_t _i191; + for (_i191 = 0; _i191 < _size187; ++_i191) { - xfer += (*(this->success))[_i180].read(iprot); + xfer += (*(this->success))[_i191].read(iprot); } xfer += iprot->readListEnd(); } @@ -10550,14 +10827,14 @@ uint32_t Airavata_getAllApplicationDeployments_result::read(::apache::thrift::pr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size181; - ::apache::thrift::protocol::TType _etype184; - xfer += iprot->readListBegin(_etype184, _size181); - this->success.resize(_size181); - uint32_t _i185; - for (_i185 = 0; _i185 < _size181; ++_i185) + uint32_t _size192; + ::apache::thrift::protocol::TType _etype195; + xfer += iprot->readListBegin(_etype195, _size192); + this->success.resize(_size192); + uint32_t _i196; + for (_i196 = 0; _i196 < _size192; ++_i196) { - xfer += this->success[_i185].read(iprot); + xfer += this->success[_i196].read(iprot); } xfer += iprot->readListEnd(); } @@ -10612,10 +10889,10 @@ uint32_t Airavata_getAllApplicationDeployments_result::write(::apache::thrift::p 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::ApplicationDeploymentDescription> ::const_iterator _iter186; - for (_iter186 = this->success.begin(); _iter186 != this->success.end(); ++_iter186) + std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationDeploymentDescription> ::const_iterator _iter197; + for (_iter197 = this->success.begin(); _iter197 != this->success.end(); ++_iter197) { - xfer += (*_iter186).write(oprot); + xfer += (*_iter197).write(oprot); } xfer += oprot->writeListEnd(); } @@ -10662,14 +10939,14 @@ uint32_t Airavata_getAllApplicationDeployments_presult::read(::apache::thrift::p if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size187; - ::apache::thrift::protocol::TType _etype190; - xfer += iprot->readListBegin(_etype190, _size187); - (*(this->success)).resize(_size187); - uint32_t _i191; - for (_i191 = 0; _i191 < _size187; ++_i191) + uint32_t _size198; + ::apache::thrift::protocol::TType _etype201; + xfer += iprot->readListBegin(_etype201, _size198); + (*(this->success)).resize(_size198); + uint32_t _i202; + for (_i202 = 0; _i202 < _size198; ++_i202) { - xfer += (*(this->success))[_i191].read(iprot); + xfer += (*(this->success))[_i202].read(iprot); } xfer += iprot->readListEnd(); } @@ -10805,16 +11082,16 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->success.clear(); - uint32_t _size192; - ::apache::thrift::protocol::TType _etype195; - xfer += iprot->readListBegin(_etype195, _size192); - this->success.resize(_size192); - uint32_t _i196; - for (_i196 = 0; _i196 < _size192; ++_i196) + { + this->success.clear(); + uint32_t _size203; + ::apache::thrift::protocol::TType _etype206; + xfer += iprot->readListBegin(_etype206, _size203); + this->success.resize(_size203); + uint32_t _i207; + for (_i207 = 0; _i207 < _size203; ++_i207) { - xfer += iprot->readString(this->success[_i196]); + xfer += iprot->readString(this->success[_i207]); } xfer += iprot->readListEnd(); } @@ -10869,10 +11146,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 _iter197; - for (_iter197 = this->success.begin(); _iter197 != this->success.end(); ++_iter197) + std::vector<std::string> ::const_iterator _iter208; + for (_iter208 = this->success.begin(); _iter208 != this->success.end(); ++_iter208) { - xfer += oprot->writeString((*_iter197)); + xfer += oprot->writeString((*_iter208)); } xfer += oprot->writeListEnd(); } @@ -10919,14 +11196,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift:: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size198; - ::apache::thrift::protocol::TType _etype201; - xfer += iprot->readListBegin(_etype201, _size198); - (*(this->success)).resize(_size198); - uint32_t _i202; - for (_i202 = 0; _i202 < _size198; ++_i202) + uint32_t _size209; + ::apache::thrift::protocol::TType _etype212; + xfer += iprot->readListBegin(_etype212, _size209); + (*(this->success)).resize(_size209); + uint32_t _i213; + for (_i213 = 0; _i213 < _size209; ++_i213) { - xfer += iprot->readString((*(this->success))[_i202]); + xfer += iprot->readString((*(this->success))[_i213]); } xfer += iprot->readListEnd(); } @@ -11959,17 +12236,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift: if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size203; - ::apache::thrift::protocol::TType _ktype204; - ::apache::thrift::protocol::TType _vtype205; - xfer += iprot->readMapBegin(_ktype204, _vtype205, _size203); - uint32_t _i207; - for (_i207 = 0; _i207 < _size203; ++_i207) + uint32_t _size214; + ::apache::thrift::protocol::TType _ktype215; + ::apache::thrift::protocol::TType _vtype216; + xfer += iprot->readMapBegin(_ktype215, _vtype216, _size214); + uint32_t _i218; + for (_i218 = 0; _i218 < _size214; ++_i218) { - std::string _key208; - xfer += iprot->readString(_key208); - std::string& _val209 = this->success[_key208]; - xfer += iprot->readString(_val209); + std::string _key219; + xfer += iprot->readString(_key219); + std::string& _val220 = this->success[_key219]; + xfer += iprot->readString(_val220); } xfer += iprot->readMapEnd(); } @@ -12024,11 +12301,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 _iter210; - for (_iter210 = this->success.begin(); _iter210 != this->success.end(); ++_iter210) + std::map<std::string, std::string> ::const_iterator _iter221; + for (_iter221 = this->success.begin(); _iter221 != this->success.end(); ++_iter221) { - xfer += oprot->writeString(_iter210->first); - xfer += oprot->writeString(_iter210->second); + xfer += oprot->writeString(_iter221->first); + xfer += oprot->writeString(_iter221->second); } xfer += oprot->writeMapEnd(); } @@ -12075,17 +12352,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size211; - ::apache::thrift::protocol::TType _ktype212; - ::apache::thrift::protocol::TType _vtype213; - xfer += iprot->readMapBegin(_ktype212, _vtype213, _size211); - uint32_t _i215; - for (_i215 = 0; _i215 < _size211; ++_i215) + uint32_t _size222; + ::apache::thrift::protocol::TType _ktype223; + ::apache::thrift::protocol::TType _vtype224; + xfer += iprot->readMapBegin(_ktype223, _vtype224, _size222); + uint32_t _i226; + for (_i226 = 0; _i226 < _size222; ++_i226) { - std::string _key216; - xfer += iprot->readString(_key216); - std::string& _val217 = (*(this->success))[_key216]; - xfer += iprot->readString(_val217); + std::string _key227; + xfer += iprot->readString(_key227); + std::string& _val228 = (*(this->success))[_key227]; + xfer += iprot->readString(_val228); } xfer += iprot->readMapEnd(); } @@ -12199,14 +12476,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - 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) + uint32_t _size229; + ::apache::thrift::protocol::TType _etype232; + xfer += iprot->readListBegin(_etype232, _size229); + this->success.resize(_size229); + uint32_t _i233; + for (_i233 = 0; _i233 < _size229; ++_i233) { - xfer += this->success[_i222].read(iprot); + xfer += this->success[_i233].read(iprot); } xfer += iprot->readListEnd(); } @@ -12261,10 +12538,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 _iter223; - for (_iter223 = this->success.begin(); _iter223 != this->success.end(); ++_iter223) + std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter234; + for (_iter234 = this->success.begin(); _iter234 != this->success.end(); ++_iter234) { - xfer += (*_iter223).write(oprot); + xfer += (*_iter234).write(oprot); } xfer += oprot->writeListEnd(); } @@ -12311,14 +12588,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - 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) + uint32_t _size235; + ::apache::thrift::protocol::TType _etype238; + xfer += iprot->readListBegin(_etype238, _size235); + (*(this->success)).resize(_size235); + uint32_t _i239; + for (_i239 = 0; _i239 < _size235; ++_i239) { - xfer += (*(this->success))[_i228].read(iprot); + xfer += (*(this->success))[_i239].read(iprot); } xfer += iprot->readListEnd(); } @@ -12456,14 +12733,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol:: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size229; - ::apache::thrift::protocol::TType _etype232; - xfer += iprot->readListBegin(_etype232, _size229); - this->success.resize(_size229); - uint32_t _i233; - for (_i233 = 0; _i233 < _size229; ++_i233) + uint32_t _size240; + ::apache::thrift::protocol::TType _etype243; + xfer += iprot->readListBegin(_etype243, _size240); + this->success.resize(_size240); + uint32_t _i244; + for (_i244 = 0; _i244 < _size240; ++_i244) { - xfer += this->success[_i233].read(iprot); + xfer += this->success[_i244].read(iprot); } xfer += iprot->readListEnd(); } @@ -12518,10 +12795,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 _iter234; - for (_iter234 = this->success.begin(); _iter234 != this->success.end(); ++_iter234) + std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter245; + for (_iter245 = this->success.begin(); _iter245 != this->success.end(); ++_iter245) { - xfer += (*_iter234).write(oprot); + xfer += (*_iter245).write(oprot); } xfer += oprot->writeListEnd(); } @@ -12568,14 +12845,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size235; - ::apache::thrift::protocol::TType _etype238; - xfer += iprot->readListBegin(_etype238, _size235); - (*(this->success)).resize(_size235); - uint32_t _i239; - for (_i239 = 0; _i239 < _size235; ++_i239) + uint32_t _size246; + ::apache::thrift::protocol::TType _etype249; + xfer += iprot->readListBegin(_etype249, _size246); + (*(this->success)).resize(_size246); + uint32_t _i250; + for (_i250 = 0; _i250 < _size246; ++_i250) { - xfer += (*(this->success))[_i239].read(iprot); + xfer += (*(this->success))[_i250].read(iprot); } xfer += iprot->readListEnd(); } @@ -12713,14 +12990,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size240; - ::apache::thrift::protocol::TType _etype243; - xfer += iprot->readListBegin(_etype243, _size240); - this->success.resize(_size240); - uint32_t _i244; - for (_i244 = 0; _i244 < _size240; ++_i244) + uint32_t _size251; + ::apache::thrift::protocol::TType _etype254; + xfer += iprot->readListBegin(_etype254, _size251); + this->success.resize(_size251); + uint32_t _i255; + for (_i255 = 0; _i255 < _size251; ++_i255) { - xfer += this->success[_i244].read(iprot); + xfer += this->success[_i255].read(iprot); } xfer += iprot->readListEnd(); } @@ -12775,10 +13052,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 _iter245; - for (_iter245 = this->success.begin(); _iter245 != this->success.end(); ++_iter245) + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter256; + for (_iter256 = this->success.begin(); _iter256 != this->success.end(); ++_iter256) { - xfer += (*_iter245).write(oprot); + xfer += (*_iter256).write(oprot); } xfer += oprot->writeListEnd(); } @@ -12825,14 +13102,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size246; - ::apache::thrift::protocol::TType _etype249; - xfer += iprot->readListBegin(_etype249, _size246); - (*(this->success)).resize(_size246); - uint32_t _i250; - for (_i250 = 0; _i250 < _size246; ++_i250) + uint32_t _size257; + ::apache::thrift::protocol::TType _etype260; + xfer += iprot->readListBegin(_etype260, _size257); + (*(this->success)).resize(_size257); + uint32_t _i261; + for (_i261 = 0; _i261 < _size257; ++_i261) { - xfer += (*(this->success))[_i250].read(iprot); + xfer += (*(this->success))[_i261].read(iprot); } xfer += iprot->readListEnd(); } @@ -12970,17 +13247,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size251; - ::apache::thrift::protocol::TType _ktype252; - ::apache::thrift::protocol::TType _vtype253; - xfer += iprot->readMapBegin(_ktype252, _vtype253, _size251); - uint32_t _i255; - for (_i255 = 0; _i255 < _size251; ++_i255) + uint32_t _size262; + ::apache::thrift::protocol::TType _ktype263; + ::apache::thrift::protocol::TType _vtype264; + xfer += iprot->readMapBegin(_ktype263, _vtype264, _size262); + uint32_t _i266; + for (_i266 = 0; _i266 < _size262; ++_i266) { - std::string _key256; - xfer += iprot->readString(_key256); - std::string& _val257 = this->success[_key256]; - xfer += iprot->readString(_val257); + std::string _key267; + xfer += iprot->readString(_key267); + std::string& _val268 = this->success[_key267]; + xfer += iprot->readString(_val268); } xfer += iprot->readMapEnd(); } @@ -13035,11 +13312,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 _iter258; - for (_iter258 = this->success.begin(); _iter258 != this->success.end(); ++_iter258) + std::map<std::string, std::string> ::const_iterator _iter269; + for (_iter269 = this->success.begin(); _iter269 != this->success.end(); ++_iter269) { - xfer += oprot->writeString(_iter258->first); - xfer += oprot->writeString(_iter258->second); + xfer += oprot->writeString(_iter269->first); + xfer += oprot->writeString(_iter269->second); } xfer += oprot->writeMapEnd(); } @@ -13086,17 +13363,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - 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) + uint32_t _size270; + ::apache::thrift::protocol::TType _ktype271; + ::apache::thrift::protocol::TType _vtype272; + xfer += iprot->readMapBegin(_ktype271, _vtype272, _size270); + uint32_t _i274; + for (_i274 = 0; _i274 < _size270; ++_i274) { - std::string _key264; - xfer += iprot->readString(_key264); - std::string& _val265 = (*(this->success))[_key264]; - xfer += iprot->readString(_val265); + std::string _key275; + xfer += iprot->readString(_key275); + std::string& _val276 = (*(this->success))[_key275]; + xfer += iprot->readString(_val276); } xfer += iprot->readMapEnd(); } @@ -13660,17 +13937,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size266; - ::apache::thrift::protocol::TType _ktype267; - ::apache::thrift::protocol::TType _vtype268; - xfer += iprot->readMapBegin(_ktype267, _vtype268, _size266); - uint32_t _i270; - for (_i270 = 0; _i270 < _size266; ++_i270) + uint32_t _size277; + ::apache::thrift::protocol::TType _ktype278; + ::apache::thrift::protocol::TType _vtype279; + xfer += iprot->readMapBegin(_ktype278, _vtype279, _size277); + uint32_t _i281; + for (_i281 = 0; _i281 < _size277; ++_i281) { - std::string _key271; - xfer += iprot->readString(_key271); - std::string& _val272 = this->success[_key271]; - xfer += iprot->readString(_val272); + std::string _key282; + xfer += iprot->readString(_key282); + std::string& _val283 = this->success[_key282]; + xfer += iprot->readString(_val283); } xfer += iprot->readMapEnd(); } @@ -13725,11 +14002,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 _iter273; - for (_iter273 = this->success.begin(); _iter273 != this->success.end(); ++_iter273) + std::map<std::string, std::string> ::const_iterator _iter284; + for (_iter284 = this->success.begin(); _iter284 != this->success.end(); ++_iter284) { - xfer += oprot->writeString(_iter273->first); - xfer += oprot->writeString(_iter273->second); + xfer += oprot->writeString(_iter284->first); + xfer += oprot->writeString(_iter284->second); } xfer += oprot->writeMapEnd(); } @@ -13776,17 +14053,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size274; - ::apache::thrift::protocol::TType _ktype275; - ::apache::thrift::protocol::TType _vtype276; - xfer += iprot->readMapBegin(_ktype275, _vtype276, _size274); - uint32_t _i278; - for (_i278 = 0; _i278 < _size274; ++_i278) + uint32_t _size285; + ::apache::thrift::protocol::TType _ktype286; + ::apache::thrift::protocol::TType _vtype287; + xfer += iprot->readMapBegin(_ktype286, _vtype287, _size285); + uint32_t _i289; + for (_i289 = 0; _i289 < _size285; ++_i289) { - std::string _key279; - xfer += iprot->readString(_key279); - std::string& _val280 = (*(this->success))[_key279]; - xfer += iprot->readString(_val280); + std::string _key290; + xfer += iprot->readString(_key290); + std::string& _val291 = (*(this->success))[_key290]; + xfer += iprot->readString(_val291); } xfer += iprot->readMapEnd(); } @@ -20669,17 +20946,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_MAP) { { this->jobSubmissionPriorityMap.clear(); - uint32_t _size281; - ::apache::thrift::protocol::TType _ktype282; - ::apache::thrift::protocol::TType _vtype283; - xfer += iprot->readMapBegin(_ktype282, _vtype283, _size281); - uint32_t _i285; - for (_i285 = 0; _i285 < _size281; ++_i285) + uint32_t _size292; + ::apache::thrift::protocol::TType _ktype293; + ::apache::thrift::protocol::TType _vtype294; + xfer += iprot->readMapBegin(_ktype293, _vtype294, _size292); + uint32_t _i296; + for (_i296 = 0; _i296 < _size292; ++_i296) { - std::string _key286; - xfer += iprot->readString(_key286); - int32_t& _val287 = this->jobSubmissionPriorityMap[_key286]; - xfer += iprot->readI32(_val287); + std::string _key297; + xfer += iprot->readString(_key297); + int32_t& _val298 = this->jobSubmissionPriorityMap[_key297]; + xfer += iprot->readI32(_val298); } xfer += iprot->readMapEnd(); } @@ -20709,11 +20986,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 _iter288; - for (_iter288 = this->jobSubmissionPriorityMap.begin(); _iter288 != this->jobSubmissionPriorityMap.end(); ++_iter288) + std::map<std::string, int32_t> ::const_iterator _iter299; + for (_iter299 = this->jobSubmissionPriorityMap.begin(); _iter299 != this->jobSubmissionPriorityMap.end(); ++_iter299) { - xfer += oprot->writeString(_iter288->first); - xfer += oprot->writeI32(_iter288->second); + xfer += oprot->writeString(_iter299->first); + xfer += oprot->writeI32(_iter299->second); } xfer += oprot->writeMapEnd(); } @@ -20731,11 +21008,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 _iter289; - for (_iter289 = (*(this->jobSubmissionPriorityMap)).begin(); _iter289 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter289) + std::map<std::string, int32_t> ::const_iterator _iter300; + for (_iter300 = (*(this->jobSubmissionPriorityMap)).begin(); _iter300 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter300) { - xfer += oprot->writeString(_iter289->first); - xfer += oprot->writeI32(_iter289->second); + xfer += oprot->writeString(_iter300->first); + xfer += oprot->writeI32(_iter300->second); } xfer += oprot->writeMapEnd(); } @@ -20927,17 +21204,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->dataMovementPriorityMap.clear(); - uint32_t _size290; - ::apache::thrift::protocol::TType _ktype291; - ::apache::thrift::protocol::TType _vtype292; - xfer += iprot->readMapBegin(_ktype291, _vtype292, _size290); - uint32_t _i294; - for (_i294 = 0; _i294 < _size290; ++_i294) + uint32_t _size301; + ::apache::thrift::protocol::TType _ktype302; + ::apache::thrift::protocol::TType _vtype303; + xfer += iprot->readMapBegin(_ktype302, _vtype303, _size301); + uint32_t _i305; + for (_i305 = 0; _i305 < _size301; ++_i305) { - std::string _key295; - xfer += iprot->readString(_key295); - int32_t& _val296 = this->dataMovementPriorityMap[_key295]; - xfer += iprot->readI32(_val296); + std::string _key306; + xfer += iprot->readString(_key306); + int32_t& _val307 = this->dataMovementPriorityMap[_key306]; + xfer += iprot->readI32(_val307); } xfer += iprot->readMapEnd(); } @@ -20967,11 +21244,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 _iter297; - for (_iter297 = this->dataMovementPriorityMap.begin(); _iter297 != this->dataMovementPriorityMap.end(); ++_iter297) + std::map<std::string, int32_t> ::const_iterator _iter308; + for (_iter308 = this->dataMovementPriorityMap.begin(); _iter308 != this->dataMovementPriorityMap.end(); ++_iter308) { - xfer += oprot->writeString(_iter297->first); - xfer += oprot->writeI32(_iter297->second); + xfer += oprot->writeString(_iter308->first); + xfer += oprot->writeI32(_iter308->second); } xfer += oprot->writeMapEnd(); } @@ -20989,11 +21266,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 _iter298; - for (_iter298 = (*(this->dataMovementPriorityMap)).begin(); _iter298 != (*(this->dataMovementPriorityMap)).end(); ++_iter298) + std::map<std::string, int32_t> ::const_iterator _iter309; + for (_iter309 = (*(this->dataMovementPriorityMap)).begin(); _iter309 != (*(this->dataMovementPriorityMap)).end(); ++_iter309) { - xfer += oprot->writeString(_iter298->first); - xfer += oprot->writeI32(_iter298->second); + xfer += oprot->writeString(_iter309->first); + xfer += oprot->writeI32(_iter309->second); } xfer += oprot->writeMapEnd(); } @@ -24330,14 +24607,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size299; - ::apache::thrift::protocol::TType _etype302; - xfer += iprot->readListBegin(_etype302, _size299); - this->success.resize(_size299); - uint32_t _i303; - for (_i303 = 0; _i303 < _size299; ++_i303) + uint32_t _size310; + ::apache::thrift::protocol::TType _etype313; + xfer += iprot->readListBegin(_etype313, _size310); + this->success.resize(_size310); + uint32_t _i314; + for (_i314 = 0; _i314 < _size310; ++_i314) { - xfer += this->success[_i303].read(iprot); + xfer += this->success[_i314].read(iprot); } xfer += iprot->readListEnd(); } @@ -24392,10 +24669,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 _iter304; - for (_iter304 = this->success.begin(); _iter304 != this->success.end(); ++_iter304) + std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter315; + for (_iter315 = this->success.begin(); _iter315 != this->success.end(); ++_iter315) { - xfer += (*_iter304).write(oprot); + xfer += (*_iter315).write(oprot); } xfer += oprot->writeListEnd(); } @@ -24442,14 +24719,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size305; - ::apache::thrift::protocol::TType _etype308; - xfer += iprot->readListBegin(_etype308, _size305); - (*(this->success)).resize(_size305); - uint32_t _i309; - for (_i309 = 0; _i309 < _size305; ++_i309) + uint32_t _size316; + ::apache::thrift::protocol::TType _etype319; + xfer += iprot->readListBegin(_etype319, _size316); + (*(this->success)).resize(_size316); + uint32_t _i320; + for (_i320 = 0; _i320 < _size316; ++_i320) { - xfer += (*(this->success))[_i309].read(iprot); + xfer += (*(this->success))[_i320].read(iprot); } xfer += iprot->readListEnd(); } @@ -24563,14 +24840,14 @@ uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::p if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size310; - ::apache::thrift::protocol::TType _etype313; - xfer += iprot->readListBegin(_etype313, _size310); - this->success.resize(_size310); - uint32_t _i314; - for (_i314 = 0; _i314 < _size310; ++_i314) + uint32_t _size321; + ::apache::thrift::protocol::TType _etype324; + xfer += iprot->readListBegin(_etype324, _size321); + this->success.resize(_size321); + uint32_t _i325; + for (_i325 = 0; _i325 < _size321; ++_i325) { - xfer += this->success[_i314].read(iprot); + xfer += this->success[_i325].read(iprot); } xfer += iprot->readListEnd(); } @@ -24625,10 +24902,10 @@ uint32_t Airavata_getAllGatewayComputeResources_result::write(::apache::thrift:: 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::GatewayResourceProfile> ::const_iterator _iter315; - for (_iter315 = this->success.begin(); _iter315 != this->success.end(); ++_iter315) + std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::GatewayResourceProfile> ::const_iterator _iter326; + for (_iter326 = this->success.begin(); _iter326 != this->success.end(); ++_iter326) { - xfer += (*_iter315).write(oprot); + xfer += (*_iter326).write(oprot); } xfer += oprot->writeListEnd(); } @@ -24675,14 +24952,14 @@ uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift:: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size316; - ::apache::thrift::protocol::TType _etype319; - xfer += iprot->readListBegin(_etype319, _size316); - (*(this->success)).resize(_size316); - uint32_t _i320; - for (_i320 = 0; _i320 < _size316; ++_i320) + uint32_t _size327; + ::apache::thrift::protocol::TType _etype330; + xfer += iprot->readListBegin(_etype330, _size327); + (*(this->success)).resize(_size327); + uint32_t _i331; + for (_i331 = 0; _i331 < _size327; ++_i331) { - xfer += (*(this->success))[_i320].read(iprot); + xfer += (*(this->success))[_i331].read(iprot); } xfer += iprot->readListEnd(); } @@ -25303,14 +25580,14 @@ uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProt if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size321; - ::apache::thrift::protocol::TType _etype324; - xfer += iprot->readListBegin(_etype324, _size321); - this->success.resize(_size321); - uint32_t _i325; - for (_i325 = 0; _i325 < _size321; ++_i325) + uint32_t _size332; + ::apache::thrift::protocol::TType _etype335; + xfer += iprot->readListBegin(_etype335, _size332); + this->success.resize(_size332); + uint32_t _i336; + for (_i336 = 0; _i336 < _size332; ++_i336) { - xfer += iprot->readString(this->success[_i325]); + xfer += iprot->readString(this->success[_i336]); } xfer += iprot->readListEnd(); } @@ -25365,10 +25642,10 @@ uint32_t Airavata_getAllWorkflows_result::write(::apache::thrift::protocol::TPro 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 _iter326; - for (_iter326 = this->success.begin(); _iter326 != this->success.end(); ++_iter326) + std::vector<std::string> ::const_iterator _iter337; + for (_iter337 = this->success.begin(); _iter337 != this->success.end(); ++_iter337) { - xfer += oprot->writeString((*_iter326)); + xfer += oprot->writeString((*_iter337)); } xfer += oprot->writeListEnd(); } @@ -25415,14 +25692,14 @@ uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TPro if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size327; - ::apache::thrift::protocol::TType _etype330; - xfer += iprot->readListBegin(_etype330, _size327); - (*(this->success)).resize(_size327); - uint32_t _i331; - for (_i331 = 0; _i331 < _size327; ++_i331) + uint32_t _size338; + ::apache::thrift::protocol::TType _etype341; + xfer += iprot->readListBegin(_etype341, _size338); + (*(this->success)).resize(_size338); + uint32_t _i342; + for (_i342 = 0; _i342 < _size338; ++_i342) { - xfer += iprot->readString((*(this->success))[_i331]); + xfer += iprot->readString((*(this->success))[_i342]); } xfer += iprot->readListEnd(); } @@ -28733,6 +29010,76 @@ void AiravataClient::recv_getExperimentOutputs(std::vector< ::apache::airavata:: throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getExperimentOutputs failed: unknown result"); } +void AiravataClient::getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) +{ + send_getIntermediateOutputs(airavataExperimentId); + recv_getIntermediateOutputs(_return); +} + +void AiravataClient::send_getIntermediateOutputs(const std::string& airavataExperimentId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getIntermediateOutputs", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_getIntermediateOutputs_pargs args; + args.airavataExperimentId = &airavataExperimentId; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _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("getIntermediateOutputs") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getIntermediateOutputs_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.enf) { + throw result.enf; + } + if (result.__isset.ace) { + throw result.ace; + } + if (result.__isset.ase) { + throw result.ase; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getIntermediateOutputs failed: unknown result"); +} + void AiravataClient::getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) { send_getJobStatuses(airavataExperimentId); @@ -36115,6 +36462,72 @@ void AiravataProcessor::process_getExperimentOutputs(int32_t seqid, ::apache::th } } +void AiravataProcessor::process_getIntermediateOutputs(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) +{ + void* ctx = NULL; + if (this->eventHandler_.get() != NULL) { + ctx = this->eventHandler_->getContext("Airavata.getIntermediateOutputs", callContext); + } + ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.getIntermediateOutputs"); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preRead(ctx, "Airavata.getIntermediateOutputs"); + } + + Airavata_getIntermediateOutputs_args args; + args.read(iprot); + iprot->readMessageEnd(); + uint32_t bytes = iprot->getTransport()->readEnd(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postRead(ctx, "Airavata.getIntermediateOutputs", bytes); + } + + Airavata_getIntermediateOutputs_result result; + try { + iface_->getIntermediateOutputs(result.success, args.airavataExperimentId); + result.__isset.success = true; + } catch ( ::apache::airavata::api::error::InvalidRequestException &ire) { + result.ire = ire; + result.__isset.ire = true; + } catch ( ::apache::airavata::api::error::ExperimentNotFoundException &enf) { + result.enf = enf; + result.__isset.enf = true; + } catch ( ::apache::airavata::api::error::AiravataClientException &ace) { + result.ace = ace; + result.__isset.ace = true; + } catch ( ::apache::airavata::api::error::AiravataSystemException &ase) { + result.ase = ase; + result.__isset.ase = true; + } catch (const std::exception& e) { + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->handlerError(ctx, "Airavata.getIntermediateOutputs"); + } + + ::apache::thrift::TApplicationException x(e.what()); + oprot->writeMessageBegin("getIntermediateOutputs", ::apache::thrift::protocol::T_EXCEPTION, seqid); + x.write(oprot); + oprot->writeMessageEnd(); + oprot->getTransport()->writeEnd(); + oprot->getTransport()->flush(); + return; + } + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preWrite(ctx, "Airavata.getIntermediateOutputs"); + } + + oprot->writeMessageBegin("getIntermediateOutputs", ::apache::thrift::protocol::T_REPLY, seqid); + result.write(oprot); + oprot->writeMessageEnd(); + bytes = oprot->getTransport()->writeEnd(); + oprot->getTransport()->flush(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postWrite(ctx, "Airavata.getIntermediateOutputs", bytes); + } +} + void AiravataProcessor::process_getJobStatuses(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL;
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h index 776ee04..a1ce19d 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h @@ -61,6 +61,7 @@ class AiravataIf { virtual void launchExperiment(const std::string& airavataExperimentId, const std::string& airavataCredStoreToken) = 0; virtual void getExperimentStatus( ::apache::airavata::model::workspace::experiment::ExperimentStatus& _return, const std::string& airavataExperimentId) = 0; virtual void getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) = 0; + virtual void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) = 0; virtual void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) = 0; virtual void getJobDetails(std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> & _return, const std::string& airavataExperimentId) = 0; virtual void getDataTransferDetails(std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> & _return, const std::string& airavataExperimentId) = 0; @@ -262,6 +263,9 @@ class AiravataNull : virtual public AiravataIf { void getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & /* _return */, const std::string& /* airavataExperimentId */) { return; } + void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & /* _return */, const std::string& /* airavataExperimentId */) { + return; + } void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & /* _return */, const std::string& /* airavataExperimentId */) { return; } @@ -4426,6 +4430,148 @@ class Airavata_getExperimentOutputs_presult { }; +class Airavata_getIntermediateOutputs_args { + public: + + Airavata_getIntermediateOutputs_args() : airavataExperimentId() { + } + + virtual ~Airavata_getIntermediateOutputs_args() throw() {} + + std::string airavataExperimentId; + + void __set_airavataExperimentId(const std::string& val) { + airavataExperimentId = val; + } + + bool operator == (const Airavata_getIntermediateOutputs_args & rhs) const + { + if (!(airavataExperimentId == rhs.airavataExperimentId)) + return false; + return true; + } + bool operator != (const Airavata_getIntermediateOutputs_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getIntermediateOutputs_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getIntermediateOutputs_pargs { + public: + + + virtual ~Airavata_getIntermediateOutputs_pargs() throw() {} + + const std::string* airavataExperimentId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getIntermediateOutputs_result__isset { + _Airavata_getIntermediateOutputs_result__isset() : success(false), ire(false), enf(false), ace(false), ase(false) {} + bool success; + bool ire; + bool enf; + bool ace; + bool ase; +} _Airavata_getIntermediateOutputs_result__isset; + +class Airavata_getIntermediateOutputs_result { + public: + + Airavata_getIntermediateOutputs_result() { + } + + virtual ~Airavata_getIntermediateOutputs_result() throw() {} + + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::ExperimentNotFoundException enf; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getIntermediateOutputs_result__isset __isset; + + void __set_success(const std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_enf(const ::apache::airavata::api::error::ExperimentNotFoundException& val) { + enf = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_getIntermediateOutputs_result & rhs) const + { + if (!(success == rhs.success)) + return false; + if (!(ire == rhs.ire)) + return false; + if (!(enf == rhs.enf)) + return false; + if (!(ace == rhs.ace)) + return false; + if (!(ase == rhs.ase)) + return false; + return true; + } + bool operator != (const Airavata_getIntermediateOutputs_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getIntermediateOutputs_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getIntermediateOutputs_presult__isset { + _Airavata_getIntermediateOutputs_presult__isset() : success(false), ire(false), enf(false), ace(false), ase(false) {} + bool success; + bool ire; + bool enf; + bool ace; + bool ase; +} _Airavata_getIntermediateOutputs_presult__isset; + +class Airavata_getIntermediateOutputs_presult { + public: + + + virtual ~Airavata_getIntermediateOutputs_presult() throw() {} + + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> * success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::ExperimentNotFoundException enf; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getIntermediateOutputs_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class Airavata_getJobStatuses_args { public: @@ -15677,6 +15823,9 @@ class AiravataClient : virtual public AiravataIf { void getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId); void send_getExperimentOutputs(const std::string& airavataExperimentId); void recv_getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return); + void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId); + void send_getIntermediateOutputs(const std::string& airavataExperimentId); + void recv_getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return); void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId); void send_getJobStatuses(const std::string& airavataExperimentId); void recv_getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return); @@ -15967,6 +16116,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { void process_launchExperiment(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getExperimentStatus(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getExperimentOutputs(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getIntermediateOutputs(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getJobStatuses(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getJobDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getDataTransferDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); @@ -16081,6 +16231,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { processMap_["launchExperiment"] = &AiravataProcessor::process_launchExperiment; processMap_["getExperimentStatus"] = &AiravataProcessor::process_getExperimentStatus; processMap_["getExperimentOutputs"] = &AiravataProcessor::process_getExperimentOutputs; + processMap_["getIntermediateOutputs"] = &AiravataProcessor::process_getIntermediateOutputs; processMap_["getJobStatuses"] = &AiravataProcessor::process_getJobStatuses; processMap_["getJobDetails"] = &AiravataProcessor::process_getJobDetails; processMap_["getDataTransferDetails"] = &AiravataProcessor::process_getDataTransferDetails; @@ -16472,6 +16623,16 @@ class AiravataMultiface : virtual public AiravataIf { return; } + void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getIntermediateOutputs(_return, airavataExperimentId); + } + ifaces_[i]->getIntermediateOutputs(_return, airavataExperimentId); + return; + } + void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) { size_t sz = ifaces_.size(); size_t i = 0; http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp index e68589f..42f63a2 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp @@ -184,6 +184,11 @@ class AiravataHandler : virtual public AiravataIf { printf("getExperimentOutputs\n"); } + void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) { + // Your implementation goes here + printf("getIntermediateOutputs\n"); + } + void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) { // Your implementation goes here printf("getJobStatuses\n");
