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/replica_catalog_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_catalog_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_catalog_models_types.h deleted file mode 100644 index c30079f..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_catalog_models_types.h +++ /dev/null @@ -1,346 +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 replica_catalog_models_TYPES_H -#define replica_catalog_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 data { namespace replica { - -struct ReplicaLocationCategory { - enum type { - GATEWAY_DATA_STORE = 0, - COMPUTE_RESOURCE = 1, - LONG_TERM_STORAGE_RESOURCE = 2, - OTHER = 3 - }; -}; - -extern const std::map<int, const char*> _ReplicaLocationCategory_VALUES_TO_NAMES; - -struct ReplicaPersistentType { - enum type { - TRANSIENT = 0, - PERSISTENT = 1 - }; -}; - -extern const std::map<int, const char*> _ReplicaPersistentType_VALUES_TO_NAMES; - -struct DataProductType { - enum type { - FILE = 0, - COLLECTION = 1 - }; -}; - -extern const std::map<int, const char*> _DataProductType_VALUES_TO_NAMES; - -class DataProductModel; - -class DataReplicaLocationModel; - -typedef struct _DataProductModel__isset { - _DataProductModel__isset() : productUri(false), gatewayId(false), parentProductUri(false), productName(false), productDescription(false), ownerName(false), dataProductType(false), productSize(false), creationTime(false), lastModifiedTime(false), productMetadata(false), replicaLocations(false) {} - bool productUri :1; - bool gatewayId :1; - bool parentProductUri :1; - bool productName :1; - bool productDescription :1; - bool ownerName :1; - bool dataProductType :1; - bool productSize :1; - bool creationTime :1; - bool lastModifiedTime :1; - bool productMetadata :1; - bool replicaLocations :1; -} _DataProductModel__isset; - -class DataProductModel { - public: - - DataProductModel(const DataProductModel&); - DataProductModel& operator=(const DataProductModel&); - DataProductModel() : productUri(), gatewayId(), parentProductUri(), productName(), productDescription(), ownerName(), dataProductType((DataProductType::type)0), productSize(0), creationTime(0), lastModifiedTime(0) { - } - - virtual ~DataProductModel() throw(); - std::string productUri; - std::string gatewayId; - std::string parentProductUri; - std::string productName; - std::string productDescription; - std::string ownerName; - DataProductType::type dataProductType; - int32_t productSize; - int64_t creationTime; - int64_t lastModifiedTime; - std::map<std::string, std::string> productMetadata; - std::vector<DataReplicaLocationModel> replicaLocations; - - _DataProductModel__isset __isset; - - void __set_productUri(const std::string& val); - - void __set_gatewayId(const std::string& val); - - void __set_parentProductUri(const std::string& val); - - void __set_productName(const std::string& val); - - void __set_productDescription(const std::string& val); - - void __set_ownerName(const std::string& val); - - void __set_dataProductType(const DataProductType::type val); - - void __set_productSize(const int32_t val); - - void __set_creationTime(const int64_t val); - - void __set_lastModifiedTime(const int64_t val); - - void __set_productMetadata(const std::map<std::string, std::string> & val); - - void __set_replicaLocations(const std::vector<DataReplicaLocationModel> & val); - - bool operator == (const DataProductModel & rhs) const - { - if (__isset.productUri != rhs.__isset.productUri) - return false; - else if (__isset.productUri && !(productUri == rhs.productUri)) - return false; - if (__isset.gatewayId != rhs.__isset.gatewayId) - return false; - else if (__isset.gatewayId && !(gatewayId == rhs.gatewayId)) - return false; - if (__isset.parentProductUri != rhs.__isset.parentProductUri) - return false; - else if (__isset.parentProductUri && !(parentProductUri == rhs.parentProductUri)) - return false; - if (__isset.productName != rhs.__isset.productName) - return false; - else if (__isset.productName && !(productName == rhs.productName)) - return false; - if (__isset.productDescription != rhs.__isset.productDescription) - return false; - else if (__isset.productDescription && !(productDescription == rhs.productDescription)) - return false; - if (__isset.ownerName != rhs.__isset.ownerName) - return false; - else if (__isset.ownerName && !(ownerName == rhs.ownerName)) - return false; - if (__isset.dataProductType != rhs.__isset.dataProductType) - return false; - else if (__isset.dataProductType && !(dataProductType == rhs.dataProductType)) - return false; - if (__isset.productSize != rhs.__isset.productSize) - return false; - else if (__isset.productSize && !(productSize == rhs.productSize)) - return false; - if (__isset.creationTime != rhs.__isset.creationTime) - return false; - else if (__isset.creationTime && !(creationTime == rhs.creationTime)) - return false; - if (__isset.lastModifiedTime != rhs.__isset.lastModifiedTime) - return false; - else if (__isset.lastModifiedTime && !(lastModifiedTime == rhs.lastModifiedTime)) - return false; - if (__isset.productMetadata != rhs.__isset.productMetadata) - return false; - else if (__isset.productMetadata && !(productMetadata == rhs.productMetadata)) - return false; - if (__isset.replicaLocations != rhs.__isset.replicaLocations) - return false; - else if (__isset.replicaLocations && !(replicaLocations == rhs.replicaLocations)) - return false; - return true; - } - bool operator != (const DataProductModel &rhs) const { - return !(*this == rhs); - } - - bool operator < (const DataProductModel & ) 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(DataProductModel &a, DataProductModel &b); - -inline std::ostream& operator<<(std::ostream& out, const DataProductModel& obj) -{ - obj.printTo(out); - return out; -} - -typedef struct _DataReplicaLocationModel__isset { - _DataReplicaLocationModel__isset() : replicaId(false), productUri(false), replicaName(false), replicaDescription(false), creationTime(false), lastModifiedTime(false), validUntilTime(false), replicaLocationCategory(false), replicaPersistentType(false), storageResourceId(false), filePath(false), replicaMetadata(false) {} - bool replicaId :1; - bool productUri :1; - bool replicaName :1; - bool replicaDescription :1; - bool creationTime :1; - bool lastModifiedTime :1; - bool validUntilTime :1; - bool replicaLocationCategory :1; - bool replicaPersistentType :1; - bool storageResourceId :1; - bool filePath :1; - bool replicaMetadata :1; -} _DataReplicaLocationModel__isset; - -class DataReplicaLocationModel { - public: - - DataReplicaLocationModel(const DataReplicaLocationModel&); - DataReplicaLocationModel& operator=(const DataReplicaLocationModel&); - DataReplicaLocationModel() : replicaId(), productUri(), replicaName(), replicaDescription(), creationTime(0), lastModifiedTime(0), validUntilTime(0), replicaLocationCategory((ReplicaLocationCategory::type)0), replicaPersistentType((ReplicaPersistentType::type)0), storageResourceId(), filePath() { - } - - virtual ~DataReplicaLocationModel() throw(); - std::string replicaId; - std::string productUri; - std::string replicaName; - std::string replicaDescription; - int64_t creationTime; - int64_t lastModifiedTime; - int64_t validUntilTime; - ReplicaLocationCategory::type replicaLocationCategory; - ReplicaPersistentType::type replicaPersistentType; - std::string storageResourceId; - std::string filePath; - std::map<std::string, std::string> replicaMetadata; - - _DataReplicaLocationModel__isset __isset; - - void __set_replicaId(const std::string& val); - - void __set_productUri(const std::string& val); - - void __set_replicaName(const std::string& val); - - void __set_replicaDescription(const std::string& val); - - void __set_creationTime(const int64_t val); - - void __set_lastModifiedTime(const int64_t val); - - void __set_validUntilTime(const int64_t val); - - void __set_replicaLocationCategory(const ReplicaLocationCategory::type val); - - void __set_replicaPersistentType(const ReplicaPersistentType::type val); - - void __set_storageResourceId(const std::string& val); - - void __set_filePath(const std::string& val); - - void __set_replicaMetadata(const std::map<std::string, std::string> & val); - - bool operator == (const DataReplicaLocationModel & rhs) const - { - if (__isset.replicaId != rhs.__isset.replicaId) - return false; - else if (__isset.replicaId && !(replicaId == rhs.replicaId)) - return false; - if (__isset.productUri != rhs.__isset.productUri) - return false; - else if (__isset.productUri && !(productUri == rhs.productUri)) - return false; - if (__isset.replicaName != rhs.__isset.replicaName) - return false; - else if (__isset.replicaName && !(replicaName == rhs.replicaName)) - return false; - if (__isset.replicaDescription != rhs.__isset.replicaDescription) - return false; - else if (__isset.replicaDescription && !(replicaDescription == rhs.replicaDescription)) - return false; - if (__isset.creationTime != rhs.__isset.creationTime) - return false; - else if (__isset.creationTime && !(creationTime == rhs.creationTime)) - return false; - if (__isset.lastModifiedTime != rhs.__isset.lastModifiedTime) - return false; - else if (__isset.lastModifiedTime && !(lastModifiedTime == rhs.lastModifiedTime)) - return false; - if (__isset.validUntilTime != rhs.__isset.validUntilTime) - return false; - else if (__isset.validUntilTime && !(validUntilTime == rhs.validUntilTime)) - return false; - if (__isset.replicaLocationCategory != rhs.__isset.replicaLocationCategory) - return false; - else if (__isset.replicaLocationCategory && !(replicaLocationCategory == rhs.replicaLocationCategory)) - return false; - if (__isset.replicaPersistentType != rhs.__isset.replicaPersistentType) - return false; - else if (__isset.replicaPersistentType && !(replicaPersistentType == rhs.replicaPersistentType)) - return false; - if (__isset.storageResourceId != rhs.__isset.storageResourceId) - return false; - else if (__isset.storageResourceId && !(storageResourceId == rhs.storageResourceId)) - return false; - if (__isset.filePath != rhs.__isset.filePath) - return false; - else if (__isset.filePath && !(filePath == rhs.filePath)) - return false; - if (__isset.replicaMetadata != rhs.__isset.replicaMetadata) - return false; - else if (__isset.replicaMetadata && !(replicaMetadata == rhs.replicaMetadata)) - return false; - return true; - } - bool operator != (const DataReplicaLocationModel &rhs) const { - return !(*this == rhs); - } - - bool operator < (const DataReplicaLocationModel & ) 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(DataReplicaLocationModel &a, DataReplicaLocationModel &b); - -inline std::ostream& operator<<(std::ostream& out, const DataReplicaLocationModel& 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/scheduling_model_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.cpp deleted file mode 100644 index 5cdbfd9..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_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 "scheduling_model_constants.h" - -namespace apache { namespace airavata { namespace model { namespace scheduling { - -const scheduling_modelConstants g_scheduling_model_constants; - -scheduling_modelConstants::scheduling_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/scheduling_model_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.h deleted file mode 100644 index ba5ed8e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_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 scheduling_model_CONSTANTS_H -#define scheduling_model_CONSTANTS_H - -#include "scheduling_model_types.h" - -namespace apache { namespace airavata { namespace model { namespace scheduling { - -class scheduling_modelConstants { - public: - scheduling_modelConstants(); - -}; - -extern const scheduling_modelConstants g_scheduling_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/scheduling_model_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp deleted file mode 100644 index 909cf5e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp +++ /dev/null @@ -1,363 +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 "scheduling_model_types.h" - -#include <algorithm> -#include <ostream> - -#include <thrift/TToString.h> - -namespace apache { namespace airavata { namespace model { namespace scheduling { - - -ComputationalResourceSchedulingModel::~ComputationalResourceSchedulingModel() throw() { -} - - -void ComputationalResourceSchedulingModel::__set_resourceHostId(const std::string& val) { - this->resourceHostId = val; -__isset.resourceHostId = true; -} - -void ComputationalResourceSchedulingModel::__set_totalCPUCount(const int32_t val) { - this->totalCPUCount = val; -__isset.totalCPUCount = true; -} - -void ComputationalResourceSchedulingModel::__set_nodeCount(const int32_t val) { - this->nodeCount = val; -__isset.nodeCount = true; -} - -void ComputationalResourceSchedulingModel::__set_numberOfThreads(const int32_t val) { - this->numberOfThreads = val; -__isset.numberOfThreads = true; -} - -void ComputationalResourceSchedulingModel::__set_queueName(const std::string& val) { - this->queueName = val; -__isset.queueName = true; -} - -void ComputationalResourceSchedulingModel::__set_wallTimeLimit(const int32_t val) { - this->wallTimeLimit = val; -__isset.wallTimeLimit = true; -} - -void ComputationalResourceSchedulingModel::__set_totalPhysicalMemory(const int32_t val) { - this->totalPhysicalMemory = val; -__isset.totalPhysicalMemory = true; -} - -void ComputationalResourceSchedulingModel::__set_chessisNumber(const std::string& val) { - this->chessisNumber = val; -__isset.chessisNumber = true; -} - -void ComputationalResourceSchedulingModel::__set_staticWorkingDir(const std::string& val) { - this->staticWorkingDir = val; -__isset.staticWorkingDir = true; -} - -void ComputationalResourceSchedulingModel::__set_overrideLoginUserName(const std::string& val) { - this->overrideLoginUserName = val; -__isset.overrideLoginUserName = true; -} - -void ComputationalResourceSchedulingModel::__set_overrideScratchLocation(const std::string& val) { - this->overrideScratchLocation = val; -__isset.overrideScratchLocation = true; -} - -void ComputationalResourceSchedulingModel::__set_overrideAllocationProjectNumber(const std::string& val) { - this->overrideAllocationProjectNumber = val; -__isset.overrideAllocationProjectNumber = true; -} - -uint32_t ComputationalResourceSchedulingModel::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->resourceHostId); - this->__isset.resourceHostId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->totalCPUCount); - this->__isset.totalCPUCount = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->nodeCount); - this->__isset.nodeCount = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->numberOfThreads); - this->__isset.numberOfThreads = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->queueName); - this->__isset.queueName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 6: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->wallTimeLimit); - this->__isset.wallTimeLimit = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 7: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->totalPhysicalMemory); - this->__isset.totalPhysicalMemory = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 8: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->chessisNumber); - this->__isset.chessisNumber = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 9: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->staticWorkingDir); - this->__isset.staticWorkingDir = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 10: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->overrideLoginUserName); - this->__isset.overrideLoginUserName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 11: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->overrideScratchLocation); - this->__isset.overrideScratchLocation = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 12: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->overrideAllocationProjectNumber); - this->__isset.overrideAllocationProjectNumber = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - return xfer; -} - -uint32_t ComputationalResourceSchedulingModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("ComputationalResourceSchedulingModel"); - - if (this->__isset.resourceHostId) { - xfer += oprot->writeFieldBegin("resourceHostId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->resourceHostId); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.totalCPUCount) { - xfer += oprot->writeFieldBegin("totalCPUCount", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32(this->totalCPUCount); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.nodeCount) { - xfer += oprot->writeFieldBegin("nodeCount", ::apache::thrift::protocol::T_I32, 3); - xfer += oprot->writeI32(this->nodeCount); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.numberOfThreads) { - xfer += oprot->writeFieldBegin("numberOfThreads", ::apache::thrift::protocol::T_I32, 4); - xfer += oprot->writeI32(this->numberOfThreads); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.queueName) { - xfer += oprot->writeFieldBegin("queueName", ::apache::thrift::protocol::T_STRING, 5); - xfer += oprot->writeString(this->queueName); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.wallTimeLimit) { - xfer += oprot->writeFieldBegin("wallTimeLimit", ::apache::thrift::protocol::T_I32, 6); - xfer += oprot->writeI32(this->wallTimeLimit); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.totalPhysicalMemory) { - xfer += oprot->writeFieldBegin("totalPhysicalMemory", ::apache::thrift::protocol::T_I32, 7); - xfer += oprot->writeI32(this->totalPhysicalMemory); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.chessisNumber) { - xfer += oprot->writeFieldBegin("chessisNumber", ::apache::thrift::protocol::T_STRING, 8); - xfer += oprot->writeString(this->chessisNumber); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.staticWorkingDir) { - xfer += oprot->writeFieldBegin("staticWorkingDir", ::apache::thrift::protocol::T_STRING, 9); - xfer += oprot->writeString(this->staticWorkingDir); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.overrideLoginUserName) { - xfer += oprot->writeFieldBegin("overrideLoginUserName", ::apache::thrift::protocol::T_STRING, 10); - xfer += oprot->writeString(this->overrideLoginUserName); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.overrideScratchLocation) { - xfer += oprot->writeFieldBegin("overrideScratchLocation", ::apache::thrift::protocol::T_STRING, 11); - xfer += oprot->writeString(this->overrideScratchLocation); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.overrideAllocationProjectNumber) { - xfer += oprot->writeFieldBegin("overrideAllocationProjectNumber", ::apache::thrift::protocol::T_STRING, 12); - xfer += oprot->writeString(this->overrideAllocationProjectNumber); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(ComputationalResourceSchedulingModel &a, ComputationalResourceSchedulingModel &b) { - using ::std::swap; - swap(a.resourceHostId, b.resourceHostId); - swap(a.totalCPUCount, b.totalCPUCount); - swap(a.nodeCount, b.nodeCount); - swap(a.numberOfThreads, b.numberOfThreads); - swap(a.queueName, b.queueName); - swap(a.wallTimeLimit, b.wallTimeLimit); - swap(a.totalPhysicalMemory, b.totalPhysicalMemory); - swap(a.chessisNumber, b.chessisNumber); - swap(a.staticWorkingDir, b.staticWorkingDir); - swap(a.overrideLoginUserName, b.overrideLoginUserName); - swap(a.overrideScratchLocation, b.overrideScratchLocation); - swap(a.overrideAllocationProjectNumber, b.overrideAllocationProjectNumber); - swap(a.__isset, b.__isset); -} - -ComputationalResourceSchedulingModel::ComputationalResourceSchedulingModel(const ComputationalResourceSchedulingModel& other0) { - resourceHostId = other0.resourceHostId; - totalCPUCount = other0.totalCPUCount; - nodeCount = other0.nodeCount; - numberOfThreads = other0.numberOfThreads; - queueName = other0.queueName; - wallTimeLimit = other0.wallTimeLimit; - totalPhysicalMemory = other0.totalPhysicalMemory; - chessisNumber = other0.chessisNumber; - staticWorkingDir = other0.staticWorkingDir; - overrideLoginUserName = other0.overrideLoginUserName; - overrideScratchLocation = other0.overrideScratchLocation; - overrideAllocationProjectNumber = other0.overrideAllocationProjectNumber; - __isset = other0.__isset; -} -ComputationalResourceSchedulingModel& ComputationalResourceSchedulingModel::operator=(const ComputationalResourceSchedulingModel& other1) { - resourceHostId = other1.resourceHostId; - totalCPUCount = other1.totalCPUCount; - nodeCount = other1.nodeCount; - numberOfThreads = other1.numberOfThreads; - queueName = other1.queueName; - wallTimeLimit = other1.wallTimeLimit; - totalPhysicalMemory = other1.totalPhysicalMemory; - chessisNumber = other1.chessisNumber; - staticWorkingDir = other1.staticWorkingDir; - overrideLoginUserName = other1.overrideLoginUserName; - overrideScratchLocation = other1.overrideScratchLocation; - overrideAllocationProjectNumber = other1.overrideAllocationProjectNumber; - __isset = other1.__isset; - return *this; -} -void ComputationalResourceSchedulingModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "ComputationalResourceSchedulingModel("; - out << "resourceHostId="; (__isset.resourceHostId ? (out << to_string(resourceHostId)) : (out << "<null>")); - out << ", " << "totalCPUCount="; (__isset.totalCPUCount ? (out << to_string(totalCPUCount)) : (out << "<null>")); - out << ", " << "nodeCount="; (__isset.nodeCount ? (out << to_string(nodeCount)) : (out << "<null>")); - out << ", " << "numberOfThreads="; (__isset.numberOfThreads ? (out << to_string(numberOfThreads)) : (out << "<null>")); - out << ", " << "queueName="; (__isset.queueName ? (out << to_string(queueName)) : (out << "<null>")); - out << ", " << "wallTimeLimit="; (__isset.wallTimeLimit ? (out << to_string(wallTimeLimit)) : (out << "<null>")); - out << ", " << "totalPhysicalMemory="; (__isset.totalPhysicalMemory ? (out << to_string(totalPhysicalMemory)) : (out << "<null>")); - out << ", " << "chessisNumber="; (__isset.chessisNumber ? (out << to_string(chessisNumber)) : (out << "<null>")); - out << ", " << "staticWorkingDir="; (__isset.staticWorkingDir ? (out << to_string(staticWorkingDir)) : (out << "<null>")); - out << ", " << "overrideLoginUserName="; (__isset.overrideLoginUserName ? (out << to_string(overrideLoginUserName)) : (out << "<null>")); - out << ", " << "overrideScratchLocation="; (__isset.overrideScratchLocation ? (out << to_string(overrideScratchLocation)) : (out << "<null>")); - out << ", " << "overrideAllocationProjectNumber="; (__isset.overrideAllocationProjectNumber ? (out << to_string(overrideAllocationProjectNumber)) : (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/scheduling_model_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h deleted file mode 100644 index 4c42e04..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h +++ /dev/null @@ -1,179 +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 scheduling_model_TYPES_H -#define scheduling_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> - - -namespace apache { namespace airavata { namespace model { namespace scheduling { - -class ComputationalResourceSchedulingModel; - -typedef struct _ComputationalResourceSchedulingModel__isset { - _ComputationalResourceSchedulingModel__isset() : resourceHostId(false), totalCPUCount(false), nodeCount(false), numberOfThreads(false), queueName(false), wallTimeLimit(false), totalPhysicalMemory(false), chessisNumber(false), staticWorkingDir(false), overrideLoginUserName(false), overrideScratchLocation(false), overrideAllocationProjectNumber(false) {} - bool resourceHostId :1; - bool totalCPUCount :1; - bool nodeCount :1; - bool numberOfThreads :1; - bool queueName :1; - bool wallTimeLimit :1; - bool totalPhysicalMemory :1; - bool chessisNumber :1; - bool staticWorkingDir :1; - bool overrideLoginUserName :1; - bool overrideScratchLocation :1; - bool overrideAllocationProjectNumber :1; -} _ComputationalResourceSchedulingModel__isset; - -class ComputationalResourceSchedulingModel { - public: - - ComputationalResourceSchedulingModel(const ComputationalResourceSchedulingModel&); - ComputationalResourceSchedulingModel& operator=(const ComputationalResourceSchedulingModel&); - ComputationalResourceSchedulingModel() : resourceHostId(), totalCPUCount(0), nodeCount(0), numberOfThreads(0), queueName(), wallTimeLimit(0), totalPhysicalMemory(0), chessisNumber(), staticWorkingDir(), overrideLoginUserName(), overrideScratchLocation(), overrideAllocationProjectNumber() { - } - - virtual ~ComputationalResourceSchedulingModel() throw(); - std::string resourceHostId; - int32_t totalCPUCount; - int32_t nodeCount; - int32_t numberOfThreads; - std::string queueName; - int32_t wallTimeLimit; - int32_t totalPhysicalMemory; - std::string chessisNumber; - std::string staticWorkingDir; - std::string overrideLoginUserName; - std::string overrideScratchLocation; - std::string overrideAllocationProjectNumber; - - _ComputationalResourceSchedulingModel__isset __isset; - - void __set_resourceHostId(const std::string& val); - - void __set_totalCPUCount(const int32_t val); - - void __set_nodeCount(const int32_t val); - - void __set_numberOfThreads(const int32_t val); - - void __set_queueName(const std::string& val); - - void __set_wallTimeLimit(const int32_t val); - - void __set_totalPhysicalMemory(const int32_t val); - - void __set_chessisNumber(const std::string& val); - - void __set_staticWorkingDir(const std::string& val); - - void __set_overrideLoginUserName(const std::string& val); - - void __set_overrideScratchLocation(const std::string& val); - - void __set_overrideAllocationProjectNumber(const std::string& val); - - bool operator == (const ComputationalResourceSchedulingModel & rhs) const - { - if (__isset.resourceHostId != rhs.__isset.resourceHostId) - return false; - else if (__isset.resourceHostId && !(resourceHostId == rhs.resourceHostId)) - return false; - if (__isset.totalCPUCount != rhs.__isset.totalCPUCount) - return false; - else if (__isset.totalCPUCount && !(totalCPUCount == rhs.totalCPUCount)) - return false; - if (__isset.nodeCount != rhs.__isset.nodeCount) - return false; - else if (__isset.nodeCount && !(nodeCount == rhs.nodeCount)) - return false; - if (__isset.numberOfThreads != rhs.__isset.numberOfThreads) - return false; - else if (__isset.numberOfThreads && !(numberOfThreads == rhs.numberOfThreads)) - return false; - if (__isset.queueName != rhs.__isset.queueName) - return false; - else if (__isset.queueName && !(queueName == rhs.queueName)) - return false; - if (__isset.wallTimeLimit != rhs.__isset.wallTimeLimit) - return false; - else if (__isset.wallTimeLimit && !(wallTimeLimit == rhs.wallTimeLimit)) - return false; - if (__isset.totalPhysicalMemory != rhs.__isset.totalPhysicalMemory) - return false; - else if (__isset.totalPhysicalMemory && !(totalPhysicalMemory == rhs.totalPhysicalMemory)) - return false; - if (__isset.chessisNumber != rhs.__isset.chessisNumber) - return false; - else if (__isset.chessisNumber && !(chessisNumber == rhs.chessisNumber)) - return false; - if (__isset.staticWorkingDir != rhs.__isset.staticWorkingDir) - return false; - else if (__isset.staticWorkingDir && !(staticWorkingDir == rhs.staticWorkingDir)) - return false; - if (__isset.overrideLoginUserName != rhs.__isset.overrideLoginUserName) - return false; - else if (__isset.overrideLoginUserName && !(overrideLoginUserName == rhs.overrideLoginUserName)) - return false; - if (__isset.overrideScratchLocation != rhs.__isset.overrideScratchLocation) - return false; - else if (__isset.overrideScratchLocation && !(overrideScratchLocation == rhs.overrideScratchLocation)) - return false; - if (__isset.overrideAllocationProjectNumber != rhs.__isset.overrideAllocationProjectNumber) - return false; - else if (__isset.overrideAllocationProjectNumber && !(overrideAllocationProjectNumber == rhs.overrideAllocationProjectNumber)) - return false; - return true; - } - bool operator != (const ComputationalResourceSchedulingModel &rhs) const { - return !(*this == rhs); - } - - bool operator < (const ComputationalResourceSchedulingModel & ) 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(ComputationalResourceSchedulingModel &a, ComputationalResourceSchedulingModel &b); - -inline std::ostream& operator<<(std::ostream& out, const ComputationalResourceSchedulingModel& 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/security_model_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.cpp deleted file mode 100644 index 74aa8aa..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_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 "security_model_constants.h" - -namespace apache { namespace airavata { namespace model { namespace security { - -const security_modelConstants g_security_model_constants; - -security_modelConstants::security_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/security_model_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.h deleted file mode 100644 index 08f4bf5..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_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 security_model_CONSTANTS_H -#define security_model_CONSTANTS_H - -#include "security_model_types.h" - -namespace apache { namespace airavata { namespace model { namespace security { - -class security_modelConstants { - public: - security_modelConstants(); - -}; - -extern const security_modelConstants g_security_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/security_model_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp deleted file mode 100644 index dbcfb76..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp +++ /dev/null @@ -1,168 +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 "security_model_types.h" - -#include <algorithm> -#include <ostream> - -#include <thrift/TToString.h> - -namespace apache { namespace airavata { namespace model { namespace security { - - -AuthzToken::~AuthzToken() throw() { -} - - -void AuthzToken::__set_accessToken(const std::string& val) { - this->accessToken = val; -} - -void AuthzToken::__set_claimsMap(const std::map<std::string, std::string> & val) { - this->claimsMap = val; -__isset.claimsMap = true; -} - -uint32_t AuthzToken::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_accessToken = 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->accessToken); - isset_accessToken = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_MAP) { - { - this->claimsMap.clear(); - uint32_t _size0; - ::apache::thrift::protocol::TType _ktype1; - ::apache::thrift::protocol::TType _vtype2; - xfer += iprot->readMapBegin(_ktype1, _vtype2, _size0); - uint32_t _i4; - for (_i4 = 0; _i4 < _size0; ++_i4) - { - std::string _key5; - xfer += iprot->readString(_key5); - std::string& _val6 = this->claimsMap[_key5]; - xfer += iprot->readString(_val6); - } - xfer += iprot->readMapEnd(); - } - this->__isset.claimsMap = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_accessToken) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t AuthzToken::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("AuthzToken"); - - xfer += oprot->writeFieldBegin("accessToken", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->accessToken); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.claimsMap) { - xfer += oprot->writeFieldBegin("claimsMap", ::apache::thrift::protocol::T_MAP, 2); - { - xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->claimsMap.size())); - std::map<std::string, std::string> ::const_iterator _iter7; - for (_iter7 = this->claimsMap.begin(); _iter7 != this->claimsMap.end(); ++_iter7) - { - xfer += oprot->writeString(_iter7->first); - xfer += oprot->writeString(_iter7->second); - } - xfer += oprot->writeMapEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(AuthzToken &a, AuthzToken &b) { - using ::std::swap; - swap(a.accessToken, b.accessToken); - swap(a.claimsMap, b.claimsMap); - swap(a.__isset, b.__isset); -} - -AuthzToken::AuthzToken(const AuthzToken& other8) { - accessToken = other8.accessToken; - claimsMap = other8.claimsMap; - __isset = other8.__isset; -} -AuthzToken& AuthzToken::operator=(const AuthzToken& other9) { - accessToken = other9.accessToken; - claimsMap = other9.claimsMap; - __isset = other9.__isset; - return *this; -} -void AuthzToken::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "AuthzToken("; - out << "accessToken=" << to_string(accessToken); - out << ", " << "claimsMap="; (__isset.claimsMap ? (out << to_string(claimsMap)) : (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/security_model_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h deleted file mode 100644 index 7519d4d..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h +++ /dev/null @@ -1,96 +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 security_model_TYPES_H -#define security_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> - - -namespace apache { namespace airavata { namespace model { namespace security { - -class AuthzToken; - -typedef struct _AuthzToken__isset { - _AuthzToken__isset() : claimsMap(false) {} - bool claimsMap :1; -} _AuthzToken__isset; - -class AuthzToken { - public: - - AuthzToken(const AuthzToken&); - AuthzToken& operator=(const AuthzToken&); - AuthzToken() : accessToken() { - } - - virtual ~AuthzToken() throw(); - std::string accessToken; - std::map<std::string, std::string> claimsMap; - - _AuthzToken__isset __isset; - - void __set_accessToken(const std::string& val); - - void __set_claimsMap(const std::map<std::string, std::string> & val); - - bool operator == (const AuthzToken & rhs) const - { - if (!(accessToken == rhs.accessToken)) - return false; - if (__isset.claimsMap != rhs.__isset.claimsMap) - return false; - else if (__isset.claimsMap && !(claimsMap == rhs.claimsMap)) - return false; - return true; - } - bool operator != (const AuthzToken &rhs) const { - return !(*this == rhs); - } - - bool operator < (const AuthzToken & ) 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(AuthzToken &a, AuthzToken &b); - -inline std::ostream& operator<<(std::ostream& out, const AuthzToken& 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/status_models_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.cpp deleted file mode 100644 index 1e4bc10..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_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 "status_models_constants.h" - -namespace apache { namespace airavata { namespace model { namespace status { - -const status_modelsConstants g_status_models_constants; - -status_modelsConstants::status_modelsConstants() { -} - -}}}} // 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/status_models_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.h deleted file mode 100644 index 8ef7437..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_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 status_models_CONSTANTS_H -#define status_models_CONSTANTS_H - -#include "status_models_types.h" - -namespace apache { namespace airavata { namespace model { namespace status { - -class status_modelsConstants { - public: - status_modelsConstants(); - -}; - -extern const status_modelsConstants g_status_models_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/status_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.cpp deleted file mode 100644 index cda0fa1..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_types.cpp +++ /dev/null @@ -1,870 +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 "status_models_types.h" - -#include <algorithm> -#include <ostream> - -#include <thrift/TToString.h> - -namespace apache { namespace airavata { namespace model { namespace status { - -int _kExperimentStateValues[] = { - ExperimentState::CREATED, - ExperimentState::VALIDATED, - ExperimentState::SCHEDULED, - ExperimentState::LAUNCHED, - ExperimentState::EXECUTING, - ExperimentState::CANCELING, - ExperimentState::CANCELED, - ExperimentState::COMPLETED, - ExperimentState::FAILED -}; -const char* _kExperimentStateNames[] = { - "CREATED", - "VALIDATED", - "SCHEDULED", - "LAUNCHED", - "EXECUTING", - "CANCELING", - "CANCELED", - "COMPLETED", - "FAILED" -}; -const std::map<int, const char*> _ExperimentState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(9, _kExperimentStateValues, _kExperimentStateNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); - -int _kTaskStateValues[] = { - TaskState::CREATED, - TaskState::EXECUTING, - TaskState::COMPLETED, - TaskState::FAILED, - TaskState::CANCELED -}; -const char* _kTaskStateNames[] = { - "CREATED", - "EXECUTING", - "COMPLETED", - "FAILED", - "CANCELED" -}; -const std::map<int, const char*> _TaskState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(5, _kTaskStateValues, _kTaskStateNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); - -int _kProcessStateValues[] = { - ProcessState::CREATED, - ProcessState::VALIDATED, - ProcessState::STARTED, - ProcessState::PRE_PROCESSING, - ProcessState::CONFIGURING_WORKSPACE, - ProcessState::INPUT_DATA_STAGING, - ProcessState::EXECUTING, - ProcessState::MONITORING, - ProcessState::OUTPUT_DATA_STAGING, - ProcessState::POST_PROCESSING, - ProcessState::COMPLETED, - ProcessState::FAILED, - ProcessState::CANCELLING, - ProcessState::CANCELED -}; -const char* _kProcessStateNames[] = { - "CREATED", - "VALIDATED", - "STARTED", - "PRE_PROCESSING", - "CONFIGURING_WORKSPACE", - "INPUT_DATA_STAGING", - "EXECUTING", - "MONITORING", - "OUTPUT_DATA_STAGING", - "POST_PROCESSING", - "COMPLETED", - "FAILED", - "CANCELLING", - "CANCELED" -}; -const std::map<int, const char*> _ProcessState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(14, _kProcessStateValues, _kProcessStateNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); - -int _kJobStateValues[] = { - JobState::SUBMITTED, - JobState::QUEUED, - JobState::ACTIVE, - JobState::COMPLETE, - JobState::CANCELED, - JobState::FAILED, - JobState::SUSPENDED, - JobState::UNKNOWN -}; -const char* _kJobStateNames[] = { - "SUBMITTED", - "QUEUED", - "ACTIVE", - "COMPLETE", - "CANCELED", - "FAILED", - "SUSPENDED", - "UNKNOWN" -}; -const std::map<int, const char*> _JobState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(8, _kJobStateValues, _kJobStateNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); - - -ExperimentStatus::~ExperimentStatus() throw() { -} - - -void ExperimentStatus::__set_state(const ExperimentState::type val) { - this->state = val; -} - -void ExperimentStatus::__set_timeOfStateChange(const int64_t val) { - this->timeOfStateChange = val; -__isset.timeOfStateChange = true; -} - -void ExperimentStatus::__set_reason(const std::string& val) { - this->reason = val; -__isset.reason = true; -} - -uint32_t ExperimentStatus::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_state = 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 ecast0; - xfer += iprot->readI32(ecast0); - this->state = (ExperimentState::type)ecast0; - isset_state = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->timeOfStateChange); - this->__isset.timeOfStateChange = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->reason); - this->__isset.reason = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_state) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t ExperimentStatus::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("ExperimentStatus"); - - xfer += oprot->writeFieldBegin("state", ::apache::thrift::protocol::T_I32, 1); - xfer += oprot->writeI32((int32_t)this->state); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.timeOfStateChange) { - xfer += oprot->writeFieldBegin("timeOfStateChange", ::apache::thrift::protocol::T_I64, 2); - xfer += oprot->writeI64(this->timeOfStateChange); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.reason) { - xfer += oprot->writeFieldBegin("reason", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->reason); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(ExperimentStatus &a, ExperimentStatus &b) { - using ::std::swap; - swap(a.state, b.state); - swap(a.timeOfStateChange, b.timeOfStateChange); - swap(a.reason, b.reason); - swap(a.__isset, b.__isset); -} - -ExperimentStatus::ExperimentStatus(const ExperimentStatus& other1) { - state = other1.state; - timeOfStateChange = other1.timeOfStateChange; - reason = other1.reason; - __isset = other1.__isset; -} -ExperimentStatus& ExperimentStatus::operator=(const ExperimentStatus& other2) { - state = other2.state; - timeOfStateChange = other2.timeOfStateChange; - reason = other2.reason; - __isset = other2.__isset; - return *this; -} -void ExperimentStatus::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "ExperimentStatus("; - out << "state=" << to_string(state); - out << ", " << "timeOfStateChange="; (__isset.timeOfStateChange ? (out << to_string(timeOfStateChange)) : (out << "<null>")); - out << ", " << "reason="; (__isset.reason ? (out << to_string(reason)) : (out << "<null>")); - out << ")"; -} - - -ProcessStatus::~ProcessStatus() throw() { -} - - -void ProcessStatus::__set_state(const ProcessState::type val) { - this->state = val; -} - -void ProcessStatus::__set_timeOfStateChange(const int64_t val) { - this->timeOfStateChange = val; -__isset.timeOfStateChange = true; -} - -void ProcessStatus::__set_reason(const std::string& val) { - this->reason = val; -__isset.reason = true; -} - -uint32_t ProcessStatus::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_state = 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 ecast3; - xfer += iprot->readI32(ecast3); - this->state = (ProcessState::type)ecast3; - isset_state = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->timeOfStateChange); - this->__isset.timeOfStateChange = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->reason); - this->__isset.reason = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_state) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t ProcessStatus::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("ProcessStatus"); - - xfer += oprot->writeFieldBegin("state", ::apache::thrift::protocol::T_I32, 1); - xfer += oprot->writeI32((int32_t)this->state); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.timeOfStateChange) { - xfer += oprot->writeFieldBegin("timeOfStateChange", ::apache::thrift::protocol::T_I64, 2); - xfer += oprot->writeI64(this->timeOfStateChange); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.reason) { - xfer += oprot->writeFieldBegin("reason", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->reason); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(ProcessStatus &a, ProcessStatus &b) { - using ::std::swap; - swap(a.state, b.state); - swap(a.timeOfStateChange, b.timeOfStateChange); - swap(a.reason, b.reason); - swap(a.__isset, b.__isset); -} - -ProcessStatus::ProcessStatus(const ProcessStatus& other4) { - state = other4.state; - timeOfStateChange = other4.timeOfStateChange; - reason = other4.reason; - __isset = other4.__isset; -} -ProcessStatus& ProcessStatus::operator=(const ProcessStatus& other5) { - state = other5.state; - timeOfStateChange = other5.timeOfStateChange; - reason = other5.reason; - __isset = other5.__isset; - return *this; -} -void ProcessStatus::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "ProcessStatus("; - out << "state=" << to_string(state); - out << ", " << "timeOfStateChange="; (__isset.timeOfStateChange ? (out << to_string(timeOfStateChange)) : (out << "<null>")); - out << ", " << "reason="; (__isset.reason ? (out << to_string(reason)) : (out << "<null>")); - out << ")"; -} - - -TaskStatus::~TaskStatus() throw() { -} - - -void TaskStatus::__set_state(const TaskState::type val) { - this->state = val; -} - -void TaskStatus::__set_timeOfStateChange(const int64_t val) { - this->timeOfStateChange = val; -__isset.timeOfStateChange = true; -} - -void TaskStatus::__set_reason(const std::string& val) { - this->reason = val; -__isset.reason = true; -} - -uint32_t TaskStatus::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_state = 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 ecast6; - xfer += iprot->readI32(ecast6); - this->state = (TaskState::type)ecast6; - isset_state = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->timeOfStateChange); - this->__isset.timeOfStateChange = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->reason); - this->__isset.reason = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_state) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t TaskStatus::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("TaskStatus"); - - xfer += oprot->writeFieldBegin("state", ::apache::thrift::protocol::T_I32, 1); - xfer += oprot->writeI32((int32_t)this->state); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.timeOfStateChange) { - xfer += oprot->writeFieldBegin("timeOfStateChange", ::apache::thrift::protocol::T_I64, 2); - xfer += oprot->writeI64(this->timeOfStateChange); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.reason) { - xfer += oprot->writeFieldBegin("reason", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->reason); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(TaskStatus &a, TaskStatus &b) { - using ::std::swap; - swap(a.state, b.state); - swap(a.timeOfStateChange, b.timeOfStateChange); - swap(a.reason, b.reason); - swap(a.__isset, b.__isset); -} - -TaskStatus::TaskStatus(const TaskStatus& other7) { - state = other7.state; - timeOfStateChange = other7.timeOfStateChange; - reason = other7.reason; - __isset = other7.__isset; -} -TaskStatus& TaskStatus::operator=(const TaskStatus& other8) { - state = other8.state; - timeOfStateChange = other8.timeOfStateChange; - reason = other8.reason; - __isset = other8.__isset; - return *this; -} -void TaskStatus::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "TaskStatus("; - out << "state=" << to_string(state); - out << ", " << "timeOfStateChange="; (__isset.timeOfStateChange ? (out << to_string(timeOfStateChange)) : (out << "<null>")); - out << ", " << "reason="; (__isset.reason ? (out << to_string(reason)) : (out << "<null>")); - out << ")"; -} - - -JobStatus::~JobStatus() throw() { -} - - -void JobStatus::__set_jobState(const JobState::type val) { - this->jobState = val; -} - -void JobStatus::__set_timeOfStateChange(const int64_t val) { - this->timeOfStateChange = val; -__isset.timeOfStateChange = true; -} - -void JobStatus::__set_reason(const std::string& val) { - this->reason = val; -__isset.reason = true; -} - -uint32_t JobStatus::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_jobState = 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 ecast9; - xfer += iprot->readI32(ecast9); - this->jobState = (JobState::type)ecast9; - isset_jobState = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->timeOfStateChange); - this->__isset.timeOfStateChange = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->reason); - this->__isset.reason = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_jobState) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t JobStatus::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("JobStatus"); - - xfer += oprot->writeFieldBegin("jobState", ::apache::thrift::protocol::T_I32, 1); - xfer += oprot->writeI32((int32_t)this->jobState); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.timeOfStateChange) { - xfer += oprot->writeFieldBegin("timeOfStateChange", ::apache::thrift::protocol::T_I64, 2); - xfer += oprot->writeI64(this->timeOfStateChange); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.reason) { - xfer += oprot->writeFieldBegin("reason", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->reason); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(JobStatus &a, JobStatus &b) { - using ::std::swap; - swap(a.jobState, b.jobState); - swap(a.timeOfStateChange, b.timeOfStateChange); - swap(a.reason, b.reason); - swap(a.__isset, b.__isset); -} - -JobStatus::JobStatus(const JobStatus& other10) { - jobState = other10.jobState; - timeOfStateChange = other10.timeOfStateChange; - reason = other10.reason; - __isset = other10.__isset; -} -JobStatus& JobStatus::operator=(const JobStatus& other11) { - jobState = other11.jobState; - timeOfStateChange = other11.timeOfStateChange; - reason = other11.reason; - __isset = other11.__isset; - return *this; -} -void JobStatus::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "JobStatus("; - out << "jobState=" << to_string(jobState); - out << ", " << "timeOfStateChange="; (__isset.timeOfStateChange ? (out << to_string(timeOfStateChange)) : (out << "<null>")); - out << ", " << "reason="; (__isset.reason ? (out << to_string(reason)) : (out << "<null>")); - out << ")"; -} - - -QueueStatusModel::~QueueStatusModel() throw() { -} - - -void QueueStatusModel::__set_hostName(const std::string& val) { - this->hostName = val; -} - -void QueueStatusModel::__set_queueName(const std::string& val) { - this->queueName = val; -} - -void QueueStatusModel::__set_queueUp(const bool val) { - this->queueUp = val; -} - -void QueueStatusModel::__set_runningJobs(const int32_t val) { - this->runningJobs = val; -} - -void QueueStatusModel::__set_queuedJobs(const int32_t val) { - this->queuedJobs = val; -} - -void QueueStatusModel::__set_time(const int64_t val) { - this->time = val; -} - -uint32_t QueueStatusModel::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_hostName = false; - bool isset_queueName = false; - bool isset_queueUp = false; - bool isset_runningJobs = false; - bool isset_queuedJobs = false; - bool isset_time = 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->hostName); - isset_hostName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->queueName); - isset_queueName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->queueUp); - isset_queueUp = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->runningJobs); - isset_runningJobs = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->queuedJobs); - isset_queuedJobs = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 6: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->time); - isset_time = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_hostName) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_queueName) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_queueUp) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_runningJobs) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_queuedJobs) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_time) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t QueueStatusModel::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("QueueStatusModel"); - - xfer += oprot->writeFieldBegin("hostName", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->hostName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("queueName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->queueName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("queueUp", ::apache::thrift::protocol::T_BOOL, 3); - xfer += oprot->writeBool(this->queueUp); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("runningJobs", ::apache::thrift::protocol::T_I32, 4); - xfer += oprot->writeI32(this->runningJobs); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("queuedJobs", ::apache::thrift::protocol::T_I32, 5); - xfer += oprot->writeI32(this->queuedJobs); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("time", ::apache::thrift::protocol::T_I64, 6); - xfer += oprot->writeI64(this->time); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(QueueStatusModel &a, QueueStatusModel &b) { - using ::std::swap; - swap(a.hostName, b.hostName); - swap(a.queueName, b.queueName); - swap(a.queueUp, b.queueUp); - swap(a.runningJobs, b.runningJobs); - swap(a.queuedJobs, b.queuedJobs); - swap(a.time, b.time); -} - -QueueStatusModel::QueueStatusModel(const QueueStatusModel& other12) { - hostName = other12.hostName; - queueName = other12.queueName; - queueUp = other12.queueUp; - runningJobs = other12.runningJobs; - queuedJobs = other12.queuedJobs; - time = other12.time; -} -QueueStatusModel& QueueStatusModel::operator=(const QueueStatusModel& other13) { - hostName = other13.hostName; - queueName = other13.queueName; - queueUp = other13.queueUp; - runningJobs = other13.runningJobs; - queuedJobs = other13.queuedJobs; - time = other13.time; - return *this; -} -void QueueStatusModel::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "QueueStatusModel("; - out << "hostName=" << to_string(hostName); - out << ", " << "queueName=" << to_string(queueName); - out << ", " << "queueUp=" << to_string(queueUp); - out << ", " << "runningJobs=" << to_string(runningJobs); - out << ", " << "queuedJobs=" << to_string(queuedJobs); - out << ", " << "time=" << to_string(time); - out << ")"; -} - -}}}} // namespace
