| /** |
| * 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.10.0) |
| * |
| * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
| * @generated |
| */ |
| #include "experiment_model_types.h" |
| |
| #include <algorithm> |
| #include <ostream> |
| |
| #include <thrift/TToString.h> |
| |
| namespace apache { namespace airavata { namespace model { namespace experiment { |
| |
| int _kExperimentTypeValues[] = { |
| ExperimentType::SINGLE_APPLICATION, |
| ExperimentType::WORKFLOW |
| }; |
| const char* _kExperimentTypeNames[] = { |
| "SINGLE_APPLICATION", |
| "WORKFLOW" |
| }; |
| const std::map<int, const char*> _ExperimentType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kExperimentTypeValues, _kExperimentTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); |
| |
| int _kExperimentSearchFieldsValues[] = { |
| ExperimentSearchFields::EXPERIMENT_NAME, |
| ExperimentSearchFields::EXPERIMENT_DESC, |
| ExperimentSearchFields::APPLICATION_ID, |
| ExperimentSearchFields::FROM_DATE, |
| ExperimentSearchFields::TO_DATE, |
| ExperimentSearchFields::STATUS, |
| ExperimentSearchFields::PROJECT_ID, |
| ExperimentSearchFields::USER_NAME, |
| ExperimentSearchFields::JOB_ID |
| }; |
| const char* _kExperimentSearchFieldsNames[] = { |
| "EXPERIMENT_NAME", |
| "EXPERIMENT_DESC", |
| "APPLICATION_ID", |
| "FROM_DATE", |
| "TO_DATE", |
| "STATUS", |
| "PROJECT_ID", |
| "USER_NAME", |
| "JOB_ID" |
| }; |
| const std::map<int, const char*> _ExperimentSearchFields_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(9, _kExperimentSearchFieldsValues, _kExperimentSearchFieldsNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); |
| |
| int _kProjectSearchFieldsValues[] = { |
| ProjectSearchFields::PROJECT_NAME, |
| ProjectSearchFields::PROJECT_DESCRIPTION |
| }; |
| const char* _kProjectSearchFieldsNames[] = { |
| "PROJECT_NAME", |
| "PROJECT_DESCRIPTION" |
| }; |
| const std::map<int, const char*> _ProjectSearchFields_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kProjectSearchFieldsValues, _kProjectSearchFieldsNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); |
| |
| |
| UserConfigurationDataModel::~UserConfigurationDataModel() throw() { |
| } |
| |
| |
| void UserConfigurationDataModel::__set_airavataAutoSchedule(const bool val) { |
| this->airavataAutoSchedule = val; |
| } |
| |
| void UserConfigurationDataModel::__set_overrideManualScheduledParams(const bool val) { |
| this->overrideManualScheduledParams = val; |
| } |
| |
| void UserConfigurationDataModel::__set_shareExperimentPublicly(const bool val) { |
| this->shareExperimentPublicly = val; |
| __isset.shareExperimentPublicly = true; |
| } |
| |
| void UserConfigurationDataModel::__set_computationalResourceScheduling(const ::apache::airavata::model::scheduling::ComputationalResourceSchedulingModel& val) { |
| this->computationalResourceScheduling = val; |
| __isset.computationalResourceScheduling = true; |
| } |
| |
| void UserConfigurationDataModel::__set_throttleResources(const bool val) { |
| this->throttleResources = val; |
| __isset.throttleResources = true; |
| } |
| |
| void UserConfigurationDataModel::__set_userDN(const std::string& val) { |
| this->userDN = val; |
| __isset.userDN = true; |
| } |
| |
| void UserConfigurationDataModel::__set_generateCert(const bool val) { |
| this->generateCert = val; |
| __isset.generateCert = true; |
| } |
| |
| void UserConfigurationDataModel::__set_storageId(const std::string& val) { |
| this->storageId = val; |
| __isset.storageId = true; |
| } |
| |
| void UserConfigurationDataModel::__set_experimentDataDir(const std::string& val) { |
| this->experimentDataDir = val; |
| __isset.experimentDataDir = true; |
| } |
| |
| void UserConfigurationDataModel::__set_useUserCRPref(const bool val) { |
| this->useUserCRPref = val; |
| __isset.useUserCRPref = true; |
| } |
| |
| void UserConfigurationDataModel::__set_groupResourceProfileId(const std::string& val) { |
| this->groupResourceProfileId = val; |
| __isset.groupResourceProfileId = true; |
| } |
| |
| void UserConfigurationDataModel::__set_autoScheduledCompResourceSchedulingList(const std::vector< ::apache::airavata::model::scheduling::ComputationalResourceSchedulingModel> & val) { |
| this->autoScheduledCompResourceSchedulingList = val; |
| __isset.autoScheduledCompResourceSchedulingList = true; |
| } |
| |
| uint32_t UserConfigurationDataModel::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_airavataAutoSchedule = false; |
| bool isset_overrideManualScheduledParams = 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_BOOL) { |
| xfer += iprot->readBool(this->airavataAutoSchedule); |
| isset_airavataAutoSchedule = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 2: |
| if (ftype == ::apache::thrift::protocol::T_BOOL) { |
| xfer += iprot->readBool(this->overrideManualScheduledParams); |
| isset_overrideManualScheduledParams = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 3: |
| if (ftype == ::apache::thrift::protocol::T_BOOL) { |
| xfer += iprot->readBool(this->shareExperimentPublicly); |
| this->__isset.shareExperimentPublicly = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 4: |
| if (ftype == ::apache::thrift::protocol::T_STRUCT) { |
| xfer += this->computationalResourceScheduling.read(iprot); |
| this->__isset.computationalResourceScheduling = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 5: |
| if (ftype == ::apache::thrift::protocol::T_BOOL) { |
| xfer += iprot->readBool(this->throttleResources); |
| this->__isset.throttleResources = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 6: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->userDN); |
| this->__isset.userDN = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 7: |
| if (ftype == ::apache::thrift::protocol::T_BOOL) { |
| xfer += iprot->readBool(this->generateCert); |
| this->__isset.generateCert = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 8: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->storageId); |
| this->__isset.storageId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 9: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->experimentDataDir); |
| this->__isset.experimentDataDir = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 10: |
| if (ftype == ::apache::thrift::protocol::T_BOOL) { |
| xfer += iprot->readBool(this->useUserCRPref); |
| this->__isset.useUserCRPref = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 11: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->groupResourceProfileId); |
| this->__isset.groupResourceProfileId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 12: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->autoScheduledCompResourceSchedulingList.clear(); |
| uint32_t _size0; |
| ::apache::thrift::protocol::TType _etype3; |
| xfer += iprot->readListBegin(_etype3, _size0); |
| this->autoScheduledCompResourceSchedulingList.resize(_size0); |
| uint32_t _i4; |
| for (_i4 = 0; _i4 < _size0; ++_i4) |
| { |
| xfer += this->autoScheduledCompResourceSchedulingList[_i4].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.autoScheduledCompResourceSchedulingList = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| default: |
| xfer += iprot->skip(ftype); |
| break; |
| } |
| xfer += iprot->readFieldEnd(); |
| } |
| |
| xfer += iprot->readStructEnd(); |
| |
| if (!isset_airavataAutoSchedule) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_overrideManualScheduledParams) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| return xfer; |
| } |
| |
| uint32_t UserConfigurationDataModel::write(::apache::thrift::protocol::TProtocol* oprot) const { |
| uint32_t xfer = 0; |
| apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); |
| xfer += oprot->writeStructBegin("UserConfigurationDataModel"); |
| |
| xfer += oprot->writeFieldBegin("airavataAutoSchedule", ::apache::thrift::protocol::T_BOOL, 1); |
| xfer += oprot->writeBool(this->airavataAutoSchedule); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("overrideManualScheduledParams", ::apache::thrift::protocol::T_BOOL, 2); |
| xfer += oprot->writeBool(this->overrideManualScheduledParams); |
| xfer += oprot->writeFieldEnd(); |
| |
| if (this->__isset.shareExperimentPublicly) { |
| xfer += oprot->writeFieldBegin("shareExperimentPublicly", ::apache::thrift::protocol::T_BOOL, 3); |
| xfer += oprot->writeBool(this->shareExperimentPublicly); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.computationalResourceScheduling) { |
| xfer += oprot->writeFieldBegin("computationalResourceScheduling", ::apache::thrift::protocol::T_STRUCT, 4); |
| xfer += this->computationalResourceScheduling.write(oprot); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.throttleResources) { |
| xfer += oprot->writeFieldBegin("throttleResources", ::apache::thrift::protocol::T_BOOL, 5); |
| xfer += oprot->writeBool(this->throttleResources); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.userDN) { |
| xfer += oprot->writeFieldBegin("userDN", ::apache::thrift::protocol::T_STRING, 6); |
| xfer += oprot->writeString(this->userDN); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.generateCert) { |
| xfer += oprot->writeFieldBegin("generateCert", ::apache::thrift::protocol::T_BOOL, 7); |
| xfer += oprot->writeBool(this->generateCert); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.storageId) { |
| xfer += oprot->writeFieldBegin("storageId", ::apache::thrift::protocol::T_STRING, 8); |
| xfer += oprot->writeString(this->storageId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.experimentDataDir) { |
| xfer += oprot->writeFieldBegin("experimentDataDir", ::apache::thrift::protocol::T_STRING, 9); |
| xfer += oprot->writeString(this->experimentDataDir); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.useUserCRPref) { |
| xfer += oprot->writeFieldBegin("useUserCRPref", ::apache::thrift::protocol::T_BOOL, 10); |
| xfer += oprot->writeBool(this->useUserCRPref); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.groupResourceProfileId) { |
| xfer += oprot->writeFieldBegin("groupResourceProfileId", ::apache::thrift::protocol::T_STRING, 11); |
| xfer += oprot->writeString(this->groupResourceProfileId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.autoScheduledCompResourceSchedulingList) { |
| xfer += oprot->writeFieldBegin("autoScheduledCompResourceSchedulingList", ::apache::thrift::protocol::T_LIST, 12); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->autoScheduledCompResourceSchedulingList.size())); |
| std::vector< ::apache::airavata::model::scheduling::ComputationalResourceSchedulingModel> ::const_iterator _iter5; |
| for (_iter5 = this->autoScheduledCompResourceSchedulingList.begin(); _iter5 != this->autoScheduledCompResourceSchedulingList.end(); ++_iter5) |
| { |
| xfer += (*_iter5).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| xfer += oprot->writeFieldStop(); |
| xfer += oprot->writeStructEnd(); |
| return xfer; |
| } |
| |
| void swap(UserConfigurationDataModel &a, UserConfigurationDataModel &b) { |
| using ::std::swap; |
| swap(a.airavataAutoSchedule, b.airavataAutoSchedule); |
| swap(a.overrideManualScheduledParams, b.overrideManualScheduledParams); |
| swap(a.shareExperimentPublicly, b.shareExperimentPublicly); |
| swap(a.computationalResourceScheduling, b.computationalResourceScheduling); |
| swap(a.throttleResources, b.throttleResources); |
| swap(a.userDN, b.userDN); |
| swap(a.generateCert, b.generateCert); |
| swap(a.storageId, b.storageId); |
| swap(a.experimentDataDir, b.experimentDataDir); |
| swap(a.useUserCRPref, b.useUserCRPref); |
| swap(a.groupResourceProfileId, b.groupResourceProfileId); |
| swap(a.autoScheduledCompResourceSchedulingList, b.autoScheduledCompResourceSchedulingList); |
| swap(a.__isset, b.__isset); |
| } |
| |
| UserConfigurationDataModel::UserConfigurationDataModel(const UserConfigurationDataModel& other6) { |
| airavataAutoSchedule = other6.airavataAutoSchedule; |
| overrideManualScheduledParams = other6.overrideManualScheduledParams; |
| shareExperimentPublicly = other6.shareExperimentPublicly; |
| computationalResourceScheduling = other6.computationalResourceScheduling; |
| throttleResources = other6.throttleResources; |
| userDN = other6.userDN; |
| generateCert = other6.generateCert; |
| storageId = other6.storageId; |
| experimentDataDir = other6.experimentDataDir; |
| useUserCRPref = other6.useUserCRPref; |
| groupResourceProfileId = other6.groupResourceProfileId; |
| autoScheduledCompResourceSchedulingList = other6.autoScheduledCompResourceSchedulingList; |
| __isset = other6.__isset; |
| } |
| UserConfigurationDataModel& UserConfigurationDataModel::operator=(const UserConfigurationDataModel& other7) { |
| airavataAutoSchedule = other7.airavataAutoSchedule; |
| overrideManualScheduledParams = other7.overrideManualScheduledParams; |
| shareExperimentPublicly = other7.shareExperimentPublicly; |
| computationalResourceScheduling = other7.computationalResourceScheduling; |
| throttleResources = other7.throttleResources; |
| userDN = other7.userDN; |
| generateCert = other7.generateCert; |
| storageId = other7.storageId; |
| experimentDataDir = other7.experimentDataDir; |
| useUserCRPref = other7.useUserCRPref; |
| groupResourceProfileId = other7.groupResourceProfileId; |
| autoScheduledCompResourceSchedulingList = other7.autoScheduledCompResourceSchedulingList; |
| __isset = other7.__isset; |
| return *this; |
| } |
| void UserConfigurationDataModel::printTo(std::ostream& out) const { |
| using ::apache::thrift::to_string; |
| out << "UserConfigurationDataModel("; |
| out << "airavataAutoSchedule=" << to_string(airavataAutoSchedule); |
| out << ", " << "overrideManualScheduledParams=" << to_string(overrideManualScheduledParams); |
| out << ", " << "shareExperimentPublicly="; (__isset.shareExperimentPublicly ? (out << to_string(shareExperimentPublicly)) : (out << "<null>")); |
| out << ", " << "computationalResourceScheduling="; (__isset.computationalResourceScheduling ? (out << to_string(computationalResourceScheduling)) : (out << "<null>")); |
| out << ", " << "throttleResources="; (__isset.throttleResources ? (out << to_string(throttleResources)) : (out << "<null>")); |
| out << ", " << "userDN="; (__isset.userDN ? (out << to_string(userDN)) : (out << "<null>")); |
| out << ", " << "generateCert="; (__isset.generateCert ? (out << to_string(generateCert)) : (out << "<null>")); |
| out << ", " << "storageId="; (__isset.storageId ? (out << to_string(storageId)) : (out << "<null>")); |
| out << ", " << "experimentDataDir="; (__isset.experimentDataDir ? (out << to_string(experimentDataDir)) : (out << "<null>")); |
| out << ", " << "useUserCRPref="; (__isset.useUserCRPref ? (out << to_string(useUserCRPref)) : (out << "<null>")); |
| out << ", " << "groupResourceProfileId="; (__isset.groupResourceProfileId ? (out << to_string(groupResourceProfileId)) : (out << "<null>")); |
| out << ", " << "autoScheduledCompResourceSchedulingList="; (__isset.autoScheduledCompResourceSchedulingList ? (out << to_string(autoScheduledCompResourceSchedulingList)) : (out << "<null>")); |
| out << ")"; |
| } |
| |
| |
| ExperimentModel::~ExperimentModel() throw() { |
| } |
| |
| |
| void ExperimentModel::__set_experimentId(const std::string& val) { |
| this->experimentId = val; |
| } |
| |
| void ExperimentModel::__set_projectId(const std::string& val) { |
| this->projectId = val; |
| } |
| |
| void ExperimentModel::__set_gatewayId(const std::string& val) { |
| this->gatewayId = val; |
| } |
| |
| void ExperimentModel::__set_experimentType(const ExperimentType::type val) { |
| this->experimentType = val; |
| } |
| |
| void ExperimentModel::__set_userName(const std::string& val) { |
| this->userName = val; |
| } |
| |
| void ExperimentModel::__set_experimentName(const std::string& val) { |
| this->experimentName = val; |
| } |
| |
| void ExperimentModel::__set_creationTime(const int64_t val) { |
| this->creationTime = val; |
| __isset.creationTime = true; |
| } |
| |
| void ExperimentModel::__set_description(const std::string& val) { |
| this->description = val; |
| __isset.description = true; |
| } |
| |
| void ExperimentModel::__set_executionId(const std::string& val) { |
| this->executionId = val; |
| __isset.executionId = true; |
| } |
| |
| void ExperimentModel::__set_gatewayExecutionId(const std::string& val) { |
| this->gatewayExecutionId = val; |
| __isset.gatewayExecutionId = true; |
| } |
| |
| void ExperimentModel::__set_gatewayInstanceId(const std::string& val) { |
| this->gatewayInstanceId = val; |
| __isset.gatewayInstanceId = true; |
| } |
| |
| void ExperimentModel::__set_enableEmailNotification(const bool val) { |
| this->enableEmailNotification = val; |
| __isset.enableEmailNotification = true; |
| } |
| |
| void ExperimentModel::__set_emailAddresses(const std::vector<std::string> & val) { |
| this->emailAddresses = val; |
| __isset.emailAddresses = true; |
| } |
| |
| void ExperimentModel::__set_userConfigurationData(const UserConfigurationDataModel& val) { |
| this->userConfigurationData = val; |
| __isset.userConfigurationData = true; |
| } |
| |
| void ExperimentModel::__set_experimentInputs(const std::vector< ::apache::airavata::model::application::io::InputDataObjectType> & val) { |
| this->experimentInputs = val; |
| __isset.experimentInputs = true; |
| } |
| |
| void ExperimentModel::__set_experimentOutputs(const std::vector< ::apache::airavata::model::application::io::OutputDataObjectType> & val) { |
| this->experimentOutputs = val; |
| __isset.experimentOutputs = true; |
| } |
| |
| void ExperimentModel::__set_experimentStatus(const std::vector< ::apache::airavata::model::status::ExperimentStatus> & val) { |
| this->experimentStatus = val; |
| __isset.experimentStatus = true; |
| } |
| |
| void ExperimentModel::__set_errors(const std::vector< ::apache::airavata::model::commons::ErrorModel> & val) { |
| this->errors = val; |
| __isset.errors = true; |
| } |
| |
| void ExperimentModel::__set_processes(const std::vector< ::apache::airavata::model::process::ProcessModel> & val) { |
| this->processes = val; |
| __isset.processes = true; |
| } |
| |
| void ExperimentModel::__set_workflow(const ::apache::airavata::model::workflow::AiravataWorkflow& val) { |
| this->workflow = val; |
| __isset.workflow = true; |
| } |
| |
| uint32_t ExperimentModel::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_experimentId = false; |
| bool isset_projectId = false; |
| bool isset_gatewayId = false; |
| bool isset_experimentType = false; |
| bool isset_userName = false; |
| bool isset_experimentName = 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->experimentId); |
| isset_experimentId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 2: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->projectId); |
| isset_projectId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 3: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->gatewayId); |
| isset_gatewayId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 4: |
| if (ftype == ::apache::thrift::protocol::T_I32) { |
| int32_t ecast8; |
| xfer += iprot->readI32(ecast8); |
| this->experimentType = (ExperimentType::type)ecast8; |
| isset_experimentType = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 5: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->userName); |
| isset_userName = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 6: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->experimentName); |
| isset_experimentName = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 7: |
| if (ftype == ::apache::thrift::protocol::T_I64) { |
| xfer += iprot->readI64(this->creationTime); |
| this->__isset.creationTime = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 8: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->description); |
| this->__isset.description = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 9: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->executionId); |
| this->__isset.executionId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 10: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->gatewayExecutionId); |
| this->__isset.gatewayExecutionId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 11: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->gatewayInstanceId); |
| this->__isset.gatewayInstanceId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 12: |
| if (ftype == ::apache::thrift::protocol::T_BOOL) { |
| xfer += iprot->readBool(this->enableEmailNotification); |
| this->__isset.enableEmailNotification = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 13: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->emailAddresses.clear(); |
| uint32_t _size9; |
| ::apache::thrift::protocol::TType _etype12; |
| xfer += iprot->readListBegin(_etype12, _size9); |
| this->emailAddresses.resize(_size9); |
| uint32_t _i13; |
| for (_i13 = 0; _i13 < _size9; ++_i13) |
| { |
| xfer += iprot->readString(this->emailAddresses[_i13]); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.emailAddresses = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 14: |
| if (ftype == ::apache::thrift::protocol::T_STRUCT) { |
| xfer += this->userConfigurationData.read(iprot); |
| this->__isset.userConfigurationData = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 15: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->experimentInputs.clear(); |
| uint32_t _size14; |
| ::apache::thrift::protocol::TType _etype17; |
| xfer += iprot->readListBegin(_etype17, _size14); |
| this->experimentInputs.resize(_size14); |
| uint32_t _i18; |
| for (_i18 = 0; _i18 < _size14; ++_i18) |
| { |
| xfer += this->experimentInputs[_i18].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.experimentInputs = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 16: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->experimentOutputs.clear(); |
| uint32_t _size19; |
| ::apache::thrift::protocol::TType _etype22; |
| xfer += iprot->readListBegin(_etype22, _size19); |
| this->experimentOutputs.resize(_size19); |
| uint32_t _i23; |
| for (_i23 = 0; _i23 < _size19; ++_i23) |
| { |
| xfer += this->experimentOutputs[_i23].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.experimentOutputs = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 17: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->experimentStatus.clear(); |
| uint32_t _size24; |
| ::apache::thrift::protocol::TType _etype27; |
| xfer += iprot->readListBegin(_etype27, _size24); |
| this->experimentStatus.resize(_size24); |
| uint32_t _i28; |
| for (_i28 = 0; _i28 < _size24; ++_i28) |
| { |
| xfer += this->experimentStatus[_i28].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.experimentStatus = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 18: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->errors.clear(); |
| uint32_t _size29; |
| ::apache::thrift::protocol::TType _etype32; |
| xfer += iprot->readListBegin(_etype32, _size29); |
| this->errors.resize(_size29); |
| uint32_t _i33; |
| for (_i33 = 0; _i33 < _size29; ++_i33) |
| { |
| xfer += this->errors[_i33].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.errors = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 19: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->processes.clear(); |
| uint32_t _size34; |
| ::apache::thrift::protocol::TType _etype37; |
| xfer += iprot->readListBegin(_etype37, _size34); |
| this->processes.resize(_size34); |
| uint32_t _i38; |
| for (_i38 = 0; _i38 < _size34; ++_i38) |
| { |
| xfer += this->processes[_i38].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.processes = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 20: |
| if (ftype == ::apache::thrift::protocol::T_STRUCT) { |
| xfer += this->workflow.read(iprot); |
| this->__isset.workflow = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| default: |
| xfer += iprot->skip(ftype); |
| break; |
| } |
| xfer += iprot->readFieldEnd(); |
| } |
| |
| xfer += iprot->readStructEnd(); |
| |
| if (!isset_experimentId) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_projectId) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_gatewayId) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_experimentType) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_userName) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_experimentName) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| return xfer; |
| } |
| |
| uint32_t ExperimentModel::write(::apache::thrift::protocol::TProtocol* oprot) const { |
| uint32_t xfer = 0; |
| apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); |
| xfer += oprot->writeStructBegin("ExperimentModel"); |
| |
| xfer += oprot->writeFieldBegin("experimentId", ::apache::thrift::protocol::T_STRING, 1); |
| xfer += oprot->writeString(this->experimentId); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 2); |
| xfer += oprot->writeString(this->projectId); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 3); |
| xfer += oprot->writeString(this->gatewayId); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("experimentType", ::apache::thrift::protocol::T_I32, 4); |
| xfer += oprot->writeI32((int32_t)this->experimentType); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 5); |
| xfer += oprot->writeString(this->userName); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("experimentName", ::apache::thrift::protocol::T_STRING, 6); |
| xfer += oprot->writeString(this->experimentName); |
| xfer += oprot->writeFieldEnd(); |
| |
| if (this->__isset.creationTime) { |
| xfer += oprot->writeFieldBegin("creationTime", ::apache::thrift::protocol::T_I64, 7); |
| xfer += oprot->writeI64(this->creationTime); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.description) { |
| xfer += oprot->writeFieldBegin("description", ::apache::thrift::protocol::T_STRING, 8); |
| xfer += oprot->writeString(this->description); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.executionId) { |
| xfer += oprot->writeFieldBegin("executionId", ::apache::thrift::protocol::T_STRING, 9); |
| xfer += oprot->writeString(this->executionId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.gatewayExecutionId) { |
| xfer += oprot->writeFieldBegin("gatewayExecutionId", ::apache::thrift::protocol::T_STRING, 10); |
| xfer += oprot->writeString(this->gatewayExecutionId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.gatewayInstanceId) { |
| xfer += oprot->writeFieldBegin("gatewayInstanceId", ::apache::thrift::protocol::T_STRING, 11); |
| xfer += oprot->writeString(this->gatewayInstanceId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.enableEmailNotification) { |
| xfer += oprot->writeFieldBegin("enableEmailNotification", ::apache::thrift::protocol::T_BOOL, 12); |
| xfer += oprot->writeBool(this->enableEmailNotification); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.emailAddresses) { |
| xfer += oprot->writeFieldBegin("emailAddresses", ::apache::thrift::protocol::T_LIST, 13); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->emailAddresses.size())); |
| std::vector<std::string> ::const_iterator _iter39; |
| for (_iter39 = this->emailAddresses.begin(); _iter39 != this->emailAddresses.end(); ++_iter39) |
| { |
| xfer += oprot->writeString((*_iter39)); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.userConfigurationData) { |
| xfer += oprot->writeFieldBegin("userConfigurationData", ::apache::thrift::protocol::T_STRUCT, 14); |
| xfer += this->userConfigurationData.write(oprot); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.experimentInputs) { |
| xfer += oprot->writeFieldBegin("experimentInputs", ::apache::thrift::protocol::T_LIST, 15); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->experimentInputs.size())); |
| std::vector< ::apache::airavata::model::application::io::InputDataObjectType> ::const_iterator _iter40; |
| for (_iter40 = this->experimentInputs.begin(); _iter40 != this->experimentInputs.end(); ++_iter40) |
| { |
| xfer += (*_iter40).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.experimentOutputs) { |
| xfer += oprot->writeFieldBegin("experimentOutputs", ::apache::thrift::protocol::T_LIST, 16); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->experimentOutputs.size())); |
| std::vector< ::apache::airavata::model::application::io::OutputDataObjectType> ::const_iterator _iter41; |
| for (_iter41 = this->experimentOutputs.begin(); _iter41 != this->experimentOutputs.end(); ++_iter41) |
| { |
| xfer += (*_iter41).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.experimentStatus) { |
| xfer += oprot->writeFieldBegin("experimentStatus", ::apache::thrift::protocol::T_LIST, 17); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->experimentStatus.size())); |
| std::vector< ::apache::airavata::model::status::ExperimentStatus> ::const_iterator _iter42; |
| for (_iter42 = this->experimentStatus.begin(); _iter42 != this->experimentStatus.end(); ++_iter42) |
| { |
| xfer += (*_iter42).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.errors) { |
| xfer += oprot->writeFieldBegin("errors", ::apache::thrift::protocol::T_LIST, 18); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->errors.size())); |
| std::vector< ::apache::airavata::model::commons::ErrorModel> ::const_iterator _iter43; |
| for (_iter43 = this->errors.begin(); _iter43 != this->errors.end(); ++_iter43) |
| { |
| xfer += (*_iter43).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.processes) { |
| xfer += oprot->writeFieldBegin("processes", ::apache::thrift::protocol::T_LIST, 19); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->processes.size())); |
| std::vector< ::apache::airavata::model::process::ProcessModel> ::const_iterator _iter44; |
| for (_iter44 = this->processes.begin(); _iter44 != this->processes.end(); ++_iter44) |
| { |
| xfer += (*_iter44).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.workflow) { |
| xfer += oprot->writeFieldBegin("workflow", ::apache::thrift::protocol::T_STRUCT, 20); |
| xfer += this->workflow.write(oprot); |
| xfer += oprot->writeFieldEnd(); |
| } |
| xfer += oprot->writeFieldStop(); |
| xfer += oprot->writeStructEnd(); |
| return xfer; |
| } |
| |
| void swap(ExperimentModel &a, ExperimentModel &b) { |
| using ::std::swap; |
| swap(a.experimentId, b.experimentId); |
| swap(a.projectId, b.projectId); |
| swap(a.gatewayId, b.gatewayId); |
| swap(a.experimentType, b.experimentType); |
| swap(a.userName, b.userName); |
| swap(a.experimentName, b.experimentName); |
| swap(a.creationTime, b.creationTime); |
| swap(a.description, b.description); |
| swap(a.executionId, b.executionId); |
| swap(a.gatewayExecutionId, b.gatewayExecutionId); |
| swap(a.gatewayInstanceId, b.gatewayInstanceId); |
| swap(a.enableEmailNotification, b.enableEmailNotification); |
| swap(a.emailAddresses, b.emailAddresses); |
| swap(a.userConfigurationData, b.userConfigurationData); |
| swap(a.experimentInputs, b.experimentInputs); |
| swap(a.experimentOutputs, b.experimentOutputs); |
| swap(a.experimentStatus, b.experimentStatus); |
| swap(a.errors, b.errors); |
| swap(a.processes, b.processes); |
| swap(a.workflow, b.workflow); |
| swap(a.__isset, b.__isset); |
| } |
| |
| ExperimentModel::ExperimentModel(const ExperimentModel& other45) { |
| experimentId = other45.experimentId; |
| projectId = other45.projectId; |
| gatewayId = other45.gatewayId; |
| experimentType = other45.experimentType; |
| userName = other45.userName; |
| experimentName = other45.experimentName; |
| creationTime = other45.creationTime; |
| description = other45.description; |
| executionId = other45.executionId; |
| gatewayExecutionId = other45.gatewayExecutionId; |
| gatewayInstanceId = other45.gatewayInstanceId; |
| enableEmailNotification = other45.enableEmailNotification; |
| emailAddresses = other45.emailAddresses; |
| userConfigurationData = other45.userConfigurationData; |
| experimentInputs = other45.experimentInputs; |
| experimentOutputs = other45.experimentOutputs; |
| experimentStatus = other45.experimentStatus; |
| errors = other45.errors; |
| processes = other45.processes; |
| workflow = other45.workflow; |
| __isset = other45.__isset; |
| } |
| ExperimentModel& ExperimentModel::operator=(const ExperimentModel& other46) { |
| experimentId = other46.experimentId; |
| projectId = other46.projectId; |
| gatewayId = other46.gatewayId; |
| experimentType = other46.experimentType; |
| userName = other46.userName; |
| experimentName = other46.experimentName; |
| creationTime = other46.creationTime; |
| description = other46.description; |
| executionId = other46.executionId; |
| gatewayExecutionId = other46.gatewayExecutionId; |
| gatewayInstanceId = other46.gatewayInstanceId; |
| enableEmailNotification = other46.enableEmailNotification; |
| emailAddresses = other46.emailAddresses; |
| userConfigurationData = other46.userConfigurationData; |
| experimentInputs = other46.experimentInputs; |
| experimentOutputs = other46.experimentOutputs; |
| experimentStatus = other46.experimentStatus; |
| errors = other46.errors; |
| processes = other46.processes; |
| workflow = other46.workflow; |
| __isset = other46.__isset; |
| return *this; |
| } |
| void ExperimentModel::printTo(std::ostream& out) const { |
| using ::apache::thrift::to_string; |
| out << "ExperimentModel("; |
| out << "experimentId=" << to_string(experimentId); |
| out << ", " << "projectId=" << to_string(projectId); |
| out << ", " << "gatewayId=" << to_string(gatewayId); |
| out << ", " << "experimentType=" << to_string(experimentType); |
| out << ", " << "userName=" << to_string(userName); |
| out << ", " << "experimentName=" << to_string(experimentName); |
| out << ", " << "creationTime="; (__isset.creationTime ? (out << to_string(creationTime)) : (out << "<null>")); |
| out << ", " << "description="; (__isset.description ? (out << to_string(description)) : (out << "<null>")); |
| out << ", " << "executionId="; (__isset.executionId ? (out << to_string(executionId)) : (out << "<null>")); |
| out << ", " << "gatewayExecutionId="; (__isset.gatewayExecutionId ? (out << to_string(gatewayExecutionId)) : (out << "<null>")); |
| out << ", " << "gatewayInstanceId="; (__isset.gatewayInstanceId ? (out << to_string(gatewayInstanceId)) : (out << "<null>")); |
| out << ", " << "enableEmailNotification="; (__isset.enableEmailNotification ? (out << to_string(enableEmailNotification)) : (out << "<null>")); |
| out << ", " << "emailAddresses="; (__isset.emailAddresses ? (out << to_string(emailAddresses)) : (out << "<null>")); |
| out << ", " << "userConfigurationData="; (__isset.userConfigurationData ? (out << to_string(userConfigurationData)) : (out << "<null>")); |
| out << ", " << "experimentInputs="; (__isset.experimentInputs ? (out << to_string(experimentInputs)) : (out << "<null>")); |
| out << ", " << "experimentOutputs="; (__isset.experimentOutputs ? (out << to_string(experimentOutputs)) : (out << "<null>")); |
| out << ", " << "experimentStatus="; (__isset.experimentStatus ? (out << to_string(experimentStatus)) : (out << "<null>")); |
| out << ", " << "errors="; (__isset.errors ? (out << to_string(errors)) : (out << "<null>")); |
| out << ", " << "processes="; (__isset.processes ? (out << to_string(processes)) : (out << "<null>")); |
| out << ", " << "workflow="; (__isset.workflow ? (out << to_string(workflow)) : (out << "<null>")); |
| out << ")"; |
| } |
| |
| |
| ExperimentSummaryModel::~ExperimentSummaryModel() throw() { |
| } |
| |
| |
| void ExperimentSummaryModel::__set_experimentId(const std::string& val) { |
| this->experimentId = val; |
| } |
| |
| void ExperimentSummaryModel::__set_projectId(const std::string& val) { |
| this->projectId = val; |
| } |
| |
| void ExperimentSummaryModel::__set_gatewayId(const std::string& val) { |
| this->gatewayId = val; |
| } |
| |
| void ExperimentSummaryModel::__set_creationTime(const int64_t val) { |
| this->creationTime = val; |
| __isset.creationTime = true; |
| } |
| |
| void ExperimentSummaryModel::__set_userName(const std::string& val) { |
| this->userName = val; |
| } |
| |
| void ExperimentSummaryModel::__set_name(const std::string& val) { |
| this->name = val; |
| } |
| |
| void ExperimentSummaryModel::__set_description(const std::string& val) { |
| this->description = val; |
| __isset.description = true; |
| } |
| |
| void ExperimentSummaryModel::__set_executionId(const std::string& val) { |
| this->executionId = val; |
| __isset.executionId = true; |
| } |
| |
| void ExperimentSummaryModel::__set_resourceHostId(const std::string& val) { |
| this->resourceHostId = val; |
| __isset.resourceHostId = true; |
| } |
| |
| void ExperimentSummaryModel::__set_experimentStatus(const std::string& val) { |
| this->experimentStatus = val; |
| __isset.experimentStatus = true; |
| } |
| |
| void ExperimentSummaryModel::__set_statusUpdateTime(const int64_t val) { |
| this->statusUpdateTime = val; |
| __isset.statusUpdateTime = true; |
| } |
| |
| uint32_t ExperimentSummaryModel::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_experimentId = false; |
| bool isset_projectId = false; |
| bool isset_gatewayId = false; |
| bool isset_userName = false; |
| bool isset_name = 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->experimentId); |
| isset_experimentId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 2: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->projectId); |
| isset_projectId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 3: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->gatewayId); |
| isset_gatewayId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 4: |
| if (ftype == ::apache::thrift::protocol::T_I64) { |
| xfer += iprot->readI64(this->creationTime); |
| this->__isset.creationTime = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 5: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->userName); |
| isset_userName = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 6: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->name); |
| isset_name = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 7: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->description); |
| this->__isset.description = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 8: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->executionId); |
| this->__isset.executionId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 9: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->resourceHostId); |
| this->__isset.resourceHostId = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 10: |
| if (ftype == ::apache::thrift::protocol::T_STRING) { |
| xfer += iprot->readString(this->experimentStatus); |
| this->__isset.experimentStatus = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 12: |
| if (ftype == ::apache::thrift::protocol::T_I64) { |
| xfer += iprot->readI64(this->statusUpdateTime); |
| this->__isset.statusUpdateTime = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| default: |
| xfer += iprot->skip(ftype); |
| break; |
| } |
| xfer += iprot->readFieldEnd(); |
| } |
| |
| xfer += iprot->readStructEnd(); |
| |
| if (!isset_experimentId) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_projectId) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_gatewayId) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_userName) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_name) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| return xfer; |
| } |
| |
| uint32_t ExperimentSummaryModel::write(::apache::thrift::protocol::TProtocol* oprot) const { |
| uint32_t xfer = 0; |
| apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); |
| xfer += oprot->writeStructBegin("ExperimentSummaryModel"); |
| |
| xfer += oprot->writeFieldBegin("experimentId", ::apache::thrift::protocol::T_STRING, 1); |
| xfer += oprot->writeString(this->experimentId); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("projectId", ::apache::thrift::protocol::T_STRING, 2); |
| xfer += oprot->writeString(this->projectId); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("gatewayId", ::apache::thrift::protocol::T_STRING, 3); |
| xfer += oprot->writeString(this->gatewayId); |
| xfer += oprot->writeFieldEnd(); |
| |
| if (this->__isset.creationTime) { |
| xfer += oprot->writeFieldBegin("creationTime", ::apache::thrift::protocol::T_I64, 4); |
| xfer += oprot->writeI64(this->creationTime); |
| xfer += oprot->writeFieldEnd(); |
| } |
| xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 5); |
| xfer += oprot->writeString(this->userName); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("name", ::apache::thrift::protocol::T_STRING, 6); |
| xfer += oprot->writeString(this->name); |
| xfer += oprot->writeFieldEnd(); |
| |
| if (this->__isset.description) { |
| xfer += oprot->writeFieldBegin("description", ::apache::thrift::protocol::T_STRING, 7); |
| xfer += oprot->writeString(this->description); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.executionId) { |
| xfer += oprot->writeFieldBegin("executionId", ::apache::thrift::protocol::T_STRING, 8); |
| xfer += oprot->writeString(this->executionId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.resourceHostId) { |
| xfer += oprot->writeFieldBegin("resourceHostId", ::apache::thrift::protocol::T_STRING, 9); |
| xfer += oprot->writeString(this->resourceHostId); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.experimentStatus) { |
| xfer += oprot->writeFieldBegin("experimentStatus", ::apache::thrift::protocol::T_STRING, 10); |
| xfer += oprot->writeString(this->experimentStatus); |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.statusUpdateTime) { |
| xfer += oprot->writeFieldBegin("statusUpdateTime", ::apache::thrift::protocol::T_I64, 12); |
| xfer += oprot->writeI64(this->statusUpdateTime); |
| xfer += oprot->writeFieldEnd(); |
| } |
| xfer += oprot->writeFieldStop(); |
| xfer += oprot->writeStructEnd(); |
| return xfer; |
| } |
| |
| void swap(ExperimentSummaryModel &a, ExperimentSummaryModel &b) { |
| using ::std::swap; |
| swap(a.experimentId, b.experimentId); |
| swap(a.projectId, b.projectId); |
| swap(a.gatewayId, b.gatewayId); |
| swap(a.creationTime, b.creationTime); |
| swap(a.userName, b.userName); |
| swap(a.name, b.name); |
| swap(a.description, b.description); |
| swap(a.executionId, b.executionId); |
| swap(a.resourceHostId, b.resourceHostId); |
| swap(a.experimentStatus, b.experimentStatus); |
| swap(a.statusUpdateTime, b.statusUpdateTime); |
| swap(a.__isset, b.__isset); |
| } |
| |
| ExperimentSummaryModel::ExperimentSummaryModel(const ExperimentSummaryModel& other47) { |
| experimentId = other47.experimentId; |
| projectId = other47.projectId; |
| gatewayId = other47.gatewayId; |
| creationTime = other47.creationTime; |
| userName = other47.userName; |
| name = other47.name; |
| description = other47.description; |
| executionId = other47.executionId; |
| resourceHostId = other47.resourceHostId; |
| experimentStatus = other47.experimentStatus; |
| statusUpdateTime = other47.statusUpdateTime; |
| __isset = other47.__isset; |
| } |
| ExperimentSummaryModel& ExperimentSummaryModel::operator=(const ExperimentSummaryModel& other48) { |
| experimentId = other48.experimentId; |
| projectId = other48.projectId; |
| gatewayId = other48.gatewayId; |
| creationTime = other48.creationTime; |
| userName = other48.userName; |
| name = other48.name; |
| description = other48.description; |
| executionId = other48.executionId; |
| resourceHostId = other48.resourceHostId; |
| experimentStatus = other48.experimentStatus; |
| statusUpdateTime = other48.statusUpdateTime; |
| __isset = other48.__isset; |
| return *this; |
| } |
| void ExperimentSummaryModel::printTo(std::ostream& out) const { |
| using ::apache::thrift::to_string; |
| out << "ExperimentSummaryModel("; |
| out << "experimentId=" << to_string(experimentId); |
| out << ", " << "projectId=" << to_string(projectId); |
| out << ", " << "gatewayId=" << to_string(gatewayId); |
| out << ", " << "creationTime="; (__isset.creationTime ? (out << to_string(creationTime)) : (out << "<null>")); |
| out << ", " << "userName=" << to_string(userName); |
| out << ", " << "name=" << to_string(name); |
| out << ", " << "description="; (__isset.description ? (out << to_string(description)) : (out << "<null>")); |
| out << ", " << "executionId="; (__isset.executionId ? (out << to_string(executionId)) : (out << "<null>")); |
| out << ", " << "resourceHostId="; (__isset.resourceHostId ? (out << to_string(resourceHostId)) : (out << "<null>")); |
| out << ", " << "experimentStatus="; (__isset.experimentStatus ? (out << to_string(experimentStatus)) : (out << "<null>")); |
| out << ", " << "statusUpdateTime="; (__isset.statusUpdateTime ? (out << to_string(statusUpdateTime)) : (out << "<null>")); |
| out << ")"; |
| } |
| |
| |
| ExperimentStatistics::~ExperimentStatistics() throw() { |
| } |
| |
| |
| void ExperimentStatistics::__set_allExperimentCount(const int32_t val) { |
| this->allExperimentCount = val; |
| } |
| |
| void ExperimentStatistics::__set_completedExperimentCount(const int32_t val) { |
| this->completedExperimentCount = val; |
| } |
| |
| void ExperimentStatistics::__set_cancelledExperimentCount(const int32_t val) { |
| this->cancelledExperimentCount = val; |
| __isset.cancelledExperimentCount = true; |
| } |
| |
| void ExperimentStatistics::__set_failedExperimentCount(const int32_t val) { |
| this->failedExperimentCount = val; |
| } |
| |
| void ExperimentStatistics::__set_createdExperimentCount(const int32_t val) { |
| this->createdExperimentCount = val; |
| } |
| |
| void ExperimentStatistics::__set_runningExperimentCount(const int32_t val) { |
| this->runningExperimentCount = val; |
| } |
| |
| void ExperimentStatistics::__set_allExperiments(const std::vector<ExperimentSummaryModel> & val) { |
| this->allExperiments = val; |
| } |
| |
| void ExperimentStatistics::__set_completedExperiments(const std::vector<ExperimentSummaryModel> & val) { |
| this->completedExperiments = val; |
| __isset.completedExperiments = true; |
| } |
| |
| void ExperimentStatistics::__set_failedExperiments(const std::vector<ExperimentSummaryModel> & val) { |
| this->failedExperiments = val; |
| __isset.failedExperiments = true; |
| } |
| |
| void ExperimentStatistics::__set_cancelledExperiments(const std::vector<ExperimentSummaryModel> & val) { |
| this->cancelledExperiments = val; |
| __isset.cancelledExperiments = true; |
| } |
| |
| void ExperimentStatistics::__set_createdExperiments(const std::vector<ExperimentSummaryModel> & val) { |
| this->createdExperiments = val; |
| __isset.createdExperiments = true; |
| } |
| |
| void ExperimentStatistics::__set_runningExperiments(const std::vector<ExperimentSummaryModel> & val) { |
| this->runningExperiments = val; |
| __isset.runningExperiments = true; |
| } |
| |
| uint32_t ExperimentStatistics::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_allExperimentCount = false; |
| bool isset_completedExperimentCount = false; |
| bool isset_failedExperimentCount = false; |
| bool isset_createdExperimentCount = false; |
| bool isset_runningExperimentCount = false; |
| bool isset_allExperiments = 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) { |
| xfer += iprot->readI32(this->allExperimentCount); |
| isset_allExperimentCount = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 2: |
| if (ftype == ::apache::thrift::protocol::T_I32) { |
| xfer += iprot->readI32(this->completedExperimentCount); |
| isset_completedExperimentCount = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 3: |
| if (ftype == ::apache::thrift::protocol::T_I32) { |
| xfer += iprot->readI32(this->cancelledExperimentCount); |
| this->__isset.cancelledExperimentCount = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 4: |
| if (ftype == ::apache::thrift::protocol::T_I32) { |
| xfer += iprot->readI32(this->failedExperimentCount); |
| isset_failedExperimentCount = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 5: |
| if (ftype == ::apache::thrift::protocol::T_I32) { |
| xfer += iprot->readI32(this->createdExperimentCount); |
| isset_createdExperimentCount = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 6: |
| if (ftype == ::apache::thrift::protocol::T_I32) { |
| xfer += iprot->readI32(this->runningExperimentCount); |
| isset_runningExperimentCount = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 7: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->allExperiments.clear(); |
| uint32_t _size49; |
| ::apache::thrift::protocol::TType _etype52; |
| xfer += iprot->readListBegin(_etype52, _size49); |
| this->allExperiments.resize(_size49); |
| uint32_t _i53; |
| for (_i53 = 0; _i53 < _size49; ++_i53) |
| { |
| xfer += this->allExperiments[_i53].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| isset_allExperiments = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 8: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->completedExperiments.clear(); |
| uint32_t _size54; |
| ::apache::thrift::protocol::TType _etype57; |
| xfer += iprot->readListBegin(_etype57, _size54); |
| this->completedExperiments.resize(_size54); |
| uint32_t _i58; |
| for (_i58 = 0; _i58 < _size54; ++_i58) |
| { |
| xfer += this->completedExperiments[_i58].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.completedExperiments = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 9: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->failedExperiments.clear(); |
| uint32_t _size59; |
| ::apache::thrift::protocol::TType _etype62; |
| xfer += iprot->readListBegin(_etype62, _size59); |
| this->failedExperiments.resize(_size59); |
| uint32_t _i63; |
| for (_i63 = 0; _i63 < _size59; ++_i63) |
| { |
| xfer += this->failedExperiments[_i63].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.failedExperiments = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 10: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->cancelledExperiments.clear(); |
| uint32_t _size64; |
| ::apache::thrift::protocol::TType _etype67; |
| xfer += iprot->readListBegin(_etype67, _size64); |
| this->cancelledExperiments.resize(_size64); |
| uint32_t _i68; |
| for (_i68 = 0; _i68 < _size64; ++_i68) |
| { |
| xfer += this->cancelledExperiments[_i68].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.cancelledExperiments = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 11: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->createdExperiments.clear(); |
| uint32_t _size69; |
| ::apache::thrift::protocol::TType _etype72; |
| xfer += iprot->readListBegin(_etype72, _size69); |
| this->createdExperiments.resize(_size69); |
| uint32_t _i73; |
| for (_i73 = 0; _i73 < _size69; ++_i73) |
| { |
| xfer += this->createdExperiments[_i73].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.createdExperiments = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| case 12: |
| if (ftype == ::apache::thrift::protocol::T_LIST) { |
| { |
| this->runningExperiments.clear(); |
| uint32_t _size74; |
| ::apache::thrift::protocol::TType _etype77; |
| xfer += iprot->readListBegin(_etype77, _size74); |
| this->runningExperiments.resize(_size74); |
| uint32_t _i78; |
| for (_i78 = 0; _i78 < _size74; ++_i78) |
| { |
| xfer += this->runningExperiments[_i78].read(iprot); |
| } |
| xfer += iprot->readListEnd(); |
| } |
| this->__isset.runningExperiments = true; |
| } else { |
| xfer += iprot->skip(ftype); |
| } |
| break; |
| default: |
| xfer += iprot->skip(ftype); |
| break; |
| } |
| xfer += iprot->readFieldEnd(); |
| } |
| |
| xfer += iprot->readStructEnd(); |
| |
| if (!isset_allExperimentCount) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_completedExperimentCount) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_failedExperimentCount) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_createdExperimentCount) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_runningExperimentCount) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| if (!isset_allExperiments) |
| throw TProtocolException(TProtocolException::INVALID_DATA); |
| return xfer; |
| } |
| |
| uint32_t ExperimentStatistics::write(::apache::thrift::protocol::TProtocol* oprot) const { |
| uint32_t xfer = 0; |
| apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); |
| xfer += oprot->writeStructBegin("ExperimentStatistics"); |
| |
| xfer += oprot->writeFieldBegin("allExperimentCount", ::apache::thrift::protocol::T_I32, 1); |
| xfer += oprot->writeI32(this->allExperimentCount); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("completedExperimentCount", ::apache::thrift::protocol::T_I32, 2); |
| xfer += oprot->writeI32(this->completedExperimentCount); |
| xfer += oprot->writeFieldEnd(); |
| |
| if (this->__isset.cancelledExperimentCount) { |
| xfer += oprot->writeFieldBegin("cancelledExperimentCount", ::apache::thrift::protocol::T_I32, 3); |
| xfer += oprot->writeI32(this->cancelledExperimentCount); |
| xfer += oprot->writeFieldEnd(); |
| } |
| xfer += oprot->writeFieldBegin("failedExperimentCount", ::apache::thrift::protocol::T_I32, 4); |
| xfer += oprot->writeI32(this->failedExperimentCount); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("createdExperimentCount", ::apache::thrift::protocol::T_I32, 5); |
| xfer += oprot->writeI32(this->createdExperimentCount); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("runningExperimentCount", ::apache::thrift::protocol::T_I32, 6); |
| xfer += oprot->writeI32(this->runningExperimentCount); |
| xfer += oprot->writeFieldEnd(); |
| |
| xfer += oprot->writeFieldBegin("allExperiments", ::apache::thrift::protocol::T_LIST, 7); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->allExperiments.size())); |
| std::vector<ExperimentSummaryModel> ::const_iterator _iter79; |
| for (_iter79 = this->allExperiments.begin(); _iter79 != this->allExperiments.end(); ++_iter79) |
| { |
| xfer += (*_iter79).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| |
| if (this->__isset.completedExperiments) { |
| xfer += oprot->writeFieldBegin("completedExperiments", ::apache::thrift::protocol::T_LIST, 8); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->completedExperiments.size())); |
| std::vector<ExperimentSummaryModel> ::const_iterator _iter80; |
| for (_iter80 = this->completedExperiments.begin(); _iter80 != this->completedExperiments.end(); ++_iter80) |
| { |
| xfer += (*_iter80).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.failedExperiments) { |
| xfer += oprot->writeFieldBegin("failedExperiments", ::apache::thrift::protocol::T_LIST, 9); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->failedExperiments.size())); |
| std::vector<ExperimentSummaryModel> ::const_iterator _iter81; |
| for (_iter81 = this->failedExperiments.begin(); _iter81 != this->failedExperiments.end(); ++_iter81) |
| { |
| xfer += (*_iter81).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.cancelledExperiments) { |
| xfer += oprot->writeFieldBegin("cancelledExperiments", ::apache::thrift::protocol::T_LIST, 10); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->cancelledExperiments.size())); |
| std::vector<ExperimentSummaryModel> ::const_iterator _iter82; |
| for (_iter82 = this->cancelledExperiments.begin(); _iter82 != this->cancelledExperiments.end(); ++_iter82) |
| { |
| xfer += (*_iter82).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.createdExperiments) { |
| xfer += oprot->writeFieldBegin("createdExperiments", ::apache::thrift::protocol::T_LIST, 11); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->createdExperiments.size())); |
| std::vector<ExperimentSummaryModel> ::const_iterator _iter83; |
| for (_iter83 = this->createdExperiments.begin(); _iter83 != this->createdExperiments.end(); ++_iter83) |
| { |
| xfer += (*_iter83).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| if (this->__isset.runningExperiments) { |
| xfer += oprot->writeFieldBegin("runningExperiments", ::apache::thrift::protocol::T_LIST, 12); |
| { |
| xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->runningExperiments.size())); |
| std::vector<ExperimentSummaryModel> ::const_iterator _iter84; |
| for (_iter84 = this->runningExperiments.begin(); _iter84 != this->runningExperiments.end(); ++_iter84) |
| { |
| xfer += (*_iter84).write(oprot); |
| } |
| xfer += oprot->writeListEnd(); |
| } |
| xfer += oprot->writeFieldEnd(); |
| } |
| xfer += oprot->writeFieldStop(); |
| xfer += oprot->writeStructEnd(); |
| return xfer; |
| } |
| |
| void swap(ExperimentStatistics &a, ExperimentStatistics &b) { |
| using ::std::swap; |
| swap(a.allExperimentCount, b.allExperimentCount); |
| swap(a.completedExperimentCount, b.completedExperimentCount); |
| swap(a.cancelledExperimentCount, b.cancelledExperimentCount); |
| swap(a.failedExperimentCount, b.failedExperimentCount); |
| swap(a.createdExperimentCount, b.createdExperimentCount); |
| swap(a.runningExperimentCount, b.runningExperimentCount); |
| swap(a.allExperiments, b.allExperiments); |
| swap(a.completedExperiments, b.completedExperiments); |
| swap(a.failedExperiments, b.failedExperiments); |
| swap(a.cancelledExperiments, b.cancelledExperiments); |
| swap(a.createdExperiments, b.createdExperiments); |
| swap(a.runningExperiments, b.runningExperiments); |
| swap(a.__isset, b.__isset); |
| } |
| |
| ExperimentStatistics::ExperimentStatistics(const ExperimentStatistics& other85) { |
| allExperimentCount = other85.allExperimentCount; |
| completedExperimentCount = other85.completedExperimentCount; |
| cancelledExperimentCount = other85.cancelledExperimentCount; |
| failedExperimentCount = other85.failedExperimentCount; |
| createdExperimentCount = other85.createdExperimentCount; |
| runningExperimentCount = other85.runningExperimentCount; |
| allExperiments = other85.allExperiments; |
| completedExperiments = other85.completedExperiments; |
| failedExperiments = other85.failedExperiments; |
| cancelledExperiments = other85.cancelledExperiments; |
| createdExperiments = other85.createdExperiments; |
| runningExperiments = other85.runningExperiments; |
| __isset = other85.__isset; |
| } |
| ExperimentStatistics& ExperimentStatistics::operator=(const ExperimentStatistics& other86) { |
| allExperimentCount = other86.allExperimentCount; |
| completedExperimentCount = other86.completedExperimentCount; |
| cancelledExperimentCount = other86.cancelledExperimentCount; |
| failedExperimentCount = other86.failedExperimentCount; |
| createdExperimentCount = other86.createdExperimentCount; |
| runningExperimentCount = other86.runningExperimentCount; |
| allExperiments = other86.allExperiments; |
| completedExperiments = other86.completedExperiments; |
| failedExperiments = other86.failedExperiments; |
| cancelledExperiments = other86.cancelledExperiments; |
| createdExperiments = other86.createdExperiments; |
| runningExperiments = other86.runningExperiments; |
| __isset = other86.__isset; |
| return *this; |
| } |
| void ExperimentStatistics::printTo(std::ostream& out) const { |
| using ::apache::thrift::to_string; |
| out << "ExperimentStatistics("; |
| out << "allExperimentCount=" << to_string(allExperimentCount); |
| out << ", " << "completedExperimentCount=" << to_string(completedExperimentCount); |
| out << ", " << "cancelledExperimentCount="; (__isset.cancelledExperimentCount ? (out << to_string(cancelledExperimentCount)) : (out << "<null>")); |
| out << ", " << "failedExperimentCount=" << to_string(failedExperimentCount); |
| out << ", " << "createdExperimentCount=" << to_string(createdExperimentCount); |
| out << ", " << "runningExperimentCount=" << to_string(runningExperimentCount); |
| out << ", " << "allExperiments=" << to_string(allExperiments); |
| out << ", " << "completedExperiments="; (__isset.completedExperiments ? (out << to_string(completedExperiments)) : (out << "<null>")); |
| out << ", " << "failedExperiments="; (__isset.failedExperiments ? (out << to_string(failedExperiments)) : (out << "<null>")); |
| out << ", " << "cancelledExperiments="; (__isset.cancelledExperiments ? (out << to_string(cancelledExperiments)) : (out << "<null>")); |
| out << ", " << "createdExperiments="; (__isset.createdExperiments ? (out << to_string(createdExperiments)) : (out << "<null>")); |
| out << ", " << "runningExperiments="; (__isset.runningExperiments ? (out << to_string(runningExperiments)) : (out << "<null>")); |
| out << ")"; |
| } |
| |
| }}}} // namespace |
