You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sa...@apache.org on 2014/05/21 07:46:59 UTC
[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<std::string> & _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<std::string> & _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<std::string> & /* _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<std::string> & _return);
void send_listComputeResourceDescriptions();
void recv_listComputeResourceDescriptions(std::vector<std::string> & _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<std::string> & _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<std::string> & _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<uint32_t>(this->gridFTPEndPoint.size()));
+ std::vector<std::string> ::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<uint32_t>(this->globusGateKeeperEndPoint.size()));
- std::vector<std::string> ::const_iterator _iter9;
- for (_iter9 = this->globusGateKeeperEndPoint.begin(); _iter9 != this->globusGateKeeperEndPoint.end(); ++_iter9)
+ std::vector<std::string> ::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<uint32_t>(this->exports.size()));
- std::set<std::string> ::const_iterator _iter27;
- for (_iter27 = this->exports.begin(); _iter27 != this->exports.end(); ++_iter27)
+ std::set<std::string> ::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<uint32_t>(this->preJobCommands.size()));
- std::vector<std::string> ::const_iterator _iter28;
- for (_iter28 = this->preJobCommands.begin(); _iter28 != this->preJobCommands.end(); ++_iter28)
+ std::vector<std::string> ::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<uint32_t>(this->postJobCommands.size()));
- std::vector<std::string> ::const_iterator _iter29;
- for (_iter29 = this->postJobCommands.begin(); _iter29 != this->postJobCommands.end(); ++_iter29)
+ std::vector<std::string> ::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<uint32_t>(this->hostAliases.size()));
- std::set<std::string> ::const_iterator _iter58;
- for (_iter58 = this->hostAliases.begin(); _iter58 != this->hostAliases.end(); ++_iter58)
+ std::set<std::string> ::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<uint32_t>(this->ipAddresses.size()));
- std::set<std::string> ::const_iterator _iter59;
- for (_iter59 = this->ipAddresses.begin(); _iter59 != this->ipAddresses.end(); ++_iter59)
+ std::set<std::string> ::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<uint32_t>(this->jobSubmissionProtocols.size()));
- std::map<std::string, JobSubmissionProtocol::type> ::const_iterator _iter60;
- for (_iter60 = this->jobSubmissionProtocols.begin(); _iter60 != this->jobSubmissionProtocols.end(); ++_iter60)
+ std::map<std::string, JobSubmissionProtocol::type> ::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<uint32_t>(this->dataMovementProtocols.size()));
- std::map<std::string, DataMovementProtocol::type> ::const_iterator _iter61;
- for (_iter61 = this->dataMovementProtocols.begin(); _iter61 != this->dataMovementProtocols.end(); ++_iter61)
+ std::map<std::string, DataMovementProtocol::type> ::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<uint32_t>(this->applicationDeployments.size()));
- std::vector<ApplicationDeployment> ::const_iterator _iter67;
- for (_iter67 = this->applicationDeployments.begin(); _iter67 != this->applicationDeployments.end(); ++_iter67)
+ std::vector<ApplicationDeployment> ::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<std::string> 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<std::string> & 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;