You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/03/03 16:00:15 UTC
[2/4] airavata git commit: adding getIntermediateOutput method to API
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");