http://git-wip-us.apache.org/repos/asf/airavata/blob/6c5645d3/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 7fc2fc4..1d6f60a 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 @@ -28145,7 +28145,7 @@ uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::proto using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_productId = false; + bool isset_productUri = false; bool isset_dataMoveType = false; bool isset_priorityOrder = false; bool isset_localDataMovement = false; @@ -28168,8 +28168,8 @@ uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::proto break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->productId); - isset_productId = true; + xfer += iprot->readString(this->productUri); + isset_productUri = true; } else { xfer += iprot->skip(ftype); } @@ -28211,7 +28211,7 @@ uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::proto if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_productId) + if (!isset_productUri) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_dataMoveType) throw TProtocolException(TProtocolException::INVALID_DATA); @@ -28231,8 +28231,8 @@ uint32_t Airavata_addLocalDataMovementDetails_args::write(::apache::thrift::prot xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->productUri); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -28266,8 +28266,8 @@ uint32_t Airavata_addLocalDataMovementDetails_pargs::write(::apache::thrift::pro xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->productId))); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->productUri))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -29090,7 +29090,7 @@ uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protoco using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_productId = false; + bool isset_productUri = false; bool isset_dataMoveType = false; bool isset_priorityOrder = false; bool isset_scpDataMovement = false; @@ -29113,8 +29113,8 @@ uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protoco break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->productId); - isset_productId = true; + xfer += iprot->readString(this->productUri); + isset_productUri = true; } else { xfer += iprot->skip(ftype); } @@ -29156,7 +29156,7 @@ uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protoco if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_productId) + if (!isset_productUri) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_dataMoveType) throw TProtocolException(TProtocolException::INVALID_DATA); @@ -29176,8 +29176,8 @@ uint32_t Airavata_addSCPDataMovementDetails_args::write(::apache::thrift::protoc xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->productUri); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -29211,8 +29211,8 @@ uint32_t Airavata_addSCPDataMovementDetails_pargs::write(::apache::thrift::proto xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->productId))); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->productUri))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -30035,7 +30035,7 @@ uint32_t Airavata_addUnicoreDataMovementDetails_args::read(::apache::thrift::pro using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_productId = false; + bool isset_productUri = false; bool isset_dataMoveType = false; bool isset_priorityOrder = false; bool isset_unicoreDataMovement = false; @@ -30058,8 +30058,8 @@ uint32_t Airavata_addUnicoreDataMovementDetails_args::read(::apache::thrift::pro break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->productId); - isset_productId = true; + xfer += iprot->readString(this->productUri); + isset_productUri = true; } else { xfer += iprot->skip(ftype); } @@ -30101,7 +30101,7 @@ uint32_t Airavata_addUnicoreDataMovementDetails_args::read(::apache::thrift::pro if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_productId) + if (!isset_productUri) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_dataMoveType) throw TProtocolException(TProtocolException::INVALID_DATA); @@ -30121,8 +30121,8 @@ uint32_t Airavata_addUnicoreDataMovementDetails_args::write(::apache::thrift::pr xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->productUri); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -30156,8 +30156,8 @@ uint32_t Airavata_addUnicoreDataMovementDetails_pargs::write(::apache::thrift::p xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->productId))); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->productUri))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -30980,7 +30980,7 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::pro using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_productId = false; + bool isset_productUri = false; bool isset_dataMoveType = false; bool isset_priorityOrder = false; bool isset_gridFTPDataMovement = false; @@ -31003,8 +31003,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::pro break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->productId); - isset_productId = true; + xfer += iprot->readString(this->productUri); + isset_productUri = true; } else { xfer += iprot->skip(ftype); } @@ -31046,7 +31046,7 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::pro if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_productId) + if (!isset_productUri) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_dataMoveType) throw TProtocolException(TProtocolException::INVALID_DATA); @@ -31066,8 +31066,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::write(::apache::thrift::pr xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->productUri); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -31101,8 +31101,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_pargs::write(::apache::thrift::p xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->productId))); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->productUri))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMoveType", ::apache::thrift::protocol::T_I32, 3); @@ -33493,7 +33493,7 @@ uint32_t Airavata_deleteDataMovementInterface_args::read(::apache::thrift::proto using ::apache::thrift::protocol::TProtocolException; bool isset_authzToken = false; - bool isset_productId = false; + bool isset_productUri = false; bool isset_dataMovementInterfaceId = false; bool isset_dataMoveType = false; @@ -33515,8 +33515,8 @@ uint32_t Airavata_deleteDataMovementInterface_args::read(::apache::thrift::proto break; case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->productId); - isset_productId = true; + xfer += iprot->readString(this->productUri); + isset_productUri = true; } else { xfer += iprot->skip(ftype); } @@ -33550,7 +33550,7 @@ uint32_t Airavata_deleteDataMovementInterface_args::read(::apache::thrift::proto if (!isset_authzToken) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_productId) + if (!isset_productUri) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_dataMovementInterfaceId) throw TProtocolException(TProtocolException::INVALID_DATA); @@ -33568,8 +33568,8 @@ uint32_t Airavata_deleteDataMovementInterface_args::write(::apache::thrift::prot xfer += this->authzToken.write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->productUri); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMovementInterfaceId", ::apache::thrift::protocol::T_STRING, 3); @@ -33599,8 +33599,8 @@ uint32_t Airavata_deleteDataMovementInterface_pargs::write(::apache::thrift::pro xfer += (*(this->authzToken)).write(oprot); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->productId))); + xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->productUri))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("dataMovementInterfaceId", ::apache::thrift::protocol::T_STRING, 3); @@ -41999,6 +41999,873 @@ uint32_t Airavata_isWorkflowExistWithName_presult::read(::apache::thrift::protoc return xfer; } + +Airavata_registerDataProduct_args::~Airavata_registerDataProduct_args() throw() { +} + + +uint32_t Airavata_registerDataProduct_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_authzToken = false; + bool isset_dataProductModel = 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_STRUCT) { + xfer += this->authzToken.read(iprot); + isset_authzToken = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->dataProductModel.read(iprot); + isset_dataProductModel = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_authzToken) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_dataProductModel) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_registerDataProduct_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("Airavata_registerDataProduct_args"); + + xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->authzToken.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataProductModel", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->dataProductModel.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_registerDataProduct_pargs::~Airavata_registerDataProduct_pargs() throw() { +} + + +uint32_t Airavata_registerDataProduct_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("Airavata_registerDataProduct_pargs"); + + xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += (*(this->authzToken)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataProductModel", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->dataProductModel)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_registerDataProduct_result::~Airavata_registerDataProduct_result() throw() { +} + + +uint32_t Airavata_registerDataProduct_result::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_STRING) { + xfer += iprot->readString(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; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ae.read(iprot); + this->__isset.ae = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_registerDataProduct_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_registerDataProduct_result"); + + if (this->__isset.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); + 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(); + } else if (this->__isset.ae) { + xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->ae.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_registerDataProduct_presult::~Airavata_registerDataProduct_presult() throw() { +} + + +uint32_t Airavata_registerDataProduct_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_STRING) { + xfer += iprot->readString((*(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; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ae.read(iprot); + this->__isset.ae = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + + +Airavata_getDataProduct_args::~Airavata_getDataProduct_args() throw() { +} + + +uint32_t Airavata_getDataProduct_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_authzToken = false; + bool isset_dataProductUri = 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_STRUCT) { + xfer += this->authzToken.read(iprot); + isset_authzToken = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->dataProductUri); + isset_dataProductUri = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_authzToken) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_dataProductUri) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_getDataProduct_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("Airavata_getDataProduct_args"); + + xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->authzToken.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataProductUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->dataProductUri); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_getDataProduct_pargs::~Airavata_getDataProduct_pargs() throw() { +} + + +uint32_t Airavata_getDataProduct_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("Airavata_getDataProduct_pargs"); + + xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += (*(this->authzToken)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataProductUri", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString((*(this->dataProductUri))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_getDataProduct_result::~Airavata_getDataProduct_result() throw() { +} + + +uint32_t Airavata_getDataProduct_result::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ae.read(iprot); + this->__isset.ae = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_getDataProduct_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_getDataProduct_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(); + } else if (this->__isset.ae) { + xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->ae.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_getDataProduct_presult::~Airavata_getDataProduct_presult() throw() { +} + + +uint32_t Airavata_getDataProduct_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ae.read(iprot); + this->__isset.ae = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + + +Airavata_registerReplicaLocation_args::~Airavata_registerReplicaLocation_args() throw() { +} + + +uint32_t Airavata_registerReplicaLocation_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_authzToken = false; + bool isset_replicaLocationModel = 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_STRUCT) { + xfer += this->authzToken.read(iprot); + isset_authzToken = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->replicaLocationModel.read(iprot); + isset_replicaLocationModel = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_authzToken) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_replicaLocationModel) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t Airavata_registerReplicaLocation_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("Airavata_registerReplicaLocation_args"); + + xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->authzToken.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("replicaLocationModel", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->replicaLocationModel.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_registerReplicaLocation_pargs::~Airavata_registerReplicaLocation_pargs() throw() { +} + + +uint32_t Airavata_registerReplicaLocation_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("Airavata_registerReplicaLocation_pargs"); + + xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += (*(this->authzToken)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("replicaLocationModel", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->replicaLocationModel)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_registerReplicaLocation_result::~Airavata_registerReplicaLocation_result() throw() { +} + + +uint32_t Airavata_registerReplicaLocation_result::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_STRING) { + xfer += iprot->readString(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; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ae.read(iprot); + this->__isset.ae = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t Airavata_registerReplicaLocation_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("Airavata_registerReplicaLocation_result"); + + if (this->__isset.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); + 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(); + } else if (this->__isset.ae) { + xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4); + xfer += this->ae.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + + +Airavata_registerReplicaLocation_presult::~Airavata_registerReplicaLocation_presult() throw() { +} + + +uint32_t Airavata_registerReplicaLocation_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*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_STRING) { + xfer += iprot->readString((*(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; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ae.read(iprot); + this->__isset.ae = 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, const ::apache::airavata::model::security::AuthzToken& authzToken) { send_getAPIVersion(authzToken); @@ -42209,24 +43076,302 @@ void AiravataClient::recv_addGateway(std::string& _return) if (result.__isset.ae) { throw result.ae; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addGateway failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addGateway failed: unknown result"); +} + +void AiravataClient::updateGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Gateway& updatedGateway) +{ + send_updateGateway(authzToken, gatewayId, updatedGateway); + recv_updateGateway(); +} + +void AiravataClient::send_updateGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Gateway& updatedGateway) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("updateGateway", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_updateGateway_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.updatedGateway = &updatedGateway; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_updateGateway() +{ + + 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("updateGateway") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_updateGateway_presult result; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + + if (result.__isset.ire) { + throw result.ire; + } + if (result.__isset.ace) { + throw result.ace; + } + if (result.__isset.ase) { + throw result.ase; + } + if (result.__isset.ae) { + throw result.ae; + } + return; +} + +void AiravataClient::getGateway( ::apache::airavata::model::workspace::Gateway& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + send_getGateway(authzToken, gatewayId); + recv_getGateway(_return); +} + +void AiravataClient::send_getGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getGateway", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_getGateway_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_getGateway( ::apache::airavata::model::workspace::Gateway& _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("getGateway") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getGateway_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; + } + if (result.__isset.ae) { + throw result.ae; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getGateway failed: unknown result"); +} + +bool AiravataClient::deleteGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + send_deleteGateway(authzToken, gatewayId); + return recv_deleteGateway(); +} + +void AiravataClient::send_deleteGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("deleteGateway", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_deleteGateway_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +bool AiravataClient::recv_deleteGateway() +{ + + 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("deleteGateway") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + bool _return; + Airavata_deleteGateway_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + + if (result.__isset.success) { + return _return; + } + if (result.__isset.ire) { + throw result.ire; + } + if (result.__isset.ace) { + throw result.ace; + } + if (result.__isset.ase) { + throw result.ase; + } + if (result.__isset.ae) { + throw result.ae; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteGateway failed: unknown result"); +} + +void AiravataClient::getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken) +{ + send_getAllGateways(authzToken); + recv_getAllGateways(_return); +} + +void AiravataClient::send_getAllGateways(const ::apache::airavata::model::security::AuthzToken& authzToken) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getAllGateways", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_getAllGateways_pargs args; + args.authzToken = &authzToken; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void AiravataClient::recv_getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _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("getAllGateways") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getAllGateways_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; + } + if (result.__isset.ae) { + throw result.ae; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGateways failed: unknown result"); } -void AiravataClient::updateGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Gateway& updatedGateway) +bool AiravataClient::isGatewayExist(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) { - send_updateGateway(authzToken, gatewayId, updatedGateway); - recv_updateGateway(); + send_isGatewayExist(authzToken, gatewayId); + return recv_isGatewayExist(); } -void AiravataClient::send_updateGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Gateway& updatedGateway) +void AiravataClient::send_isGatewayExist(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) { int32_t cseqid = 0; - oprot_->writeMessageBegin("updateGateway", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("isGatewayExist", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_updateGateway_pargs args; + Airavata_isGatewayExist_pargs args; args.authzToken = &authzToken; args.gatewayId = &gatewayId; - args.updatedGateway = &updatedGateway; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42234,7 +43379,7 @@ void AiravataClient::send_updateGateway(const ::apache::airavata::model::securi oprot_->getTransport()->flush(); } -void AiravataClient::recv_updateGateway() +bool AiravataClient::recv_isGatewayExist() { int32_t rseqid = 0; @@ -42254,16 +43399,21 @@ void AiravataClient::recv_updateGateway() iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("updateGateway") != 0) { + if (fname.compare("isGatewayExist") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_updateGateway_presult result; + bool _return; + Airavata_isGatewayExist_presult result; + result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); + if (result.__isset.success) { + return _return; + } if (result.__isset.ire) { throw result.ire; } @@ -42276,23 +43426,24 @@ void AiravataClient::recv_updateGateway() if (result.__isset.ae) { throw result.ae; } - return; + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "isGatewayExist failed: unknown result"); } -void AiravataClient::getGateway( ::apache::airavata::model::workspace::Gateway& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::generateAndRegisterSSHKeys(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName) { - send_getGateway(authzToken, gatewayId); - recv_getGateway(_return); + send_generateAndRegisterSSHKeys(authzToken, gatewayId, userName); + recv_generateAndRegisterSSHKeys(_return); } -void AiravataClient::send_getGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::send_generateAndRegisterSSHKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getGateway", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("generateAndRegisterSSHKeys", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_getGateway_pargs args; + Airavata_generateAndRegisterSSHKeys_pargs args; args.authzToken = &authzToken; args.gatewayId = &gatewayId; + args.userName = &userName; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42300,7 +43451,7 @@ void AiravataClient::send_getGateway(const ::apache::airavata::model::security: oprot_->getTransport()->flush(); } -void AiravataClient::recv_getGateway( ::apache::airavata::model::workspace::Gateway& _return) +void AiravataClient::recv_generateAndRegisterSSHKeys(std::string& _return) { int32_t rseqid = 0; @@ -42320,12 +43471,12 @@ void AiravataClient::recv_getGateway( ::apache::airavata::model::workspace::Gate iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getGateway") != 0) { + if (fname.compare("generateAndRegisterSSHKeys") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getGateway_presult result; + Airavata_generateAndRegisterSSHKeys_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -42344,25 +43495,23 @@ void AiravataClient::recv_getGateway( ::apache::airavata::model::workspace::Gate if (result.__isset.ase) { throw result.ase; } - if (result.__isset.ae) { - throw result.ae; - } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getGateway failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result"); } -bool AiravataClient::deleteGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::getSSHPubKey(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) { - send_deleteGateway(authzToken, gatewayId); - return recv_deleteGateway(); + send_getSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); + recv_getSSHPubKey(_return); } -void AiravataClient::send_deleteGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::send_getSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) { int32_t cseqid = 0; - oprot_->writeMessageBegin("deleteGateway", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("getSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_deleteGateway_pargs args; + Airavata_getSSHPubKey_pargs args; args.authzToken = &authzToken; + args.airavataCredStoreToken = &airavataCredStoreToken; args.gatewayId = &gatewayId; args.write(oprot_); @@ -42371,7 +43520,7 @@ void AiravataClient::send_deleteGateway(const ::apache::airavata::model::securi oprot_->getTransport()->flush(); } -bool AiravataClient::recv_deleteGateway() +void AiravataClient::recv_getSSHPubKey(std::string& _return) { int32_t rseqid = 0; @@ -42391,20 +43540,20 @@ bool AiravataClient::recv_deleteGateway() iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("deleteGateway") != 0) { + if (fname.compare("getSSHPubKey") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - bool _return; - Airavata_deleteGateway_presult result; + Airavata_getSSHPubKey_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { - return _return; + // _return pointer has now been filled + return; } if (result.__isset.ire) { throw result.ire; @@ -42415,25 +43564,23 @@ bool AiravataClient::recv_deleteGateway() if (result.__isset.ase) { throw result.ase; } - if (result.__isset.ae) { - throw result.ae; - } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteGateway failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getSSHPubKey failed: unknown result"); } -void AiravataClient::getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken) +void AiravataClient::getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& userName) { - send_getAllGateways(authzToken); - recv_getAllGateways(_return); + send_getAllUserSSHPubKeys(authzToken, userName); + recv_getAllUserSSHPubKeys(_return); } -void AiravataClient::send_getAllGateways(const ::apache::airavata::model::security::AuthzToken& authzToken) +void AiravataClient::send_getAllUserSSHPubKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& userName) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getAllGateways", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("getAllUserSSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_getAllGateways_pargs args; + Airavata_getAllUserSSHPubKeys_pargs args; args.authzToken = &authzToken; + args.userName = &userName; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42441,7 +43588,7 @@ void AiravataClient::send_getAllGateways(const ::apache::airavata::model::secur oprot_->getTransport()->flush(); } -void AiravataClient::recv_getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return) +void AiravataClient::recv_getAllUserSSHPubKeys(std::map<std::string, std::string> & _return) { int32_t rseqid = 0; @@ -42461,12 +43608,12 @@ void AiravataClient::recv_getAllGateways(std::vector< ::apache::airavata::model: iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getAllGateways") != 0) { + if (fname.compare("getAllUserSSHPubKeys") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getAllGateways_presult result; + Airavata_getAllUserSSHPubKeys_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -42485,24 +43632,21 @@ void AiravataClient::recv_getAllGateways(std::vector< ::apache::airavata::model: if (result.__isset.ase) { throw result.ase; } - if (result.__isset.ae) { - throw result.ae; - } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGateways failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllUserSSHPubKeys failed: unknown result"); } -bool AiravataClient::isGatewayExist(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) { - send_isGatewayExist(authzToken, gatewayId); - return recv_isGatewayExist(); + send_getAllGatewaySSHPubKeys(authzToken, gatewayId); + recv_getAllGatewaySSHPubKeys(_return); } -void AiravataClient::send_isGatewayExist(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::send_getAllGatewaySSHPubKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) { int32_t cseqid = 0; - oprot_->writeMessageBegin("isGatewayExist", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("getAllGatewaySSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_isGatewayExist_pargs args; + Airavata_getAllGatewaySSHPubKeys_pargs args; args.authzToken = &authzToken; args.gatewayId = &gatewayId; args.write(oprot_); @@ -42512,7 +43656,7 @@ void AiravataClient::send_isGatewayExist(const ::apache::airavata::model::secur oprot_->getTransport()->flush(); } -bool AiravataClient::recv_isGatewayExist() +void AiravataClient::recv_getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return) { int32_t rseqid = 0; @@ -42532,20 +43676,20 @@ bool AiravataClient::recv_isGatewayExist() iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("isGatewayExist") != 0) { + if (fname.compare("getAllGatewaySSHPubKeys") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - bool _return; - Airavata_isGatewayExist_presult result; + Airavata_getAllGatewaySSHPubKeys_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { - return _return; + // _return pointer has now been filled + return; } if (result.__isset.ire) { throw result.ire; @@ -42556,27 +43700,24 @@ bool AiravataClient::recv_isGatewayExist() if (result.__isset.ase) { throw result.ase; } - if (result.__isset.ae) { - throw result.ae; - } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "isGatewayExist failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result"); } -void AiravataClient::generateAndRegisterSSHKeys(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName) +bool AiravataClient::deleteSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) { - send_generateAndRegisterSSHKeys(authzToken, gatewayId, userName); - recv_generateAndRegisterSSHKeys(_return); + send_deleteSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); + return recv_deleteSSHPubKey(); } -void AiravataClient::send_generateAndRegisterSSHKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName) +void AiravataClient::send_deleteSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) { int32_t cseqid = 0; - oprot_->writeMessageBegin("generateAndRegisterSSHKeys", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("deleteSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_generateAndRegisterSSHKeys_pargs args; + Airavata_deleteSSHPubKey_pargs args; args.authzToken = &authzToken; + args.airavataCredStoreToken = &airavataCredStoreToken; args.gatewayId = &gatewayId; - args.userName = &userName; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42584,7 +43725,7 @@ void AiravataClient::send_generateAndRegisterSSHKeys(const ::apache::airavata:: oprot_->getTransport()->flush(); } -void AiravataClient::recv_generateAndRegisterSSHKeys(std::string& _return) +bool AiravataClient::recv_deleteSSHPubKey() { int32_t rseqid = 0; @@ -42604,20 +43745,20 @@ void AiravataClient::recv_generateAndRegisterSSHKeys(std::string& _return) iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("generateAndRegisterSSHKeys") != 0) { + if (fname.compare("deleteSSHPubKey") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_generateAndRegisterSSHKeys_presult result; + bool _return; + Airavata_deleteSSHPubKey_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { - // _return pointer has now been filled - return; + return _return; } if (result.__isset.ire) { throw result.ire; @@ -42628,24 +43769,24 @@ void AiravataClient::recv_generateAndRegisterSSHKeys(std::string& _return) if (result.__isset.ase) { throw result.ase; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteSSHPubKey failed: unknown result"); } -void AiravataClient::getSSHPubKey(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) +void AiravataClient::createProject(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Project& project) { - send_getSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); - recv_getSSHPubKey(_return); + send_createProject(authzToken, gatewayId, project); + recv_createProject(_return); } -void AiravataClient::send_getSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) +void AiravataClient::send_createProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Project& project) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("createProject", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_getSSHPubKey_pargs args; + Airavata_createProject_pargs args; args.authzToken = &authzToken; - args.airavataCredStoreToken = &airavataCredStoreToken; args.gatewayId = &gatewayId; + args.project = &project; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42653,7 +43794,7 @@ void AiravataClient::send_getSSHPubKey(const ::apache::airavata::model::securit oprot_->getTransport()->flush(); } -void AiravataClient::recv_getSSHPubKey(std::string& _return) +void AiravataClient::recv_createProject(std::string& _return) { int32_t rseqid = 0; @@ -42673,12 +43814,12 @@ void AiravataClient::recv_getSSHPubKey(std::string& _return) iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getSSHPubKey") != 0) { + if (fname.compare("createProject") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getSSHPubKey_presult result; + Airavata_createProject_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -42697,23 +43838,27 @@ void AiravataClient::recv_getSSHPubKey(std::string& _return) if (result.__isset.ase) { throw result.ase; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getSSHPubKey failed: unknown result"); + if (result.__isset.ae) { + throw result.ae; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "createProject failed: unknown result"); } -void AiravataClient::getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& userName) +void AiravataClient::updateProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) { - send_getAllUserSSHPubKeys(authzToken, userName); - recv_getAllUserSSHPubKeys(_return); + send_updateProject(authzToken, projectId, updatedProject); + recv_updateProject(); } -void AiravataClient::send_getAllUserSSHPubKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& userName) +void AiravataClient::send_updateProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getAllUserSSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("updateProject", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_getAllUserSSHPubKeys_pargs args; + Airavata_updateProject_pargs args; args.authzToken = &authzToken; - args.userName = &userName; + args.projectId = &projectId; + args.updatedProject = &updatedProject; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42721,7 +43866,7 @@ void AiravataClient::send_getAllUserSSHPubKeys(const ::apache::airavata::model: oprot_->getTransport()->flush(); } -void AiravataClient::recv_getAllUserSSHPubKeys(std::map<std::string, std::string> & _return) +void AiravataClient::recv_updateProject() { int32_t rseqid = 0; @@ -42741,21 +43886,16 @@ void AiravataClient::recv_getAllUserSSHPubKeys(std::map<std::string, std::string iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getAllUserSSHPubKeys") != 0) { + if (fname.compare("updateProject") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getAllUserSSHPubKeys_presult result; - result.success = &_return; + Airavata_updateProject_presult result; 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; } @@ -42765,23 +43905,29 @@ void AiravataClient::recv_getAllUserSSHPubKeys(std::map<std::string, std::string if (result.__isset.ase) { throw result.ase; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllUserSSHPubKeys failed: unknown result"); + if (result.__isset.pnfe) { + throw result.pnfe; + } + if (result.__isset.ae) { + throw result.ae; + } + return; } -void AiravataClient::getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::getProject( ::apache::airavata::model::workspace::Project& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) { - send_getAllGatewaySSHPubKeys(authzToken, gatewayId); - recv_getAllGatewaySSHPubKeys(_return); + send_getProject(authzToken, projectId); + recv_getProject(_return); } -void AiravataClient::send_getAllGatewaySSHPubKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +void AiravataClient::send_getProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getAllGatewaySSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("getProject", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_getAllGatewaySSHPubKeys_pargs args; + Airavata_getProject_pargs args; args.authzToken = &authzToken; - args.gatewayId = &gatewayId; + args.projectId = &projectId; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42789,7 +43935,7 @@ void AiravataClient::send_getAllGatewaySSHPubKeys(const ::apache::airavata::mod oprot_->getTransport()->flush(); } -void AiravataClient::recv_getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return) +void AiravataClient::recv_getProject( ::apache::airavata::model::workspace::Project& _return) { int32_t rseqid = 0; @@ -42809,12 +43955,12 @@ void AiravataClient::recv_getAllGatewaySSHPubKeys(std::map<std::string, std::str iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getAllGatewaySSHPubKeys") != 0) { + if (fname.compare("getProject") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getAllGatewaySSHPubKeys_presult result; + Airavata_getProject_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -42833,24 +43979,29 @@ void AiravataClient::recv_getAllGatewaySSHPubKeys(std::map<std::string, std::str if (result.__isset.ase) { throw result.ase; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result"); + if (result.__isset.pnfe) { + throw result.pnfe; + } + if (result.__isset.ae) { + throw result.ae; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getProject failed: unknown result"); } -bool AiravataClient::deleteSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) +bool AiravataClient::deleteProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) { - send_deleteSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); - return recv_deleteSSHPubKey(); + send_deleteProject(authzToken, projectId); + return recv_deleteProject(); } -void AiravataClient::send_deleteSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) +void AiravataClient::send_deleteProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) { int32_t cseqid = 0; - oprot_->writeMessageBegin("deleteSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("deleteProject", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_deleteSSHPubKey_pargs args; + Airavata_deleteProject_pargs args; args.authzToken = &authzToken; - args.airavataCredStoreToken = &airavataCredStoreToken; - args.gatewayId = &gatewayId; + args.projectId = &projectId; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42858,7 +44009,7 @@ void AiravataClient::send_deleteSSHPubKey(const ::apache::airavata::model::secu oprot_->getTransport()->flush(); } -bool AiravataClient::recv_deleteSSHPubKey() +bool AiravataClient::recv_deleteProject() { int32_t rseqid = 0; @@ -42878,13 +44029,13 @@ bool AiravataClient::recv_deleteSSHPubKey() iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("deleteSSHPubKey") != 0) { + if (fname.compare("deleteProject") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } bool _return; - Airavata_deleteSSHPubKey_presult result; + Airavata_deleteProject_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -42902,24 +44053,32 @@ bool AiravataClient::recv_deleteSSHPubKey() if (result.__isset.ase) { throw result.ase; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteSSHPubKey failed: unknown result"); + if (result.__isset.pnfe) { + throw result.pnfe; + } + if (result.__isset.ae) { + throw result.ae; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteProject failed: unknown result"); } -void AiravataClient::createProject(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Project& project) +void AiravataClient::getUserProjects(std::vector< ::apache::airavata::model::workspace::Project> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const int32_t limit, const int32_t offset) { - send_createProject(authzToken, gatewayId, project); - recv_createProject(_return); + send_getUserProjects(authzToken, gatewayId, userName, limit, offset); + recv_getUserProjects(_return); } -void AiravataClient::send_createProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const ::apache::airavata::model::workspace::Project& project) +void AiravataClient::send_getUserProjects(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const int32_t limit, const int32_t offset) { int32_t cseqid = 0; - oprot_->writeMessageBegin("createProject", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("getUserProjects", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_createProject_pargs args; + Airavata_getUserProjects_pargs args; args.authzToken = &authzToken; args.gatewayId = &gatewayId; - args.project = &project; + args.userName = &userName; + args.limit = &limit; + args.offset = &offset; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42927,7 +44086,7 @@ void AiravataClient::send_createProject(const ::apache::airavata::model::securi oprot_->getTransport()->flush(); } -void AiravataClient::recv_createProject(std::string& _return) +void AiravataClient::recv_getUserProjects(std::vector< ::apache::airavata::model::workspace::Project> & _return) { int32_t rseqid = 0; @@ -42947,12 +44106,12 @@ void AiravataClient::recv_createProject(std::string& _return) iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("createProject") != 0) { + if (fname.compare("getUserProjects") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_createProject_presult result; + Airavata_getUserProjects_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -42974,24 +44133,27 @@ void AiravataClient::recv_createProject(std::string& _return) if (result.__isset.ae) { throw result.ae; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "createProject failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getUserProjects failed: unknown result"); } -void AiravataClient::updateProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) +void AiravataClient::searchProjectsByProjectName(std::vector< ::apache::airavata::model::workspace::Project> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& projectName, const int32_t limit, const int32_t offset) { - send_updateProject(authzToken, projectId, updatedProject); - recv_updateProject(); + send_searchProjectsByProjectName(authzToken, gatewayId, userName, projectName, limit, offset); + recv_searchProjectsByProjectName(_return); } -void AiravataClient::send_updateProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) +void AiravataClient::send_searchProjectsByProjectName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& projectName, const int32_t limit, const int32_t offset) { int32_t cseqid = 0; - oprot_->writeMessageBegin("updateProject", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("searchProjectsByProjectName", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_updateProject_pargs args; + Airavata_searchProjectsByProjectName_pargs args; args.authzToken = &authzToken; - args.projectId = &projectId; - args.updatedProject = &updatedProject; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.projectName = &projectName; + args.limit = &limit; + args.offset = &offset; args.write(oprot_); oprot_->writeMessageEnd(); @@ -42999,7 +44161,7 @@ void AiravataClient::send_updateProject(const ::apache::airavata::model::securi oprot_->getTransport()->flush(); } -void AiravataClient::recv_updateProject() +void AiravataClient::recv_searchProjectsByProjectName(std::vector< ::apache::airavata::model::workspace::Project> & _return) { int32_t rseqid = 0; @@ -43019,16 +44181,21 @@ void AiravataClient::recv_updateProject() iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("updateProject") != 0) { + if (fname.compare("searchProjectsByProjectName") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_updateProject_presult result; + Airavata_searchProjectsByProjectName_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; } @@ -43038,29 +44205,30 @@ void AiravataClient::recv_updateProject() if (result.__isset.ase) { throw result.ase; } - if (result.__isset.pnfe) { - throw result.pnfe; - } if (result.__isset.ae) { throw result.ae; } - return; + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchProjectsByProjectName failed: unknown result"); } -void AiravataClient::getProject( ::apache::airavata::model::workspace::Project& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +void AiravataClient::searchProjectsByProjectDesc(std::vector< ::apache::airavata::model::workspace::Project> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& description, const int32_t limit, const int32_t offset) { - send_getProject(authzToken, projectId); - recv_getProject(_return); + send_searchProjectsByProjectDesc(authzToken, gatewayId, userName, description, limit, offset); + recv_searchProjectsByProjectDesc(_return); } -void AiravataClient::send_getProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +void AiravataClient::send_searchProjectsByProjectDesc(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& description, const int32_t limit, const int32_t offset) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getProject", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("searchProjectsByProjectDesc", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_getProject_pargs args; + Airavata_searchProjectsByProjectDesc_pargs args; args.authzToken = &authzToken; - args.projectId = &projectId; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.description = &description; + args.limit = &limit; + args.offset = &offset; args.write(oprot_); oprot_->writeMessageEnd(); @@ -43068,7 +44236,7 @@ void AiravataClient::send_getProject(const ::apache::airavata::model::security: oprot_->getTransport()->flush(); } -void AiravataClient::recv_getProject( ::apache::airavata::model::workspace::Project& _return) +void AiravataClient::recv_searchProjectsByProjectDesc(std::vector< ::apache::airavata::model::workspace::Project> & _return) { int32_t rseqid = 0; @@ -43088,12 +44256,12 @@ void AiravataClient::recv_getProject( ::apache::airavata::model::workspace::Proj iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getProject") != 0) { + if (fname.compare("searchProjectsByProjectDesc") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - Airavata_getProject_presult result; + Airavata_searchProjectsByProjectDesc_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -43112,29 +44280,30 @@ void AiravataClient::recv_getProject( ::apache::airavata::model::workspace::Proj if (result.__isset.ase) { throw result.ase; } - if (result.__isset.pnfe) { - throw result.pnfe; - } if (result.__isset.ae) { throw result.ae; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getProject failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchProjectsByProjectDesc failed: unknown result"); } -bool AiravataClient::deleteProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +void AiravataClient::searchExperimentsByName(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& expName, const int32_t limit, const int32_t offset) { - send_deleteProject(authzToken, projectId); - return recv_deleteProject(); + send_searchExperimentsByName(authzToken, gatewayId, userName, expName, limit, offset); + recv_searchExperimentsByName(_return); } -void AiravataClient::send_deleteProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +void AiravataClient::send_searchExperimentsByName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& expName, const int32_t limit, const int32_t offset) { int32_t cseqid = 0; - oprot_->writeMessageBegin("deleteProject", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("searchExperimentsByName", ::apache::thrift::protocol::T_CALL, cseqid); - Airavata_deleteProject_pargs args; + Airavata_searchExperimentsByName_pargs args; args.authzToken = &authzToken; - args.projectId = &projectId; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.expName = &expName; + args.limit = &limit; + args.offset = &offset; args.write(oprot_); oprot_->writeMessageEnd(); @@ -43142,7 +44311,7 @@ void AiravataClient::send_deleteProject(const ::apache::airavata::model::securi oprot_->getTransport()->flush(); } -bool AiravataClient::recv_deleteProject() +void AiravataClient::recv_searchExperimentsByName(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return) { int32_t rseqid = 0; @@ -43162,20 +44331,20 @@ bool AiravataClient::recv_deleteProject() iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("deleteProject") != 0) { + if (fname.compare("searchExperimentsByName") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - bool _return; - Airavata_deleteProject_presult result; + Airavata_searchExperimentsByName_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { - return _return; + // _return pointer has now been filled + return; } if (result.__isset.ire) { throw result.ire; @@ -43186,30 +44355,28 @@ bool AiravataClient::recv_deleteProject() if (result.__isset.ase) { throw result.ase; } - if (result.__isset.pnfe) { - throw result.pnfe; - } if (result.__isset.ae) { throw result.ae; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteProject failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperimentsByName failed: unknown result"); } -void AiravataClient::getUserProjects(std::vector< ::apache::airavata::model::workspace::Project> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const int32_t limit, const int32_t offset) +void AiravataClient::searchExperimentsByDesc(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& description, const int32_t limit, const int32_t offset) { - send_getUserProjects(authzToken, gatewayId, userName, limit, offset); - recv_getUserProjects(_return); + send_searchExperimentsByDesc(authzToken, gatewayId, userName, d
<TRUNCATED>
