You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/12/13 22:09:32 UTC
[19/51] [partial] airavata-php-gateway git commit: removing files
from wrong merge
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