http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/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 4c1b1d7..b67d8f1 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 @@ -2608,22 +2608,6 @@ class AiravataIf { virtual void updateWorkflow(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowTemplateId, const ::WorkflowModel& 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; - - /** - * * - * * Data Manager Related API Methods. - * * - * * - * - * @param authzToken - * @param dataResourceModel - */ - virtual void registerDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel) = 0; - virtual void updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel) = 0; - virtual void removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId) = 0; - virtual void getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId) = 0; - virtual void copyDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath) = 0; - virtual void copyDataReplica(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath) = 0; }; class AiravataIfFactory { @@ -3098,24 +3082,6 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } - void registerDataResource(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const ::apache::airavata::model::data::resource::DataResourceModel& /* dataResourceModel */) { - return; - } - void updateDataResource(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const ::apache::airavata::model::data::resource::DataResourceModel& /* dataResourceModel */) { - return; - } - void removeDataResource(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* resourceId */) { - return; - } - void getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* resourceId */) { - return; - } - void copyDataResource(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* resourceId */, const std::string& /* destStorageResourceId */, const std::string& /* destinationParentPath */) { - return; - } - void copyDataReplica(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* resourceId */, const std::string& /* replicaId */, const std::string& /* destStorageResourceId */, const std::string& /* destinationParentPath */) { - return; - } }; @@ -22022,860 +21988,30 @@ class Airavata_isWorkflowExistWithName_presult { }; - -class Airavata_registerDataResource_args { - public: - - Airavata_registerDataResource_args(const Airavata_registerDataResource_args&); - Airavata_registerDataResource_args& operator=(const Airavata_registerDataResource_args&); - Airavata_registerDataResource_args() { - } - - virtual ~Airavata_registerDataResource_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - ::apache::airavata::model::data::resource::DataResourceModel dataResourceModel; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_dataResourceModel(const ::apache::airavata::model::data::resource::DataResourceModel& val); - - bool operator == (const Airavata_registerDataResource_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(dataResourceModel == rhs.dataResourceModel)) - return false; - return true; - } - bool operator != (const Airavata_registerDataResource_args &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_registerDataResource_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - - -class Airavata_registerDataResource_pargs { - public: - - - virtual ~Airavata_registerDataResource_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const ::apache::airavata::model::data::resource::DataResourceModel* dataResourceModel; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_registerDataResource_result__isset { - _Airavata_registerDataResource_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_registerDataResource_result__isset; - -class Airavata_registerDataResource_result { - public: - - Airavata_registerDataResource_result(const Airavata_registerDataResource_result&); - Airavata_registerDataResource_result& operator=(const Airavata_registerDataResource_result&); - Airavata_registerDataResource_result() : success() { - } - - virtual ~Airavata_registerDataResource_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_registerDataResource_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_registerDataResource_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_registerDataResource_result &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_registerDataResource_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_registerDataResource_presult__isset { - _Airavata_registerDataResource_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_registerDataResource_presult__isset; - -class Airavata_registerDataResource_presult { - public: - - - virtual ~Airavata_registerDataResource_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_registerDataResource_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - -}; - - -class Airavata_updateDataResource_args { +class AiravataClient : virtual public AiravataIf { public: - - Airavata_updateDataResource_args(const Airavata_updateDataResource_args&); - Airavata_updateDataResource_args& operator=(const Airavata_updateDataResource_args&); - Airavata_updateDataResource_args() { - } - - virtual ~Airavata_updateDataResource_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - ::apache::airavata::model::data::resource::DataResourceModel dataResourceModel; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_dataResourceModel(const ::apache::airavata::model::data::resource::DataResourceModel& val); - - bool operator == (const Airavata_updateDataResource_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(dataResourceModel == rhs.dataResourceModel)) - return false; - return true; - } - bool operator != (const Airavata_updateDataResource_args &rhs) const { - return !(*this == rhs); + AiravataClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) { + setProtocol(prot); } - - bool operator < (const Airavata_updateDataResource_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - - -class Airavata_updateDataResource_pargs { - public: - - - virtual ~Airavata_updateDataResource_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const ::apache::airavata::model::data::resource::DataResourceModel* dataResourceModel; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_updateDataResource_result__isset { - _Airavata_updateDataResource_result__isset() : ire(false), ace(false), ase(false), ae(false) {} - bool ire :1; - bool ace :1; - bool ase :1; - bool ae :1; -} _Airavata_updateDataResource_result__isset; - -class Airavata_updateDataResource_result { - public: - - Airavata_updateDataResource_result(const Airavata_updateDataResource_result&); - Airavata_updateDataResource_result& operator=(const Airavata_updateDataResource_result&); - Airavata_updateDataResource_result() { + AiravataClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) { + setProtocol(iprot,oprot); } - - virtual ~Airavata_updateDataResource_result() throw(); - ::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_updateDataResource_result__isset __isset; - - 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_updateDataResource_result & rhs) const - { - 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; + private: + void setProtocol(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) { + setProtocol(prot,prot); } - bool operator != (const Airavata_updateDataResource_result &rhs) const { - return !(*this == rhs); + void setProtocol(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) { + piprot_=iprot; + poprot_=oprot; + iprot_ = iprot.get(); + oprot_ = oprot.get(); } - - bool operator < (const Airavata_updateDataResource_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_updateDataResource_presult__isset { - _Airavata_updateDataResource_presult__isset() : ire(false), ace(false), ase(false), ae(false) {} - bool ire :1; - bool ace :1; - bool ase :1; - bool ae :1; -} _Airavata_updateDataResource_presult__isset; - -class Airavata_updateDataResource_presult { - public: - - - virtual ~Airavata_updateDataResource_presult() throw(); - ::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_updateDataResource_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - -}; - - -class Airavata_removeDataResource_args { public: - - Airavata_removeDataResource_args(const Airavata_removeDataResource_args&); - Airavata_removeDataResource_args& operator=(const Airavata_removeDataResource_args&); - Airavata_removeDataResource_args() : resourceId() { - } - - virtual ~Airavata_removeDataResource_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - std::string resourceId; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_resourceId(const std::string& val); - - bool operator == (const Airavata_removeDataResource_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(resourceId == rhs.resourceId)) - return false; - return true; + boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() { + return piprot_; } - bool operator != (const Airavata_removeDataResource_args &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_removeDataResource_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - - -class Airavata_removeDataResource_pargs { - public: - - - virtual ~Airavata_removeDataResource_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* resourceId; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_removeDataResource_result__isset { - _Airavata_removeDataResource_result__isset() : ire(false), ace(false), ase(false), ae(false) {} - bool ire :1; - bool ace :1; - bool ase :1; - bool ae :1; -} _Airavata_removeDataResource_result__isset; - -class Airavata_removeDataResource_result { - public: - - Airavata_removeDataResource_result(const Airavata_removeDataResource_result&); - Airavata_removeDataResource_result& operator=(const Airavata_removeDataResource_result&); - Airavata_removeDataResource_result() { - } - - virtual ~Airavata_removeDataResource_result() throw(); - ::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_removeDataResource_result__isset __isset; - - 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_removeDataResource_result & rhs) const - { - 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_removeDataResource_result &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_removeDataResource_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_removeDataResource_presult__isset { - _Airavata_removeDataResource_presult__isset() : ire(false), ace(false), ase(false), ae(false) {} - bool ire :1; - bool ace :1; - bool ase :1; - bool ae :1; -} _Airavata_removeDataResource_presult__isset; - -class Airavata_removeDataResource_presult { - public: - - - virtual ~Airavata_removeDataResource_presult() throw(); - ::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_removeDataResource_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - -}; - - -class Airavata_getDataResource_args { - public: - - Airavata_getDataResource_args(const Airavata_getDataResource_args&); - Airavata_getDataResource_args& operator=(const Airavata_getDataResource_args&); - Airavata_getDataResource_args() : resourceId() { - } - - virtual ~Airavata_getDataResource_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - std::string resourceId; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_resourceId(const std::string& val); - - bool operator == (const Airavata_getDataResource_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(resourceId == rhs.resourceId)) - return false; - return true; - } - bool operator != (const Airavata_getDataResource_args &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_getDataResource_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - - -class Airavata_getDataResource_pargs { - public: - - - virtual ~Airavata_getDataResource_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* resourceId; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_getDataResource_result__isset { - _Airavata_getDataResource_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_getDataResource_result__isset; - -class Airavata_getDataResource_result { - public: - - Airavata_getDataResource_result(const Airavata_getDataResource_result&); - Airavata_getDataResource_result& operator=(const Airavata_getDataResource_result&); - Airavata_getDataResource_result() { - } - - virtual ~Airavata_getDataResource_result() throw(); - ::apache::airavata::model::data::resource::DataResourceModel 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_getDataResource_result__isset __isset; - - void __set_success(const ::apache::airavata::model::data::resource::DataResourceModel& 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_getDataResource_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_getDataResource_result &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_getDataResource_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_getDataResource_presult__isset { - _Airavata_getDataResource_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_getDataResource_presult__isset; - -class Airavata_getDataResource_presult { - public: - - - virtual ~Airavata_getDataResource_presult() throw(); - ::apache::airavata::model::data::resource::DataResourceModel* 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_getDataResource_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - -}; - - -class Airavata_copyDataResource_args { - public: - - Airavata_copyDataResource_args(const Airavata_copyDataResource_args&); - Airavata_copyDataResource_args& operator=(const Airavata_copyDataResource_args&); - Airavata_copyDataResource_args() : resourceId(), destStorageResourceId(), destinationParentPath() { - } - - virtual ~Airavata_copyDataResource_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - std::string resourceId; - std::string destStorageResourceId; - std::string destinationParentPath; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_resourceId(const std::string& val); - - void __set_destStorageResourceId(const std::string& val); - - void __set_destinationParentPath(const std::string& val); - - bool operator == (const Airavata_copyDataResource_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(resourceId == rhs.resourceId)) - return false; - if (!(destStorageResourceId == rhs.destStorageResourceId)) - return false; - if (!(destinationParentPath == rhs.destinationParentPath)) - return false; - return true; - } - bool operator != (const Airavata_copyDataResource_args &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_copyDataResource_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - - -class Airavata_copyDataResource_pargs { - public: - - - virtual ~Airavata_copyDataResource_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* resourceId; - const std::string* destStorageResourceId; - const std::string* destinationParentPath; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_copyDataResource_result__isset { - _Airavata_copyDataResource_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_copyDataResource_result__isset; - -class Airavata_copyDataResource_result { - public: - - Airavata_copyDataResource_result(const Airavata_copyDataResource_result&); - Airavata_copyDataResource_result& operator=(const Airavata_copyDataResource_result&); - Airavata_copyDataResource_result() : success() { - } - - virtual ~Airavata_copyDataResource_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_copyDataResource_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_copyDataResource_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_copyDataResource_result &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_copyDataResource_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_copyDataResource_presult__isset { - _Airavata_copyDataResource_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_copyDataResource_presult__isset; - -class Airavata_copyDataResource_presult { - public: - - - virtual ~Airavata_copyDataResource_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_copyDataResource_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - -}; - - -class Airavata_copyDataReplica_args { - public: - - Airavata_copyDataReplica_args(const Airavata_copyDataReplica_args&); - Airavata_copyDataReplica_args& operator=(const Airavata_copyDataReplica_args&); - Airavata_copyDataReplica_args() : resourceId(), replicaId(), destStorageResourceId(), destinationParentPath() { - } - - virtual ~Airavata_copyDataReplica_args() throw(); - ::apache::airavata::model::security::AuthzToken authzToken; - std::string resourceId; - std::string replicaId; - std::string destStorageResourceId; - std::string destinationParentPath; - - void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - - void __set_resourceId(const std::string& val); - - void __set_replicaId(const std::string& val); - - void __set_destStorageResourceId(const std::string& val); - - void __set_destinationParentPath(const std::string& val); - - bool operator == (const Airavata_copyDataReplica_args & rhs) const - { - if (!(authzToken == rhs.authzToken)) - return false; - if (!(resourceId == rhs.resourceId)) - return false; - if (!(replicaId == rhs.replicaId)) - return false; - if (!(destStorageResourceId == rhs.destStorageResourceId)) - return false; - if (!(destinationParentPath == rhs.destinationParentPath)) - return false; - return true; - } - bool operator != (const Airavata_copyDataReplica_args &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_copyDataReplica_args & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - - -class Airavata_copyDataReplica_pargs { - public: - - - virtual ~Airavata_copyDataReplica_pargs() throw(); - const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* resourceId; - const std::string* replicaId; - const std::string* destStorageResourceId; - const std::string* destinationParentPath; - - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_copyDataReplica_result__isset { - _Airavata_copyDataReplica_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_copyDataReplica_result__isset; - -class Airavata_copyDataReplica_result { - public: - - Airavata_copyDataReplica_result(const Airavata_copyDataReplica_result&); - Airavata_copyDataReplica_result& operator=(const Airavata_copyDataReplica_result&); - Airavata_copyDataReplica_result() : success() { - } - - virtual ~Airavata_copyDataReplica_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_copyDataReplica_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_copyDataReplica_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_copyDataReplica_result &rhs) const { - return !(*this == rhs); - } - - bool operator < (const Airavata_copyDataReplica_result & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -typedef struct _Airavata_copyDataReplica_presult__isset { - _Airavata_copyDataReplica_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_copyDataReplica_presult__isset; - -class Airavata_copyDataReplica_presult { - public: - - - virtual ~Airavata_copyDataReplica_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_copyDataReplica_presult__isset __isset; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - -}; - -class AiravataClient : virtual public AiravataIf { - public: - AiravataClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) { - setProtocol(prot); - } - AiravataClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) { - setProtocol(iprot,oprot); - } - private: - void setProtocol(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) { - setProtocol(prot,prot); - } - void setProtocol(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) { - piprot_=iprot; - poprot_=oprot; - iprot_ = iprot.get(); - oprot_ = oprot.get(); - } - public: - boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() { - return piprot_; - } - boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getOutputProtocol() { - return poprot_; + boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getOutputProtocol() { + return poprot_; } void getAPIVersion(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken); void send_getAPIVersion(const ::apache::airavata::model::security::AuthzToken& authzToken); @@ -23279,24 +22415,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 registerDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - void send_registerDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - void recv_registerDataResource(std::string& _return); - void updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - void send_updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - void recv_updateDataResource(); - void removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - void send_removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - void recv_removeDataResource(); - void getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - void send_getDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - void recv_getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return); - void copyDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - void send_copyDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - void recv_copyDataResource(std::string& _return); - void copyDataReplica(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - void send_copyDataReplica(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - void recv_copyDataReplica(std::string& _return); protected: boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot_; boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot_; @@ -23446,12 +22564,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_registerDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_updateDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_removeDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_getDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_copyDataResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_copyDataReplica(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); public: AiravataProcessor(boost::shared_ptr<AiravataIf> iface) : iface_(iface) { @@ -23589,12 +22701,6 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { processMap_["updateWorkflow"] = &AiravataProcessor::process_updateWorkflow; processMap_["getWorkflowTemplateId"] = &AiravataProcessor::process_getWorkflowTemplateId; processMap_["isWorkflowExistWithName"] = &AiravataProcessor::process_isWorkflowExistWithName; - processMap_["registerDataResource"] = &AiravataProcessor::process_registerDataResource; - processMap_["updateDataResource"] = &AiravataProcessor::process_updateDataResource; - processMap_["removeDataResource"] = &AiravataProcessor::process_removeDataResource; - processMap_["getDataResource"] = &AiravataProcessor::process_getDataResource; - processMap_["copyDataResource"] = &AiravataProcessor::process_copyDataResource; - processMap_["copyDataReplica"] = &AiravataProcessor::process_copyDataReplica; } virtual ~AiravataProcessor() {} @@ -24911,64 +24017,6 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->isWorkflowExistWithName(authzToken, workflowName); } - void registerDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->registerDataResource(_return, authzToken, dataResourceModel); - } - ifaces_[i]->registerDataResource(_return, authzToken, dataResourceModel); - return; - } - - void updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->updateDataResource(authzToken, dataResourceModel); - } - ifaces_[i]->updateDataResource(authzToken, dataResourceModel); - } - - void removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->removeDataResource(authzToken, resourceId); - } - ifaces_[i]->removeDataResource(authzToken, resourceId); - } - - void getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->getDataResource(_return, authzToken, resourceId); - } - ifaces_[i]->getDataResource(_return, authzToken, resourceId); - return; - } - - void copyDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->copyDataResource(_return, authzToken, resourceId, destStorageResourceId, destinationParentPath); - } - ifaces_[i]->copyDataResource(_return, authzToken, resourceId, destStorageResourceId, destinationParentPath); - return; - } - - void copyDataReplica(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath) { - size_t sz = ifaces_.size(); - size_t i = 0; - for (; i < (sz - 1); ++i) { - ifaces_[i]->copyDataReplica(_return, authzToken, resourceId, replicaId, destStorageResourceId, destinationParentPath); - } - ifaces_[i]->copyDataReplica(_return, authzToken, resourceId, replicaId, destStorageResourceId, destinationParentPath); - return; - } - }; // The 'concurrent' client is a thread safe client that correctly handles @@ -25401,24 +24449,6 @@ class AiravataConcurrentClient : virtual public AiravataIf { bool isWorkflowExistWithName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowName); int32_t send_isWorkflowExistWithName(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& workflowName); bool recv_isWorkflowExistWithName(const int32_t seqid); - void registerDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - int32_t send_registerDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - void recv_registerDataResource(std::string& _return, const int32_t seqid); - void updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - int32_t send_updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel); - void recv_updateDataResource(const int32_t seqid); - void removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - int32_t send_removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - void recv_removeDataResource(const int32_t seqid); - void getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - int32_t send_getDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId); - void recv_getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return, const int32_t seqid); - void copyDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - int32_t send_copyDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - void recv_copyDataResource(std::string& _return, const int32_t seqid); - void copyDataReplica(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - int32_t send_copyDataReplica(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath); - void recv_copyDataReplica(std::string& _return, const int32_t seqid); protected: boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot_; boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot_;
http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/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 9f2aa0a..148db2d 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 @@ -3022,45 +3022,6 @@ class AiravataHandler : virtual public AiravataIf { printf("isWorkflowExistWithName\n"); } - /** - * * - * * Data Manager Related API Methods. - * * - * * - * - * @param authzToken - * @param dataResourceModel - */ - void registerDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel) { - // Your implementation goes here - printf("registerDataResource\n"); - } - - void updateDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::resource::DataResourceModel& dataResourceModel) { - // Your implementation goes here - printf("updateDataResource\n"); - } - - void removeDataResource(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId) { - // Your implementation goes here - printf("removeDataResource\n"); - } - - void getDataResource( ::apache::airavata::model::data::resource::DataResourceModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId) { - // Your implementation goes here - printf("getDataResource\n"); - } - - void copyDataResource(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& destStorageResourceId, const std::string& destinationParentPath) { - // Your implementation goes here - printf("copyDataResource\n"); - } - - void copyDataReplica(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceId, const std::string& replicaId, const std::string& destStorageResourceId, const std::string& destinationParentPath) { - // Your implementation goes here - printf("copyDataReplica\n"); - } - }; int main(int argc, char **argv) { http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_api_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_api_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_api_types.h index 5d059c5..3afad01 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_api_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_api_types.h @@ -48,7 +48,7 @@ #include "gateway_resource_profile_model_types.h" #include "data_movement_models_types.h" #include "workflow_data_model_types.h" -#include "replica_catalog_models_types.h" +#include "data_catalog_models_types.h" namespace apache { namespace airavata { namespace api { http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_data_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_data_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_data_models_types.h index ca6796a..03958f1 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_data_models_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/airavata_data_models_types.h @@ -44,7 +44,7 @@ #include "scheduling_model_types.h" #include "status_models_types.h" #include "data_movement_models_types.h" -#include "replica_catalog_models_types.h" +#include "data_catalog_models_types.h" namespace apache { namespace airavata { namespace model { http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.cpp new file mode 100644 index 0000000..53eac5e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.cpp @@ -0,0 +1,34 @@ +/** + * 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.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +#include "data_catalog_models_constants.h" + +namespace apache { namespace airavata { namespace model { namespace data { namespace product { + +const data_catalog_modelsConstants g_data_catalog_models_constants; + +data_catalog_modelsConstants::data_catalog_modelsConstants() { +} + +}}}}} // namespace + http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.h new file mode 100644 index 0000000..4841fb7 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_constants.h @@ -0,0 +1,41 @@ +/** + * 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.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +#ifndef data_catalog_models_CONSTANTS_H +#define data_catalog_models_CONSTANTS_H + +#include "data_catalog_models_types.h" + +namespace apache { namespace airavata { namespace model { namespace data { namespace product { + +class data_catalog_modelsConstants { + public: + data_catalog_modelsConstants(); + +}; + +extern const data_catalog_modelsConstants g_data_catalog_models_constants; + +}}}}} // namespace + +#endif http://git-wip-us.apache.org/repos/asf/airavata/blob/a963d3f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_types.cpp new file mode 100644 index 0000000..c7150cd --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/data_catalog_models_types.cpp @@ -0,0 +1,845 @@ +/** + * 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.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +#include "data_catalog_models_types.h" + +#include <algorithm> +#include <ostream> + +#include <thrift/TToString.h> + +namespace apache { namespace airavata { namespace model { namespace data { namespace product { + +int _kReplicaLocationCategoryValues[] = { + ReplicaLocationCategory::GATEWAY_DATA_STORE, + ReplicaLocationCategory::COMPUTE_RESOURCE, + ReplicaLocationCategory::LONG_TERM_STORAGE_RESOURCE, + ReplicaLocationCategory::OTHER +}; +const char* _kReplicaLocationCategoryNames[] = { + "GATEWAY_DATA_STORE", + "COMPUTE_RESOURCE", + "LONG_TERM_STORAGE_RESOURCE", + "OTHER" +}; +const std::map<int, const char*> _ReplicaLocationCategory_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kReplicaLocationCategoryValues, _kReplicaLocationCategoryNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + +int _kReplicaPersistentTypeValues[] = { + ReplicaPersistentType::TRANSIENT, + ReplicaPersistentType::PERSISTENT +}; +const char* _kReplicaPersistentTypeNames[] = { + "TRANSIENT", + "PERSISTENT" +}; +const std::map<int, const char*> _ReplicaPersistentType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kReplicaPersistentTypeValues, _kReplicaPersistentTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + +int _kDataProductTypeValues[] = { + DataProductType::DIR, + DataProductType::FILE, + DataProductType::COLLECTION +}; +const char* _kDataProductTypeNames[] = { + "DIR", + "FILE", + "COLLECTION" +}; +const std::map<int, const char*> _DataProductType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3, _kDataProductTypeValues, _kDataProductTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + + +DataProductModel::~DataProductModel() throw() { +} + + +void DataProductModel::__set_productId(const std::string& val) { + this->productId = val; +__isset.productId = true; +} + +void DataProductModel::__set_gatewayId(const std::string& val) { + this->gatewayId = val; +__isset.gatewayId = true; +} + +void DataProductModel::__set_parentProductId(const std::string& val) { + this->parentProductId = val; +__isset.parentProductId = true; +} + +void DataProductModel::__set_productName(const std::string& val) { + this->productName = val; +__isset.productName = true; +} + +void DataProductModel::__set_productDescription(const std::string& val) { + this->productDescription = val; +__isset.productDescription = true; +} + +void DataProductModel::__set_ownerName(const std::string& val) { + this->ownerName = val; +__isset.ownerName = true; +} + +void DataProductModel::__set_dataProductType(const DataProductType::type val) { + this->dataProductType = val; +__isset.dataProductType = true; +} + +void DataProductModel::__set_productSize(const int32_t val) { + this->productSize = val; +__isset.productSize = true; +} + +void DataProductModel::__set_creationTime(const int64_t val) { + this->creationTime = val; +__isset.creationTime = true; +} + +void DataProductModel::__set_lastModifiedTime(const int64_t val) { + this->lastModifiedTime = val; +__isset.lastModifiedTime = true; +} + +void DataProductModel::__set_productMetadata(const std::map<std::string, std::string> & val) { + this->productMetadata = val; +__isset.productMetadata = true; +} + +void DataProductModel::__set_replicaLocations(const std::vector<DataReplicaLocationModel> & val) { + this->replicaLocations = val; +__isset.replicaLocations = true; +} + +void DataProductModel::__set_childProducts(const std::vector<DataProductModel> & val) { + this->childProducts = val; +__isset.childProducts = true; +} + +uint32_t DataProductModel::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->productId); + this->__isset.productId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->gatewayId); + this->__isset.gatewayId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->parentProductId); + this->__isset.parentProductId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->productName); + this->__isset.productName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 5: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->productDescription); + this->__isset.productDescription = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 6: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->ownerName); + this->__isset.ownerName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 7: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast0; + xfer += iprot->readI32(ecast0); + this->dataProductType = (DataProductType::type)ecast0; + this->__isset.dataProductType = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 8: + if (ftype == ::apache::thrift::protocol::T_I32) { + xfer += iprot->readI32(this->productSize); + this->__isset.productSize = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 9: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->creationTime); + this->__isset.creationTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 10: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->lastModifiedTime); + this->__isset.lastModifiedTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 11: + if (ftype == ::apache::thrift::protocol::T_MAP) { + { + this->productMetadata.clear(); + uint32_t _size1; + ::apache::thrift::protocol::TType _ktype2; + ::apache::thrift::protocol::TType _vtype3; + xfer += iprot->readMapBegin(_ktype2, _vtype3, _size1); + uint32_t _i5; + for (_i5 = 0; _i5 < _size1; ++_i5) + { + std::string _key6; + xfer += iprot->readString(_key6); + std::string& _val7 = this->productMetadata[_key6]; + xfer += iprot->readString(_val7); + } + xfer += iprot->readMapEnd(); + } + this->__isset.productMetadata = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 12: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->replicaLocations.clear(); + uint32_t _size8; + ::apache::thrift::protocol::TType _etype11; + xfer += iprot->readListBegin(_etype11, _size8); + this->replicaLocations.resize(_size8); + uint32_t _i12; + for (_i12 = 0; _i12 < _size8; ++_i12) + { + xfer += this->replicaLocations[_i12].read(iprot); + } + xfer += iprot->readListEnd(); + } + this->__isset.replicaLocations = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 13: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->childProducts.clear(); + uint32_t _size13; + ::apache::thrift::protocol::TType _etype16; + xfer += iprot->readListBegin(_etype16, _size13); + this->childProducts.resize(_size13); + uint32_t _i17; + for (_i17 = 0; _i17 < _size13; ++_i17) + { + xfer += this->childProducts[_i17].read(iprot); + } + xfer += iprot->readListEnd(); + } + this->__isset.childProducts = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t DataProductModel::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("DataProductModel"); + + if (this->__isset.productId) { + xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.gatewayId) { + xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->gatewayId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.parentProductId) { + xfer += oprot->writeFieldBegin("parentProductId", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->parentProductId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.productName) { + xfer += oprot->writeFieldBegin("productName", ::apache::thrift::protocol::T_STRING, 4); + xfer += oprot->writeString(this->productName); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.productDescription) { + xfer += oprot->writeFieldBegin("productDescription", ::apache::thrift::protocol::T_STRING, 5); + xfer += oprot->writeString(this->productDescription); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.ownerName) { + xfer += oprot->writeFieldBegin("ownerName", ::apache::thrift::protocol::T_STRING, 6); + xfer += oprot->writeString(this->ownerName); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.dataProductType) { + xfer += oprot->writeFieldBegin("dataProductType", ::apache::thrift::protocol::T_I32, 7); + xfer += oprot->writeI32((int32_t)this->dataProductType); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.productSize) { + xfer += oprot->writeFieldBegin("productSize", ::apache::thrift::protocol::T_I32, 8); + xfer += oprot->writeI32(this->productSize); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.creationTime) { + xfer += oprot->writeFieldBegin("creationTime", ::apache::thrift::protocol::T_I64, 9); + xfer += oprot->writeI64(this->creationTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.lastModifiedTime) { + xfer += oprot->writeFieldBegin("lastModifiedTime", ::apache::thrift::protocol::T_I64, 10); + xfer += oprot->writeI64(this->lastModifiedTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.productMetadata) { + xfer += oprot->writeFieldBegin("productMetadata", ::apache::thrift::protocol::T_MAP, 11); + { + xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->productMetadata.size())); + std::map<std::string, std::string> ::const_iterator _iter18; + for (_iter18 = this->productMetadata.begin(); _iter18 != this->productMetadata.end(); ++_iter18) + { + xfer += oprot->writeString(_iter18->first); + xfer += oprot->writeString(_iter18->second); + } + xfer += oprot->writeMapEnd(); + } + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.replicaLocations) { + xfer += oprot->writeFieldBegin("replicaLocations", ::apache::thrift::protocol::T_LIST, 12); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->replicaLocations.size())); + std::vector<DataReplicaLocationModel> ::const_iterator _iter19; + for (_iter19 = this->replicaLocations.begin(); _iter19 != this->replicaLocations.end(); ++_iter19) + { + xfer += (*_iter19).write(oprot); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.childProducts) { + xfer += oprot->writeFieldBegin("childProducts", ::apache::thrift::protocol::T_LIST, 13); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->childProducts.size())); + std::vector<DataProductModel> ::const_iterator _iter20; + for (_iter20 = this->childProducts.begin(); _iter20 != this->childProducts.end(); ++_iter20) + { + xfer += (*_iter20).write(oprot); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +void swap(DataProductModel &a, DataProductModel &b) { + using ::std::swap; + swap(a.productId, b.productId); + swap(a.gatewayId, b.gatewayId); + swap(a.parentProductId, b.parentProductId); + swap(a.productName, b.productName); + swap(a.productDescription, b.productDescription); + swap(a.ownerName, b.ownerName); + swap(a.dataProductType, b.dataProductType); + swap(a.productSize, b.productSize); + swap(a.creationTime, b.creationTime); + swap(a.lastModifiedTime, b.lastModifiedTime); + swap(a.productMetadata, b.productMetadata); + swap(a.replicaLocations, b.replicaLocations); + swap(a.childProducts, b.childProducts); + swap(a.__isset, b.__isset); +} + +DataProductModel::DataProductModel(const DataProductModel& other21) { + productId = other21.productId; + gatewayId = other21.gatewayId; + parentProductId = other21.parentProductId; + productName = other21.productName; + productDescription = other21.productDescription; + ownerName = other21.ownerName; + dataProductType = other21.dataProductType; + productSize = other21.productSize; + creationTime = other21.creationTime; + lastModifiedTime = other21.lastModifiedTime; + productMetadata = other21.productMetadata; + replicaLocations = other21.replicaLocations; + childProducts = other21.childProducts; + __isset = other21.__isset; +} +DataProductModel& DataProductModel::operator=(const DataProductModel& other22) { + productId = other22.productId; + gatewayId = other22.gatewayId; + parentProductId = other22.parentProductId; + productName = other22.productName; + productDescription = other22.productDescription; + ownerName = other22.ownerName; + dataProductType = other22.dataProductType; + productSize = other22.productSize; + creationTime = other22.creationTime; + lastModifiedTime = other22.lastModifiedTime; + productMetadata = other22.productMetadata; + replicaLocations = other22.replicaLocations; + childProducts = other22.childProducts; + __isset = other22.__isset; + return *this; +} +void DataProductModel::printTo(std::ostream& out) const { + using ::apache::thrift::to_string; + out << "DataProductModel("; + out << "productId="; (__isset.productId ? (out << to_string(productId)) : (out << "<null>")); + out << ", " << "gatewayId="; (__isset.gatewayId ? (out << to_string(gatewayId)) : (out << "<null>")); + out << ", " << "parentProductId="; (__isset.parentProductId ? (out << to_string(parentProductId)) : (out << "<null>")); + out << ", " << "productName="; (__isset.productName ? (out << to_string(productName)) : (out << "<null>")); + out << ", " << "productDescription="; (__isset.productDescription ? (out << to_string(productDescription)) : (out << "<null>")); + out << ", " << "ownerName="; (__isset.ownerName ? (out << to_string(ownerName)) : (out << "<null>")); + out << ", " << "dataProductType="; (__isset.dataProductType ? (out << to_string(dataProductType)) : (out << "<null>")); + out << ", " << "productSize="; (__isset.productSize ? (out << to_string(productSize)) : (out << "<null>")); + out << ", " << "creationTime="; (__isset.creationTime ? (out << to_string(creationTime)) : (out << "<null>")); + out << ", " << "lastModifiedTime="; (__isset.lastModifiedTime ? (out << to_string(lastModifiedTime)) : (out << "<null>")); + out << ", " << "productMetadata="; (__isset.productMetadata ? (out << to_string(productMetadata)) : (out << "<null>")); + out << ", " << "replicaLocations="; (__isset.replicaLocations ? (out << to_string(replicaLocations)) : (out << "<null>")); + out << ", " << "childProducts="; (__isset.childProducts ? (out << to_string(childProducts)) : (out << "<null>")); + out << ")"; +} + + +DataReplicaLocationModel::~DataReplicaLocationModel() throw() { +} + + +void DataReplicaLocationModel::__set_replicaId(const std::string& val) { + this->replicaId = val; +__isset.replicaId = true; +} + +void DataReplicaLocationModel::__set_productId(const std::string& val) { + this->productId = val; +__isset.productId = true; +} + +void DataReplicaLocationModel::__set_replicaName(const std::string& val) { + this->replicaName = val; +__isset.replicaName = true; +} + +void DataReplicaLocationModel::__set_replicaDescription(const std::string& val) { + this->replicaDescription = val; +__isset.replicaDescription = true; +} + +void DataReplicaLocationModel::__set_creationTime(const int64_t val) { + this->creationTime = val; +__isset.creationTime = true; +} + +void DataReplicaLocationModel::__set_lastModifiedTime(const int64_t val) { + this->lastModifiedTime = val; +__isset.lastModifiedTime = true; +} + +void DataReplicaLocationModel::__set_validUntilTime(const int64_t val) { + this->validUntilTime = val; +__isset.validUntilTime = true; +} + +void DataReplicaLocationModel::__set_replicaLocationCategory(const ReplicaLocationCategory::type val) { + this->replicaLocationCategory = val; +__isset.replicaLocationCategory = true; +} + +void DataReplicaLocationModel::__set_replicaPersistentType(const ReplicaPersistentType::type val) { + this->replicaPersistentType = val; +__isset.replicaPersistentType = true; +} + +void DataReplicaLocationModel::__set_storageResourceId(const std::string& val) { + this->storageResourceId = val; +__isset.storageResourceId = true; +} + +void DataReplicaLocationModel::__set_fileAbsolutePath(const std::string& val) { + this->fileAbsolutePath = val; +__isset.fileAbsolutePath = true; +} + +void DataReplicaLocationModel::__set_replicaMetadata(const std::map<std::string, std::string> & val) { + this->replicaMetadata = val; +__isset.replicaMetadata = true; +} + +uint32_t DataReplicaLocationModel::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->replicaId); + this->__isset.replicaId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->productId); + this->__isset.productId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->replicaName); + this->__isset.replicaName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->replicaDescription); + this->__isset.replicaDescription = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 5: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->creationTime); + this->__isset.creationTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 6: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->lastModifiedTime); + this->__isset.lastModifiedTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 7: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->validUntilTime); + this->__isset.validUntilTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 8: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast23; + xfer += iprot->readI32(ecast23); + this->replicaLocationCategory = (ReplicaLocationCategory::type)ecast23; + this->__isset.replicaLocationCategory = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 9: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast24; + xfer += iprot->readI32(ecast24); + this->replicaPersistentType = (ReplicaPersistentType::type)ecast24; + this->__isset.replicaPersistentType = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 10: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->storageResourceId); + this->__isset.storageResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 11: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->fileAbsolutePath); + this->__isset.fileAbsolutePath = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 12: + if (ftype == ::apache::thrift::protocol::T_MAP) { + { + this->replicaMetadata.clear(); + uint32_t _size25; + ::apache::thrift::protocol::TType _ktype26; + ::apache::thrift::protocol::TType _vtype27; + xfer += iprot->readMapBegin(_ktype26, _vtype27, _size25); + uint32_t _i29; + for (_i29 = 0; _i29 < _size25; ++_i29) + { + std::string _key30; + xfer += iprot->readString(_key30); + std::string& _val31 = this->replicaMetadata[_key30]; + xfer += iprot->readString(_val31); + } + xfer += iprot->readMapEnd(); + } + this->__isset.replicaMetadata = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t DataReplicaLocationModel::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("DataReplicaLocationModel"); + + if (this->__isset.replicaId) { + xfer += oprot->writeFieldBegin("replicaId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->replicaId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.productId) { + xfer += oprot->writeFieldBegin("productId", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->productId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.replicaName) { + xfer += oprot->writeFieldBegin("replicaName", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->replicaName); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.replicaDescription) { + xfer += oprot->writeFieldBegin("replicaDescription", ::apache::thrift::protocol::T_STRING, 4); + xfer += oprot->writeString(this->replicaDescription); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.creationTime) { + xfer += oprot->writeFieldBegin("creationTime", ::apache::thrift::protocol::T_I64, 5); + xfer += oprot->writeI64(this->creationTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.lastModifiedTime) { + xfer += oprot->writeFieldBegin("lastModifiedTime", ::apache::thrift::protocol::T_I64, 6); + xfer += oprot->writeI64(this->lastModifiedTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.validUntilTime) { + xfer += oprot->writeFieldBegin("validUntilTime", ::apache::thrift::protocol::T_I64, 7); + xfer += oprot->writeI64(this->validUntilTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.replicaLocationCategory) { + xfer += oprot->writeFieldBegin("replicaLocationCategory", ::apache::thrift::protocol::T_I32, 8); + xfer += oprot->writeI32((int32_t)this->replicaLocationCategory); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.replicaPersistentType) { + xfer += oprot->writeFieldBegin("replicaPersistentType", ::apache::thrift::protocol::T_I32, 9); + xfer += oprot->writeI32((int32_t)this->replicaPersistentType); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.storageResourceId) { + xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 10); + xfer += oprot->writeString(this->storageResourceId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.fileAbsolutePath) { + xfer += oprot->writeFieldBegin("fileAbsolutePath", ::apache::thrift::protocol::T_STRING, 11); + xfer += oprot->writeString(this->fileAbsolutePath); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.replicaMetadata) { + xfer += oprot->writeFieldBegin("replicaMetadata", ::apache::thrift::protocol::T_MAP, 12); + { + xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->replicaMetadata.size())); + std::map<std::string, std::string> ::const_iterator _iter32; + for (_iter32 = this->replicaMetadata.begin(); _iter32 != this->replicaMetadata.end(); ++_iter32) + { + xfer += oprot->writeString(_iter32->first); + xfer += oprot->writeString(_iter32->second); + } + xfer += oprot->writeMapEnd(); + } + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +void swap(DataReplicaLocationModel &a, DataReplicaLocationModel &b) { + using ::std::swap; + swap(a.replicaId, b.replicaId); + swap(a.productId, b.productId); + swap(a.replicaName, b.replicaName); + swap(a.replicaDescription, b.replicaDescription); + swap(a.creationTime, b.creationTime); + swap(a.lastModifiedTime, b.lastModifiedTime); + swap(a.validUntilTime, b.validUntilTime); + swap(a.replicaLocationCategory, b.replicaLocationCategory); + swap(a.replicaPersistentType, b.replicaPersistentType); + swap(a.storageResourceId, b.storageResourceId); + swap(a.fileAbsolutePath, b.fileAbsolutePath); + swap(a.replicaMetadata, b.replicaMetadata); + swap(a.__isset, b.__isset); +} + +DataReplicaLocationModel::DataReplicaLocationModel(const DataReplicaLocationModel& other33) { + replicaId = other33.replicaId; + productId = other33.productId; + replicaName = other33.replicaName; + replicaDescription = other33.replicaDescription; + creationTime = other33.creationTime; + lastModifiedTime = other33.lastModifiedTime; + validUntilTime = other33.validUntilTime; + replicaLocationCategory = other33.replicaLocationCategory; + replicaPersistentType = other33.replicaPersistentType; + storageResourceId = other33.storageResourceId; + fileAbsolutePath = other33.fileAbsolutePath; + replicaMetadata = other33.replicaMetadata; + __isset = other33.__isset; +} +DataReplicaLocationModel& DataReplicaLocationModel::operator=(const DataReplicaLocationModel& other34) { + replicaId = other34.replicaId; + productId = other34.productId; + replicaName = other34.replicaName; + replicaDescription = other34.replicaDescription; + creationTime = other34.creationTime; + lastModifiedTime = other34.lastModifiedTime; + validUntilTime = other34.validUntilTime; + replicaLocationCategory = other34.replicaLocationCategory; + replicaPersistentType = other34.replicaPersistentType; + storageResourceId = other34.storageResourceId; + fileAbsolutePath = other34.fileAbsolutePath; + replicaMetadata = other34.replicaMetadata; + __isset = other34.__isset; + return *this; +} +void DataReplicaLocationModel::printTo(std::ostream& out) const { + using ::apache::thrift::to_string; + out << "DataReplicaLocationModel("; + out << "replicaId="; (__isset.replicaId ? (out << to_string(replicaId)) : (out << "<null>")); + out << ", " << "productId="; (__isset.productId ? (out << to_string(productId)) : (out << "<null>")); + out << ", " << "replicaName="; (__isset.replicaName ? (out << to_string(replicaName)) : (out << "<null>")); + out << ", " << "replicaDescription="; (__isset.replicaDescription ? (out << to_string(replicaDescription)) : (out << "<null>")); + out << ", " << "creationTime="; (__isset.creationTime ? (out << to_string(creationTime)) : (out << "<null>")); + out << ", " << "lastModifiedTime="; (__isset.lastModifiedTime ? (out << to_string(lastModifiedTime)) : (out << "<null>")); + out << ", " << "validUntilTime="; (__isset.validUntilTime ? (out << to_string(validUntilTime)) : (out << "<null>")); + out << ", " << "replicaLocationCategory="; (__isset.replicaLocationCategory ? (out << to_string(replicaLocationCategory)) : (out << "<null>")); + out << ", " << "replicaPersistentType="; (__isset.replicaPersistentType ? (out << to_string(replicaPersistentType)) : (out << "<null>")); + out << ", " << "storageResourceId="; (__isset.storageResourceId ? (out << to_string(storageResourceId)) : (out << "<null>")); + out << ", " << "fileAbsolutePath="; (__isset.fileAbsolutePath ? (out << to_string(fileAbsolutePath)) : (out << "<null>")); + out << ", " << "replicaMetadata="; (__isset.replicaMetadata ? (out << to_string(replicaMetadata)) : (out << "<null>")); + out << ")"; +} + +}}}}} // namespace
