You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2015/05/31 23:23:19 UTC
[08/13] airavata git commit: Adding searchExperiments methods to the
Airavata API
http://git-wip-us.apache.org/repos/asf/airavata/blob/7e67ca09/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 8c7d1ee..95da26b 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
@@ -8322,6 +8322,369 @@ uint32_t Airavata_searchExperimentsByCreationTimeWithPagination_presult::read(::
return xfer;
}
+uint32_t Airavata_searchExperiments_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_gatewayId = false;
+ bool isset_userName = false;
+ bool isset_limit = false;
+ bool isset_offset = 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->gatewayId);
+ isset_gatewayId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->userName);
+ isset_userName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->filters.clear();
+ uint32_t _size204;
+ ::apache::thrift::protocol::TType _ktype205;
+ ::apache::thrift::protocol::TType _vtype206;
+ xfer += iprot->readMapBegin(_ktype205, _vtype206, _size204);
+ uint32_t _i208;
+ for (_i208 = 0; _i208 < _size204; ++_i208)
+ {
+ std::string _key209;
+ xfer += iprot->readString(_key209);
+ std::string& _val210 = this->filters[_key209];
+ xfer += iprot->readString(_val210);
+ }
+ xfer += iprot->readMapEnd();
+ }
+ this->__isset.filters = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->limit);
+ isset_limit = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 5:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->offset);
+ isset_offset = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_gatewayId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_userName)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_limit)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_offset)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_searchExperiments_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchExperiments_args");
+
+ xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->gatewayId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->userName);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("filters", ::apache::thrift::protocol::T_MAP, 3);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->filters.size()));
+ std::map<std::string, std::string> ::const_iterator _iter211;
+ for (_iter211 = this->filters.begin(); _iter211 != this->filters.end(); ++_iter211)
+ {
+ xfer += oprot->writeString(_iter211->first);
+ xfer += oprot->writeString(_iter211->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("limit", ::apache::thrift::protocol::T_I32, 4);
+ xfer += oprot->writeI32(this->limit);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("offset", ::apache::thrift::protocol::T_I32, 5);
+ xfer += oprot->writeI32(this->offset);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperiments_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchExperiments_pargs");
+
+ xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->gatewayId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->userName)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("filters", ::apache::thrift::protocol::T_MAP, 3);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>((*(this->filters)).size()));
+ std::map<std::string, std::string> ::const_iterator _iter212;
+ for (_iter212 = (*(this->filters)).begin(); _iter212 != (*(this->filters)).end(); ++_iter212)
+ {
+ xfer += oprot->writeString(_iter212->first);
+ xfer += oprot->writeString(_iter212->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("limit", ::apache::thrift::protocol::T_I32, 4);
+ xfer += oprot->writeI32((*(this->limit)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("offset", ::apache::thrift::protocol::T_I32, 5);
+ xfer += oprot->writeI32((*(this->offset)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperiments_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 _size213;
+ ::apache::thrift::protocol::TType _etype216;
+ xfer += iprot->readListBegin(_etype216, _size213);
+ this->success.resize(_size213);
+ uint32_t _i217;
+ for (_i217 = 0; _i217 < _size213; ++_i217)
+ {
+ xfer += this->success[_i217].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_searchExperiments_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_searchExperiments_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::workspace::experiment::ExperimentSummary> ::const_iterator _iter218;
+ for (_iter218 = this->success.begin(); _iter218 != this->success.end(); ++_iter218)
+ {
+ xfer += (*_iter218).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
+ xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->ire.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperiments_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 _size219;
+ ::apache::thrift::protocol::TType _etype222;
+ xfer += iprot->readListBegin(_etype222, _size219);
+ (*(this->success)).resize(_size219);
+ uint32_t _i223;
+ for (_i223 = 0; _i223 < _size219; ++_i223)
+ {
+ xfer += (*(this->success))[_i223].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
uint32_t Airavata_getAllExperimentsInProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
@@ -8415,14 +8778,14 @@ uint32_t Airavata_getAllExperimentsInProject_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size204;
- ::apache::thrift::protocol::TType _etype207;
- xfer += iprot->readListBegin(_etype207, _size204);
- this->success.resize(_size204);
- uint32_t _i208;
- for (_i208 = 0; _i208 < _size204; ++_i208)
+ uint32_t _size224;
+ ::apache::thrift::protocol::TType _etype227;
+ xfer += iprot->readListBegin(_etype227, _size224);
+ this->success.resize(_size224);
+ uint32_t _i228;
+ for (_i228 = 0; _i228 < _size224; ++_i228)
{
- xfer += this->success[_i208].read(iprot);
+ xfer += this->success[_i228].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -8485,10 +8848,10 @@ uint32_t Airavata_getAllExperimentsInProject_result::write(::apache::thrift::pro
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::Experiment> ::const_iterator _iter209;
- for (_iter209 = this->success.begin(); _iter209 != this->success.end(); ++_iter209)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter229;
+ for (_iter229 = this->success.begin(); _iter229 != this->success.end(); ++_iter229)
{
- xfer += (*_iter209).write(oprot);
+ xfer += (*_iter229).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -8539,14 +8902,14 @@ uint32_t Airavata_getAllExperimentsInProject_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size210;
- ::apache::thrift::protocol::TType _etype213;
- xfer += iprot->readListBegin(_etype213, _size210);
- (*(this->success)).resize(_size210);
- uint32_t _i214;
- for (_i214 = 0; _i214 < _size210; ++_i214)
+ uint32_t _size230;
+ ::apache::thrift::protocol::TType _etype233;
+ xfer += iprot->readListBegin(_etype233, _size230);
+ (*(this->success)).resize(_size230);
+ uint32_t _i234;
+ for (_i234 = 0; _i234 < _size230; ++_i234)
{
- xfer += (*(this->success))[_i214].read(iprot);
+ xfer += (*(this->success))[_i234].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -8730,14 +9093,14 @@ uint32_t Airavata_getAllExperimentsInProjectWithPagination_result::read(::apache
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size215;
- ::apache::thrift::protocol::TType _etype218;
- xfer += iprot->readListBegin(_etype218, _size215);
- this->success.resize(_size215);
- uint32_t _i219;
- for (_i219 = 0; _i219 < _size215; ++_i219)
+ 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[_i219].read(iprot);
+ xfer += this->success[_i239].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -8800,10 +9163,10 @@ uint32_t Airavata_getAllExperimentsInProjectWithPagination_result::write(::apach
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::Experiment> ::const_iterator _iter220;
- for (_iter220 = this->success.begin(); _iter220 != this->success.end(); ++_iter220)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter240;
+ for (_iter240 = this->success.begin(); _iter240 != this->success.end(); ++_iter240)
{
- xfer += (*_iter220).write(oprot);
+ xfer += (*_iter240).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -8854,14 +9217,14 @@ uint32_t Airavata_getAllExperimentsInProjectWithPagination_presult::read(::apach
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size221;
- ::apache::thrift::protocol::TType _etype224;
- xfer += iprot->readListBegin(_etype224, _size221);
- (*(this->success)).resize(_size221);
- uint32_t _i225;
- for (_i225 = 0; _i225 < _size221; ++_i225)
+ uint32_t _size241;
+ ::apache::thrift::protocol::TType _etype244;
+ xfer += iprot->readListBegin(_etype244, _size241);
+ (*(this->success)).resize(_size241);
+ uint32_t _i245;
+ for (_i245 = 0; _i245 < _size241; ++_i245)
{
- xfer += (*(this->success))[_i225].read(iprot);
+ xfer += (*(this->success))[_i245].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9026,14 +9389,14 @@ uint32_t Airavata_getAllUserExperiments_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size226;
- ::apache::thrift::protocol::TType _etype229;
- xfer += iprot->readListBegin(_etype229, _size226);
- this->success.resize(_size226);
- uint32_t _i230;
- for (_i230 = 0; _i230 < _size226; ++_i230)
+ 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[_i230].read(iprot);
+ xfer += this->success[_i250].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9088,10 +9451,10 @@ uint32_t Airavata_getAllUserExperiments_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::workspace::experiment::Experiment> ::const_iterator _iter231;
- for (_iter231 = this->success.begin(); _iter231 != this->success.end(); ++_iter231)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter251;
+ for (_iter251 = this->success.begin(); _iter251 != this->success.end(); ++_iter251)
{
- xfer += (*_iter231).write(oprot);
+ xfer += (*_iter251).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9138,14 +9501,14 @@ uint32_t Airavata_getAllUserExperiments_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size232;
- ::apache::thrift::protocol::TType _etype235;
- xfer += iprot->readListBegin(_etype235, _size232);
- (*(this->success)).resize(_size232);
- uint32_t _i236;
- for (_i236 = 0; _i236 < _size232; ++_i236)
+ uint32_t _size252;
+ ::apache::thrift::protocol::TType _etype255;
+ xfer += iprot->readListBegin(_etype255, _size252);
+ (*(this->success)).resize(_size252);
+ uint32_t _i256;
+ for (_i256 = 0; _i256 < _size252; ++_i256)
{
- xfer += (*(this->success))[_i236].read(iprot);
+ xfer += (*(this->success))[_i256].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9340,14 +9703,14 @@ uint32_t Airavata_getAllUserExperimentsWithPagination_result::read(::apache::thr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size237;
- ::apache::thrift::protocol::TType _etype240;
- xfer += iprot->readListBegin(_etype240, _size237);
- this->success.resize(_size237);
- uint32_t _i241;
- for (_i241 = 0; _i241 < _size237; ++_i241)
+ 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[_i241].read(iprot);
+ xfer += this->success[_i261].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9402,10 +9765,10 @@ uint32_t Airavata_getAllUserExperimentsWithPagination_result::write(::apache::th
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::Experiment> ::const_iterator _iter242;
- for (_iter242 = this->success.begin(); _iter242 != this->success.end(); ++_iter242)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter262;
+ for (_iter262 = this->success.begin(); _iter262 != this->success.end(); ++_iter262)
{
- xfer += (*_iter242).write(oprot);
+ xfer += (*_iter262).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9452,14 +9815,14 @@ uint32_t Airavata_getAllUserExperimentsWithPagination_presult::read(::apache::th
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size243;
- ::apache::thrift::protocol::TType _etype246;
- xfer += iprot->readListBegin(_etype246, _size243);
- (*(this->success)).resize(_size243);
- uint32_t _i247;
- for (_i247 = 0; _i247 < _size243; ++_i247)
+ uint32_t _size263;
+ ::apache::thrift::protocol::TType _etype266;
+ xfer += iprot->readListBegin(_etype266, _size263);
+ (*(this->success)).resize(_size263);
+ uint32_t _i267;
+ for (_i267 = 0; _i267 < _size263; ++_i267)
{
- xfer += (*(this->success))[_i247].read(iprot);
+ xfer += (*(this->success))[_i267].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11390,14 +11753,14 @@ uint32_t Airavata_getExperimentOutputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size248;
- ::apache::thrift::protocol::TType _etype251;
- xfer += iprot->readListBegin(_etype251, _size248);
- this->success.resize(_size248);
- uint32_t _i252;
- for (_i252 = 0; _i252 < _size248; ++_i252)
+ uint32_t _size268;
+ ::apache::thrift::protocol::TType _etype271;
+ xfer += iprot->readListBegin(_etype271, _size268);
+ this->success.resize(_size268);
+ uint32_t _i272;
+ for (_i272 = 0; _i272 < _size268; ++_i272)
{
- xfer += this->success[_i252].read(iprot);
+ xfer += this->success[_i272].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11460,10 +11823,10 @@ uint32_t Airavata_getExperimentOutputs_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 _iter253;
- for (_iter253 = this->success.begin(); _iter253 != this->success.end(); ++_iter253)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter273;
+ for (_iter273 = this->success.begin(); _iter273 != this->success.end(); ++_iter273)
{
- xfer += (*_iter253).write(oprot);
+ xfer += (*_iter273).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11514,14 +11877,14 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size254;
- ::apache::thrift::protocol::TType _etype257;
- xfer += iprot->readListBegin(_etype257, _size254);
- (*(this->success)).resize(_size254);
- uint32_t _i258;
- for (_i258 = 0; _i258 < _size254; ++_i258)
+ uint32_t _size274;
+ ::apache::thrift::protocol::TType _etype277;
+ xfer += iprot->readListBegin(_etype277, _size274);
+ (*(this->success)).resize(_size274);
+ uint32_t _i278;
+ for (_i278 = 0; _i278 < _size274; ++_i278)
{
- xfer += (*(this->success))[_i258].read(iprot);
+ xfer += (*(this->success))[_i278].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11667,14 +12030,14 @@ uint32_t Airavata_getIntermediateOutputs_result::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size259;
- ::apache::thrift::protocol::TType _etype262;
- xfer += iprot->readListBegin(_etype262, _size259);
- this->success.resize(_size259);
- uint32_t _i263;
- for (_i263 = 0; _i263 < _size259; ++_i263)
+ uint32_t _size279;
+ ::apache::thrift::protocol::TType _etype282;
+ xfer += iprot->readListBegin(_etype282, _size279);
+ this->success.resize(_size279);
+ uint32_t _i283;
+ for (_i283 = 0; _i283 < _size279; ++_i283)
{
- xfer += this->success[_i263].read(iprot);
+ xfer += this->success[_i283].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11737,10 +12100,10 @@ uint32_t Airavata_getIntermediateOutputs_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::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter264;
- for (_iter264 = this->success.begin(); _iter264 != this->success.end(); ++_iter264)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter284;
+ for (_iter284 = this->success.begin(); _iter284 != this->success.end(); ++_iter284)
{
- xfer += (*_iter264).write(oprot);
+ xfer += (*_iter284).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11791,14 +12154,14 @@ uint32_t Airavata_getIntermediateOutputs_presult::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size265;
- ::apache::thrift::protocol::TType _etype268;
- xfer += iprot->readListBegin(_etype268, _size265);
- (*(this->success)).resize(_size265);
- uint32_t _i269;
- for (_i269 = 0; _i269 < _size265; ++_i269)
+ uint32_t _size285;
+ ::apache::thrift::protocol::TType _etype288;
+ xfer += iprot->readListBegin(_etype288, _size285);
+ (*(this->success)).resize(_size285);
+ uint32_t _i289;
+ for (_i289 = 0; _i289 < _size285; ++_i289)
{
- xfer += (*(this->success))[_i269].read(iprot);
+ xfer += (*(this->success))[_i289].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11944,17 +12307,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- 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)
+ 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)
{
- std::string _key275;
- xfer += iprot->readString(_key275);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val276 = this->success[_key275];
- xfer += _val276.read(iprot);
+ std::string _key295;
+ xfer += iprot->readString(_key295);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val296 = this->success[_key295];
+ xfer += _val296.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -12017,11 +12380,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 _iter277;
- for (_iter277 = this->success.begin(); _iter277 != this->success.end(); ++_iter277)
+ std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter297;
+ for (_iter297 = this->success.begin(); _iter297 != this->success.end(); ++_iter297)
{
- xfer += oprot->writeString(_iter277->first);
- xfer += _iter277->second.write(oprot);
+ xfer += oprot->writeString(_iter297->first);
+ xfer += _iter297->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -12072,17 +12435,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size278;
- ::apache::thrift::protocol::TType _ktype279;
- ::apache::thrift::protocol::TType _vtype280;
- xfer += iprot->readMapBegin(_ktype279, _vtype280, _size278);
- uint32_t _i282;
- for (_i282 = 0; _i282 < _size278; ++_i282)
+ uint32_t _size298;
+ ::apache::thrift::protocol::TType _ktype299;
+ ::apache::thrift::protocol::TType _vtype300;
+ xfer += iprot->readMapBegin(_ktype299, _vtype300, _size298);
+ uint32_t _i302;
+ for (_i302 = 0; _i302 < _size298; ++_i302)
{
- std::string _key283;
- xfer += iprot->readString(_key283);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val284 = (*(this->success))[_key283];
- xfer += _val284.read(iprot);
+ std::string _key303;
+ xfer += iprot->readString(_key303);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val304 = (*(this->success))[_key303];
+ xfer += _val304.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -12228,14 +12591,14 @@ uint32_t Airavata_getJobDetails_result::read(::apache::thrift::protocol::TProtoc
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size285;
- ::apache::thrift::protocol::TType _etype288;
- xfer += iprot->readListBegin(_etype288, _size285);
- this->success.resize(_size285);
- uint32_t _i289;
- for (_i289 = 0; _i289 < _size285; ++_i289)
+ 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)
{
- xfer += this->success[_i289].read(iprot);
+ xfer += this->success[_i309].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12298,10 +12661,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 _iter290;
- for (_iter290 = this->success.begin(); _iter290 != this->success.end(); ++_iter290)
+ std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> ::const_iterator _iter310;
+ for (_iter310 = this->success.begin(); _iter310 != this->success.end(); ++_iter310)
{
- xfer += (*_iter290).write(oprot);
+ xfer += (*_iter310).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -12352,14 +12715,14 @@ uint32_t Airavata_getJobDetails_presult::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size291;
- ::apache::thrift::protocol::TType _etype294;
- xfer += iprot->readListBegin(_etype294, _size291);
- (*(this->success)).resize(_size291);
- uint32_t _i295;
- for (_i295 = 0; _i295 < _size291; ++_i295)
+ uint32_t _size311;
+ ::apache::thrift::protocol::TType _etype314;
+ xfer += iprot->readListBegin(_etype314, _size311);
+ (*(this->success)).resize(_size311);
+ uint32_t _i315;
+ for (_i315 = 0; _i315 < _size311; ++_i315)
{
- xfer += (*(this->success))[_i295].read(iprot);
+ xfer += (*(this->success))[_i315].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12505,14 +12868,14 @@ uint32_t Airavata_getDataTransferDetails_result::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size296;
- ::apache::thrift::protocol::TType _etype299;
- xfer += iprot->readListBegin(_etype299, _size296);
- this->success.resize(_size296);
- uint32_t _i300;
- for (_i300 = 0; _i300 < _size296; ++_i300)
+ 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[_i300].read(iprot);
+ xfer += this->success[_i320].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12575,10 +12938,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 _iter301;
- for (_iter301 = this->success.begin(); _iter301 != this->success.end(); ++_iter301)
+ std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> ::const_iterator _iter321;
+ for (_iter321 = this->success.begin(); _iter321 != this->success.end(); ++_iter321)
{
- xfer += (*_iter301).write(oprot);
+ xfer += (*_iter321).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -12629,14 +12992,14 @@ uint32_t Airavata_getDataTransferDetails_presult::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size302;
- ::apache::thrift::protocol::TType _etype305;
- xfer += iprot->readListBegin(_etype305, _size302);
- (*(this->success)).resize(_size302);
- uint32_t _i306;
- for (_i306 = 0; _i306 < _size302; ++_i306)
+ uint32_t _size322;
+ ::apache::thrift::protocol::TType _etype325;
+ xfer += iprot->readListBegin(_etype325, _size322);
+ (*(this->success)).resize(_size322);
+ uint32_t _i326;
+ for (_i326 = 0; _i326 < _size322; ++_i326)
{
- xfer += (*(this->success))[_i306].read(iprot);
+ xfer += (*(this->success))[_i326].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -13991,14 +14354,14 @@ uint32_t Airavata_getAllAppModules_result::read(::apache::thrift::protocol::TPro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size307;
- ::apache::thrift::protocol::TType _etype310;
- xfer += iprot->readListBegin(_etype310, _size307);
- this->success.resize(_size307);
- uint32_t _i311;
- for (_i311 = 0; _i311 < _size307; ++_i311)
+ 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[_i311].read(iprot);
+ xfer += this->success[_i331].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -14053,10 +14416,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 _iter312;
- for (_iter312 = this->success.begin(); _iter312 != this->success.end(); ++_iter312)
+ std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter332;
+ for (_iter332 = this->success.begin(); _iter332 != this->success.end(); ++_iter332)
{
- xfer += (*_iter312).write(oprot);
+ xfer += (*_iter332).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -14103,14 +14466,14 @@ uint32_t Airavata_getAllAppModules_presult::read(::apache::thrift::protocol::TPr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size313;
- ::apache::thrift::protocol::TType _etype316;
- xfer += iprot->readListBegin(_etype316, _size313);
- (*(this->success)).resize(_size313);
- uint32_t _i317;
- for (_i317 = 0; _i317 < _size313; ++_i317)
+ uint32_t _size333;
+ ::apache::thrift::protocol::TType _etype336;
+ xfer += iprot->readListBegin(_etype336, _size333);
+ (*(this->success)).resize(_size333);
+ uint32_t _i337;
+ for (_i337 = 0; _i337 < _size333; ++_i337)
{
- xfer += (*(this->success))[_i317].read(iprot);
+ xfer += (*(this->success))[_i337].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -15411,14 +15774,14 @@ uint32_t Airavata_getAllApplicationDeployments_result::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size318;
- ::apache::thrift::protocol::TType _etype321;
- xfer += iprot->readListBegin(_etype321, _size318);
- this->success.resize(_size318);
- uint32_t _i322;
- for (_i322 = 0; _i322 < _size318; ++_i322)
+ 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 += this->success[_i322].read(iprot);
+ xfer += this->success[_i342].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -15473,10 +15836,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 _iter323;
- for (_iter323 = this->success.begin(); _iter323 != this->success.end(); ++_iter323)
+ std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationDeploymentDescription> ::const_iterator _iter343;
+ for (_iter343 = this->success.begin(); _iter343 != this->success.end(); ++_iter343)
{
- xfer += (*_iter323).write(oprot);
+ xfer += (*_iter343).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -15523,14 +15886,14 @@ uint32_t Airavata_getAllApplicationDeployments_presult::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size324;
- ::apache::thrift::protocol::TType _etype327;
- xfer += iprot->readListBegin(_etype327, _size324);
- (*(this->success)).resize(_size324);
- uint32_t _i328;
- for (_i328 = 0; _i328 < _size324; ++_i328)
+ uint32_t _size344;
+ ::apache::thrift::protocol::TType _etype347;
+ xfer += iprot->readListBegin(_etype347, _size344);
+ (*(this->success)).resize(_size344);
+ uint32_t _i348;
+ for (_i348 = 0; _i348 < _size344; ++_i348)
{
- xfer += (*(this->success))[_i328].read(iprot);
+ xfer += (*(this->success))[_i348].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -15668,14 +16031,14 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size329;
- ::apache::thrift::protocol::TType _etype332;
- xfer += iprot->readListBegin(_etype332, _size329);
- this->success.resize(_size329);
- uint32_t _i333;
- for (_i333 = 0; _i333 < _size329; ++_i333)
+ uint32_t _size349;
+ ::apache::thrift::protocol::TType _etype352;
+ xfer += iprot->readListBegin(_etype352, _size349);
+ this->success.resize(_size349);
+ uint32_t _i353;
+ for (_i353 = 0; _i353 < _size349; ++_i353)
{
- xfer += iprot->readString(this->success[_i333]);
+ xfer += iprot->readString(this->success[_i353]);
}
xfer += iprot->readListEnd();
}
@@ -15730,10 +16093,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 _iter334;
- for (_iter334 = this->success.begin(); _iter334 != this->success.end(); ++_iter334)
+ std::vector<std::string> ::const_iterator _iter354;
+ for (_iter354 = this->success.begin(); _iter354 != this->success.end(); ++_iter354)
{
- xfer += oprot->writeString((*_iter334));
+ xfer += oprot->writeString((*_iter354));
}
xfer += oprot->writeListEnd();
}
@@ -15780,14 +16143,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size335;
- ::apache::thrift::protocol::TType _etype338;
- xfer += iprot->readListBegin(_etype338, _size335);
- (*(this->success)).resize(_size335);
- uint32_t _i339;
- for (_i339 = 0; _i339 < _size335; ++_i339)
+ uint32_t _size355;
+ ::apache::thrift::protocol::TType _etype358;
+ xfer += iprot->readListBegin(_etype358, _size355);
+ (*(this->success)).resize(_size355);
+ uint32_t _i359;
+ for (_i359 = 0; _i359 < _size355; ++_i359)
{
- xfer += iprot->readString((*(this->success))[_i339]);
+ xfer += iprot->readString((*(this->success))[_i359]);
}
xfer += iprot->readListEnd();
}
@@ -16863,17 +17226,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size340;
- ::apache::thrift::protocol::TType _ktype341;
- ::apache::thrift::protocol::TType _vtype342;
- xfer += iprot->readMapBegin(_ktype341, _vtype342, _size340);
- uint32_t _i344;
- for (_i344 = 0; _i344 < _size340; ++_i344)
+ uint32_t _size360;
+ ::apache::thrift::protocol::TType _ktype361;
+ ::apache::thrift::protocol::TType _vtype362;
+ xfer += iprot->readMapBegin(_ktype361, _vtype362, _size360);
+ uint32_t _i364;
+ for (_i364 = 0; _i364 < _size360; ++_i364)
{
- std::string _key345;
- xfer += iprot->readString(_key345);
- std::string& _val346 = this->success[_key345];
- xfer += iprot->readString(_val346);
+ std::string _key365;
+ xfer += iprot->readString(_key365);
+ std::string& _val366 = this->success[_key365];
+ xfer += iprot->readString(_val366);
}
xfer += iprot->readMapEnd();
}
@@ -16928,11 +17291,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 _iter347;
- for (_iter347 = this->success.begin(); _iter347 != this->success.end(); ++_iter347)
+ std::map<std::string, std::string> ::const_iterator _iter367;
+ for (_iter367 = this->success.begin(); _iter367 != this->success.end(); ++_iter367)
{
- xfer += oprot->writeString(_iter347->first);
- xfer += oprot->writeString(_iter347->second);
+ xfer += oprot->writeString(_iter367->first);
+ xfer += oprot->writeString(_iter367->second);
}
xfer += oprot->writeMapEnd();
}
@@ -16979,17 +17342,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size348;
- ::apache::thrift::protocol::TType _ktype349;
- ::apache::thrift::protocol::TType _vtype350;
- xfer += iprot->readMapBegin(_ktype349, _vtype350, _size348);
- uint32_t _i352;
- for (_i352 = 0; _i352 < _size348; ++_i352)
+ uint32_t _size368;
+ ::apache::thrift::protocol::TType _ktype369;
+ ::apache::thrift::protocol::TType _vtype370;
+ xfer += iprot->readMapBegin(_ktype369, _vtype370, _size368);
+ uint32_t _i372;
+ for (_i372 = 0; _i372 < _size368; ++_i372)
{
- std::string _key353;
- xfer += iprot->readString(_key353);
- std::string& _val354 = (*(this->success))[_key353];
- xfer += iprot->readString(_val354);
+ std::string _key373;
+ xfer += iprot->readString(_key373);
+ std::string& _val374 = (*(this->success))[_key373];
+ xfer += iprot->readString(_val374);
}
xfer += iprot->readMapEnd();
}
@@ -17127,14 +17490,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size355;
- ::apache::thrift::protocol::TType _etype358;
- xfer += iprot->readListBegin(_etype358, _size355);
- this->success.resize(_size355);
- uint32_t _i359;
- for (_i359 = 0; _i359 < _size355; ++_i359)
+ uint32_t _size375;
+ ::apache::thrift::protocol::TType _etype378;
+ xfer += iprot->readListBegin(_etype378, _size375);
+ this->success.resize(_size375);
+ uint32_t _i379;
+ for (_i379 = 0; _i379 < _size375; ++_i379)
{
- xfer += this->success[_i359].read(iprot);
+ xfer += this->success[_i379].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17189,10 +17552,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 _iter360;
- for (_iter360 = this->success.begin(); _iter360 != this->success.end(); ++_iter360)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter380;
+ for (_iter380 = this->success.begin(); _iter380 != this->success.end(); ++_iter380)
{
- xfer += (*_iter360).write(oprot);
+ xfer += (*_iter380).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -17239,14 +17602,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size361;
- ::apache::thrift::protocol::TType _etype364;
- xfer += iprot->readListBegin(_etype364, _size361);
- (*(this->success)).resize(_size361);
- uint32_t _i365;
- for (_i365 = 0; _i365 < _size361; ++_i365)
+ uint32_t _size381;
+ ::apache::thrift::protocol::TType _etype384;
+ xfer += iprot->readListBegin(_etype384, _size381);
+ (*(this->success)).resize(_size381);
+ uint32_t _i385;
+ for (_i385 = 0; _i385 < _size381; ++_i385)
{
- xfer += (*(this->success))[_i365].read(iprot);
+ xfer += (*(this->success))[_i385].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17384,14 +17747,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size366;
- ::apache::thrift::protocol::TType _etype369;
- xfer += iprot->readListBegin(_etype369, _size366);
- this->success.resize(_size366);
- uint32_t _i370;
- for (_i370 = 0; _i370 < _size366; ++_i370)
+ uint32_t _size386;
+ ::apache::thrift::protocol::TType _etype389;
+ xfer += iprot->readListBegin(_etype389, _size386);
+ this->success.resize(_size386);
+ uint32_t _i390;
+ for (_i390 = 0; _i390 < _size386; ++_i390)
{
- xfer += this->success[_i370].read(iprot);
+ xfer += this->success[_i390].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17446,10 +17809,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 _iter371;
- for (_iter371 = this->success.begin(); _iter371 != this->success.end(); ++_iter371)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter391;
+ for (_iter391 = this->success.begin(); _iter391 != this->success.end(); ++_iter391)
{
- xfer += (*_iter371).write(oprot);
+ xfer += (*_iter391).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -17496,14 +17859,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size372;
- ::apache::thrift::protocol::TType _etype375;
- xfer += iprot->readListBegin(_etype375, _size372);
- (*(this->success)).resize(_size372);
- uint32_t _i376;
- for (_i376 = 0; _i376 < _size372; ++_i376)
+ uint32_t _size392;
+ ::apache::thrift::protocol::TType _etype395;
+ xfer += iprot->readListBegin(_etype395, _size392);
+ (*(this->success)).resize(_size392);
+ uint32_t _i396;
+ for (_i396 = 0; _i396 < _size392; ++_i396)
{
- xfer += (*(this->success))[_i376].read(iprot);
+ xfer += (*(this->success))[_i396].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17641,14 +18004,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size377;
- ::apache::thrift::protocol::TType _etype380;
- xfer += iprot->readListBegin(_etype380, _size377);
- this->success.resize(_size377);
- uint32_t _i381;
- for (_i381 = 0; _i381 < _size377; ++_i381)
+ uint32_t _size397;
+ ::apache::thrift::protocol::TType _etype400;
+ xfer += iprot->readListBegin(_etype400, _size397);
+ this->success.resize(_size397);
+ uint32_t _i401;
+ for (_i401 = 0; _i401 < _size397; ++_i401)
{
- xfer += this->success[_i381].read(iprot);
+ xfer += this->success[_i401].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17703,10 +18066,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 _iter382;
- for (_iter382 = this->success.begin(); _iter382 != this->success.end(); ++_iter382)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter402;
+ for (_iter402 = this->success.begin(); _iter402 != this->success.end(); ++_iter402)
{
- xfer += (*_iter382).write(oprot);
+ xfer += (*_iter402).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -17753,14 +18116,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size383;
- ::apache::thrift::protocol::TType _etype386;
- xfer += iprot->readListBegin(_etype386, _size383);
- (*(this->success)).resize(_size383);
- uint32_t _i387;
- for (_i387 = 0; _i387 < _size383; ++_i387)
+ uint32_t _size403;
+ ::apache::thrift::protocol::TType _etype406;
+ xfer += iprot->readListBegin(_etype406, _size403);
+ (*(this->success)).resize(_size403);
+ uint32_t _i407;
+ for (_i407 = 0; _i407 < _size403; ++_i407)
{
- xfer += (*(this->success))[_i387].read(iprot);
+ xfer += (*(this->success))[_i407].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17898,17 +18261,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size388;
- ::apache::thrift::protocol::TType _ktype389;
- ::apache::thrift::protocol::TType _vtype390;
- xfer += iprot->readMapBegin(_ktype389, _vtype390, _size388);
- uint32_t _i392;
- for (_i392 = 0; _i392 < _size388; ++_i392)
+ uint32_t _size408;
+ ::apache::thrift::protocol::TType _ktype409;
+ ::apache::thrift::protocol::TType _vtype410;
+ xfer += iprot->readMapBegin(_ktype409, _vtype410, _size408);
+ uint32_t _i412;
+ for (_i412 = 0; _i412 < _size408; ++_i412)
{
- std::string _key393;
- xfer += iprot->readString(_key393);
- std::string& _val394 = this->success[_key393];
- xfer += iprot->readString(_val394);
+ std::string _key413;
+ xfer += iprot->readString(_key413);
+ std::string& _val414 = this->success[_key413];
+ xfer += iprot->readString(_val414);
}
xfer += iprot->readMapEnd();
}
@@ -17963,11 +18326,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 _iter395;
- for (_iter395 = this->success.begin(); _iter395 != this->success.end(); ++_iter395)
+ std::map<std::string, std::string> ::const_iterator _iter415;
+ for (_iter415 = this->success.begin(); _iter415 != this->success.end(); ++_iter415)
{
- xfer += oprot->writeString(_iter395->first);
- xfer += oprot->writeString(_iter395->second);
+ xfer += oprot->writeString(_iter415->first);
+ xfer += oprot->writeString(_iter415->second);
}
xfer += oprot->writeMapEnd();
}
@@ -18014,17 +18377,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size396;
- ::apache::thrift::protocol::TType _ktype397;
- ::apache::thrift::protocol::TType _vtype398;
- xfer += iprot->readMapBegin(_ktype397, _vtype398, _size396);
- uint32_t _i400;
- for (_i400 = 0; _i400 < _size396; ++_i400)
+ uint32_t _size416;
+ ::apache::thrift::protocol::TType _ktype417;
+ ::apache::thrift::protocol::TType _vtype418;
+ xfer += iprot->readMapBegin(_ktype417, _vtype418, _size416);
+ uint32_t _i420;
+ for (_i420 = 0; _i420 < _size416; ++_i420)
{
- std::string _key401;
- xfer += iprot->readString(_key401);
- std::string& _val402 = (*(this->success))[_key401];
- xfer += iprot->readString(_val402);
+ std::string _key421;
+ xfer += iprot->readString(_key421);
+ std::string& _val422 = (*(this->success))[_key421];
+ xfer += iprot->readString(_val422);
}
xfer += iprot->readMapEnd();
}
@@ -18588,17 +18951,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size403;
- ::apache::thrift::protocol::TType _ktype404;
- ::apache::thrift::protocol::TType _vtype405;
- xfer += iprot->readMapBegin(_ktype404, _vtype405, _size403);
- uint32_t _i407;
- for (_i407 = 0; _i407 < _size403; ++_i407)
+ uint32_t _size423;
+ ::apache::thrift::protocol::TType _ktype424;
+ ::apache::thrift::protocol::TType _vtype425;
+ xfer += iprot->readMapBegin(_ktype424, _vtype425, _size423);
+ uint32_t _i427;
+ for (_i427 = 0; _i427 < _size423; ++_i427)
{
- std::string _key408;
- xfer += iprot->readString(_key408);
- std::string& _val409 = this->success[_key408];
- xfer += iprot->readString(_val409);
+ std::string _key428;
+ xfer += iprot->readString(_key428);
+ std::string& _val429 = this->success[_key428];
+ xfer += iprot->readString(_val429);
}
xfer += iprot->readMapEnd();
}
@@ -18653,11 +19016,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 _iter410;
- for (_iter410 = this->success.begin(); _iter410 != this->success.end(); ++_iter410)
+ std::map<std::string, std::string> ::const_iterator _iter430;
+ for (_iter430 = this->success.begin(); _iter430 != this->success.end(); ++_iter430)
{
- xfer += oprot->writeString(_iter410->first);
- xfer += oprot->writeString(_iter410->second);
+ xfer += oprot->writeString(_iter430->first);
+ xfer += oprot->writeString(_iter430->second);
}
xfer += oprot->writeMapEnd();
}
@@ -18704,17 +19067,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size411;
- ::apache::thrift::protocol::TType _ktype412;
- ::apache::thrift::protocol::TType _vtype413;
- xfer += iprot->readMapBegin(_ktype412, _vtype413, _size411);
- uint32_t _i415;
- for (_i415 = 0; _i415 < _size411; ++_i415)
+ uint32_t _size431;
+ ::apache::thrift::protocol::TType _ktype432;
+ ::apache::thrift::protocol::TType _vtype433;
+ xfer += iprot->readMapBegin(_ktype432, _vtype433, _size431);
+ uint32_t _i435;
+ for (_i435 = 0; _i435 < _size431; ++_i435)
{
- std::string _key416;
- xfer += iprot->readString(_key416);
- std::string& _val417 = (*(this->success))[_key416];
- xfer += iprot->readString(_val417);
+ std::string _key436;
+ xfer += iprot->readString(_key436);
+ std::string& _val437 = (*(this->success))[_key436];
+ xfer += iprot->readString(_val437);
}
xfer += iprot->readMapEnd();
}
@@ -25597,17 +25960,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->jobSubmissionPriorityMap.clear();
- uint32_t _size418;
- ::apache::thrift::protocol::TType _ktype419;
- ::apache::thrift::protocol::TType _vtype420;
- xfer += iprot->readMapBegin(_ktype419, _vtype420, _size418);
- uint32_t _i422;
- for (_i422 = 0; _i422 < _size418; ++_i422)
+ uint32_t _size438;
+ ::apache::thrift::protocol::TType _ktype439;
+ ::apache::thrift::protocol::TType _vtype440;
+ xfer += iprot->readMapBegin(_ktype439, _vtype440, _size438);
+ uint32_t _i442;
+ for (_i442 = 0; _i442 < _size438; ++_i442)
{
- std::string _key423;
- xfer += iprot->readString(_key423);
- int32_t& _val424 = this->jobSubmissionPriorityMap[_key423];
- xfer += iprot->readI32(_val424);
+ std::string _key443;
+ xfer += iprot->readString(_key443);
+ int32_t& _val444 = this->jobSubmissionPriorityMap[_key443];
+ xfer += iprot->readI32(_val444);
}
xfer += iprot->readMapEnd();
}
@@ -25637,11 +26000,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 _iter425;
- for (_iter425 = this->jobSubmissionPriorityMap.begin(); _iter425 != this->jobSubmissionPriorityMap.end(); ++_iter425)
+ std::map<std::string, int32_t> ::const_iterator _iter445;
+ for (_iter445 = this->jobSubmissionPriorityMap.begin(); _iter445 != this->jobSubmissionPriorityMap.end(); ++_iter445)
{
- xfer += oprot->writeString(_iter425->first);
- xfer += oprot->writeI32(_iter425->second);
+ xfer += oprot->writeString(_iter445->first);
+ xfer += oprot->writeI32(_iter445->second);
}
xfer += oprot->writeMapEnd();
}
@@ -25659,11 +26022,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 _iter426;
- for (_iter426 = (*(this->jobSubmissionPriorityMap)).begin(); _iter426 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter426)
+ std::map<std::string, int32_t> ::const_iterator _iter446;
+ for (_iter446 = (*(this->jobSubmissionPriorityMap)).begin(); _iter446 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter446)
{
- xfer += oprot->writeString(_iter426->first);
- xfer += oprot->writeI32(_iter426->second);
+ xfer += oprot->writeString(_iter446->first);
+ xfer += oprot->writeI32(_iter446->second);
}
xfer += oprot->writeMapEnd();
}
@@ -25855,17 +26218,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->dataMovementPriorityMap.clear();
- uint32_t _size427;
- ::apache::thrift::protocol::TType _ktype428;
- ::apache::thrift::protocol::TType _vtype429;
- xfer += iprot->readMapBegin(_ktype428, _vtype429, _size427);
- uint32_t _i431;
- for (_i431 = 0; _i431 < _size427; ++_i431)
+ uint32_t _size447;
+ ::apache::thrift::protocol::TType _ktype448;
+ ::apache::thrift::protocol::TType _vtype449;
+ xfer += iprot->readMapBegin(_ktype448, _vtype449, _size447);
+ uint32_t _i451;
+ for (_i451 = 0; _i451 < _size447; ++_i451)
{
- std::string _key432;
- xfer += iprot->readString(_key432);
- int32_t& _val433 = this->dataMovementPriorityMap[_key432];
- xfer += iprot->readI32(_val433);
+ std::string _key452;
+ xfer += iprot->readString(_key452);
+ int32_t& _val453 = this->dataMovementPriorityMap[_key452];
+ xfer += iprot->readI32(_val453);
}
xfer += iprot->readMapEnd();
}
@@ -25895,11 +26258,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 _iter434;
- for (_iter434 = this->dataMovementPriorityMap.begin(); _iter434 != this->dataMovementPriorityMap.end(); ++_iter434)
+ std::map<std::string, int32_t> ::const_iterator _iter454;
+ for (_iter454 = this->dataMovementPriorityMap.begin(); _iter454 != this->dataMovementPriorityMap.end(); ++_iter454)
{
- xfer += oprot->writeString(_iter434->first);
- xfer += oprot->writeI32(_iter434->second);
+ xfer += oprot->writeString(_iter454->first);
+ xfer += oprot->writeI32(_iter454->second);
}
xfer += oprot->writeMapEnd();
}
@@ -25917,11 +26280,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 _iter435;
- for (_iter435 = (*(this->dataMovementPriorityMap)).begin(); _iter435 != (*(this->dataMovementPriorityMap)).end(); ++_iter435)
+ std::map<std::string, int32_t> ::const_iterator _iter455;
+ for (_iter455 = (*(this->dataMovementPriorityMap)).begin(); _iter455 != (*(this->dataMovementPriorityMap)).end(); ++_iter455)
{
- xfer += oprot->writeString(_iter435->first);
- xfer += oprot->writeI32(_iter435->second);
+ xfer += oprot->writeString(_iter455->first);
+ xfer += oprot->writeI32(_iter455->second);
}
xfer += oprot->writeMapEnd();
}
@@ -29258,14 +29621,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size436;
- ::apache::thrift::protocol::TType _etype439;
- xfer += iprot->readListBegin(_etype439, _size436);
- this->success.resize(_size436);
- uint32_t _i440;
- for (_i440 = 0; _i440 < _size436; ++_i440)
+ uint32_t _size456;
+ ::apache::thrift::protocol::TType _etype459;
+ xfer += iprot->readListBegin(_etype459, _size456);
+ this->success.resize(_size456);
+ uint32_t _i460;
+ for (_i460 = 0; _i460 < _size456; ++_i460)
{
- xfer += this->success[_i440].read(iprot);
+ xfer += this->success[_i460].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -29320,10 +29683,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 _iter441;
- for (_iter441 = this->success.begin(); _iter441 != this->success.end(); ++_iter441)
+ std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter461;
+ for (_iter461 = this->success.begin(); _iter461 != this->success.end(); ++_iter461)
{
- xfer += (*_iter441).write(oprot);
+ xfer += (*_iter461).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -29370,14 +29733,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size442;
- ::apache::thrift::protocol::TType _etype445;
- xfer += iprot->readListBegin(_etype445, _size442);
- (*(this->success)).resize(_size442);
- uint32_t _i446;
- for (_i446 = 0; _i446 < _size442; ++_i446)
+ uint32_t _size462;
+ ::apache::thrift::protocol::TType _etype465;
+ xfer += iprot->readListBegin(_etype465, _size462);
+ (*(this->success)).resize(_size462);
+ uint32_t _i466;
+ for (_i466 = 0; _i466 < _size462; ++_i466)
{
- xfer += (*(this->success))[_i446].read(iprot);
+ xfer += (*(this->success))[_i466].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -29491,14 +29854,14 @@ uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size447;
- ::apache::thrift::protocol::TType _etype450;
- xfer += iprot->readListBegin(_etype450, _size447);
- this->success.resize(_size447);
- uint32_t _i451;
- for (_i451 = 0; _i451 < _size447; ++_i451)
+ uint32_t _size467;
+ ::apache::thrift::protocol::TType _etype470;
+ xfer += iprot->readListBegin(_etype470, _size467);
+ this->success.resize(_size467);
+ uint32_t _i471;
+ for (_i471 = 0; _i471 < _size467; ++_i471)
{
- xfer += this->success[_i451].read(iprot);
+ xfer += this->success[_i471].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -29553,10 +29916,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 _iter452;
- for (_iter452 = this->success.begin(); _iter452 != this->success.end(); ++_iter452)
+ std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::GatewayResourceProfile> ::const_iterator _iter472;
+ for (_iter472 = this->success.begin(); _iter472 != this->success.end(); ++_iter472)
{
- xfer += (*_iter452).write(oprot);
+ xfer += (*_iter472).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -29603,14 +29966,14 @@ uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size453;
- ::apache::thrift::protocol::TType _etype456;
- xfer += iprot->readListBegin(_etype456, _size453);
- (*(this->success)).resize(_size453);
- uint32_t _i457;
- for (_i457 = 0; _i457 < _size453; ++_i457)
+ uint32_t _size473;
+ ::apache::thrift::protocol::TType _etype476;
+ xfer += iprot->readListBegin(_etype476, _size473);
+ (*(this->success)).resize(_size473);
+ uint32_t _i477;
+ for (_i477 = 0; _i477 < _size473; ++_i477)
{
- xfer += (*(this->success))[_i457].read(iprot);
+ xfer += (*(this->success))[_i477].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -30255,14 +30618,14 @@ uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size458;
- ::apache::thrift::protocol::TType _etype461;
- xfer += iprot->readListBegin(_etype461, _size458);
- this->success.resize(_size458);
- uint32_t _i462;
- for (_i462 = 0; _i462 < _size458; ++_i462)
+ uint32_t _size478;
+ ::apache::thrift::protocol::TType _etype481;
+ xfer += iprot->readListBegin(_etype481, _size478);
+ this->success.resize(_size478);
+ uint32_t _i482;
+ for (_i482 = 0; _i482 < _size478; ++_i482)
{
- xfer += iprot->readString(this->success[_i462]);
+ xfer += iprot->readString(this->success[_i482]);
}
xfer += iprot->readListEnd();
}
@@ -30317,10 +30680,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 _iter463;
- for (_iter463 = this->success.begin(); _iter463 != this->success.end(); ++_iter463)
+ std::vector<std::string> ::const_iterator _iter483;
+ for (_iter483 = this->success.begin(); _iter483 != this->success.end(); ++_iter483)
{
- xfer += oprot->writeString((*_iter463));
+ xfer += oprot->writeString((*_iter483));
}
xfer += oprot->writeListEnd();
}
@@ -30367,14 +30730,14 @@ uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TPro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size464;
- ::apache::thrift::protocol::TType _etype467;
- xfer += iprot->readListBegin(_etype467, _size464);
- (*(this->success)).resize(_size464);
- uint32_t _i468;
- for (_i468 = 0; _i468 < _size464; ++_i468)
+ uint32_t _size484;
+ ::apache::thrift::protocol::TType _etype487;
+ xfer += iprot->readListBegin(_etype487, _size484);
+ (*(this->success)).resize(_size484);
+ uint32_t _i488;
+ for (_i488 = 0; _i488 < _size484; ++_i488)
{
- xfer += iprot->readString((*(this->success))[_i468]);
+ xfer += iprot->readString((*(this->success))[_i488]);
}
xfer += iprot->readListEnd();
}
@@ -33826,6 +34189,77 @@ void AiravataClient::recv_searchExperimentsByCreationTimeWithPagination(std::vec
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperimentsByCreationTimeWithPagination failed: unknown result");
}
+void AiravataClient::searchExperiments(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& gatewayId, const std::string& userName, const std::map<std::string, std::string> & filters, const int32_t limit, const int32_t offset)
+{
+ send_searchExperiments(gatewayId, userName, filters, limit, offset);
+ recv_searchExperiments(_return);
+}
+
+void AiravataClient::send_searchExperiments(const std::string& gatewayId, const std::string& userName, const std::map<std::string, std::string> & filters, const int32_t limit, const int32_t offset)
+{
+ int32_t cseqid = 0;
+ oprot_->writeMessageBegin("searchExperiments", ::apache::thrift::protocol::T_CALL, cseqid);
+
+ Airavata_searchExperiments_pargs args;
+ args.gatewayId = &gatewayId;
+ args.userName = &userName;
+ args.filters = &filters;
+ args.limit = &limit;
+ args.offset = &offset;
+ args.write(oprot_);
+
+ oprot_->writeMessageEnd();
+ oprot_->getTransport()->writeEnd();
+ oprot_->getTransport()->flush();
+}
+
+void AiravataClient::recv_searchExperiments(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _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("searchExperiments") != 0) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ Airavata_searchExperiments_presult result;
+ result.success = &_return;
+ result.read(iprot_);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
+ if (result.__isset.ire) {
+ throw result.ire;
+ }
+ if (result.__isset.ace) {
+ throw result.ace;
+ }
+ if (result.__isset.ase) {
+ throw result.ase;
+ }
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperiments failed: unknown result");
+}
+
void AiravataClient::getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId)
{
send_getAllExperimentsInProject(projectId);
@@ -42223,6 +42657,69 @@ void AiravataProcessor::process_searchExperimentsByCreationTimeWithPagination(in
}
}
+void AiravataProcessor::process_searchExperiments(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.searchExperiments", callContext);
+ }
+ ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.searchExperiments");
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preRead(ctx, "Airavata.searchExperiments");
+ }
+
+ Airavata_searchExperiments_args args;
+ args.read(iprot);
+ iprot->readMessageEnd();
+ uint32_t bytes = iprot->getTransport()->readEnd();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postRead(ctx, "Airavata.searchExperiments", bytes);
+ }
+
+ Airavata_searchExperiments_result result;
+ try {
+ iface_->searchExperiments(result.success, args.gatewayId, args.userName, args.filters, args.limit, args.offset);
+ result.__isset.success = true;
+ } catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
+ result.ire = ire;
+ result.__isset.ire = 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.searchExperiments");
+ }
+
+ ::apache::thrift::TApplicationException x(e.what());
+ oprot->writeMessageBegin("searchExperiments", ::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.searchExperiments");
+ }
+
+ oprot->writeMessageBegin("searchExperiments", ::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.searchExperiments", bytes);
+ }
+}
+
void AiravataProcessor::process_getAllExperimentsInProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
{
void* ctx = NULL;