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/compute_resource_model_types.cpp
----------------------------------------------------------------------
diff --git
a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
deleted file mode 100644
index 8f88e12..0000000
---
a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
+++ /dev/null
@@ -1,2222 +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 "compute_resource_model_types.h"
-
-#include <algorithm>
-#include <ostream>
-
-#include <thrift/TToString.h>
-
-namespace apache { namespace airavata { namespace model { namespace appcatalog
{ namespace computeresource {
-
-int _kResourceJobManagerTypeValues[] = {
- ResourceJobManagerType::FORK,
- ResourceJobManagerType::PBS,
- ResourceJobManagerType::SLURM,
- ResourceJobManagerType::LSF,
- ResourceJobManagerType::UGE,
- ResourceJobManagerType::CLOUD
-};
-const char* _kResourceJobManagerTypeNames[] = {
- "FORK",
- "PBS",
- "SLURM",
- "LSF",
- "UGE",
- "CLOUD"
-};
-const std::map<int, const char*>
_ResourceJobManagerType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(6,
_kResourceJobManagerTypeValues, _kResourceJobManagerTypeNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kJobManagerCommandValues[] = {
- JobManagerCommand::SUBMISSION,
- JobManagerCommand::JOB_MONITORING,
- JobManagerCommand::DELETION,
- JobManagerCommand::CHECK_JOB,
- JobManagerCommand::SHOW_QUEUE,
- JobManagerCommand::SHOW_RESERVATION,
- JobManagerCommand::SHOW_START
-};
-const char* _kJobManagerCommandNames[] = {
- "SUBMISSION",
- "JOB_MONITORING",
- "DELETION",
- "CHECK_JOB",
- "SHOW_QUEUE",
- "SHOW_RESERVATION",
- "SHOW_START"
-};
-const std::map<int, const char*>
_JobManagerCommand_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(7,
_kJobManagerCommandValues, _kJobManagerCommandNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kFileSystemsValues[] = {
- FileSystems::HOME,
- FileSystems::WORK,
- FileSystems::LOCALTMP,
- FileSystems::SCRATCH,
- FileSystems::ARCHIVE
-};
-const char* _kFileSystemsNames[] = {
- "HOME",
- "WORK",
- "LOCALTMP",
- "SCRATCH",
- "ARCHIVE"
-};
-const std::map<int, const char*>
_FileSystems_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(5,
_kFileSystemsValues, _kFileSystemsNames), ::apache::thrift::TEnumIterator(-1,
NULL, NULL));
-
-int _kJobSubmissionProtocolValues[] = {
- JobSubmissionProtocol::LOCAL,
- JobSubmissionProtocol::SSH,
- JobSubmissionProtocol::GLOBUS,
- JobSubmissionProtocol::UNICORE,
- JobSubmissionProtocol::CLOUD,
- JobSubmissionProtocol::SSH_FORK,
- JobSubmissionProtocol::LOCAL_FORK
-};
-const char* _kJobSubmissionProtocolNames[] = {
- "LOCAL",
- "SSH",
- "GLOBUS",
- "UNICORE",
- "CLOUD",
- "SSH_FORK",
- "LOCAL_FORK"
-};
-const std::map<int, const char*>
_JobSubmissionProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(7,
_kJobSubmissionProtocolValues, _kJobSubmissionProtocolNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kMonitorModeValues[] = {
- MonitorMode::POLL_JOB_MANAGER,
- MonitorMode::CLOUD_JOB_MONITOR,
- MonitorMode::JOB_EMAIL_NOTIFICATION_MONITOR,
- MonitorMode::XSEDE_AMQP_SUBSCRIBE,
- MonitorMode::FORK,
- MonitorMode::LOCAL
-};
-const char* _kMonitorModeNames[] = {
- "POLL_JOB_MANAGER",
- "CLOUD_JOB_MONITOR",
- "JOB_EMAIL_NOTIFICATION_MONITOR",
- "XSEDE_AMQP_SUBSCRIBE",
- "FORK",
- "LOCAL"
-};
-const std::map<int, const char*>
_MonitorMode_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(6,
_kMonitorModeValues, _kMonitorModeNames), ::apache::thrift::TEnumIterator(-1,
NULL, NULL));
-
-int _kDMTypeValues[] = {
- DMType::COMPUTE_RESOURCE,
- DMType::STORAGE_RESOURCE
-};
-const char* _kDMTypeNames[] = {
- "COMPUTE_RESOURCE",
- "STORAGE_RESOURCE"
-};
-const std::map<int, const char*>
_DMType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kDMTypeValues,
_kDMTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kProviderNameValues[] = {
- ProviderName::EC2,
- ProviderName::AWSEC2,
- ProviderName::RACKSPACE
-};
-const char* _kProviderNameNames[] = {
- "EC2",
- "AWSEC2",
- "RACKSPACE"
-};
-const std::map<int, const char*>
_ProviderName_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3,
_kProviderNameValues, _kProviderNameNames), ::apache::thrift::TEnumIterator(-1,
NULL, NULL));
-
-
-ResourceJobManager::~ResourceJobManager() throw() {
-}
-
-
-void ResourceJobManager::__set_resourceJobManagerId(const std::string& val) {
- this->resourceJobManagerId = val;
-}
-
-void ResourceJobManager::__set_resourceJobManagerType(const
ResourceJobManagerType::type val) {
- this->resourceJobManagerType = val;
-}
-
-void ResourceJobManager::__set_pushMonitoringEndpoint(const std::string& val) {
- this->pushMonitoringEndpoint = val;
-__isset.pushMonitoringEndpoint = true;
-}
-
-void ResourceJobManager::__set_jobManagerBinPath(const std::string& val) {
- this->jobManagerBinPath = val;
-__isset.jobManagerBinPath = true;
-}
-
-void ResourceJobManager::__set_jobManagerCommands(const
std::map<JobManagerCommand::type, std::string> & val) {
- this->jobManagerCommands = val;
-__isset.jobManagerCommands = true;
-}
-
-void ResourceJobManager::__set_parallelismPrefix(const std::map<
::apache::airavata::model::appcatalog::parallelism::ApplicationParallelismType::type,
std::string> & val) {
- this->parallelismPrefix = val;
-__isset.parallelismPrefix = true;
-}
-
-uint32_t ResourceJobManager::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_resourceJobManagerId = false;
- bool isset_resourceJobManagerType = 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->resourceJobManagerId);
- isset_resourceJobManagerId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast0;
- xfer += iprot->readI32(ecast0);
- this->resourceJobManagerType = (ResourceJobManagerType::type)ecast0;
- isset_resourceJobManagerType = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->pushMonitoringEndpoint);
- this->__isset.pushMonitoringEndpoint = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobManagerBinPath);
- this->__isset.jobManagerBinPath = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_MAP) {
- {
- this->jobManagerCommands.clear();
- uint32_t _size1;
- ::apache::thrift::protocol::TType _ktype2;
- ::apache::thrift::protocol::TType _vtype3;
- xfer += iprot->readMapBegin(_ktype2, _vtype3, _size1);
- uint32_t _i5;
- for (_i5 = 0; _i5 < _size1; ++_i5)
- {
- JobManagerCommand::type _key6;
- int32_t ecast8;
- xfer += iprot->readI32(ecast8);
- _key6 = (JobManagerCommand::type)ecast8;
- std::string& _val7 = this->jobManagerCommands[_key6];
- xfer += iprot->readString(_val7);
- }
- xfer += iprot->readMapEnd();
- }
- this->__isset.jobManagerCommands = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_MAP) {
- {
- this->parallelismPrefix.clear();
- uint32_t _size9;
- ::apache::thrift::protocol::TType _ktype10;
- ::apache::thrift::protocol::TType _vtype11;
- xfer += iprot->readMapBegin(_ktype10, _vtype11, _size9);
- uint32_t _i13;
- for (_i13 = 0; _i13 < _size9; ++_i13)
- {
-
::apache::airavata::model::appcatalog::parallelism::ApplicationParallelismType::type
_key14;
- int32_t ecast16;
- xfer += iprot->readI32(ecast16);
- _key14 = (
::apache::airavata::model::appcatalog::parallelism::ApplicationParallelismType::type)ecast16;
- std::string& _val15 = this->parallelismPrefix[_key14];
- xfer += iprot->readString(_val15);
- }
- xfer += iprot->readMapEnd();
- }
- this->__isset.parallelismPrefix = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_resourceJobManagerId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceJobManagerType)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t ResourceJobManager::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("ResourceJobManager");
-
- xfer += oprot->writeFieldBegin("resourceJobManagerId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->resourceJobManagerId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManagerType",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->resourceJobManagerType);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.pushMonitoringEndpoint) {
- xfer += oprot->writeFieldBegin("pushMonitoringEndpoint",
::apache::thrift::protocol::T_STRING, 3);
- xfer += oprot->writeString(this->pushMonitoringEndpoint);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.jobManagerBinPath) {
- xfer += oprot->writeFieldBegin("jobManagerBinPath",
::apache::thrift::protocol::T_STRING, 4);
- xfer += oprot->writeString(this->jobManagerBinPath);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.jobManagerCommands) {
- xfer += oprot->writeFieldBegin("jobManagerCommands",
::apache::thrift::protocol::T_MAP, 5);
- {
- xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_I32,
::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->jobManagerCommands.size()));
- std::map<JobManagerCommand::type, std::string> ::const_iterator _iter17;
- for (_iter17 = this->jobManagerCommands.begin(); _iter17 !=
this->jobManagerCommands.end(); ++_iter17)
- {
- xfer += oprot->writeI32((int32_t)_iter17->first);
- xfer += oprot->writeString(_iter17->second);
- }
- xfer += oprot->writeMapEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.parallelismPrefix) {
- xfer += oprot->writeFieldBegin("parallelismPrefix",
::apache::thrift::protocol::T_MAP, 6);
- {
- xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_I32,
::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->parallelismPrefix.size()));
- std::map<
::apache::airavata::model::appcatalog::parallelism::ApplicationParallelismType::type,
std::string> ::const_iterator _iter18;
- for (_iter18 = this->parallelismPrefix.begin(); _iter18 !=
this->parallelismPrefix.end(); ++_iter18)
- {
- xfer += oprot->writeI32((int32_t)_iter18->first);
- xfer += oprot->writeString(_iter18->second);
- }
- xfer += oprot->writeMapEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(ResourceJobManager &a, ResourceJobManager &b) {
- using ::std::swap;
- swap(a.resourceJobManagerId, b.resourceJobManagerId);
- swap(a.resourceJobManagerType, b.resourceJobManagerType);
- swap(a.pushMonitoringEndpoint, b.pushMonitoringEndpoint);
- swap(a.jobManagerBinPath, b.jobManagerBinPath);
- swap(a.jobManagerCommands, b.jobManagerCommands);
- swap(a.parallelismPrefix, b.parallelismPrefix);
- swap(a.__isset, b.__isset);
-}
-
-ResourceJobManager::ResourceJobManager(const ResourceJobManager& other19) {
- resourceJobManagerId = other19.resourceJobManagerId;
- resourceJobManagerType = other19.resourceJobManagerType;
- pushMonitoringEndpoint = other19.pushMonitoringEndpoint;
- jobManagerBinPath = other19.jobManagerBinPath;
- jobManagerCommands = other19.jobManagerCommands;
- parallelismPrefix = other19.parallelismPrefix;
- __isset = other19.__isset;
-}
-ResourceJobManager& ResourceJobManager::operator=(const ResourceJobManager&
other20) {
- resourceJobManagerId = other20.resourceJobManagerId;
- resourceJobManagerType = other20.resourceJobManagerType;
- pushMonitoringEndpoint = other20.pushMonitoringEndpoint;
- jobManagerBinPath = other20.jobManagerBinPath;
- jobManagerCommands = other20.jobManagerCommands;
- parallelismPrefix = other20.parallelismPrefix;
- __isset = other20.__isset;
- return *this;
-}
-void ResourceJobManager::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "ResourceJobManager(";
- out << "resourceJobManagerId=" << to_string(resourceJobManagerId);
- out << ", " << "resourceJobManagerType=" <<
to_string(resourceJobManagerType);
- out << ", " << "pushMonitoringEndpoint="; (__isset.pushMonitoringEndpoint ?
(out << to_string(pushMonitoringEndpoint)) : (out << "<null>"));
- out << ", " << "jobManagerBinPath="; (__isset.jobManagerBinPath ? (out <<
to_string(jobManagerBinPath)) : (out << "<null>"));
- out << ", " << "jobManagerCommands="; (__isset.jobManagerCommands ? (out <<
to_string(jobManagerCommands)) : (out << "<null>"));
- out << ", " << "parallelismPrefix="; (__isset.parallelismPrefix ? (out <<
to_string(parallelismPrefix)) : (out << "<null>"));
- out << ")";
-}
-
-
-BatchQueue::~BatchQueue() throw() {
-}
-
-
-void BatchQueue::__set_queueName(const std::string& val) {
- this->queueName = val;
-}
-
-void BatchQueue::__set_queueDescription(const std::string& val) {
- this->queueDescription = val;
-__isset.queueDescription = true;
-}
-
-void BatchQueue::__set_maxRunTime(const int32_t val) {
- this->maxRunTime = val;
-__isset.maxRunTime = true;
-}
-
-void BatchQueue::__set_maxNodes(const int32_t val) {
- this->maxNodes = val;
-__isset.maxNodes = true;
-}
-
-void BatchQueue::__set_maxProcessors(const int32_t val) {
- this->maxProcessors = val;
-__isset.maxProcessors = true;
-}
-
-void BatchQueue::__set_maxJobsInQueue(const int32_t val) {
- this->maxJobsInQueue = val;
-__isset.maxJobsInQueue = true;
-}
-
-void BatchQueue::__set_maxMemory(const int32_t val) {
- this->maxMemory = val;
-__isset.maxMemory = true;
-}
-
-void BatchQueue::__set_cpuPerNode(const int32_t val) {
- this->cpuPerNode = val;
-__isset.cpuPerNode = true;
-}
-
-void BatchQueue::__set_defaultNodeCount(const int32_t val) {
- this->defaultNodeCount = val;
-__isset.defaultNodeCount = true;
-}
-
-void BatchQueue::__set_defaultCPUCount(const int32_t val) {
- this->defaultCPUCount = val;
-__isset.defaultCPUCount = true;
-}
-
-void BatchQueue::__set_isDefaultQueue(const bool val) {
- this->isDefaultQueue = val;
-__isset.isDefaultQueue = true;
-}
-
-uint32_t BatchQueue::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_queueName = 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->queueName);
- isset_queueName = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->queueDescription);
- this->__isset.queueDescription = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->maxRunTime);
- this->__isset.maxRunTime = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->maxNodes);
- this->__isset.maxNodes = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->maxProcessors);
- this->__isset.maxProcessors = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->maxJobsInQueue);
- this->__isset.maxJobsInQueue = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->maxMemory);
- this->__isset.maxMemory = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->cpuPerNode);
- this->__isset.cpuPerNode = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 9:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->defaultNodeCount);
- this->__isset.defaultNodeCount = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 10:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->defaultCPUCount);
- this->__isset.defaultCPUCount = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 11:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->isDefaultQueue);
- this->__isset.isDefaultQueue = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_queueName)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t BatchQueue::write(::apache::thrift::protocol::TProtocol* oprot) const
{
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("BatchQueue");
-
- xfer += oprot->writeFieldBegin("queueName",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->queueName);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.queueDescription) {
- xfer += oprot->writeFieldBegin("queueDescription",
::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->queueDescription);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.maxRunTime) {
- xfer += oprot->writeFieldBegin("maxRunTime",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->maxRunTime);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.maxNodes) {
- xfer += oprot->writeFieldBegin("maxNodes",
::apache::thrift::protocol::T_I32, 4);
- xfer += oprot->writeI32(this->maxNodes);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.maxProcessors) {
- xfer += oprot->writeFieldBegin("maxProcessors",
::apache::thrift::protocol::T_I32, 5);
- xfer += oprot->writeI32(this->maxProcessors);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.maxJobsInQueue) {
- xfer += oprot->writeFieldBegin("maxJobsInQueue",
::apache::thrift::protocol::T_I32, 6);
- xfer += oprot->writeI32(this->maxJobsInQueue);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.maxMemory) {
- xfer += oprot->writeFieldBegin("maxMemory",
::apache::thrift::protocol::T_I32, 7);
- xfer += oprot->writeI32(this->maxMemory);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.cpuPerNode) {
- xfer += oprot->writeFieldBegin("cpuPerNode",
::apache::thrift::protocol::T_I32, 8);
- xfer += oprot->writeI32(this->cpuPerNode);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.defaultNodeCount) {
- xfer += oprot->writeFieldBegin("defaultNodeCount",
::apache::thrift::protocol::T_I32, 9);
- xfer += oprot->writeI32(this->defaultNodeCount);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.defaultCPUCount) {
- xfer += oprot->writeFieldBegin("defaultCPUCount",
::apache::thrift::protocol::T_I32, 10);
- xfer += oprot->writeI32(this->defaultCPUCount);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.isDefaultQueue) {
- xfer += oprot->writeFieldBegin("isDefaultQueue",
::apache::thrift::protocol::T_BOOL, 11);
- xfer += oprot->writeBool(this->isDefaultQueue);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(BatchQueue &a, BatchQueue &b) {
- using ::std::swap;
- swap(a.queueName, b.queueName);
- swap(a.queueDescription, b.queueDescription);
- swap(a.maxRunTime, b.maxRunTime);
- swap(a.maxNodes, b.maxNodes);
- swap(a.maxProcessors, b.maxProcessors);
- swap(a.maxJobsInQueue, b.maxJobsInQueue);
- swap(a.maxMemory, b.maxMemory);
- swap(a.cpuPerNode, b.cpuPerNode);
- swap(a.defaultNodeCount, b.defaultNodeCount);
- swap(a.defaultCPUCount, b.defaultCPUCount);
- swap(a.isDefaultQueue, b.isDefaultQueue);
- swap(a.__isset, b.__isset);
-}
-
-BatchQueue::BatchQueue(const BatchQueue& other21) {
- queueName = other21.queueName;
- queueDescription = other21.queueDescription;
- maxRunTime = other21.maxRunTime;
- maxNodes = other21.maxNodes;
- maxProcessors = other21.maxProcessors;
- maxJobsInQueue = other21.maxJobsInQueue;
- maxMemory = other21.maxMemory;
- cpuPerNode = other21.cpuPerNode;
- defaultNodeCount = other21.defaultNodeCount;
- defaultCPUCount = other21.defaultCPUCount;
- isDefaultQueue = other21.isDefaultQueue;
- __isset = other21.__isset;
-}
-BatchQueue& BatchQueue::operator=(const BatchQueue& other22) {
- queueName = other22.queueName;
- queueDescription = other22.queueDescription;
- maxRunTime = other22.maxRunTime;
- maxNodes = other22.maxNodes;
- maxProcessors = other22.maxProcessors;
- maxJobsInQueue = other22.maxJobsInQueue;
- maxMemory = other22.maxMemory;
- cpuPerNode = other22.cpuPerNode;
- defaultNodeCount = other22.defaultNodeCount;
- defaultCPUCount = other22.defaultCPUCount;
- isDefaultQueue = other22.isDefaultQueue;
- __isset = other22.__isset;
- return *this;
-}
-void BatchQueue::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "BatchQueue(";
- out << "queueName=" << to_string(queueName);
- out << ", " << "queueDescription="; (__isset.queueDescription ? (out <<
to_string(queueDescription)) : (out << "<null>"));
- out << ", " << "maxRunTime="; (__isset.maxRunTime ? (out <<
to_string(maxRunTime)) : (out << "<null>"));
- out << ", " << "maxNodes="; (__isset.maxNodes ? (out << to_string(maxNodes))
: (out << "<null>"));
- out << ", " << "maxProcessors="; (__isset.maxProcessors ? (out <<
to_string(maxProcessors)) : (out << "<null>"));
- out << ", " << "maxJobsInQueue="; (__isset.maxJobsInQueue ? (out <<
to_string(maxJobsInQueue)) : (out << "<null>"));
- out << ", " << "maxMemory="; (__isset.maxMemory ? (out <<
to_string(maxMemory)) : (out << "<null>"));
- out << ", " << "cpuPerNode="; (__isset.cpuPerNode ? (out <<
to_string(cpuPerNode)) : (out << "<null>"));
- out << ", " << "defaultNodeCount="; (__isset.defaultNodeCount ? (out <<
to_string(defaultNodeCount)) : (out << "<null>"));
- out << ", " << "defaultCPUCount="; (__isset.defaultCPUCount ? (out <<
to_string(defaultCPUCount)) : (out << "<null>"));
- out << ", " << "isDefaultQueue="; (__isset.isDefaultQueue ? (out <<
to_string(isDefaultQueue)) : (out << "<null>"));
- out << ")";
-}
-
-
-LOCALSubmission::~LOCALSubmission() throw() {
-}
-
-
-void LOCALSubmission::__set_jobSubmissionInterfaceId(const std::string& val) {
- this->jobSubmissionInterfaceId = val;
-}
-
-void LOCALSubmission::__set_resourceJobManager(const ResourceJobManager& val) {
- this->resourceJobManager = val;
-}
-
-void LOCALSubmission::__set_securityProtocol(const
::apache::airavata::model::data::movement::SecurityProtocol::type val) {
- this->securityProtocol = val;
-}
-
-uint32_t LOCALSubmission::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_jobSubmissionInterfaceId = false;
- bool isset_resourceJobManager = false;
- bool isset_securityProtocol = 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->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->resourceJobManager.read(iprot);
- isset_resourceJobManager = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast23;
- xfer += iprot->readI32(ecast23);
- this->securityProtocol = (
::apache::airavata::model::data::movement::SecurityProtocol::type)ecast23;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceJobManager)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t LOCALSubmission::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("LOCALSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManager",
::apache::thrift::protocol::T_STRUCT, 2);
- xfer += this->resourceJobManager.write(oprot);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(LOCALSubmission &a, LOCALSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.resourceJobManager, b.resourceJobManager);
- swap(a.securityProtocol, b.securityProtocol);
-}
-
-LOCALSubmission::LOCALSubmission(const LOCALSubmission& other24) {
- jobSubmissionInterfaceId = other24.jobSubmissionInterfaceId;
- resourceJobManager = other24.resourceJobManager;
- securityProtocol = other24.securityProtocol;
-}
-LOCALSubmission& LOCALSubmission::operator=(const LOCALSubmission& other25) {
- jobSubmissionInterfaceId = other25.jobSubmissionInterfaceId;
- resourceJobManager = other25.resourceJobManager;
- securityProtocol = other25.securityProtocol;
- return *this;
-}
-void LOCALSubmission::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "LOCALSubmission(";
- out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "resourceJobManager=" << to_string(resourceJobManager);
- out << ", " << "securityProtocol=" << to_string(securityProtocol);
- out << ")";
-}
-
-
-SSHJobSubmission::~SSHJobSubmission() throw() {
-}
-
-
-void SSHJobSubmission::__set_jobSubmissionInterfaceId(const std::string& val) {
- this->jobSubmissionInterfaceId = val;
-}
-
-void SSHJobSubmission::__set_securityProtocol(const
::apache::airavata::model::data::movement::SecurityProtocol::type val) {
- this->securityProtocol = val;
-}
-
-void SSHJobSubmission::__set_resourceJobManager(const ResourceJobManager& val)
{
- this->resourceJobManager = val;
-}
-
-void SSHJobSubmission::__set_alternativeSSHHostName(const std::string& val) {
- this->alternativeSSHHostName = val;
-__isset.alternativeSSHHostName = true;
-}
-
-void SSHJobSubmission::__set_sshPort(const int32_t val) {
- this->sshPort = val;
-__isset.sshPort = true;
-}
-
-void SSHJobSubmission::__set_monitorMode(const MonitorMode::type val) {
- this->monitorMode = val;
-__isset.monitorMode = true;
-}
-
-void SSHJobSubmission::__set_batchQueueEmailSenders(const
std::vector<std::string> & val) {
- this->batchQueueEmailSenders = val;
-__isset.batchQueueEmailSenders = true;
-}
-
-uint32_t SSHJobSubmission::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_jobSubmissionInterfaceId = false;
- bool isset_securityProtocol = false;
- bool isset_resourceJobManager = 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->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast26;
- xfer += iprot->readI32(ecast26);
- this->securityProtocol = (
::apache::airavata::model::data::movement::SecurityProtocol::type)ecast26;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->resourceJobManager.read(iprot);
- isset_resourceJobManager = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->alternativeSSHHostName);
- this->__isset.alternativeSSHHostName = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->sshPort);
- this->__isset.sshPort = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast27;
- xfer += iprot->readI32(ecast27);
- this->monitorMode = (MonitorMode::type)ecast27;
- this->__isset.monitorMode = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->batchQueueEmailSenders.clear();
- uint32_t _size28;
- ::apache::thrift::protocol::TType _etype31;
- xfer += iprot->readListBegin(_etype31, _size28);
- this->batchQueueEmailSenders.resize(_size28);
- uint32_t _i32;
- for (_i32 = 0; _i32 < _size28; ++_i32)
- {
- xfer += iprot->readString(this->batchQueueEmailSenders[_i32]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.batchQueueEmailSenders = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_resourceJobManager)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t SSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("SSHJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManager",
::apache::thrift::protocol::T_STRUCT, 3);
- xfer += this->resourceJobManager.write(oprot);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.alternativeSSHHostName) {
- xfer += oprot->writeFieldBegin("alternativeSSHHostName",
::apache::thrift::protocol::T_STRING, 4);
- xfer += oprot->writeString(this->alternativeSSHHostName);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.sshPort) {
- xfer += oprot->writeFieldBegin("sshPort",
::apache::thrift::protocol::T_I32, 5);
- xfer += oprot->writeI32(this->sshPort);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.monitorMode) {
- xfer += oprot->writeFieldBegin("monitorMode",
::apache::thrift::protocol::T_I32, 6);
- xfer += oprot->writeI32((int32_t)this->monitorMode);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.batchQueueEmailSenders) {
- xfer += oprot->writeFieldBegin("batchQueueEmailSenders",
::apache::thrift::protocol::T_LIST, 7);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->batchQueueEmailSenders.size()));
- std::vector<std::string> ::const_iterator _iter33;
- for (_iter33 = this->batchQueueEmailSenders.begin(); _iter33 !=
this->batchQueueEmailSenders.end(); ++_iter33)
- {
- xfer += oprot->writeString((*_iter33));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(SSHJobSubmission &a, SSHJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.resourceJobManager, b.resourceJobManager);
- swap(a.alternativeSSHHostName, b.alternativeSSHHostName);
- swap(a.sshPort, b.sshPort);
- swap(a.monitorMode, b.monitorMode);
- swap(a.batchQueueEmailSenders, b.batchQueueEmailSenders);
- swap(a.__isset, b.__isset);
-}
-
-SSHJobSubmission::SSHJobSubmission(const SSHJobSubmission& other34) {
- jobSubmissionInterfaceId = other34.jobSubmissionInterfaceId;
- securityProtocol = other34.securityProtocol;
- resourceJobManager = other34.resourceJobManager;
- alternativeSSHHostName = other34.alternativeSSHHostName;
- sshPort = other34.sshPort;
- monitorMode = other34.monitorMode;
- batchQueueEmailSenders = other34.batchQueueEmailSenders;
- __isset = other34.__isset;
-}
-SSHJobSubmission& SSHJobSubmission::operator=(const SSHJobSubmission& other35)
{
- jobSubmissionInterfaceId = other35.jobSubmissionInterfaceId;
- securityProtocol = other35.securityProtocol;
- resourceJobManager = other35.resourceJobManager;
- alternativeSSHHostName = other35.alternativeSSHHostName;
- sshPort = other35.sshPort;
- monitorMode = other35.monitorMode;
- batchQueueEmailSenders = other35.batchQueueEmailSenders;
- __isset = other35.__isset;
- return *this;
-}
-void SSHJobSubmission::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "SSHJobSubmission(";
- out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "securityProtocol=" << to_string(securityProtocol);
- out << ", " << "resourceJobManager=" << to_string(resourceJobManager);
- out << ", " << "alternativeSSHHostName="; (__isset.alternativeSSHHostName ?
(out << to_string(alternativeSSHHostName)) : (out << "<null>"));
- out << ", " << "sshPort="; (__isset.sshPort ? (out << to_string(sshPort)) :
(out << "<null>"));
- out << ", " << "monitorMode="; (__isset.monitorMode ? (out <<
to_string(monitorMode)) : (out << "<null>"));
- out << ", " << "batchQueueEmailSenders="; (__isset.batchQueueEmailSenders ?
(out << to_string(batchQueueEmailSenders)) : (out << "<null>"));
- out << ")";
-}
-
-
-GlobusJobSubmission::~GlobusJobSubmission() throw() {
-}
-
-
-void GlobusJobSubmission::__set_jobSubmissionInterfaceId(const std::string&
val) {
- this->jobSubmissionInterfaceId = val;
-}
-
-void GlobusJobSubmission::__set_securityProtocol(const
::apache::airavata::model::data::movement::SecurityProtocol::type val) {
- this->securityProtocol = val;
-}
-
-void GlobusJobSubmission::__set_globusGateKeeperEndPoint(const
std::vector<std::string> & val) {
- this->globusGateKeeperEndPoint = val;
-__isset.globusGateKeeperEndPoint = true;
-}
-
-uint32_t GlobusJobSubmission::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_jobSubmissionInterfaceId = false;
- bool isset_securityProtocol = 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->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast36;
- xfer += iprot->readI32(ecast36);
- this->securityProtocol = (
::apache::airavata::model::data::movement::SecurityProtocol::type)ecast36;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->globusGateKeeperEndPoint.clear();
- uint32_t _size37;
- ::apache::thrift::protocol::TType _etype40;
- xfer += iprot->readListBegin(_etype40, _size37);
- this->globusGateKeeperEndPoint.resize(_size37);
- uint32_t _i41;
- for (_i41 = 0; _i41 < _size37; ++_i41)
- {
- xfer += iprot->readString(this->globusGateKeeperEndPoint[_i41]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.globusGateKeeperEndPoint = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t GlobusJobSubmission::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("GlobusJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.globusGateKeeperEndPoint) {
- xfer += oprot->writeFieldBegin("globusGateKeeperEndPoint",
::apache::thrift::protocol::T_LIST, 3);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->globusGateKeeperEndPoint.size()));
- std::vector<std::string> ::const_iterator _iter42;
- for (_iter42 = this->globusGateKeeperEndPoint.begin(); _iter42 !=
this->globusGateKeeperEndPoint.end(); ++_iter42)
- {
- xfer += oprot->writeString((*_iter42));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(GlobusJobSubmission &a, GlobusJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.globusGateKeeperEndPoint, b.globusGateKeeperEndPoint);
- swap(a.__isset, b.__isset);
-}
-
-GlobusJobSubmission::GlobusJobSubmission(const GlobusJobSubmission& other43) {
- jobSubmissionInterfaceId = other43.jobSubmissionInterfaceId;
- securityProtocol = other43.securityProtocol;
- globusGateKeeperEndPoint = other43.globusGateKeeperEndPoint;
- __isset = other43.__isset;
-}
-GlobusJobSubmission& GlobusJobSubmission::operator=(const GlobusJobSubmission&
other44) {
- jobSubmissionInterfaceId = other44.jobSubmissionInterfaceId;
- securityProtocol = other44.securityProtocol;
- globusGateKeeperEndPoint = other44.globusGateKeeperEndPoint;
- __isset = other44.__isset;
- return *this;
-}
-void GlobusJobSubmission::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "GlobusJobSubmission(";
- out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "securityProtocol=" << to_string(securityProtocol);
- out << ", " << "globusGateKeeperEndPoint=";
(__isset.globusGateKeeperEndPoint ? (out <<
to_string(globusGateKeeperEndPoint)) : (out << "<null>"));
- out << ")";
-}
-
-
-UnicoreJobSubmission::~UnicoreJobSubmission() throw() {
-}
-
-
-void UnicoreJobSubmission::__set_jobSubmissionInterfaceId(const std::string&
val) {
- this->jobSubmissionInterfaceId = val;
-}
-
-void UnicoreJobSubmission::__set_securityProtocol(const
::apache::airavata::model::data::movement::SecurityProtocol::type val) {
- this->securityProtocol = val;
-}
-
-void UnicoreJobSubmission::__set_unicoreEndPointURL(const std::string& val) {
- this->unicoreEndPointURL = val;
-}
-
-uint32_t UnicoreJobSubmission::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_jobSubmissionInterfaceId = false;
- bool isset_securityProtocol = false;
- bool isset_unicoreEndPointURL = 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->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast45;
- xfer += iprot->readI32(ecast45);
- this->securityProtocol = (
::apache::airavata::model::data::movement::SecurityProtocol::type)ecast45;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->unicoreEndPointURL);
- isset_unicoreEndPointURL = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_unicoreEndPointURL)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t UnicoreJobSubmission::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("UnicoreJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("unicoreEndPointURL",
::apache::thrift::protocol::T_STRING, 3);
- xfer += oprot->writeString(this->unicoreEndPointURL);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(UnicoreJobSubmission &a, UnicoreJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.unicoreEndPointURL, b.unicoreEndPointURL);
-}
-
-UnicoreJobSubmission::UnicoreJobSubmission(const UnicoreJobSubmission&
other46) {
- jobSubmissionInterfaceId = other46.jobSubmissionInterfaceId;
- securityProtocol = other46.securityProtocol;
- unicoreEndPointURL = other46.unicoreEndPointURL;
-}
-UnicoreJobSubmission& UnicoreJobSubmission::operator=(const
UnicoreJobSubmission& other47) {
- jobSubmissionInterfaceId = other47.jobSubmissionInterfaceId;
- securityProtocol = other47.securityProtocol;
- unicoreEndPointURL = other47.unicoreEndPointURL;
- return *this;
-}
-void UnicoreJobSubmission::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "UnicoreJobSubmission(";
- out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "securityProtocol=" << to_string(securityProtocol);
- out << ", " << "unicoreEndPointURL=" << to_string(unicoreEndPointURL);
- out << ")";
-}
-
-
-CloudJobSubmission::~CloudJobSubmission() throw() {
-}
-
-
-void CloudJobSubmission::__set_jobSubmissionInterfaceId(const std::string&
val) {
- this->jobSubmissionInterfaceId = val;
-}
-
-void CloudJobSubmission::__set_securityProtocol(const
::apache::airavata::model::data::movement::SecurityProtocol::type val) {
- this->securityProtocol = val;
-}
-
-void CloudJobSubmission::__set_nodeId(const std::string& val) {
- this->nodeId = val;
-}
-
-void CloudJobSubmission::__set_executableType(const std::string& val) {
- this->executableType = val;
-}
-
-void CloudJobSubmission::__set_providerName(const ProviderName::type val) {
- this->providerName = val;
-}
-
-void CloudJobSubmission::__set_userAccountName(const std::string& val) {
- this->userAccountName = val;
-}
-
-uint32_t CloudJobSubmission::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_jobSubmissionInterfaceId = false;
- bool isset_securityProtocol = false;
- bool isset_nodeId = false;
- bool isset_executableType = false;
- bool isset_providerName = false;
- bool isset_userAccountName = 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->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast48;
- xfer += iprot->readI32(ecast48);
- this->securityProtocol = (
::apache::airavata::model::data::movement::SecurityProtocol::type)ecast48;
- isset_securityProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->nodeId);
- isset_nodeId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->executableType);
- isset_executableType = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast49;
- xfer += iprot->readI32(ecast49);
- this->providerName = (ProviderName::type)ecast49;
- isset_providerName = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->userAccountName);
- isset_userAccountName = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_nodeId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_executableType)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_providerName)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_userAccountName)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t CloudJobSubmission::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("CloudJobSubmission");
-
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("securityProtocol",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("nodeId",
::apache::thrift::protocol::T_STRING, 3);
- xfer += oprot->writeString(this->nodeId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("executableType",
::apache::thrift::protocol::T_STRING, 4);
- xfer += oprot->writeString(this->executableType);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("providerName",
::apache::thrift::protocol::T_I32, 5);
- xfer += oprot->writeI32((int32_t)this->providerName);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("userAccountName",
::apache::thrift::protocol::T_STRING, 6);
- xfer += oprot->writeString(this->userAccountName);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(CloudJobSubmission &a, CloudJobSubmission &b) {
- using ::std::swap;
- swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.securityProtocol, b.securityProtocol);
- swap(a.nodeId, b.nodeId);
- swap(a.executableType, b.executableType);
- swap(a.providerName, b.providerName);
- swap(a.userAccountName, b.userAccountName);
-}
-
-CloudJobSubmission::CloudJobSubmission(const CloudJobSubmission& other50) {
- jobSubmissionInterfaceId = other50.jobSubmissionInterfaceId;
- securityProtocol = other50.securityProtocol;
- nodeId = other50.nodeId;
- executableType = other50.executableType;
- providerName = other50.providerName;
- userAccountName = other50.userAccountName;
-}
-CloudJobSubmission& CloudJobSubmission::operator=(const CloudJobSubmission&
other51) {
- jobSubmissionInterfaceId = other51.jobSubmissionInterfaceId;
- securityProtocol = other51.securityProtocol;
- nodeId = other51.nodeId;
- executableType = other51.executableType;
- providerName = other51.providerName;
- userAccountName = other51.userAccountName;
- return *this;
-}
-void CloudJobSubmission::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "CloudJobSubmission(";
- out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "securityProtocol=" << to_string(securityProtocol);
- out << ", " << "nodeId=" << to_string(nodeId);
- out << ", " << "executableType=" << to_string(executableType);
- out << ", " << "providerName=" << to_string(providerName);
- out << ", " << "userAccountName=" << to_string(userAccountName);
- out << ")";
-}
-
-
-JobSubmissionInterface::~JobSubmissionInterface() throw() {
-}
-
-
-void JobSubmissionInterface::__set_jobSubmissionInterfaceId(const std::string&
val) {
- this->jobSubmissionInterfaceId = val;
-}
-
-void JobSubmissionInterface::__set_jobSubmissionProtocol(const
JobSubmissionProtocol::type val) {
- this->jobSubmissionProtocol = val;
-}
-
-void JobSubmissionInterface::__set_priorityOrder(const int32_t val) {
- this->priorityOrder = val;
-}
-
-uint32_t JobSubmissionInterface::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_jobSubmissionInterfaceId = false;
- bool isset_jobSubmissionProtocol = false;
- bool isset_priorityOrder = 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->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast52;
- xfer += iprot->readI32(ecast52);
- this->jobSubmissionProtocol = (JobSubmissionProtocol::type)ecast52;
- isset_jobSubmissionProtocol = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->priorityOrder);
- isset_priorityOrder = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_priorityOrder)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t JobSubmissionInterface::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("JobSubmissionInterface");
-
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("jobSubmissionProtocol",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->jobSubmissionProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->priorityOrder);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(JobSubmissionInterface &a, JobSubmissionInterface &b) {
- using ::std::swap;
- swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.jobSubmissionProtocol, b.jobSubmissionProtocol);
- swap(a.priorityOrder, b.priorityOrder);
-}
-
-JobSubmissionInterface::JobSubmissionInterface(const JobSubmissionInterface&
other53) {
- jobSubmissionInterfaceId = other53.jobSubmissionInterfaceId;
- jobSubmissionProtocol = other53.jobSubmissionProtocol;
- priorityOrder = other53.priorityOrder;
-}
-JobSubmissionInterface& JobSubmissionInterface::operator=(const
JobSubmissionInterface& other54) {
- jobSubmissionInterfaceId = other54.jobSubmissionInterfaceId;
- jobSubmissionProtocol = other54.jobSubmissionProtocol;
- priorityOrder = other54.priorityOrder;
- return *this;
-}
-void JobSubmissionInterface::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "JobSubmissionInterface(";
- out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "jobSubmissionProtocol=" << to_string(jobSubmissionProtocol);
- out << ", " << "priorityOrder=" << to_string(priorityOrder);
- out << ")";
-}
-
-
-ComputeResourceDescription::~ComputeResourceDescription() throw() {
-}
-
-
-void ComputeResourceDescription::__set_computeResourceId(const std::string&
val) {
- this->computeResourceId = val;
-}
-
-void ComputeResourceDescription::__set_hostName(const std::string& val) {
- this->hostName = val;
-}
-
-void ComputeResourceDescription::__set_hostAliases(const
std::vector<std::string> & val) {
- this->hostAliases = val;
-__isset.hostAliases = true;
-}
-
-void ComputeResourceDescription::__set_ipAddresses(const
std::vector<std::string> & val) {
- this->ipAddresses = val;
-__isset.ipAddresses = true;
-}
-
-void ComputeResourceDescription::__set_resourceDescription(const std::string&
val) {
- this->resourceDescription = val;
-__isset.resourceDescription = true;
-}
-
-void ComputeResourceDescription::__set_enabled(const bool val) {
- this->enabled = val;
-__isset.enabled = true;
-}
-
-void ComputeResourceDescription::__set_batchQueues(const
std::vector<BatchQueue> & val) {
- this->batchQueues = val;
-__isset.batchQueues = true;
-}
-
-void ComputeResourceDescription::__set_fileSystems(const
std::map<FileSystems::type, std::string> & val) {
- this->fileSystems = val;
-__isset.fileSystems = true;
-}
-
-void ComputeResourceDescription::__set_jobSubmissionInterfaces(const
std::vector<JobSubmissionInterface> & val) {
- this->jobSubmissionInterfaces = val;
-__isset.jobSubmissionInterfaces = true;
-}
-
-void ComputeResourceDescription::__set_dataMovementInterfaces(const
std::vector< ::apache::airavata::model::data::movement::DataMovementInterface>
& val) {
- this->dataMovementInterfaces = val;
-__isset.dataMovementInterfaces = true;
-}
-
-void ComputeResourceDescription::__set_maxMemoryPerNode(const int32_t val) {
- this->maxMemoryPerNode = val;
-__isset.maxMemoryPerNode = true;
-}
-
-void ComputeResourceDescription::__set_gatewayUsageReporting(const bool val) {
- this->gatewayUsageReporting = val;
-__isset.gatewayUsageReporting = true;
-}
-
-void ComputeResourceDescription::__set_gatewayUsageModuleLoadCommand(const
std::string& val) {
- this->gatewayUsageModuleLoadCommand = val;
-__isset.gatewayUsageModuleLoadCommand = true;
-}
-
-void ComputeResourceDescription::__set_gatewayUsageExecutable(const
std::string& val) {
- this->gatewayUsageExecutable = val;
-__isset.gatewayUsageExecutable = true;
-}
-
-uint32_t
ComputeResourceDescription::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_computeResourceId = false;
- bool isset_hostName = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->computeResourceId);
- isset_computeResourceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->hostName);
- isset_hostName = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->hostAliases.clear();
- uint32_t _size55;
- ::apache::thrift::protocol::TType _etype58;
- xfer += iprot->readListBegin(_etype58, _size55);
- this->hostAliases.resize(_size55);
- uint32_t _i59;
- for (_i59 = 0; _i59 < _size55; ++_i59)
- {
- xfer += iprot->readString(this->hostAliases[_i59]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.hostAliases = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->ipAddresses.clear();
- uint32_t _size60;
- ::apache::thrift::protocol::TType _etype63;
- xfer += iprot->readListBegin(_etype63, _size60);
- this->ipAddresses.resize(_size60);
- uint32_t _i64;
- for (_i64 = 0; _i64 < _size60; ++_i64)
- {
- xfer += iprot->readString(this->ipAddresses[_i64]);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.ipAddresses = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->resourceDescription);
- this->__isset.resourceDescription = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->enabled);
- this->__isset.enabled = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->batchQueues.clear();
- uint32_t _size65;
- ::apache::thrift::protocol::TType _etype68;
- xfer += iprot->readListBegin(_etype68, _size65);
- this->batchQueues.resize(_size65);
- uint32_t _i69;
- for (_i69 = 0; _i69 < _size65; ++_i69)
- {
- xfer += this->batchQueues[_i69].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.batchQueues = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_MAP) {
- {
- this->fileSystems.clear();
- uint32_t _size70;
- ::apache::thrift::protocol::TType _ktype71;
- ::apache::thrift::protocol::TType _vtype72;
- xfer += iprot->readMapBegin(_ktype71, _vtype72, _size70);
- uint32_t _i74;
- for (_i74 = 0; _i74 < _size70; ++_i74)
- {
- FileSystems::type _key75;
- int32_t ecast77;
- xfer += iprot->readI32(ecast77);
- _key75 = (FileSystems::type)ecast77;
- std::string& _val76 = this->fileSystems[_key75];
- xfer += iprot->readString(_val76);
- }
- xfer += iprot->readMapEnd();
- }
- this->__isset.fileSystems = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 9:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->jobSubmissionInterfaces.clear();
- uint32_t _size78;
- ::apache::thrift::protocol::TType _etype81;
- xfer += iprot->readListBegin(_etype81, _size78);
- this->jobSubmissionInterfaces.resize(_size78);
- uint32_t _i82;
- for (_i82 = 0; _i82 < _size78; ++_i82)
- {
- xfer += this->jobSubmissionInterfaces[_i82].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.jobSubmissionInterfaces = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 10:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->dataMovementInterfaces.clear();
- uint32_t _size83;
- ::apache::thrift::protocol::TType _etype86;
- xfer += iprot->readListBegin(_etype86, _size83);
- this->dataMovementInterfaces.resize(_size83);
- uint32_t _i87;
- for (_i87 = 0; _i87 < _size83; ++_i87)
- {
- xfer += this->dataMovementInterfaces[_i87].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.dataMovementInterfaces = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 11:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->maxMemoryPerNode);
- this->__isset.maxMemoryPerNode = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 12:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->gatewayUsageReporting);
- this->__isset.gatewayUsageReporting = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 13:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->gatewayUsageModuleLoadCommand);
- this->__isset.gatewayUsageModuleLoadCommand = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 14:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->gatewayUsageExecutable);
- this->__isset.gatewayUsageExecutable = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_computeResourceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_hostName)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t
ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
- xfer += oprot->writeStructBegin("ComputeResourceDescription");
-
- xfer += oprot->writeFieldBegin("computeResourceId",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->computeResourceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("hostName",
::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->hostName);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.hostAliases) {
- xfer += oprot->writeFieldBegin("hostAliases",
::apache::thrift::protocol::T_LIST, 3);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->hostAliases.size()));
- std::vector<std::string> ::const_iterator _iter88;
- for (_iter88 = this->hostAliases.begin(); _iter88 !=
this->hostAliases.end(); ++_iter88)
- {
- xfer += oprot->writeString((*_iter88));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.ipAddresses) {
- xfer += oprot->writeFieldBegin("ipAddresses",
::apache::thrift::protocol::T_LIST, 4);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->ipAddresses.size()));
- std::vector<std::string> ::const_iterator _iter89;
- for (_iter89 = this->ipAddresses.begin(); _iter89 !=
this->ipAddresses.end(); ++_iter89)
- {
- xfer += oprot->writeString((*_iter89));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.resourceDescription) {
- xfer += oprot->writeFieldBegin("resourceDescription",
::apache::thrift::protocol::T_STRING, 5);
- xfer += oprot->writeString(this->resourceDescription);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.enabled) {
- xfer += oprot->writeFieldBegin("enabled",
::apache::thrift::protocol::T_BOOL, 6);
- xfer += oprot->writeBool(this->enabled);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.batchQueues) {
- xfer += oprot->writeFieldBegin("batchQueues",
::apache::thrift::protocol::T_LIST, 7);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->batchQueues.size()));
- std::vector<BatchQueue> ::const_iterator _iter90;
- for (_iter90 = this->batchQueues.begin(); _iter90 !=
this->batchQueues.end(); ++_iter90)
- {
- xfer += (*_iter90).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.fileSystems) {
- xfer += oprot->writeFieldBegin("fileSystems",
::apache::thrift::protocol::T_MAP, 8);
- {
- xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_I32,
::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->fileSystems.size()));
- std::map<FileSystems::type, std::string> ::const_iterator _iter91;
- for (_iter91 = this->fileSystems.begin(); _iter91 !=
this->fileSystems.end(); ++_iter91)
- {
- xfer += oprot->writeI32((int32_t)_iter91->first);
- xfer += oprot->writeString(_iter91->second);
- }
- xfer += oprot->writeMapEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.jobSubmissionInterfaces) {
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaces",
::apache::thrift::protocol::T_LIST, 9);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->jobSubmissionInterfaces.size()));
- std::vector<JobSubmissionInterface> ::const_iterator _iter92;
- for (_iter92 = this->jobSubmissionInterfaces.begin(); _iter92 !=
this->jobSubmissionInterfaces.end(); ++_iter92)
- {
- xfer += (*_iter92).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.dataMovementInterfaces) {
- xfer += oprot->writeFieldBegin("dataMovementInterfaces",
::apache::thrift::protocol::T_LIST, 10);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->dataMovementInterfaces.size()));
- std::vector<
::apache::airavata::model::data::movement::DataMovementInterface>
::const_iterator _iter93;
- for (_iter93 = this->dataMovementInterfaces.begin(); _iter93 !=
this->dataMovementInterfaces.end(); ++_iter93)
- {
- xfer += (*_iter93).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.maxMemoryPerNode) {
- xfer += oprot->writeFieldBegin("maxMemoryPerNode",
::apache::thrift::protocol::T_I32, 11);
- xfer += oprot->writeI32(this->maxMemoryPerNode);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.gatewayUsageReporting) {
- xfer += oprot->writeFieldBegin("gatewayUsageReporting",
::apache::thrift::protocol::T_BOOL, 12);
- xfer += oprot->writeBool(this->gatewayUsageReporting);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.gatewayUsageModuleLoadCommand) {
- xfer += oprot->writeFieldBegin("gatewayUsageModuleLoadCommand",
::apache::thrift::protocol::T_STRING, 13);
- xfer += oprot->writeString(this->gatewayUsageModuleLoadCommand);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.gatewayUsageExecutable) {
- xfer += oprot->writeFieldBegin("gatewayUsageExecutable",
::apache::thrift::protocol::T_STRING, 14);
- xfer += oprot->writeString(this->gatewayUsageExecutable);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(ComputeResourceDescription &a, ComputeResourceDescription &b) {
- using ::std::swap;
- swap(a.computeResourceId, b.computeResourceId);
- swap(a.hostName, b.hostName);
- swap(a.hostAliases, b.hostAliases);
- swap(a.ipAddresses, b.ipAddresses);
- swap(a.resourceDescription, b.resourceDescription);
- swap(a.enabled, b.enabled);
- swap(a.batchQueues, b.batchQueues);
- swap(a.fileSystems, b.fileSystems);
- swap(a.jobSubmissionInterfaces, b.jobSubmissionInterfaces);
- swap(a.dataMovementInterfaces, b.dataMovementInterfaces);
- swap(a.maxMemoryPerNode, b.maxMemoryPerNode);
- swap(a.gatewayUsageReporting, b.gatewayUsageReporting);
- swap(a.gatewayUsageModuleLoadCommand, b.gatewayUsageModuleLoadCommand);
- swap(a.gatewayUsageExecutable, b.gatewayUsageExecutable);
- swap(a.__isset, b.__isset);
-}
-
-ComputeResourceDescription::ComputeResourceDescription(const
ComputeResourceDescription& other94) {
- computeResourceId = other94.computeResourceId;
- hostName = other94.hostName;
- hostAliases = other94.hostAliases;
- ipAddresses = other94.ipAddresses;
- resourceDescription = other94.resourceDescription;
- enabled = other94.enabled;
- batchQueues = other94.batchQueues;
- fileSystems = other94.fileSystems;
- jobSubmissionInterfaces = other94.jobSubmissionInterfaces;
- dataMovementInterfaces = other94.dataMovementInterfaces;
- maxMemoryPerNode = other94.maxMemoryPerNode;
- gatewayUsageReporting = other94.gatewayUsageReporting;
- gatewayUsageModuleLoadCommand = other94.gatewayUsageModuleLoadCommand;
- gatewayUsageExecutable = other94.gatewayUsageExecutable;
- __isset = other94.__isset;
-}
-ComputeResourceDescription& ComputeResourceDescription::operator=(const
ComputeResourceDescription& other95) {
- computeResourceId = other95.computeResourceId;
- hostName = other95.hostName;
- hostAliases = other95.hostAliases;
- ipAddresses = other95.ipAddresses;
- resourceDescription = other95.resourceDescription;
- enabled = other95.enabled;
- batchQueues = other95.batchQueues;
- fileSystems = other95.fileSystems;
- jobSubmissionInterfaces = other95.jobSubmissionInterfaces;
- dataMovementInterfaces = other95.dataMovementInterfaces;
- maxMemoryPerNode = other95.maxMemoryPerNode;
- gatewayUsageReporting = other95.gatewayUsageReporting;
- gatewayUsageModuleLoadCommand = other95.gatewayUsageModuleLoadCommand;
- gatewayUsageExecutable = other95.gatewayUsageExecutable;
- __isset = other95.__isset;
- return *this;
-}
-void ComputeResourceDescription::printTo(std::ostream& out) const {
- using ::apache::thrift::to_string;
- out << "ComputeResourceDescription(";
- out << "computeResourceId=" << to_string(computeResourceId);
- out << ", " << "hostName=" << to_string(hostName);
- out << ", " << "hostAliases="; (__isset.hostAliases ? (out <<
to_string(hostAliases)) : (out << "<null>"));
- out << ", " << "ipAddresses="; (__isset.ipAddresses ? (out <<
to_string(ipAddresses)) : (out << "<null>"));
- out << ", " << "resourceDescription="; (__isset.resourceDescription ? (out
<< to_string(resourceDescription)) : (out << "<null>"));
- out << ", " << "enabled="; (__isset.enabled ? (out << to_string(enabled)) :
(out << "<null>"));
- out << ", " << "batchQueues="; (__isset.batchQueues ? (out <<
to_string(batchQueues)) : (out << "<null>"));
- out << ", " << "fileSystems="; (__isset.fileSystems ? (out <<
to_string(fileSystems)) : (out << "<null>"));
- out << ", " << "jobSubmissionInterfaces="; (__isset.jobSubmissionInterfaces
? (out << to_string(jobSubmissionInterfaces)) : (out << "<null>"));
- out << ", " << "dataMovementInterfaces="; (__isset.dataMovementInterfaces ?
(out << to_string(dataMovementInterfaces)) : (out << "<null>"));
- out << ", " << "maxMemoryPerNode="; (__isset.maxMemoryPerNode ? (out <<
to_string(maxMemoryPerNode)) : (out << "<null>"));
- out << ", " << "gatewayUsageReporting="; (__isset.gatewayUsageReporting ?
(out << to_string(gatewayUsageReporting)) : (out << "<null>"));
- out << ", " << "gatewayUsageModuleLoadCommand=";
(__isset.gatewayUsageModuleLoadCommand ? (out <<
to_string(gatewayUsageModuleLoadCommand)) : (out << "<null>"));
- out << ", " << "gatewayUsageExecutable="; (__isset.gatewayUsageExecutable ?
(out << to_string(gatewayUsageExecutable)) : (out << "<null>"));
- out << ")";
-}
-
-}}}}} // namespace
