Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1457911533 for ; Wed, 21 May 2014 05:46:58 +0000 (UTC) Received: (qmail 22978 invoked by uid 500); 21 May 2014 05:46:58 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 22857 invoked by uid 500); 21 May 2014 05:46:57 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 22763 invoked by uid 99); 21 May 2014 05:46:57 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 21 May 2014 05:46:57 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 957AB99A15B; Wed, 21 May 2014 05:46:57 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: samindaw@apache.org To: commits@airavata.apache.org Date: Wed, 21 May 2014 05:46:59 -0000 Message-Id: In-Reply-To: <14cf823645b048229c2b4a9b5a0cd3bf@git.apache.org> References: <14cf823645b048229c2b4a9b5a0cd3bf@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [3/5] generated code for gridftp model http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp index 429b558..032f449 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp @@ -1250,6 +1250,230 @@ uint32_t ApplicationCatalogAPI_addSCPDataMovementProtocol_presult::read(::apache return xfer; } +uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args::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_dataMovement = 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_STRUCT) { + xfer += this->dataMovement.read(iprot); + isset_dataMovement = 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_dataMovement) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args"); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->computeResourceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataMovement", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->dataMovement.write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addGridFTPDataMovementProtocol_pargs"); + + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->computeResourceId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("dataMovement", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->dataMovement)).write(oprot); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result::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; + + + 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_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result"); + + if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult::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; + + + 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_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + uint32_t ApplicationCatalogAPI_listComputeResourceDescriptions_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -2181,8 +2405,233 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args::read(::apach { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->globusJobSubmissionProtocolResourceId); - isset_globusJobSubmissionProtocolResourceId = true; + xfer += iprot->readString(this->globusJobSubmissionProtocolResourceId); + isset_globusJobSubmissionProtocolResourceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_globusJobSubmissionProtocolResourceId) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args"); + + xfer += oprot->writeFieldBegin("globusJobSubmissionProtocolResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->globusJobSubmissionProtocolResourceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_pargs"); + + xfer += oprot->writeFieldBegin("globusJobSubmissionProtocolResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->globusJobSubmissionProtocolResourceId))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result::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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result"); + + if (this->__isset.success) { + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); + xfer += this->success.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ire) { + xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->ire.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ace) { + xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->ace.write(oprot); + xfer += oprot->writeFieldEnd(); + } else if (this->__isset.ase) { + xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->ase.write(oprot); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_presult::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; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); + this->__isset.success = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ire.read(iprot); + this->__isset.ire = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ace.read(iprot); + this->__isset.ace = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->ase.read(iprot); + this->__isset.ase = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::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_scpDataMovementResourceId = 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->scpDataMovementResourceId); + isset_scpDataMovementResourceId = true; } else { xfer += iprot->skip(ftype); } @@ -2196,17 +2645,17 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args::read(::apach xfer += iprot->readStructEnd(); - if (!isset_globusJobSubmissionProtocolResourceId) + if (!isset_scpDataMovementResourceId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args"); + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getSCPDataMovementProtocol_args"); - xfer += oprot->writeFieldBegin("globusJobSubmissionProtocolResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->globusJobSubmissionProtocolResourceId); + xfer += oprot->writeFieldBegin("scpDataMovementResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->scpDataMovementResourceId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -2214,12 +2663,12 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args::write(::apac return xfer; } -uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_pargs"); + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getSCPDataMovementProtocol_pargs"); - xfer += oprot->writeFieldBegin("globusJobSubmissionProtocolResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->globusJobSubmissionProtocolResourceId))); + xfer += oprot->writeFieldBegin("scpDataMovementResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->scpDataMovementResourceId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -2227,7 +2676,7 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_pargs::write(::apa return xfer; } -uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -2291,11 +2740,11 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result::read(::apa return xfer; } -uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result"); + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getSCPDataMovementProtocol_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); @@ -2319,7 +2768,7 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result::write(::ap return xfer; } -uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -2383,7 +2832,7 @@ uint32_t ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_presult::read(::ap return xfer; } -uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -2394,7 +2843,7 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::read(::apache::t using ::apache::thrift::protocol::TProtocolException; - bool isset_scpDataMovementResourceId = false; + bool isset_gridFTPDataMovementResourceId = false; while (true) { @@ -2406,8 +2855,8 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::read(::apache::t { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->scpDataMovementResourceId); - isset_scpDataMovementResourceId = true; + xfer += iprot->readString(this->gridFTPDataMovementResourceId); + isset_gridFTPDataMovementResourceId = true; } else { xfer += iprot->skip(ftype); } @@ -2421,17 +2870,17 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::read(::apache::t xfer += iprot->readStructEnd(); - if (!isset_scpDataMovementResourceId) + if (!isset_gridFTPDataMovementResourceId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getSCPDataMovementProtocol_args"); + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args"); - xfer += oprot->writeFieldBegin("scpDataMovementResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->scpDataMovementResourceId); + xfer += oprot->writeFieldBegin("gridFTPDataMovementResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->gridFTPDataMovementResourceId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -2439,12 +2888,12 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_args::write(::apache:: return xfer; } -uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ApplicationCatalogAPI_getGridFTPDataMovementProtocol_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getSCPDataMovementProtocol_pargs"); + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGridFTPDataMovementProtocol_pargs"); - xfer += oprot->writeFieldBegin("scpDataMovementResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->scpDataMovementResourceId))); + xfer += oprot->writeFieldBegin("gridFTPDataMovementResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->gridFTPDataMovementResourceId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -2452,7 +2901,7 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_pargs::write(::apache: return xfer; } -uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -2516,11 +2965,11 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_result::read(::apache: return xfer; } -uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getSCPDataMovementProtocol_result"); + xfer += oprot->writeStructBegin("ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); @@ -2544,7 +2993,7 @@ uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_result::write(::apache return xfer; } -uint32_t ApplicationCatalogAPI_getSCPDataMovementProtocol_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -4817,6 +5266,69 @@ void ApplicationCatalogAPIClient::recv_addSCPDataMovementProtocol() return; } +void ApplicationCatalogAPIClient::addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) +{ + send_addGridFTPDataMovementProtocol(computeResourceId, dataMovement); + recv_addGridFTPDataMovementProtocol(); +} + +void ApplicationCatalogAPIClient::send_addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("addGridFTPDataMovementProtocol", ::apache::thrift::protocol::T_CALL, cseqid); + + ApplicationCatalogAPI_addGridFTPDataMovementProtocol_pargs args; + args.computeResourceId = &computeResourceId; + args.dataMovement = &dataMovement; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void ApplicationCatalogAPIClient::recv_addGridFTPDataMovementProtocol() +{ + + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; + + iprot_->readMessageBegin(fname, mtype, rseqid); + if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { + ::apache::thrift::TApplicationException x; + x.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("addGridFTPDataMovementProtocol") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult result; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + + if (result.__isset.ire) { + throw result.ire; + } + if (result.__isset.ace) { + throw result.ace; + } + if (result.__isset.ase) { + throw result.ase; + } + return; +} + void ApplicationCatalogAPIClient::listComputeResourceDescriptions(std::vector & _return) { send_listComputeResourceDescriptions(); @@ -5218,6 +5730,73 @@ void ApplicationCatalogAPIClient::recv_getSCPDataMovementProtocol( ::SCPDataMove throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getSCPDataMovementProtocol failed: unknown result"); } +void ApplicationCatalogAPIClient::getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return, const std::string& gridFTPDataMovementResourceId) +{ + send_getGridFTPDataMovementProtocol(gridFTPDataMovementResourceId); + recv_getGridFTPDataMovementProtocol(_return); +} + +void ApplicationCatalogAPIClient::send_getGridFTPDataMovementProtocol(const std::string& gridFTPDataMovementResourceId) +{ + int32_t cseqid = 0; + oprot_->writeMessageBegin("getGridFTPDataMovementProtocol", ::apache::thrift::protocol::T_CALL, cseqid); + + ApplicationCatalogAPI_getGridFTPDataMovementProtocol_pargs args; + args.gridFTPDataMovementResourceId = &gridFTPDataMovementResourceId; + args.write(oprot_); + + oprot_->writeMessageEnd(); + oprot_->getTransport()->writeEnd(); + oprot_->getTransport()->flush(); +} + +void ApplicationCatalogAPIClient::recv_getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return) +{ + + int32_t rseqid = 0; + std::string fname; + ::apache::thrift::protocol::TMessageType mtype; + + iprot_->readMessageBegin(fname, mtype, rseqid); + if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { + ::apache::thrift::TApplicationException x; + x.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + throw x; + } + if (mtype != ::apache::thrift::protocol::T_REPLY) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + if (fname.compare("getGridFTPDataMovementProtocol") != 0) { + iprot_->skip(::apache::thrift::protocol::T_STRUCT); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + } + ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult result; + result.success = &_return; + result.read(iprot_); + iprot_->readMessageEnd(); + iprot_->getTransport()->readEnd(); + + if (result.__isset.success) { + // _return pointer has now been filled + return; + } + if (result.__isset.ire) { + throw result.ire; + } + if (result.__isset.ace) { + throw result.ace; + } + if (result.__isset.ase) { + throw result.ase; + } + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getGridFTPDataMovementProtocol failed: unknown result"); +} + bool ApplicationCatalogAPIClient::isComputeResourceDescriptionRegistered(const std::string& hostName) { send_isComputeResourceDescriptionRegistered(hostName); @@ -6128,6 +6707,68 @@ void ApplicationCatalogAPIProcessor::process_addSCPDataMovementProtocol(int32_t } } +void ApplicationCatalogAPIProcessor::process_addGridFTPDataMovementProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) +{ + void* ctx = NULL; + if (this->eventHandler_.get() != NULL) { + ctx = this->eventHandler_->getContext("ApplicationCatalogAPI.addGridFTPDataMovementProtocol", callContext); + } + ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ApplicationCatalogAPI.addGridFTPDataMovementProtocol"); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preRead(ctx, "ApplicationCatalogAPI.addGridFTPDataMovementProtocol"); + } + + ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args args; + args.read(iprot); + iprot->readMessageEnd(); + uint32_t bytes = iprot->getTransport()->readEnd(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postRead(ctx, "ApplicationCatalogAPI.addGridFTPDataMovementProtocol", bytes); + } + + ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result result; + try { + iface_->addGridFTPDataMovementProtocol(args.computeResourceId, args.dataMovement); + } catch ( ::airavata::api::error::InvalidRequestException &ire) { + result.ire = ire; + result.__isset.ire = true; + } catch ( ::airavata::api::error::AiravataClientException &ace) { + result.ace = ace; + result.__isset.ace = true; + } catch ( ::airavata::api::error::AiravataSystemException &ase) { + result.ase = ase; + result.__isset.ase = true; + } catch (const std::exception& e) { + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->handlerError(ctx, "ApplicationCatalogAPI.addGridFTPDataMovementProtocol"); + } + + ::apache::thrift::TApplicationException x(e.what()); + oprot->writeMessageBegin("addGridFTPDataMovementProtocol", ::apache::thrift::protocol::T_EXCEPTION, seqid); + x.write(oprot); + oprot->writeMessageEnd(); + oprot->getTransport()->writeEnd(); + oprot->getTransport()->flush(); + return; + } + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preWrite(ctx, "ApplicationCatalogAPI.addGridFTPDataMovementProtocol"); + } + + oprot->writeMessageBegin("addGridFTPDataMovementProtocol", ::apache::thrift::protocol::T_REPLY, seqid); + result.write(oprot); + oprot->writeMessageEnd(); + bytes = oprot->getTransport()->writeEnd(); + oprot->getTransport()->flush(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postWrite(ctx, "ApplicationCatalogAPI.addGridFTPDataMovementProtocol", bytes); + } +} + void ApplicationCatalogAPIProcessor::process_listComputeResourceDescriptions(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; @@ -6506,6 +7147,69 @@ void ApplicationCatalogAPIProcessor::process_getSCPDataMovementProtocol(int32_t } } +void ApplicationCatalogAPIProcessor::process_getGridFTPDataMovementProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) +{ + void* ctx = NULL; + if (this->eventHandler_.get() != NULL) { + ctx = this->eventHandler_->getContext("ApplicationCatalogAPI.getGridFTPDataMovementProtocol", callContext); + } + ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ApplicationCatalogAPI.getGridFTPDataMovementProtocol"); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preRead(ctx, "ApplicationCatalogAPI.getGridFTPDataMovementProtocol"); + } + + ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args args; + args.read(iprot); + iprot->readMessageEnd(); + uint32_t bytes = iprot->getTransport()->readEnd(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postRead(ctx, "ApplicationCatalogAPI.getGridFTPDataMovementProtocol", bytes); + } + + ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result result; + try { + iface_->getGridFTPDataMovementProtocol(result.success, args.gridFTPDataMovementResourceId); + result.__isset.success = true; + } catch ( ::airavata::api::error::InvalidRequestException &ire) { + result.ire = ire; + result.__isset.ire = true; + } catch ( ::airavata::api::error::AiravataClientException &ace) { + result.ace = ace; + result.__isset.ace = true; + } catch ( ::airavata::api::error::AiravataSystemException &ase) { + result.ase = ase; + result.__isset.ase = true; + } catch (const std::exception& e) { + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->handlerError(ctx, "ApplicationCatalogAPI.getGridFTPDataMovementProtocol"); + } + + ::apache::thrift::TApplicationException x(e.what()); + oprot->writeMessageBegin("getGridFTPDataMovementProtocol", ::apache::thrift::protocol::T_EXCEPTION, seqid); + x.write(oprot); + oprot->writeMessageEnd(); + oprot->getTransport()->writeEnd(); + oprot->getTransport()->flush(); + return; + } + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->preWrite(ctx, "ApplicationCatalogAPI.getGridFTPDataMovementProtocol"); + } + + oprot->writeMessageBegin("getGridFTPDataMovementProtocol", ::apache::thrift::protocol::T_REPLY, seqid); + result.write(oprot); + oprot->writeMessageEnd(); + bytes = oprot->getTransport()->writeEnd(); + oprot->getTransport()->flush(); + + if (this->eventHandler_.get() != NULL) { + this->eventHandler_->postWrite(ctx, "ApplicationCatalogAPI.getGridFTPDataMovementProtocol", bytes); + } +} + void ApplicationCatalogAPIProcessor::process_isComputeResourceDescriptionRegistered(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h index e56ef4a..3d63beb 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h @@ -21,12 +21,14 @@ class ApplicationCatalogAPIIf { virtual void addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) = 0; virtual void addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) = 0; virtual void addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) = 0; + virtual void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) = 0; virtual void listComputeResourceDescriptions(std::vector & _return) = 0; virtual void getComputeResourceDescription( ::ComputeResourceDescription& _return, const std::string& computeResourceId) = 0; virtual void getSSHJobSubmissionProtocol( ::SSHJobSubmission& _return, const std::string& sshJobSubmissionProtocolResourceId) = 0; virtual void getGSISSHJobSubmissionProtocol( ::GSISSHJobSubmission& _return, const std::string& gsisshJobSubmissionProtocolResourceId) = 0; virtual void getGlobusJobSubmissionProtocol( ::GlobusJobSubmission& _return, const std::string& globusJobSubmissionProtocolResourceId) = 0; virtual void getSCPDataMovementProtocol( ::SCPDataMovement& _return, const std::string& scpDataMovementResourceId) = 0; + virtual void getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return, const std::string& gridFTPDataMovementResourceId) = 0; virtual bool isComputeResourceDescriptionRegistered(const std::string& hostName) = 0; virtual void getComputeResourceDescriptionFromHostName( ::ComputeResourceDescription& _return, const std::string& hostName) = 0; virtual void addApplicationInterface(const ::ApplicationInterface& applicationInterface) = 0; @@ -82,6 +84,9 @@ class ApplicationCatalogAPINull : virtual public ApplicationCatalogAPIIf { void addSCPDataMovementProtocol(const std::string& /* computeResourceId */, const ::SCPDataMovement& /* dataMovement */) { return; } + void addGridFTPDataMovementProtocol(const std::string& /* computeResourceId */, const ::GridFTPDataMovement& /* dataMovement */) { + return; + } void listComputeResourceDescriptions(std::vector & /* _return */) { return; } @@ -100,6 +105,9 @@ class ApplicationCatalogAPINull : virtual public ApplicationCatalogAPIIf { void getSCPDataMovementProtocol( ::SCPDataMovement& /* _return */, const std::string& /* scpDataMovementResourceId */) { return; } + void getGridFTPDataMovementProtocol( ::GridFTPDataMovement& /* _return */, const std::string& /* gridFTPDataMovementResourceId */) { + return; + } bool isComputeResourceDescriptionRegistered(const std::string& /* hostName */) { bool _return = false; return _return; @@ -864,6 +872,136 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_presult { }; +class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args { + public: + + ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args() : computeResourceId() { + } + + virtual ~ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args() throw() {} + + std::string computeResourceId; + ::GridFTPDataMovement dataMovement; + + void __set_computeResourceId(const std::string& val) { + computeResourceId = val; + } + + void __set_dataMovement(const ::GridFTPDataMovement& val) { + dataMovement = val; + } + + bool operator == (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args & rhs) const + { + if (!(computeResourceId == rhs.computeResourceId)) + return false; + if (!(dataMovement == rhs.dataMovement)) + return false; + return true; + } + bool operator != (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_pargs { + public: + + + virtual ~ApplicationCatalogAPI_addGridFTPDataMovementProtocol_pargs() throw() {} + + const std::string* computeResourceId; + const ::GridFTPDataMovement* dataMovement; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset { + _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset() : ire(false), ace(false), ase(false) {} + bool ire; + bool ace; + bool ase; +} _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset; + +class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result { + public: + + ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result() { + } + + virtual ~ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result() throw() {} + + ::airavata::api::error::InvalidRequestException ire; + ::airavata::api::error::AiravataClientException ace; + ::airavata::api::error::AiravataSystemException ase; + + _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset __isset; + + void __set_ire(const ::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result & rhs) const + { + if (!(ire == rhs.ire)) + return false; + if (!(ace == rhs.ace)) + return false; + if (!(ase == rhs.ase)) + return false; + return true; + } + bool operator != (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset { + _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset() : ire(false), ace(false), ase(false) {} + bool ire; + bool ace; + bool ase; +} _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset; + +class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult { + public: + + + virtual ~ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult() throw() {} + + ::airavata::api::error::InvalidRequestException ire; + ::airavata::api::error::AiravataClientException ace; + ::airavata::api::error::AiravataSystemException ase; + + _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class ApplicationCatalogAPI_listComputeResourceDescriptions_args { public: @@ -1648,6 +1786,138 @@ class ApplicationCatalogAPI_getSCPDataMovementProtocol_presult { }; +class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args { + public: + + ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args() : gridFTPDataMovementResourceId() { + } + + virtual ~ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args() throw() {} + + std::string gridFTPDataMovementResourceId; + + void __set_gridFTPDataMovementResourceId(const std::string& val) { + gridFTPDataMovementResourceId = val; + } + + bool operator == (const ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args & rhs) const + { + if (!(gridFTPDataMovementResourceId == rhs.gridFTPDataMovementResourceId)) + return false; + return true; + } + bool operator != (const ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + + +class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_pargs { + public: + + + virtual ~ApplicationCatalogAPI_getGridFTPDataMovementProtocol_pargs() throw() {} + + const std::string* gridFTPDataMovementResourceId; + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result__isset { + _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result__isset; + +class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result { + public: + + ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result() { + } + + virtual ~ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result() throw() {} + + ::GridFTPDataMovement success; + ::airavata::api::error::InvalidRequestException ire; + ::airavata::api::error::AiravataClientException ace; + ::airavata::api::error::AiravataSystemException ase; + + _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result__isset __isset; + + void __set_success(const ::GridFTPDataMovement& val) { + success = val; + } + + void __set_ire(const ::airavata::api::error::InvalidRequestException& val) { + ire = val; + } + + void __set_ace(const ::airavata::api::error::AiravataClientException& val) { + ace = val; + } + + void __set_ase(const ::airavata::api::error::AiravataSystemException& val) { + ase = val; + } + + bool operator == (const ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result & rhs) const + { + if (!(success == rhs.success)) + return false; + if (!(ire == rhs.ire)) + return false; + if (!(ace == rhs.ace)) + return false; + if (!(ase == rhs.ase)) + return false; + return true; + } + bool operator != (const ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +typedef struct _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult__isset { + _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult__isset() : success(false), ire(false), ace(false), ase(false) {} + bool success; + bool ire; + bool ace; + bool ase; +} _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult__isset; + +class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult { + public: + + + virtual ~ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult() throw() {} + + ::GridFTPDataMovement* success; + ::airavata::api::error::InvalidRequestException ire; + ::airavata::api::error::AiravataClientException ace; + ::airavata::api::error::AiravataSystemException ase; + + _ApplicationCatalogAPI_getGridFTPDataMovementProtocol_presult__isset __isset; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + +}; + + class ApplicationCatalogAPI_isComputeResourceDescriptionRegistered_args { public: @@ -2729,6 +2999,9 @@ class ApplicationCatalogAPIClient : virtual public ApplicationCatalogAPIIf { void addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement); void send_addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement); void recv_addSCPDataMovementProtocol(); + void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement); + void send_addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement); + void recv_addGridFTPDataMovementProtocol(); void listComputeResourceDescriptions(std::vector & _return); void send_listComputeResourceDescriptions(); void recv_listComputeResourceDescriptions(std::vector & _return); @@ -2747,6 +3020,9 @@ class ApplicationCatalogAPIClient : virtual public ApplicationCatalogAPIIf { void getSCPDataMovementProtocol( ::SCPDataMovement& _return, const std::string& scpDataMovementResourceId); void send_getSCPDataMovementProtocol(const std::string& scpDataMovementResourceId); void recv_getSCPDataMovementProtocol( ::SCPDataMovement& _return); + void getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return, const std::string& gridFTPDataMovementResourceId); + void send_getGridFTPDataMovementProtocol(const std::string& gridFTPDataMovementResourceId); + void recv_getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return); bool isComputeResourceDescriptionRegistered(const std::string& hostName); void send_isComputeResourceDescriptionRegistered(const std::string& hostName); bool recv_isComputeResourceDescriptionRegistered(); @@ -2792,12 +3068,14 @@ class ApplicationCatalogAPIProcessor : public ::apache::thrift::TDispatchProcess void process_addGSISSHJobSubmissionProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addGlobusJobSubmissionProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addSCPDataMovementProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_addGridFTPDataMovementProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_listComputeResourceDescriptions(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getComputeResourceDescription(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getSSHJobSubmissionProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getGSISSHJobSubmissionProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getGlobusJobSubmissionProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getSCPDataMovementProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_getGridFTPDataMovementProtocol(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_isComputeResourceDescriptionRegistered(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_getComputeResourceDescriptionFromHostName(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_addApplicationInterface(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); @@ -2815,12 +3093,14 @@ class ApplicationCatalogAPIProcessor : public ::apache::thrift::TDispatchProcess processMap_["addGSISSHJobSubmissionProtocol"] = &ApplicationCatalogAPIProcessor::process_addGSISSHJobSubmissionProtocol; processMap_["addGlobusJobSubmissionProtocol"] = &ApplicationCatalogAPIProcessor::process_addGlobusJobSubmissionProtocol; processMap_["addSCPDataMovementProtocol"] = &ApplicationCatalogAPIProcessor::process_addSCPDataMovementProtocol; + processMap_["addGridFTPDataMovementProtocol"] = &ApplicationCatalogAPIProcessor::process_addGridFTPDataMovementProtocol; processMap_["listComputeResourceDescriptions"] = &ApplicationCatalogAPIProcessor::process_listComputeResourceDescriptions; processMap_["getComputeResourceDescription"] = &ApplicationCatalogAPIProcessor::process_getComputeResourceDescription; processMap_["getSSHJobSubmissionProtocol"] = &ApplicationCatalogAPIProcessor::process_getSSHJobSubmissionProtocol; processMap_["getGSISSHJobSubmissionProtocol"] = &ApplicationCatalogAPIProcessor::process_getGSISSHJobSubmissionProtocol; processMap_["getGlobusJobSubmissionProtocol"] = &ApplicationCatalogAPIProcessor::process_getGlobusJobSubmissionProtocol; processMap_["getSCPDataMovementProtocol"] = &ApplicationCatalogAPIProcessor::process_getSCPDataMovementProtocol; + processMap_["getGridFTPDataMovementProtocol"] = &ApplicationCatalogAPIProcessor::process_getGridFTPDataMovementProtocol; processMap_["isComputeResourceDescriptionRegistered"] = &ApplicationCatalogAPIProcessor::process_isComputeResourceDescriptionRegistered; processMap_["getComputeResourceDescriptionFromHostName"] = &ApplicationCatalogAPIProcessor::process_getComputeResourceDescriptionFromHostName; processMap_["addApplicationInterface"] = &ApplicationCatalogAPIProcessor::process_addApplicationInterface; @@ -2912,6 +3192,15 @@ class ApplicationCatalogAPIMultiface : virtual public ApplicationCatalogAPIIf { ifaces_[i]->addSCPDataMovementProtocol(computeResourceId, dataMovement); } + void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->addGridFTPDataMovementProtocol(computeResourceId, dataMovement); + } + ifaces_[i]->addGridFTPDataMovementProtocol(computeResourceId, dataMovement); + } + void listComputeResourceDescriptions(std::vector & _return) { size_t sz = ifaces_.size(); size_t i = 0; @@ -2972,6 +3261,16 @@ class ApplicationCatalogAPIMultiface : virtual public ApplicationCatalogAPIIf { return; } + void getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return, const std::string& gridFTPDataMovementResourceId) { + size_t sz = ifaces_.size(); + size_t i = 0; + for (; i < (sz - 1); ++i) { + ifaces_[i]->getGridFTPDataMovementProtocol(_return, gridFTPDataMovementResourceId); + } + ifaces_[i]->getGridFTPDataMovementProtocol(_return, gridFTPDataMovementResourceId); + return; + } + bool isComputeResourceDescriptionRegistered(const std::string& hostName) { size_t sz = ifaces_.size(); size_t i = 0; http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp index 957e511..4a53bfd 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp @@ -52,6 +52,11 @@ class ApplicationCatalogAPIHandler : virtual public ApplicationCatalogAPIIf { printf("addSCPDataMovementProtocol\n"); } + void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) { + // Your implementation goes here + printf("addGridFTPDataMovementProtocol\n"); + } + void listComputeResourceDescriptions(std::vector & _return) { // Your implementation goes here printf("listComputeResourceDescriptions\n"); @@ -82,6 +87,11 @@ class ApplicationCatalogAPIHandler : virtual public ApplicationCatalogAPIIf { printf("getSCPDataMovementProtocol\n"); } + void getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return, const std::string& gridFTPDataMovementResourceId) { + // Your implementation goes here + printf("getGridFTPDataMovementProtocol\n"); + } + bool isComputeResourceDescriptionRegistered(const std::string& hostName) { // Your implementation goes here printf("isComputeResourceDescriptionRegistered\n"); http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.cpp index 6fa5f9a..9cdf168 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.cpp @@ -82,7 +82,7 @@ uint32_t SCPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) { using ::apache::thrift::protocol::TProtocolException; - bool isset_dataSubmissionDataID = false; + bool isset_dataMovementDataID = false; bool isset_securityProtocol = false; while (true) @@ -95,8 +95,8 @@ uint32_t SCPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) { { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->dataSubmissionDataID); - isset_dataSubmissionDataID = true; + xfer += iprot->readString(this->dataMovementDataID); + isset_dataMovementDataID = true; } else { xfer += iprot->skip(ftype); } @@ -128,7 +128,7 @@ uint32_t SCPDataMovement::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->readStructEnd(); - if (!isset_dataSubmissionDataID) + if (!isset_dataMovementDataID) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_securityProtocol) throw TProtocolException(TProtocolException::INVALID_DATA); @@ -139,8 +139,8 @@ uint32_t SCPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) co uint32_t xfer = 0; xfer += oprot->writeStructBegin("SCPDataMovement"); - xfer += oprot->writeFieldBegin("dataSubmissionDataID", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->dataSubmissionDataID); + xfer += oprot->writeFieldBegin("dataMovementDataID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->dataMovementDataID); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2); @@ -159,12 +159,130 @@ uint32_t SCPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) co void swap(SCPDataMovement &a, SCPDataMovement &b) { using ::std::swap; - swap(a.dataSubmissionDataID, b.dataSubmissionDataID); + swap(a.dataMovementDataID, b.dataMovementDataID); swap(a.securityProtocol, b.securityProtocol); swap(a.sshPort, b.sshPort); swap(a.__isset, b.__isset); } +const char* GridFTPDataMovement::ascii_fingerprint = "790EE8B1D56A3B9B76C41DD063726E75"; +const uint8_t GridFTPDataMovement::binary_fingerprint[16] = {0x79,0x0E,0xE8,0xB1,0xD5,0x6A,0x3B,0x9B,0x76,0xC4,0x1D,0xD0,0x63,0x72,0x6E,0x75}; + +uint32_t GridFTPDataMovement::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_dataMovementDataID = false; + bool isset_securityProtocol = false; + bool isset_gridFTPEndPoint = 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->dataMovementDataID); + isset_dataMovementDataID = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_I32) { + int32_t ecast1; + xfer += iprot->readI32(ecast1); + this->securityProtocol = (SecurityProtocol::type)ecast1; + isset_securityProtocol = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->gridFTPEndPoint.clear(); + uint32_t _size2; + ::apache::thrift::protocol::TType _etype5; + xfer += iprot->readListBegin(_etype5, _size2); + this->gridFTPEndPoint.resize(_size2); + uint32_t _i6; + for (_i6 = 0; _i6 < _size2; ++_i6) + { + xfer += iprot->readString(this->gridFTPEndPoint[_i6]); + } + xfer += iprot->readListEnd(); + } + isset_gridFTPEndPoint = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_dataMovementDataID) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_securityProtocol) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_gridFTPEndPoint) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; +} + +uint32_t GridFTPDataMovement::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + xfer += oprot->writeStructBegin("GridFTPDataMovement"); + + xfer += oprot->writeFieldBegin("dataMovementDataID", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->dataMovementDataID); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2); + xfer += oprot->writeI32((int32_t)this->securityProtocol); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("gridFTPEndPoint", ::apache::thrift::protocol::T_LIST, 3); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->gridFTPEndPoint.size())); + std::vector ::const_iterator _iter7; + for (_iter7 = this->gridFTPEndPoint.begin(); _iter7 != this->gridFTPEndPoint.end(); ++_iter7) + { + xfer += oprot->writeString((*_iter7)); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + +void swap(GridFTPDataMovement &a, GridFTPDataMovement &b) { + using ::std::swap; + swap(a.dataMovementDataID, b.dataMovementDataID); + swap(a.securityProtocol, b.securityProtocol); + swap(a.gridFTPEndPoint, b.gridFTPEndPoint); +} + const char* SSHJobSubmission::ascii_fingerprint = "FEB6B2CD28861B4EED855CACA1FEF2CB"; const uint8_t SSHJobSubmission::binary_fingerprint[16] = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB}; @@ -200,9 +318,9 @@ uint32_t SSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) { break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast1; - xfer += iprot->readI32(ecast1); - this->resourceJobManager = (ResourceJobManager::type)ecast1; + int32_t ecast8; + xfer += iprot->readI32(ecast8); + this->resourceJobManager = (ResourceJobManager::type)ecast8; isset_resourceJobManager = true; } else { xfer += iprot->skip(ftype); @@ -298,9 +416,9 @@ uint32_t GlobusJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast2; - xfer += iprot->readI32(ecast2); - this->securityProtocol = (SecurityProtocol::type)ecast2; + int32_t ecast9; + xfer += iprot->readI32(ecast9); + this->securityProtocol = (SecurityProtocol::type)ecast9; isset_securityProtocol = true; } else { xfer += iprot->skip(ftype); @@ -308,9 +426,9 @@ uint32_t GlobusJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) break; case 3: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast3; - xfer += iprot->readI32(ecast3); - this->resourceJobManager = (ResourceJobManager::type)ecast3; + int32_t ecast10; + xfer += iprot->readI32(ecast10); + this->resourceJobManager = (ResourceJobManager::type)ecast10; isset_resourceJobManager = true; } else { xfer += iprot->skip(ftype); @@ -320,14 +438,14 @@ uint32_t GlobusJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->globusGateKeeperEndPoint.clear(); - uint32_t _size4; - ::apache::thrift::protocol::TType _etype7; - xfer += iprot->readListBegin(_etype7, _size4); - this->globusGateKeeperEndPoint.resize(_size4); - uint32_t _i8; - for (_i8 = 0; _i8 < _size4; ++_i8) + uint32_t _size11; + ::apache::thrift::protocol::TType _etype14; + xfer += iprot->readListBegin(_etype14, _size11); + this->globusGateKeeperEndPoint.resize(_size11); + uint32_t _i15; + for (_i15 = 0; _i15 < _size11; ++_i15) { - xfer += iprot->readString(this->globusGateKeeperEndPoint[_i8]); + xfer += iprot->readString(this->globusGateKeeperEndPoint[_i15]); } xfer += iprot->readListEnd(); } @@ -374,10 +492,10 @@ uint32_t GlobusJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("globusGateKeeperEndPoint", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->globusGateKeeperEndPoint.size())); - std::vector ::const_iterator _iter9; - for (_iter9 = this->globusGateKeeperEndPoint.begin(); _iter9 != this->globusGateKeeperEndPoint.end(); ++_iter9) + std::vector ::const_iterator _iter16; + for (_iter16 = this->globusGateKeeperEndPoint.begin(); _iter16 != this->globusGateKeeperEndPoint.end(); ++_iter16) { - xfer += oprot->writeString((*_iter9)); + xfer += oprot->writeString((*_iter16)); } xfer += oprot->writeListEnd(); } @@ -432,9 +550,9 @@ uint32_t GSISSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast10; - xfer += iprot->readI32(ecast10); - this->resourceJobManager = (ResourceJobManager::type)ecast10; + int32_t ecast17; + xfer += iprot->readI32(ecast17); + this->resourceJobManager = (ResourceJobManager::type)ecast17; isset_resourceJobManager = true; } else { xfer += iprot->skip(ftype); @@ -452,15 +570,15 @@ uint32_t GSISSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_SET) { { this->exports.clear(); - uint32_t _size11; - ::apache::thrift::protocol::TType _etype14; - xfer += iprot->readSetBegin(_etype14, _size11); - uint32_t _i15; - for (_i15 = 0; _i15 < _size11; ++_i15) + uint32_t _size18; + ::apache::thrift::protocol::TType _etype21; + xfer += iprot->readSetBegin(_etype21, _size18); + uint32_t _i22; + for (_i22 = 0; _i22 < _size18; ++_i22) { - std::string _elem16; - xfer += iprot->readString(_elem16); - this->exports.insert(_elem16); + std::string _elem23; + xfer += iprot->readString(_elem23); + this->exports.insert(_elem23); } xfer += iprot->readSetEnd(); } @@ -473,14 +591,14 @@ uint32_t GSISSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->preJobCommands.clear(); - uint32_t _size17; - ::apache::thrift::protocol::TType _etype20; - xfer += iprot->readListBegin(_etype20, _size17); - this->preJobCommands.resize(_size17); - uint32_t _i21; - for (_i21 = 0; _i21 < _size17; ++_i21) + uint32_t _size24; + ::apache::thrift::protocol::TType _etype27; + xfer += iprot->readListBegin(_etype27, _size24); + this->preJobCommands.resize(_size24); + uint32_t _i28; + for (_i28 = 0; _i28 < _size24; ++_i28) { - xfer += iprot->readString(this->preJobCommands[_i21]); + xfer += iprot->readString(this->preJobCommands[_i28]); } xfer += iprot->readListEnd(); } @@ -493,14 +611,14 @@ uint32_t GSISSHJobSubmission::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->postJobCommands.clear(); - uint32_t _size22; - ::apache::thrift::protocol::TType _etype25; - xfer += iprot->readListBegin(_etype25, _size22); - this->postJobCommands.resize(_size22); - uint32_t _i26; - for (_i26 = 0; _i26 < _size22; ++_i26) + uint32_t _size29; + ::apache::thrift::protocol::TType _etype32; + xfer += iprot->readListBegin(_etype32, _size29); + this->postJobCommands.resize(_size29); + uint32_t _i33; + for (_i33 = 0; _i33 < _size29; ++_i33) { - xfer += iprot->readString(this->postJobCommands[_i26]); + xfer += iprot->readString(this->postJobCommands[_i33]); } xfer += iprot->readListEnd(); } @@ -562,10 +680,10 @@ uint32_t GSISSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("exports", ::apache::thrift::protocol::T_SET, 4); { xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast(this->exports.size())); - std::set ::const_iterator _iter27; - for (_iter27 = this->exports.begin(); _iter27 != this->exports.end(); ++_iter27) + std::set ::const_iterator _iter34; + for (_iter34 = this->exports.begin(); _iter34 != this->exports.end(); ++_iter34) { - xfer += oprot->writeString((*_iter27)); + xfer += oprot->writeString((*_iter34)); } xfer += oprot->writeSetEnd(); } @@ -575,10 +693,10 @@ uint32_t GSISSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("preJobCommands", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->preJobCommands.size())); - std::vector ::const_iterator _iter28; - for (_iter28 = this->preJobCommands.begin(); _iter28 != this->preJobCommands.end(); ++_iter28) + std::vector ::const_iterator _iter35; + for (_iter35 = this->preJobCommands.begin(); _iter35 != this->preJobCommands.end(); ++_iter35) { - xfer += oprot->writeString((*_iter28)); + xfer += oprot->writeString((*_iter35)); } xfer += oprot->writeListEnd(); } @@ -588,10 +706,10 @@ uint32_t GSISSHJobSubmission::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("postJobCommands", ::apache::thrift::protocol::T_LIST, 6); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->postJobCommands.size())); - std::vector ::const_iterator _iter29; - for (_iter29 = this->postJobCommands.begin(); _iter29 != this->postJobCommands.end(); ++_iter29) + std::vector ::const_iterator _iter36; + for (_iter36 = this->postJobCommands.begin(); _iter36 != this->postJobCommands.end(); ++_iter36) { - xfer += oprot->writeString((*_iter29)); + xfer += oprot->writeString((*_iter36)); } xfer += oprot->writeListEnd(); } @@ -681,15 +799,15 @@ uint32_t ComputeResourceDescription::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_SET) { { this->hostAliases.clear(); - uint32_t _size30; - ::apache::thrift::protocol::TType _etype33; - xfer += iprot->readSetBegin(_etype33, _size30); - uint32_t _i34; - for (_i34 = 0; _i34 < _size30; ++_i34) + uint32_t _size37; + ::apache::thrift::protocol::TType _etype40; + xfer += iprot->readSetBegin(_etype40, _size37); + uint32_t _i41; + for (_i41 = 0; _i41 < _size37; ++_i41) { - std::string _elem35; - xfer += iprot->readString(_elem35); - this->hostAliases.insert(_elem35); + std::string _elem42; + xfer += iprot->readString(_elem42); + this->hostAliases.insert(_elem42); } xfer += iprot->readSetEnd(); } @@ -702,15 +820,15 @@ uint32_t ComputeResourceDescription::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_SET) { { this->ipAddresses.clear(); - uint32_t _size36; - ::apache::thrift::protocol::TType _etype39; - xfer += iprot->readSetBegin(_etype39, _size36); - uint32_t _i40; - for (_i40 = 0; _i40 < _size36; ++_i40) + uint32_t _size43; + ::apache::thrift::protocol::TType _etype46; + xfer += iprot->readSetBegin(_etype46, _size43); + uint32_t _i47; + for (_i47 = 0; _i47 < _size43; ++_i47) { - std::string _elem41; - xfer += iprot->readString(_elem41); - this->ipAddresses.insert(_elem41); + std::string _elem48; + xfer += iprot->readString(_elem48); + this->ipAddresses.insert(_elem48); } xfer += iprot->readSetEnd(); } @@ -747,19 +865,19 @@ uint32_t ComputeResourceDescription::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_MAP) { { this->jobSubmissionProtocols.clear(); - uint32_t _size42; - ::apache::thrift::protocol::TType _ktype43; - ::apache::thrift::protocol::TType _vtype44; - xfer += iprot->readMapBegin(_ktype43, _vtype44, _size42); - uint32_t _i46; - for (_i46 = 0; _i46 < _size42; ++_i46) + uint32_t _size49; + ::apache::thrift::protocol::TType _ktype50; + ::apache::thrift::protocol::TType _vtype51; + xfer += iprot->readMapBegin(_ktype50, _vtype51, _size49); + uint32_t _i53; + for (_i53 = 0; _i53 < _size49; ++_i53) { - std::string _key47; - xfer += iprot->readString(_key47); - JobSubmissionProtocol::type& _val48 = this->jobSubmissionProtocols[_key47]; - int32_t ecast49; - xfer += iprot->readI32(ecast49); - _val48 = (JobSubmissionProtocol::type)ecast49; + std::string _key54; + xfer += iprot->readString(_key54); + JobSubmissionProtocol::type& _val55 = this->jobSubmissionProtocols[_key54]; + int32_t ecast56; + xfer += iprot->readI32(ecast56); + _val55 = (JobSubmissionProtocol::type)ecast56; } xfer += iprot->readMapEnd(); } @@ -772,19 +890,19 @@ uint32_t ComputeResourceDescription::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_MAP) { { this->dataMovementProtocols.clear(); - uint32_t _size50; - ::apache::thrift::protocol::TType _ktype51; - ::apache::thrift::protocol::TType _vtype52; - xfer += iprot->readMapBegin(_ktype51, _vtype52, _size50); - uint32_t _i54; - for (_i54 = 0; _i54 < _size50; ++_i54) + uint32_t _size57; + ::apache::thrift::protocol::TType _ktype58; + ::apache::thrift::protocol::TType _vtype59; + xfer += iprot->readMapBegin(_ktype58, _vtype59, _size57); + uint32_t _i61; + for (_i61 = 0; _i61 < _size57; ++_i61) { - std::string _key55; - xfer += iprot->readString(_key55); - DataMovementProtocol::type& _val56 = this->dataMovementProtocols[_key55]; - int32_t ecast57; - xfer += iprot->readI32(ecast57); - _val56 = (DataMovementProtocol::type)ecast57; + std::string _key62; + xfer += iprot->readString(_key62); + DataMovementProtocol::type& _val63 = this->dataMovementProtocols[_key62]; + int32_t ecast64; + xfer += iprot->readI32(ecast64); + _val63 = (DataMovementProtocol::type)ecast64; } xfer += iprot->readMapEnd(); } @@ -835,10 +953,10 @@ uint32_t ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeFieldBegin("hostAliases", ::apache::thrift::protocol::T_SET, 4); { xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast(this->hostAliases.size())); - std::set ::const_iterator _iter58; - for (_iter58 = this->hostAliases.begin(); _iter58 != this->hostAliases.end(); ++_iter58) + std::set ::const_iterator _iter65; + for (_iter65 = this->hostAliases.begin(); _iter65 != this->hostAliases.end(); ++_iter65) { - xfer += oprot->writeString((*_iter58)); + xfer += oprot->writeString((*_iter65)); } xfer += oprot->writeSetEnd(); } @@ -848,10 +966,10 @@ uint32_t ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeFieldBegin("ipAddresses", ::apache::thrift::protocol::T_SET, 5); { xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast(this->ipAddresses.size())); - std::set ::const_iterator _iter59; - for (_iter59 = this->ipAddresses.begin(); _iter59 != this->ipAddresses.end(); ++_iter59) + std::set ::const_iterator _iter66; + for (_iter66 = this->ipAddresses.begin(); _iter66 != this->ipAddresses.end(); ++_iter66) { - xfer += oprot->writeString((*_iter59)); + xfer += oprot->writeString((*_iter66)); } xfer += oprot->writeSetEnd(); } @@ -875,11 +993,11 @@ uint32_t ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeFieldBegin("jobSubmissionProtocols", ::apache::thrift::protocol::T_MAP, 9); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast(this->jobSubmissionProtocols.size())); - std::map ::const_iterator _iter60; - for (_iter60 = this->jobSubmissionProtocols.begin(); _iter60 != this->jobSubmissionProtocols.end(); ++_iter60) + std::map ::const_iterator _iter67; + for (_iter67 = this->jobSubmissionProtocols.begin(); _iter67 != this->jobSubmissionProtocols.end(); ++_iter67) { - xfer += oprot->writeString(_iter60->first); - xfer += oprot->writeI32((int32_t)_iter60->second); + xfer += oprot->writeString(_iter67->first); + xfer += oprot->writeI32((int32_t)_iter67->second); } xfer += oprot->writeMapEnd(); } @@ -888,11 +1006,11 @@ uint32_t ComputeResourceDescription::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeFieldBegin("dataMovementProtocols", ::apache::thrift::protocol::T_MAP, 10); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast(this->dataMovementProtocols.size())); - std::map ::const_iterator _iter61; - for (_iter61 = this->dataMovementProtocols.begin(); _iter61 != this->dataMovementProtocols.end(); ++_iter61) + std::map ::const_iterator _iter68; + for (_iter68 = this->dataMovementProtocols.begin(); _iter68 != this->dataMovementProtocols.end(); ++_iter68) { - xfer += oprot->writeString(_iter61->first); - xfer += oprot->writeI32((int32_t)_iter61->second); + xfer += oprot->writeString(_iter68->first); + xfer += oprot->writeI32((int32_t)_iter68->second); } xfer += oprot->writeMapEnd(); } @@ -1137,14 +1255,14 @@ uint32_t ApplicationInterface::read(::apache::thrift::protocol::TProtocol* iprot if (ftype == ::apache::thrift::protocol::T_LIST) { { this->applicationDeployments.clear(); - uint32_t _size62; - ::apache::thrift::protocol::TType _etype65; - xfer += iprot->readListBegin(_etype65, _size62); - this->applicationDeployments.resize(_size62); - uint32_t _i66; - for (_i66 = 0; _i66 < _size62; ++_i66) + uint32_t _size69; + ::apache::thrift::protocol::TType _etype72; + xfer += iprot->readListBegin(_etype72, _size69); + this->applicationDeployments.resize(_size69); + uint32_t _i73; + for (_i73 = 0; _i73 < _size69; ++_i73) { - xfer += this->applicationDeployments[_i66].read(iprot); + xfer += this->applicationDeployments[_i73].read(iprot); } xfer += iprot->readListEnd(); } @@ -1184,10 +1302,10 @@ uint32_t ApplicationInterface::write(::apache::thrift::protocol::TProtocol* opro xfer += oprot->writeFieldBegin("applicationDeployments", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->applicationDeployments.size())); - std::vector ::const_iterator _iter67; - for (_iter67 = this->applicationDeployments.begin(); _iter67 != this->applicationDeployments.end(); ++_iter67) + std::vector ::const_iterator _iter74; + for (_iter74 = this->applicationDeployments.begin(); _iter74 != this->applicationDeployments.end(); ++_iter74) { - xfer += (*_iter67).write(oprot); + xfer += (*_iter74).write(oprot); } xfer += oprot->writeListEnd(); } http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.h index 3cd2194..814bcd3 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/applicationCatalogDataModel_types.h @@ -73,19 +73,19 @@ class SCPDataMovement { static const char* ascii_fingerprint; // = "FEB6B2CD28861B4EED855CACA1FEF2CB"; static const uint8_t binary_fingerprint[16]; // = {0xFE,0xB6,0xB2,0xCD,0x28,0x86,0x1B,0x4E,0xED,0x85,0x5C,0xAC,0xA1,0xFE,0xF2,0xCB}; - SCPDataMovement() : dataSubmissionDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0), sshPort(22) { + SCPDataMovement() : dataMovementDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0), sshPort(22) { } virtual ~SCPDataMovement() throw() {} - std::string dataSubmissionDataID; + std::string dataMovementDataID; SecurityProtocol::type securityProtocol; int32_t sshPort; _SCPDataMovement__isset __isset; - void __set_dataSubmissionDataID(const std::string& val) { - dataSubmissionDataID = val; + void __set_dataMovementDataID(const std::string& val) { + dataMovementDataID = val; } void __set_securityProtocol(const SecurityProtocol::type val) { @@ -99,7 +99,7 @@ class SCPDataMovement { bool operator == (const SCPDataMovement & rhs) const { - if (!(dataSubmissionDataID == rhs.dataSubmissionDataID)) + if (!(dataMovementDataID == rhs.dataMovementDataID)) return false; if (!(securityProtocol == rhs.securityProtocol)) return false; @@ -122,6 +122,57 @@ class SCPDataMovement { void swap(SCPDataMovement &a, SCPDataMovement &b); + +class GridFTPDataMovement { + public: + + static const char* ascii_fingerprint; // = "790EE8B1D56A3B9B76C41DD063726E75"; + static const uint8_t binary_fingerprint[16]; // = {0x79,0x0E,0xE8,0xB1,0xD5,0x6A,0x3B,0x9B,0x76,0xC4,0x1D,0xD0,0x63,0x72,0x6E,0x75}; + + GridFTPDataMovement() : dataMovementDataID("DO_NOT_SET_AT_CLIENTS"), securityProtocol((SecurityProtocol::type)0) { + } + + virtual ~GridFTPDataMovement() throw() {} + + std::string dataMovementDataID; + SecurityProtocol::type securityProtocol; + std::vector gridFTPEndPoint; + + void __set_dataMovementDataID(const std::string& val) { + dataMovementDataID = val; + } + + void __set_securityProtocol(const SecurityProtocol::type val) { + securityProtocol = val; + } + + void __set_gridFTPEndPoint(const std::vector & val) { + gridFTPEndPoint = val; + } + + bool operator == (const GridFTPDataMovement & rhs) const + { + if (!(dataMovementDataID == rhs.dataMovementDataID)) + return false; + if (!(securityProtocol == rhs.securityProtocol)) + return false; + if (!(gridFTPEndPoint == rhs.gridFTPEndPoint)) + return false; + return true; + } + bool operator != (const GridFTPDataMovement &rhs) const { + return !(*this == rhs); + } + + bool operator < (const GridFTPDataMovement & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + +}; + +void swap(GridFTPDataMovement &a, GridFTPDataMovement &b); + typedef struct _SSHJobSubmission__isset { _SSHJobSubmission__isset() : sshPort(true) {} bool sshPort;