You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2014/10/23 19:54:45 UTC
[2/4] fixing AIRAVATA-1479
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
index 1db5477..f166f89 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
@@ -12605,8 +12605,8 @@ uint32_t Airavata_addLocalSubmissionDetails_result::read(::apache::thrift::proto
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -12655,8 +12655,8 @@ uint32_t Airavata_addLocalSubmissionDetails_result::write(::apache::thrift::prot
xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -12697,8 +12697,8 @@ uint32_t Airavata_addLocalSubmissionDetails_presult::read(::apache::thrift::prot
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -13112,8 +13112,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_result::read(::apache::thrift::prot
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -13162,8 +13162,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_result::write(::apache::thrift::pro
xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -13204,8 +13204,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_presult::read(::apache::thrift::pro
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -13375,8 +13375,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_result::read(::apache::thrift::
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -13425,8 +13425,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_result::write(::apache::thrift:
xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -13467,8 +13467,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_presult::read(::apache::thrift:
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -13638,8 +13638,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_result::read(::apache::thrift::pr
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -13688,8 +13688,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_result::write(::apache::thrift::p
xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -13730,8 +13730,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_presult::read(::apache::thrift::p
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -14389,8 +14389,8 @@ uint32_t Airavata_addLocalDataMovementDetails_result::read(::apache::thrift::pro
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -14439,8 +14439,8 @@ uint32_t Airavata_addLocalDataMovementDetails_result::write(::apache::thrift::pr
xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -14481,8 +14481,8 @@ uint32_t Airavata_addLocalDataMovementDetails_presult::read(::apache::thrift::pr
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -14896,8 +14896,8 @@ uint32_t Airavata_addSCPDataMovementDetails_result::read(::apache::thrift::proto
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -14946,8 +14946,8 @@ uint32_t Airavata_addSCPDataMovementDetails_result::write(::apache::thrift::prot
xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -14988,8 +14988,8 @@ uint32_t Airavata_addSCPDataMovementDetails_presult::read(::apache::thrift::prot
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -15403,8 +15403,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_result::read(::apache::thrift::p
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->success);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -15453,8 +15453,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_result::write(::apache::thrift::
xfer += oprot->writeStructBegin("Airavata_addGridFTPDataMovementDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
- xfer += oprot->writeBool(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -15495,8 +15495,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_presult::read(::apache::thrift::
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22854,10 +22854,10 @@ bool AiravataClient::recv_deleteComputeResource()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteComputeResource failed: unknown result");
}
-bool AiravataClient::addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission)
+void AiravataClient::addLocalSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission)
{
send_addLocalSubmissionDetails(computeResourceId, priorityOrder, localSubmission);
- return recv_addLocalSubmissionDetails();
+ recv_addLocalSubmissionDetails(_return);
}
void AiravataClient::send_addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission)
@@ -22876,7 +22876,7 @@ void AiravataClient::send_addLocalSubmissionDetails(const std::string& computeRe
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addLocalSubmissionDetails()
+void AiravataClient::recv_addLocalSubmissionDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -22901,7 +22901,6 @@ bool AiravataClient::recv_addLocalSubmissionDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addLocalSubmissionDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -22909,7 +22908,8 @@ bool AiravataClient::recv_addLocalSubmissionDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -22991,10 +22991,10 @@ bool AiravataClient::recv_updateLocalSubmissionDetails()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "updateLocalSubmissionDetails failed: unknown result");
}
-bool AiravataClient::addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission)
+void AiravataClient::addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission)
{
send_addSSHJobSubmissionDetails(computeResourceId, priorityOrder, sshJobSubmission);
- return recv_addSSHJobSubmissionDetails();
+ recv_addSSHJobSubmissionDetails(_return);
}
void AiravataClient::send_addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission)
@@ -23013,7 +23013,7 @@ void AiravataClient::send_addSSHJobSubmissionDetails(const std::string& computeR
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addSSHJobSubmissionDetails()
+void AiravataClient::recv_addSSHJobSubmissionDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -23038,7 +23038,6 @@ bool AiravataClient::recv_addSSHJobSubmissionDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addSSHJobSubmissionDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -23046,7 +23045,8 @@ bool AiravataClient::recv_addSSHJobSubmissionDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -23060,10 +23060,10 @@ bool AiravataClient::recv_addSSHJobSubmissionDetails()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addSSHJobSubmissionDetails failed: unknown result");
}
-bool AiravataClient::addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission)
+void AiravataClient::addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission)
{
send_addUNICOREJobSubmissionDetails(computeResourceId, priorityOrder, unicoreJobSubmission);
- return recv_addUNICOREJobSubmissionDetails();
+ recv_addUNICOREJobSubmissionDetails(_return);
}
void AiravataClient::send_addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission)
@@ -23082,7 +23082,7 @@ void AiravataClient::send_addUNICOREJobSubmissionDetails(const std::string& comp
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addUNICOREJobSubmissionDetails()
+void AiravataClient::recv_addUNICOREJobSubmissionDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -23107,7 +23107,6 @@ bool AiravataClient::recv_addUNICOREJobSubmissionDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addUNICOREJobSubmissionDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -23115,7 +23114,8 @@ bool AiravataClient::recv_addUNICOREJobSubmissionDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -23129,10 +23129,10 @@ bool AiravataClient::recv_addUNICOREJobSubmissionDetails()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addUNICOREJobSubmissionDetails failed: unknown result");
}
-bool AiravataClient::addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission)
+void AiravataClient::addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission)
{
send_addCloudJobSubmissionDetails(computeResourceId, priorityOrder, cloudSubmission);
- return recv_addCloudJobSubmissionDetails();
+ recv_addCloudJobSubmissionDetails(_return);
}
void AiravataClient::send_addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission)
@@ -23151,7 +23151,7 @@ void AiravataClient::send_addCloudJobSubmissionDetails(const std::string& comput
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addCloudJobSubmissionDetails()
+void AiravataClient::recv_addCloudJobSubmissionDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -23176,7 +23176,6 @@ bool AiravataClient::recv_addCloudJobSubmissionDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addCloudJobSubmissionDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -23184,7 +23183,8 @@ bool AiravataClient::recv_addCloudJobSubmissionDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -23334,10 +23334,10 @@ bool AiravataClient::recv_updateCloudJobSubmissionDetails()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "updateCloudJobSubmissionDetails failed: unknown result");
}
-bool AiravataClient::addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement)
+void AiravataClient::addLocalDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement)
{
send_addLocalDataMovementDetails(computeResourceId, priorityOrder, localDataMovement);
- return recv_addLocalDataMovementDetails();
+ recv_addLocalDataMovementDetails(_return);
}
void AiravataClient::send_addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement)
@@ -23356,7 +23356,7 @@ void AiravataClient::send_addLocalDataMovementDetails(const std::string& compute
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addLocalDataMovementDetails()
+void AiravataClient::recv_addLocalDataMovementDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -23381,7 +23381,6 @@ bool AiravataClient::recv_addLocalDataMovementDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addLocalDataMovementDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -23389,7 +23388,8 @@ bool AiravataClient::recv_addLocalDataMovementDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -23471,10 +23471,10 @@ bool AiravataClient::recv_updateLocalDataMovementDetails()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "updateLocalDataMovementDetails failed: unknown result");
}
-bool AiravataClient::addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement)
+void AiravataClient::addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement)
{
send_addSCPDataMovementDetails(computeResourceId, priorityOrder, scpDataMovement);
- return recv_addSCPDataMovementDetails();
+ recv_addSCPDataMovementDetails(_return);
}
void AiravataClient::send_addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement)
@@ -23493,7 +23493,7 @@ void AiravataClient::send_addSCPDataMovementDetails(const std::string& computeRe
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addSCPDataMovementDetails()
+void AiravataClient::recv_addSCPDataMovementDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -23518,7 +23518,6 @@ bool AiravataClient::recv_addSCPDataMovementDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addSCPDataMovementDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -23526,7 +23525,8 @@ bool AiravataClient::recv_addSCPDataMovementDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -23608,10 +23608,10 @@ bool AiravataClient::recv_updateSCPDataMovementDetails()
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "updateSCPDataMovementDetails failed: unknown result");
}
-bool AiravataClient::addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement)
+void AiravataClient::addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement)
{
send_addGridFTPDataMovementDetails(computeResourceId, priorityOrder, gridFTPDataMovement);
- return recv_addGridFTPDataMovementDetails();
+ recv_addGridFTPDataMovementDetails(_return);
}
void AiravataClient::send_addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement)
@@ -23630,7 +23630,7 @@ void AiravataClient::send_addGridFTPDataMovementDetails(const std::string& compu
oprot_->getTransport()->flush();
}
-bool AiravataClient::recv_addGridFTPDataMovementDetails()
+void AiravataClient::recv_addGridFTPDataMovementDetails(std::string& _return)
{
int32_t rseqid = 0;
@@ -23655,7 +23655,6 @@ bool AiravataClient::recv_addGridFTPDataMovementDetails()
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
}
- bool _return;
Airavata_addGridFTPDataMovementDetails_presult result;
result.success = &_return;
result.read(iprot_);
@@ -23663,7 +23662,8 @@ bool AiravataClient::recv_addGridFTPDataMovementDetails()
iprot_->getTransport()->readEnd();
if (result.__isset.success) {
- return _return;
+ // _return pointer has now been filled
+ return;
}
if (result.__isset.ire) {
throw result.ire;
@@ -28035,7 +28035,7 @@ void AiravataProcessor::process_addLocalSubmissionDetails(int32_t seqid, ::apach
Airavata_addLocalSubmissionDetails_result result;
try {
- result.success = iface_->addLocalSubmissionDetails(args.computeResourceId, args.priorityOrder, args.localSubmission);
+ iface_->addLocalSubmissionDetails(result.success, args.computeResourceId, args.priorityOrder, args.localSubmission);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
@@ -28161,7 +28161,7 @@ void AiravataProcessor::process_addSSHJobSubmissionDetails(int32_t seqid, ::apac
Airavata_addSSHJobSubmissionDetails_result result;
try {
- result.success = iface_->addSSHJobSubmissionDetails(args.computeResourceId, args.priorityOrder, args.sshJobSubmission);
+ iface_->addSSHJobSubmissionDetails(result.success, args.computeResourceId, args.priorityOrder, args.sshJobSubmission);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
@@ -28224,7 +28224,7 @@ void AiravataProcessor::process_addUNICOREJobSubmissionDetails(int32_t seqid, ::
Airavata_addUNICOREJobSubmissionDetails_result result;
try {
- result.success = iface_->addUNICOREJobSubmissionDetails(args.computeResourceId, args.priorityOrder, args.unicoreJobSubmission);
+ iface_->addUNICOREJobSubmissionDetails(result.success, args.computeResourceId, args.priorityOrder, args.unicoreJobSubmission);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
@@ -28287,7 +28287,7 @@ void AiravataProcessor::process_addCloudJobSubmissionDetails(int32_t seqid, ::ap
Airavata_addCloudJobSubmissionDetails_result result;
try {
- result.success = iface_->addCloudJobSubmissionDetails(args.computeResourceId, args.priorityOrder, args.cloudSubmission);
+ iface_->addCloudJobSubmissionDetails(result.success, args.computeResourceId, args.priorityOrder, args.cloudSubmission);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
@@ -28476,7 +28476,7 @@ void AiravataProcessor::process_addLocalDataMovementDetails(int32_t seqid, ::apa
Airavata_addLocalDataMovementDetails_result result;
try {
- result.success = iface_->addLocalDataMovementDetails(args.computeResourceId, args.priorityOrder, args.localDataMovement);
+ iface_->addLocalDataMovementDetails(result.success, args.computeResourceId, args.priorityOrder, args.localDataMovement);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
@@ -28602,7 +28602,7 @@ void AiravataProcessor::process_addSCPDataMovementDetails(int32_t seqid, ::apach
Airavata_addSCPDataMovementDetails_result result;
try {
- result.success = iface_->addSCPDataMovementDetails(args.computeResourceId, args.priorityOrder, args.scpDataMovement);
+ iface_->addSCPDataMovementDetails(result.success, args.computeResourceId, args.priorityOrder, args.scpDataMovement);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
@@ -28728,7 +28728,7 @@ void AiravataProcessor::process_addGridFTPDataMovementDetails(int32_t seqid, ::a
Airavata_addGridFTPDataMovementDetails_result result;
try {
- result.success = iface_->addGridFTPDataMovementDetails(args.computeResourceId, args.priorityOrder, args.gridFTPDataMovement);
+ iface_->addGridFTPDataMovementDetails(result.success, args.computeResourceId, args.priorityOrder, args.gridFTPDataMovement);
result.__isset.success = true;
} catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
index 96d7557..9066026 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
@@ -83,18 +83,18 @@ class AiravataIf {
virtual void getAllComputeResourceNames(std::map<std::string, std::string> & _return) = 0;
virtual bool updateComputeResource(const std::string& computeResourceId, const ::apache::airavata::model::appcatalog::computeresource::ComputeResourceDescription& computeResourceDescription) = 0;
virtual bool deleteComputeResource(const std::string& computeResourceId) = 0;
- virtual bool addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) = 0;
+ virtual void addLocalSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) = 0;
virtual bool updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) = 0;
- virtual bool addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) = 0;
- virtual bool addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) = 0;
- virtual bool addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) = 0;
+ virtual void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) = 0;
+ virtual void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) = 0;
+ virtual void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) = 0;
virtual bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) = 0;
virtual bool updateCloudJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& sshJobSubmission) = 0;
- virtual bool addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) = 0;
+ virtual void addLocalDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) = 0;
virtual bool updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) = 0;
- virtual bool addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) = 0;
+ virtual void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) = 0;
virtual bool updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) = 0;
- virtual bool addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) = 0;
+ virtual void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) = 0;
virtual bool updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) = 0;
virtual bool changeJobSubmissionPriority(const std::string& jobSubmissionInterfaceId, const int32_t newPriorityOrder) = 0;
virtual bool changeDataMovementPriority(const std::string& dataMovementInterfaceId, const int32_t newPriorityOrder) = 0;
@@ -302,25 +302,21 @@ class AiravataNull : virtual public AiravataIf {
bool _return = false;
return _return;
}
- bool addLocalSubmissionDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& /* localSubmission */) {
- bool _return = false;
- return _return;
+ void addLocalSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& /* localSubmission */) {
+ return;
}
bool updateLocalSubmissionDetails(const std::string& /* jobSubmissionInterfaceId */, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& /* localSubmission */) {
bool _return = false;
return _return;
}
- bool addSSHJobSubmissionDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& /* sshJobSubmission */) {
- bool _return = false;
- return _return;
+ void addSSHJobSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& /* sshJobSubmission */) {
+ return;
}
- bool addUNICOREJobSubmissionDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& /* unicoreJobSubmission */) {
- bool _return = false;
- return _return;
+ void addUNICOREJobSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& /* unicoreJobSubmission */) {
+ return;
}
- bool addCloudJobSubmissionDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& /* cloudSubmission */) {
- bool _return = false;
- return _return;
+ void addCloudJobSubmissionDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& /* cloudSubmission */) {
+ return;
}
bool updateSSHJobSubmissionDetails(const std::string& /* jobSubmissionInterfaceId */, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& /* sshJobSubmission */) {
bool _return = false;
@@ -330,25 +326,22 @@ class AiravataNull : virtual public AiravataIf {
bool _return = false;
return _return;
}
- bool addLocalDataMovementDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& /* localDataMovement */) {
- bool _return = false;
- return _return;
+ void addLocalDataMovementDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& /* localDataMovement */) {
+ return;
}
bool updateLocalDataMovementDetails(const std::string& /* jobSubmissionInterfaceId */, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& /* localDataMovement */) {
bool _return = false;
return _return;
}
- bool addSCPDataMovementDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& /* scpDataMovement */) {
- bool _return = false;
- return _return;
+ void addSCPDataMovementDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& /* scpDataMovement */) {
+ return;
}
bool updateSCPDataMovementDetails(const std::string& /* jobSubmissionInterfaceId */, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& /* scpDataMovement */) {
bool _return = false;
return _return;
}
- bool addGridFTPDataMovementDetails(const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& /* gridFTPDataMovement */) {
- bool _return = false;
- return _return;
+ void addGridFTPDataMovementDetails(std::string& /* _return */, const std::string& /* computeResourceId */, const int32_t /* priorityOrder */, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& /* gridFTPDataMovement */) {
+ return;
}
bool updateGridFTPDataMovementDetails(const std::string& /* jobSubmissionInterfaceId */, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& /* gridFTPDataMovement */) {
bool _return = false;
@@ -7351,19 +7344,19 @@ typedef struct _Airavata_addLocalSubmissionDetails_result__isset {
class Airavata_addLocalSubmissionDetails_result {
public:
- Airavata_addLocalSubmissionDetails_result() : success(0) {
+ Airavata_addLocalSubmissionDetails_result() : success() {
}
virtual ~Airavata_addLocalSubmissionDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addLocalSubmissionDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -7416,7 +7409,7 @@ class Airavata_addLocalSubmissionDetails_presult {
virtual ~Airavata_addLocalSubmissionDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -7639,19 +7632,19 @@ typedef struct _Airavata_addSSHJobSubmissionDetails_result__isset {
class Airavata_addSSHJobSubmissionDetails_result {
public:
- Airavata_addSSHJobSubmissionDetails_result() : success(0) {
+ Airavata_addSSHJobSubmissionDetails_result() : success() {
}
virtual ~Airavata_addSSHJobSubmissionDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addSSHJobSubmissionDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -7704,7 +7697,7 @@ class Airavata_addSSHJobSubmissionDetails_presult {
virtual ~Airavata_addSSHJobSubmissionDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -7787,19 +7780,19 @@ typedef struct _Airavata_addUNICOREJobSubmissionDetails_result__isset {
class Airavata_addUNICOREJobSubmissionDetails_result {
public:
- Airavata_addUNICOREJobSubmissionDetails_result() : success(0) {
+ Airavata_addUNICOREJobSubmissionDetails_result() : success() {
}
virtual ~Airavata_addUNICOREJobSubmissionDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addUNICOREJobSubmissionDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -7852,7 +7845,7 @@ class Airavata_addUNICOREJobSubmissionDetails_presult {
virtual ~Airavata_addUNICOREJobSubmissionDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -7935,19 +7928,19 @@ typedef struct _Airavata_addCloudJobSubmissionDetails_result__isset {
class Airavata_addCloudJobSubmissionDetails_result {
public:
- Airavata_addCloudJobSubmissionDetails_result() : success(0) {
+ Airavata_addCloudJobSubmissionDetails_result() : success() {
}
virtual ~Airavata_addCloudJobSubmissionDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addCloudJobSubmissionDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -8000,7 +7993,7 @@ class Airavata_addCloudJobSubmissionDetails_presult {
virtual ~Airavata_addCloudJobSubmissionDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -8363,19 +8356,19 @@ typedef struct _Airavata_addLocalDataMovementDetails_result__isset {
class Airavata_addLocalDataMovementDetails_result {
public:
- Airavata_addLocalDataMovementDetails_result() : success(0) {
+ Airavata_addLocalDataMovementDetails_result() : success() {
}
virtual ~Airavata_addLocalDataMovementDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addLocalDataMovementDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -8428,7 +8421,7 @@ class Airavata_addLocalDataMovementDetails_presult {
virtual ~Airavata_addLocalDataMovementDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -8651,19 +8644,19 @@ typedef struct _Airavata_addSCPDataMovementDetails_result__isset {
class Airavata_addSCPDataMovementDetails_result {
public:
- Airavata_addSCPDataMovementDetails_result() : success(0) {
+ Airavata_addSCPDataMovementDetails_result() : success() {
}
virtual ~Airavata_addSCPDataMovementDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addSCPDataMovementDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -8716,7 +8709,7 @@ class Airavata_addSCPDataMovementDetails_presult {
virtual ~Airavata_addSCPDataMovementDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -8939,19 +8932,19 @@ typedef struct _Airavata_addGridFTPDataMovementDetails_result__isset {
class Airavata_addGridFTPDataMovementDetails_result {
public:
- Airavata_addGridFTPDataMovementDetails_result() : success(0) {
+ Airavata_addGridFTPDataMovementDetails_result() : success() {
}
virtual ~Airavata_addGridFTPDataMovementDetails_result() throw() {}
- bool success;
+ std::string success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
_Airavata_addGridFTPDataMovementDetails_result__isset __isset;
- void __set_success(const bool val) {
+ void __set_success(const std::string& val) {
success = val;
}
@@ -9004,7 +8997,7 @@ class Airavata_addGridFTPDataMovementDetails_presult {
virtual ~Airavata_addGridFTPDataMovementDetails_presult() throw() {}
- bool* success;
+ std::string* success;
::apache::airavata::api::error::InvalidRequestException ire;
::apache::airavata::api::error::AiravataClientException ace;
::apache::airavata::api::error::AiravataSystemException ase;
@@ -11380,42 +11373,42 @@ class AiravataClient : virtual public AiravataIf {
bool deleteComputeResource(const std::string& computeResourceId);
void send_deleteComputeResource(const std::string& computeResourceId);
bool recv_deleteComputeResource();
- bool addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission);
+ void addLocalSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission);
void send_addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission);
- bool recv_addLocalSubmissionDetails();
+ void recv_addLocalSubmissionDetails(std::string& _return);
bool updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission);
void send_updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission);
bool recv_updateLocalSubmissionDetails();
- bool addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission);
+ void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission);
void send_addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission);
- bool recv_addSSHJobSubmissionDetails();
- bool addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission);
+ void recv_addSSHJobSubmissionDetails(std::string& _return);
+ void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission);
void send_addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission);
- bool recv_addUNICOREJobSubmissionDetails();
- bool addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission);
+ void recv_addUNICOREJobSubmissionDetails(std::string& _return);
+ void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission);
void send_addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission);
- bool recv_addCloudJobSubmissionDetails();
+ void recv_addCloudJobSubmissionDetails(std::string& _return);
bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission);
void send_updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission);
bool recv_updateSSHJobSubmissionDetails();
bool updateCloudJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& sshJobSubmission);
void send_updateCloudJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& sshJobSubmission);
bool recv_updateCloudJobSubmissionDetails();
- bool addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement);
+ void addLocalDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement);
void send_addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement);
- bool recv_addLocalDataMovementDetails();
+ void recv_addLocalDataMovementDetails(std::string& _return);
bool updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement);
void send_updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement);
bool recv_updateLocalDataMovementDetails();
- bool addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement);
+ void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement);
void send_addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement);
- bool recv_addSCPDataMovementDetails();
+ void recv_addSCPDataMovementDetails(std::string& _return);
bool updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement);
void send_updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement);
bool recv_updateSCPDataMovementDetails();
- bool addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement);
+ void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement);
void send_addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement);
- bool recv_addGridFTPDataMovementDetails();
+ void recv_addGridFTPDataMovementDetails(std::string& _return);
bool updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement);
void send_updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement);
bool recv_updateGridFTPDataMovementDetails();
@@ -12163,13 +12156,14 @@ class AiravataMultiface : virtual public AiravataIf {
return ifaces_[i]->deleteComputeResource(computeResourceId);
}
- bool addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) {
+ void addLocalSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addLocalSubmissionDetails(computeResourceId, priorityOrder, localSubmission);
+ ifaces_[i]->addLocalSubmissionDetails(_return, computeResourceId, priorityOrder, localSubmission);
}
- return ifaces_[i]->addLocalSubmissionDetails(computeResourceId, priorityOrder, localSubmission);
+ ifaces_[i]->addLocalSubmissionDetails(_return, computeResourceId, priorityOrder, localSubmission);
+ return;
}
bool updateLocalSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) {
@@ -12181,31 +12175,34 @@ class AiravataMultiface : virtual public AiravataIf {
return ifaces_[i]->updateLocalSubmissionDetails(jobSubmissionInterfaceId, localSubmission);
}
- bool addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) {
+ void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addSSHJobSubmissionDetails(computeResourceId, priorityOrder, sshJobSubmission);
+ ifaces_[i]->addSSHJobSubmissionDetails(_return, computeResourceId, priorityOrder, sshJobSubmission);
}
- return ifaces_[i]->addSSHJobSubmissionDetails(computeResourceId, priorityOrder, sshJobSubmission);
+ ifaces_[i]->addSSHJobSubmissionDetails(_return, computeResourceId, priorityOrder, sshJobSubmission);
+ return;
}
- bool addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) {
+ void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addUNICOREJobSubmissionDetails(computeResourceId, priorityOrder, unicoreJobSubmission);
+ ifaces_[i]->addUNICOREJobSubmissionDetails(_return, computeResourceId, priorityOrder, unicoreJobSubmission);
}
- return ifaces_[i]->addUNICOREJobSubmissionDetails(computeResourceId, priorityOrder, unicoreJobSubmission);
+ ifaces_[i]->addUNICOREJobSubmissionDetails(_return, computeResourceId, priorityOrder, unicoreJobSubmission);
+ return;
}
- bool addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) {
+ void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addCloudJobSubmissionDetails(computeResourceId, priorityOrder, cloudSubmission);
+ ifaces_[i]->addCloudJobSubmissionDetails(_return, computeResourceId, priorityOrder, cloudSubmission);
}
- return ifaces_[i]->addCloudJobSubmissionDetails(computeResourceId, priorityOrder, cloudSubmission);
+ ifaces_[i]->addCloudJobSubmissionDetails(_return, computeResourceId, priorityOrder, cloudSubmission);
+ return;
}
bool updateSSHJobSubmissionDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) {
@@ -12226,13 +12223,14 @@ class AiravataMultiface : virtual public AiravataIf {
return ifaces_[i]->updateCloudJobSubmissionDetails(jobSubmissionInterfaceId, sshJobSubmission);
}
- bool addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) {
+ void addLocalDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addLocalDataMovementDetails(computeResourceId, priorityOrder, localDataMovement);
+ ifaces_[i]->addLocalDataMovementDetails(_return, computeResourceId, priorityOrder, localDataMovement);
}
- return ifaces_[i]->addLocalDataMovementDetails(computeResourceId, priorityOrder, localDataMovement);
+ ifaces_[i]->addLocalDataMovementDetails(_return, computeResourceId, priorityOrder, localDataMovement);
+ return;
}
bool updateLocalDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) {
@@ -12244,13 +12242,14 @@ class AiravataMultiface : virtual public AiravataIf {
return ifaces_[i]->updateLocalDataMovementDetails(jobSubmissionInterfaceId, localDataMovement);
}
- bool addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) {
+ void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addSCPDataMovementDetails(computeResourceId, priorityOrder, scpDataMovement);
+ ifaces_[i]->addSCPDataMovementDetails(_return, computeResourceId, priorityOrder, scpDataMovement);
}
- return ifaces_[i]->addSCPDataMovementDetails(computeResourceId, priorityOrder, scpDataMovement);
+ ifaces_[i]->addSCPDataMovementDetails(_return, computeResourceId, priorityOrder, scpDataMovement);
+ return;
}
bool updateSCPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) {
@@ -12262,13 +12261,14 @@ class AiravataMultiface : virtual public AiravataIf {
return ifaces_[i]->updateSCPDataMovementDetails(jobSubmissionInterfaceId, scpDataMovement);
}
- bool addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) {
+ void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addGridFTPDataMovementDetails(computeResourceId, priorityOrder, gridFTPDataMovement);
+ ifaces_[i]->addGridFTPDataMovementDetails(_return, computeResourceId, priorityOrder, gridFTPDataMovement);
}
- return ifaces_[i]->addGridFTPDataMovementDetails(computeResourceId, priorityOrder, gridFTPDataMovement);
+ ifaces_[i]->addGridFTPDataMovementDetails(_return, computeResourceId, priorityOrder, gridFTPDataMovement);
+ return;
}
bool updateGridFTPDataMovementDetails(const std::string& jobSubmissionInterfaceId, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) {
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
index ab69e4e..b2405ce 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
@@ -294,7 +294,7 @@ class AiravataHandler : virtual public AiravataIf {
printf("deleteComputeResource\n");
}
- bool addLocalSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) {
+ void addLocalSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALSubmission& localSubmission) {
// Your implementation goes here
printf("addLocalSubmissionDetails\n");
}
@@ -304,17 +304,17 @@ class AiravataHandler : virtual public AiravataIf {
printf("updateLocalSubmissionDetails\n");
}
- bool addSSHJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) {
+ void addSSHJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SSHJobSubmission& sshJobSubmission) {
// Your implementation goes here
printf("addSSHJobSubmissionDetails\n");
}
- bool addUNICOREJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) {
+ void addUNICOREJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::UnicoreJobSubmission& unicoreJobSubmission) {
// Your implementation goes here
printf("addUNICOREJobSubmissionDetails\n");
}
- bool addCloudJobSubmissionDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) {
+ void addCloudJobSubmissionDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::CloudJobSubmission& cloudSubmission) {
// Your implementation goes here
printf("addCloudJobSubmissionDetails\n");
}
@@ -329,7 +329,7 @@ class AiravataHandler : virtual public AiravataIf {
printf("updateCloudJobSubmissionDetails\n");
}
- bool addLocalDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) {
+ void addLocalDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::LOCALDataMovement& localDataMovement) {
// Your implementation goes here
printf("addLocalDataMovementDetails\n");
}
@@ -339,7 +339,7 @@ class AiravataHandler : virtual public AiravataIf {
printf("updateLocalDataMovementDetails\n");
}
- bool addSCPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) {
+ void addSCPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::SCPDataMovement& scpDataMovement) {
// Your implementation goes here
printf("addSCPDataMovementDetails\n");
}
@@ -349,7 +349,7 @@ class AiravataHandler : virtual public AiravataIf {
printf("updateSCPDataMovementDetails\n");
}
- bool addGridFTPDataMovementDetails(const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) {
+ void addGridFTPDataMovementDetails(std::string& _return, const std::string& computeResourceId, const int32_t priorityOrder, const ::apache::airavata::model::appcatalog::computeresource::GridFTPDataMovement& gridFTPDataMovement) {
// Your implementation goes here
printf("addGridFTPDataMovementDetails\n");
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
index 943db42..c4e018c 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
@@ -16808,7 +16808,7 @@ class Airavata_addLocalSubmissionDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -16863,8 +16863,8 @@ class Airavata_addLocalSubmissionDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -16907,8 +16907,8 @@ class Airavata_addLocalSubmissionDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addLocalSubmissionDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -17298,7 +17298,7 @@ class Airavata_addSSHJobSubmissionDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -17353,8 +17353,8 @@ class Airavata_addSSHJobSubmissionDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -17397,8 +17397,8 @@ class Airavata_addSSHJobSubmissionDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addSSHJobSubmissionDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -17553,7 +17553,7 @@ class Airavata_addUNICOREJobSubmissionDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -17608,8 +17608,8 @@ class Airavata_addUNICOREJobSubmissionDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -17652,8 +17652,8 @@ class Airavata_addUNICOREJobSubmissionDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addUNICOREJobSubmissionDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -17808,7 +17808,7 @@ class Airavata_addCloudJobSubmissionDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -17863,8 +17863,8 @@ class Airavata_addCloudJobSubmissionDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -17907,8 +17907,8 @@ class Airavata_addCloudJobSubmissionDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addCloudJobSubmissionDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -18533,7 +18533,7 @@ class Airavata_addLocalDataMovementDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -18588,8 +18588,8 @@ class Airavata_addLocalDataMovementDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -18632,8 +18632,8 @@ class Airavata_addLocalDataMovementDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addLocalDataMovementDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -19023,7 +19023,7 @@ class Airavata_addSCPDataMovementDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -19078,8 +19078,8 @@ class Airavata_addSCPDataMovementDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -19122,8 +19122,8 @@ class Airavata_addSCPDataMovementDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addSCPDataMovementDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
@@ -19513,7 +19513,7 @@ class Airavata_addGridFTPDataMovementDetails_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::BOOL,
+ 'type' => TType::STRING,
),
1 => array(
'var' => 'ire',
@@ -19568,8 +19568,8 @@ class Airavata_addGridFTPDataMovementDetails_result {
switch ($fid)
{
case 0:
- if ($ftype == TType::BOOL) {
- $xfer += $input->readBool($this->success);
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->success);
} else {
$xfer += $input->skip($ftype);
}
@@ -19612,8 +19612,8 @@ class Airavata_addGridFTPDataMovementDetails_result {
$xfer = 0;
$xfer += $output->writeStructBegin('Airavata_addGridFTPDataMovementDetails_result');
if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::BOOL, 0);
- $xfer += $output->writeBool($this->success);
+ $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
+ $xfer += $output->writeString($this->success);
$xfer += $output->writeFieldEnd();
}
if ($this->ire !== null) {
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterOGCEUS3Application.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterOGCEUS3Application.java b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterOGCEUS3Application.java
index e5eaf23..d6cd8f8 100644
--- a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterOGCEUS3Application.java
+++ b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterOGCEUS3Application.java
@@ -261,18 +261,12 @@ public class RegisterOGCEUS3Application {
sshJobSubmission.setResourceJobManager(resourceJobManager);
sshJobSubmission.setSecurityProtocol(securityProtocol);
sshJobSubmission.setSshPort(portNumber);
- boolean sshAddStatus = airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
-
- if (!sshAddStatus)
- throw new AiravataClientException();
+ airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
SCPDataMovement scpDataMovement = new SCPDataMovement();
scpDataMovement.setSecurityProtocol(securityProtocol);
scpDataMovement.setSshPort(portNumber);
- boolean scpAddStatus = airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
-
- if (!scpAddStatus)
- throw new AiravataClientException();
+ airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
return computeResourceId;
}
@@ -294,19 +288,13 @@ public class RegisterOGCEUS3Application {
sshJobSubmission.setResourceJobManager(resourceJobManager);
sshJobSubmission.setSecurityProtocol(securityProtocol);
sshJobSubmission.setSshPort(portNumber);
- boolean sshAddStatus = airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
+ airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
ComputeResourceDescription computeResourceDescription = airavataClient.getComputeResource(computeResourceId);
computeResourceDescription.getJobSubmissionInterfacesIterator();
- if (!sshAddStatus)
- throw new AiravataClientException();
-
SCPDataMovement scpDataMovement = new SCPDataMovement();
scpDataMovement.setSecurityProtocol(securityProtocol);
scpDataMovement.setSshPort(portNumber);
- boolean scpAddStatus = airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
-
- if (!scpAddStatus)
- throw new AiravataClientException();
+ airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
return computeResourceId;
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterSampleApplications.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterSampleApplications.java b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterSampleApplications.java
index a92ec73..83cd33b 100644
--- a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterSampleApplications.java
+++ b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterSampleApplications.java
@@ -159,8 +159,7 @@ public class RegisterSampleApplications {
createResourceJobManager(ResourceJobManagerType.FORK, null, null, null);
LOCALSubmission submission = new LOCALSubmission();
submission.setResourceJobManager(resourceJobManager);
- boolean localSubmission = airavataClient.addLocalSubmissionDetails(localhostId, 1, submission);
- if (!localSubmission) throw new AiravataClientException();
+ airavataClient.addLocalSubmissionDetails(localhostId, 1, submission);
System.out.println("LocalHost Resource Id is " + localhostId);
} catch (TException e) {
@@ -1070,16 +1069,12 @@ public class RegisterSampleApplications {
sshJobSubmission.setResourceJobManager(resourceJobManager);
sshJobSubmission.setSecurityProtocol(securityProtocol);
sshJobSubmission.setSshPort(portNumber);
- boolean sshAddStatus = airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
-
- if (!sshAddStatus) throw new AiravataClientException();
+ airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
SCPDataMovement scpDataMovement = new SCPDataMovement();
scpDataMovement.setSecurityProtocol(securityProtocol);
scpDataMovement.setSshPort(portNumber);
- boolean scpAddStatus = airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
-
- if (!scpAddStatus) throw new AiravataClientException();
+ airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
return computeResourceId;
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d83a48b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterUS3Application.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterUS3Application.java b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterUS3Application.java
index 9f59a4f..ccb4e24 100644
--- a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterUS3Application.java
+++ b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/tools/RegisterUS3Application.java
@@ -261,18 +261,12 @@ public class RegisterUS3Application {
sshJobSubmission.setResourceJobManager(resourceJobManager);
sshJobSubmission.setSecurityProtocol(securityProtocol);
sshJobSubmission.setSshPort(portNumber);
- boolean sshAddStatus = airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
-
- if (!sshAddStatus)
- throw new AiravataClientException();
+ airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
SCPDataMovement scpDataMovement = new SCPDataMovement();
scpDataMovement.setSecurityProtocol(securityProtocol);
scpDataMovement.setSshPort(portNumber);
- boolean scpAddStatus = airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
-
- if (!scpAddStatus)
- throw new AiravataClientException();
+ airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
return computeResourceId;
}
@@ -294,19 +288,13 @@ public class RegisterUS3Application {
sshJobSubmission.setResourceJobManager(resourceJobManager);
sshJobSubmission.setSecurityProtocol(securityProtocol);
sshJobSubmission.setSshPort(portNumber);
- boolean sshAddStatus = airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
+ airavataClient.addSSHJobSubmissionDetails(computeResourceId, 1, sshJobSubmission);
ComputeResourceDescription computeResourceDescription = airavataClient.getComputeResource(computeResourceId);
computeResourceDescription.getJobSubmissionInterfacesIterator();
- if (!sshAddStatus)
- throw new AiravataClientException();
-
SCPDataMovement scpDataMovement = new SCPDataMovement();
scpDataMovement.setSecurityProtocol(securityProtocol);
scpDataMovement.setSshPort(portNumber);
- boolean scpAddStatus = airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
-
- if (!scpAddStatus)
- throw new AiravataClientException();
+ airavataClient.addSCPDataMovementDetails(computeResourceId, 1, scpDataMovement);
return computeResourceId;
}