You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/03/22 17:37:28 UTC
[13/16] airavata git commit: refactoring the datacatalog code
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