http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 6aac2e5..383d43e 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 @@ -2855,6 +2855,301 @@ uint32_t Airavata_searchExperimentsByStatus_presult::read(::apache::thrift::prot return xfer; } +uint32_t Airavata_searchExperimentsByCreationTime_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_userName = false; + bool isset_fromTime = false; + bool isset_toTime = 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->userName); + isset_userName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->fromTime); + isset_fromTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->toTime); + isset_toTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_userName) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_fromTime) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_toTime) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_searchExperimentsByCreationTime_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_searchExperimentsByCreationTime_args"); + + xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->userName); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("fromTime", ::apache::thrift::protocol::T_I64, 2); + xfer += oprot->writeI64(this->fromTime); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("toTime", ::apache::thrift::protocol::T_I64, 3); + xfer += oprot->writeI64(this->toTime); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_searchExperimentsByCreationTime_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_searchExperimentsByCreationTime_pargs"); + + xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->userName))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("fromTime", ::apache::thrift::protocol::T_I64, 2); + xfer += oprot->writeI64((*(this->fromTime))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("toTime", ::apache::thrift::protocol::T_I64, 3); + xfer += oprot->writeI64((*(this->toTime))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_searchExperimentsByCreationTime_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 _size78; + ::apache::thrift::protocol::TType _etype81; + xfer += iprot->readListBegin(_etype81, _size78); + this->success.resize(_size78); + uint32_t _i82; + for (_i82 = 0; _i82 < _size78; ++_i82) + { + xfer += this->success[_i82].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_searchExperimentsByCreationTime_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_searchExperimentsByCreationTime_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 _iter83; + for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83) + { + xfer += (*_iter83).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_searchExperimentsByCreationTime_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 _size84; + ::apache::thrift::protocol::TType _etype87; + xfer += iprot->readListBegin(_etype87, _size84); + (*(this->success)).resize(_size84); + uint32_t _i88; + for (_i88 = 0; _i88 < _size84; ++_i88) + { + xfer += (*(this->success))[_i88].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; @@ -2948,14 +3243,14 @@ uint32_t Airavata_getAllExperimentsInProject_result::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size78; - ::apache::thrift::protocol::TType _etype81; - xfer += iprot->readListBegin(_etype81, _size78); - this->success.resize(_size78); - uint32_t _i82; - for (_i82 = 0; _i82 < _size78; ++_i82) + uint32_t _size89; + ::apache::thrift::protocol::TType _etype92; + xfer += iprot->readListBegin(_etype92, _size89); + this->success.resize(_size89); + uint32_t _i93; + for (_i93 = 0; _i93 < _size89; ++_i93) { - xfer += this->success[_i82].read(iprot); + xfer += this->success[_i93].read(iprot); } xfer += iprot->readListEnd(); } @@ -3018,10 +3313,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 _iter83; - for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83) + std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter94; + for (_iter94 = this->success.begin(); _iter94 != this->success.end(); ++_iter94) { - xfer += (*_iter83).write(oprot); + xfer += (*_iter94).write(oprot); } xfer += oprot->writeListEnd(); } @@ -3072,14 +3367,14 @@ uint32_t Airavata_getAllExperimentsInProject_presult::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size84; - ::apache::thrift::protocol::TType _etype87; - xfer += iprot->readListBegin(_etype87, _size84); - (*(this->success)).resize(_size84); - uint32_t _i88; - for (_i88 = 0; _i88 < _size84; ++_i88) + uint32_t _size95; + ::apache::thrift::protocol::TType _etype98; + xfer += iprot->readListBegin(_etype98, _size95); + (*(this->success)).resize(_size95); + uint32_t _i99; + for (_i99 = 0; _i99 < _size95; ++_i99) { - xfer += (*(this->success))[_i88].read(iprot); + xfer += (*(this->success))[_i99].read(iprot); } xfer += iprot->readListEnd(); } @@ -3225,14 +3520,14 @@ uint32_t Airavata_getAllUserExperiments_result::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size89; - ::apache::thrift::protocol::TType _etype92; - xfer += iprot->readListBegin(_etype92, _size89); - this->success.resize(_size89); - uint32_t _i93; - for (_i93 = 0; _i93 < _size89; ++_i93) + uint32_t _size100; + ::apache::thrift::protocol::TType _etype103; + xfer += iprot->readListBegin(_etype103, _size100); + this->success.resize(_size100); + uint32_t _i104; + for (_i104 = 0; _i104 < _size100; ++_i104) { - xfer += this->success[_i93].read(iprot); + xfer += this->success[_i104].read(iprot); } xfer += iprot->readListEnd(); } @@ -3287,10 +3582,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 _iter94; - for (_iter94 = this->success.begin(); _iter94 != this->success.end(); ++_iter94) + std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter105; + for (_iter105 = this->success.begin(); _iter105 != this->success.end(); ++_iter105) { - xfer += (*_iter94).write(oprot); + xfer += (*_iter105).write(oprot); } xfer += oprot->writeListEnd(); } @@ -3337,14 +3632,14 @@ uint32_t Airavata_getAllUserExperiments_presult::read(::apache::thrift::protocol if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size95; - ::apache::thrift::protocol::TType _etype98; - xfer += iprot->readListBegin(_etype98, _size95); - (*(this->success)).resize(_size95); - uint32_t _i99; - for (_i99 = 0; _i99 < _size95; ++_i99) + uint32_t _size106; + ::apache::thrift::protocol::TType _etype109; + xfer += iprot->readListBegin(_etype109, _size106); + (*(this->success)).resize(_size106); + uint32_t _i110; + for (_i110 = 0; _i110 < _size106; ++_i110) { - xfer += (*(this->success))[_i99].read(iprot); + xfer += (*(this->success))[_i110].read(iprot); } xfer += iprot->readListEnd(); } @@ -5256,14 +5551,14 @@ uint32_t Airavata_getExperimentOutputs_result::read(::apache::thrift::protocol:: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size100; - ::apache::thrift::protocol::TType _etype103; - xfer += iprot->readListBegin(_etype103, _size100); - this->success.resize(_size100); - uint32_t _i104; - for (_i104 = 0; _i104 < _size100; ++_i104) + uint32_t _size111; + ::apache::thrift::protocol::TType _etype114; + xfer += iprot->readListBegin(_etype114, _size111); + this->success.resize(_size111); + uint32_t _i115; + for (_i115 = 0; _i115 < _size111; ++_i115) { - xfer += this->success[_i104].read(iprot); + xfer += this->success[_i115].read(iprot); } xfer += iprot->readListEnd(); } @@ -5294,10 +5589,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::workspace::experiment::DataObjectType> ::const_iterator _iter105; - for (_iter105 = this->success.begin(); _iter105 != this->success.end(); ++_iter105) + std::vector< ::apache::airavata::model::workspace::experiment::DataObjectType> ::const_iterator _iter116; + for (_iter116 = this->success.begin(); _iter116 != this->success.end(); ++_iter116) { - xfer += (*_iter105).write(oprot); + xfer += (*_iter116).write(oprot); } xfer += oprot->writeListEnd(); } @@ -5332,14 +5627,14 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size106; - ::apache::thrift::protocol::TType _etype109; - xfer += iprot->readListBegin(_etype109, _size106); - (*(this->success)).resize(_size106); - uint32_t _i110; - for (_i110 = 0; _i110 < _size106; ++_i110) + uint32_t _size117; + ::apache::thrift::protocol::TType _etype120; + xfer += iprot->readListBegin(_etype120, _size117); + (*(this->success)).resize(_size117); + uint32_t _i121; + for (_i121 = 0; _i121 < _size117; ++_i121) { - xfer += (*(this->success))[_i110].read(iprot); + xfer += (*(this->success))[_i121].read(iprot); } xfer += iprot->readListEnd(); } @@ -5453,17 +5748,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size111; - ::apache::thrift::protocol::TType _ktype112; - ::apache::thrift::protocol::TType _vtype113; - xfer += iprot->readMapBegin(_ktype112, _vtype113, _size111); - uint32_t _i115; - for (_i115 = 0; _i115 < _size111; ++_i115) + uint32_t _size122; + ::apache::thrift::protocol::TType _ktype123; + ::apache::thrift::protocol::TType _vtype124; + xfer += iprot->readMapBegin(_ktype123, _vtype124, _size122); + uint32_t _i126; + for (_i126 = 0; _i126 < _size122; ++_i126) { - std::string _key116; - xfer += iprot->readString(_key116); - ::apache::airavata::model::workspace::experiment::JobStatus& _val117 = this->success[_key116]; - xfer += _val117.read(iprot); + std::string _key127; + xfer += iprot->readString(_key127); + ::apache::airavata::model::workspace::experiment::JobStatus& _val128 = this->success[_key127]; + xfer += _val128.read(iprot); } xfer += iprot->readMapEnd(); } @@ -5494,11 +5789,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 _iter118; - for (_iter118 = this->success.begin(); _iter118 != this->success.end(); ++_iter118) + std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter129; + for (_iter129 = this->success.begin(); _iter129 != this->success.end(); ++_iter129) { - xfer += oprot->writeString(_iter118->first); - xfer += _iter118->second.write(oprot); + xfer += oprot->writeString(_iter129->first); + xfer += _iter129->second.write(oprot); } xfer += oprot->writeMapEnd(); } @@ -5533,17 +5828,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size119; - ::apache::thrift::protocol::TType _ktype120; - ::apache::thrift::protocol::TType _vtype121; - xfer += iprot->readMapBegin(_ktype120, _vtype121, _size119); - uint32_t _i123; - for (_i123 = 0; _i123 < _size119; ++_i123) + uint32_t _size130; + ::apache::thrift::protocol::TType _ktype131; + ::apache::thrift::protocol::TType _vtype132; + xfer += iprot->readMapBegin(_ktype131, _vtype132, _size130); + uint32_t _i134; + for (_i134 = 0; _i134 < _size130; ++_i134) { - std::string _key124; - xfer += iprot->readString(_key124); - ::apache::airavata::model::workspace::experiment::JobStatus& _val125 = (*(this->success))[_key124]; - xfer += _val125.read(iprot); + std::string _key135; + xfer += iprot->readString(_key135); + ::apache::airavata::model::workspace::experiment::JobStatus& _val136 = (*(this->success))[_key135]; + xfer += _val136.read(iprot); } xfer += iprot->readMapEnd(); } @@ -7975,14 +8270,14 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size126; - ::apache::thrift::protocol::TType _etype129; - xfer += iprot->readListBegin(_etype129, _size126); - this->success.resize(_size126); - uint32_t _i130; - for (_i130 = 0; _i130 < _size126; ++_i130) + uint32_t _size137; + ::apache::thrift::protocol::TType _etype140; + xfer += iprot->readListBegin(_etype140, _size137); + this->success.resize(_size137); + uint32_t _i141; + for (_i141 = 0; _i141 < _size137; ++_i141) { - xfer += iprot->readString(this->success[_i130]); + xfer += iprot->readString(this->success[_i141]); } xfer += iprot->readListEnd(); } @@ -8037,10 +8332,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 _iter131; - for (_iter131 = this->success.begin(); _iter131 != this->success.end(); ++_iter131) + std::vector<std::string> ::const_iterator _iter142; + for (_iter142 = this->success.begin(); _iter142 != this->success.end(); ++_iter142) { - xfer += oprot->writeString((*_iter131)); + xfer += oprot->writeString((*_iter142)); } xfer += oprot->writeListEnd(); } @@ -8087,14 +8382,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift:: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size132; - ::apache::thrift::protocol::TType _etype135; - xfer += iprot->readListBegin(_etype135, _size132); - (*(this->success)).resize(_size132); - uint32_t _i136; - for (_i136 = 0; _i136 < _size132; ++_i136) + uint32_t _size143; + ::apache::thrift::protocol::TType _etype146; + xfer += iprot->readListBegin(_etype146, _size143); + (*(this->success)).resize(_size143); + uint32_t _i147; + for (_i147 = 0; _i147 < _size143; ++_i147) { - xfer += iprot->readString((*(this->success))[_i136]); + xfer += iprot->readString((*(this->success))[_i147]); } xfer += iprot->readListEnd(); } @@ -9127,17 +9422,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift: if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size137; - ::apache::thrift::protocol::TType _ktype138; - ::apache::thrift::protocol::TType _vtype139; - xfer += iprot->readMapBegin(_ktype138, _vtype139, _size137); - uint32_t _i141; - for (_i141 = 0; _i141 < _size137; ++_i141) + uint32_t _size148; + ::apache::thrift::protocol::TType _ktype149; + ::apache::thrift::protocol::TType _vtype150; + xfer += iprot->readMapBegin(_ktype149, _vtype150, _size148); + uint32_t _i152; + for (_i152 = 0; _i152 < _size148; ++_i152) { - std::string _key142; - xfer += iprot->readString(_key142); - std::string& _val143 = this->success[_key142]; - xfer += iprot->readString(_val143); + std::string _key153; + xfer += iprot->readString(_key153); + std::string& _val154 = this->success[_key153]; + xfer += iprot->readString(_val154); } xfer += iprot->readMapEnd(); } @@ -9192,11 +9487,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 _iter144; - for (_iter144 = this->success.begin(); _iter144 != this->success.end(); ++_iter144) + std::map<std::string, std::string> ::const_iterator _iter155; + for (_iter155 = this->success.begin(); _iter155 != this->success.end(); ++_iter155) { - xfer += oprot->writeString(_iter144->first); - xfer += oprot->writeString(_iter144->second); + xfer += oprot->writeString(_iter155->first); + xfer += oprot->writeString(_iter155->second); } xfer += oprot->writeMapEnd(); } @@ -9243,17 +9538,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size145; - ::apache::thrift::protocol::TType _ktype146; - ::apache::thrift::protocol::TType _vtype147; - xfer += iprot->readMapBegin(_ktype146, _vtype147, _size145); - uint32_t _i149; - for (_i149 = 0; _i149 < _size145; ++_i149) + uint32_t _size156; + ::apache::thrift::protocol::TType _ktype157; + ::apache::thrift::protocol::TType _vtype158; + xfer += iprot->readMapBegin(_ktype157, _vtype158, _size156); + uint32_t _i160; + for (_i160 = 0; _i160 < _size156; ++_i160) { - std::string _key150; - xfer += iprot->readString(_key150); - std::string& _val151 = (*(this->success))[_key150]; - xfer += iprot->readString(_val151); + std::string _key161; + xfer += iprot->readString(_key161); + std::string& _val162 = (*(this->success))[_key161]; + xfer += iprot->readString(_val162); } xfer += iprot->readMapEnd(); } @@ -9367,14 +9662,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size152; - ::apache::thrift::protocol::TType _etype155; - xfer += iprot->readListBegin(_etype155, _size152); - this->success.resize(_size152); - uint32_t _i156; - for (_i156 = 0; _i156 < _size152; ++_i156) + uint32_t _size163; + ::apache::thrift::protocol::TType _etype166; + xfer += iprot->readListBegin(_etype166, _size163); + this->success.resize(_size163); + uint32_t _i167; + for (_i167 = 0; _i167 < _size163; ++_i167) { - xfer += this->success[_i156].read(iprot); + xfer += this->success[_i167].read(iprot); } xfer += iprot->readListEnd(); } @@ -9429,10 +9724,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 _iter157; - for (_iter157 = this->success.begin(); _iter157 != this->success.end(); ++_iter157) + std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter168; + for (_iter168 = this->success.begin(); _iter168 != this->success.end(); ++_iter168) { - xfer += (*_iter157).write(oprot); + xfer += (*_iter168).write(oprot); } xfer += oprot->writeListEnd(); } @@ -9479,14 +9774,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size158; - ::apache::thrift::protocol::TType _etype161; - xfer += iprot->readListBegin(_etype161, _size158); - (*(this->success)).resize(_size158); - uint32_t _i162; - for (_i162 = 0; _i162 < _size158; ++_i162) + uint32_t _size169; + ::apache::thrift::protocol::TType _etype172; + xfer += iprot->readListBegin(_etype172, _size169); + (*(this->success)).resize(_size169); + uint32_t _i173; + for (_i173 = 0; _i173 < _size169; ++_i173) { - xfer += (*(this->success))[_i162].read(iprot); + xfer += (*(this->success))[_i173].read(iprot); } xfer += iprot->readListEnd(); } @@ -9624,14 +9919,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol:: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size163; - ::apache::thrift::protocol::TType _etype166; - xfer += iprot->readListBegin(_etype166, _size163); - this->success.resize(_size163); - uint32_t _i167; - for (_i167 = 0; _i167 < _size163; ++_i167) + uint32_t _size174; + ::apache::thrift::protocol::TType _etype177; + xfer += iprot->readListBegin(_etype177, _size174); + this->success.resize(_size174); + uint32_t _i178; + for (_i178 = 0; _i178 < _size174; ++_i178) { - xfer += this->success[_i167].read(iprot); + xfer += this->success[_i178].read(iprot); } xfer += iprot->readListEnd(); } @@ -9686,10 +9981,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 _iter168; - for (_iter168 = this->success.begin(); _iter168 != this->success.end(); ++_iter168) + std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter179; + for (_iter179 = this->success.begin(); _iter179 != this->success.end(); ++_iter179) { - xfer += (*_iter168).write(oprot); + xfer += (*_iter179).write(oprot); } xfer += oprot->writeListEnd(); } @@ -9736,14 +10031,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size169; - ::apache::thrift::protocol::TType _etype172; - xfer += iprot->readListBegin(_etype172, _size169); - (*(this->success)).resize(_size169); - uint32_t _i173; - for (_i173 = 0; _i173 < _size169; ++_i173) + uint32_t _size180; + ::apache::thrift::protocol::TType _etype183; + xfer += iprot->readListBegin(_etype183, _size180); + (*(this->success)).resize(_size180); + uint32_t _i184; + for (_i184 = 0; _i184 < _size180; ++_i184) { - xfer += (*(this->success))[_i173].read(iprot); + xfer += (*(this->success))[_i184].read(iprot); } xfer += iprot->readListEnd(); } @@ -9881,14 +10176,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size174; - ::apache::thrift::protocol::TType _etype177; - xfer += iprot->readListBegin(_etype177, _size174); - this->success.resize(_size174); - uint32_t _i178; - for (_i178 = 0; _i178 < _size174; ++_i178) + uint32_t _size185; + ::apache::thrift::protocol::TType _etype188; + xfer += iprot->readListBegin(_etype188, _size185); + this->success.resize(_size185); + uint32_t _i189; + for (_i189 = 0; _i189 < _size185; ++_i189) { - xfer += this->success[_i178].read(iprot); + xfer += this->success[_i189].read(iprot); } xfer += iprot->readListEnd(); } @@ -9943,10 +10238,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 _iter179; - for (_iter179 = this->success.begin(); _iter179 != this->success.end(); ++_iter179) + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter190; + for (_iter190 = this->success.begin(); _iter190 != this->success.end(); ++_iter190) { - xfer += (*_iter179).write(oprot); + xfer += (*_iter190).write(oprot); } xfer += oprot->writeListEnd(); } @@ -9993,14 +10288,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size180; - ::apache::thrift::protocol::TType _etype183; - xfer += iprot->readListBegin(_etype183, _size180); - (*(this->success)).resize(_size180); - uint32_t _i184; - for (_i184 = 0; _i184 < _size180; ++_i184) + uint32_t _size191; + ::apache::thrift::protocol::TType _etype194; + xfer += iprot->readListBegin(_etype194, _size191); + (*(this->success)).resize(_size191); + uint32_t _i195; + for (_i195 = 0; _i195 < _size191; ++_i195) { - xfer += (*(this->success))[_i184].read(iprot); + xfer += (*(this->success))[_i195].read(iprot); } xfer += iprot->readListEnd(); } @@ -10138,17 +10433,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size185; - ::apache::thrift::protocol::TType _ktype186; - ::apache::thrift::protocol::TType _vtype187; - xfer += iprot->readMapBegin(_ktype186, _vtype187, _size185); - uint32_t _i189; - for (_i189 = 0; _i189 < _size185; ++_i189) + uint32_t _size196; + ::apache::thrift::protocol::TType _ktype197; + ::apache::thrift::protocol::TType _vtype198; + xfer += iprot->readMapBegin(_ktype197, _vtype198, _size196); + uint32_t _i200; + for (_i200 = 0; _i200 < _size196; ++_i200) { - std::string _key190; - xfer += iprot->readString(_key190); - std::string& _val191 = this->success[_key190]; - xfer += iprot->readString(_val191); + std::string _key201; + xfer += iprot->readString(_key201); + std::string& _val202 = this->success[_key201]; + xfer += iprot->readString(_val202); } xfer += iprot->readMapEnd(); } @@ -10203,11 +10498,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 _iter192; - for (_iter192 = this->success.begin(); _iter192 != this->success.end(); ++_iter192) + std::map<std::string, std::string> ::const_iterator _iter203; + for (_iter203 = this->success.begin(); _iter203 != this->success.end(); ++_iter203) { - xfer += oprot->writeString(_iter192->first); - xfer += oprot->writeString(_iter192->second); + xfer += oprot->writeString(_iter203->first); + xfer += oprot->writeString(_iter203->second); } xfer += oprot->writeMapEnd(); } @@ -10254,17 +10549,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size193; - ::apache::thrift::protocol::TType _ktype194; - ::apache::thrift::protocol::TType _vtype195; - xfer += iprot->readMapBegin(_ktype194, _vtype195, _size193); - uint32_t _i197; - for (_i197 = 0; _i197 < _size193; ++_i197) + 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 _key198; - xfer += iprot->readString(_key198); - std::string& _val199 = (*(this->success))[_key198]; - xfer += iprot->readString(_val199); + std::string _key209; + xfer += iprot->readString(_key209); + std::string& _val210 = (*(this->success))[_key209]; + xfer += iprot->readString(_val210); } xfer += iprot->readMapEnd(); } @@ -10828,17 +11123,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->success.clear(); - uint32_t _size200; - ::apache::thrift::protocol::TType _ktype201; - ::apache::thrift::protocol::TType _vtype202; - xfer += iprot->readMapBegin(_ktype201, _vtype202, _size200); - uint32_t _i204; - for (_i204 = 0; _i204 < _size200; ++_i204) + 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) { - std::string _key205; - xfer += iprot->readString(_key205); - std::string& _val206 = this->success[_key205]; - xfer += iprot->readString(_val206); + std::string _key216; + xfer += iprot->readString(_key216); + std::string& _val217 = this->success[_key216]; + xfer += iprot->readString(_val217); } xfer += iprot->readMapEnd(); } @@ -10893,11 +11188,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 _iter207; - for (_iter207 = this->success.begin(); _iter207 != this->success.end(); ++_iter207) + std::map<std::string, std::string> ::const_iterator _iter218; + for (_iter218 = this->success.begin(); _iter218 != this->success.end(); ++_iter218) { - xfer += oprot->writeString(_iter207->first); - xfer += oprot->writeString(_iter207->second); + xfer += oprot->writeString(_iter218->first); + xfer += oprot->writeString(_iter218->second); } xfer += oprot->writeMapEnd(); } @@ -10944,17 +11239,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_MAP) { { (*(this->success)).clear(); - uint32_t _size208; - ::apache::thrift::protocol::TType _ktype209; - ::apache::thrift::protocol::TType _vtype210; - xfer += iprot->readMapBegin(_ktype209, _vtype210, _size208); - uint32_t _i212; - for (_i212 = 0; _i212 < _size208; ++_i212) + uint32_t _size219; + ::apache::thrift::protocol::TType _ktype220; + ::apache::thrift::protocol::TType _vtype221; + xfer += iprot->readMapBegin(_ktype220, _vtype221, _size219); + uint32_t _i223; + for (_i223 = 0; _i223 < _size219; ++_i223) { - std::string _key213; - xfer += iprot->readString(_key213); - std::string& _val214 = (*(this->success))[_key213]; - xfer += iprot->readString(_val214); + std::string _key224; + xfer += iprot->readString(_key224); + std::string& _val225 = (*(this->success))[_key224]; + xfer += iprot->readString(_val225); } xfer += iprot->readMapEnd(); } @@ -15023,17 +15318,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro if (ftype == ::apache::thrift::protocol::T_MAP) { { this->jobSubmissionPriorityMap.clear(); - uint32_t _size215; - ::apache::thrift::protocol::TType _ktype216; - ::apache::thrift::protocol::TType _vtype217; - xfer += iprot->readMapBegin(_ktype216, _vtype217, _size215); - uint32_t _i219; - for (_i219 = 0; _i219 < _size215; ++_i219) + uint32_t _size226; + ::apache::thrift::protocol::TType _ktype227; + ::apache::thrift::protocol::TType _vtype228; + xfer += iprot->readMapBegin(_ktype227, _vtype228, _size226); + uint32_t _i230; + for (_i230 = 0; _i230 < _size226; ++_i230) { - std::string _key220; - xfer += iprot->readString(_key220); - int32_t& _val221 = this->jobSubmissionPriorityMap[_key220]; - xfer += iprot->readI32(_val221); + std::string _key231; + xfer += iprot->readString(_key231); + int32_t& _val232 = this->jobSubmissionPriorityMap[_key231]; + xfer += iprot->readI32(_val232); } xfer += iprot->readMapEnd(); } @@ -15063,11 +15358,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 _iter222; - for (_iter222 = this->jobSubmissionPriorityMap.begin(); _iter222 != this->jobSubmissionPriorityMap.end(); ++_iter222) + std::map<std::string, int32_t> ::const_iterator _iter233; + for (_iter233 = this->jobSubmissionPriorityMap.begin(); _iter233 != this->jobSubmissionPriorityMap.end(); ++_iter233) { - xfer += oprot->writeString(_iter222->first); - xfer += oprot->writeI32(_iter222->second); + xfer += oprot->writeString(_iter233->first); + xfer += oprot->writeI32(_iter233->second); } xfer += oprot->writeMapEnd(); } @@ -15085,11 +15380,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 _iter223; - for (_iter223 = (*(this->jobSubmissionPriorityMap)).begin(); _iter223 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter223) + std::map<std::string, int32_t> ::const_iterator _iter234; + for (_iter234 = (*(this->jobSubmissionPriorityMap)).begin(); _iter234 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter234) { - xfer += oprot->writeString(_iter223->first); - xfer += oprot->writeI32(_iter223->second); + xfer += oprot->writeString(_iter234->first); + xfer += oprot->writeI32(_iter234->second); } xfer += oprot->writeMapEnd(); } @@ -15281,17 +15576,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->dataMovementPriorityMap.clear(); - uint32_t _size224; - ::apache::thrift::protocol::TType _ktype225; - ::apache::thrift::protocol::TType _vtype226; - xfer += iprot->readMapBegin(_ktype225, _vtype226, _size224); - uint32_t _i228; - for (_i228 = 0; _i228 < _size224; ++_i228) + uint32_t _size235; + ::apache::thrift::protocol::TType _ktype236; + ::apache::thrift::protocol::TType _vtype237; + xfer += iprot->readMapBegin(_ktype236, _vtype237, _size235); + uint32_t _i239; + for (_i239 = 0; _i239 < _size235; ++_i239) { - std::string _key229; - xfer += iprot->readString(_key229); - int32_t& _val230 = this->dataMovementPriorityMap[_key229]; - xfer += iprot->readI32(_val230); + std::string _key240; + xfer += iprot->readString(_key240); + int32_t& _val241 = this->dataMovementPriorityMap[_key240]; + xfer += iprot->readI32(_val241); } xfer += iprot->readMapEnd(); } @@ -15321,11 +15616,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 _iter231; - for (_iter231 = this->dataMovementPriorityMap.begin(); _iter231 != this->dataMovementPriorityMap.end(); ++_iter231) + std::map<std::string, int32_t> ::const_iterator _iter242; + for (_iter242 = this->dataMovementPriorityMap.begin(); _iter242 != this->dataMovementPriorityMap.end(); ++_iter242) { - xfer += oprot->writeString(_iter231->first); - xfer += oprot->writeI32(_iter231->second); + xfer += oprot->writeString(_iter242->first); + xfer += oprot->writeI32(_iter242->second); } xfer += oprot->writeMapEnd(); } @@ -15343,11 +15638,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 _iter232; - for (_iter232 = (*(this->dataMovementPriorityMap)).begin(); _iter232 != (*(this->dataMovementPriorityMap)).end(); ++_iter232) + std::map<std::string, int32_t> ::const_iterator _iter243; + for (_iter243 = (*(this->dataMovementPriorityMap)).begin(); _iter243 != (*(this->dataMovementPriorityMap)).end(); ++_iter243) { - xfer += oprot->writeString(_iter232->first); - xfer += oprot->writeI32(_iter232->second); + xfer += oprot->writeString(_iter243->first); + xfer += oprot->writeI32(_iter243->second); } xfer += oprot->writeMapEnd(); } @@ -17483,14 +17778,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size233; - ::apache::thrift::protocol::TType _etype236; - xfer += iprot->readListBegin(_etype236, _size233); - this->success.resize(_size233); - uint32_t _i237; - for (_i237 = 0; _i237 < _size233; ++_i237) + uint32_t _size244; + ::apache::thrift::protocol::TType _etype247; + xfer += iprot->readListBegin(_etype247, _size244); + this->success.resize(_size244); + uint32_t _i248; + for (_i248 = 0; _i248 < _size244; ++_i248) { - xfer += this->success[_i237].read(iprot); + xfer += this->success[_i248].read(iprot); } xfer += iprot->readListEnd(); } @@ -17545,10 +17840,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 _iter238; - for (_iter238 = this->success.begin(); _iter238 != this->success.end(); ++_iter238) + std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter249; + for (_iter249 = this->success.begin(); _iter249 != this->success.end(); ++_iter249) { - xfer += (*_iter238).write(oprot); + xfer += (*_iter249).write(oprot); } xfer += oprot->writeListEnd(); } @@ -17595,14 +17890,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size239; - ::apache::thrift::protocol::TType _etype242; - xfer += iprot->readListBegin(_etype242, _size239); - (*(this->success)).resize(_size239); - uint32_t _i243; - for (_i243 = 0; _i243 < _size239; ++_i243) + uint32_t _size250; + ::apache::thrift::protocol::TType _etype253; + xfer += iprot->readListBegin(_etype253, _size250); + (*(this->success)).resize(_size250); + uint32_t _i254; + for (_i254 = 0; _i254 < _size250; ++_i254) { - xfer += (*(this->success))[_i243].read(iprot); + xfer += (*(this->success))[_i254].read(iprot); } xfer += iprot->readListEnd(); } @@ -18898,6 +19193,75 @@ void AiravataClient::recv_searchExperimentsByStatus(std::vector< ::apache::airav throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperimentsByStatus failed: unknown result"); } +void AiravataClient::searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) +{ + send_searchExperimentsByCreationTime(userName, fromTime, toTime); + recv_searchExperimentsByCreationTime(_return); +} + +void AiravataClient::send_searchExperimentsByCreationTime(const std::string& userName, const int64_t fromTime, const int64_t toTime) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("searchExperimentsByCreationTime", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_searchExperimentsByCreationTime_pargs args; + args.userName = &userName; + args.fromTime = &fromTime; + args.toTime = &toTime; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_searchExperimentsByCreationTime(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("searchExperimentsByCreationTime") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchExperimentsByCreationTime_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, "searchExperimentsByCreationTime failed: unknown result"); +} + void AiravataClient::getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) { send_getAllExperimentsInProject(projectId); @@ -23902,6 +24266,69 @@ void AiravataProcessor::process_searchExperimentsByStatus(int32_t seqid, ::apach } } +void AiravataProcessor::process_searchExperimentsByCreationTime(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.searchExperimentsByCreationTime", callContext); + } + ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.searchExperimentsByCreationTime"); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preRead(ctx, "Airavata.searchExperimentsByCreationTime"); + } + + Airavata_searchExperimentsByCreationTime_args args; + args.read(iprot); + iprot->readMessageEnd(); + uint32_t bytes = iprot->getTransport()->readEnd(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postRead(ctx, "Airavata.searchExperimentsByCreationTime", bytes); + } + + Airavata_searchExperimentsByCreationTime_result result; + try { + iface_->searchExperimentsByCreationTime(result.success, args.userName, args.fromTime, args.toTime); + 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.searchExperimentsByCreationTime"); + } + + ::apache::thrift::TApplicationException x(e.what()); + oprot->writeMessageBegin("searchExperimentsByCreationTime", ::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.searchExperimentsByCreationTime"); + } + + oprot->writeMessageBegin("searchExperimentsByCreationTime", ::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.searchExperimentsByCreationTime", bytes); + } +} + void AiravataProcessor::process_getAllExperimentsInProject(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/9c1f44d0/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 bd09cc7..727ae9e 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 @@ -43,6 +43,7 @@ class AiravataIf { virtual void searchExperimentsByDesc(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const std::string& description) = 0; virtual void searchExperimentsByApplication(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const std::string& applicationId) = 0; virtual void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState) = 0; + virtual void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) = 0; virtual void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) = 0; virtual void getAllUserExperiments(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& userName) = 0; virtual void createExperiment(std::string& _return, const ::apache::airavata::model::workspace::experiment::Experiment& experiment) = 0; @@ -169,6 +170,9 @@ class AiravataNull : virtual public AiravataIf { void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & /* _return */, const std::string& /* userName */, const ::apache::airavata::model::workspace::experiment::ExperimentState::type /* experimentState */) { return; } + void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & /* _return */, const std::string& /* userName */, const int64_t /* fromTime */, const int64_t /* toTime */) { + return; + } void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & /* _return */, const std::string& /* projectId */) { return; } @@ -1906,6 +1910,154 @@ class Airavata_searchExperimentsByStatus_presult { }; +class Airavata_searchExperimentsByCreationTime_args { + public: + + Airavata_searchExperimentsByCreationTime_args() : userName(), fromTime(0), toTime(0) { + } + + virtual ~Airavata_searchExperimentsByCreationTime_args() throw() {} + + std::string userName; + int64_t fromTime; + int64_t toTime; + + void __set_userName(const std::string& val) { + userName = val; + } + + void __set_fromTime(const int64_t val) { + fromTime = val; + } + + void __set_toTime(const int64_t val) { + toTime = val; + } + + bool operator == (const Airavata_searchExperimentsByCreationTime_args & rhs) const + { + if (!(userName == rhs.userName)) + return false; + if (!(fromTime == rhs.fromTime)) + return false; + if (!(toTime == rhs.toTime)) + return false; + return true; + } + bool operator != (const Airavata_searchExperimentsByCreationTime_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_searchExperimentsByCreationTime_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_searchExperimentsByCreationTime_pargs { + public: + + + virtual ~Airavata_searchExperimentsByCreationTime_pargs() throw() {} + + const std::string* userName; + const int64_t* fromTime; + const int64_t* toTime; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_searchExperimentsByCreationTime_result__isset { + _Airavata_searchExperimentsByCreationTime_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_searchExperimentsByCreationTime_result__isset; + +class Airavata_searchExperimentsByCreationTime_result { + public: + + Airavata_searchExperimentsByCreationTime_result() { + } + + virtual ~Airavata_searchExperimentsByCreationTime_result() throw() {} + + std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_searchExperimentsByCreationTime_result__isset __isset; + + void __set_success(const std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = 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_searchExperimentsByCreationTime_result & rhs) const + { + if (!(success == rhs.success)) + return false; + if (!(ire == rhs.ire)) + return false; + if (!(ace == rhs.ace)) + return false; + if (!(ase == rhs.ase)) + return false; + return true; + } + bool operator != (const Airavata_searchExperimentsByCreationTime_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_searchExperimentsByCreationTime_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_searchExperimentsByCreationTime_presult__isset { + _Airavata_searchExperimentsByCreationTime_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_searchExperimentsByCreationTime_presult__isset; + +class Airavata_searchExperimentsByCreationTime_presult { + public: + + + virtual ~Airavata_searchExperimentsByCreationTime_presult() throw() {} + + std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> * success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_searchExperimentsByCreationTime_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class Airavata_getAllExperimentsInProject_args { public: @@ -10583,6 +10735,9 @@ class AiravataClient : virtual public AiravataIf { void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState); void send_searchExperimentsByStatus(const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState); void recv_searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return); + void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime); + void send_searchExperimentsByCreationTime(const std::string& userName, const int64_t fromTime, const int64_t toTime); + void recv_searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return); void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId); void send_getAllExperimentsInProject(const std::string& projectId); void recv_getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return); @@ -10801,6 +10956,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { void process_searchExperimentsByDesc(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_searchExperimentsByApplication(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_searchExperimentsByStatus(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_searchExperimentsByCreationTime(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getAllExperimentsInProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getAllUserExperiments(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_createExperiment(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); @@ -10879,6 +11035,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { processMap_["searchExperimentsByDesc"] = &AiravataProcessor::process_searchExperimentsByDesc; processMap_["searchExperimentsByApplication"] = &AiravataProcessor::process_searchExperimentsByApplication; processMap_["searchExperimentsByStatus"] = &AiravataProcessor::process_searchExperimentsByStatus; + processMap_["searchExperimentsByCreationTime"] = &AiravataProcessor::process_searchExperimentsByCreationTime; processMap_["getAllExperimentsInProject"] = &AiravataProcessor::process_getAllExperimentsInProject; processMap_["getAllUserExperiments"] = &AiravataProcessor::process_getAllUserExperiments; processMap_["createExperiment"] = &AiravataProcessor::process_createExperiment; @@ -11080,6 +11237,16 @@ class AiravataMultiface : virtual public AiravataIf { return; } + void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->searchExperimentsByCreationTime(_return, userName, fromTime, toTime); + } + ifaces_[i]->searchExperimentsByCreationTime(_return, userName, fromTime, toTime); + return; + } + void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) { size_t sz = ifaces_.size(); size_t i = 0; http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 2106a0b..a9a0b83 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 @@ -94,6 +94,11 @@ class AiravataHandler : virtual public AiravataIf { printf("searchExperimentsByStatus\n"); } + void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) { + // Your implementation goes here + printf("searchExperimentsByCreationTime\n"); + } + void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) { // Your implementation goes here printf("getAllExperimentsInProject\n");
