http://git-wip-us.apache.org/repos/asf/airavata/blob/47e82148/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 9066026..3bbe805 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 @@ -85,17 +85,24 @@ class AiravataIf { virtual bool deleteComputeResource(const std::string& computeResourceId) = 0; virtual void addLocalSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) = 0; virtual bool updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) = 0; + virtual void getLocalJobSubmission( ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& _return, const std::string& jobSubmissionId) = 0; virtual void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) = 0; + virtual void getSSHJobSubmission( ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& _return, const std::string& jobSubmissionId) = 0; virtual void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) = 0; + virtual void getUnicoreJobSubmission( ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& _return, const std::string& jobSubmissionId) = 0; virtual void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) = 0; + virtual void getCloudJobSubmission( ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& _return, const std::string& jobSubmissionId) = 0; virtual bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) = 0; virtual bool updateCloudJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& sshJobSubmission) = 0; virtual void addLocalDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) = 0; virtual bool updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) = 0; + virtual void getLocalDataMovement( ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& _return, const std::string& dataMovementId) = 0; virtual void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) = 0; virtual bool updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) = 0; + virtual void getSCPDataMovement( ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& _return, const std::string& dataMovementId) = 0; virtual void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) = 0; virtual bool updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) = 0; + virtual void getGridFTPDataMovement( ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& _return, const std::string& dataMovementId) = 0; virtual bool changeJobSubmissionPriority(const std::string& jobSubmissionInterfaceId, const int32_t newPriorityOrder) = 0; virtual bool changeDataMovementPriority(const std::string& dataMovementInterfaceId, const int32_t newPriorityOrder) = 0; virtual bool changeJobSubmissionPriorities(const std::map<std::string, int32_t> & jobSubmissionPriorityMap) = 0; @@ -309,15 +316,27 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } + void getLocalJobSubmission( ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& /* _return */, const std::string& /* jobSubmissionId */) { + return; + } void addSSHJobSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& /* sshJobSubmission */) { return; } + void getSSHJobSubmission( ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& /* _return */, const std::string& /* jobSubmissionId */) { + return; + } void addUNICOREJobSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& /* unicoreJobSubmission */) { return; } + void getUnicoreJobSubmission( ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& /* _return */, const std::string& /* jobSubmissionId */) { + return; + } void addCloudJobSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& /* cloudSubmission */) { return; } + void getCloudJobSubmission( ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& /* _return */, const std::string& /* jobSubmissionId */) { + return; + } bool updateSSHJobSubmissionDetails(const std::string& /* jobSubmissionInterfaceId */, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& /* sshJobSubmission */) { bool _return = false; return _return; @@ -333,6 +352,9 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } + void getLocalDataMovement( ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& /* _return */, const std::string& /* dataMovementId */) { + return; + } void addSCPDataMovementDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& /* scpDataMovement */) { return; } @@ -340,6 +362,9 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } + void getSCPDataMovement( ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& /* _return */, const std::string& /* dataMovementId */) { + return; + } void addGridFTPDataMovementDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& /* gridFTPDataMovement */) { return; } @@ -347,6 +372,9 @@ class AiravataNull : virtual public AiravataIf { bool _return = false; return _return; } + void getGridFTPDataMovement( ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& /* _return */, const std::string& /* dataMovementId */) { + return; + } bool changeJobSubmissionPriority(const std::string& /* jobSubmissionInterfaceId */, const int32_t /* newPriorityOrder */) { bool _return = false; return _return; @@ -7561,6 +7589,138 @@ class Airavata_updateLocalSubmissionDetails_presult { }; +class Airavata_getLocalJobSubmission_args { + public: + + Airavata_getLocalJobSubmission_args() : jobSubmissionId() { + } + + virtual ~Airavata_getLocalJobSubmission_args() throw() {} + + std::string jobSubmissionId; + + void __set_jobSubmissionId(const std::string& val) { + jobSubmissionId = val; + } + + bool operator == (const Airavata_getLocalJobSubmission_args & rhs) const + { + if (!(jobSubmissionId == rhs.jobSubmissionId)) + return false; + return true; + } + bool operator != (const Airavata_getLocalJobSubmission_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getLocalJobSubmission_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getLocalJobSubmission_pargs { + public: + + + virtual ~Airavata_getLocalJobSubmission_pargs() throw() {} + + const std::string* jobSubmissionId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getLocalJobSubmission_result__isset { + _Airavata_getLocalJobSubmission_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getLocalJobSubmission_result__isset; + +class Airavata_getLocalJobSubmission_result { + public: + + Airavata_getLocalJobSubmission_result() { + } + + virtual ~Airavata_getLocalJobSubmission_result() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getLocalJobSubmission_result__isset __isset; + + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_getLocalJobSubmission_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; + return true; + } + bool operator != (const Airavata_getLocalJobSubmission_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getLocalJobSubmission_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getLocalJobSubmission_presult__isset { + _Airavata_getLocalJobSubmission_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getLocalJobSubmission_presult__isset; + +class Airavata_getLocalJobSubmission_presult { + public: + + + virtual ~Airavata_getLocalJobSubmission_presult() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getLocalJobSubmission_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class Airavata_addSSHJobSubmissionDetails_args { public: @@ -7709,45 +7869,31 @@ class Airavata_addSSHJobSubmissionDetails_presult { }; -class Airavata_addUNICOREJobSubmissionDetails_args { +class Airavata_getSSHJobSubmission_args { public: - Airavata_addUNICOREJobSubmissionDetails_args() : computeResourceId(), priorityOrder(0) { + Airavata_getSSHJobSubmission_args() : jobSubmissionId() { } - virtual ~Airavata_addUNICOREJobSubmissionDetails_args() throw() {} - - std::string computeResourceId; - int32_t priorityOrder; - ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission unicoreJobSubmission; - - void __set_computeResourceId(const std::string& val) { - computeResourceId = val; - } + virtual ~Airavata_getSSHJobSubmission_args() throw() {} - void __set_priorityOrder(const int32_t val) { - priorityOrder = val; - } + std::string jobSubmissionId; - void __set_unicoreJobSubmission(const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& val) { - unicoreJobSubmission = val; + void __set_jobSubmissionId(const std::string& val) { + jobSubmissionId = val; } - bool operator == (const Airavata_addUNICOREJobSubmissionDetails_args & rhs) const + bool operator == (const Airavata_getSSHJobSubmission_args & rhs) const { - if (!(computeResourceId == rhs.computeResourceId)) - return false; - if (!(priorityOrder == rhs.priorityOrder)) - return false; - if (!(unicoreJobSubmission == rhs.unicoreJobSubmission)) + if (!(jobSubmissionId == rhs.jobSubmissionId)) return false; return true; } - bool operator != (const Airavata_addUNICOREJobSubmissionDetails_args &rhs) const { + bool operator != (const Airavata_getSSHJobSubmission_args &rhs) const { return !(*this == rhs); } - bool operator < (const Airavata_addUNICOREJobSubmissionDetails_args & ) const; + bool operator < (const Airavata_getSSHJobSubmission_args & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; @@ -7755,44 +7901,42 @@ class Airavata_addUNICOREJobSubmissionDetails_args { }; -class Airavata_addUNICOREJobSubmissionDetails_pargs { +class Airavata_getSSHJobSubmission_pargs { public: - virtual ~Airavata_addUNICOREJobSubmissionDetails_pargs() throw() {} + virtual ~Airavata_getSSHJobSubmission_pargs() throw() {} - const std::string* computeResourceId; - const int32_t* priorityOrder; - const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission* unicoreJobSubmission; + const std::string* jobSubmissionId; uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _Airavata_addUNICOREJobSubmissionDetails_result__isset { - _Airavata_addUNICOREJobSubmissionDetails_result__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_getSSHJobSubmission_result__isset { + _Airavata_getSSHJobSubmission_result__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_addUNICOREJobSubmissionDetails_result__isset; +} _Airavata_getSSHJobSubmission_result__isset; -class Airavata_addUNICOREJobSubmissionDetails_result { +class Airavata_getSSHJobSubmission_result { public: - Airavata_addUNICOREJobSubmissionDetails_result() : success() { + Airavata_getSSHJobSubmission_result() { } - virtual ~Airavata_addUNICOREJobSubmissionDetails_result() throw() {} + virtual ~Airavata_getSSHJobSubmission_result() throw() {} - std::string success; + ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission success; ::apache::airavata::api::error::InvalidRequestException ire; ::apache::airavata::api::error::AiravataClientException ace; ::apache::airavata::api::error::AiravataSystemException ase; - _Airavata_addUNICOREJobSubmissionDetails_result__isset __isset; + _Airavata_getSSHJobSubmission_result__isset __isset; - void __set_success(const std::string& val) { + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& val) { success = val; } @@ -7808,7 +7952,7 @@ class Airavata_addUNICOREJobSubmissionDetails_result { ase = val; } - bool operator == (const Airavata_addUNICOREJobSubmissionDetails_result & rhs) const + bool operator == (const Airavata_getSSHJobSubmission_result & rhs) const { if (!(success == rhs.success)) return false; @@ -7820,54 +7964,54 @@ class Airavata_addUNICOREJobSubmissionDetails_result { return false; return true; } - bool operator != (const Airavata_addUNICOREJobSubmissionDetails_result &rhs) const { + bool operator != (const Airavata_getSSHJobSubmission_result &rhs) const { return !(*this == rhs); } - bool operator < (const Airavata_addUNICOREJobSubmissionDetails_result & ) const; + bool operator < (const Airavata_getSSHJobSubmission_result & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _Airavata_addUNICOREJobSubmissionDetails_presult__isset { - _Airavata_addUNICOREJobSubmissionDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_getSSHJobSubmission_presult__isset { + _Airavata_getSSHJobSubmission_presult__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_addUNICOREJobSubmissionDetails_presult__isset; +} _Airavata_getSSHJobSubmission_presult__isset; -class Airavata_addUNICOREJobSubmissionDetails_presult { +class Airavata_getSSHJobSubmission_presult { public: - virtual ~Airavata_addUNICOREJobSubmissionDetails_presult() throw() {} + virtual ~Airavata_getSSHJobSubmission_presult() throw() {} - std::string* success; + ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission* success; ::apache::airavata::api::error::InvalidRequestException ire; ::apache::airavata::api::error::AiravataClientException ace; ::apache::airavata::api::error::AiravataSystemException ase; - _Airavata_addUNICOREJobSubmissionDetails_presult__isset __isset; + _Airavata_getSSHJobSubmission_presult__isset __isset; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); }; -class Airavata_addCloudJobSubmissionDetails_args { +class Airavata_addUNICOREJobSubmissionDetails_args { public: - Airavata_addCloudJobSubmissionDetails_args() : computeResourceId(), priorityOrder(0) { + Airavata_addUNICOREJobSubmissionDetails_args() : computeResourceId(), priorityOrder(0) { } - virtual ~Airavata_addCloudJobSubmissionDetails_args() throw() {} + virtual ~Airavata_addUNICOREJobSubmissionDetails_args() throw() {} std::string computeResourceId; int32_t priorityOrder; - ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission cloudSubmission; + ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission unicoreJobSubmission; void __set_computeResourceId(const std::string& val) { computeResourceId = val; @@ -7877,25 +8021,25 @@ class Airavata_addCloudJobSubmissionDetails_args { priorityOrder = val; } - void __set_cloudSubmission(const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& val) { - cloudSubmission = val; + void __set_unicoreJobSubmission(const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& val) { + unicoreJobSubmission = val; } - bool operator == (const Airavata_addCloudJobSubmissionDetails_args & rhs) const + bool operator == (const Airavata_addUNICOREJobSubmissionDetails_args & rhs) const { if (!(computeResourceId == rhs.computeResourceId)) return false; if (!(priorityOrder == rhs.priorityOrder)) return false; - if (!(cloudSubmission == rhs.cloudSubmission)) + if (!(unicoreJobSubmission == rhs.unicoreJobSubmission)) return false; return true; } - bool operator != (const Airavata_addCloudJobSubmissionDetails_args &rhs) const { + bool operator != (const Airavata_addUNICOREJobSubmissionDetails_args &rhs) const { return !(*this == rhs); } - bool operator < (const Airavata_addCloudJobSubmissionDetails_args & ) const; + bool operator < (const Airavata_addUNICOREJobSubmissionDetails_args & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; @@ -7903,42 +8047,42 @@ class Airavata_addCloudJobSubmissionDetails_args { }; -class Airavata_addCloudJobSubmissionDetails_pargs { +class Airavata_addUNICOREJobSubmissionDetails_pargs { public: - virtual ~Airavata_addCloudJobSubmissionDetails_pargs() throw() {} + virtual ~Airavata_addUNICOREJobSubmissionDetails_pargs() throw() {} const std::string* computeResourceId; const int32_t* priorityOrder; - const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission* cloudSubmission; + const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission* unicoreJobSubmission; uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _Airavata_addCloudJobSubmissionDetails_result__isset { - _Airavata_addCloudJobSubmissionDetails_result__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_addUNICOREJobSubmissionDetails_result__isset { + _Airavata_addUNICOREJobSubmissionDetails_result__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_addCloudJobSubmissionDetails_result__isset; +} _Airavata_addUNICOREJobSubmissionDetails_result__isset; -class Airavata_addCloudJobSubmissionDetails_result { +class Airavata_addUNICOREJobSubmissionDetails_result { public: - Airavata_addCloudJobSubmissionDetails_result() : success() { + Airavata_addUNICOREJobSubmissionDetails_result() : success() { } - virtual ~Airavata_addCloudJobSubmissionDetails_result() throw() {} + virtual ~Airavata_addUNICOREJobSubmissionDetails_result() throw() {} std::string success; ::apache::airavata::api::error::InvalidRequestException ire; ::apache::airavata::api::error::AiravataClientException ace; ::apache::airavata::api::error::AiravataSystemException ase; - _Airavata_addCloudJobSubmissionDetails_result__isset __isset; + _Airavata_addUNICOREJobSubmissionDetails_result__isset __isset; void __set_success(const std::string& val) { success = val; @@ -7956,7 +8100,7 @@ class Airavata_addCloudJobSubmissionDetails_result { ase = val; } - bool operator == (const Airavata_addCloudJobSubmissionDetails_result & rhs) const + bool operator == (const Airavata_addUNICOREJobSubmissionDetails_result & rhs) const { if (!(success == rhs.success)) return false; @@ -7968,75 +8112,68 @@ class Airavata_addCloudJobSubmissionDetails_result { return false; return true; } - bool operator != (const Airavata_addCloudJobSubmissionDetails_result &rhs) const { + bool operator != (const Airavata_addUNICOREJobSubmissionDetails_result &rhs) const { return !(*this == rhs); } - bool operator < (const Airavata_addCloudJobSubmissionDetails_result & ) const; + bool operator < (const Airavata_addUNICOREJobSubmissionDetails_result & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _Airavata_addCloudJobSubmissionDetails_presult__isset { - _Airavata_addCloudJobSubmissionDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_addUNICOREJobSubmissionDetails_presult__isset { + _Airavata_addUNICOREJobSubmissionDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_addCloudJobSubmissionDetails_presult__isset; +} _Airavata_addUNICOREJobSubmissionDetails_presult__isset; -class Airavata_addCloudJobSubmissionDetails_presult { +class Airavata_addUNICOREJobSubmissionDetails_presult { public: - virtual ~Airavata_addCloudJobSubmissionDetails_presult() throw() {} + virtual ~Airavata_addUNICOREJobSubmissionDetails_presult() throw() {} std::string* success; ::apache::airavata::api::error::InvalidRequestException ire; ::apache::airavata::api::error::AiravataClientException ace; ::apache::airavata::api::error::AiravataSystemException ase; - _Airavata_addCloudJobSubmissionDetails_presult__isset __isset; + _Airavata_addUNICOREJobSubmissionDetails_presult__isset __isset; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); }; -class Airavata_updateSSHJobSubmissionDetails_args { +class Airavata_getUnicoreJobSubmission_args { public: - Airavata_updateSSHJobSubmissionDetails_args() : jobSubmissionInterfaceId() { + Airavata_getUnicoreJobSubmission_args() : jobSubmissionId() { } - virtual ~Airavata_updateSSHJobSubmissionDetails_args() throw() {} - - std::string jobSubmissionInterfaceId; - ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission sshJobSubmission; + virtual ~Airavata_getUnicoreJobSubmission_args() throw() {} - void __set_jobSubmissionInterfaceId(const std::string& val) { - jobSubmissionInterfaceId = val; - } + std::string jobSubmissionId; - void __set_sshJobSubmission(const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& val) { - sshJobSubmission = val; + void __set_jobSubmissionId(const std::string& val) { + jobSubmissionId = val; } - bool operator == (const Airavata_updateSSHJobSubmissionDetails_args & rhs) const + bool operator == (const Airavata_getUnicoreJobSubmission_args & rhs) const { - if (!(jobSubmissionInterfaceId == rhs.jobSubmissionInterfaceId)) - return false; - if (!(sshJobSubmission == rhs.sshJobSubmission)) + if (!(jobSubmissionId == rhs.jobSubmissionId)) return false; return true; } - bool operator != (const Airavata_updateSSHJobSubmissionDetails_args &rhs) const { + bool operator != (const Airavata_getUnicoreJobSubmission_args &rhs) const { return !(*this == rhs); } - bool operator < (const Airavata_updateSSHJobSubmissionDetails_args & ) const; + bool operator < (const Airavata_getUnicoreJobSubmission_args & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; @@ -8044,43 +8181,42 @@ class Airavata_updateSSHJobSubmissionDetails_args { }; -class Airavata_updateSSHJobSubmissionDetails_pargs { +class Airavata_getUnicoreJobSubmission_pargs { public: - virtual ~Airavata_updateSSHJobSubmissionDetails_pargs() throw() {} + virtual ~Airavata_getUnicoreJobSubmission_pargs() throw() {} - const std::string* jobSubmissionInterfaceId; - const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission* sshJobSubmission; + const std::string* jobSubmissionId; uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _Airavata_updateSSHJobSubmissionDetails_result__isset { - _Airavata_updateSSHJobSubmissionDetails_result__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_getUnicoreJobSubmission_result__isset { + _Airavata_getUnicoreJobSubmission_result__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_updateSSHJobSubmissionDetails_result__isset; +} _Airavata_getUnicoreJobSubmission_result__isset; -class Airavata_updateSSHJobSubmissionDetails_result { +class Airavata_getUnicoreJobSubmission_result { public: - Airavata_updateSSHJobSubmissionDetails_result() : success(0) { + Airavata_getUnicoreJobSubmission_result() { } - virtual ~Airavata_updateSSHJobSubmissionDetails_result() throw() {} + virtual ~Airavata_getUnicoreJobSubmission_result() throw() {} - bool success; + ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission success; ::apache::airavata::api::error::InvalidRequestException ire; ::apache::airavata::api::error::AiravataClientException ace; ::apache::airavata::api::error::AiravataSystemException ase; - _Airavata_updateSSHJobSubmissionDetails_result__isset __isset; + _Airavata_getUnicoreJobSubmission_result__isset __isset; - void __set_success(const bool val) { + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& val) { success = val; } @@ -8096,7 +8232,7 @@ class Airavata_updateSSHJobSubmissionDetails_result { ase = val; } - bool operator == (const Airavata_updateSSHJobSubmissionDetails_result & rhs) const + bool operator == (const Airavata_getUnicoreJobSubmission_result & rhs) const { if (!(success == rhs.success)) return false; @@ -8108,24 +8244,444 @@ class Airavata_updateSSHJobSubmissionDetails_result { return false; return true; } - bool operator != (const Airavata_updateSSHJobSubmissionDetails_result &rhs) const { + bool operator != (const Airavata_getUnicoreJobSubmission_result &rhs) const { return !(*this == rhs); } - bool operator < (const Airavata_updateSSHJobSubmissionDetails_result & ) const; + bool operator < (const Airavata_getUnicoreJobSubmission_result & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _Airavata_updateSSHJobSubmissionDetails_presult__isset { - _Airavata_updateSSHJobSubmissionDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_getUnicoreJobSubmission_presult__isset { + _Airavata_getUnicoreJobSubmission_presult__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_updateSSHJobSubmissionDetails_presult__isset; +} _Airavata_getUnicoreJobSubmission_presult__isset; + +class Airavata_getUnicoreJobSubmission_presult { + public: + + + virtual ~Airavata_getUnicoreJobSubmission_presult() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getUnicoreJobSubmission_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + +class Airavata_addCloudJobSubmissionDetails_args { + public: + + Airavata_addCloudJobSubmissionDetails_args() : computeResourceId(), priorityOrder(0) { + } + + virtual ~Airavata_addCloudJobSubmissionDetails_args() throw() {} + + std::string computeResourceId; + int32_t priorityOrder; + ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission cloudSubmission; + + void __set_computeResourceId(const std::string& val) { + computeResourceId = val; + } + + void __set_priorityOrder(const int32_t val) { + priorityOrder = val; + } + + void __set_cloudSubmission(const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& val) { + cloudSubmission = val; + } + + bool operator == (const Airavata_addCloudJobSubmissionDetails_args & rhs) const + { + if (!(computeResourceId == rhs.computeResourceId)) + return false; + if (!(priorityOrder == rhs.priorityOrder)) + return false; + if (!(cloudSubmission == rhs.cloudSubmission)) + return false; + return true; + } + bool operator != (const Airavata_addCloudJobSubmissionDetails_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_addCloudJobSubmissionDetails_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_addCloudJobSubmissionDetails_pargs { + public: + + + virtual ~Airavata_addCloudJobSubmissionDetails_pargs() throw() {} + + const std::string* computeResourceId; + const int32_t* priorityOrder; + const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission* cloudSubmission; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_addCloudJobSubmissionDetails_result__isset { + _Airavata_addCloudJobSubmissionDetails_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_addCloudJobSubmissionDetails_result__isset; + +class Airavata_addCloudJobSubmissionDetails_result { + public: + + Airavata_addCloudJobSubmissionDetails_result() : success() { + } + + virtual ~Airavata_addCloudJobSubmissionDetails_result() throw() {} + + std::string success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_addCloudJobSubmissionDetails_result__isset __isset; + + void __set_success(const std::string& val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_addCloudJobSubmissionDetails_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; + return true; + } + bool operator != (const Airavata_addCloudJobSubmissionDetails_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_addCloudJobSubmissionDetails_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_addCloudJobSubmissionDetails_presult__isset { + _Airavata_addCloudJobSubmissionDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_addCloudJobSubmissionDetails_presult__isset; + +class Airavata_addCloudJobSubmissionDetails_presult { + public: + + + virtual ~Airavata_addCloudJobSubmissionDetails_presult() throw() {} + + std::string* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_addCloudJobSubmissionDetails_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + +class Airavata_getCloudJobSubmission_args { + public: + + Airavata_getCloudJobSubmission_args() : jobSubmissionId() { + } + + virtual ~Airavata_getCloudJobSubmission_args() throw() {} + + std::string jobSubmissionId; + + void __set_jobSubmissionId(const std::string& val) { + jobSubmissionId = val; + } + + bool operator == (const Airavata_getCloudJobSubmission_args & rhs) const + { + if (!(jobSubmissionId == rhs.jobSubmissionId)) + return false; + return true; + } + bool operator != (const Airavata_getCloudJobSubmission_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getCloudJobSubmission_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getCloudJobSubmission_pargs { + public: + + + virtual ~Airavata_getCloudJobSubmission_pargs() throw() {} + + const std::string* jobSubmissionId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getCloudJobSubmission_result__isset { + _Airavata_getCloudJobSubmission_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getCloudJobSubmission_result__isset; + +class Airavata_getCloudJobSubmission_result { + public: + + Airavata_getCloudJobSubmission_result() { + } + + virtual ~Airavata_getCloudJobSubmission_result() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getCloudJobSubmission_result__isset __isset; + + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_getCloudJobSubmission_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; + return true; + } + bool operator != (const Airavata_getCloudJobSubmission_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getCloudJobSubmission_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getCloudJobSubmission_presult__isset { + _Airavata_getCloudJobSubmission_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getCloudJobSubmission_presult__isset; + +class Airavata_getCloudJobSubmission_presult { + public: + + + virtual ~Airavata_getCloudJobSubmission_presult() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getCloudJobSubmission_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + +class Airavata_updateSSHJobSubmissionDetails_args { + public: + + Airavata_updateSSHJobSubmissionDetails_args() : jobSubmissionInterfaceId() { + } + + virtual ~Airavata_updateSSHJobSubmissionDetails_args() throw() {} + + std::string jobSubmissionInterfaceId; + ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission sshJobSubmission; + + void __set_jobSubmissionInterfaceId(const std::string& val) { + jobSubmissionInterfaceId = val; + } + + void __set_sshJobSubmission(const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& val) { + sshJobSubmission = val; + } + + bool operator == (const Airavata_updateSSHJobSubmissionDetails_args & rhs) const + { + if (!(jobSubmissionInterfaceId == rhs.jobSubmissionInterfaceId)) + return false; + if (!(sshJobSubmission == rhs.sshJobSubmission)) + return false; + return true; + } + bool operator != (const Airavata_updateSSHJobSubmissionDetails_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_updateSSHJobSubmissionDetails_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_updateSSHJobSubmissionDetails_pargs { + public: + + + virtual ~Airavata_updateSSHJobSubmissionDetails_pargs() throw() {} + + const std::string* jobSubmissionInterfaceId; + const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission* sshJobSubmission; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_updateSSHJobSubmissionDetails_result__isset { + _Airavata_updateSSHJobSubmissionDetails_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_updateSSHJobSubmissionDetails_result__isset; + +class Airavata_updateSSHJobSubmissionDetails_result { + public: + + Airavata_updateSSHJobSubmissionDetails_result() : success(0) { + } + + virtual ~Airavata_updateSSHJobSubmissionDetails_result() throw() {} + + bool success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_updateSSHJobSubmissionDetails_result__isset __isset; + + void __set_success(const bool val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_updateSSHJobSubmissionDetails_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; + return true; + } + bool operator != (const Airavata_updateSSHJobSubmissionDetails_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_updateSSHJobSubmissionDetails_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_updateSSHJobSubmissionDetails_presult__isset { + _Airavata_updateSSHJobSubmissionDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_updateSSHJobSubmissionDetails_presult__isset; class Airavata_updateSSHJobSubmissionDetails_presult { public: @@ -8547,26 +9103,158 @@ class Airavata_updateLocalDataMovementDetails_result { }; -typedef struct _Airavata_updateLocalDataMovementDetails_presult__isset { - _Airavata_updateLocalDataMovementDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} +typedef struct _Airavata_updateLocalDataMovementDetails_presult__isset { + _Airavata_updateLocalDataMovementDetails_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_updateLocalDataMovementDetails_presult__isset; + +class Airavata_updateLocalDataMovementDetails_presult { + public: + + + virtual ~Airavata_updateLocalDataMovementDetails_presult() throw() {} + + bool* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_updateLocalDataMovementDetails_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + +class Airavata_getLocalDataMovement_args { + public: + + Airavata_getLocalDataMovement_args() : dataMovementId() { + } + + virtual ~Airavata_getLocalDataMovement_args() throw() {} + + std::string dataMovementId; + + void __set_dataMovementId(const std::string& val) { + dataMovementId = val; + } + + bool operator == (const Airavata_getLocalDataMovement_args & rhs) const + { + if (!(dataMovementId == rhs.dataMovementId)) + return false; + return true; + } + bool operator != (const Airavata_getLocalDataMovement_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getLocalDataMovement_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getLocalDataMovement_pargs { + public: + + + virtual ~Airavata_getLocalDataMovement_pargs() throw() {} + + const std::string* dataMovementId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getLocalDataMovement_result__isset { + _Airavata_getLocalDataMovement_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getLocalDataMovement_result__isset; + +class Airavata_getLocalDataMovement_result { + public: + + Airavata_getLocalDataMovement_result() { + } + + virtual ~Airavata_getLocalDataMovement_result() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getLocalDataMovement_result__isset __isset; + + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_getLocalDataMovement_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; + return true; + } + bool operator != (const Airavata_getLocalDataMovement_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getLocalDataMovement_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getLocalDataMovement_presult__isset { + _Airavata_getLocalDataMovement_presult__isset() : success(false), ire(false), ace(false), ase(false) {} bool success; bool ire; bool ace; bool ase; -} _Airavata_updateLocalDataMovementDetails_presult__isset; +} _Airavata_getLocalDataMovement_presult__isset; -class Airavata_updateLocalDataMovementDetails_presult { +class Airavata_getLocalDataMovement_presult { public: - virtual ~Airavata_updateLocalDataMovementDetails_presult() throw() {} + virtual ~Airavata_getLocalDataMovement_presult() throw() {} - bool* success; + ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement* success; ::apache::airavata::api::error::InvalidRequestException ire; ::apache::airavata::api::error::AiravataClientException ace; ::apache::airavata::api::error::AiravataSystemException ase; - _Airavata_updateLocalDataMovementDetails_presult__isset __isset; + _Airavata_getLocalDataMovement_presult__isset __isset; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); @@ -8861,6 +9549,138 @@ class Airavata_updateSCPDataMovementDetails_presult { }; +class Airavata_getSCPDataMovement_args { + public: + + Airavata_getSCPDataMovement_args() : dataMovementId() { + } + + virtual ~Airavata_getSCPDataMovement_args() throw() {} + + std::string dataMovementId; + + void __set_dataMovementId(const std::string& val) { + dataMovementId = val; + } + + bool operator == (const Airavata_getSCPDataMovement_args & rhs) const + { + if (!(dataMovementId == rhs.dataMovementId)) + return false; + return true; + } + bool operator != (const Airavata_getSCPDataMovement_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getSCPDataMovement_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getSCPDataMovement_pargs { + public: + + + virtual ~Airavata_getSCPDataMovement_pargs() throw() {} + + const std::string* dataMovementId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getSCPDataMovement_result__isset { + _Airavata_getSCPDataMovement_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getSCPDataMovement_result__isset; + +class Airavata_getSCPDataMovement_result { + public: + + Airavata_getSCPDataMovement_result() { + } + + virtual ~Airavata_getSCPDataMovement_result() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getSCPDataMovement_result__isset __isset; + + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_getSCPDataMovement_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; + return true; + } + bool operator != (const Airavata_getSCPDataMovement_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getSCPDataMovement_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getSCPDataMovement_presult__isset { + _Airavata_getSCPDataMovement_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getSCPDataMovement_presult__isset; + +class Airavata_getSCPDataMovement_presult { + public: + + + virtual ~Airavata_getSCPDataMovement_presult() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getSCPDataMovement_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class Airavata_addGridFTPDataMovementDetails_args { public: @@ -9149,6 +9969,138 @@ class Airavata_updateGridFTPDataMovementDetails_presult { }; +class Airavata_getGridFTPDataMovement_args { + public: + + Airavata_getGridFTPDataMovement_args() : dataMovementId() { + } + + virtual ~Airavata_getGridFTPDataMovement_args() throw() {} + + std::string dataMovementId; + + void __set_dataMovementId(const std::string& val) { + dataMovementId = val; + } + + bool operator == (const Airavata_getGridFTPDataMovement_args & rhs) const + { + if (!(dataMovementId == rhs.dataMovementId)) + return false; + return true; + } + bool operator != (const Airavata_getGridFTPDataMovement_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getGridFTPDataMovement_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class Airavata_getGridFTPDataMovement_pargs { + public: + + + virtual ~Airavata_getGridFTPDataMovement_pargs() throw() {} + + const std::string* dataMovementId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getGridFTPDataMovement_result__isset { + _Airavata_getGridFTPDataMovement_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getGridFTPDataMovement_result__isset; + +class Airavata_getGridFTPDataMovement_result { + public: + + Airavata_getGridFTPDataMovement_result() { + } + + virtual ~Airavata_getGridFTPDataMovement_result() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getGridFTPDataMovement_result__isset __isset; + + void __set_success(const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& val) { + success = val; + } + + void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const Airavata_getGridFTPDataMovement_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; + return true; + } + bool operator != (const Airavata_getGridFTPDataMovement_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const Airavata_getGridFTPDataMovement_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _Airavata_getGridFTPDataMovement_presult__isset { + _Airavata_getGridFTPDataMovement_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _Airavata_getGridFTPDataMovement_presult__isset; + +class Airavata_getGridFTPDataMovement_presult { + public: + + + virtual ~Airavata_getGridFTPDataMovement_presult() throw() {} + + ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement* success; + ::apache::airavata::api::error::InvalidRequestException ire; + ::apache::airavata::api::error::AiravataClientException ace; + ::apache::airavata::api::error::AiravataSystemException ase; + + _Airavata_getGridFTPDataMovement_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class Airavata_changeJobSubmissionPriority_args { public: @@ -11379,15 +12331,27 @@ class AiravataClient : virtual public AiravataIf { bool updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission); void send_updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission); bool recv_updateLocalSubmissionDetails(); + void getLocalJobSubmission( ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& _return, const std::string& jobSubmissionId); + void send_getLocalJobSubmission(const std::string& jobSubmissionId); + void recv_getLocalJobSubmission( ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& _return); void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission); void send_addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission); void recv_addSSHJobSubmissionDetails(std::string& _return); + void getSSHJobSubmission( ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& _return, const std::string& jobSubmissionId); + void send_getSSHJobSubmission(const std::string& jobSubmissionId); + void recv_getSSHJobSubmission( ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& _return); void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission); void send_addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission); void recv_addUNICOREJobSubmissionDetails(std::string& _return); + void getUnicoreJobSubmission( ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& _return, const std::string& jobSubmissionId); + void send_getUnicoreJobSubmission(const std::string& jobSubmissionId); + void recv_getUnicoreJobSubmission( ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& _return); void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission); void send_addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission); void recv_addCloudJobSubmissionDetails(std::string& _return); + void getCloudJobSubmission( ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& _return, const std::string& jobSubmissionId); + void send_getCloudJobSubmission(const std::string& jobSubmissionId); + void recv_getCloudJobSubmission( ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& _return); bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission); void send_updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission); bool recv_updateSSHJobSubmissionDetails(); @@ -11400,18 +12364,27 @@ class AiravataClient : virtual public AiravataIf { bool updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement); void send_updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement); bool recv_updateLocalDataMovementDetails(); + void getLocalDataMovement( ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& _return, const std::string& dataMovementId); + void send_getLocalDataMovement(const std::string& dataMovementId); + void recv_getLocalDataMovement( ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& _return); void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement); void send_addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement); void recv_addSCPDataMovementDetails(std::string& _return); bool updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement); void send_updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement); bool recv_updateSCPDataMovementDetails(); + void getSCPDataMovement( ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& _return, const std::string& dataMovementId); + void send_getSCPDataMovement(const std::string& dataMovementId); + void recv_getSCPDataMovement( ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& _return); void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement); void send_addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement); void recv_addGridFTPDataMovementDetails(std::string& _return); bool updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement); void send_updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement); bool recv_updateGridFTPDataMovementDetails(); + void getGridFTPDataMovement( ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& _return, const std::string& dataMovementId); + void send_getGridFTPDataMovement(const std::string& dataMovementId); + void recv_getGridFTPDataMovement( ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& _return); bool changeJobSubmissionPriority(const std::string& jobSubmissionInterfaceId, const int32_t newPriorityOrder); void send_changeJobSubmissionPriority(const std::string& jobSubmissionInterfaceId, const int32_t newPriorityOrder); bool recv_changeJobSubmissionPriority(); @@ -11525,17 +12498,24 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { void process_deleteComputeResource(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addLocalSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_updateLocalSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getLocalJobSubmission(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addSSHJobSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getSSHJobSubmission(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addUNICOREJobSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getUnicoreJobSubmission(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addCloudJobSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getCloudJobSubmission(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_updateSSHJobSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_updateCloudJobSubmissionDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addLocalDataMovementDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_updateLocalDataMovementDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getLocalDataMovement(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addSCPDataMovementDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_updateSCPDataMovementDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getSCPDataMovement(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addGridFTPDataMovementDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_updateGridFTPDataMovementDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getGridFTPDataMovement(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_changeJobSubmissionPriority(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_changeDataMovementPriority(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_changeJobSubmissionPriorities(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); @@ -11607,17 +12587,24 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor { processMap_["deleteComputeResource"] = &AiravataProcessor::process_deleteComputeResource; processMap_["addLocalSubmissionDetails"] = &AiravataProcessor::process_addLocalSubmissionDetails; processMap_["updateLocalSubmissionDetails"] = &AiravataProcessor::process_updateLocalSubmissionDetails; + processMap_["getLocalJobSubmission"] = &AiravataProcessor::process_getLocalJobSubmission; processMap_["addSSHJobSubmissionDetails"] = &AiravataProcessor::process_addSSHJobSubmissionDetails; + processMap_["getSSHJobSubmission"] = &AiravataProcessor::process_getSSHJobSubmission; processMap_["addUNICOREJobSubmissionDetails"] = &AiravataProcessor::process_addUNICOREJobSubmissionDetails; + processMap_["getUnicoreJobSubmission"] = &AiravataProcessor::process_getUnicoreJobSubmission; processMap_["addCloudJobSubmissionDetails"] = &AiravataProcessor::process_addCloudJobSubmissionDetails; + processMap_["getCloudJobSubmission"] = &AiravataProcessor::process_getCloudJobSubmission; processMap_["updateSSHJobSubmissionDetails"] = &AiravataProcessor::process_updateSSHJobSubmissionDetails; processMap_["updateCloudJobSubmissionDetails"] = &AiravataProcessor::process_updateCloudJobSubmissionDetails; processMap_["addLocalDataMovementDetails"] = &AiravataProcessor::process_addLocalDataMovementDetails; processMap_["updateLocalDataMovementDetails"] = &AiravataProcessor::process_updateLocalDataMovementDetails; + processMap_["getLocalDataMovement"] = &AiravataProcessor::process_getLocalDataMovement; processMap_["addSCPDataMovementDetails"] = &AiravataProcessor::process_addSCPDataMovementDetails; processMap_["updateSCPDataMovementDetails"] = &AiravataProcessor::process_updateSCPDataMovementDetails; + processMap_["getSCPDataMovement"] = &AiravataProcessor::process_getSCPDataMovement; processMap_["addGridFTPDataMovementDetails"] = &AiravataProcessor::process_addGridFTPDataMovementDetails; processMap_["updateGridFTPDataMovementDetails"] = &AiravataProcessor::process_updateGridFTPDataMovementDetails; + processMap_["getGridFTPDataMovement"] = &AiravataProcessor::process_getGridFTPDataMovement; processMap_["changeJobSubmissionPriority"] = &AiravataProcessor::process_changeJobSubmissionPriority; processMap_["changeDataMovementPriority"] = &AiravataProcessor::process_changeDataMovementPriority; processMap_["changeJobSubmissionPriorities"] = &AiravataProcessor::process_changeJobSubmissionPriorities; @@ -12175,6 +13162,16 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->updateLocalSubmissionDetails(jobSubmissionInterfaceId, localSubmission); } + void getLocalJobSubmission( ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& _return, const std::string& jobSubmissionId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getLocalJobSubmission(_return, jobSubmissionId); + } + ifaces_[i]->getLocalJobSubmission(_return, jobSubmissionId); + return; + } + void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) { size_t sz = ifaces_.size(); size_t i = 0; @@ -12185,6 +13182,16 @@ class AiravataMultiface : virtual public AiravataIf { return; } + void getSSHJobSubmission( ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& _return, const std::string& jobSubmissionId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getSSHJobSubmission(_return, jobSubmissionId); + } + ifaces_[i]->getSSHJobSubmission(_return, jobSubmissionId); + return; + } + void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) { size_t sz = ifaces_.size(); size_t i = 0; @@ -12195,6 +13202,16 @@ class AiravataMultiface : virtual public AiravataIf { return; } + void getUnicoreJobSubmission( ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& _return, const std::string& jobSubmissionId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getUnicoreJobSubmission(_return, jobSubmissionId); + } + ifaces_[i]->getUnicoreJobSubmission(_return, jobSubmissionId); + return; + } + void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) { size_t sz = ifaces_.size(); size_t i = 0; @@ -12205,6 +13222,16 @@ class AiravataMultiface : virtual public AiravataIf { return; } + void getCloudJobSubmission( ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& _return, const std::string& jobSubmissionId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getCloudJobSubmission(_return, jobSubmissionId); + } + ifaces_[i]->getCloudJobSubmission(_return, jobSubmissionId); + return; + } + bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) { size_t sz = ifaces_.size(); size_t i = 0; @@ -12242,6 +13269,16 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->updateLocalDataMovementDetails(jobSubmissionInterfaceId, localDataMovement); } + void getLocalDataMovement( ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& _return, const std::string& dataMovementId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getLocalDataMovement(_return, dataMovementId); + } + ifaces_[i]->getLocalDataMovement(_return, dataMovementId); + return; + } + void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) { size_t sz = ifaces_.size(); size_t i = 0; @@ -12261,6 +13298,16 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->updateSCPDataMovementDetails(jobSubmissionInterfaceId, scpDataMovement); } + void getSCPDataMovement( ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& _return, const std::string& dataMovementId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getSCPDataMovement(_return, dataMovementId); + } + ifaces_[i]->getSCPDataMovement(_return, dataMovementId); + return; + } + void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) { size_t sz = ifaces_.size(); size_t i = 0; @@ -12280,6 +13327,16 @@ class AiravataMultiface : virtual public AiravataIf { return ifaces_[i]->updateGridFTPDataMovementDetails(jobSubmissionInterfaceId, gridFTPDataMovement); } + void getGridFTPDataMovement( ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& _return, const std::string& dataMovementId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getGridFTPDataMovement(_return, dataMovementId); + } + ifaces_[i]->getGridFTPDataMovement(_return, dataMovementId); + return; + } + bool changeJobSubmissionPriority(const std::string& jobSubmissionInterfaceId, const int32_t newPriorityOrder) { size_t sz = ifaces_.size(); size_t i = 0;
http://git-wip-us.apache.org/repos/asf/airavata/blob/47e82148/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 b2405ce..6b062f4 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 @@ -304,21 +304,41 @@ class AiravataHandler : virtual public AiravataIf { printf("updateLocalSubmissionDetails\n"); } + void getLocalJobSubmission( ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& _return, const std::string& jobSubmissionId) { + // Your implementation goes here + printf("getLocalJobSubmission\n"); + } + void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) { // Your implementation goes here printf("addSSHJobSubmissionDetails\n"); } + void getSSHJobSubmission( ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& _return, const std::string& jobSubmissionId) { + // Your implementation goes here + printf("getSSHJobSubmission\n"); + } + void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) { // Your implementation goes here printf("addUNICOREJobSubmissionDetails\n"); } + void getUnicoreJobSubmission( ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& _return, const std::string& jobSubmissionId) { + // Your implementation goes here + printf("getUnicoreJobSubmission\n"); + } + void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) { // Your implementation goes here printf("addCloudJobSubmissionDetails\n"); } + void getCloudJobSubmission( ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& _return, const std::string& jobSubmissionId) { + // Your implementation goes here + printf("getCloudJobSubmission\n"); + } + bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) { // Your implementation goes here printf("updateSSHJobSubmissionDetails\n"); @@ -339,6 +359,11 @@ class AiravataHandler : virtual public AiravataIf { printf("updateLocalDataMovementDetails\n"); } + void getLocalDataMovement( ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& _return, const std::string& dataMovementId) { + // Your implementation goes here + printf("getLocalDataMovement\n"); + } + void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) { // Your implementation goes here printf("addSCPDataMovementDetails\n"); @@ -349,6 +374,11 @@ class AiravataHandler : virtual public AiravataIf { printf("updateSCPDataMovementDetails\n"); } + void getSCPDataMovement( ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& _return, const std::string& dataMovementId) { + // Your implementation goes here + printf("getSCPDataMovement\n"); + } + void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) { // Your implementation goes here printf("addGridFTPDataMovementDetails\n"); @@ -359,6 +389,11 @@ class AiravataHandler : virtual public AiravataIf { printf("updateGridFTPDataMovementDetails\n"); } + void getGridFTPDataMovement( ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& _return, const std::string& dataMovementId) { + // Your implementation goes here + printf("getGridFTPDataMovement\n"); + } + bool changeJobSubmissionPriority(const std::string& jobSubmissionInterfaceId, const int32_t newPriorityOrder) { // Your implementation goes here printf("changeJobSubmissionPriority\n");
