http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp new file mode 100644 index 0000000..84240c5 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp @@ -0,0 +1,823 @@ +/** + * 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 "file__transfer_models_types.h" + +#include <algorithm> +#include <ostream> + +#include <thrift/TToString.h> + +namespace apache { namespace airavata { namespace model { namespace file { + +int _kStorageResourceProtocolValues[] = { + StorageResourceProtocol::SCP, + StorageResourceProtocol::SFTP, + StorageResourceProtocol::HTTP, + StorageResourceProtocol::HTTPS, + StorageResourceProtocol::GridFTP, + StorageResourceProtocol::LOCAL +}; +const char* _kStorageResourceProtocolNames[] = { + "SCP", + "SFTP", + "HTTP", + "HTTPS", + "GridFTP", + "LOCAL" +}; +const std::map<int, const char*> _StorageResourceProtocol_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(6, _kStorageResourceProtocolValues, _kStorageResourceProtocolNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + +int _kFileNodeTypesValues[] = { + FileNodeTypes::DIRECTORY, + FileNodeTypes::FILE +}; +const char* _kFileNodeTypesNames[] = { + "DIRECTORY", + "FILE" +}; +const std::map<int, const char*> _FileNodeTypes_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kFileNodeTypesValues, _kFileNodeTypesNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + +int _kFileTransferModeValues[] = { + FileTransferMode::SYNC, + FileTransferMode::ASYNC +}; +const char* _kFileTransferModeNames[] = { + "SYNC", + "ASYNC" +}; +const std::map<int, const char*> _FileTransferMode_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kFileTransferModeValues, _kFileTransferModeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + +int _kFileTransferStatusValues[] = { + FileTransferStatus::CREATED, + FileTransferStatus::QUEUED, + FileTransferStatus::RUNNING, + FileTransferStatus::COMPLETED, + FileTransferStatus::FAILED +}; +const char* _kFileTransferStatusNames[] = { + "CREATED", + "QUEUED", + "RUNNING", + "COMPLETED", + "FAILED" +}; +const std::map<int, const char*> _FileTransferStatus_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(5, _kFileTransferStatusValues, _kFileTransferStatusNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + + +FileTransferRequest::~FileTransferRequest() throw() { +} + + +void FileTransferRequest::__set_transferId(const std::string& val) { + this->transferId = val; +__isset.transferId = true; +} + +void FileTransferRequest::__set_srcHostname(const std::string& val) { + this->srcHostname = val; +__isset.srcHostname = true; +} + +void FileTransferRequest::__set_srcLoginName(const std::string& val) { + this->srcLoginName = val; +__isset.srcLoginName = true; +} + +void FileTransferRequest::__set_srcPort(const int64_t val) { + this->srcPort = val; +__isset.srcPort = true; +} + +void FileTransferRequest::__set_srcProtocol(const StorageResourceProtocol::type val) { + this->srcProtocol = val; +__isset.srcProtocol = true; +} + +void FileTransferRequest::__set_srcFilePath(const std::string& val) { + this->srcFilePath = val; +__isset.srcFilePath = true; +} + +void FileTransferRequest::__set_srcHostCredToken(const std::string& val) { + this->srcHostCredToken = val; +__isset.srcHostCredToken = true; +} + +void FileTransferRequest::__set_destHostname(const std::string& val) { + this->destHostname = val; +__isset.destHostname = true; +} + +void FileTransferRequest::__set_destLoginName(const std::string& val) { + this->destLoginName = val; +__isset.destLoginName = true; +} + +void FileTransferRequest::__set_destPort(const int64_t val) { + this->destPort = val; +__isset.destPort = true; +} + +void FileTransferRequest::__set_destProtocol(const StorageResourceProtocol::type val) { + this->destProtocol = val; +__isset.destProtocol = true; +} + +void FileTransferRequest::__set_destFilePath(const std::string& val) { + this->destFilePath = val; +__isset.destFilePath = true; +} + +void FileTransferRequest::__set_destHostCredToken(const std::string& val) { + this->destHostCredToken = val; +__isset.destHostCredToken = true; +} + +void FileTransferRequest::__set_fileTransferMode(const FileTransferMode::type val) { + this->fileTransferMode = val; +__isset.fileTransferMode = true; +} + +void FileTransferRequest::__set_transferStatus(const FileTransferStatus::type val) { + this->transferStatus = val; +__isset.transferStatus = true; +} + +void FileTransferRequest::__set_fileSize(const int64_t val) { + this->fileSize = val; +__isset.fileSize = true; +} + +void FileTransferRequest::__set_transferTime(const int64_t val) { + this->transferTime = val; +__isset.transferTime = true; +} + +void FileTransferRequest::__set_createdTime(const int64_t val) { + this->createdTime = val; +__isset.createdTime = true; +} + +void FileTransferRequest::__set_lastModifiedType(const int64_t val) { + this->lastModifiedType = val; +__isset.lastModifiedType = true; +} + +uint32_t FileTransferRequest::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->transferId); + this->__isset.transferId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->srcHostname); + this->__isset.srcHostname = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->srcLoginName); + this->__isset.srcLoginName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->srcPort); + this->__isset.srcPort = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 5: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast0; + xfer += iprot->readI32(ecast0); + this->srcProtocol = (StorageResourceProtocol::type)ecast0; + this->__isset.srcProtocol = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 6: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->srcFilePath); + this->__isset.srcFilePath = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 7: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->srcHostCredToken); + this->__isset.srcHostCredToken = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 8: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->destHostname); + this->__isset.destHostname = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 9: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->destLoginName); + this->__isset.destLoginName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 10: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->destPort); + this->__isset.destPort = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 11: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast1; + xfer += iprot->readI32(ecast1); + this->destProtocol = (StorageResourceProtocol::type)ecast1; + this->__isset.destProtocol = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 12: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->destFilePath); + this->__isset.destFilePath = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 13: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->destHostCredToken); + this->__isset.destHostCredToken = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 14: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast2; + xfer += iprot->readI32(ecast2); + this->fileTransferMode = (FileTransferMode::type)ecast2; + this->__isset.fileTransferMode = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 15: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast3; + xfer += iprot->readI32(ecast3); + this->transferStatus = (FileTransferStatus::type)ecast3; + this->__isset.transferStatus = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 16: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->fileSize); + this->__isset.fileSize = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 17: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->transferTime); + this->__isset.transferTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 18: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->createdTime); + this->__isset.createdTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 19: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->lastModifiedType); + this->__isset.lastModifiedType = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t FileTransferRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("FileTransferRequest"); + + if (this->__isset.transferId) { + xfer += oprot->writeFieldBegin("transferId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->transferId); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.srcHostname) { + xfer += oprot->writeFieldBegin("srcHostname", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->srcHostname); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.srcLoginName) { + xfer += oprot->writeFieldBegin("srcLoginName", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->srcLoginName); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.srcPort) { + xfer += oprot->writeFieldBegin("srcPort", ::apache::thrift::protocol::T_I64, 4); + xfer += oprot->writeI64(this->srcPort); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.srcProtocol) { + xfer += oprot->writeFieldBegin("srcProtocol", ::apache::thrift::protocol::T_I32, 5); + xfer += oprot->writeI32((int32_t)this->srcProtocol); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.srcFilePath) { + xfer += oprot->writeFieldBegin("srcFilePath", ::apache::thrift::protocol::T_STRING, 6); + xfer += oprot->writeString(this->srcFilePath); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.srcHostCredToken) { + xfer += oprot->writeFieldBegin("srcHostCredToken", ::apache::thrift::protocol::T_STRING, 7); + xfer += oprot->writeString(this->srcHostCredToken); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.destHostname) { + xfer += oprot->writeFieldBegin("destHostname", ::apache::thrift::protocol::T_STRING, 8); + xfer += oprot->writeString(this->destHostname); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.destLoginName) { + xfer += oprot->writeFieldBegin("destLoginName", ::apache::thrift::protocol::T_STRING, 9); + xfer += oprot->writeString(this->destLoginName); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.destPort) { + xfer += oprot->writeFieldBegin("destPort", ::apache::thrift::protocol::T_I64, 10); + xfer += oprot->writeI64(this->destPort); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.destProtocol) { + xfer += oprot->writeFieldBegin("destProtocol", ::apache::thrift::protocol::T_I32, 11); + xfer += oprot->writeI32((int32_t)this->destProtocol); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.destFilePath) { + xfer += oprot->writeFieldBegin("destFilePath", ::apache::thrift::protocol::T_STRING, 12); + xfer += oprot->writeString(this->destFilePath); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.destHostCredToken) { + xfer += oprot->writeFieldBegin("destHostCredToken", ::apache::thrift::protocol::T_STRING, 13); + xfer += oprot->writeString(this->destHostCredToken); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.fileTransferMode) { + xfer += oprot->writeFieldBegin("fileTransferMode", ::apache::thrift::protocol::T_I32, 14); + xfer += oprot->writeI32((int32_t)this->fileTransferMode); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.transferStatus) { + xfer += oprot->writeFieldBegin("transferStatus", ::apache::thrift::protocol::T_I32, 15); + xfer += oprot->writeI32((int32_t)this->transferStatus); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.fileSize) { + xfer += oprot->writeFieldBegin("fileSize", ::apache::thrift::protocol::T_I64, 16); + xfer += oprot->writeI64(this->fileSize); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.transferTime) { + xfer += oprot->writeFieldBegin("transferTime", ::apache::thrift::protocol::T_I64, 17); + xfer += oprot->writeI64(this->transferTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.createdTime) { + xfer += oprot->writeFieldBegin("createdTime", ::apache::thrift::protocol::T_I64, 18); + xfer += oprot->writeI64(this->createdTime); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.lastModifiedType) { + xfer += oprot->writeFieldBegin("lastModifiedType", ::apache::thrift::protocol::T_I64, 19); + xfer += oprot->writeI64(this->lastModifiedType); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +void swap(FileTransferRequest &a, FileTransferRequest &b) { + using ::std::swap; + swap(a.transferId, b.transferId); + swap(a.srcHostname, b.srcHostname); + swap(a.srcLoginName, b.srcLoginName); + swap(a.srcPort, b.srcPort); + swap(a.srcProtocol, b.srcProtocol); + swap(a.srcFilePath, b.srcFilePath); + swap(a.srcHostCredToken, b.srcHostCredToken); + swap(a.destHostname, b.destHostname); + swap(a.destLoginName, b.destLoginName); + swap(a.destPort, b.destPort); + swap(a.destProtocol, b.destProtocol); + swap(a.destFilePath, b.destFilePath); + swap(a.destHostCredToken, b.destHostCredToken); + swap(a.fileTransferMode, b.fileTransferMode); + swap(a.transferStatus, b.transferStatus); + swap(a.fileSize, b.fileSize); + swap(a.transferTime, b.transferTime); + swap(a.createdTime, b.createdTime); + swap(a.lastModifiedType, b.lastModifiedType); + swap(a.__isset, b.__isset); +} + +FileTransferRequest::FileTransferRequest(const FileTransferRequest& other4) { + transferId = other4.transferId; + srcHostname = other4.srcHostname; + srcLoginName = other4.srcLoginName; + srcPort = other4.srcPort; + srcProtocol = other4.srcProtocol; + srcFilePath = other4.srcFilePath; + srcHostCredToken = other4.srcHostCredToken; + destHostname = other4.destHostname; + destLoginName = other4.destLoginName; + destPort = other4.destPort; + destProtocol = other4.destProtocol; + destFilePath = other4.destFilePath; + destHostCredToken = other4.destHostCredToken; + fileTransferMode = other4.fileTransferMode; + transferStatus = other4.transferStatus; + fileSize = other4.fileSize; + transferTime = other4.transferTime; + createdTime = other4.createdTime; + lastModifiedType = other4.lastModifiedType; + __isset = other4.__isset; +} +FileTransferRequest& FileTransferRequest::operator=(const FileTransferRequest& other5) { + transferId = other5.transferId; + srcHostname = other5.srcHostname; + srcLoginName = other5.srcLoginName; + srcPort = other5.srcPort; + srcProtocol = other5.srcProtocol; + srcFilePath = other5.srcFilePath; + srcHostCredToken = other5.srcHostCredToken; + destHostname = other5.destHostname; + destLoginName = other5.destLoginName; + destPort = other5.destPort; + destProtocol = other5.destProtocol; + destFilePath = other5.destFilePath; + destHostCredToken = other5.destHostCredToken; + fileTransferMode = other5.fileTransferMode; + transferStatus = other5.transferStatus; + fileSize = other5.fileSize; + transferTime = other5.transferTime; + createdTime = other5.createdTime; + lastModifiedType = other5.lastModifiedType; + __isset = other5.__isset; + return *this; +} +void FileTransferRequest::printTo(std::ostream& out) const { + using ::apache::thrift::to_string; + out << "FileTransferRequest("; + out << "transferId="; (__isset.transferId ? (out << to_string(transferId)) : (out << "<null>")); + out << ", " << "srcHostname="; (__isset.srcHostname ? (out << to_string(srcHostname)) : (out << "<null>")); + out << ", " << "srcLoginName="; (__isset.srcLoginName ? (out << to_string(srcLoginName)) : (out << "<null>")); + out << ", " << "srcPort="; (__isset.srcPort ? (out << to_string(srcPort)) : (out << "<null>")); + out << ", " << "srcProtocol="; (__isset.srcProtocol ? (out << to_string(srcProtocol)) : (out << "<null>")); + out << ", " << "srcFilePath="; (__isset.srcFilePath ? (out << to_string(srcFilePath)) : (out << "<null>")); + out << ", " << "srcHostCredToken="; (__isset.srcHostCredToken ? (out << to_string(srcHostCredToken)) : (out << "<null>")); + out << ", " << "destHostname="; (__isset.destHostname ? (out << to_string(destHostname)) : (out << "<null>")); + out << ", " << "destLoginName="; (__isset.destLoginName ? (out << to_string(destLoginName)) : (out << "<null>")); + out << ", " << "destPort="; (__isset.destPort ? (out << to_string(destPort)) : (out << "<null>")); + out << ", " << "destProtocol="; (__isset.destProtocol ? (out << to_string(destProtocol)) : (out << "<null>")); + out << ", " << "destFilePath="; (__isset.destFilePath ? (out << to_string(destFilePath)) : (out << "<null>")); + out << ", " << "destHostCredToken="; (__isset.destHostCredToken ? (out << to_string(destHostCredToken)) : (out << "<null>")); + out << ", " << "fileTransferMode="; (__isset.fileTransferMode ? (out << to_string(fileTransferMode)) : (out << "<null>")); + out << ", " << "transferStatus="; (__isset.transferStatus ? (out << to_string(transferStatus)) : (out << "<null>")); + out << ", " << "fileSize="; (__isset.fileSize ? (out << to_string(fileSize)) : (out << "<null>")); + out << ", " << "transferTime="; (__isset.transferTime ? (out << to_string(transferTime)) : (out << "<null>")); + out << ", " << "createdTime="; (__isset.createdTime ? (out << to_string(createdTime)) : (out << "<null>")); + out << ", " << "lastModifiedType="; (__isset.lastModifiedType ? (out << to_string(lastModifiedType)) : (out << "<null>")); + out << ")"; +} + + +FileNode::~FileNode() throw() { +} + + +void FileNode::__set_type(const FileNodeTypes::type val) { + this->type = val; +__isset.type = true; +} + +void FileNode::__set_size(const int64_t val) { + this->size = val; +__isset.size = true; +} + +void FileNode::__set_nativeType(const std::string& val) { + this->nativeType = val; +__isset.nativeType = true; +} + +void FileNode::__set_name(const std::string& val) { + this->name = val; +__isset.name = true; +} + +void FileNode::__set_path(const std::string& val) { + this->path = val; +__isset.path = true; +} + +void FileNode::__set_storageHostName(const std::string& val) { + this->storageHostName = val; +__isset.storageHostName = true; +} + +void FileNode::__set_lastModifiedType(const int64_t val) { + this->lastModifiedType = val; +__isset.lastModifiedType = true; +} + +void FileNode::__set_createdTime(const int64_t val) { + this->createdTime = val; +__isset.createdTime = true; +} + +uint32_t FileNode::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast6; + xfer += iprot->readI32(ecast6); + this->type = (FileNodeTypes::type)ecast6; + this->__isset.type = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->size); + this->__isset.size = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->nativeType); + this->__isset.nativeType = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->name); + this->__isset.name = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 5: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->path); + this->__isset.path = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 6: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->storageHostName); + this->__isset.storageHostName = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 7: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->lastModifiedType); + this->__isset.lastModifiedType = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 8: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->createdTime); + this->__isset.createdTime = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t FileNode::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("FileNode"); + + if (this->__isset.type) { + xfer += oprot->writeFieldBegin("type", ::apache::thrift::protocol::T_I32, 1); + xfer += oprot->writeI32((int32_t)this->type); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.size) { + xfer += oprot->writeFieldBegin("size", ::apache::thrift::protocol::T_I64, 2); + xfer += oprot->writeI64(this->size); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.nativeType) { + xfer += oprot->writeFieldBegin("nativeType", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->nativeType); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.name) { + xfer += oprot->writeFieldBegin("name", ::apache::thrift::protocol::T_STRING, 4); + xfer += oprot->writeString(this->name); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.path) { + xfer += oprot->writeFieldBegin("path", ::apache::thrift::protocol::T_STRING, 5); + xfer += oprot->writeString(this->path); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.storageHostName) { + xfer += oprot->writeFieldBegin("storageHostName", ::apache::thrift::protocol::T_STRING, 6); + xfer += oprot->writeString(this->storageHostName); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.lastModifiedType) { + xfer += oprot->writeFieldBegin("lastModifiedType", ::apache::thrift::protocol::T_I64, 7); + xfer += oprot->writeI64(this->lastModifiedType); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.createdTime) { + xfer += oprot->writeFieldBegin("createdTime", ::apache::thrift::protocol::T_I64, 8); + xfer += oprot->writeI64(this->createdTime); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +void swap(FileNode &a, FileNode &b) { + using ::std::swap; + swap(a.type, b.type); + swap(a.size, b.size); + swap(a.nativeType, b.nativeType); + swap(a.name, b.name); + swap(a.path, b.path); + swap(a.storageHostName, b.storageHostName); + swap(a.lastModifiedType, b.lastModifiedType); + swap(a.createdTime, b.createdTime); + swap(a.__isset, b.__isset); +} + +FileNode::FileNode(const FileNode& other7) { + type = other7.type; + size = other7.size; + nativeType = other7.nativeType; + name = other7.name; + path = other7.path; + storageHostName = other7.storageHostName; + lastModifiedType = other7.lastModifiedType; + createdTime = other7.createdTime; + __isset = other7.__isset; +} +FileNode& FileNode::operator=(const FileNode& other8) { + type = other8.type; + size = other8.size; + nativeType = other8.nativeType; + name = other8.name; + path = other8.path; + storageHostName = other8.storageHostName; + lastModifiedType = other8.lastModifiedType; + createdTime = other8.createdTime; + __isset = other8.__isset; + return *this; +} +void FileNode::printTo(std::ostream& out) const { + using ::apache::thrift::to_string; + out << "FileNode("; + out << "type="; (__isset.type ? (out << to_string(type)) : (out << "<null>")); + out << ", " << "size="; (__isset.size ? (out << to_string(size)) : (out << "<null>")); + out << ", " << "nativeType="; (__isset.nativeType ? (out << to_string(nativeType)) : (out << "<null>")); + out << ", " << "name="; (__isset.name ? (out << to_string(name)) : (out << "<null>")); + out << ", " << "path="; (__isset.path ? (out << to_string(path)) : (out << "<null>")); + out << ", " << "storageHostName="; (__isset.storageHostName ? (out << to_string(storageHostName)) : (out << "<null>")); + out << ", " << "lastModifiedType="; (__isset.lastModifiedType ? (out << to_string(lastModifiedType)) : (out << "<null>")); + out << ", " << "createdTime="; (__isset.createdTime ? (out << to_string(createdTime)) : (out << "<null>")); + out << ")"; +} + +}}}} // namespace
http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h new file mode 100644 index 0000000..0ea49e6 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h @@ -0,0 +1,384 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +#ifndef file__transfer_models_TYPES_H +#define file__transfer_models_TYPES_H + +#include <iosfwd> + +#include <thrift/Thrift.h> +#include <thrift/TApplicationException.h> +#include <thrift/protocol/TProtocol.h> +#include <thrift/transport/TTransport.h> + +#include <thrift/cxxfunctional.h> + + +namespace apache { namespace airavata { namespace model { namespace file { + +struct StorageResourceProtocol { + enum type { + SCP = 0, + SFTP = 1, + HTTP = 2, + HTTPS = 3, + GridFTP = 4, + LOCAL = 5 + }; +}; + +extern const std::map<int, const char*> _StorageResourceProtocol_VALUES_TO_NAMES; + +struct FileNodeTypes { + enum type { + DIRECTORY = 0, + FILE = 1 + }; +}; + +extern const std::map<int, const char*> _FileNodeTypes_VALUES_TO_NAMES; + +struct FileTransferMode { + enum type { + SYNC = 0, + ASYNC = 1 + }; +}; + +extern const std::map<int, const char*> _FileTransferMode_VALUES_TO_NAMES; + +struct FileTransferStatus { + enum type { + CREATED = 0, + QUEUED = 1, + RUNNING = 2, + COMPLETED = 3, + FAILED = 4 + }; +}; + +extern const std::map<int, const char*> _FileTransferStatus_VALUES_TO_NAMES; + +class FileTransferRequest; + +class FileNode; + +typedef struct _FileTransferRequest__isset { + _FileTransferRequest__isset() : transferId(false), srcHostname(false), srcLoginName(false), srcPort(false), srcProtocol(false), srcFilePath(false), srcHostCredToken(false), destHostname(false), destLoginName(false), destPort(false), destProtocol(false), destFilePath(false), destHostCredToken(false), fileTransferMode(false), transferStatus(false), fileSize(false), transferTime(false), createdTime(false), lastModifiedType(false) {} + bool transferId :1; + bool srcHostname :1; + bool srcLoginName :1; + bool srcPort :1; + bool srcProtocol :1; + bool srcFilePath :1; + bool srcHostCredToken :1; + bool destHostname :1; + bool destLoginName :1; + bool destPort :1; + bool destProtocol :1; + bool destFilePath :1; + bool destHostCredToken :1; + bool fileTransferMode :1; + bool transferStatus :1; + bool fileSize :1; + bool transferTime :1; + bool createdTime :1; + bool lastModifiedType :1; +} _FileTransferRequest__isset; + +class FileTransferRequest { + public: + + FileTransferRequest(const FileTransferRequest&); + FileTransferRequest& operator=(const FileTransferRequest&); + FileTransferRequest() : transferId(), srcHostname(), srcLoginName(), srcPort(0), srcProtocol((StorageResourceProtocol::type)0), srcFilePath(), srcHostCredToken(), destHostname(), destLoginName(), destPort(0), destProtocol((StorageResourceProtocol::type)0), destFilePath(), destHostCredToken(), fileTransferMode((FileTransferMode::type)0), transferStatus((FileTransferStatus::type)0), fileSize(0), transferTime(0), createdTime(0), lastModifiedType(0) { + } + + virtual ~FileTransferRequest() throw(); + std::string transferId; + std::string srcHostname; + std::string srcLoginName; + int64_t srcPort; + StorageResourceProtocol::type srcProtocol; + std::string srcFilePath; + std::string srcHostCredToken; + std::string destHostname; + std::string destLoginName; + int64_t destPort; + StorageResourceProtocol::type destProtocol; + std::string destFilePath; + std::string destHostCredToken; + FileTransferMode::type fileTransferMode; + FileTransferStatus::type transferStatus; + int64_t fileSize; + int64_t transferTime; + int64_t createdTime; + int64_t lastModifiedType; + + _FileTransferRequest__isset __isset; + + void __set_transferId(const std::string& val); + + void __set_srcHostname(const std::string& val); + + void __set_srcLoginName(const std::string& val); + + void __set_srcPort(const int64_t val); + + void __set_srcProtocol(const StorageResourceProtocol::type val); + + void __set_srcFilePath(const std::string& val); + + void __set_srcHostCredToken(const std::string& val); + + void __set_destHostname(const std::string& val); + + void __set_destLoginName(const std::string& val); + + void __set_destPort(const int64_t val); + + void __set_destProtocol(const StorageResourceProtocol::type val); + + void __set_destFilePath(const std::string& val); + + void __set_destHostCredToken(const std::string& val); + + void __set_fileTransferMode(const FileTransferMode::type val); + + void __set_transferStatus(const FileTransferStatus::type val); + + void __set_fileSize(const int64_t val); + + void __set_transferTime(const int64_t val); + + void __set_createdTime(const int64_t val); + + void __set_lastModifiedType(const int64_t val); + + bool operator == (const FileTransferRequest & rhs) const + { + if (__isset.transferId != rhs.__isset.transferId) + return false; + else if (__isset.transferId && !(transferId == rhs.transferId)) + return false; + if (__isset.srcHostname != rhs.__isset.srcHostname) + return false; + else if (__isset.srcHostname && !(srcHostname == rhs.srcHostname)) + return false; + if (__isset.srcLoginName != rhs.__isset.srcLoginName) + return false; + else if (__isset.srcLoginName && !(srcLoginName == rhs.srcLoginName)) + return false; + if (__isset.srcPort != rhs.__isset.srcPort) + return false; + else if (__isset.srcPort && !(srcPort == rhs.srcPort)) + return false; + if (__isset.srcProtocol != rhs.__isset.srcProtocol) + return false; + else if (__isset.srcProtocol && !(srcProtocol == rhs.srcProtocol)) + return false; + if (__isset.srcFilePath != rhs.__isset.srcFilePath) + return false; + else if (__isset.srcFilePath && !(srcFilePath == rhs.srcFilePath)) + return false; + if (__isset.srcHostCredToken != rhs.__isset.srcHostCredToken) + return false; + else if (__isset.srcHostCredToken && !(srcHostCredToken == rhs.srcHostCredToken)) + return false; + if (__isset.destHostname != rhs.__isset.destHostname) + return false; + else if (__isset.destHostname && !(destHostname == rhs.destHostname)) + return false; + if (__isset.destLoginName != rhs.__isset.destLoginName) + return false; + else if (__isset.destLoginName && !(destLoginName == rhs.destLoginName)) + return false; + if (__isset.destPort != rhs.__isset.destPort) + return false; + else if (__isset.destPort && !(destPort == rhs.destPort)) + return false; + if (__isset.destProtocol != rhs.__isset.destProtocol) + return false; + else if (__isset.destProtocol && !(destProtocol == rhs.destProtocol)) + return false; + if (__isset.destFilePath != rhs.__isset.destFilePath) + return false; + else if (__isset.destFilePath && !(destFilePath == rhs.destFilePath)) + return false; + if (__isset.destHostCredToken != rhs.__isset.destHostCredToken) + return false; + else if (__isset.destHostCredToken && !(destHostCredToken == rhs.destHostCredToken)) + return false; + if (__isset.fileTransferMode != rhs.__isset.fileTransferMode) + return false; + else if (__isset.fileTransferMode && !(fileTransferMode == rhs.fileTransferMode)) + return false; + if (__isset.transferStatus != rhs.__isset.transferStatus) + return false; + else if (__isset.transferStatus && !(transferStatus == rhs.transferStatus)) + return false; + if (__isset.fileSize != rhs.__isset.fileSize) + return false; + else if (__isset.fileSize && !(fileSize == rhs.fileSize)) + return false; + if (__isset.transferTime != rhs.__isset.transferTime) + return false; + else if (__isset.transferTime && !(transferTime == rhs.transferTime)) + return false; + if (__isset.createdTime != rhs.__isset.createdTime) + return false; + else if (__isset.createdTime && !(createdTime == rhs.createdTime)) + return false; + if (__isset.lastModifiedType != rhs.__isset.lastModifiedType) + return false; + else if (__isset.lastModifiedType && !(lastModifiedType == rhs.lastModifiedType)) + return false; + return true; + } + bool operator != (const FileTransferRequest &rhs) const { + return !(*this == rhs); + } + + bool operator < (const FileTransferRequest & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + + virtual void printTo(std::ostream& out) const; +}; + +void swap(FileTransferRequest &a, FileTransferRequest &b); + +inline std::ostream& operator<<(std::ostream& out, const FileTransferRequest& obj) +{ + obj.printTo(out); + return out; +} + +typedef struct _FileNode__isset { + _FileNode__isset() : type(false), size(false), nativeType(false), name(false), path(false), storageHostName(false), lastModifiedType(false), createdTime(false) {} + bool type :1; + bool size :1; + bool nativeType :1; + bool name :1; + bool path :1; + bool storageHostName :1; + bool lastModifiedType :1; + bool createdTime :1; +} _FileNode__isset; + +class FileNode { + public: + + FileNode(const FileNode&); + FileNode& operator=(const FileNode&); + FileNode() : type((FileNodeTypes::type)0), size(0), nativeType(), name(), path(), storageHostName(), lastModifiedType(0), createdTime(0) { + } + + virtual ~FileNode() throw(); + FileNodeTypes::type type; + int64_t size; + std::string nativeType; + std::string name; + std::string path; + std::string storageHostName; + int64_t lastModifiedType; + int64_t createdTime; + + _FileNode__isset __isset; + + void __set_type(const FileNodeTypes::type val); + + void __set_size(const int64_t val); + + void __set_nativeType(const std::string& val); + + void __set_name(const std::string& val); + + void __set_path(const std::string& val); + + void __set_storageHostName(const std::string& val); + + void __set_lastModifiedType(const int64_t val); + + void __set_createdTime(const int64_t val); + + bool operator == (const FileNode & rhs) const + { + if (__isset.type != rhs.__isset.type) + return false; + else if (__isset.type && !(type == rhs.type)) + return false; + if (__isset.size != rhs.__isset.size) + return false; + else if (__isset.size && !(size == rhs.size)) + return false; + if (__isset.nativeType != rhs.__isset.nativeType) + return false; + else if (__isset.nativeType && !(nativeType == rhs.nativeType)) + return false; + if (__isset.name != rhs.__isset.name) + return false; + else if (__isset.name && !(name == rhs.name)) + return false; + if (__isset.path != rhs.__isset.path) + return false; + else if (__isset.path && !(path == rhs.path)) + return false; + if (__isset.storageHostName != rhs.__isset.storageHostName) + return false; + else if (__isset.storageHostName && !(storageHostName == rhs.storageHostName)) + return false; + if (__isset.lastModifiedType != rhs.__isset.lastModifiedType) + return false; + else if (__isset.lastModifiedType && !(lastModifiedType == rhs.lastModifiedType)) + return false; + if (__isset.createdTime != rhs.__isset.createdTime) + return false; + else if (__isset.createdTime && !(createdTime == rhs.createdTime)) + return false; + return true; + } + bool operator != (const FileNode &rhs) const { + return !(*this == rhs); + } + + bool operator < (const FileNode & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + + virtual void printTo(std::ostream& out) const; +}; + +void swap(FileNode &a, FileNode &b); + +inline std::ostream& operator<<(std::ostream& out, const FileNode& obj) +{ + obj.printTo(out); + return out; +} + +}}}} // namespace + +#endif http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.cpp deleted file mode 100644 index d130bfd..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.cpp +++ /dev/null @@ -1,34 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "gatewayResourceProfileModel_constants.h" - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace gatewayprofile { - -const gatewayResourceProfileModelConstants g_gatewayResourceProfileModel_constants; - -gatewayResourceProfileModelConstants::gatewayResourceProfileModelConstants() { -} - -}}}}} // namespace - http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.h deleted file mode 100644 index da93846..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_constants.h +++ /dev/null @@ -1,41 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef gatewayResourceProfileModel_CONSTANTS_H -#define gatewayResourceProfileModel_CONSTANTS_H - -#include "gatewayResourceProfileModel_types.h" - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace gatewayprofile { - -class gatewayResourceProfileModelConstants { - public: - gatewayResourceProfileModelConstants(); - -}; - -extern const gatewayResourceProfileModelConstants g_gatewayResourceProfileModel_constants; - -}}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp deleted file mode 100644 index 1c465e4..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.cpp +++ /dev/null @@ -1,298 +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.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "gatewayResourceProfileModel_types.h" - -#include <algorithm> - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace gatewayprofile { - -const char* ComputeResourcePreference::ascii_fingerprint = "D89E0E13D04B60B99B78496AC9B85D52"; -const uint8_t ComputeResourcePreference::binary_fingerprint[16] = {0xD8,0x9E,0x0E,0x13,0xD0,0x4B,0x60,0xB9,0x9B,0x78,0x49,0x6A,0xC9,0xB8,0x5D,0x52}; - -uint32_t ComputeResourcePreference::read(::apache::thrift::protocol::TProtocol* 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_overridebyAiravata = 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_BOOL) { - xfer += iprot->readBool(this->overridebyAiravata); - isset_overridebyAiravata = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->loginUserName); - this->__isset.loginUserName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast0; - xfer += iprot->readI32(ecast0); - this->preferredJobSubmissionProtocol = ( ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type)ecast0; - this->__isset.preferredJobSubmissionProtocol = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast1; - xfer += iprot->readI32(ecast1); - this->preferredDataMovementProtocol = ( ::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type)ecast1; - this->__isset.preferredDataMovementProtocol = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 6: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->preferredBatchQueue); - this->__isset.preferredBatchQueue = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 7: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->scratchLocation); - this->__isset.scratchLocation = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 8: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->allocationProjectNumber); - this->__isset.allocationProjectNumber = 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_overridebyAiravata) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t ComputeResourcePreference::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ComputeResourcePreference"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("overridebyAiravata", ::apache::thrift::protocol::T_BOOL, 2); - xfer += oprot->writeBool(this->overridebyAiravata); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.loginUserName) { - xfer += oprot->writeFieldBegin("loginUserName", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->loginUserName); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.preferredJobSubmissionProtocol) { - xfer += oprot->writeFieldBegin("preferredJobSubmissionProtocol", ::apache::thrift::protocol::T_I32, 4); - xfer += oprot->writeI32((int32_t)this->preferredJobSubmissionProtocol); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.preferredDataMovementProtocol) { - xfer += oprot->writeFieldBegin("preferredDataMovementProtocol", ::apache::thrift::protocol::T_I32, 5); - xfer += oprot->writeI32((int32_t)this->preferredDataMovementProtocol); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.preferredBatchQueue) { - xfer += oprot->writeFieldBegin("preferredBatchQueue", ::apache::thrift::protocol::T_STRING, 6); - xfer += oprot->writeString(this->preferredBatchQueue); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.scratchLocation) { - xfer += oprot->writeFieldBegin("scratchLocation", ::apache::thrift::protocol::T_STRING, 7); - xfer += oprot->writeString(this->scratchLocation); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.allocationProjectNumber) { - xfer += oprot->writeFieldBegin("allocationProjectNumber", ::apache::thrift::protocol::T_STRING, 8); - xfer += oprot->writeString(this->allocationProjectNumber); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(ComputeResourcePreference &a, ComputeResourcePreference &b) { - using ::std::swap; - swap(a.computeResourceId, b.computeResourceId); - swap(a.overridebyAiravata, b.overridebyAiravata); - swap(a.loginUserName, b.loginUserName); - swap(a.preferredJobSubmissionProtocol, b.preferredJobSubmissionProtocol); - swap(a.preferredDataMovementProtocol, b.preferredDataMovementProtocol); - swap(a.preferredBatchQueue, b.preferredBatchQueue); - swap(a.scratchLocation, b.scratchLocation); - swap(a.allocationProjectNumber, b.allocationProjectNumber); - swap(a.__isset, b.__isset); -} - -const char* GatewayResourceProfile::ascii_fingerprint = "106DE1CD0F7026F6471DE8DAF360BE03"; -const uint8_t GatewayResourceProfile::binary_fingerprint[16] = {0x10,0x6D,0xE1,0xCD,0x0F,0x70,0x26,0xF6,0x47,0x1D,0xE8,0xDA,0xF3,0x60,0xBE,0x03}; - -uint32_t GatewayResourceProfile::read(::apache::thrift::protocol::TProtocol* 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_gatewayID = 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->gatewayID); - isset_gatewayID = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->computeResourcePreferences.clear(); - uint32_t _size2; - ::apache::thrift::protocol::TType _etype5; - xfer += iprot->readListBegin(_etype5, _size2); - this->computeResourcePreferences.resize(_size2); - uint32_t _i6; - for (_i6 = 0; _i6 < _size2; ++_i6) - { - xfer += this->computeResourcePreferences[_i6].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.computeResourcePreferences = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_gatewayID) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t GatewayResourceProfile::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - xfer += oprot->writeStructBegin("GatewayResourceProfile"); - - xfer += oprot->writeFieldBegin("gatewayID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->gatewayID); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.computeResourcePreferences) { - xfer += oprot->writeFieldBegin("computeResourcePreferences", ::apache::thrift::protocol::T_LIST, 2); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->computeResourcePreferences.size())); - std::vector<ComputeResourcePreference> ::const_iterator _iter7; - for (_iter7 = this->computeResourcePreferences.begin(); _iter7 != this->computeResourcePreferences.end(); ++_iter7) - { - xfer += (*_iter7).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GatewayResourceProfile &a, GatewayResourceProfile &b) { - using ::std::swap; - swap(a.gatewayID, b.gatewayID); - swap(a.computeResourcePreferences, b.computeResourcePreferences); - swap(a.__isset, b.__isset); -} - -}}}}} // namespace http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h deleted file mode 100644 index c664087..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/gatewayResourceProfileModel_types.h +++ /dev/null @@ -1,208 +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.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef gatewayResourceProfileModel_TYPES_H -#define gatewayResourceProfileModel_TYPES_H - -#include <thrift/Thrift.h> -#include <thrift/TApplicationException.h> -#include <thrift/protocol/TProtocol.h> -#include <thrift/transport/TTransport.h> - -#include <thrift/cxxfunctional.h> -#include "computeResourceModel_types.h" - - -namespace apache { namespace airavata { namespace model { namespace appcatalog { namespace gatewayprofile { - -typedef struct _ComputeResourcePreference__isset { - _ComputeResourcePreference__isset() : loginUserName(false), preferredJobSubmissionProtocol(false), preferredDataMovementProtocol(false), preferredBatchQueue(false), scratchLocation(false), allocationProjectNumber(false) {} - bool loginUserName; - bool preferredJobSubmissionProtocol; - bool preferredDataMovementProtocol; - bool preferredBatchQueue; - bool scratchLocation; - bool allocationProjectNumber; -} _ComputeResourcePreference__isset; - -class ComputeResourcePreference { - public: - - static const char* ascii_fingerprint; // = "D89E0E13D04B60B99B78496AC9B85D52"; - static const uint8_t binary_fingerprint[16]; // = {0xD8,0x9E,0x0E,0x13,0xD0,0x4B,0x60,0xB9,0x9B,0x78,0x49,0x6A,0xC9,0xB8,0x5D,0x52}; - - ComputeResourcePreference() : computeResourceId(), overridebyAiravata(true), loginUserName(), preferredJobSubmissionProtocol(( ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type)0), preferredDataMovementProtocol(( ::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type)0), preferredBatchQueue(), scratchLocation(), allocationProjectNumber() { - } - - virtual ~ComputeResourcePreference() throw() {} - - std::string computeResourceId; - bool overridebyAiravata; - std::string loginUserName; - ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type preferredJobSubmissionProtocol; - ::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type preferredDataMovementProtocol; - std::string preferredBatchQueue; - std::string scratchLocation; - std::string allocationProjectNumber; - - _ComputeResourcePreference__isset __isset; - - void __set_computeResourceId(const std::string& val) { - computeResourceId = val; - } - - void __set_overridebyAiravata(const bool val) { - overridebyAiravata = val; - } - - void __set_loginUserName(const std::string& val) { - loginUserName = val; - __isset.loginUserName = true; - } - - void __set_preferredJobSubmissionProtocol(const ::apache::airavata::model::appcatalog::computeresource::JobSubmissionProtocol::type val) { - preferredJobSubmissionProtocol = val; - __isset.preferredJobSubmissionProtocol = true; - } - - void __set_preferredDataMovementProtocol(const ::apache::airavata::model::appcatalog::computeresource::DataMovementProtocol::type val) { - preferredDataMovementProtocol = val; - __isset.preferredDataMovementProtocol = true; - } - - void __set_preferredBatchQueue(const std::string& val) { - preferredBatchQueue = val; - __isset.preferredBatchQueue = true; - } - - void __set_scratchLocation(const std::string& val) { - scratchLocation = val; - __isset.scratchLocation = true; - } - - void __set_allocationProjectNumber(const std::string& val) { - allocationProjectNumber = val; - __isset.allocationProjectNumber = true; - } - - bool operator == (const ComputeResourcePreference & rhs) const - { - if (!(computeResourceId == rhs.computeResourceId)) - return false; - if (!(overridebyAiravata == rhs.overridebyAiravata)) - return false; - if (__isset.loginUserName != rhs.__isset.loginUserName) - return false; - else if (__isset.loginUserName && !(loginUserName == rhs.loginUserName)) - return false; - if (__isset.preferredJobSubmissionProtocol != rhs.__isset.preferredJobSubmissionProtocol) - return false; - else if (__isset.preferredJobSubmissionProtocol && !(preferredJobSubmissionProtocol == rhs.preferredJobSubmissionProtocol)) - return false; - if (__isset.preferredDataMovementProtocol != rhs.__isset.preferredDataMovementProtocol) - return false; - else if (__isset.preferredDataMovementProtocol && !(preferredDataMovementProtocol == rhs.preferredDataMovementProtocol)) - return false; - if (__isset.preferredBatchQueue != rhs.__isset.preferredBatchQueue) - return false; - else if (__isset.preferredBatchQueue && !(preferredBatchQueue == rhs.preferredBatchQueue)) - return false; - if (__isset.scratchLocation != rhs.__isset.scratchLocation) - return false; - else if (__isset.scratchLocation && !(scratchLocation == rhs.scratchLocation)) - return false; - if (__isset.allocationProjectNumber != rhs.__isset.allocationProjectNumber) - return false; - else if (__isset.allocationProjectNumber && !(allocationProjectNumber == rhs.allocationProjectNumber)) - return false; - return true; - } - bool operator != (const ComputeResourcePreference &rhs) const { - return !(*this == rhs); - } - - bool operator < (const ComputeResourcePreference & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -void swap(ComputeResourcePreference &a, ComputeResourcePreference &b); - -typedef struct _GatewayResourceProfile__isset { - _GatewayResourceProfile__isset() : computeResourcePreferences(false) {} - bool computeResourcePreferences; -} _GatewayResourceProfile__isset; - -class GatewayResourceProfile { - public: - - static const char* ascii_fingerprint; // = "106DE1CD0F7026F6471DE8DAF360BE03"; - static const uint8_t binary_fingerprint[16]; // = {0x10,0x6D,0xE1,0xCD,0x0F,0x70,0x26,0xF6,0x47,0x1D,0xE8,0xDA,0xF3,0x60,0xBE,0x03}; - - GatewayResourceProfile() : gatewayID() { - } - - virtual ~GatewayResourceProfile() throw() {} - - std::string gatewayID; - std::vector<ComputeResourcePreference> computeResourcePreferences; - - _GatewayResourceProfile__isset __isset; - - void __set_gatewayID(const std::string& val) { - gatewayID = val; - } - - void __set_computeResourcePreferences(const std::vector<ComputeResourcePreference> & val) { - computeResourcePreferences = val; - __isset.computeResourcePreferences = true; - } - - bool operator == (const GatewayResourceProfile & rhs) const - { - if (!(gatewayID == rhs.gatewayID)) - return false; - if (__isset.computeResourcePreferences != rhs.__isset.computeResourcePreferences) - return false; - else if (__isset.computeResourcePreferences && !(computeResourcePreferences == rhs.computeResourcePreferences)) - return false; - return true; - } - bool operator != (const GatewayResourceProfile &rhs) const { - return !(*this == rhs); - } - - bool operator < (const GatewayResourceProfile & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -void swap(GatewayResourceProfile &a, GatewayResourceProfile &b); - -}}}}} // namespace - -#endif http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.cpp deleted file mode 100644 index 5086851..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.cpp +++ /dev/null @@ -1,36 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#include "messagingEvents_constants.h" - -namespace apache { namespace airavata { namespace model { namespace messaging { namespace event { - -const messagingEventsConstants g_messagingEvents_constants; - -messagingEventsConstants::messagingEventsConstants() { - DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS"; - -} - -}}}}} // namespace - http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.h deleted file mode 100644 index b6d7dbc..0000000 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/messagingEvents_constants.h +++ /dev/null @@ -1,42 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -#ifndef messagingEvents_CONSTANTS_H -#define messagingEvents_CONSTANTS_H - -#include "messagingEvents_types.h" - -namespace apache { namespace airavata { namespace model { namespace messaging { namespace event { - -class messagingEventsConstants { - public: - messagingEventsConstants(); - - std::string DEFAULT_ID; -}; - -extern const messagingEventsConstants g_messagingEvents_constants; - -}}}}} // namespace - -#endif
