| /** |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| /** |
| * Autogenerated by Thrift Compiler (0.9.2) |
| * |
| * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
| * @generated |
| */ |
| #ifndef task_model_TYPES_H |
| #define task_model_TYPES_H |
| |
| #include <iosfwd> |
| |
| #include <thrift/Thrift.h> |
| #include <thrift/TApplicationException.h> |
| #include <thrift/protocol/TProtocol.h> |
| #include <thrift/transport/TTransport.h> |
| |
| #include <thrift/cxxfunctional.h> |
| #include "airavata_commons_types.h" |
| #include "status_models_types.h" |
| #include "compute_resource_model_types.h" |
| #include "application_io_models_types.h" |
| #include "job_model_types.h" |
| |
| |
| namespace apache { namespace airavata { namespace model { namespace task { |
| |
| struct TaskTypes { |
| enum type { |
| ENV_SETUP = 0, |
| DATA_STAGING = 1, |
| JOB_SUBMISSION = 2, |
| ENV_CLEANUP = 3, |
| MONITORING = 4 |
| }; |
| }; |
| |
| extern const std::map<int, const char*> _TaskTypes_VALUES_TO_NAMES; |
| |
| struct DataStageType { |
| enum type { |
| INPUT = 0, |
| OUPUT = 1 |
| }; |
| }; |
| |
| extern const std::map<int, const char*> _DataStageType_VALUES_TO_NAMES; |
| |
| class TaskModel; |
| |
| class DataStagingTaskModel; |
| |
| class EnvironmentSetupTaskModel; |
| |
| class JobSubmissionTaskModel; |
| |
| class MonitorTaskModel; |
| |
| typedef struct _TaskModel__isset { |
| _TaskModel__isset() : taskDetail(false), subTaskModel(false), taskError(false), jobs(false) {} |
| bool taskDetail :1; |
| bool subTaskModel :1; |
| bool taskError :1; |
| bool jobs :1; |
| } _TaskModel__isset; |
| |
| class TaskModel { |
| public: |
| |
| static const char* ascii_fingerprint; // = "BA52131C9C867CBF7281F29EDD7DDB6F"; |
| static const uint8_t binary_fingerprint[16]; // = {0xBA,0x52,0x13,0x1C,0x9C,0x86,0x7C,0xBF,0x72,0x81,0xF2,0x9E,0xDD,0x7D,0xDB,0x6F}; |
| |
| TaskModel(const TaskModel&); |
| TaskModel& operator=(const TaskModel&); |
| TaskModel() : taskId("DO_NOT_SET_AT_CLIENTS"), taskType((TaskTypes::type)0), parentProcessId(), creationTime(0), lastUpdateTime(0), taskDetail(), subTaskModel() { |
| } |
| |
| virtual ~TaskModel() throw(); |
| std::string taskId; |
| TaskTypes::type taskType; |
| std::string parentProcessId; |
| int64_t creationTime; |
| int64_t lastUpdateTime; |
| ::apache::airavata::model::status::TaskStatus taskStatus; |
| std::string taskDetail; |
| std::string subTaskModel; |
| ::apache::airavata::model::commons::ErrorModel taskError; |
| std::vector< ::apache::airavata::model::job::JobModel> jobs; |
| |
| _TaskModel__isset __isset; |
| |
| void __set_taskId(const std::string& val); |
| |
| void __set_taskType(const TaskTypes::type val); |
| |
| void __set_parentProcessId(const std::string& val); |
| |
| void __set_creationTime(const int64_t val); |
| |
| void __set_lastUpdateTime(const int64_t val); |
| |
| void __set_taskStatus(const ::apache::airavata::model::status::TaskStatus& val); |
| |
| void __set_taskDetail(const std::string& val); |
| |
| void __set_subTaskModel(const std::string& val); |
| |
| void __set_taskError(const ::apache::airavata::model::commons::ErrorModel& val); |
| |
| void __set_jobs(const std::vector< ::apache::airavata::model::job::JobModel> & val); |
| |
| bool operator == (const TaskModel & rhs) const |
| { |
| if (!(taskId == rhs.taskId)) |
| return false; |
| if (!(taskType == rhs.taskType)) |
| return false; |
| if (!(parentProcessId == rhs.parentProcessId)) |
| return false; |
| if (!(creationTime == rhs.creationTime)) |
| return false; |
| if (!(lastUpdateTime == rhs.lastUpdateTime)) |
| return false; |
| if (!(taskStatus == rhs.taskStatus)) |
| return false; |
| if (__isset.taskDetail != rhs.__isset.taskDetail) |
| return false; |
| else if (__isset.taskDetail && !(taskDetail == rhs.taskDetail)) |
| return false; |
| if (__isset.subTaskModel != rhs.__isset.subTaskModel) |
| return false; |
| else if (__isset.subTaskModel && !(subTaskModel == rhs.subTaskModel)) |
| return false; |
| if (__isset.taskError != rhs.__isset.taskError) |
| return false; |
| else if (__isset.taskError && !(taskError == rhs.taskError)) |
| return false; |
| if (__isset.jobs != rhs.__isset.jobs) |
| return false; |
| else if (__isset.jobs && !(jobs == rhs.jobs)) |
| return false; |
| return true; |
| } |
| bool operator != (const TaskModel &rhs) const { |
| return !(*this == rhs); |
| } |
| |
| bool operator < (const TaskModel & ) const; |
| |
| uint32_t read(::apache::thrift::protocol::TProtocol* iprot); |
| uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; |
| |
| friend std::ostream& operator<<(std::ostream& out, const TaskModel& obj); |
| }; |
| |
| void swap(TaskModel &a, TaskModel &b); |
| |
| typedef struct _DataStagingTaskModel__isset { |
| _DataStagingTaskModel__isset() : transferStartTime(false), transferEndTime(false), transferRate(false), processInput(false), processOutput(false) {} |
| bool transferStartTime :1; |
| bool transferEndTime :1; |
| bool transferRate :1; |
| bool processInput :1; |
| bool processOutput :1; |
| } _DataStagingTaskModel__isset; |
| |
| class DataStagingTaskModel { |
| public: |
| |
| static const char* ascii_fingerprint; // = "ACF0A091382F299B453E77765150F8C9"; |
| static const uint8_t binary_fingerprint[16]; // = {0xAC,0xF0,0xA0,0x91,0x38,0x2F,0x29,0x9B,0x45,0x3E,0x77,0x76,0x51,0x50,0xF8,0xC9}; |
| |
| DataStagingTaskModel(const DataStagingTaskModel&); |
| DataStagingTaskModel& operator=(const DataStagingTaskModel&); |
| DataStagingTaskModel() : source(), destination(), type((DataStageType::type)0), transferStartTime(0), transferEndTime(0), transferRate() { |
| } |
| |
| virtual ~DataStagingTaskModel() throw(); |
| std::string source; |
| std::string destination; |
| DataStageType::type type; |
| int64_t transferStartTime; |
| int64_t transferEndTime; |
| std::string transferRate; |
| ::apache::airavata::model::application::io::InputDataObjectType processInput; |
| ::apache::airavata::model::application::io::OutputDataObjectType processOutput; |
| |
| _DataStagingTaskModel__isset __isset; |
| |
| void __set_source(const std::string& val); |
| |
| void __set_destination(const std::string& val); |
| |
| void __set_type(const DataStageType::type val); |
| |
| void __set_transferStartTime(const int64_t val); |
| |
| void __set_transferEndTime(const int64_t val); |
| |
| void __set_transferRate(const std::string& val); |
| |
| void __set_processInput(const ::apache::airavata::model::application::io::InputDataObjectType& val); |
| |
| void __set_processOutput(const ::apache::airavata::model::application::io::OutputDataObjectType& val); |
| |
| bool operator == (const DataStagingTaskModel & rhs) const |
| { |
| if (!(source == rhs.source)) |
| return false; |
| if (!(destination == rhs.destination)) |
| return false; |
| if (!(type == rhs.type)) |
| return false; |
| if (__isset.transferStartTime != rhs.__isset.transferStartTime) |
| return false; |
| else if (__isset.transferStartTime && !(transferStartTime == rhs.transferStartTime)) |
| return false; |
| if (__isset.transferEndTime != rhs.__isset.transferEndTime) |
| return false; |
| else if (__isset.transferEndTime && !(transferEndTime == rhs.transferEndTime)) |
| return false; |
| if (__isset.transferRate != rhs.__isset.transferRate) |
| return false; |
| else if (__isset.transferRate && !(transferRate == rhs.transferRate)) |
| return false; |
| if (__isset.processInput != rhs.__isset.processInput) |
| return false; |
| else if (__isset.processInput && !(processInput == rhs.processInput)) |
| return false; |
| if (__isset.processOutput != rhs.__isset.processOutput) |
| return false; |
| else if (__isset.processOutput && !(processOutput == rhs.processOutput)) |
| return false; |
| return true; |
| } |
| bool operator != (const DataStagingTaskModel &rhs) const { |
| return !(*this == rhs); |
| } |
| |
| bool operator < (const DataStagingTaskModel & ) const; |
| |
| uint32_t read(::apache::thrift::protocol::TProtocol* iprot); |
| uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; |
| |
| friend std::ostream& operator<<(std::ostream& out, const DataStagingTaskModel& obj); |
| }; |
| |
| void swap(DataStagingTaskModel &a, DataStagingTaskModel &b); |
| |
| |
| class EnvironmentSetupTaskModel { |
| public: |
| |
| static const char* ascii_fingerprint; // = "D6FD826D949221396F4FFC3ECCD3D192"; |
| static const uint8_t binary_fingerprint[16]; // = {0xD6,0xFD,0x82,0x6D,0x94,0x92,0x21,0x39,0x6F,0x4F,0xFC,0x3E,0xCC,0xD3,0xD1,0x92}; |
| |
| EnvironmentSetupTaskModel(const EnvironmentSetupTaskModel&); |
| EnvironmentSetupTaskModel& operator=(const EnvironmentSetupTaskModel&); |
| EnvironmentSetupTaskModel() : location(), protocol(( ::apache::airavata::model::appcatalog::computeresource::SecurityProtocol::type)0) { |
| } |
| |
| virtual ~EnvironmentSetupTaskModel() throw(); |
| std::string location; |
| ::apache::airavata::model::appcatalog::computeresource::SecurityProtocol::type protocol; |
| |
| void __set_location(const std::string& val); |
| |
| void __set_protocol(const ::apache::airavata::model::appcatalog::computeresource::SecurityProtocol::type val); |
| |
| bool operator == (const EnvironmentSetupTaskModel & rhs) const |
| { |
| if (!(location == rhs.location)) |
| return false; |
| if (!(protocol == rhs.protocol)) |
| return false; |
| return true; |
| } |
| bool operator != (const EnvironmentSetupTaskModel &rhs) const { |
| return !(*this == rhs); |
| } |
| |
| bool operator < (const EnvironmentSetupTaskModel & ) const; |
| |
| uint32_t read(::apache::thrift::protocol::TProtocol* iprot); |
| uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; |
| |
| friend std::ostream& operator<<(std::ostream& out, const EnvironmentSetupTaskModel& obj); |
| }; |
| |
| void swap(EnvironmentSetupTaskModel &a, EnvironmentSetupTaskModel &b); |
| |
| typedef struct _JobSubmissionTaskModel__isset { |
| _JobSubmissionTaskModel__isset() : wallTime(false) {} |
| bool wallTime :1; |
| } _JobSubmissionTaskModel__isset; |
| |
| class JobSubmissionTaskModel { |
| public: |
| |
| static const char* ascii_fingerprint; // = "AEF3E1D4E4ADDD8D31BD954A62F3809C"; |
| static const uint8_t binary_fingerprint[16]; // = {0xAE,0xF3,0xE1,0xD4,0xE4,0xAD,0xDD,0x8D,0x31,0xBD,0x95,0x4A,0x62,0xF3,0x80,0x9C}; |
| |
| JobSubmissionTaskModel(const JobSubmissionTaskModel&); |
| JobSubmissionTaskModel& operator=(const JobSubmissionTaskModel&); |
| JobSubmissionTaskModel() : jobSubmissionProtocol(( ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type)0), monitorMode(( ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type)0), wallTime(0) { |
| } |
| |
| virtual ~JobSubmissionTaskModel() throw(); |
| ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type jobSubmissionProtocol; |
| ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type monitorMode; |
| int32_t wallTime; |
| |
| _JobSubmissionTaskModel__isset __isset; |
| |
| void __set_jobSubmissionProtocol(const ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type val); |
| |
| void __set_monitorMode(const ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type val); |
| |
| void __set_wallTime(const int32_t val); |
| |
| bool operator == (const JobSubmissionTaskModel & rhs) const |
| { |
| if (!(jobSubmissionProtocol == rhs.jobSubmissionProtocol)) |
| return false; |
| if (!(monitorMode == rhs.monitorMode)) |
| return false; |
| if (__isset.wallTime != rhs.__isset.wallTime) |
| return false; |
| else if (__isset.wallTime && !(wallTime == rhs.wallTime)) |
| return false; |
| return true; |
| } |
| bool operator != (const JobSubmissionTaskModel &rhs) const { |
| return !(*this == rhs); |
| } |
| |
| bool operator < (const JobSubmissionTaskModel & ) const; |
| |
| uint32_t read(::apache::thrift::protocol::TProtocol* iprot); |
| uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; |
| |
| friend std::ostream& operator<<(std::ostream& out, const JobSubmissionTaskModel& obj); |
| }; |
| |
| void swap(JobSubmissionTaskModel &a, JobSubmissionTaskModel &b); |
| |
| |
| class MonitorTaskModel { |
| public: |
| |
| static const char* ascii_fingerprint; // = "8BBB3D0C3B370CB38F2D1340BB79F0AA"; |
| static const uint8_t binary_fingerprint[16]; // = {0x8B,0xBB,0x3D,0x0C,0x3B,0x37,0x0C,0xB3,0x8F,0x2D,0x13,0x40,0xBB,0x79,0xF0,0xAA}; |
| |
| MonitorTaskModel(const MonitorTaskModel&); |
| MonitorTaskModel& operator=(const MonitorTaskModel&); |
| MonitorTaskModel() : monitorMode(( ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type)0) { |
| } |
| |
| virtual ~MonitorTaskModel() throw(); |
| ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type monitorMode; |
| |
| void __set_monitorMode(const ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type val); |
| |
| bool operator == (const MonitorTaskModel & rhs) const |
| { |
| if (!(monitorMode == rhs.monitorMode)) |
| return false; |
| return true; |
| } |
| bool operator != (const MonitorTaskModel &rhs) const { |
| return !(*this == rhs); |
| } |
| |
| bool operator < (const MonitorTaskModel & ) const; |
| |
| uint32_t read(::apache::thrift::protocol::TProtocol* iprot); |
| uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; |
| |
| friend std::ostream& operator<<(std::ostream& out, const MonitorTaskModel& obj); |
| }; |
| |
| void swap(MonitorTaskModel &a, MonitorTaskModel &b); |
| |
| }}}} // namespace |
| |
| #endif |