http://git-wip-us.apache.org/repos/asf/airavata/blob/6c5645d3/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.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 a91f277..fd22834 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 @@ -1910,7 +1910,7 @@ class AiravataIf { * Add a Local data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which JobSubmission protocol to be added * * @param DMType @@ -1928,12 +1928,12 @@ class AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param localDataMovement */ - virtual void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement) = 0; + virtual void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement) = 0; /** * @@ -1977,7 +1977,7 @@ class AiravataIf { * Add a SCP data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which JobSubmission protocol to be added * * @param priorityOrder @@ -1991,12 +1991,12 @@ class AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param scpDataMovement */ - virtual void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement) = 0; + virtual void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement) = 0; /** * @@ -2039,7 +2039,7 @@ class AiravataIf { * Add a UNICORE data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which data movement protocol to be added * * @param priorityOrder @@ -2053,12 +2053,12 @@ class AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param unicoreDataMovement */ - virtual void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement) = 0; + virtual void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement) = 0; /** * @@ -2103,7 +2103,7 @@ class AiravataIf { * Add a GridFTP data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which dataMovement protocol to be added * * @param DMType @@ -2121,12 +2121,12 @@ class AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param gridFTPDataMovement */ - virtual void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement) = 0; + virtual void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement) = 0; /** * Update the given GridFTP data movement details to a compute resource @@ -2264,11 +2264,11 @@ class AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMovementInterfaceId * @param dataMoveType */ - virtual bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType) = 0; + virtual bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType) = 0; virtual void registerResourceJobManager(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& resourceJobManager) = 0; virtual bool updateResourceJobManager(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceJobManagerId, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& updatedResourceJobManager) = 0; virtual void getResourceJobManager( ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& resourceJobManagerId) = 0; @@ -2608,6 +2608,17 @@ 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; + + /** + * API Methods related to data catalog + * + * + * @param authzToken + * @param dataProductModel + */ + virtual void registerDataProduct(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel) = 0; + virtual void getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri) = 0; + virtual void registerReplicaLocation(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel) = 0; }; class AiravataIfFactory { @@ -2925,7 +2936,7 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } - void addLocalDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productId */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::LOCALDataMovement& /* localDataMovement */) { + void addLocalDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productUri */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::LOCALDataMovement& /* localDataMovement */) { return; } bool updateLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementInterfaceId */, const ::apache::airavata::model::data::movement::LOCALDataMovement& /* localDataMovement */) { @@ -2935,7 +2946,7 @@ class AiravataNull : virtual public AiravataIf { void getLocalDataMovement( ::apache::airavata::model::data::movement::LOCALDataMovement& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementId */) { return; } - void addSCPDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productId */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::SCPDataMovement& /* scpDataMovement */) { + void addSCPDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productUri */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::SCPDataMovement& /* scpDataMovement */) { return; } bool updateSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementInterfaceId */, const ::apache::airavata::model::data::movement::SCPDataMovement& /* scpDataMovement */) { @@ -2945,7 +2956,7 @@ class AiravataNull : virtual public AiravataIf { void getSCPDataMovement( ::apache::airavata::model::data::movement::SCPDataMovement& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementId */) { return; } - void addUnicoreDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productId */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::UnicoreDataMovement& /* unicoreDataMovement */) { + void addUnicoreDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productUri */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::UnicoreDataMovement& /* unicoreDataMovement */) { return; } bool updateUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementInterfaceId */, const ::apache::airavata::model::data::movement::UnicoreDataMovement& /* unicoreDataMovement */) { @@ -2955,7 +2966,7 @@ class AiravataNull : virtual public AiravataIf { void getUnicoreDataMovement( ::apache::airavata::model::data::movement::UnicoreDataMovement& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementId */) { return; } - void addGridFTPDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productId */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::GridFTPDataMovement& /* gridFTPDataMovement */) { + void addGridFTPDataMovementDetails(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productUri */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */, const int32_t /* priorityOrder */, const ::apache::airavata::model::data::movement::GridFTPDataMovement& /* gridFTPDataMovement */) { return; } bool updateGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataMovementInterfaceId */, const ::apache::airavata::model::data::movement::GridFTPDataMovement& /* gridFTPDataMovement */) { @@ -2985,7 +2996,7 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } - bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productId */, const std::string& /* dataMovementInterfaceId */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */) { + bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* productUri */, const std::string& /* dataMovementInterfaceId */, const ::apache::airavata::model::data::movement::DMType::type /* dataMoveType */) { bool _return = false; return _return; } @@ -3082,6 +3093,15 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } + void registerDataProduct(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const ::apache::airavata::model::data::product::DataProductModel& /* dataProductModel */) { + return; + } + void getDataProduct( ::apache::airavata::model::data::product::DataProductModel& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const std::string& /* dataProductUri */) { + return; + } + void registerReplicaLocation(std::string& /* _return */, const ::apache::airavata::model::security::AuthzToken& /* authzToken */, const ::apache::airavata::model::data::product::DataReplicaLocationModel& /* replicaLocationModel */) { + return; + } }; @@ -15668,19 +15688,19 @@ class Airavata_addLocalDataMovementDetails_args { Airavata_addLocalDataMovementDetails_args(const Airavata_addLocalDataMovementDetails_args&); Airavata_addLocalDataMovementDetails_args& operator=(const Airavata_addLocalDataMovementDetails_args&); - Airavata_addLocalDataMovementDetails_args() : productId(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { + Airavata_addLocalDataMovementDetails_args() : productUri(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { } virtual ~Airavata_addLocalDataMovementDetails_args() throw(); ::apache::airavata::model::security::AuthzToken authzToken; - std::string productId; + std::string productUri; ::apache::airavata::model::data::movement::DMType::type dataMoveType; int32_t priorityOrder; ::apache::airavata::model::data::movement::LOCALDataMovement localDataMovement; void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - void __set_productId(const std::string& val); + void __set_productUri(const std::string& val); void __set_dataMoveType(const ::apache::airavata::model::data::movement::DMType::type val); @@ -15692,7 +15712,7 @@ class Airavata_addLocalDataMovementDetails_args { { if (!(authzToken == rhs.authzToken)) return false; - if (!(productId == rhs.productId)) + if (!(productUri == rhs.productUri)) return false; if (!(dataMoveType == rhs.dataMoveType)) return false; @@ -15720,7 +15740,7 @@ class Airavata_addLocalDataMovementDetails_pargs { virtual ~Airavata_addLocalDataMovementDetails_pargs() throw(); const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* productId; + const std::string* productUri; const ::apache::airavata::model::data::movement::DMType::type* dataMoveType; const int32_t* priorityOrder; const ::apache::airavata::model::data::movement::LOCALDataMovement* localDataMovement; @@ -16100,19 +16120,19 @@ class Airavata_addSCPDataMovementDetails_args { Airavata_addSCPDataMovementDetails_args(const Airavata_addSCPDataMovementDetails_args&); Airavata_addSCPDataMovementDetails_args& operator=(const Airavata_addSCPDataMovementDetails_args&); - Airavata_addSCPDataMovementDetails_args() : productId(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { + Airavata_addSCPDataMovementDetails_args() : productUri(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { } virtual ~Airavata_addSCPDataMovementDetails_args() throw(); ::apache::airavata::model::security::AuthzToken authzToken; - std::string productId; + std::string productUri; ::apache::airavata::model::data::movement::DMType::type dataMoveType; int32_t priorityOrder; ::apache::airavata::model::data::movement::SCPDataMovement scpDataMovement; void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - void __set_productId(const std::string& val); + void __set_productUri(const std::string& val); void __set_dataMoveType(const ::apache::airavata::model::data::movement::DMType::type val); @@ -16124,7 +16144,7 @@ class Airavata_addSCPDataMovementDetails_args { { if (!(authzToken == rhs.authzToken)) return false; - if (!(productId == rhs.productId)) + if (!(productUri == rhs.productUri)) return false; if (!(dataMoveType == rhs.dataMoveType)) return false; @@ -16152,7 +16172,7 @@ class Airavata_addSCPDataMovementDetails_pargs { virtual ~Airavata_addSCPDataMovementDetails_pargs() throw(); const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* productId; + const std::string* productUri; const ::apache::airavata::model::data::movement::DMType::type* dataMoveType; const int32_t* priorityOrder; const ::apache::airavata::model::data::movement::SCPDataMovement* scpDataMovement; @@ -16532,19 +16552,19 @@ class Airavata_addUnicoreDataMovementDetails_args { Airavata_addUnicoreDataMovementDetails_args(const Airavata_addUnicoreDataMovementDetails_args&); Airavata_addUnicoreDataMovementDetails_args& operator=(const Airavata_addUnicoreDataMovementDetails_args&); - Airavata_addUnicoreDataMovementDetails_args() : productId(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { + Airavata_addUnicoreDataMovementDetails_args() : productUri(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { } virtual ~Airavata_addUnicoreDataMovementDetails_args() throw(); ::apache::airavata::model::security::AuthzToken authzToken; - std::string productId; + std::string productUri; ::apache::airavata::model::data::movement::DMType::type dataMoveType; int32_t priorityOrder; ::apache::airavata::model::data::movement::UnicoreDataMovement unicoreDataMovement; void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - void __set_productId(const std::string& val); + void __set_productUri(const std::string& val); void __set_dataMoveType(const ::apache::airavata::model::data::movement::DMType::type val); @@ -16556,7 +16576,7 @@ class Airavata_addUnicoreDataMovementDetails_args { { if (!(authzToken == rhs.authzToken)) return false; - if (!(productId == rhs.productId)) + if (!(productUri == rhs.productUri)) return false; if (!(dataMoveType == rhs.dataMoveType)) return false; @@ -16584,7 +16604,7 @@ class Airavata_addUnicoreDataMovementDetails_pargs { virtual ~Airavata_addUnicoreDataMovementDetails_pargs() throw(); const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* productId; + const std::string* productUri; const ::apache::airavata::model::data::movement::DMType::type* dataMoveType; const int32_t* priorityOrder; const ::apache::airavata::model::data::movement::UnicoreDataMovement* unicoreDataMovement; @@ -16964,19 +16984,19 @@ class Airavata_addGridFTPDataMovementDetails_args { Airavata_addGridFTPDataMovementDetails_args(const Airavata_addGridFTPDataMovementDetails_args&); Airavata_addGridFTPDataMovementDetails_args& operator=(const Airavata_addGridFTPDataMovementDetails_args&); - Airavata_addGridFTPDataMovementDetails_args() : productId(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { + Airavata_addGridFTPDataMovementDetails_args() : productUri(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0), priorityOrder(0) { } virtual ~Airavata_addGridFTPDataMovementDetails_args() throw(); ::apache::airavata::model::security::AuthzToken authzToken; - std::string productId; + std::string productUri; ::apache::airavata::model::data::movement::DMType::type dataMoveType; int32_t priorityOrder; ::apache::airavata::model::data::movement::GridFTPDataMovement gridFTPDataMovement; void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - void __set_productId(const std::string& val); + void __set_productUri(const std::string& val); void __set_dataMoveType(const ::apache::airavata::model::data::movement::DMType::type val); @@ -16988,7 +17008,7 @@ class Airavata_addGridFTPDataMovementDetails_args { { if (!(authzToken == rhs.authzToken)) return false; - if (!(productId == rhs.productId)) + if (!(productUri == rhs.productUri)) return false; if (!(dataMoveType == rhs.dataMoveType)) return false; @@ -17016,7 +17036,7 @@ class Airavata_addGridFTPDataMovementDetails_pargs { virtual ~Airavata_addGridFTPDataMovementDetails_pargs() throw(); const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* productId; + const std::string* productUri; const ::apache::airavata::model::data::movement::DMType::type* dataMoveType; const int32_t* priorityOrder; const ::apache::airavata::model::data::movement::GridFTPDataMovement* gridFTPDataMovement; @@ -18094,18 +18114,18 @@ class Airavata_deleteDataMovementInterface_args { Airavata_deleteDataMovementInterface_args(const Airavata_deleteDataMovementInterface_args&); Airavata_deleteDataMovementInterface_args& operator=(const Airavata_deleteDataMovementInterface_args&); - Airavata_deleteDataMovementInterface_args() : productId(), dataMovementInterfaceId(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0) { + Airavata_deleteDataMovementInterface_args() : productUri(), dataMovementInterfaceId(), dataMoveType(( ::apache::airavata::model::data::movement::DMType::type)0) { } virtual ~Airavata_deleteDataMovementInterface_args() throw(); ::apache::airavata::model::security::AuthzToken authzToken; - std::string productId; + std::string productUri; std::string dataMovementInterfaceId; ::apache::airavata::model::data::movement::DMType::type dataMoveType; void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); - void __set_productId(const std::string& val); + void __set_productUri(const std::string& val); void __set_dataMovementInterfaceId(const std::string& val); @@ -18115,7 +18135,7 @@ class Airavata_deleteDataMovementInterface_args { { if (!(authzToken == rhs.authzToken)) return false; - if (!(productId == rhs.productId)) + if (!(productUri == rhs.productUri)) return false; if (!(dataMovementInterfaceId == rhs.dataMovementInterfaceId)) return false; @@ -18141,7 +18161,7 @@ class Airavata_deleteDataMovementInterface_pargs { virtual ~Airavata_deleteDataMovementInterface_pargs() throw(); const ::apache::airavata::model::security::AuthzToken* authzToken; - const std::string* productId; + const std::string* productUri; const std::string* dataMovementInterfaceId; const ::apache::airavata::model::data::movement::DMType::type* dataMoveType; @@ -21988,6 +22008,414 @@ class Airavata_isWorkflowExistWithName_presult { }; + +class Airavata_registerDataProduct_args { + public: + + Airavata_registerDataProduct_args(const Airavata_registerDataProduct_args&); + Airavata_registerDataProduct_args& operator=(const Airavata_registerDataProduct_args&); + Airavata_registerDataProduct_args() { + } + + virtual ~Airavata_registerDataProduct_args() throw(); + ::apache::airavata::model::security::AuthzToken authzToken; + ::apache::airavata::model::data::product::DataProductModel dataProductModel; + + void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); + + void __set_dataProductModel(const ::apache::airavata::model::data::product::DataProductModel& val); + + bool operator == (const Airavata_registerDataProduct_args & rhs) const + { + if (!(authzToken == rhs.authzToken)) + return false; + if (!(dataProductModel == rhs.dataProductModel)) + return false; + return true; + } + bool operator != (const Airavata_registerDataProduct_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_registerDataProduct_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_registerDataProduct_pargs { + public: + + + virtual ~Airavata_registerDataProduct_pargs() throw(); + const ::apache::airavata::model::security::AuthzToken* authzToken; + const ::apache::airavata::model::data::product::DataProductModel* dataProductModel; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_registerDataProduct_result__isset { + _Airavata_registerDataProduct_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_registerDataProduct_result__isset; + +class Airavata_registerDataProduct_result { + public: + + Airavata_registerDataProduct_result(const Airavata_registerDataProduct_result&); + Airavata_registerDataProduct_result& operator=(const Airavata_registerDataProduct_result&); + Airavata_registerDataProduct_result() : success() { + } + + virtual ~Airavata_registerDataProduct_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_registerDataProduct_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_registerDataProduct_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_registerDataProduct_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_registerDataProduct_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_registerDataProduct_presult__isset { + _Airavata_registerDataProduct_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_registerDataProduct_presult__isset; + +class Airavata_registerDataProduct_presult { + public: + + + virtual ~Airavata_registerDataProduct_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_registerDataProduct_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + +class Airavata_getDataProduct_args { + public: + + Airavata_getDataProduct_args(const Airavata_getDataProduct_args&); + Airavata_getDataProduct_args& operator=(const Airavata_getDataProduct_args&); + Airavata_getDataProduct_args() : dataProductUri() { + } + + virtual ~Airavata_getDataProduct_args() throw(); + ::apache::airavata::model::security::AuthzToken authzToken; + std::string dataProductUri; + + void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); + + void __set_dataProductUri(const std::string& val); + + bool operator == (const Airavata_getDataProduct_args & rhs) const + { + if (!(authzToken == rhs.authzToken)) + return false; + if (!(dataProductUri == rhs.dataProductUri)) + return false; + return true; + } + bool operator != (const Airavata_getDataProduct_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getDataProduct_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getDataProduct_pargs { + public: + + + virtual ~Airavata_getDataProduct_pargs() throw(); + const ::apache::airavata::model::security::AuthzToken* authzToken; + const std::string* dataProductUri; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getDataProduct_result__isset { + _Airavata_getDataProduct_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_getDataProduct_result__isset; + +class Airavata_getDataProduct_result { + public: + + Airavata_getDataProduct_result(const Airavata_getDataProduct_result&); + Airavata_getDataProduct_result& operator=(const Airavata_getDataProduct_result&); + Airavata_getDataProduct_result() { + } + + virtual ~Airavata_getDataProduct_result() throw(); + ::apache::airavata::model::data::product::DataProductModel 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_getDataProduct_result__isset __isset; + + void __set_success(const ::apache::airavata::model::data::product::DataProductModel& 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_getDataProduct_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_getDataProduct_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getDataProduct_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getDataProduct_presult__isset { + _Airavata_getDataProduct_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_getDataProduct_presult__isset; + +class Airavata_getDataProduct_presult { + public: + + + virtual ~Airavata_getDataProduct_presult() throw(); + ::apache::airavata::model::data::product::DataProductModel* 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_getDataProduct_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + +class Airavata_registerReplicaLocation_args { + public: + + Airavata_registerReplicaLocation_args(const Airavata_registerReplicaLocation_args&); + Airavata_registerReplicaLocation_args& operator=(const Airavata_registerReplicaLocation_args&); + Airavata_registerReplicaLocation_args() { + } + + virtual ~Airavata_registerReplicaLocation_args() throw(); + ::apache::airavata::model::security::AuthzToken authzToken; + ::apache::airavata::model::data::product::DataReplicaLocationModel replicaLocationModel; + + void __set_authzToken(const ::apache::airavata::model::security::AuthzToken& val); + + void __set_replicaLocationModel(const ::apache::airavata::model::data::product::DataReplicaLocationModel& val); + + bool operator == (const Airavata_registerReplicaLocation_args & rhs) const + { + if (!(authzToken == rhs.authzToken)) + return false; + if (!(replicaLocationModel == rhs.replicaLocationModel)) + return false; + return true; + } + bool operator != (const Airavata_registerReplicaLocation_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_registerReplicaLocation_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_registerReplicaLocation_pargs { + public: + + + virtual ~Airavata_registerReplicaLocation_pargs() throw(); + const ::apache::airavata::model::security::AuthzToken* authzToken; + const ::apache::airavata::model::data::product::DataReplicaLocationModel* replicaLocationModel; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_registerReplicaLocation_result__isset { + _Airavata_registerReplicaLocation_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_registerReplicaLocation_result__isset; + +class Airavata_registerReplicaLocation_result { + public: + + Airavata_registerReplicaLocation_result(const Airavata_registerReplicaLocation_result&); + Airavata_registerReplicaLocation_result& operator=(const Airavata_registerReplicaLocation_result&); + Airavata_registerReplicaLocation_result() : success() { + } + + virtual ~Airavata_registerReplicaLocation_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_registerReplicaLocation_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_registerReplicaLocation_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_registerReplicaLocation_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_registerReplicaLocation_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_registerReplicaLocation_presult__isset { + _Airavata_registerReplicaLocation_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_registerReplicaLocation_presult__isset; + +class Airavata_registerReplicaLocation_presult { + public: + + + virtual ~Airavata_registerReplicaLocation_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_registerReplicaLocation_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) { @@ -22280,8 +22708,8 @@ class AiravataClient : virtual public AiravataIf { bool updateUnicoreJobSubmissionDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission); void send_updateUnicoreJobSubmissionDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission); bool recv_updateUnicoreJobSubmissionDetails(); - void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); - void send_addLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); + void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); + void send_addLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); void recv_addLocalDataMovementDetails(std::string& _return); bool updateLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); void send_updateLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); @@ -22289,8 +22717,8 @@ class AiravataClient : virtual public AiravataIf { void getLocalDataMovement( ::apache::airavata::model::data::movement::LOCALDataMovement& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void send_getLocalDataMovement(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void recv_getLocalDataMovement( ::apache::airavata::model::data::movement::LOCALDataMovement& _return); - void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); - void send_addSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); + void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); + void send_addSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); void recv_addSCPDataMovementDetails(std::string& _return); bool updateSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); void send_updateSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); @@ -22298,8 +22726,8 @@ class AiravataClient : virtual public AiravataIf { void getSCPDataMovement( ::apache::airavata::model::data::movement::SCPDataMovement& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void send_getSCPDataMovement(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void recv_getSCPDataMovement( ::apache::airavata::model::data::movement::SCPDataMovement& _return); - void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); - void send_addUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); + void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); + void send_addUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); void recv_addUnicoreDataMovementDetails(std::string& _return); bool updateUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); void send_updateUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); @@ -22307,8 +22735,8 @@ class AiravataClient : virtual public AiravataIf { void getUnicoreDataMovement( ::apache::airavata::model::data::movement::UnicoreDataMovement& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void send_getUnicoreDataMovement(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void recv_getUnicoreDataMovement( ::apache::airavata::model::data::movement::UnicoreDataMovement& _return); - void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); - void send_addGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); + void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); + void send_addGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); void recv_addGridFTPDataMovementDetails(std::string& _return); bool updateGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); void send_updateGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); @@ -22331,8 +22759,8 @@ class AiravataClient : virtual public AiravataIf { bool deleteJobSubmissionInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& computeResourceId, const std::string& jobSubmissionInterfaceId); void send_deleteJobSubmissionInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& computeResourceId, const std::string& jobSubmissionInterfaceId); bool recv_deleteJobSubmissionInterface(); - bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); - void send_deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); + bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); + void send_deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); bool recv_deleteDataMovementInterface(); void registerResourceJobManager(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& resourceJobManager); void send_registerResourceJobManager(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& resourceJobManager); @@ -22415,6 +22843,15 @@ 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 registerDataProduct(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel); + void send_registerDataProduct(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel); + void recv_registerDataProduct(std::string& _return); + void getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri); + void send_getDataProduct(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri); + void recv_getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return); + void registerReplicaLocation(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel); + void send_registerReplicaLocation(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel); + void recv_registerReplicaLocation(std::string& _return); protected: boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot_; boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot_; @@ -22564,6 +23001,9 @@ 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_registerDataProduct(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getDataProduct(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_registerReplicaLocation(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); public: AiravataProcessor(boost::shared_ptr<AiravataIf> iface) : iface_(iface) { @@ -22701,6 +23141,9 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { processMap_["updateWorkflow"] = &AiravataProcessor::process_updateWorkflow; processMap_["getWorkflowTemplateId"] = &AiravataProcessor::process_getWorkflowTemplateId; processMap_["isWorkflowExistWithName"] = &AiravataProcessor::process_isWorkflowExistWithName; + processMap_["registerDataProduct"] = &AiravataProcessor::process_registerDataProduct; + processMap_["getDataProduct"] = &AiravataProcessor::process_getDataProduct; + processMap_["registerReplicaLocation"] = &AiravataProcessor::process_registerReplicaLocation; } virtual ~AiravataProcessor() {} @@ -23591,13 +24034,13 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->updateUnicoreJobSubmissionDetails(authzToken, jobSubmissionInterfaceId, unicoreJobSubmission); } - void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement) { + void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->addLocalDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, localDataMovement); + ifaces_[i]->addLocalDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, localDataMovement); } - ifaces_[i]->addLocalDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, localDataMovement); + ifaces_[i]->addLocalDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, localDataMovement); return; } @@ -23620,13 +24063,13 @@ class AiravataMultiface : virtual public AiravataIf { return; } - void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement) { + void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->addSCPDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, scpDataMovement); + ifaces_[i]->addSCPDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, scpDataMovement); } - ifaces_[i]->addSCPDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, scpDataMovement); + ifaces_[i]->addSCPDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, scpDataMovement); return; } @@ -23649,13 +24092,13 @@ class AiravataMultiface : virtual public AiravataIf { return; } - void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement) { + void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->addUnicoreDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, unicoreDataMovement); + ifaces_[i]->addUnicoreDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, unicoreDataMovement); } - ifaces_[i]->addUnicoreDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, unicoreDataMovement); + ifaces_[i]->addUnicoreDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, unicoreDataMovement); return; } @@ -23678,13 +24121,13 @@ class AiravataMultiface : virtual public AiravataIf { return; } - void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement) { + void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->addGridFTPDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, gridFTPDataMovement); + ifaces_[i]->addGridFTPDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, gridFTPDataMovement); } - ifaces_[i]->addGridFTPDataMovementDetails(_return, authzToken, productId, dataMoveType, priorityOrder, gridFTPDataMovement); + ifaces_[i]->addGridFTPDataMovementDetails(_return, authzToken, productUri, dataMoveType, priorityOrder, gridFTPDataMovement); return; } @@ -23752,13 +24195,13 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->deleteJobSubmissionInterface(authzToken, computeResourceId, jobSubmissionInterfaceId); } - bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType) { + bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->deleteDataMovementInterface(authzToken, productId, dataMovementInterfaceId, dataMoveType); + ifaces_[i]->deleteDataMovementInterface(authzToken, productUri, dataMovementInterfaceId, dataMoveType); } - return ifaces_[i]->deleteDataMovementInterface(authzToken, productId, dataMovementInterfaceId, dataMoveType); + return ifaces_[i]->deleteDataMovementInterface(authzToken, productUri, dataMovementInterfaceId, dataMoveType); } void registerResourceJobManager(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& resourceJobManager) { @@ -24017,6 +24460,36 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->isWorkflowExistWithName(authzToken, workflowName); } + void registerDataProduct(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->registerDataProduct(_return, authzToken, dataProductModel); + } + ifaces_[i]->registerDataProduct(_return, authzToken, dataProductModel); + return; + } + + void getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getDataProduct(_return, authzToken, dataProductUri); + } + ifaces_[i]->getDataProduct(_return, authzToken, dataProductUri); + return; + } + + void registerReplicaLocation(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->registerReplicaLocation(_return, authzToken, replicaLocationModel); + } + ifaces_[i]->registerReplicaLocation(_return, authzToken, replicaLocationModel); + return; + } + }; // The 'concurrent' client is a thread safe client that correctly handles @@ -24314,8 +24787,8 @@ class AiravataConcurrentClient : virtual public AiravataIf { bool updateUnicoreJobSubmissionDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission); int32_t send_updateUnicoreJobSubmissionDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission); bool recv_updateUnicoreJobSubmissionDetails(const int32_t seqid); - void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); - int32_t send_addLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); + void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); + int32_t send_addLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); void recv_addLocalDataMovementDetails(std::string& _return, const int32_t seqid); bool updateLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); int32_t send_updateLocalDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement); @@ -24323,8 +24796,8 @@ class AiravataConcurrentClient : virtual public AiravataIf { void getLocalDataMovement( ::apache::airavata::model::data::movement::LOCALDataMovement& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); int32_t send_getLocalDataMovement(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void recv_getLocalDataMovement( ::apache::airavata::model::data::movement::LOCALDataMovement& _return, const int32_t seqid); - void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); - int32_t send_addSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); + void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); + int32_t send_addSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); void recv_addSCPDataMovementDetails(std::string& _return, const int32_t seqid); bool updateSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); int32_t send_updateSCPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement); @@ -24332,8 +24805,8 @@ class AiravataConcurrentClient : virtual public AiravataIf { void getSCPDataMovement( ::apache::airavata::model::data::movement::SCPDataMovement& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); int32_t send_getSCPDataMovement(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void recv_getSCPDataMovement( ::apache::airavata::model::data::movement::SCPDataMovement& _return, const int32_t seqid); - void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); - int32_t send_addUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); + void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); + int32_t send_addUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); void recv_addUnicoreDataMovementDetails(std::string& _return, const int32_t seqid); bool updateUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); int32_t send_updateUnicoreDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement); @@ -24341,8 +24814,8 @@ class AiravataConcurrentClient : virtual public AiravataIf { void getUnicoreDataMovement( ::apache::airavata::model::data::movement::UnicoreDataMovement& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); int32_t send_getUnicoreDataMovement(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementId); void recv_getUnicoreDataMovement( ::apache::airavata::model::data::movement::UnicoreDataMovement& _return, const int32_t seqid); - void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); - int32_t send_addGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); + void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); + int32_t send_addGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); void recv_addGridFTPDataMovementDetails(std::string& _return, const int32_t seqid); bool updateGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); int32_t send_updateGridFTPDataMovementDetails(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement); @@ -24365,8 +24838,8 @@ class AiravataConcurrentClient : virtual public AiravataIf { bool deleteJobSubmissionInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& computeResourceId, const std::string& jobSubmissionInterfaceId); int32_t send_deleteJobSubmissionInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& computeResourceId, const std::string& jobSubmissionInterfaceId); bool recv_deleteJobSubmissionInterface(const int32_t seqid); - bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); - int32_t send_deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); + bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); + int32_t send_deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType); bool recv_deleteDataMovementInterface(const int32_t seqid); void registerResourceJobManager(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& resourceJobManager); int32_t send_registerResourceJobManager(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::appcatalog::computeresource::ResourceJobManager& resourceJobManager); @@ -24449,6 +24922,15 @@ 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 registerDataProduct(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel); + int32_t send_registerDataProduct(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel); + void recv_registerDataProduct(std::string& _return, const int32_t seqid); + void getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri); + int32_t send_getDataProduct(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri); + void recv_getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return, const int32_t seqid); + void registerReplicaLocation(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel); + int32_t send_registerReplicaLocation(const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel); + void recv_registerReplicaLocation(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/6c5645d3/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 c0d29ec..28ad7aa 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 @@ -2179,7 +2179,7 @@ class AiravataHandler : virtual public AiravataIf { * Add a Local data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which JobSubmission protocol to be added * * @param DMType @@ -2197,12 +2197,12 @@ class AiravataHandler : virtual public AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param localDataMovement */ - void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement) { + void addLocalDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::LOCALDataMovement& localDataMovement) { // Your implementation goes here printf("addLocalDataMovementDetails\n"); } @@ -2255,7 +2255,7 @@ class AiravataHandler : virtual public AiravataIf { * Add a SCP data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which JobSubmission protocol to be added * * @param priorityOrder @@ -2269,12 +2269,12 @@ class AiravataHandler : virtual public AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param scpDataMovement */ - void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement) { + void addSCPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::SCPDataMovement& scpDataMovement) { // Your implementation goes here printf("addSCPDataMovementDetails\n"); } @@ -2326,7 +2326,7 @@ class AiravataHandler : virtual public AiravataIf { * Add a UNICORE data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which data movement protocol to be added * * @param priorityOrder @@ -2340,12 +2340,12 @@ class AiravataHandler : virtual public AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param unicoreDataMovement */ - void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement) { + void addUnicoreDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::UnicoreDataMovement& unicoreDataMovement) { // Your implementation goes here printf("addUnicoreDataMovementDetails\n"); } @@ -2399,7 +2399,7 @@ class AiravataHandler : virtual public AiravataIf { * Add a GridFTP data movement details to a compute resource * App catalog will return a dataMovementInterfaceId which will be added to the dataMovementInterfaces. * - * @param productId + * @param productUri * The identifier of the compute resource to which dataMovement protocol to be added * * @param DMType @@ -2417,12 +2417,12 @@ class AiravataHandler : virtual public AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMoveType * @param priorityOrder * @param gridFTPDataMovement */ - void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement) { + void addGridFTPDataMovementDetails(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const ::apache::airavata::model::data::movement::DMType::type dataMoveType, const int32_t priorityOrder, const ::apache::airavata::model::data::movement::GridFTPDataMovement& gridFTPDataMovement) { // Your implementation goes here printf("addGridFTPDataMovementDetails\n"); } @@ -2584,11 +2584,11 @@ class AiravataHandler : virtual public AiravataIf { * * * @param authzToken - * @param productId + * @param productUri * @param dataMovementInterfaceId * @param dataMoveType */ - bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productId, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType) { + bool deleteDataMovementInterface(const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& productUri, const std::string& dataMovementInterfaceId, const ::apache::airavata::model::data::movement::DMType::type dataMoveType) { // Your implementation goes here printf("deleteDataMovementInterface\n"); } @@ -3022,6 +3022,28 @@ class AiravataHandler : virtual public AiravataIf { printf("isWorkflowExistWithName\n"); } + /** + * API Methods related to data catalog + * + * + * @param authzToken + * @param dataProductModel + */ + void registerDataProduct(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataProductModel& dataProductModel) { + // Your implementation goes here + printf("registerDataProduct\n"); + } + + void getDataProduct( ::apache::airavata::model::data::product::DataProductModel& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& dataProductUri) { + // Your implementation goes here + printf("getDataProduct\n"); + } + + void registerReplicaLocation(std::string& _return, const ::apache::airavata::model::security::AuthzToken& authzToken, const ::apache::airavata::model::data::product::DataReplicaLocationModel& replicaLocationModel) { + // Your implementation goes here + printf("registerReplicaLocation\n"); + } + }; int main(int argc, char **argv) {
