http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.h deleted file mode 100644 index f8045af..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.h +++ /dev/null @@ -1,424 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef status_models_TYPES_H -#define status_models_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> - - -namespace apache { namespace airavata { namespace model { namespace status { - -struct ExperimentState { - enum type { - CREATED = 0, - VALIDATED = 1, - SCHEDULED = 2, - LAUNCHED = 3, - EXECUTING = 4, - CANCELING = 5, - CANCELED = 6, - COMPLETED = 7, - FAILED = 8 - }; -}; - -extern const std::map<int, const char*> _ExperimentState_VALUES_TO_NAMES; - -struct TaskState { - enum type { - CREATED = 0, - EXECUTING = 1, - COMPLETED = 2, - FAILED = 3, - CANCELED = 4 - }; -}; - -extern const std::map<int, const char*> _TaskState_VALUES_TO_NAMES; - -struct ProcessState { - enum type { - CREATED = 0, - VALIDATED = 1, - STARTED = 2, - PRE_PROCESSING = 3, - CONFIGURING_WORKSPACE = 4, - INPUT_DATA_STAGING = 5, - EXECUTING = 6, - MONITORING = 7, - OUTPUT_DATA_STAGING = 8, - POST_PROCESSING = 9, - COMPLETED = 10, - FAILED = 11, - CANCELLING = 12, - CANCELED = 13 - }; -}; - -extern const std::map<int, const char*> _ProcessState_VALUES_TO_NAMES; - -struct JobState { - enum type { - SUBMITTED = 0, - QUEUED = 1, - ACTIVE = 2, - COMPLETE = 3, - CANCELED = 4, - FAILED = 5, - SUSPENDED = 6, - UNKNOWN = 7 - }; -}; - -extern const std::map<int, const char*> _JobState_VALUES_TO_NAMES; - -class ExperimentStatus; - -class ProcessStatus; - -class TaskStatus; - -class JobStatus; - -class QueueStatusModel; - -typedef struct _ExperimentStatus__isset { - _ExperimentStatus__isset() : timeOfStateChange(false), reason(false) {} - bool timeOfStateChange :1; - bool reason :1; -} _ExperimentStatus__isset; - -class ExperimentStatus { - public: - - ExperimentStatus(const ExperimentStatus&); - ExperimentStatus& operator=(const ExperimentStatus&); - ExperimentStatus() : state((ExperimentState::type)0), timeOfStateChange(0), reason() { - } - - virtual ~ExperimentStatus() throw(); - ExperimentState::type state; - int64_t timeOfStateChange; - std::string reason; - - _ExperimentStatus__isset __isset; - - void __set_state(const ExperimentState::type val); - - void __set_timeOfStateChange(const int64_t val); - - void __set_reason(const std::string& val); - - bool operator == (const ExperimentStatus & rhs) const - { - if (!(state == rhs.state)) - return false; - if (__isset.timeOfStateChange != rhs.__isset.timeOfStateChange) - return false; - else if (__isset.timeOfStateChange && !(timeOfStateChange == rhs.timeOfStateChange)) - return false; - if (__isset.reason != rhs.__isset.reason) - return false; - else if (__isset.reason && !(reason == rhs.reason)) - return false; - return true; - } - bool operator != (const ExperimentStatus &rhs) const { - return !(*this == rhs); - } - - bool operator < (const ExperimentStatus & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(ExperimentStatus &a, ExperimentStatus &b); - -inline std::ostream& operator<<(std::ostream& out, const ExperimentStatus& obj) -{ - obj.printTo(out); - return out; -} - -typedef struct _ProcessStatus__isset { - _ProcessStatus__isset() : timeOfStateChange(false), reason(false) {} - bool timeOfStateChange :1; - bool reason :1; -} _ProcessStatus__isset; - -class ProcessStatus { - public: - - ProcessStatus(const ProcessStatus&); - ProcessStatus& operator=(const ProcessStatus&); - ProcessStatus() : state((ProcessState::type)0), timeOfStateChange(0), reason() { - } - - virtual ~ProcessStatus() throw(); - ProcessState::type state; - int64_t timeOfStateChange; - std::string reason; - - _ProcessStatus__isset __isset; - - void __set_state(const ProcessState::type val); - - void __set_timeOfStateChange(const int64_t val); - - void __set_reason(const std::string& val); - - bool operator == (const ProcessStatus & rhs) const - { - if (!(state == rhs.state)) - return false; - if (__isset.timeOfStateChange != rhs.__isset.timeOfStateChange) - return false; - else if (__isset.timeOfStateChange && !(timeOfStateChange == rhs.timeOfStateChange)) - return false; - if (__isset.reason != rhs.__isset.reason) - return false; - else if (__isset.reason && !(reason == rhs.reason)) - return false; - return true; - } - bool operator != (const ProcessStatus &rhs) const { - return !(*this == rhs); - } - - bool operator < (const ProcessStatus & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(ProcessStatus &a, ProcessStatus &b); - -inline std::ostream& operator<<(std::ostream& out, const ProcessStatus& obj) -{ - obj.printTo(out); - return out; -} - -typedef struct _TaskStatus__isset { - _TaskStatus__isset() : timeOfStateChange(false), reason(false) {} - bool timeOfStateChange :1; - bool reason :1; -} _TaskStatus__isset; - -class TaskStatus { - public: - - TaskStatus(const TaskStatus&); - TaskStatus& operator=(const TaskStatus&); - TaskStatus() : state((TaskState::type)0), timeOfStateChange(0), reason() { - } - - virtual ~TaskStatus() throw(); - TaskState::type state; - int64_t timeOfStateChange; - std::string reason; - - _TaskStatus__isset __isset; - - void __set_state(const TaskState::type val); - - void __set_timeOfStateChange(const int64_t val); - - void __set_reason(const std::string& val); - - bool operator == (const TaskStatus & rhs) const - { - if (!(state == rhs.state)) - return false; - if (__isset.timeOfStateChange != rhs.__isset.timeOfStateChange) - return false; - else if (__isset.timeOfStateChange && !(timeOfStateChange == rhs.timeOfStateChange)) - return false; - if (__isset.reason != rhs.__isset.reason) - return false; - else if (__isset.reason && !(reason == rhs.reason)) - return false; - return true; - } - bool operator != (const TaskStatus &rhs) const { - return !(*this == rhs); - } - - bool operator < (const TaskStatus & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(TaskStatus &a, TaskStatus &b); - -inline std::ostream& operator<<(std::ostream& out, const TaskStatus& obj) -{ - obj.printTo(out); - return out; -} - -typedef struct _JobStatus__isset { - _JobStatus__isset() : timeOfStateChange(false), reason(false) {} - bool timeOfStateChange :1; - bool reason :1; -} _JobStatus__isset; - -class JobStatus { - public: - - JobStatus(const JobStatus&); - JobStatus& operator=(const JobStatus&); - JobStatus() : jobState((JobState::type)0), timeOfStateChange(0), reason() { - } - - virtual ~JobStatus() throw(); - JobState::type jobState; - int64_t timeOfStateChange; - std::string reason; - - _JobStatus__isset __isset; - - void __set_jobState(const JobState::type val); - - void __set_timeOfStateChange(const int64_t val); - - void __set_reason(const std::string& val); - - bool operator == (const JobStatus & rhs) const - { - if (!(jobState == rhs.jobState)) - return false; - if (__isset.timeOfStateChange != rhs.__isset.timeOfStateChange) - return false; - else if (__isset.timeOfStateChange && !(timeOfStateChange == rhs.timeOfStateChange)) - return false; - if (__isset.reason != rhs.__isset.reason) - return false; - else if (__isset.reason && !(reason == rhs.reason)) - return false; - return true; - } - bool operator != (const JobStatus &rhs) const { - return !(*this == rhs); - } - - bool operator < (const JobStatus & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(JobStatus &a, JobStatus &b); - -inline std::ostream& operator<<(std::ostream& out, const JobStatus& obj) -{ - obj.printTo(out); - return out; -} - - -class QueueStatusModel { - public: - - QueueStatusModel(const QueueStatusModel&); - QueueStatusModel& operator=(const QueueStatusModel&); - QueueStatusModel() : hostName(), queueName(), queueUp(0), runningJobs(0), queuedJobs(0), time(0) { - } - - virtual ~QueueStatusModel() throw(); - std::string hostName; - std::string queueName; - bool queueUp; - int32_t runningJobs; - int32_t queuedJobs; - int64_t time; - - void __set_hostName(const std::string& val); - - void __set_queueName(const std::string& val); - - void __set_queueUp(const bool val); - - void __set_runningJobs(const int32_t val); - - void __set_queuedJobs(const int32_t val); - - void __set_time(const int64_t val); - - bool operator == (const QueueStatusModel & rhs) const - { - if (!(hostName == rhs.hostName)) - return false; - if (!(queueName == rhs.queueName)) - return false; - if (!(queueUp == rhs.queueUp)) - return false; - if (!(runningJobs == rhs.runningJobs)) - return false; - if (!(queuedJobs == rhs.queuedJobs)) - return false; - if (!(time == rhs.time)) - return false; - return true; - } - bool operator != (const QueueStatusModel &rhs) const { - return !(*this == rhs); - } - - bool operator < (const QueueStatusModel & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(QueueStatusModel &a, QueueStatusModel &b); - -inline std::ostream& operator<<(std::ostream& out, const QueueStatusModel& obj) -{ - obj.printTo(out); - return out; -} - -}}}} // namespace - -#endif
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.cpp deleted file mode 100644 index 41397a0..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.cpp +++ /dev/null @@ -1,34 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "storage_resource_model_constants.h" - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace storageresource { - -const storage_resource_modelConstants g_storage_resource_model_constants; - -storage_resource_modelConstants::storage_resource_modelConstants() { -} - -}}}}} // namespace - http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.h deleted file mode 100644 index d31946c..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_constants.h +++ /dev/null @@ -1,41 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef storage_resource_model_CONSTANTS_H -#define storage_resource_model_CONSTANTS_H - -#include "storage_resource_model_types.h" - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace storageresource { - -class storage_resource_modelConstants { - public: - storage_resource_modelConstants(); - -}; - -extern const storage_resource_modelConstants g_storage_resource_model_constants; - -}}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.cpp deleted file mode 100644 index 62c4508..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.cpp +++ /dev/null @@ -1,231 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "storage_resource_model_types.h" - -#include <algorithm> -#include <ostream> - -#include <thrift/TToString.h> - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace storageresource { - - -StorageResourceDescription::~StorageResourceDescription() throw() { -} - - -void StorageResourceDescription::__set_storageResourceId(const std::string& val) { - this->storageResourceId = val; -} - -void StorageResourceDescription::__set_hostName(const std::string& val) { - this->hostName = val; -} - -void StorageResourceDescription::__set_storageResourceDescription(const std::string& val) { - this->storageResourceDescription = val; -__isset.storageResourceDescription = true; -} - -void StorageResourceDescription::__set_enabled(const bool val) { - this->enabled = val; -__isset.enabled = true; -} - -void StorageResourceDescription::__set_dataMovementInterfaces(const std::vector< ::apache::airavata::model::data::movement::DataMovementInterface> & val) { - this->dataMovementInterfaces = val; -__isset.dataMovementInterfaces = true; -} - -uint32_t StorageResourceDescription::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_storageResourceId = false; - bool isset_hostName = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->storageResourceId); - isset_storageResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->hostName); - isset_hostName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->storageResourceDescription); - this->__isset.storageResourceDescription = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->enabled); - this->__isset.enabled = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->dataMovementInterfaces.clear(); - uint32_t _size0; - ::apache::thrift::protocol::TType _etype3; - xfer += iprot->readListBegin(_etype3, _size0); - this->dataMovementInterfaces.resize(_size0); - uint32_t _i4; - for (_i4 = 0; _i4 < _size0; ++_i4) - { - xfer += this->dataMovementInterfaces[_i4].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.dataMovementInterfaces = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_storageResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_hostName) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t StorageResourceDescription::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("StorageResourceDescription"); - - xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->storageResourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("hostName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->hostName); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.storageResourceDescription) { - xfer += oprot->writeFieldBegin("storageResourceDescription", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->storageResourceDescription); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.enabled) { - xfer += oprot->writeFieldBegin("enabled", ::apache::thrift::protocol::T_BOOL, 4); - xfer += oprot->writeBool(this->enabled); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.dataMovementInterfaces) { - xfer += oprot->writeFieldBegin("dataMovementInterfaces", ::apache::thrift::protocol::T_LIST, 5); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->dataMovementInterfaces.size())); - std::vector< ::apache::airavata::model::data::movement::DataMovementInterface> ::const_iterator _iter5; - for (_iter5 = this->dataMovementInterfaces.begin(); _iter5 != this->dataMovementInterfaces.end(); ++_iter5) - { - xfer += (*_iter5).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(StorageResourceDescription &a, StorageResourceDescription &b) { - using ::std::swap; - swap(a.storageResourceId, b.storageResourceId); - swap(a.hostName, b.hostName); - swap(a.storageResourceDescription, b.storageResourceDescription); - swap(a.enabled, b.enabled); - swap(a.dataMovementInterfaces, b.dataMovementInterfaces); - swap(a.__isset, b.__isset); -} - -StorageResourceDescription::StorageResourceDescription(const StorageResourceDescription& other6) { - storageResourceId = other6.storageResourceId; - hostName = other6.hostName; - storageResourceDescription = other6.storageResourceDescription; - enabled = other6.enabled; - dataMovementInterfaces = other6.dataMovementInterfaces; - __isset = other6.__isset; -} -StorageResourceDescription& StorageResourceDescription::operator=(const StorageResourceDescription& other7) { - storageResourceId = other7.storageResourceId; - hostName = other7.hostName; - storageResourceDescription = other7.storageResourceDescription; - enabled = other7.enabled; - dataMovementInterfaces = other7.dataMovementInterfaces; - __isset = other7.__isset; - return *this; -} -void StorageResourceDescription::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "StorageResourceDescription("; - out << "storageResourceId=" << to_string(storageResourceId); - out << ", " << "hostName=" << to_string(hostName); - out << ", " << "storageResourceDescription="; (__isset.storageResourceDescription ? (out << to_string(storageResourceDescription)) : (out << "<null>")); - out << ", " << "enabled="; (__isset.enabled ? (out << to_string(enabled)) : (out << "<null>")); - out << ", " << "dataMovementInterfaces="; (__isset.dataMovementInterfaces ? (out << to_string(dataMovementInterfaces)) : (out << "<null>")); - out << ")"; -} - -}}}}} // namespace http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.h deleted file mode 100644 index 57cbc86..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/storage_resource_model_types.h +++ /dev/null @@ -1,119 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef storage_resource_model_TYPES_H -#define storage_resource_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 "data_movement_models_types.h" - - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace storageresource { - -class StorageResourceDescription; - -typedef struct _StorageResourceDescription__isset { - _StorageResourceDescription__isset() : storageResourceDescription(false), enabled(false), dataMovementInterfaces(false) {} - bool storageResourceDescription :1; - bool enabled :1; - bool dataMovementInterfaces :1; -} _StorageResourceDescription__isset; - -class StorageResourceDescription { - public: - - StorageResourceDescription(const StorageResourceDescription&); - StorageResourceDescription& operator=(const StorageResourceDescription&); - StorageResourceDescription() : storageResourceId("DO_NOT_SET_AT_CLIENTS"), hostName(), storageResourceDescription(), enabled(0) { - } - - virtual ~StorageResourceDescription() throw(); - std::string storageResourceId; - std::string hostName; - std::string storageResourceDescription; - bool enabled; - std::vector< ::apache::airavata::model::data::movement::DataMovementInterface> dataMovementInterfaces; - - _StorageResourceDescription__isset __isset; - - void __set_storageResourceId(const std::string& val); - - void __set_hostName(const std::string& val); - - void __set_storageResourceDescription(const std::string& val); - - void __set_enabled(const bool val); - - void __set_dataMovementInterfaces(const std::vector< ::apache::airavata::model::data::movement::DataMovementInterface> & val); - - bool operator == (const StorageResourceDescription & rhs) const - { - if (!(storageResourceId == rhs.storageResourceId)) - return false; - if (!(hostName == rhs.hostName)) - return false; - if (__isset.storageResourceDescription != rhs.__isset.storageResourceDescription) - return false; - else if (__isset.storageResourceDescription && !(storageResourceDescription == rhs.storageResourceDescription)) - return false; - if (__isset.enabled != rhs.__isset.enabled) - return false; - else if (__isset.enabled && !(enabled == rhs.enabled)) - return false; - if (__isset.dataMovementInterfaces != rhs.__isset.dataMovementInterfaces) - return false; - else if (__isset.dataMovementInterfaces && !(dataMovementInterfaces == rhs.dataMovementInterfaces)) - return false; - return true; - } - bool operator != (const StorageResourceDescription &rhs) const { - return !(*this == rhs); - } - - bool operator < (const StorageResourceDescription & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(StorageResourceDescription &a, StorageResourceDescription &b); - -inline std::ostream& operator<<(std::ostream& out, const StorageResourceDescription& obj) -{ - obj.printTo(out); - return out; -} - -}}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.cpp deleted file mode 100644 index 8446c0e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.cpp +++ /dev/null @@ -1,34 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "task_model_constants.h" - -namespace apache { namespace airavata { namespace model { namespace task { - -const task_modelConstants g_task_model_constants; - -task_modelConstants::task_modelConstants() { -} - -}}}} // namespace - http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.h deleted file mode 100644 index b0bd423..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_constants.h +++ /dev/null @@ -1,41 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef task_model_CONSTANTS_H -#define task_model_CONSTANTS_H - -#include "task_model_types.h" - -namespace apache { namespace airavata { namespace model { namespace task { - -class task_modelConstants { - public: - task_modelConstants(); - -}; - -extern const task_modelConstants g_task_model_constants; - -}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.cpp deleted file mode 100644 index 337f2d5..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.cpp +++ /dev/null @@ -1,1001 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "task_model_types.h" - -#include <algorithm> -#include <ostream> - -#include <thrift/TToString.h> - -namespace apache { namespace airavata { namespace model { namespace task { - -int _kTaskTypesValues[] = { - TaskTypes::ENV_SETUP, - TaskTypes::DATA_STAGING, - TaskTypes::JOB_SUBMISSION, - TaskTypes::ENV_CLEANUP, - TaskTypes::MONITORING, - TaskTypes::OUTPUT_FETCHING -}; -const char* _kTaskTypesNames[] = { - "ENV_SETUP", - "DATA_STAGING", - "JOB_SUBMISSION", - "ENV_CLEANUP", - "MONITORING", - "OUTPUT_FETCHING" -}; -const std::map<int, const char*> _TaskTypes_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(6, _kTaskTypesValues, _kTaskTypesNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); - -int _kDataStageTypeValues[] = { - DataStageType::INPUT, - DataStageType::OUPUT, - DataStageType::ARCHIVE_OUTPUT -}; -const char* _kDataStageTypeNames[] = { - "INPUT", - "OUPUT", - "ARCHIVE_OUTPUT" -}; -const std::map<int, const char*> _DataStageType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3, _kDataStageTypeValues, _kDataStageTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); - - -TaskModel::~TaskModel() throw() { -} - - -void TaskModel::__set_taskId(const std::string& val) { - this->taskId = val; -} - -void TaskModel::__set_taskType(const TaskTypes::type val) { - this->taskType = val; -} - -void TaskModel::__set_parentProcessId(const std::string& val) { - this->parentProcessId = val; -} - -void TaskModel::__set_creationTime(const int64_t val) { - this->creationTime = val; -} - -void TaskModel::__set_lastUpdateTime(const int64_t val) { - this->lastUpdateTime = val; -} - -void TaskModel::__set_taskStatuses(const std::vector< ::apache::airavata::model::status::TaskStatus> & val) { - this->taskStatuses = val; -} - -void TaskModel::__set_taskDetail(const std::string& val) { - this->taskDetail = val; -__isset.taskDetail = true; -} - -void TaskModel::__set_subTaskModel(const std::string& val) { - this->subTaskModel = val; -__isset.subTaskModel = true; -} - -void TaskModel::__set_taskErrors(const std::vector< ::apache::airavata::model::commons::ErrorModel> & val) { - this->taskErrors = val; -__isset.taskErrors = true; -} - -void TaskModel::__set_jobs(const std::vector< ::apache::airavata::model::job::JobModel> & val) { - this->jobs = val; -__isset.jobs = true; -} - -uint32_t TaskModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_taskId = false; - bool isset_taskType = false; - bool isset_parentProcessId = false; - bool isset_creationTime = false; - bool isset_lastUpdateTime = false; - bool isset_taskStatuses = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->taskId); - isset_taskId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast0; - xfer += iprot->readI32(ecast0); - this->taskType = (TaskTypes::type)ecast0; - isset_taskType = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->parentProcessId); - isset_parentProcessId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->creationTime); - isset_creationTime = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->lastUpdateTime); - isset_lastUpdateTime = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 6: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->taskStatuses.clear(); - uint32_t _size1; - ::apache::thrift::protocol::TType _etype4; - xfer += iprot->readListBegin(_etype4, _size1); - this->taskStatuses.resize(_size1); - uint32_t _i5; - for (_i5 = 0; _i5 < _size1; ++_i5) - { - xfer += this->taskStatuses[_i5].read(iprot); - } - xfer += iprot->readListEnd(); - } - isset_taskStatuses = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 7: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->taskDetail); - this->__isset.taskDetail = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 8: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readBinary(this->subTaskModel); - this->__isset.subTaskModel = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 9: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->taskErrors.clear(); - uint32_t _size6; - ::apache::thrift::protocol::TType _etype9; - xfer += iprot->readListBegin(_etype9, _size6); - this->taskErrors.resize(_size6); - uint32_t _i10; - for (_i10 = 0; _i10 < _size6; ++_i10) - { - xfer += this->taskErrors[_i10].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.taskErrors = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 10: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->jobs.clear(); - uint32_t _size11; - ::apache::thrift::protocol::TType _etype14; - xfer += iprot->readListBegin(_etype14, _size11); - this->jobs.resize(_size11); - uint32_t _i15; - for (_i15 = 0; _i15 < _size11; ++_i15) - { - xfer += this->jobs[_i15].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.jobs = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_taskId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_taskType) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_parentProcessId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_creationTime) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_lastUpdateTime) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_taskStatuses) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t TaskModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("TaskModel"); - - xfer += oprot->writeFieldBegin("taskId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->taskId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("taskType", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((int32_t)this->taskType); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("parentProcessId", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->parentProcessId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("creationTime", ::apache::thrift::protocol::T_I64, 4); - xfer += oprot->writeI64(this->creationTime); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("lastUpdateTime", ::apache::thrift::protocol::T_I64, 5); - xfer += oprot->writeI64(this->lastUpdateTime); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("taskStatuses", ::apache::thrift::protocol::T_LIST, 6); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->taskStatuses.size())); - std::vector< ::apache::airavata::model::status::TaskStatus> ::const_iterator _iter16; - for (_iter16 = this->taskStatuses.begin(); _iter16 != this->taskStatuses.end(); ++_iter16) - { - xfer += (*_iter16).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - if (this->__isset.taskDetail) { - xfer += oprot->writeFieldBegin("taskDetail", ::apache::thrift::protocol::T_STRING, 7); - xfer += oprot->writeString(this->taskDetail); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.subTaskModel) { - xfer += oprot->writeFieldBegin("subTaskModel", ::apache::thrift::protocol::T_STRING, 8); - xfer += oprot->writeBinary(this->subTaskModel); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.taskErrors) { - xfer += oprot->writeFieldBegin("taskErrors", ::apache::thrift::protocol::T_LIST, 9); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->taskErrors.size())); - std::vector< ::apache::airavata::model::commons::ErrorModel> ::const_iterator _iter17; - for (_iter17 = this->taskErrors.begin(); _iter17 != this->taskErrors.end(); ++_iter17) - { - xfer += (*_iter17).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.jobs) { - xfer += oprot->writeFieldBegin("jobs", ::apache::thrift::protocol::T_LIST, 10); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->jobs.size())); - std::vector< ::apache::airavata::model::job::JobModel> ::const_iterator _iter18; - for (_iter18 = this->jobs.begin(); _iter18 != this->jobs.end(); ++_iter18) - { - xfer += (*_iter18).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(TaskModel &a, TaskModel &b) { - using ::std::swap; - swap(a.taskId, b.taskId); - swap(a.taskType, b.taskType); - swap(a.parentProcessId, b.parentProcessId); - swap(a.creationTime, b.creationTime); - swap(a.lastUpdateTime, b.lastUpdateTime); - swap(a.taskStatuses, b.taskStatuses); - swap(a.taskDetail, b.taskDetail); - swap(a.subTaskModel, b.subTaskModel); - swap(a.taskErrors, b.taskErrors); - swap(a.jobs, b.jobs); - swap(a.__isset, b.__isset); -} - -TaskModel::TaskModel(const TaskModel& other19) { - taskId = other19.taskId; - taskType = other19.taskType; - parentProcessId = other19.parentProcessId; - creationTime = other19.creationTime; - lastUpdateTime = other19.lastUpdateTime; - taskStatuses = other19.taskStatuses; - taskDetail = other19.taskDetail; - subTaskModel = other19.subTaskModel; - taskErrors = other19.taskErrors; - jobs = other19.jobs; - __isset = other19.__isset; -} -TaskModel& TaskModel::operator=(const TaskModel& other20) { - taskId = other20.taskId; - taskType = other20.taskType; - parentProcessId = other20.parentProcessId; - creationTime = other20.creationTime; - lastUpdateTime = other20.lastUpdateTime; - taskStatuses = other20.taskStatuses; - taskDetail = other20.taskDetail; - subTaskModel = other20.subTaskModel; - taskErrors = other20.taskErrors; - jobs = other20.jobs; - __isset = other20.__isset; - return *this; -} -void TaskModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "TaskModel("; - out << "taskId=" << to_string(taskId); - out << ", " << "taskType=" << to_string(taskType); - out << ", " << "parentProcessId=" << to_string(parentProcessId); - out << ", " << "creationTime=" << to_string(creationTime); - out << ", " << "lastUpdateTime=" << to_string(lastUpdateTime); - out << ", " << "taskStatuses=" << to_string(taskStatuses); - out << ", " << "taskDetail="; (__isset.taskDetail ? (out << to_string(taskDetail)) : (out << "<null>")); - out << ", " << "subTaskModel="; (__isset.subTaskModel ? (out << to_string(subTaskModel)) : (out << "<null>")); - out << ", " << "taskErrors="; (__isset.taskErrors ? (out << to_string(taskErrors)) : (out << "<null>")); - out << ", " << "jobs="; (__isset.jobs ? (out << to_string(jobs)) : (out << "<null>")); - out << ")"; -} - - -DataStagingTaskModel::~DataStagingTaskModel() throw() { -} - - -void DataStagingTaskModel::__set_source(const std::string& val) { - this->source = val; -} - -void DataStagingTaskModel::__set_destination(const std::string& val) { - this->destination = val; -} - -void DataStagingTaskModel::__set_type(const DataStageType::type val) { - this->type = val; -} - -void DataStagingTaskModel::__set_transferStartTime(const int64_t val) { - this->transferStartTime = val; -__isset.transferStartTime = true; -} - -void DataStagingTaskModel::__set_transferEndTime(const int64_t val) { - this->transferEndTime = val; -__isset.transferEndTime = true; -} - -void DataStagingTaskModel::__set_transferRate(const std::string& val) { - this->transferRate = val; -__isset.transferRate = true; -} - -void DataStagingTaskModel::__set_processInput(const ::apache::airavata::model::application::io::InputDataObjectType& val) { - this->processInput = val; -__isset.processInput = true; -} - -void DataStagingTaskModel::__set_processOutput(const ::apache::airavata::model::application::io::OutputDataObjectType& val) { - this->processOutput = val; -__isset.processOutput = true; -} - -uint32_t DataStagingTaskModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_source = false; - bool isset_destination = false; - bool isset_type = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->source); - isset_source = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->destination); - isset_destination = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast21; - xfer += iprot->readI32(ecast21); - this->type = (DataStageType::type)ecast21; - isset_type = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->transferStartTime); - this->__isset.transferStartTime = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->transferEndTime); - this->__isset.transferEndTime = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 6: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->transferRate); - this->__isset.transferRate = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 7: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->processInput.read(iprot); - this->__isset.processInput = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 8: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->processOutput.read(iprot); - this->__isset.processOutput = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_source) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_destination) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_type) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t DataStagingTaskModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("DataStagingTaskModel"); - - xfer += oprot->writeFieldBegin("source", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->source); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("destination", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->destination); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("type", ::apache::thrift::protocol::T_I32, 3); - xfer += oprot->writeI32((int32_t)this->type); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.transferStartTime) { - xfer += oprot->writeFieldBegin("transferStartTime", ::apache::thrift::protocol::T_I64, 4); - xfer += oprot->writeI64(this->transferStartTime); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.transferEndTime) { - xfer += oprot->writeFieldBegin("transferEndTime", ::apache::thrift::protocol::T_I64, 5); - xfer += oprot->writeI64(this->transferEndTime); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.transferRate) { - xfer += oprot->writeFieldBegin("transferRate", ::apache::thrift::protocol::T_STRING, 6); - xfer += oprot->writeString(this->transferRate); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.processInput) { - xfer += oprot->writeFieldBegin("processInput", ::apache::thrift::protocol::T_STRUCT, 7); - xfer += this->processInput.write(oprot); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.processOutput) { - xfer += oprot->writeFieldBegin("processOutput", ::apache::thrift::protocol::T_STRUCT, 8); - xfer += this->processOutput.write(oprot); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(DataStagingTaskModel &a, DataStagingTaskModel &b) { - using ::std::swap; - swap(a.source, b.source); - swap(a.destination, b.destination); - swap(a.type, b.type); - swap(a.transferStartTime, b.transferStartTime); - swap(a.transferEndTime, b.transferEndTime); - swap(a.transferRate, b.transferRate); - swap(a.processInput, b.processInput); - swap(a.processOutput, b.processOutput); - swap(a.__isset, b.__isset); -} - -DataStagingTaskModel::DataStagingTaskModel(const DataStagingTaskModel& other22) { - source = other22.source; - destination = other22.destination; - type = other22.type; - transferStartTime = other22.transferStartTime; - transferEndTime = other22.transferEndTime; - transferRate = other22.transferRate; - processInput = other22.processInput; - processOutput = other22.processOutput; - __isset = other22.__isset; -} -DataStagingTaskModel& DataStagingTaskModel::operator=(const DataStagingTaskModel& other23) { - source = other23.source; - destination = other23.destination; - type = other23.type; - transferStartTime = other23.transferStartTime; - transferEndTime = other23.transferEndTime; - transferRate = other23.transferRate; - processInput = other23.processInput; - processOutput = other23.processOutput; - __isset = other23.__isset; - return *this; -} -void DataStagingTaskModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "DataStagingTaskModel("; - out << "source=" << to_string(source); - out << ", " << "destination=" << to_string(destination); - out << ", " << "type=" << to_string(type); - out << ", " << "transferStartTime="; (__isset.transferStartTime ? (out << to_string(transferStartTime)) : (out << "<null>")); - out << ", " << "transferEndTime="; (__isset.transferEndTime ? (out << to_string(transferEndTime)) : (out << "<null>")); - out << ", " << "transferRate="; (__isset.transferRate ? (out << to_string(transferRate)) : (out << "<null>")); - out << ", " << "processInput="; (__isset.processInput ? (out << to_string(processInput)) : (out << "<null>")); - out << ", " << "processOutput="; (__isset.processOutput ? (out << to_string(processOutput)) : (out << "<null>")); - out << ")"; -} - - -EnvironmentSetupTaskModel::~EnvironmentSetupTaskModel() throw() { -} - - -void EnvironmentSetupTaskModel::__set_location(const std::string& val) { - this->location = val; -} - -void EnvironmentSetupTaskModel::__set_protocol(const ::apache::airavata::model::data::movement::SecurityProtocol::type val) { - this->protocol = val; -} - -uint32_t EnvironmentSetupTaskModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_location = false; - bool isset_protocol = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->location); - isset_location = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast24; - xfer += iprot->readI32(ecast24); - this->protocol = ( ::apache::airavata::model::data::movement::SecurityProtocol::type)ecast24; - isset_protocol = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_location) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_protocol) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t EnvironmentSetupTaskModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("EnvironmentSetupTaskModel"); - - xfer += oprot->writeFieldBegin("location", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->location); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("protocol", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((int32_t)this->protocol); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(EnvironmentSetupTaskModel &a, EnvironmentSetupTaskModel &b) { - using ::std::swap; - swap(a.location, b.location); - swap(a.protocol, b.protocol); -} - -EnvironmentSetupTaskModel::EnvironmentSetupTaskModel(const EnvironmentSetupTaskModel& other25) { - location = other25.location; - protocol = other25.protocol; -} -EnvironmentSetupTaskModel& EnvironmentSetupTaskModel::operator=(const EnvironmentSetupTaskModel& other26) { - location = other26.location; - protocol = other26.protocol; - return *this; -} -void EnvironmentSetupTaskModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "EnvironmentSetupTaskModel("; - out << "location=" << to_string(location); - out << ", " << "protocol=" << to_string(protocol); - out << ")"; -} - - -JobSubmissionTaskModel::~JobSubmissionTaskModel() throw() { -} - - -void JobSubmissionTaskModel::__set_jobSubmissionProtocol(const ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type val) { - this->jobSubmissionProtocol = val; -} - -void JobSubmissionTaskModel::__set_monitorMode(const ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type val) { - this->monitorMode = val; -} - -void JobSubmissionTaskModel::__set_wallTime(const int32_t val) { - this->wallTime = val; -__isset.wallTime = true; -} - -uint32_t JobSubmissionTaskModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_jobSubmissionProtocol = false; - bool isset_monitorMode = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast27; - xfer += iprot->readI32(ecast27); - this->jobSubmissionProtocol = ( ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type)ecast27; - isset_jobSubmissionProtocol = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast28; - xfer += iprot->readI32(ecast28); - this->monitorMode = ( ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type)ecast28; - isset_monitorMode = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->wallTime); - this->__isset.wallTime = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_jobSubmissionProtocol) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_monitorMode) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t JobSubmissionTaskModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("JobSubmissionTaskModel"); - - xfer += oprot->writeFieldBegin("jobSubmissionProtocol", ::apache::thrift::protocol::T_I32, 1); - xfer += oprot->writeI32((int32_t)this->jobSubmissionProtocol); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("monitorMode", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((int32_t)this->monitorMode); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.wallTime) { - xfer += oprot->writeFieldBegin("wallTime", ::apache::thrift::protocol::T_I32, 3); - xfer += oprot->writeI32(this->wallTime); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(JobSubmissionTaskModel &a, JobSubmissionTaskModel &b) { - using ::std::swap; - swap(a.jobSubmissionProtocol, b.jobSubmissionProtocol); - swap(a.monitorMode, b.monitorMode); - swap(a.wallTime, b.wallTime); - swap(a.__isset, b.__isset); -} - -JobSubmissionTaskModel::JobSubmissionTaskModel(const JobSubmissionTaskModel& other29) { - jobSubmissionProtocol = other29.jobSubmissionProtocol; - monitorMode = other29.monitorMode; - wallTime = other29.wallTime; - __isset = other29.__isset; -} -JobSubmissionTaskModel& JobSubmissionTaskModel::operator=(const JobSubmissionTaskModel& other30) { - jobSubmissionProtocol = other30.jobSubmissionProtocol; - monitorMode = other30.monitorMode; - wallTime = other30.wallTime; - __isset = other30.__isset; - return *this; -} -void JobSubmissionTaskModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "JobSubmissionTaskModel("; - out << "jobSubmissionProtocol=" << to_string(jobSubmissionProtocol); - out << ", " << "monitorMode=" << to_string(monitorMode); - out << ", " << "wallTime="; (__isset.wallTime ? (out << to_string(wallTime)) : (out << "<null>")); - out << ")"; -} - - -MonitorTaskModel::~MonitorTaskModel() throw() { -} - - -void MonitorTaskModel::__set_monitorMode(const ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type val) { - this->monitorMode = val; -} - -uint32_t MonitorTaskModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_monitorMode = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast31; - xfer += iprot->readI32(ecast31); - this->monitorMode = ( ::apache::airavata::model::appcatalog::computeresource::MonitorMode::type)ecast31; - isset_monitorMode = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_monitorMode) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t MonitorTaskModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("MonitorTaskModel"); - - xfer += oprot->writeFieldBegin("monitorMode", ::apache::thrift::protocol::T_I32, 1); - xfer += oprot->writeI32((int32_t)this->monitorMode); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(MonitorTaskModel &a, MonitorTaskModel &b) { - using ::std::swap; - swap(a.monitorMode, b.monitorMode); -} - -MonitorTaskModel::MonitorTaskModel(const MonitorTaskModel& other32) { - monitorMode = other32.monitorMode; -} -MonitorTaskModel& MonitorTaskModel::operator=(const MonitorTaskModel& other33) { - monitorMode = other33.monitorMode; - return *this; -} -void MonitorTaskModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "MonitorTaskModel("; - out << "monitorMode=" << to_string(monitorMode); - out << ")"; -} - -}}}} // namespace http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.h deleted file mode 100644 index ab0089c..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/task_model_types.h +++ /dev/null @@ -1,420 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef 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 "compute_resource_model_types.h" -#include "data_movement_models_types.h" -#include "application_io_models_types.h" -#include "status_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, - OUTPUT_FETCHING = 5 - }; -}; - -extern const std::map<int, const char*> _TaskTypes_VALUES_TO_NAMES; - -struct DataStageType { - enum type { - INPUT = 0, - OUPUT = 1, - ARCHIVE_OUTPUT = 2 - }; -}; - -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), taskErrors(false), jobs(false) {} - bool taskDetail :1; - bool subTaskModel :1; - bool taskErrors :1; - bool jobs :1; -} _TaskModel__isset; - -class TaskModel { - public: - - 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; - std::vector< ::apache::airavata::model::status::TaskStatus> taskStatuses; - std::string taskDetail; - std::string subTaskModel; - std::vector< ::apache::airavata::model::commons::ErrorModel> taskErrors; - 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_taskStatuses(const std::vector< ::apache::airavata::model::status::TaskStatus> & val); - - void __set_taskDetail(const std::string& val); - - void __set_subTaskModel(const std::string& val); - - void __set_taskErrors(const std::vector< ::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 (!(taskStatuses == rhs.taskStatuses)) - 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.taskErrors != rhs.__isset.taskErrors) - return false; - else if (__isset.taskErrors && !(taskErrors == rhs.taskErrors)) - 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; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(TaskModel &a, TaskModel &b); - -inline std::ostream& operator<<(std::ostream& out, const TaskModel& obj) -{ - obj.printTo(out); - return out; -} - -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: - - 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; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(DataStagingTaskModel &a, DataStagingTaskModel &b); - -inline std::ostream& operator<<(std::ostream& out, const DataStagingTaskModel& obj) -{ - obj.printTo(out); - return out; -} - - -class EnvironmentSetupTaskModel { - public: - - EnvironmentSetupTaskModel(const EnvironmentSetupTaskModel&); - EnvironmentSetupTaskModel& operator=(const EnvironmentSetupTaskModel&); - EnvironmentSetupTaskModel() : location(), protocol(( ::apache::airavata::model::data::movement::SecurityProtocol::type)0) { - } - - virtual ~EnvironmentSetupTaskModel() throw(); - std::string location; - ::apache::airavata::model::data::movement::SecurityProtocol::type protocol; - - void __set_location(const std::string& val); - - void __set_protocol(const ::apache::airavata::model::data::movement::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; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(EnvironmentSetupTaskModel &a, EnvironmentSetupTaskModel &b); - -inline std::ostream& operator<<(std::ostream& out, const EnvironmentSetupTaskModel& obj) -{ - obj.printTo(out); - return out; -} - -typedef struct _JobSubmissionTaskModel__isset { - _JobSubmissionTaskModel__isset() : wallTime(false) {} - bool wallTime :1; -} _JobSubmissionTaskModel__isset; - -class JobSubmissionTaskModel { - public: - - 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; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(JobSubmissionTaskModel &a, JobSubmissionTaskModel &b); - -inline std::ostream& operator<<(std::ostream& out, const JobSubmissionTaskModel& obj) -{ - obj.printTo(out); - return out; -} - - -class MonitorTaskModel { - public: - - 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; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(MonitorTaskModel &a, MonitorTaskModel &b); - -inline std::ostream& operator<<(std::ostream& out, const MonitorTaskModel& obj) -{ - obj.printTo(out); - return out; -} - -}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.cpp deleted file mode 100644 index 617e15c..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.cpp +++ /dev/null @@ -1,36 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "user_profile_model_constants.h" - -namespace apache { namespace airavata { namespace model { namespace user { - -const user_profile_modelConstants g_user_profile_model_constants; - -user_profile_modelConstants::user_profile_modelConstants() { - USER_PROFILE_VERSION = "1.0"; - -} - -}}}} // namespace - http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.h deleted file mode 100644 index 813151f..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/user_profile_model_constants.h +++ /dev/null @@ -1,42 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef user_profile_model_CONSTANTS_H -#define user_profile_model_CONSTANTS_H - -#include "user_profile_model_types.h" - -namespace apache { namespace airavata { namespace model { namespace user { - -class user_profile_modelConstants { - public: - user_profile_modelConstants(); - - std::string USER_PROFILE_VERSION; -}; - -extern const user_profile_modelConstants g_user_profile_model_constants; - -}}}} // namespace - -#endif
