http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/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 c0c97ea..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,291 +41352,6 @@ uint32_t Airavata_isWorkflowExistWithName_presult::read(::apache::thrift::protoc return xfer; } - -Airavata_publishDataResource_args::~Airavata_publishDataResource_args() throw() { -} - - -uint32_t Airavata_publishDataResource_args::read(::apache::thrift::protocol::TProtocol* iprot) { - - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_authzToken = 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->resourceModel.read(iprot); - this->__isset.resourceModel = 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); - return xfer; -} - -uint32_t Airavata_publishDataResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_publishDataResource_args"); - - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->authzToken.write(oprot); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("resourceModel", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->resourceModel.write(oprot); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - oprot->decrementRecursionDepth(); - return xfer; -} - - -Airavata_publishDataResource_pargs::~Airavata_publishDataResource_pargs() throw() { -} - - -uint32_t Airavata_publishDataResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("Airavata_publishDataResource_pargs"); - - xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += (*(this->authzToken)).write(oprot); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("resourceModel", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->resourceModel)).write(oprot); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - oprot->decrementRecursionDepth(); - return xfer; -} - - -Airavata_publishDataResource_result::~Airavata_publishDataResource_result() throw() { -} - - -uint32_t Airavata_publishDataResource_result::read(::apache::thrift::protocol::TProtocol* iprot) { - - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 0: - if (ftype == ::apache::thrift::protocol::T_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_publishDataResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const { - - uint32_t xfer = 0; - - xfer += oprot->writeStructBegin("Airavata_publishDataResource_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_publishDataResource_presult::~Airavata_publishDataResource_presult() throw() { -} - - -uint32_t Airavata_publishDataResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 0: - if (ftype == ::apache::thrift::protocol::T_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); @@ -51089,77 +50804,6 @@ bool AiravataClient::recv_isWorkflowExistWithName() throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "isWorkflowExistWithName failed: unknown result"); } -void AiravataClient::publishDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel) -{ - send_publishDataResource(authzToken, resourceModel); - recv_publishDataResource(_return); -} - -void AiravataClient::send_publishDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel) -{ - int32_t cseqid = 0; - oprot_->writeMessageBegin("publishDataResource", ::apache::thrift::protocol::T_CALL, cseqid); - - Airavata_publishDataResource_pargs args; - args.authzToken = &authzToken; - args.resourceModel = &resourceModel; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); -} - -void AiravataClient::recv_publishDataResource(std::string& _return) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - iprot_->readMessageBegin(fname, mtype, rseqid); - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("publishDataResource") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - Airavata_publishDataResource_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, "publishDataResource failed: unknown result"); -} - bool AiravataProcessor::dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext) { ProcessMap::iterator pfn; pfn = processMap_.find(fname); @@ -59897,72 +59541,6 @@ void AiravataProcessor::process_isWorkflowExistWithName(int32_t seqid, ::apache: } } -void AiravataProcessor::process_publishDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) -{ - void* ctx = NULL; - if (this->eventHandler_.get() != NULL) { - ctx = this->eventHandler_->getContext("Airavata.publishDataResource", callContext); - } - ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.publishDataResource"); - - if (this->eventHandler_.get() != NULL) { - this->eventHandler_->preRead(ctx, "Airavata.publishDataResource"); - } - - Airavata_publishDataResource_args args; - args.read(iprot); - iprot->readMessageEnd(); - uint32_t bytes = iprot->getTransport()->readEnd(); - - if (this->eventHandler_.get() != NULL) { - this->eventHandler_->postRead(ctx, "Airavata.publishDataResource", bytes); - } - - Airavata_publishDataResource_result result; - try { - iface_->publishDataResource(result.success, args.authzToken, args.resourceModel); - result.__isset.success = true; - } catch ( ::apache::airavata::api::error::InvalidRequestException &ire) { - result.ire = ire; - result.__isset.ire = true; - } catch ( ::apache::airavata::api::error::AiravataClientException &ace) { - result.ace = ace; - result.__isset.ace = true; - } catch ( ::apache::airavata::api::error::AiravataSystemException &ase) { - result.ase = ase; - result.__isset.ase = true; - } catch ( ::apache::airavata::api::error::AuthorizationException &ae) { - result.ae = ae; - result.__isset.ae = true; - } catch (const std::exception& e) { - if (this->eventHandler_.get() != NULL) { - this->eventHandler_->handlerError(ctx, "Airavata.publishDataResource"); - } - - ::apache::thrift::TApplicationException x(e.what()); - oprot->writeMessageBegin("publishDataResource", ::apache::thrift::protocol::T_EXCEPTION, seqid); - x.write(oprot); - oprot->writeMessageEnd(); - oprot->getTransport()->writeEnd(); - oprot->getTransport()->flush(); - return; - } - - if (this->eventHandler_.get() != NULL) { - this->eventHandler_->preWrite(ctx, "Airavata.publishDataResource"); - } - - oprot->writeMessageBegin("publishDataResource", ::apache::thrift::protocol::T_REPLY, seqid); - result.write(oprot); - oprot->writeMessageEnd(); - bytes = oprot->getTransport()->writeEnd(); - oprot->getTransport()->flush(); - - if (this->eventHandler_.get() != NULL) { - this->eventHandler_->postWrite(ctx, "Airavata.publishDataResource", bytes); - } -} - ::boost::shared_ptr< ::apache::thrift::TProcessor > AiravataProcessorFactory::getProcessor(const ::apache::thrift::TConnectionInfo& connInfo) { ::apache::thrift::ReleaseHandler< AiravataIfFactory > cleanup(handlerFactory_); ::boost::shared_ptr< AiravataIf > handler(handlerFactory_->getHandler(connInfo), cleanup);
http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h index 4adbd55..758208b 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h @@ -2272,7 +2272,6 @@ class AiravataIf { virtual void updateWorkflow(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowTemplateId, const ::Workflow& workflow) = 0; virtual void getWorkflowTemplateId(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowName) = 0; virtual bool isWorkflowExistWithName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowName) = 0; - virtual void publishDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel) = 0; }; class AiravataIfFactory { @@ -2740,9 +2739,6 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } - void publishDataResource(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const ::apache::airavata::model::data::resource::DataResourceModel& /* resourceModel */) { - return; - } }; @@ -21345,164 +21341,6 @@ class Airavata_isWorkflowExistWithName_presult { }; -typedef struct _Airavata_publishDataResource_args__isset { - _Airavata_publishDataResource_args__isset() : resourceModel(false) {} - bool resourceModel :1; -} _Airavata_publishDataResource_args__isset; - -class Airavata_publishDataResource_args { - public: - - static const char* ascii_fingerprint; // = "3CA987536633345DF8FE6263AF84A8FF"; - static const uint8_t binary_fingerprint[16]; // = {0x3C,0xA9,0x87,0x53,0x66,0x33,0x34,0x5D,0xF8,0xFE,0x62,0x63,0xAF,0x84,0xA8,0xFF}; - - Airavata_publishDataResource_args(const Airavata_publishDataResource_args&); - Airavata_publishDataResource_args& operator=(const Airavata_publishDataResource_args&); - Airavata_publishDataResource_args() { - } - - virtual ~Airavata_publishDataResource_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - ::apache::airavata::model::data::resource::DataResourceModel resourceModel; - - _Airavata_publishDataResource_args__isset __isset; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_resourceModel(const ::apache::airavata::model::data::resource::DataResourceModel& val); - - bool operator == (const Airavata_publishDataResource_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(resourceModel == rhs.resourceModel)) - return false; - return true; - } - bool operator != (const Airavata_publishDataResource_args &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_publishDataResource_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - friend std::ostream& operator<<(std::ostream& out, const Airavata_publishDataResource_args& obj); -}; - - -class Airavata_publishDataResource_pargs { - public: - - static const char* ascii_fingerprint; // = "3CA987536633345DF8FE6263AF84A8FF"; - static const uint8_t binary_fingerprint[16]; // = {0x3C,0xA9,0x87,0x53,0x66,0x33,0x34,0x5D,0xF8,0xFE,0x62,0x63,0xAF,0x84,0xA8,0xFF}; - - - virtual ~Airavata_publishDataResource_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const ::apache::airavata::model::data::resource::DataResourceModel* resourceModel; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - friend std::ostream& operator<<(std::ostream& out, const Airavata_publishDataResource_pargs& obj); -}; - -typedef struct _Airavata_publishDataResource_result__isset { - _Airavata_publishDataResource_result__isset() : success(false), ire(false), ace(false), ase(false), ae(false) {} - bool success :1; - bool ire :1; - bool ace :1; - bool ase :1; - bool ae :1; -} _Airavata_publishDataResource_result__isset; - -class Airavata_publishDataResource_result { - public: - - static const char* ascii_fingerprint; // = "21BF57A9FE5AAA661540804D4FB9F023"; - static const uint8_t binary_fingerprint[16]; // = {0x21,0xBF,0x57,0xA9,0xFE,0x5A,0xAA,0x66,0x15,0x40,0x80,0x4D,0x4F,0xB9,0xF0,0x23}; - - Airavata_publishDataResource_result(const Airavata_publishDataResource_result&); - Airavata_publishDataResource_result& operator=(const Airavata_publishDataResource_result&); - Airavata_publishDataResource_result() : success() { - } - - virtual ~Airavata_publishDataResource_result() throw(); - std::string success; - ::apache::airavata::api::error::InvalidRequestException ire; - ::apache::airavata::api::error::AiravataClientException ace; - ::apache::airavata::api::error::AiravataSystemException ase; - ::apache::airavata::api::error::AuthorizationException ae; - - _Airavata_publishDataResource_result__isset __isset; - - void __set_success(const std::string& val); - - void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val); - - void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val); - - void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val); - - void __set_ae(const ::apache::airavata::api::error::AuthorizationException& val); - - bool operator == (const Airavata_publishDataResource_result & rhs) const - { - if (!(success == rhs.success)) - return false; - if (!(ire == rhs.ire)) - return false; - if (!(ace == rhs.ace)) - return false; - if (!(ase == rhs.ase)) - return false; - if (!(ae == rhs.ae)) - return false; - return true; - } - bool operator != (const Airavata_publishDataResource_result &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_publishDataResource_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - friend std::ostream& operator<<(std::ostream& out, const Airavata_publishDataResource_result& obj); -}; - -typedef struct _Airavata_publishDataResource_presult__isset { - _Airavata_publishDataResource_presult__isset() : success(false), ire(false), ace(false), ase(false), ae(false) {} - bool success :1; - bool ire :1; - bool ace :1; - bool ase :1; - bool ae :1; -} _Airavata_publishDataResource_presult__isset; - -class Airavata_publishDataResource_presult { - public: - - static const char* ascii_fingerprint; // = "21BF57A9FE5AAA661540804D4FB9F023"; - static const uint8_t binary_fingerprint[16]; // = {0x21,0xBF,0x57,0xA9,0xFE,0x5A,0xAA,0x66,0x15,0x40,0x80,0x4D,0x4F,0xB9,0xF0,0x23}; - - - virtual ~Airavata_publishDataResource_presult() throw(); - std::string* success; - ::apache::airavata::api::error::InvalidRequestException ire; - ::apache::airavata::api::error::AiravataClientException ace; - ::apache::airavata::api::error::AiravataSystemException ase; - ::apache::airavata::api::error::AuthorizationException ae; - - _Airavata_publishDataResource_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - - friend std::ostream& operator<<(std::ostream& out, const Airavata_publishDataResource_presult& obj); -}; - class AiravataClient : virtual public AiravataIf { public: AiravataClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) { @@ -21924,9 +21762,6 @@ class AiravataClient : virtual public AiravataIf { bool isWorkflowExistWithName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowName); void send_isWorkflowExistWithName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowName); bool recv_isWorkflowExistWithName(); - void publishDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel); - void send_publishDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel); - void recv_publishDataResource(std::string& _return); protected: boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot_; boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot_; @@ -22074,7 +21909,6 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { void process_updateWorkflow(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getWorkflowTemplateId(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_isWorkflowExistWithName(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_publishDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); public: AiravataProcessor(boost::shared_ptr<AiravataIf> iface) : iface_(iface) { @@ -22210,7 +22044,6 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { processMap_["updateWorkflow"] = &AiravataProcessor::process_updateWorkflow; processMap_["getWorkflowTemplateId"] = &AiravataProcessor::process_getWorkflowTemplateId; processMap_["isWorkflowExistWithName"] = &AiravataProcessor::process_isWorkflowExistWithName; - processMap_["publishDataResource"] = &AiravataProcessor::process_publishDataResource; } virtual ~AiravataProcessor() {} @@ -23508,16 +23341,6 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->isWorkflowExistWithName(authzToken, workflowName); } - void publishDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->publishDataResource(_return, authzToken, resourceModel); - } - ifaces_[i]->publishDataResource(_return, authzToken, resourceModel); - return; - } - }; // The 'concurrent' client is a thread safe client that correctly handles http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp index 16d1af9..382818b 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp @@ -2688,11 +2688,6 @@ class AiravataHandler : virtual public AiravataIf { printf("isWorkflowExistWithName\n"); } - void publishDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& resourceModel) { - // Your implementation goes here - printf("publishDataResource\n"); - } - }; int main(int argc, char **argv) { http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.cpp deleted file mode 100644 index c4fb5fd..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.cpp +++ /dev/null @@ -1,34 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.2) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "data_resource_models_constants.h" - -namespace apache { namespace airavata { namespace model { namespace data { namespace resource { - -const data_resource_modelsConstants g_data_resource_models_constants; - -data_resource_modelsConstants::data_resource_modelsConstants() { -} - -}}}}} // namespace - http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.h deleted file mode 100644 index 62881c7..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_constants.h +++ /dev/null @@ -1,41 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.2) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef data_resource_models_CONSTANTS_H -#define data_resource_models_CONSTANTS_H - -#include "data_resource_models_types.h" - -namespace apache { namespace airavata { namespace model { namespace data { namespace resource { - -class data_resource_modelsConstants { - public: - data_resource_modelsConstants(); - -}; - -extern const data_resource_modelsConstants g_data_resource_models_constants; - -}}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.cpp deleted file mode 100644 index d260a1c..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.cpp +++ /dev/null @@ -1,299 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.2) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "data_resource_models_types.h" - -#include <algorithm> -#include <ostream> - -#include <thrift/TToString.h> - -namespace apache { namespace airavata { namespace model { namespace data { namespace resource { - - -ResourceModel::~ResourceModel() throw() { -} - - -void ResourceModel::__set_resourceId(const std::string& val) { - this->resourceId = val; -__isset.resourceId = true; -} - -void ResourceModel::__set_resourceName(const std::string& val) { - this->resourceName = val; -__isset.resourceName = true; -} - -void ResourceModel::__set_replicaLocations(const std::vector<ReplicaLocationModel> & val) { - this->replicaLocations = val; -} - -const char* ResourceModel::ascii_fingerprint = "D638A8293F444DF2C34755C1D925146E"; -const uint8_t ResourceModel::binary_fingerprint[16] = {0xD6,0x38,0xA8,0x29,0x3F,0x44,0x4D,0xF2,0xC3,0x47,0x55,0xC1,0xD9,0x25,0x14,0x6E}; - -uint32_t ResourceModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->resourceId); - this->__isset.resourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->resourceName); - this->__isset.resourceName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->replicaLocations.clear(); - uint32_t _size0; - ::apache::thrift::protocol::TType _etype3; - xfer += iprot->readListBegin(_etype3, _size0); - this->replicaLocations.resize(_size0); - uint32_t _i4; - for (_i4 = 0; _i4 < _size0; ++_i4) - { - xfer += this->replicaLocations[_i4].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.replicaLocations = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - return xfer; -} - -uint32_t ResourceModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("ResourceModel"); - - if (this->__isset.resourceId) { - xfer += oprot->writeFieldBegin("resourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->resourceId); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.resourceName) { - xfer += oprot->writeFieldBegin("resourceName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->resourceName); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldBegin("replicaLocations", ::apache::thrift::protocol::T_LIST, 3); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->replicaLocations.size())); - std::vector<ReplicaLocationModel> ::const_iterator _iter5; - for (_iter5 = this->replicaLocations.begin(); _iter5 != this->replicaLocations.end(); ++_iter5) - { - xfer += (*_iter5).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - oprot->decrementRecursionDepth(); - return xfer; -} - -void swap(ResourceModel &a, ResourceModel &b) { - using ::std::swap; - swap(a.resourceId, b.resourceId); - swap(a.resourceName, b.resourceName); - swap(a.replicaLocations, b.replicaLocations); - swap(a.__isset, b.__isset); -} - -ResourceModel::ResourceModel(const ResourceModel& other6) { - resourceId = other6.resourceId; - resourceName = other6.resourceName; - replicaLocations = other6.replicaLocations; - __isset = other6.__isset; -} -ResourceModel& ResourceModel::operator=(const ResourceModel& other7) { - resourceId = other7.resourceId; - resourceName = other7.resourceName; - replicaLocations = other7.replicaLocations; - __isset = other7.__isset; - return *this; -} -std::ostream& operator<<(std::ostream& out, const ResourceModel& obj) { - using apache::thrift::to_string; - out << "ResourceModel("; - out << "resourceId="; (obj.__isset.resourceId ? (out << to_string(obj.resourceId)) : (out << "<null>")); - out << ", " << "resourceName="; (obj.__isset.resourceName ? (out << to_string(obj.resourceName)) : (out << "<null>")); - out << ", " << "replicaLocations=" << to_string(obj.replicaLocations); - out << ")"; - return out; -} - - -ReplicaLocationModel::~ReplicaLocationModel() throw() { -} - - -void ReplicaLocationModel::__set_physicalLocations(const std::vector<std::string> & val) { - this->physicalLocations = val; -__isset.physicalLocations = true; -} - -const char* ReplicaLocationModel::ascii_fingerprint = "6A3474ADDA840BE2091105F0DFB630C7"; -const uint8_t ReplicaLocationModel::binary_fingerprint[16] = {0x6A,0x34,0x74,0xAD,0xDA,0x84,0x0B,0xE2,0x09,0x11,0x05,0xF0,0xDF,0xB6,0x30,0xC7}; - -uint32_t ReplicaLocationModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->physicalLocations.clear(); - uint32_t _size8; - ::apache::thrift::protocol::TType _etype11; - xfer += iprot->readListBegin(_etype11, _size8); - this->physicalLocations.resize(_size8); - uint32_t _i12; - for (_i12 = 0; _i12 < _size8; ++_i12) - { - xfer += iprot->readString(this->physicalLocations[_i12]); - } - xfer += iprot->readListEnd(); - } - this->__isset.physicalLocations = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - return xfer; -} - -uint32_t ReplicaLocationModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - oprot->incrementRecursionDepth(); - xfer += oprot->writeStructBegin("ReplicaLocationModel"); - - if (this->__isset.physicalLocations) { - xfer += oprot->writeFieldBegin("physicalLocations", ::apache::thrift::protocol::T_LIST, 1); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->physicalLocations.size())); - std::vector<std::string> ::const_iterator _iter13; - for (_iter13 = this->physicalLocations.begin(); _iter13 != this->physicalLocations.end(); ++_iter13) - { - xfer += oprot->writeString((*_iter13)); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - oprot->decrementRecursionDepth(); - return xfer; -} - -void swap(ReplicaLocationModel &a, ReplicaLocationModel &b) { - using ::std::swap; - swap(a.physicalLocations, b.physicalLocations); - swap(a.__isset, b.__isset); -} - -ReplicaLocationModel::ReplicaLocationModel(const ReplicaLocationModel& other14) { - physicalLocations = other14.physicalLocations; - __isset = other14.__isset; -} -ReplicaLocationModel& ReplicaLocationModel::operator=(const ReplicaLocationModel& other15) { - physicalLocations = other15.physicalLocations; - __isset = other15.__isset; - return *this; -} -std::ostream& operator<<(std::ostream& out, const ReplicaLocationModel& obj) { - using apache::thrift::to_string; - out << "ReplicaLocationModel("; - out << "physicalLocations="; (obj.__isset.physicalLocations ? (out << to_string(obj.physicalLocations)) : (out << "<null>")); - out << ")"; - return out; -} - -}}}}} // namespace http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.h deleted file mode 100644 index 213bd9e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_resource_models_types.h +++ /dev/null @@ -1,149 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.2) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef data_resource_models_TYPES_H -#define data_resource_models_TYPES_H - -#include <iosfwd> - -#include <thrift/Thrift.h> -#include <thrift/TApplicationException.h> -#include <thrift/protocol/TProtocol.h> -#include <thrift/transport/TTransport.h> - -#include <thrift/cxxfunctional.h> - - -namespace apache { namespace airavata { namespace model { namespace data { namespace resource { - -class ResourceModel; - -class ReplicaLocationModel; - -typedef struct _ResourceModel__isset { - _ResourceModel__isset() : resourceId(false), resourceName(false), replicaLocations(false) {} - bool resourceId :1; - bool resourceName :1; - bool replicaLocations :1; -} _ResourceModel__isset; - -class ResourceModel { - public: - - static const char* ascii_fingerprint; // = "D638A8293F444DF2C34755C1D925146E"; - static const uint8_t binary_fingerprint[16]; // = {0xD6,0x38,0xA8,0x29,0x3F,0x44,0x4D,0xF2,0xC3,0x47,0x55,0xC1,0xD9,0x25,0x14,0x6E}; - - ResourceModel(const ResourceModel&); - ResourceModel& operator=(const ResourceModel&); - ResourceModel() : resourceId(), resourceName() { - } - - virtual ~ResourceModel() throw(); - std::string resourceId; - std::string resourceName; - std::vector<ReplicaLocationModel> replicaLocations; - - _ResourceModel__isset __isset; - - void __set_resourceId(const std::string& val); - - void __set_resourceName(const std::string& val); - - void __set_replicaLocations(const std::vector<ReplicaLocationModel> & val); - - bool operator == (const ResourceModel & rhs) const - { - if (__isset.resourceId != rhs.__isset.resourceId) - return false; - else if (__isset.resourceId && !(resourceId == rhs.resourceId)) - return false; - if (__isset.resourceName != rhs.__isset.resourceName) - return false; - else if (__isset.resourceName && !(resourceName == rhs.resourceName)) - return false; - if (!(replicaLocations == rhs.replicaLocations)) - return false; - return true; - } - bool operator != (const ResourceModel &rhs) const { - return !(*this == rhs); - } - - bool operator < (const ResourceModel & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - friend std::ostream& operator<<(std::ostream& out, const ResourceModel& obj); -}; - -void swap(ResourceModel &a, ResourceModel &b); - -typedef struct _ReplicaLocationModel__isset { - _ReplicaLocationModel__isset() : physicalLocations(false) {} - bool physicalLocations :1; -} _ReplicaLocationModel__isset; - -class ReplicaLocationModel { - public: - - static const char* ascii_fingerprint; // = "6A3474ADDA840BE2091105F0DFB630C7"; - static const uint8_t binary_fingerprint[16]; // = {0x6A,0x34,0x74,0xAD,0xDA,0x84,0x0B,0xE2,0x09,0x11,0x05,0xF0,0xDF,0xB6,0x30,0xC7}; - - ReplicaLocationModel(const ReplicaLocationModel&); - ReplicaLocationModel& operator=(const ReplicaLocationModel&); - ReplicaLocationModel() { - } - - virtual ~ReplicaLocationModel() throw(); - std::vector<std::string> physicalLocations; - - _ReplicaLocationModel__isset __isset; - - void __set_physicalLocations(const std::vector<std::string> & val); - - bool operator == (const ReplicaLocationModel & rhs) const - { - if (__isset.physicalLocations != rhs.__isset.physicalLocations) - return false; - else if (__isset.physicalLocations && !(physicalLocations == rhs.physicalLocations)) - return false; - return true; - } - bool operator != (const ReplicaLocationModel &rhs) const { - return !(*this == rhs); - } - - bool operator < (const ReplicaLocationModel & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - friend std::ostream& operator<<(std::ostream& out, const ReplicaLocationModel& obj); -}; - -void swap(ReplicaLocationModel &a, ReplicaLocationModel &b); - -}}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php index 326751b..394a8b9 100644 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php @@ -3123,16 +3123,6 @@ interface AiravataIf { * @throws \Airavata\API\Error\AuthorizationException */ public function isWorkflowExistWithName(\Airavata\Model\Security\AuthzToken $authzToken, $workflowName); - /** - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param \Airavata\Model\Data\Resource\DataResourceModel $resourceModel - * @return string - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function publishDataResource(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Resource\DataResourceModel $resourceModel); } class AiravataClient implements \Airavata\API\AiravataIf { @@ -11692,70 +11682,6 @@ class AiravataClient implements \Airavata\API\AiravataIf { throw new \Exception("isWorkflowExistWithName failed: unknown result"); } - public function publishDataResource(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Resource\DataResourceModel $resourceModel) - { - $this->send_publishDataResource($authzToken, $resourceModel); - return $this->recv_publishDataResource(); - } - - public function send_publishDataResource(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Data\Resource\DataResourceModel $resourceModel) - { - $args = new \Airavata\API\Airavata_publishDataResource_args(); - $args->authzToken = $authzToken; - $args->resourceModel = $resourceModel; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'publishDataResource', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('publishDataResource', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_publishDataResource() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_publishDataResource_result', $this->input_->isStrictRead()); - else - { - $rseqid = 0; - $fname = null; - $mtype = 0; - - $this->input_->readMessageBegin($fname, $mtype, $rseqid); - if ($mtype == TMessageType::EXCEPTION) { - $x = new TApplicationException(); - $x->read($this->input_); - $this->input_->readMessageEnd(); - throw $x; - } - $result = new \Airavata\API\Airavata_publishDataResource_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->success !== null) { - return $result->success; - } - if ($result->ire !== null) { - throw $result->ire; - } - if ($result->ace !== null) { - throw $result->ace; - } - if ($result->ase !== null) { - throw $result->ase; - } - if ($result->ae !== null) { - throw $result->ae; - } - throw new \Exception("publishDataResource failed: unknown result"); - } - } // HELPER FUNCTIONS AND STRUCTURES @@ -52287,287 +52213,4 @@ class Airavata_isWorkflowExistWithName_result { } -class Airavata_publishDataResource_args { - static $_TSPEC; - - /** - * @var \Airavata\Model\Security\AuthzToken - */ - public $authzToken = null; - /** - * @var \Airavata\Model\Data\Resource\DataResourceModel - */ - public $resourceModel = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'authzToken', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Security\AuthzToken', - ), - 2 => array( - 'var' => 'resourceModel', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Data\Resource\DataResourceModel', - ), - ); - } - if (is_array($vals)) { - if (isset($vals['authzToken'])) { - $this->authzToken = $vals['authzToken']; - } - if (isset($vals['resourceModel'])) { - $this->resourceModel = $vals['resourceModel']; - } - } - } - - public function getName() { - return 'Airavata_publishDataResource_args'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRUCT) { - $this->authzToken = new \Airavata\Model\Security\AuthzToken(); - $xfer += $this->authzToken->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRUCT) { - $this->resourceModel = new \Airavata\Model\Data\Resource\DataResourceModel(); - $xfer += $this->resourceModel->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('Airavata_publishDataResource_args'); - if ($this->authzToken !== null) { - if (!is_object($this->authzToken)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('authzToken', TType::STRUCT, 1); - $xfer += $this->authzToken->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->resourceModel !== null) { - if (!is_object($this->resourceModel)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('resourceModel', TType::STRUCT, 2); - $xfer += $this->resourceModel->write($output); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -class Airavata_publishDataResource_result { - static $_TSPEC; - - /** - * @var string - */ - public $success = null; - /** - * @var \Airavata\API\Error\InvalidRequestException - */ - public $ire = null; - /** - * @var \Airavata\API\Error\AiravataClientException - */ - public $ace = null; - /** - * @var \Airavata\API\Error\AiravataSystemException - */ - public $ase = null; - /** - * @var \Airavata\API\Error\AuthorizationException - */ - public $ae = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 0 => array( - 'var' => 'success', - 'type' => TType::STRING, - ), - 1 => array( - 'var' => 'ire', - 'type' => TType::STRUCT, - 'class' => '\Airavata\API\Error\InvalidRequestException', - ), - 2 => array( - 'var' => 'ace', - 'type' => TType::STRUCT, - 'class' => '\Airavata\API\Error\AiravataClientException', - ), - 3 => array( - 'var' => 'ase', - 'type' => TType::STRUCT, - 'class' => '\Airavata\API\Error\AiravataSystemException', - ), - 4 => array( - 'var' => 'ae', - 'type' => TType::STRUCT, - 'class' => '\Airavata\API\Error\AuthorizationException', - ), - ); - } - if (is_array($vals)) { - if (isset($vals['success'])) { - $this->success = $vals['success']; - } - if (isset($vals['ire'])) { - $this->ire = $vals['ire']; - } - if (isset($vals['ace'])) { - $this->ace = $vals['ace']; - } - if (isset($vals['ase'])) { - $this->ase = $vals['ase']; - } - if (isset($vals['ae'])) { - $this->ae = $vals['ae']; - } - } - } - - public function getName() { - return 'Airavata_publishDataResource_result'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 0: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->success); - } else { - $xfer += $input->skip($ftype); - } - break; - case 1: - if ($ftype == TType::STRUCT) { - $this->ire = new \Airavata\API\Error\InvalidRequestException(); - $xfer += $this->ire->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRUCT) { - $this->ace = new \Airavata\API\Error\AiravataClientException(); - $xfer += $this->ace->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRUCT) { - $this->ase = new \Airavata\API\Error\AiravataSystemException(); - $xfer += $this->ase->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::STRUCT) { - $this->ae = new \Airavata\API\Error\AuthorizationException(); - $xfer += $this->ae->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('Airavata_publishDataResource_result'); - if ($this->success !== null) { - $xfer += $output->writeFieldBegin('success', TType::STRING, 0); - $xfer += $output->writeString($this->success); - $xfer += $output->writeFieldEnd(); - } - if ($this->ire !== null) { - $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1); - $xfer += $this->ire->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->ace !== null) { - $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2); - $xfer += $this->ace->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->ase !== null) { - $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3); - $xfer += $this->ase->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->ae !== null) { - $xfer += $output->writeFieldBegin('ae', TType::STRUCT, 4); - $xfer += $this->ae->write($output); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php deleted file mode 100644 index 4e638e6..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Data/Resource/Types.php +++ /dev/null @@ -1,270 +0,0 @@ -<?php -namespace Airavata\Model\Data\Resource; - -/** - * Autogenerated by Thrift Compiler (0.9.2) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -use Thrift\Base\TBase; -use Thrift\Type\TType; -use Thrift\Type\TMessageType; -use Thrift\Exception\TException; -use Thrift\Exception\TProtocolException; -use Thrift\Protocol\TProtocol; -use Thrift\Protocol\TBinaryProtocolAccelerated; -use Thrift\Exception\TApplicationException; - - -class ResourceModel { - static $_TSPEC; - - /** - * @var string - */ - public $resourceId = null; - /** - * @var string - */ - public $resourceName = null; - /** - * @var \Airavata\Model\Data\Resource\ReplicaLocationModel[] - */ - public $replicaLocations = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'resourceId', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'resourceName', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'replicaLocations', - 'type' => TType::LST, - 'etype' => TType::STRUCT, - 'elem' => array( - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Data\Resource\ReplicaLocationModel', - ), - ), - ); - } - if (is_array($vals)) { - if (isset($vals['resourceId'])) { - $this->resourceId = $vals['resourceId']; - } - if (isset($vals['resourceName'])) { - $this->resourceName = $vals['resourceName']; - } - if (isset($vals['replicaLocations'])) { - $this->replicaLocations = $vals['replicaLocations']; - } - } - } - - public function getName() { - return 'ResourceModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->resourceId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->resourceName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::LST) { - $this->replicaLocations = array(); - $_size0 = 0; - $_etype3 = 0; - $xfer += $input->readListBegin($_etype3, $_size0); - for ($_i4 = 0; $_i4 < $_size0; ++$_i4) - { - $elem5 = null; - $elem5 = new \Airavata\Model\Data\Resource\ReplicaLocationModel(); - $xfer += $elem5->read($input); - $this->replicaLocations []= $elem5; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('ResourceModel'); - if ($this->resourceId !== null) { - $xfer += $output->writeFieldBegin('resourceId', TType::STRING, 1); - $xfer += $output->writeString($this->resourceId); - $xfer += $output->writeFieldEnd(); - } - if ($this->resourceName !== null) { - $xfer += $output->writeFieldBegin('resourceName', TType::STRING, 2); - $xfer += $output->writeString($this->resourceName); - $xfer += $output->writeFieldEnd(); - } - if ($this->replicaLocations !== null) { - if (!is_array($this->replicaLocations)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('replicaLocations', TType::LST, 3); - { - $output->writeListBegin(TType::STRUCT, count($this->replicaLocations)); - { - foreach ($this->replicaLocations as $iter6) - { - $xfer += $iter6->write($output); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -class ReplicaLocationModel { - static $_TSPEC; - - /** - * @var string[] - */ - public $physicalLocations = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'physicalLocations', - 'type' => TType::LST, - 'etype' => TType::STRING, - 'elem' => array( - 'type' => TType::STRING, - ), - ), - ); - } - if (is_array($vals)) { - if (isset($vals['physicalLocations'])) { - $this->physicalLocations = $vals['physicalLocations']; - } - } - } - - public function getName() { - return 'ReplicaLocationModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::LST) { - $this->physicalLocations = array(); - $_size7 = 0; - $_etype10 = 0; - $xfer += $input->readListBegin($_etype10, $_size7); - for ($_i11 = 0; $_i11 < $_size7; ++$_i11) - { - $elem12 = null; - $xfer += $input->readString($elem12); - $this->physicalLocations []= $elem12; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('ReplicaLocationModel'); - if ($this->physicalLocations !== null) { - if (!is_array($this->physicalLocations)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('physicalLocations', TType::LST, 1); - { - $output->writeListBegin(TType::STRING, count($this->physicalLocations)); - { - foreach ($this->physicalLocations as $iter13) - { - $xfer += $output->writeString($iter13); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - - http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote index 161b547..89d3a68 100755 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote @@ -156,7 +156,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' void updateWorkflow(AuthzToken authzToken, string workflowTemplateId, Workflow workflow)') print(' string getWorkflowTemplateId(AuthzToken authzToken, string workflowName)') print(' bool isWorkflowExistWithName(AuthzToken authzToken, string workflowName)') - print(' string publishDataResource(AuthzToken authzToken, DataResourceModel resourceModel)') print('') sys.exit(0) @@ -1005,12 +1004,6 @@ elif cmd == 'isWorkflowExistWithName': sys.exit(1) pp.pprint(client.isWorkflowExistWithName(eval(args[0]),args[1],)) -elif cmd == 'publishDataResource': - if len(args) != 2: - print('publishDataResource requires 2 args') - sys.exit(1) - pp.pprint(client.publishDataResource(eval(args[0]),eval(args[1]),)) - else: print('Unrecognized method %s' % cmd) sys.exit(1) http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py index 1adc769..2161889 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py @@ -2623,14 +2623,6 @@ class Iface: """ pass - def publishDataResource(self, authzToken, resourceModel): - """ - Parameters: - - authzToken - - resourceModel - """ - pass - class Client(Iface): def __init__(self, iprot, oprot=None): @@ -9701,47 +9693,6 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "isWorkflowExistWithName failed: unknown result") - def publishDataResource(self, authzToken, resourceModel): - """ - Parameters: - - authzToken - - resourceModel - """ - self.send_publishDataResource(authzToken, resourceModel) - return self.recv_publishDataResource() - - def send_publishDataResource(self, authzToken, resourceModel): - self._oprot.writeMessageBegin('publishDataResource', TMessageType.CALL, self._seqid) - args = publishDataResource_args() - args.authzToken = authzToken - args.resourceModel = resourceModel - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_publishDataResource(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = publishDataResource_result() - result.read(iprot) - iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.ire is not None: - raise result.ire - if result.ace is not None: - raise result.ace - if result.ase is not None: - raise result.ase - if result.ae is not None: - raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "publishDataResource failed: unknown result"); - class Processor(Iface, TProcessor): def __init__(self, handler): @@ -9879,7 +9830,6 @@ class Processor(Iface, TProcessor): self._processMap["updateWorkflow"] = Processor.process_updateWorkflow self._processMap["getWorkflowTemplateId"] = Processor.process_getWorkflowTemplateId self._processMap["isWorkflowExistWithName"] = Processor.process_isWorkflowExistWithName - self._processMap["publishDataResource"] = Processor.process_publishDataResource def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -14003,26 +13953,6 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_publishDataResource(self, seqid, iprot, oprot): - args = publishDataResource_args() - args.read(iprot) - iprot.readMessageEnd() - result = publishDataResource_result() - try: - result.success = self._handler.publishDataResource(args.authzToken, args.resourceModel) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: - result.ae = ae - oprot.writeMessageBegin("publishDataResource", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - # HELPER FUNCTIONS AND STRUCTURES @@ -42816,205 +42746,3 @@ class isWorkflowExistWithName_result: def __ne__(self, other): return not (self == other) - -class publishDataResource_args: - """ - Attributes: - - authzToken - - resourceModel - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'resourceModel', (apache.airavata.model.data.resource.ttypes.DataResourceModel, apache.airavata.model.data.resource.ttypes.DataResourceModel.thrift_spec), None, ), # 2 - ) - - def __init__(self, authzToken=None, resourceModel=None,): - self.authzToken = authzToken - self.resourceModel = resourceModel - - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.STRUCT: - self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() - self.authzToken.read(iprot) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.resourceModel = apache.airavata.model.data.resource.ttypes.DataResourceModel() - self.resourceModel.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('publishDataResource_args') - if self.authzToken is not None: - oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) - self.authzToken.write(oprot) - oprot.writeFieldEnd() - if self.resourceModel is not None: - oprot.writeFieldBegin('resourceModel', TType.STRUCT, 2) - self.resourceModel.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.authzToken is None: - raise TProtocol.TProtocolException(message='Required field authzToken is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.resourceModel) - return value - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - -class publishDataResource_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.STRING, 'success', None, None, ), # 0 - (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 - (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 - (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 - ) - - def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): - self.success = success - self.ire = ire - self.ace = ace - self.ase = ase - self.ae = ae - - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 0: - if ftype == TType.STRING: - self.success = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 1: - if ftype == TType.STRUCT: - self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() - self.ire.read(iprot) - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRUCT: - self.ace = apache.airavata.api.error.ttypes.AiravataClientException() - self.ace.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() - self.ase.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRUCT: - self.ae = apache.airavata.api.error.ttypes.AuthorizationException() - self.ae.read(iprot) - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('publishDataResource_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.STRING, 0) - oprot.writeString(self.success) - oprot.writeFieldEnd() - if self.ire is not None: - oprot.writeFieldBegin('ire', TType.STRUCT, 1) - self.ire.write(oprot) - oprot.writeFieldEnd() - if self.ace is not None: - oprot.writeFieldBegin('ace', TType.STRUCT, 2) - self.ace.write(oprot) - oprot.writeFieldEnd() - if self.ase is not None: - oprot.writeFieldBegin('ase', TType.STRUCT, 3) - self.ase.write(oprot) - oprot.writeFieldEnd() - if self.ae is not None: - oprot.writeFieldBegin('ae', TType.STRUCT, 4) - self.ae.write(oprot) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.success) - value = (value * 31) ^ hash(self.ire) - value = (value * 31) ^ hash(self.ace) - value = (value * 31) ^ hash(self.ase) - value = (value * 31) ^ hash(self.ae) - return value - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py deleted file mode 100644 index adefd8e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py +++ /dev/null @@ -1 +0,0 @@ -__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/e7ebb144/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py deleted file mode 100644 index 99717a9..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py +++ /dev/null @@ -1,11 +0,0 @@ -# -# Autogenerated by Thrift Compiler (0.9.2) -# -# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -# -# options string: py -# - -from thrift.Thrift import TType, TMessageType, TException, TApplicationException -from ttypes import * -
