http://git-wip-us.apache.org/repos/asf/airavata/blob/8b82bee9/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 1aa8caa..7f5e807 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 @@ -18811,7 +18811,7 @@ uint32_t Airavata_deleteDataMovementInterface_presult::read(::apache::thrift::pr return xfer; } -uint32_t Airavata_registerGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_registerResourceJobManager_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -18822,7 +18822,7 @@ uint32_t Airavata_registerGatewayResourceProfile_args::read(::apache::thrift::pr using ::apache::thrift::protocol::TProtocolException; - bool isset_gatewayResourceProfile = false; + bool isset_resourceJobManager = false; while (true) { @@ -18834,8 +18834,8 @@ uint32_t Airavata_registerGatewayResourceProfile_args::read(::apache::thrift::pr { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->gatewayResourceProfile.read(iprot); - isset_gatewayResourceProfile = true; + xfer += this->resourceJobManager.read(iprot); + isset_resourceJobManager = true; } else { xfer += iprot->skip(ftype); } @@ -18849,17 +18849,17 @@ uint32_t Airavata_registerGatewayResourceProfile_args::read(::apache::thrift::pr xfer += iprot->readStructEnd(); - if (!isset_gatewayResourceProfile) + if (!isset_resourceJobManager) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_registerGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_registerResourceJobManager_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_registerGatewayResourceProfile_args"); + xfer += oprot->writeStructBegin("Airavata_registerResourceJobManager_args"); - xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->gatewayResourceProfile.write(oprot); + xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->resourceJobManager.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -18867,12 +18867,12 @@ uint32_t Airavata_registerGatewayResourceProfile_args::write(::apache::thrift::p return xfer; } -uint32_t Airavata_registerGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_registerResourceJobManager_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_registerGatewayResourceProfile_pargs"); + xfer += oprot->writeStructBegin("Airavata_registerResourceJobManager_pargs"); - xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += (*(this->gatewayResourceProfile)).write(oprot); + xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += (*(this->resourceJobManager)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -18880,7 +18880,7 @@ uint32_t Airavata_registerGatewayResourceProfile_pargs::write(::apache::thrift:: return xfer; } -uint32_t Airavata_registerGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_registerResourceJobManager_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -18944,11 +18944,11 @@ uint32_t Airavata_registerGatewayResourceProfile_result::read(::apache::thrift:: return xfer; } -uint32_t Airavata_registerGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_registerResourceJobManager_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_registerGatewayResourceProfile_result"); + xfer += oprot->writeStructBegin("Airavata_registerResourceJobManager_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); @@ -18972,7 +18972,7 @@ uint32_t Airavata_registerGatewayResourceProfile_result::write(::apache::thrift: return xfer; } -uint32_t Airavata_registerGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_registerResourceJobManager_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19036,7 +19036,7 @@ uint32_t Airavata_registerGatewayResourceProfile_presult::read(::apache::thrift: return xfer; } -uint32_t Airavata_getGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateResourceJobManager_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19047,7 +19047,8 @@ uint32_t Airavata_getGatewayResourceProfile_args::read(::apache::thrift::protoco using ::apache::thrift::protocol::TProtocolException; - bool isset_gatewayID = false; + bool isset_resourceJobManagerId = false; + bool isset_updatedResourceJobManager = false; while (true) { @@ -19059,8 +19060,16 @@ uint32_t Airavata_getGatewayResourceProfile_args::read(::apache::thrift::protoco { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->gatewayID); - isset_gatewayID = true; + xfer += iprot->readString(this->resourceJobManagerId); + isset_resourceJobManagerId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->updatedResourceJobManager.read(iprot); + isset_updatedResourceJobManager = true; } else { xfer += iprot->skip(ftype); } @@ -19074,17 +19083,23 @@ uint32_t Airavata_getGatewayResourceProfile_args::read(::apache::thrift::protoco xfer += iprot->readStructEnd(); - if (!isset_gatewayID) + if (!isset_resourceJobManagerId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_updatedResourceJobManager) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateResourceJobManager_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayResourceProfile_args"); + xfer += oprot->writeStructBegin("Airavata_updateResourceJobManager_args"); - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldBegin("resourceJobManagerId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->resourceJobManagerId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("updatedResourceJobManager", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->updatedResourceJobManager.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19092,12 +19107,16 @@ uint32_t Airavata_getGatewayResourceProfile_args::write(::apache::thrift::protoc return xfer; } -uint32_t Airavata_getGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateResourceJobManager_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayResourceProfile_pargs"); + xfer += oprot->writeStructBegin("Airavata_updateResourceJobManager_pargs"); - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldBegin("resourceJobManagerId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->resourceJobManagerId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("updatedResourceJobManager", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->updatedResourceJobManager)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19105,7 +19124,7 @@ uint32_t Airavata_getGatewayResourceProfile_pargs::write(::apache::thrift::proto return xfer; } -uint32_t Airavata_getGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateResourceJobManager_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19126,8 +19145,8 @@ uint32_t Airavata_getGatewayResourceProfile_result::read(::apache::thrift::proto 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); @@ -19169,15 +19188,15 @@ uint32_t Airavata_getGatewayResourceProfile_result::read(::apache::thrift::proto return xfer; } -uint32_t Airavata_getGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateResourceJobManager_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayResourceProfile_result"); + xfer += oprot->writeStructBegin("Airavata_updateResourceJobManager_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); @@ -19197,7 +19216,7 @@ uint32_t Airavata_getGatewayResourceProfile_result::write(::apache::thrift::prot return xfer; } -uint32_t Airavata_getGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateResourceJobManager_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19218,8 +19237,8 @@ uint32_t Airavata_getGatewayResourceProfile_presult::read(::apache::thrift::prot 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); @@ -19261,7 +19280,7 @@ uint32_t Airavata_getGatewayResourceProfile_presult::read(::apache::thrift::prot return xfer; } -uint32_t Airavata_updateGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getResourceJobManager_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19272,8 +19291,7 @@ uint32_t Airavata_updateGatewayResourceProfile_args::read(::apache::thrift::prot using ::apache::thrift::protocol::TProtocolException; - bool isset_gatewayID = false; - bool isset_gatewayResourceProfile = false; + bool isset_resourceJobManagerId = false; while (true) { @@ -19285,16 +19303,8 @@ uint32_t Airavata_updateGatewayResourceProfile_args::read(::apache::thrift::prot { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->gatewayID); - isset_gatewayID = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->gatewayResourceProfile.read(iprot); - isset_gatewayResourceProfile = true; + xfer += iprot->readString(this->resourceJobManagerId); + isset_resourceJobManagerId = true; } else { xfer += iprot->skip(ftype); } @@ -19308,23 +19318,17 @@ uint32_t Airavata_updateGatewayResourceProfile_args::read(::apache::thrift::prot xfer += iprot->readStructEnd(); - if (!isset_gatewayID) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_gatewayResourceProfile) + if (!isset_resourceJobManagerId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getResourceJobManager_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayResourceProfile_args"); - - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->gatewayID); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getResourceJobManager_args"); - xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->gatewayResourceProfile.write(oprot); + xfer += oprot->writeFieldBegin("resourceJobManagerId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->resourceJobManagerId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19332,16 +19336,12 @@ uint32_t Airavata_updateGatewayResourceProfile_args::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_updateGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getResourceJobManager_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayResourceProfile_pargs"); - - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->gatewayID))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getResourceJobManager_pargs"); - xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->gatewayResourceProfile)).write(oprot); + xfer += oprot->writeFieldBegin("resourceJobManagerId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->resourceJobManagerId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19349,7 +19349,7 @@ uint32_t Airavata_updateGatewayResourceProfile_pargs::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_updateGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getResourceJobManager_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19370,8 +19370,8 @@ uint32_t Airavata_updateGatewayResourceProfile_result::read(::apache::thrift::pr switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -19413,15 +19413,15 @@ uint32_t Airavata_updateGatewayResourceProfile_result::read(::apache::thrift::pr return xfer; } -uint32_t Airavata_updateGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getResourceJobManager_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayResourceProfile_result"); + xfer += oprot->writeStructBegin("Airavata_getResourceJobManager_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_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); @@ -19441,7 +19441,7 @@ uint32_t Airavata_updateGatewayResourceProfile_result::write(::apache::thrift::p return xfer; } -uint32_t Airavata_updateGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getResourceJobManager_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19462,8 +19462,8 @@ uint32_t Airavata_updateGatewayResourceProfile_presult::read(::apache::thrift::p switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -19505,7 +19505,7 @@ uint32_t Airavata_updateGatewayResourceProfile_presult::read(::apache::thrift::p return xfer; } -uint32_t Airavata_deleteGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteResourceJobManager_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19516,7 +19516,7 @@ uint32_t Airavata_deleteGatewayResourceProfile_args::read(::apache::thrift::prot using ::apache::thrift::protocol::TProtocolException; - bool isset_gatewayID = false; + bool isset_resourceJobManagerId = false; while (true) { @@ -19528,8 +19528,8 @@ uint32_t Airavata_deleteGatewayResourceProfile_args::read(::apache::thrift::prot { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->gatewayID); - isset_gatewayID = true; + xfer += iprot->readString(this->resourceJobManagerId); + isset_resourceJobManagerId = true; } else { xfer += iprot->skip(ftype); } @@ -19543,17 +19543,17 @@ uint32_t Airavata_deleteGatewayResourceProfile_args::read(::apache::thrift::prot xfer += iprot->readStructEnd(); - if (!isset_gatewayID) + if (!isset_resourceJobManagerId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_deleteGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteResourceJobManager_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayResourceProfile_args"); + xfer += oprot->writeStructBegin("Airavata_deleteResourceJobManager_args"); - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldBegin("resourceJobManagerId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->resourceJobManagerId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19561,12 +19561,12 @@ uint32_t Airavata_deleteGatewayResourceProfile_args::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_deleteGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteResourceJobManager_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayResourceProfile_pargs"); + xfer += oprot->writeStructBegin("Airavata_deleteResourceJobManager_pargs"); - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldBegin("resourceJobManagerId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->resourceJobManagerId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19574,7 +19574,7 @@ uint32_t Airavata_deleteGatewayResourceProfile_pargs::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_deleteGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteResourceJobManager_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19638,11 +19638,11 @@ uint32_t Airavata_deleteGatewayResourceProfile_result::read(::apache::thrift::pr return xfer; } -uint32_t Airavata_deleteGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteResourceJobManager_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayResourceProfile_result"); + xfer += oprot->writeStructBegin("Airavata_deleteResourceJobManager_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); @@ -19666,7 +19666,7 @@ uint32_t Airavata_deleteGatewayResourceProfile_result::write(::apache::thrift::p return xfer; } -uint32_t Airavata_deleteGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteResourceJobManager_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19730,7 +19730,7 @@ uint32_t Airavata_deleteGatewayResourceProfile_presult::read(::apache::thrift::p return xfer; } -uint32_t Airavata_addGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_registerGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19741,9 +19741,7 @@ uint32_t Airavata_addGatewayComputeResourcePreference_args::read(::apache::thrif using ::apache::thrift::protocol::TProtocolException; - bool isset_gatewayID = false; - bool isset_computeResourceId = false; - bool isset_computeResourcePreference = false; + bool isset_gatewayResourceProfile = false; while (true) { @@ -19754,25 +19752,9 @@ uint32_t Airavata_addGatewayComputeResourcePreference_args::read(::apache::thrif switch (fid) { case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->gatewayID); - isset_gatewayID = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->computeResourcePreference.read(iprot); - isset_computeResourcePreference = true; + xfer += this->gatewayResourceProfile.read(iprot); + isset_gatewayResourceProfile = true; } else { xfer += iprot->skip(ftype); } @@ -19786,29 +19768,17 @@ uint32_t Airavata_addGatewayComputeResourcePreference_args::read(::apache::thrif xfer += iprot->readStructEnd(); - if (!isset_gatewayID) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourcePreference) + if (!isset_gatewayResourceProfile) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_registerGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addGatewayComputeResourcePreference_args"); - - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->gatewayID); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_registerGatewayResourceProfile_args"); - xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->computeResourcePreference.write(oprot); + xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->gatewayResourceProfile.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19816,20 +19786,12 @@ uint32_t Airavata_addGatewayComputeResourcePreference_args::write(::apache::thri return xfer; } -uint32_t Airavata_addGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_registerGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addGatewayComputeResourcePreference_pargs"); - - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->gatewayID))); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_registerGatewayResourceProfile_pargs"); - xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->computeResourcePreference)).write(oprot); + xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += (*(this->gatewayResourceProfile)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -19837,7 +19799,7 @@ uint32_t Airavata_addGatewayComputeResourcePreference_pargs::write(::apache::thr return xfer; } -uint32_t Airavata_addGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_registerGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19858,8 +19820,8 @@ uint32_t Airavata_addGatewayComputeResourcePreference_result::read(::apache::thr switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -19901,15 +19863,15 @@ uint32_t Airavata_addGatewayComputeResourcePreference_result::read(::apache::thr return xfer; } -uint32_t Airavata_addGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_registerGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_registerGatewayResourceProfile_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_STRING, 0); + xfer += oprot->writeString(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -19929,7 +19891,7 @@ uint32_t Airavata_addGatewayComputeResourcePreference_result::write(::apache::th return xfer; } -uint32_t Airavata_addGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_registerGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -19950,8 +19912,8 @@ uint32_t Airavata_addGatewayComputeResourcePreference_presult::read(::apache::th switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -19993,7 +19955,7 @@ uint32_t Airavata_addGatewayComputeResourcePreference_presult::read(::apache::th return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20005,7 +19967,6 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrif using ::apache::thrift::protocol::TProtocolException; bool isset_gatewayID = false; - bool isset_computeResourceId = false; while (true) { @@ -20023,14 +19984,6 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrif xfer += iprot->skip(ftype); } break; - case 2: - 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; @@ -20042,46 +19995,36 @@ uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrif if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_args"); + xfer += oprot->writeStructBegin("Airavata_getGatewayResourceProfile_args"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_pargs"); + xfer += oprot->writeStructBegin("Airavata_getGatewayResourceProfile_pargs"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20145,11 +20088,11 @@ 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_getGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_getGatewayResourceProfile_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); @@ -20173,7 +20116,7 @@ uint32_t Airavata_getGatewayComputeResourcePreference_result::write(::apache::th return xfer; } -uint32_t Airavata_getGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20237,7 +20180,7 @@ uint32_t Airavata_getGatewayComputeResourcePreference_presult::read(::apache::th return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20249,6 +20192,7 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::t using ::apache::thrift::protocol::TProtocolException; bool isset_gatewayID = false; + bool isset_gatewayResourceProfile = false; while (true) { @@ -20266,6 +20210,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::t xfer += iprot->skip(ftype); } break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->gatewayResourceProfile.read(iprot); + isset_gatewayResourceProfile = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -20277,36 +20229,46 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::read(::apache::t if (!isset_gatewayID) throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_gatewayResourceProfile) + throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_args"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayResourceProfile_args"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->gatewayResourceProfile.write(oprot); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_pargs"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayResourceProfile_pargs"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("gatewayResourceProfile", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->gatewayResourceProfile)).write(oprot); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20327,20 +20289,8 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->success.clear(); - uint32_t _size266; - ::apache::thrift::protocol::TType _etype269; - xfer += iprot->readListBegin(_etype269, _size266); - this->success.resize(_size266); - uint32_t _i270; - for (_i270 = 0; _i270 < _size266; ++_i270) - { - xfer += this->success[_i270].read(iprot); - } - xfer += iprot->readListEnd(); - } + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -20382,23 +20332,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_updateGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_result"); + xfer += oprot->writeStructBegin("Airavata_updateGatewayResourceProfile_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 _iter271; - for (_iter271 = this->success.begin(); _iter271 != this->success.end(); ++_iter271) - { - xfer += (*_iter271).write(oprot); - } - xfer += oprot->writeListEnd(); - } + 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); @@ -20418,7 +20360,7 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::write(::apache return xfer; } -uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20439,20 +20381,8 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - (*(this->success)).clear(); - uint32_t _size272; - ::apache::thrift::protocol::TType _etype275; - xfer += iprot->readListBegin(_etype275, _size272); - (*(this->success)).resize(_size272); - uint32_t _i276; - for (_i276 = 0; _i276 < _size272; ++_i276) - { - xfer += (*(this->success))[_i276].read(iprot); - } - xfer += iprot->readListEnd(); - } + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -20494,7 +20424,7 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayResourceProfile_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20506,8 +20436,6 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::th using ::apache::thrift::protocol::TProtocolException; bool isset_gatewayID = false; - bool isset_computeResourceId = false; - bool isset_computeResourcePreference = false; while (true) { @@ -20525,22 +20453,6 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::th xfer += iprot->skip(ftype); } break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - 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; @@ -20552,56 +20464,36 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_args::read(::apache::th 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_deleteGatewayResourceProfile_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_args"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayResourceProfile_args"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->gatewayID); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->computeResourcePreference.write(oprot); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayResourceProfile_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_pargs"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayResourceProfile_pargs"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->gatewayID))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->computeResourcePreference)).write(oprot); - xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayResourceProfile_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20665,11 +20557,11 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_result::read(::apache:: return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_deleteGatewayResourceProfile_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_deleteGatewayResourceProfile_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); @@ -20693,7 +20585,7 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_result::write(::apache: return xfer; } -uint32_t Airavata_updateGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_deleteGatewayResourceProfile_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20757,7 +20649,7 @@ uint32_t Airavata_updateGatewayComputeResourcePreference_presult::read(::apache: return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20770,6 +20662,7 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::th bool isset_gatewayID = false; bool isset_computeResourceId = false; + bool isset_computeResourcePreference = false; while (true) { @@ -20795,6 +20688,14 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::th xfer += iprot->skip(ftype); } break; + case 3: + 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; @@ -20808,12 +20709,14 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::read(::apache::th 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_deleteGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_args"); + xfer += oprot->writeStructBegin("Airavata_addGatewayComputeResourcePreference_args"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->gatewayID); @@ -20823,14 +20726,18 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_args::write(::apache::t xfer += oprot->writeString(this->computeResourceId); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->computeResourcePreference.write(oprot); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_pargs"); + xfer += oprot->writeStructBegin("Airavata_addGatewayComputeResourcePreference_pargs"); xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->gatewayID))); @@ -20840,12 +20747,16 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache:: xfer += oprot->writeString((*(this->computeResourceId))); xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->computeResourcePreference)).write(oprot); + xfer += oprot->writeFieldEnd(); + xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addGatewayComputeResourcePreference_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -20909,11 +20820,11 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_result::read(::apache:: return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_result"); + xfer += oprot->writeStructBegin("Airavata_addGatewayComputeResourcePreference_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); @@ -20937,7 +20848,7 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_result::write(::apache: return xfer; } -uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addGatewayComputeResourcePreference_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -21001,38 +20912,1113 @@ uint32_t Airavata_deleteGatewayComputeResourcePreference_presult::read(::apache: return xfer; } -void AiravataClient::getAPIVersion(std::string& _return) -{ - send_getAPIVersion(); - recv_getAPIVersion(_return); +uint32_t Airavata_getGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + bool isset_gatewayID = false; + bool isset_computeResourceId = false; + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_gatewayID) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_computeResourceId) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; } -void AiravataClient::send_getAPIVersion() -{ - int32_t cseqid = 0; - oprot_->writeMessageBegin("getAPIVersion", ::apache::thrift::protocol::T_CALL, cseqid); +uint32_t Airavata_getGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_args"); - Airavata_getAPIVersion_pargs args; - args.write(oprot_); + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; } -void AiravataClient::recv_getAPIVersion(std::string& _return) -{ +uint32_t Airavata_getGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_pargs"); - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldEnd(); - iprot_->readMessageBegin(fname, mtype, rseqid); - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getGatewayComputeResourcePreference_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_STRUCT) { + xfer += this->success.read(iprot); + 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_getGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getGatewayComputeResourcePreference_result"); + + if (this->__isset.success) { + 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); + 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_getGatewayComputeResourcePreference_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_STRUCT) { + xfer += (*(this->success)).read(iprot); + 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_getAllGatewayComputeResourcePreferences_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + bool isset_gatewayID = false; + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_gatewayID) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_getAllGatewayComputeResourcePreferences_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_args"); + + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getAllGatewayComputeResourcePreferences_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_pargs"); + + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_getAllGatewayComputeResourcePreferences_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 _size266; + ::apache::thrift::protocol::TType _etype269; + xfer += iprot->readListBegin(_etype269, _size266); + this->success.resize(_size266); + uint32_t _i270; + for (_i270 = 0; _i270 < _size266; ++_i270) + { + xfer += this->success[_i270].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_getAllGatewayComputeResourcePreferences_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getAllGatewayComputeResourcePreferences_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 _iter271; + for (_iter271 = this->success.begin(); _iter271 != this->success.end(); ++_iter271) + { + xfer += (*_iter271).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_getAllGatewayComputeResourcePreferences_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 _size272; + ::apache::thrift::protocol::TType _etype275; + xfer += iprot->readListBegin(_etype275, _size272); + (*(this->success)).resize(_size272); + uint32_t _i276; + for (_i276 = 0; _i276 < _size272; ++_i276) + { + xfer += (*(this->success))[_i276].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_updateGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + bool isset_gatewayID = false; + bool isset_computeResourceId = false; + bool isset_computeResourcePreference = false; + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + 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; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + 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 xfer = 0; + xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_args"); + + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->computeResourcePreference.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_updateGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_pargs"); + + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourcePreference", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->computeResourcePreference)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_updateGatewayComputeResourcePreference_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_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); + 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_updateGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_updateGatewayComputeResourcePreference_result"); + + 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(); + } 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_updateGatewayComputeResourcePreference_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_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); + 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_deleteGatewayComputeResourcePreference_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + bool isset_gatewayID = false; + bool isset_computeResourceId = false; + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->gatewayID); + isset_gatewayID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_gatewayID) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_computeResourceId) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_deleteGatewayComputeResourcePreference_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_args"); + + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->gatewayID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_deleteGatewayComputeResourcePreference_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_pargs"); + + xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->gatewayID))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t Airavata_deleteGatewayComputeResourcePreference_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_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); + 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_deleteGatewayComputeResourcePreference_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_deleteGatewayComputeResourcePreference_result"); + + 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(); + } 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_deleteGatewayComputeResourcePreference_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_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); + 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; +} + +void AiravataClient::getAPIVersion(std::string& _return) +{ + send_getAPIVersion(); + recv_getAPIVersion(_return); +} + +void AiravataClient::send_getAPIVersion() +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getAPIVersion", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_getAPIVersion_pargs args; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_getAPIVersion(std::string& _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("getAPIVersion") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getAPIVersion_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, "getAPIVersion failed: unknown result"); +} + +void AiravataClient::createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project) +{ + send_createProject(project); + recv_createProject(_return); +} + +void AiravataClient::send_createProject(const ::apache::airavata::model::workspace::Project& project) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("createProject", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_createProject_pargs args; + args.project = &project; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_createProject(std::string& _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) { @@ -21040,12 +22026,12 @@ void AiravataClient::recv_getAPIVersion(std::string& _return) iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getAPIVersion") != 0) { + if (fname.compare("createProject") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getAPIVersion_presult result; + Airavata_createProject_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -21064,22 +22050,23 @@ void AiravataClient::recv_getAPIVersion(std::string& _return) if (result.__isset.ase) { throw result.ase; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAPIVersion failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "createProject failed: unknown result"); } -void AiravataClient::createProject(std::string& _return, const ::apache::airavata::model::workspace::Project& project) +void AiravataClient::updateProject(const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) { - send_createProject(project); - recv_createProject(_return); + send_updateProject(projectId, updatedProject); + recv_updateProject(); } -void AiravataClient::send_createProject(const ::apache::airavata::model::workspace::Project& project) +void AiravataClient::send_updateProject(const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) { int32_t cseqid = 0; - oprot_->writeMessageBegin("createProject", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("updateProject", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_createProject_pargs args; - arg
<TRUNCATED>
