http://git-wip-us.apache.org/repos/asf/airavata/blob/d84783da/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 160b94f..875474e 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 @@ -33275,11 +33275,11 @@ uint32_t Airavata_addGatewayComputeResourcePreference_presult::read(::apache::th } -Airavata_getGatewayComputeResourcePreference_args::~Airavata_getGatewayComputeResourcePreference_args() throw() { +Airavata_addGatewayDataStoragePreference_args::~Airavata_addGatewayDataStoragePreference_args() throw() { } -uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addGatewayDataStoragePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33292,7 +33292,8 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrif bool isset_authzToken = false; bool isset_gatewayID = false; - bool isset_computeResourceId = false; + bool isset_dataMoveId = false; + bool isset_dataStoragePreference = false; while (true) { @@ -33320,8 +33321,16 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrif break; case 3: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; + xfer += iprot->readString(this->dataMoveId); + isset_dataMoveId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->dataStoragePreference.read(iprot); + isset_dataStoragePreference = true; } else { xfer += iprot->skip(ftype); } @@ -33339,15 +33348,17 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrif throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourceId) + if (!isset_dataMoveId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_dataStoragePreference) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addGatewayDataStoragePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_args"); + xfer += oprot->writeStructBegin("Airavata_addGatewayDataStoragePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); @@ -33357,8 +33368,12 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::write(::apache::thri xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->dataMoveId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataStoragePreference", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->dataStoragePreference.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -33368,14 +33383,14 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::write(::apache::thri } -Airavata_getGatewayComputeResourcePreference_pargs::~Airavata_getGatewayComputeResourcePreference_pargs() throw() { +Airavata_addGatewayDataStoragePreference_pargs::~Airavata_addGatewayDataStoragePreference_pargs() throw() { } -uint32_t Airavata_getGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addGatewayDataStoragePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_pargs"); + xfer += oprot->writeStructBegin("Airavata_addGatewayDataStoragePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); @@ -33385,8 +33400,12 @@ uint32_t Airavata_getGatewayComputeResourcePreference_pargs::write(::apache::thr xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->dataMoveId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataStoragePreference", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += (*(this->dataStoragePreference)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -33396,11 +33415,11 @@ uint32_t Airavata_getGatewayComputeResourcePreference_pargs::write(::apache::thr } -Airavata_getGatewayComputeResourcePreference_result::~Airavata_getGatewayComputeResourcePreference_result() throw() { +Airavata_addGatewayDataStoragePreference_result::~Airavata_addGatewayDataStoragePreference_result() throw() { } -uint32_t Airavata_getGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addGatewayDataStoragePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33421,8 +33440,8 @@ uint32_t Airavata_getGatewayComputeResourcePreference_result::read(::apache::thr switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->success.read(iprot); + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -33472,15 +33491,15 @@ uint32_t Airavata_getGatewayComputeResourcePreference_result::read(::apache::thr return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addGatewayDataStoragePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_addGatewayDataStoragePreference_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); - xfer += this->success.write(oprot); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); + xfer += oprot->writeBool(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -33505,11 +33524,11 @@ uint32_t Airavata_getGatewayComputeResourcePreference_result::write(::apache::th } -Airavata_getGatewayComputeResourcePreference_presult::~Airavata_getGatewayComputeResourcePreference_presult() throw() { +Airavata_addGatewayDataStoragePreference_presult::~Airavata_addGatewayDataStoragePreference_presult() throw() { } -uint32_t Airavata_getGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addGatewayDataStoragePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33530,8 +33549,8 @@ uint32_t Airavata_getGatewayComputeResourcePreference_presult::read(::apache::th switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += (*(this->success)).read(iprot); + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -33582,11 +33601,11 @@ uint32_t Airavata_getGatewayComputeResourcePreference_presult::read(::apache::th } -Airavata_getAllGatewayComputeResourcePreferences_args::~Airavata_getAllGatewayComputeResourcePreferences_args() throw() { +Airavata_getGatewayComputeResourcePreference_args::~Airavata_getGatewayComputeResourcePreference_args() throw() { } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33599,6 +33618,7 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::t bool isset_authzToken = false; bool isset_gatewayID = false; + bool isset_computeResourceId = false; while (true) { @@ -33624,6 +33644,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::t xfer += iprot->skip(ftype); } break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -33637,13 +33665,15 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::t throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_computeResourceId) + throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_args"); + xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); @@ -33653,6 +33683,10 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::write(::apache:: xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -33660,14 +33694,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::write(::apache:: } -Airavata_getAllGatewayComputeResourcePreferences_pargs::~Airavata_getAllGatewayComputeResourcePreferences_pargs() throw() { +Airavata_getGatewayComputeResourcePreference_pargs::~Airavata_getGatewayComputeResourcePreference_pargs() throw() { } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_pargs"); + xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); @@ -33677,6 +33711,10 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_pargs::write(::apache: xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -33684,11 +33722,11 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_pargs::write(::apache: } -Airavata_getAllGatewayComputeResourcePreferences_result::~Airavata_getAllGatewayComputeResourcePreferences_result() throw() { +Airavata_getGatewayComputeResourcePreference_result::~Airavata_getGatewayComputeResourcePreference_result() throw() { } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33709,20 +33747,8 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache: switch (fid) { case 0: - 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) - { - xfer += this->success[_i339].read(iprot); - } - xfer += iprot->readListEnd(); - } + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -33772,23 +33798,15 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache: return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_result"); + xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter340; - for (_iter340 = this->success.begin(); _iter340 != this->success.end(); ++_iter340) - { - xfer += (*_iter340).write(oprot); - } - xfer += oprot->writeListEnd(); - } + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); + xfer += this->success.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -33813,11 +33831,11 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::write(::apache } -Airavata_getAllGatewayComputeResourcePreferences_presult::~Airavata_getAllGatewayComputeResourcePreferences_presult() throw() { +Airavata_getGatewayComputeResourcePreference_presult::~Airavata_getGatewayComputeResourcePreference_presult() throw() { } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33838,20 +33856,8 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - (*(this->success)).clear(); - uint32_t _size341; - ::apache::thrift::protocol::TType _etype344; - xfer += iprot->readListBegin(_etype344, _size341); - (*(this->success)).resize(_size341); - uint32_t _i345; - for (_i345 = 0; _i345 < _size341; ++_i345) - { - xfer += (*(this->success))[_i345].read(iprot); - } - xfer += iprot->readListEnd(); - } + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -33902,11 +33908,11 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache } -Airavata_getAllGatewayComputeResources_args::~Airavata_getAllGatewayComputeResources_args() throw() { +Airavata_getGatewayDataStoragePreference_args::~Airavata_getGatewayDataStoragePreference_args() throw() { } -uint32_t Airavata_getAllGatewayComputeResources_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayDataStoragePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -33918,6 +33924,8 @@ uint32_t Airavata_getAllGatewayComputeResources_args::read(::apache::thrift::pro using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; + bool isset_gatewayID = false; + bool isset_dataMoveId = false; while (true) { @@ -33935,6 +33943,22 @@ uint32_t Airavata_getAllGatewayComputeResources_args::read(::apache::thrift::pro xfer += iprot->skip(ftype); } break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->dataMoveId); + isset_dataMoveId = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -33946,18 +33970,30 @@ uint32_t Airavata_getAllGatewayComputeResources_args::read(::apache::thrift::pro if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_gatewayID) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_dataMoveId) + throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getAllGatewayComputeResources_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayDataStoragePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResources_args"); + xfer += oprot->writeStructBegin("Airavata_getGatewayDataStoragePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->dataMoveId); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -33965,19 +34001,27 @@ uint32_t Airavata_getAllGatewayComputeResources_args::write(::apache::thrift::pr } -Airavata_getAllGatewayComputeResources_pargs::~Airavata_getAllGatewayComputeResources_pargs() throw() { +Airavata_getGatewayDataStoragePreference_pargs::~Airavata_getGatewayDataStoragePreference_pargs() throw() { } -uint32_t Airavata_getAllGatewayComputeResources_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayDataStoragePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResources_pargs"); + xfer += oprot->writeStructBegin("Airavata_getGatewayDataStoragePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->dataMoveId))); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -33985,11 +34029,11 @@ uint32_t Airavata_getAllGatewayComputeResources_pargs::write(::apache::thrift::p } -Airavata_getAllGatewayComputeResources_result::~Airavata_getAllGatewayComputeResources_result() throw() { +Airavata_getGatewayDataStoragePreference_result::~Airavata_getGatewayDataStoragePreference_result() throw() { } -uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayDataStoragePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34010,20 +34054,8 @@ uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::p switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->success.clear(); - uint32_t _size346; - ::apache::thrift::protocol::TType _etype349; - xfer += iprot->readListBegin(_etype349, _size346); - this->success.resize(_size346); - uint32_t _i350; - for (_i350 = 0; _i350 < _size346; ++_i350) - { - xfer += this->success[_i350].read(iprot); - } - xfer += iprot->readListEnd(); - } + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -34073,23 +34105,15 @@ uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::p return xfer; } -uint32_t Airavata_getAllGatewayComputeResources_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayDataStoragePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResources_result"); + xfer += oprot->writeStructBegin("Airavata_getGatewayDataStoragePreference_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); - std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::GatewayResourceProfile> ::const_iterator _iter351; - for (_iter351 = this->success.begin(); _iter351 != this->success.end(); ++_iter351) - { - xfer += (*_iter351).write(oprot); - } - xfer += oprot->writeListEnd(); - } + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); + xfer += this->success.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -34114,11 +34138,11 @@ uint32_t Airavata_getAllGatewayComputeResources_result::write(::apache::thrift:: } -Airavata_getAllGatewayComputeResources_presult::~Airavata_getAllGatewayComputeResources_presult() throw() { +Airavata_getGatewayDataStoragePreference_presult::~Airavata_getGatewayDataStoragePreference_presult() throw() { } -uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayDataStoragePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34139,20 +34163,8 @@ uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift:: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - (*(this->success)).clear(); - uint32_t _size352; - ::apache::thrift::protocol::TType _etype355; - xfer += iprot->readListBegin(_etype355, _size352); - (*(this->success)).resize(_size352); - uint32_t _i356; - for (_i356 = 0; _i356 < _size352; ++_i356) - { - xfer += (*(this->success))[_i356].read(iprot); - } - xfer += iprot->readListEnd(); - } + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -34203,11 +34215,11 @@ uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift:: } -Airavata_updateGatewayComputeResourcePreference_args::~Airavata_updateGatewayComputeResourcePreference_args() throw() { +Airavata_getAllGatewayComputeResourcePreferences_args::~Airavata_getAllGatewayComputeResourcePreferences_args() throw() { } -uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34220,8 +34232,6 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::th bool isset_authzToken = false; bool isset_gatewayID = false; - bool isset_computeResourceId = false; - bool isset_computeResourcePreference = false; while (true) { @@ -34247,22 +34257,6 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::th xfer += iprot->skip(ftype); } break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->computeResourcePreference.read(iprot); - isset_computeResourcePreference = true; - } else { - xfer += iprot->skip(ftype); - } - break; default: xfer += iprot->skip(ftype); break; @@ -34276,17 +34270,13 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::th throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourcePreference) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_args"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); @@ -34296,14 +34286,6 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::write(::apache::t xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 4); - xfer += this->computeResourcePreference.write(oprot); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -34311,14 +34293,14 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::write(::apache::t } -Airavata_updateGatewayComputeResourcePreference_pargs::~Airavata_updateGatewayComputeResourcePreference_pargs() throw() { +Airavata_getAllGatewayComputeResourcePreferences_pargs::~Airavata_getAllGatewayComputeResourcePreferences_pargs() throw() { } -uint32_t Airavata_updateGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayComputeResourcePreferences_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_pargs"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); @@ -34328,14 +34310,6 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_pargs::write(::apache:: xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 4); - xfer += (*(this->computeResourcePreference)).write(oprot); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -34343,11 +34317,11 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_pargs::write(::apache:: } -Airavata_updateGatewayComputeResourcePreference_result::~Airavata_updateGatewayComputeResourcePreference_result() throw() { +Airavata_getAllGatewayComputeResourcePreferences_result::~Airavata_getAllGatewayComputeResourcePreferences_result() throw() { } -uint32_t Airavata_updateGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34368,8 +34342,20 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_result::read(::apache:: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + 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) + { + xfer += this->success[_i339].read(iprot); + } + xfer += iprot->readListEnd(); + } this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -34419,15 +34405,23 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_result::read(::apache:: return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); - xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); + std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter340; + for (_iter340 = this->success.begin(); _iter340 != this->success.end(); ++_iter340) + { + xfer += (*_iter340).write(oprot); + } + xfer += oprot->writeListEnd(); + } xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -34452,11 +34446,11 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_result::write(::apache: } -Airavata_updateGatewayComputeResourcePreference_presult::~Airavata_updateGatewayComputeResourcePreference_presult() throw() { +Airavata_getAllGatewayComputeResourcePreferences_presult::~Airavata_getAllGatewayComputeResourcePreferences_presult() throw() { } -uint32_t Airavata_updateGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34477,8 +34471,20 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_presult::read(::apache: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + (*(this->success)).clear(); + uint32_t _size341; + ::apache::thrift::protocol::TType _etype344; + xfer += iprot->readListBegin(_etype344, _size341); + (*(this->success)).resize(_size341); + uint32_t _i345; + for (_i345 = 0; _i345 < _size341; ++_i345) + { + xfer += (*(this->success))[_i345].read(iprot); + } + xfer += iprot->readListEnd(); + } this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -34529,11 +34535,11 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_presult::read(::apache: } -Airavata_deleteGatewayComputeResourcePreference_args::~Airavata_deleteGatewayComputeResourcePreference_args() throw() { +Airavata_getAllGatewayDataStoragePreferences_args::~Airavata_getAllGatewayDataStoragePreferences_args() throw() { } -uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayDataStoragePreferences_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34546,7 +34552,6 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::th bool isset_authzToken = false; bool isset_gatewayID = false; - bool isset_computeResourceId = false; while (true) { @@ -34572,14 +34577,6 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::th xfer += iprot->skip(ftype); } break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; default: xfer += iprot->skip(ftype); break; @@ -34593,15 +34590,13 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::th throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayDataStoragePreferences_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_args"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayDataStoragePreferences_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); @@ -34611,10 +34606,6 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::write(::apache::t xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -34622,14 +34613,14 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::write(::apache::t } -Airavata_deleteGatewayComputeResourcePreference_pargs::~Airavata_deleteGatewayComputeResourcePreference_pargs() throw() { +Airavata_getAllGatewayDataStoragePreferences_pargs::~Airavata_getAllGatewayDataStoragePreferences_pargs() throw() { } -uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayDataStoragePreferences_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_pargs"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayDataStoragePreferences_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); @@ -34639,10 +34630,6 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache:: xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -34650,11 +34637,11 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache:: } -Airavata_deleteGatewayComputeResourcePreference_result::~Airavata_deleteGatewayComputeResourcePreference_result() throw() { +Airavata_getAllGatewayDataStoragePreferences_result::~Airavata_getAllGatewayDataStoragePreferences_result() throw() { } -uint32_t Airavata_deleteGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayDataStoragePreferences_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34675,8 +34662,20 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_result::read(::apache:: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->success.clear(); + uint32_t _size346; + ::apache::thrift::protocol::TType _etype349; + xfer += iprot->readListBegin(_etype349, _size346); + this->success.resize(_size346); + uint32_t _i350; + for (_i350 = 0; _i350 < _size346; ++_i350) + { + xfer += this->success[_i350].read(iprot); + } + xfer += iprot->readListEnd(); + } this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -34726,15 +34725,23 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_result::read(::apache:: return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayDataStoragePreferences_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayDataStoragePreferences_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); - xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size())); + std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::DataStoragePreference> ::const_iterator _iter351; + for (_iter351 = this->success.begin(); _iter351 != this->success.end(); ++_iter351) + { + xfer += (*_iter351).write(oprot); + } + xfer += oprot->writeListEnd(); + } xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -34759,11 +34766,11 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_result::write(::apache: } -Airavata_deleteGatewayComputeResourcePreference_presult::~Airavata_deleteGatewayComputeResourcePreference_presult() throw() { +Airavata_getAllGatewayDataStoragePreferences_presult::~Airavata_getAllGatewayDataStoragePreferences_presult() throw() { } -uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayDataStoragePreferences_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34784,8 +34791,20 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + (*(this->success)).clear(); + uint32_t _size352; + ::apache::thrift::protocol::TType _etype355; + xfer += iprot->readListBegin(_etype355, _size352); + (*(this->success)).resize(_size352); + uint32_t _i356; + for (_i356 = 0; _i356 < _size352; ++_i356) + { + xfer += (*(this->success))[_i356].read(iprot); + } + xfer += iprot->readListEnd(); + } this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -34836,11 +34855,11 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache: } -Airavata_getAllWorkflows_args::~Airavata_getAllWorkflows_args() throw() { +Airavata_getAllGatewayComputeResources_args::~Airavata_getAllGatewayComputeResources_args() throw() { } -uint32_t Airavata_getAllWorkflows_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayComputeResources_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34852,7 +34871,6 @@ uint32_t Airavata_getAllWorkflows_args::read(::apache::thrift::protocol::TProtoc using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_gatewayId = false; while (true) { @@ -34870,14 +34888,6 @@ uint32_t Airavata_getAllWorkflows_args::read(::apache::thrift::protocol::TProtoc xfer += iprot->skip(ftype); } break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->gatewayId); - isset_gatewayId = true; - } else { - xfer += iprot->skip(ftype); - } - break; default: xfer += iprot->skip(ftype); break; @@ -34889,24 +34899,18 @@ uint32_t Airavata_getAllWorkflows_args::read(::apache::thrift::protocol::TProtoc if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_gatewayId) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getAllWorkflows_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayComputeResources_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_args"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResources_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->gatewayId); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -34914,23 +34918,19 @@ uint32_t Airavata_getAllWorkflows_args::write(::apache::thrift::protocol::TProto } -Airavata_getAllWorkflows_pargs::~Airavata_getAllWorkflows_pargs() throw() { +Airavata_getAllGatewayComputeResources_pargs::~Airavata_getAllGatewayComputeResources_pargs() throw() { } -uint32_t Airavata_getAllWorkflows_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayComputeResources_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_pargs"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResources_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->gatewayId))); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); oprot->decrementRecursionDepth(); @@ -34938,11 +34938,11 @@ uint32_t Airavata_getAllWorkflows_pargs::write(::apache::thrift::protocol::TProt } -Airavata_getAllWorkflows_result::~Airavata_getAllWorkflows_result() throw() { +Airavata_getAllGatewayComputeResources_result::~Airavata_getAllGatewayComputeResources_result() throw() { } -uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34973,7 +34973,7 @@ uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProt uint32_t _i361; for (_i361 = 0; _i361 < _size357; ++_i361) { - xfer += iprot->readString(this->success[_i361]); + xfer += this->success[_i361].read(iprot); } xfer += iprot->readListEnd(); } @@ -35026,20 +35026,20 @@ uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProt return xfer; } -uint32_t Airavata_getAllWorkflows_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllGatewayComputeResources_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_result"); + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResources_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::vector<std::string> ::const_iterator _iter362; + 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 _iter362; for (_iter362 = this->success.begin(); _iter362 != this->success.end(); ++_iter362) { - xfer += oprot->writeString((*_iter362)); + xfer += (*_iter362).write(oprot); } xfer += oprot->writeListEnd(); } @@ -35067,11 +35067,11 @@ uint32_t Airavata_getAllWorkflows_result::write(::apache::thrift::protocol::TPro } -Airavata_getAllWorkflows_presult::~Airavata_getAllWorkflows_presult() throw() { +Airavata_getAllGatewayComputeResources_presult::~Airavata_getAllGatewayComputeResources_presult() throw() { } -uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35102,7 +35102,7 @@ uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TPro uint32_t _i367; for (_i367 = 0; _i367 < _size363; ++_i367) { - xfer += iprot->readString((*(this->success))[_i367]); + xfer += (*(this->success))[_i367].read(iprot); } xfer += iprot->readListEnd(); } @@ -35156,11 +35156,11 @@ uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TPro } -Airavata_getWorkflow_args::~Airavata_getWorkflow_args() throw() { +Airavata_updateGatewayComputeResourcePreference_args::~Airavata_updateGatewayComputeResourcePreference_args() throw() { } -uint32_t Airavata_getWorkflow_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35172,7 +35172,9 @@ uint32_t Airavata_getWorkflow_args::read(::apache::thrift::protocol::TProtocol* using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_workflowTemplateId = false; + bool isset_gatewayID = false; + bool isset_computeResourceId = false; + bool isset_computeResourcePreference = false; while (true) { @@ -35192,8 +35194,24 @@ uint32_t Airavata_getWorkflow_args::read(::apache::thrift::protocol::TProtocol* break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->workflowTemplateId); - isset_workflowTemplateId = true; + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->computeResourcePreference.read(iprot); + isset_computeResourcePreference = true; } else { xfer += iprot->skip(ftype); } @@ -35209,22 +35227,34 @@ uint32_t Airavata_getWorkflow_args::read(::apache::thrift::protocol::TProtocol* if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workflowTemplateId) + if (!isset_gatewayID) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_computeResourceId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_computeResourcePreference) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getWorkflow_args"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->workflowTemplateId); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->computeResourcePreference.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -35234,35 +35264,43 @@ uint32_t Airavata_getWorkflow_args::write(::apache::thrift::protocol::TProtocol* } -Airavata_getWorkflow_pargs::~Airavata_getWorkflow_pargs() throw() { +Airavata_updateGatewayComputeResourcePreference_pargs::~Airavata_updateGatewayComputeResourcePreference_pargs() throw() { } -uint32_t Airavata_getWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getWorkflow_pargs"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->workflowTemplateId))); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - oprot->decrementRecursionDepth(); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += (*(this->computeResourcePreference)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } -Airavata_getWorkflow_result::~Airavata_getWorkflow_result() throw() { +Airavata_updateGatewayComputeResourcePreference_result::~Airavata_updateGatewayComputeResourcePreference_result() throw() { } -uint32_t Airavata_getWorkflow_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35283,8 +35321,8 @@ uint32_t Airavata_getWorkflow_result::read(::apache::thrift::protocol::TProtocol switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->success.read(iprot); + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -35334,15 +35372,15 @@ uint32_t Airavata_getWorkflow_result::read(::apache::thrift::protocol::TProtocol return xfer; } -uint32_t Airavata_getWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getWorkflow_result"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); - xfer += this->success.write(oprot); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); + xfer += oprot->writeBool(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -35367,11 +35405,11 @@ uint32_t Airavata_getWorkflow_result::write(::apache::thrift::protocol::TProtoco } -Airavata_getWorkflow_presult::~Airavata_getWorkflow_presult() throw() { +Airavata_updateGatewayComputeResourcePreference_presult::~Airavata_updateGatewayComputeResourcePreference_presult() throw() { } -uint32_t Airavata_getWorkflow_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35392,8 +35430,8 @@ uint32_t Airavata_getWorkflow_presult::read(::apache::thrift::protocol::TProtoco switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += (*(this->success)).read(iprot); + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -35444,11 +35482,11 @@ uint32_t Airavata_getWorkflow_presult::read(::apache::thrift::protocol::TProtoco } -Airavata_deleteWorkflow_args::~Airavata_deleteWorkflow_args() throw() { +Airavata_updateGatewayDataStoragePreference_args::~Airavata_updateGatewayDataStoragePreference_args() throw() { } -uint32_t Airavata_deleteWorkflow_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayDataStoragePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35460,7 +35498,9 @@ uint32_t Airavata_deleteWorkflow_args::read(::apache::thrift::protocol::TProtoco using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_workflowTemplateId = false; + bool isset_gatewayID = false; + bool isset_dataMoveId = false; + bool isset_dataStoragePreference = false; while (true) { @@ -35480,8 +35520,24 @@ uint32_t Airavata_deleteWorkflow_args::read(::apache::thrift::protocol::TProtoco break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->workflowTemplateId); - isset_workflowTemplateId = true; + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->dataMoveId); + isset_dataMoveId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->dataStoragePreference.read(iprot); + isset_dataStoragePreference = true; } else { xfer += iprot->skip(ftype); } @@ -35497,22 +35553,34 @@ uint32_t Airavata_deleteWorkflow_args::read(::apache::thrift::protocol::TProtoco if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workflowTemplateId) + if (!isset_gatewayID) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_dataMoveId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_dataStoragePreference) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_deleteWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayDataStoragePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_deleteWorkflow_args"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayDataStoragePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->workflowTemplateId); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->dataMoveId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataStoragePreference", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->dataStoragePreference.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -35522,21 +35590,29 @@ uint32_t Airavata_deleteWorkflow_args::write(::apache::thrift::protocol::TProtoc } -Airavata_deleteWorkflow_pargs::~Airavata_deleteWorkflow_pargs() throw() { +Airavata_updateGatewayDataStoragePreference_pargs::~Airavata_updateGatewayDataStoragePreference_pargs() throw() { } -uint32_t Airavata_deleteWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayDataStoragePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_deleteWorkflow_pargs"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayDataStoragePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->workflowTemplateId))); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->dataMoveId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataStoragePreference", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += (*(this->dataStoragePreference)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -35546,11 +35622,11 @@ uint32_t Airavata_deleteWorkflow_pargs::write(::apache::thrift::protocol::TProto } -Airavata_deleteWorkflow_result::~Airavata_deleteWorkflow_result() throw() { +Airavata_updateGatewayDataStoragePreference_result::~Airavata_updateGatewayDataStoragePreference_result() throw() { } -uint32_t Airavata_deleteWorkflow_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayDataStoragePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35570,6 +35646,14 @@ uint32_t Airavata_deleteWorkflow_result::read(::apache::thrift::protocol::TProto } switch (fid) { + case 0: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->ire.read(iprot); @@ -35614,13 +35698,17 @@ uint32_t Airavata_deleteWorkflow_result::read(::apache::thrift::protocol::TProto return xfer; } -uint32_t Airavata_deleteWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayDataStoragePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteWorkflow_result"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayDataStoragePreference_result"); - if (this->__isset.ire) { + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); + xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->ire.write(oprot); xfer += oprot->writeFieldEnd(); @@ -35643,11 +35731,11 @@ uint32_t Airavata_deleteWorkflow_result::write(::apache::thrift::protocol::TProt } -Airavata_deleteWorkflow_presult::~Airavata_deleteWorkflow_presult() throw() { +Airavata_updateGatewayDataStoragePreference_presult::~Airavata_updateGatewayDataStoragePreference_presult() throw() { } -uint32_t Airavata_deleteWorkflow_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayDataStoragePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35667,6 +35755,14 @@ uint32_t Airavata_deleteWorkflow_presult::read(::apache::thrift::protocol::TProt } switch (fid) { + case 0: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->ire.read(iprot); @@ -35712,11 +35808,11 @@ uint32_t Airavata_deleteWorkflow_presult::read(::apache::thrift::protocol::TProt } -Airavata_registerWorkflow_args::~Airavata_registerWorkflow_args() throw() { +Airavata_deleteGatewayComputeResourcePreference_args::~Airavata_deleteGatewayComputeResourcePreference_args() throw() { } -uint32_t Airavata_registerWorkflow_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35728,8 +35824,8 @@ uint32_t Airavata_registerWorkflow_args::read(::apache::thrift::protocol::TProto using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_gatewayId = false; - bool isset_workflow = false; + bool isset_gatewayID = false; + bool isset_computeResourceId = false; while (true) { @@ -35749,16 +35845,16 @@ uint32_t Airavata_registerWorkflow_args::read(::apache::thrift::protocol::TProto break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->gatewayId); - isset_gatewayId = true; + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; } else { xfer += iprot->skip(ftype); } break; case 3: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->workflow.read(iprot); - isset_workflow = true; + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; } else { xfer += iprot->skip(ftype); } @@ -35774,28 +35870,28 @@ uint32_t Airavata_registerWorkflow_args::read(::apache::thrift::protocol::TProto if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_gatewayId) + if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workflow) + if (!isset_computeResourceId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_registerWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_registerWorkflow_args"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->gatewayId); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->workflow.write(oprot); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->computeResourceId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -35805,25 +35901,25 @@ uint32_t Airavata_registerWorkflow_args::write(::apache::thrift::protocol::TProt } -Airavata_registerWorkflow_pargs::~Airavata_registerWorkflow_pargs() throw() { +Airavata_deleteGatewayComputeResourcePreference_pargs::~Airavata_deleteGatewayComputeResourcePreference_pargs() throw() { } -uint32_t Airavata_registerWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_registerWorkflow_pargs"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->gatewayId))); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->workflow)).write(oprot); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->computeResourceId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -35833,11 +35929,11 @@ uint32_t Airavata_registerWorkflow_pargs::write(::apache::thrift::protocol::TPro } -Airavata_registerWorkflow_result::~Airavata_registerWorkflow_result() throw() { +Airavata_deleteGatewayComputeResourcePreference_result::~Airavata_deleteGatewayComputeResourcePreference_result() throw() { } -uint32_t Airavata_registerWorkflow_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35858,8 +35954,8 @@ uint32_t Airavata_registerWorkflow_result::read(::apache::thrift::protocol::TPro switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->success); + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -35909,15 +36005,15 @@ uint32_t Airavata_registerWorkflow_result::read(::apache::thrift::protocol::TPro return xfer; } -uint32_t Airavata_registerWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_registerWorkflow_result"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); - xfer += oprot->writeString(this->success); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); + xfer += oprot->writeBool(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -35942,11 +36038,11 @@ uint32_t Airavata_registerWorkflow_result::write(::apache::thrift::protocol::TPr } -Airavata_registerWorkflow_presult::~Airavata_registerWorkflow_presult() throw() { +Airavata_deleteGatewayComputeResourcePreference_presult::~Airavata_deleteGatewayComputeResourcePreference_presult() throw() { } -uint32_t Airavata_registerWorkflow_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -35967,8 +36063,8 @@ uint32_t Airavata_registerWorkflow_presult::read(::apache::thrift::protocol::TPr switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -36019,11 +36115,11 @@ uint32_t Airavata_registerWorkflow_presult::read(::apache::thrift::protocol::TPr } -Airavata_updateWorkflow_args::~Airavata_updateWorkflow_args() throw() { +Airavata_deleteGatewayDataStoragePreference_args::~Airavata_deleteGatewayDataStoragePreference_args() throw() { } -uint32_t Airavata_updateWorkflow_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayDataStoragePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -36035,8 +36131,8 @@ uint32_t Airavata_updateWorkflow_args::read(::apache::thrift::protocol::TProtoco using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_workflowTemplateId = false; - bool isset_workflow = false; + bool isset_gatewayID = false; + bool isset_dataMoveId = false; while (true) { @@ -36056,16 +36152,16 @@ uint32_t Airavata_updateWorkflow_args::read(::apache::thrift::protocol::TProtoco break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->workflowTemplateId); - isset_workflowTemplateId = true; + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; } else { xfer += iprot->skip(ftype); } break; case 3: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->workflow.read(iprot); - isset_workflow = true; + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->dataMoveId); + isset_dataMoveId = true; } else { xfer += iprot->skip(ftype); } @@ -36081,28 +36177,28 @@ uint32_t Airavata_updateWorkflow_args::read(::apache::thrift::protocol::TProtoco if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workflowTemplateId) + if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workflow) + if (!isset_dataMoveId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateWorkflow_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayDataStoragePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_updateWorkflow_args"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayDataStoragePreference_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->workflowTemplateId); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->workflow.write(oprot); + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->dataMoveId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -36112,25 +36208,25 @@ uint32_t Airavata_updateWorkflow_args::write(::apache::thrift::protocol::TProtoc } -Airavata_updateWorkflow_pargs::~Airavata_updateWorkflow_pargs() throw() { +Airavata_deleteGatewayDataStoragePreference_pargs::~Airavata_deleteGatewayDataStoragePreference_pargs() throw() { } -uint32_t Airavata_updateWorkflow_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayDataStoragePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_updateWorkflow_pargs"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayDataStoragePreference_pargs"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowTemplateId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->workflowTemplateId))); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->workflow)).write(oprot); + xfer += oprot->writeFieldBegin("dataMoveId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString((*(this->dataMoveId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -36140,11 +36236,11 @@ uint32_t Airavata_updateWorkflow_pargs::write(::apache::thrift::protocol::TProto } -Airavata_updateWorkflow_result::~Airavata_updateWorkflow_result() throw() { +Airavata_deleteGatewayDataStoragePreference_result::~Airavata_deleteGatewayDataStoragePreference_result() throw() { } -uint32_t Airavata_updateWorkflow_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayDataStoragePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -36164,6 +36260,14 @@ uint32_t Airavata_updateWorkflow_result::read(::apache::thrift::protocol::TProto } switch (fid) { + case 0: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->ire.read(iprot); @@ -36208,13 +36312,17 @@ uint32_t Airavata_updateWorkflow_result::read(::apache::thrift::protocol::TProto return xfer; } -uint32_t Airavata_updateWorkflow_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayDataStoragePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateWorkflow_result"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayDataStoragePreference_result"); - if (this->__isset.ire) { + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); + xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->ire.write(oprot); xfer += oprot->writeFieldEnd(); @@ -36237,11 +36345,11 @@ uint32_t Airavata_updateWorkflow_result::write(::apache::thrift::protocol::TProt } -Airavata_updateWorkflow_presult::~Airavata_updateWorkflow_presult() throw() { +Airavata_deleteGatewayDataStoragePreference_presult::~Airavata_deleteGatewayDataStoragePreference_presult() throw() { } -uint32_t Airavata_updateWorkflow_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayDataStoragePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -36261,6 +36369,14 @@ uint32_t Airavata_updateWorkflow_presult::read(::apache::thrift::protocol::TProt } switch (fid) { + case 0: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->ire.read(iprot); @@ -36306,11 +36422,11 @@ uint32_t Airavata_updateWorkflow_presult::read(::apache::thrift::protocol::TProt } -Airavata_getWorkflowTemplateId_args::~Airavata_getWorkflowTemplateId_args() throw() { +Airavata_getAllWorkflows_args::~Airavata_getAllWorkflows_args() throw() { } -uint32_t Airavata_getWorkflowTemplateId_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getAllWorkflows_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -36322,7 +36438,7 @@ uint32_t Airavata_getWorkflowTemplateId_args::read(::apache::thrift::protocol::T using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_workflowName = false; + bool isset_gatewayId = false; while (true) { @@ -36342,8 +36458,8 @@ uint32_t Airavata_getWorkflowTemplateId_args::read(::apache::thrift::protocol::T break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->workflowName); - isset_workflowName = true; + xfer += iprot->readString(this->gatewayId); + isset_gatewayId = true; } else { xfer += iprot->skip(ftype); } @@ -36359,22 +36475,22 @@ uint32_t Airavata_getWorkflowTemplateId_args::read(::apache::thrift::protocol::T if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workflowName) + if (!isset_gatewayId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getWorkflowTemplateId_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getAllWorkflows_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_getWorkflowTemplateId_args"); + xfer += oprot->writeStructBegin("Airavata_getAllWorkflows_args"); xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workflowName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->workflowName); + xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -36384,21 +36500,21 @@ uint32_t Airavata_getWorkflowTemplateId_args::write(::apache::thrift::protocol:: } -Airavata_getWorkflowTemplateId_pargs::~Airavata_getWorkflowTemplateId_pargs() throw() { +Airavata_getAllWorkflows_pargs::~Airavata_getAllWorkflows_pargs() throw() { } -uint32_t
<TRUNCATED>
