http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/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 c73bcc9..d384450 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 @@ -41352,1817 +41352,1903 @@ uint32_t Airavata_isWorkflowExistWithName_presult::read(::apache::thrift::protoc return xfer; } - -Airavata_registerDataResource_args::~Airavata_registerDataResource_args() throw() { +void AiravataClient::getAPIVersion(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken) +{ + send_getAPIVersion(authzToken); + recv_getAPIVersion(_return); } +void AiravataClient::send_getAPIVersion(const ::apache::airavata::model::security::AuthzToken& authzToken) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getAPIVersion", ::apache::thrift::protocol::T_CALL, cseqid); -uint32_t Airavata_registerDataResource_args::read(::apache::thrift::protocol::TProtocol* iprot) { + Airavata_getAPIVersion_pargs args; + args.authzToken = &authzToken; + args.write(oprot_); - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - xfer += iprot->readStructBegin(fname); +void AiravataClient::recv_getAPIVersion(std::string& _return) +{ - using ::apache::thrift::protocol::TProtocolException; + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - bool isset_authzToken = false; - bool isset_dataResourceModel = false; + 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(); - 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->dataResourceModel.read(iprot); - isset_dataResourceModel = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); + 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, "getAPIVersion failed: unknown result"); +} - xfer += iprot->readStructEnd(); +void AiravataClient::addGateway(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::workspace::Gateway& gateway) +{ + send_addGateway(authzToken, gateway); + recv_addGateway(_return); +} - if (!isset_authzToken) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_dataResourceModel) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; +void AiravataClient::send_addGateway(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::workspace::Gateway& gateway) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("addGateway", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_addGateway_pargs args; + args.authzToken = &authzToken; + args.gateway = &gateway; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } -uint32_t Airavata_registerDataResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_registerDataResource_args"); +void AiravataClient::recv_addGateway(std::string& _return) +{ - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->authzToken.write(oprot); - xfer += oprot->writeFieldEnd(); + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeFieldBegin("dataResourceModel", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->dataResourceModel.write(oprot); - 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(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("addGateway") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_addGateway_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; + 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, "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_); -Airavata_registerDataResource_pargs::~Airavata_registerDataResource_pargs() throw() { + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } +void AiravataClient::recv_updateGateway() +{ -uint32_t Airavata_registerDataResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_registerDataResource_pargs"); + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += (*(this->authzToken)).write(oprot); - 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(); + 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(); - xfer += oprot->writeFieldBegin("dataResourceModel", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->dataResourceModel)).write(oprot); - xfer += oprot->writeFieldEnd(); + 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; +} - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; +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_registerDataResource_result::~Airavata_registerDataResource_result() throw() { -} + Airavata_getGateway_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.write(oprot_); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} -uint32_t Airavata_registerDataResource_result::read(::apache::thrift::protocol::TProtocol* iprot) { +void AiravataClient::recv_getGateway( ::apache::airavata::model::workspace::Gateway& _return) +{ - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; + int32_t rseqid = 0; std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + ::apache::thrift::protocol::TMessageType mtype; - xfer += iprot->readStructBegin(fname); + 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(); - using ::apache::thrift::protocol::TProtocolException; + 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(); +} - 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(); - } +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); - xfer += iprot->readStructEnd(); + Airavata_deleteGateway_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.write(oprot_); - return xfer; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } -uint32_t Airavata_registerDataResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +bool AiravataClient::recv_deleteGateway() +{ - uint32_t xfer = 0; + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeStructBegin("Airavata_registerDataResource_result"); + 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 (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(); + if (result.__isset.success) { + return _return; } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; + 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"); } - -Airavata_registerDataResource_presult::~Airavata_registerDataResource_presult() throw() { +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); -uint32_t Airavata_registerDataResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + Airavata_getAllGateways_pargs args; + args.authzToken = &authzToken; + args.write(oprot_); - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - xfer += iprot->readStructBegin(fname); +void AiravataClient::recv_getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return) +{ - using ::apache::thrift::protocol::TProtocolException; + 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(); - 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(); + 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"); +} - xfer += iprot->readStructEnd(); - - return xfer; +bool AiravataClient::isGatewayExist(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + send_isGatewayExist(authzToken, gatewayId); + return recv_isGatewayExist(); } +void AiravataClient::send_isGatewayExist(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("isGatewayExist", ::apache::thrift::protocol::T_CALL, cseqid); -Airavata_updateDataResource_args::~Airavata_updateDataResource_args() throw() { -} + Airavata_isGatewayExist_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.write(oprot_); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} -uint32_t Airavata_updateDataResource_args::read(::apache::thrift::protocol::TProtocol* iprot) { +bool AiravataClient::recv_isGatewayExist() +{ - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; + int32_t rseqid = 0; std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + ::apache::thrift::protocol::TMessageType mtype; - xfer += iprot->readStructBegin(fname); + 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("isGatewayExist") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + bool _return; + Airavata_isGatewayExist_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - using ::apache::thrift::protocol::TProtocolException; + 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, "isGatewayExist failed: unknown result"); +} - bool isset_authzToken = false; - bool isset_dataResourceModel = false; +void AiravataClient::generateAndRegisterSSHKeys(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName) +{ + send_generateAndRegisterSSHKeys(authzToken, gatewayId, userName); + recv_generateAndRegisterSSHKeys(_return); +} - 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->dataResourceModel.read(iprot); - isset_dataResourceModel = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } +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("generateAndRegisterSSHKeys", ::apache::thrift::protocol::T_CALL, cseqid); - xfer += iprot->readStructEnd(); + Airavata_generateAndRegisterSSHKeys_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.write(oprot_); - if (!isset_authzToken) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_dataResourceModel) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } -uint32_t Airavata_updateDataResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_updateDataResource_args"); +void AiravataClient::recv_generateAndRegisterSSHKeys(std::string& _return) +{ - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->authzToken.write(oprot); - xfer += oprot->writeFieldEnd(); + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeFieldBegin("dataResourceModel", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->dataResourceModel.write(oprot); - 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(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("generateAndRegisterSSHKeys") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_generateAndRegisterSSHKeys_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; + 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, "generateAndRegisterSSHKeys failed: unknown result"); } +void AiravataClient::getSSHPubKey(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) +{ + send_getSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); + recv_getSSHPubKey(_return); +} + +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("getSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_getSSHPubKey_pargs args; + args.authzToken = &authzToken; + args.airavataCredStoreToken = &airavataCredStoreToken; + args.gatewayId = &gatewayId; + args.write(oprot_); -Airavata_updateDataResource_pargs::~Airavata_updateDataResource_pargs() throw() { + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } +void AiravataClient::recv_getSSHPubKey(std::string& _return) +{ -uint32_t Airavata_updateDataResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_updateDataResource_pargs"); + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += (*(this->authzToken)).write(oprot); - 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(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("getSSHPubKey") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getSSHPubKey_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += oprot->writeFieldBegin("dataResourceModel", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->dataResourceModel)).write(oprot); - xfer += oprot->writeFieldEnd(); + 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, "getSSHPubKey failed: unknown result"); +} - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; +void AiravataClient::getAllUserSSHPubKeys(std::map<std::string, std::string> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& userName) +{ + send_getAllUserSSHPubKeys(authzToken, userName); + recv_getAllUserSSHPubKeys(_return); } +void AiravataClient::send_getAllUserSSHPubKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& userName) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getAllUserSSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid); -Airavata_updateDataResource_result::~Airavata_updateDataResource_result() throw() { -} + Airavata_getAllUserSSHPubKeys_pargs args; + args.authzToken = &authzToken; + args.userName = &userName; + args.write(oprot_); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} -uint32_t Airavata_updateDataResource_result::read(::apache::thrift::protocol::TProtocol* iprot) { +void AiravataClient::recv_getAllUserSSHPubKeys(std::map<std::string, std::string> & _return) +{ - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; + int32_t rseqid = 0; std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + ::apache::thrift::protocol::TMessageType mtype; - xfer += iprot->readStructBegin(fname); + 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("getAllUserSSHPubKeys") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getAllUserSSHPubKeys_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - using ::apache::thrift::protocol::TProtocolException; + 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, "getAllUserSSHPubKeys failed: unknown result"); +} +void AiravataClient::getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + send_getAllGatewaySSHPubKeys(authzToken, gatewayId); + recv_getAllGatewaySSHPubKeys(_return); +} - 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->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(); - } +void AiravataClient::send_getAllGatewaySSHPubKeys(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getAllGatewaySSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid); - xfer += iprot->readStructEnd(); + Airavata_getAllGatewaySSHPubKeys_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.write(oprot_); - return xfer; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } -uint32_t Airavata_updateDataResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +void AiravataClient::recv_getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return) +{ - uint32_t xfer = 0; + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeStructBegin("Airavata_updateDataResource_result"); + 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("getAllGatewaySSHPubKeys") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getAllGatewaySSHPubKeys_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - 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(); + if (result.__isset.success) { + // _return pointer has now been filled + return; } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; + 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, "getAllGatewaySSHPubKeys failed: unknown result"); } - -Airavata_updateDataResource_presult::~Airavata_updateDataResource_presult() throw() { +bool AiravataClient::deleteSSHPubKey(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId) +{ + send_deleteSSHPubKey(authzToken, airavataCredStoreToken, gatewayId); + return recv_deleteSSHPubKey(); } +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("deleteSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid); -uint32_t Airavata_updateDataResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + Airavata_deleteSSHPubKey_pargs args; + args.authzToken = &authzToken; + args.airavataCredStoreToken = &airavataCredStoreToken; + args.gatewayId = &gatewayId; + args.write(oprot_); - 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); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - using ::apache::thrift::protocol::TProtocolException; +bool AiravataClient::recv_deleteSSHPubKey() +{ + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - 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->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(); + 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("deleteSSHPubKey") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + bool _return; + Airavata_deleteSSHPubKey_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += iprot->readStructEnd(); - - return xfer; + 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; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteSSHPubKey failed: unknown result"); } - -Airavata_removeDataResource_args::~Airavata_removeDataResource_args() throw() { +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_createProject(authzToken, gatewayId, project); + recv_createProject(_return); } +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("createProject", ::apache::thrift::protocol::T_CALL, cseqid); -uint32_t Airavata_removeDataResource_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; + Airavata_createProject_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.project = &project; + args.write(oprot_); - xfer += iprot->readStructBegin(fname); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - using ::apache::thrift::protocol::TProtocolException; +void AiravataClient::recv_createProject(std::string& _return) +{ - bool isset_authzToken = false; - bool isset_resourceId = false; + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - 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->resourceId); - isset_resourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); + 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("createProject") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_createProject_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += iprot->readStructEnd(); - - if (!isset_authzToken) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_resourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; + 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, "createProject failed: unknown result"); } -uint32_t Airavata_removeDataResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_removeDataResource_args"); - - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->authzToken.write(oprot); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->resourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; +void AiravataClient::updateProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId, const ::apache::airavata::model::workspace::Project& updatedProject) +{ + send_updateProject(authzToken, projectId, updatedProject); + recv_updateProject(); } +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("updateProject", ::apache::thrift::protocol::T_CALL, cseqid); + + Airavata_updateProject_pargs args; + args.authzToken = &authzToken; + args.projectId = &projectId; + args.updatedProject = &updatedProject; + args.write(oprot_); -Airavata_removeDataResource_pargs::~Airavata_removeDataResource_pargs() throw() { + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } +void AiravataClient::recv_updateProject() +{ -uint32_t Airavata_removeDataResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_removeDataResource_pargs"); + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += (*(this->authzToken)).write(oprot); - 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(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("updateProject") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_updateProject_presult result; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->resourceId))); - xfer += oprot->writeFieldEnd(); + if (result.__isset.ire) { + throw result.ire; + } + if (result.__isset.ace) { + throw result.ace; + } + if (result.__isset.ase) { + throw result.ase; + } + if (result.__isset.pnfe) { + throw result.pnfe; + } + if (result.__isset.ae) { + throw result.ae; + } + return; +} - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; +void AiravataClient::getProject( ::apache::airavata::model::workspace::Project& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +{ + send_getProject(authzToken, projectId); + recv_getProject(_return); } +void AiravataClient::send_getProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getProject", ::apache::thrift::protocol::T_CALL, cseqid); -Airavata_removeDataResource_result::~Airavata_removeDataResource_result() throw() { -} + Airavata_getProject_pargs args; + args.authzToken = &authzToken; + args.projectId = &projectId; + args.write(oprot_); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} -uint32_t Airavata_removeDataResource_result::read(::apache::thrift::protocol::TProtocol* iprot) { +void AiravataClient::recv_getProject( ::apache::airavata::model::workspace::Project& _return) +{ - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; + int32_t rseqid = 0; std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + ::apache::thrift::protocol::TMessageType mtype; - xfer += iprot->readStructBegin(fname); + 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("getProject") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_getProject_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - using ::apache::thrift::protocol::TProtocolException; + 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.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::deleteProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +{ + send_deleteProject(authzToken, projectId); + return recv_deleteProject(); +} - 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->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(); - } +void AiravataClient::send_deleteProject(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& projectId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("deleteProject", ::apache::thrift::protocol::T_CALL, cseqid); - xfer += iprot->readStructEnd(); + Airavata_deleteProject_pargs args; + args.authzToken = &authzToken; + args.projectId = &projectId; + args.write(oprot_); - return xfer; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } -uint32_t Airavata_removeDataResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +bool AiravataClient::recv_deleteProject() +{ - uint32_t xfer = 0; + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeStructBegin("Airavata_removeDataResource_result"); + 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("deleteProject") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + bool _return; + Airavata_deleteProject_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - 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(); + if (result.__isset.success) { + return _return; } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; + if (result.__isset.ire) { + throw result.ire; + } + if (result.__isset.ace) { + throw result.ace; + } + 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"); } - -Airavata_removeDataResource_presult::~Airavata_removeDataResource_presult() throw() { +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_getUserProjects(authzToken, gatewayId, userName, limit, offset); + recv_getUserProjects(_return); } +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("getUserProjects", ::apache::thrift::protocol::T_CALL, cseqid); -uint32_t Airavata_removeDataResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + Airavata_getUserProjects_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - 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); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - using ::apache::thrift::protocol::TProtocolException; +void AiravataClient::recv_getUserProjects(std::vector< ::apache::airavata::model::workspace::Project> & _return) +{ + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - 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->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(); + 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("getUserProjects") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); } + Airavata_getUserProjects_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += iprot->readStructEnd(); + 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, "getUserProjects failed: unknown result"); +} - return xfer; +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_searchProjectsByProjectName(authzToken, gatewayId, userName, projectName, limit, offset); + recv_searchProjectsByProjectName(_return); } +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("searchProjectsByProjectName", ::apache::thrift::protocol::T_CALL, cseqid); -Airavata_getDataResource_args::~Airavata_getDataResource_args() throw() { -} + Airavata_searchProjectsByProjectName_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.projectName = &projectName; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} -uint32_t Airavata_getDataResource_args::read(::apache::thrift::protocol::TProtocol* iprot) { +void AiravataClient::recv_searchProjectsByProjectName(std::vector< ::apache::airavata::model::workspace::Project> & _return) +{ - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; + int32_t rseqid = 0; std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + ::apache::thrift::protocol::TMessageType mtype; - xfer += iprot->readStructBegin(fname); + 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("searchProjectsByProjectName") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchProjectsByProjectName_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - using ::apache::thrift::protocol::TProtocolException; + 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, "searchProjectsByProjectName failed: unknown result"); +} - bool isset_authzToken = false; - bool isset_resourceId = false; +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_searchProjectsByProjectDesc(authzToken, gatewayId, userName, description, limit, offset); + recv_searchProjectsByProjectDesc(_return); +} - 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->resourceId); - isset_resourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } +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("searchProjectsByProjectDesc", ::apache::thrift::protocol::T_CALL, cseqid); - xfer += iprot->readStructEnd(); + Airavata_searchProjectsByProjectDesc_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.description = &description; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - if (!isset_authzToken) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_resourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } -uint32_t Airavata_getDataResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_getDataResource_args"); +void AiravataClient::recv_searchProjectsByProjectDesc(std::vector< ::apache::airavata::model::workspace::Project> & _return) +{ - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->authzToken.write(oprot); - xfer += oprot->writeFieldEnd(); + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->resourceId); - 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(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("searchProjectsByProjectDesc") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchProjectsByProjectDesc_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; + 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, "searchProjectsByProjectDesc failed: unknown result"); } - -Airavata_getDataResource_pargs::~Airavata_getDataResource_pargs() throw() { +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_searchExperimentsByName(authzToken, gatewayId, userName, expName, limit, offset); + recv_searchExperimentsByName(_return); } +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("searchExperimentsByName", ::apache::thrift::protocol::T_CALL, cseqid); -uint32_t Airavata_getDataResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("Airavata_getDataResource_pargs"); + Airavata_searchExperimentsByName_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.expName = &expName; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += (*(this->authzToken)).write(oprot); - xfer += oprot->writeFieldEnd(); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString((*(this->resourceId))); - xfer += oprot->writeFieldEnd(); +void AiravataClient::recv_searchExperimentsByName(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return) +{ - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} + 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("searchExperimentsByName") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchExperimentsByName_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); -Airavata_getDataResource_result::~Airavata_getDataResource_result() throw() { + 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, "searchExperimentsByName failed: unknown result"); } +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_searchExperimentsByDesc(authzToken, gatewayId, userName, description, limit, offset); + recv_searchExperimentsByDesc(_return); +} -uint32_t Airavata_getDataResource_result::read(::apache::thrift::protocol::TProtocol* iprot) { +void AiravataClient::send_searchExperimentsByDesc(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("searchExperimentsByDesc", ::apache::thrift::protocol::T_CALL, cseqid); - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + Airavata_searchExperimentsByDesc_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.description = &description; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - xfer += iprot->readStructBegin(fname); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - using ::apache::thrift::protocol::TProtocolException; +void AiravataClient::recv_searchExperimentsByDesc(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return) +{ + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - 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(); + 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("searchExperimentsByDesc") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchExperimentsByDesc_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += iprot->readStructEnd(); - - return xfer; + 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, "searchExperimentsByDesc failed: unknown result"); } -uint32_t Airavata_getDataResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +void AiravataClient::searchExperimentsByApplication(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& applicationId, const int32_t limit, const int32_t offset) +{ + send_searchExperimentsByApplication(authzToken, gatewayId, userName, applicationId, limit, offset); + recv_searchExperimentsByApplication(_return); +} - uint32_t xfer = 0; +void AiravataClient::send_searchExperimentsByApplication(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const std::string& applicationId, const int32_t limit, const int32_t offset) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("searchExperimentsByApplication", ::apache::thrift::protocol::T_CALL, cseqid); - xfer += oprot->writeStructBegin("Airavata_getDataResource_result"); + Airavata_searchExperimentsByApplication_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.applicationId = &applicationId; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - 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; + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); } +void AiravataClient::recv_searchExperimentsByApplication(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _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("searchExperimentsByApplication") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchExperimentsByApplication_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); -Airavata_getDataResource_presult::~Airavata_getDataResource_presult() throw() { + 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, "searchExperimentsByApplication failed: unknown result"); } +void AiravataClient::searchExperimentsByStatus(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const ::apache::airavata::model::status::ExperimentState::type experimentState, const int32_t limit, const int32_t offset) +{ + send_searchExperimentsByStatus(authzToken, gatewayId, userName, experimentState, limit, offset); + recv_searchExperimentsByStatus(_return); +} -uint32_t Airavata_getDataResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +void AiravataClient::send_searchExperimentsByStatus(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const ::apache::airavata::model::status::ExperimentState::type experimentState, const int32_t limit, const int32_t offset) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("searchExperimentsByStatus", ::apache::thrift::protocol::T_CALL, cseqid); - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; + Airavata_searchExperimentsByStatus_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.experimentState = &experimentState; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - xfer += iprot->readStructBegin(fname); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - using ::apache::thrift::protocol::TProtocolException; +void AiravataClient::recv_searchExperimentsByStatus(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return) +{ + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; - 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(); + 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("searchExperimentsByStatus") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + Airavata_searchExperimentsByStatus_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); - xfer += iprot->readStructEnd(); - - return xfer; + 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, "searchExperimentsByStatus failed: unknown result"); } - -Airavata_copyDataResource_args::~Airavata_copyDataResource_args() throw() { +void AiravataClient::searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const int64_t fromTime, const int64_t toTime, const int32_t limit, const int32_t offset) +{ + send_searchExperimentsByCreationTime(authzToken, gatewayId, userName, fromTime, toTime, limit, offset); + recv_searchExperimentsByCreationTime(_return); } +void AiravataClient::send_searchExperimentsByCreationTime(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName, const int64_t fromTime, const int64_t toTime, const int32_t limit, const int32_t offset) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("searchExperimentsByCreationTime", ::apache::thrift::protocol::T_CALL, cseqid); -uint32_t Airavata_copyDataResource_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; + Airavata_searchExperimentsByCreationTime_pargs args; + args.authzToken = &authzToken; + args.gatewayId = &gatewayId; + args.userName = &userName; + args.fromTime = &fromTime; + args.toTime = &toTime; + args.limit = &limit; + args.offset = &offset; + args.write(oprot_); - xfer += iprot->readStructBegin(fname); + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} - using ::apache::thrift::protocol::TProtocolException; +void AiravataClient::recv_searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::experiment::ExperimentSummaryModel> & _return) +{ - bool isset_authzToken = false; - bool isset_resourceId = false; - bool isset_destStorageResourceId = false; - bool isset_destinationParentPath = false; + int32_t rseqid = 0; + std::string fname; + ::apac
<TRUNCATED>
