You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2015/11/12 20:55:55 UTC
[7/9] airavata git commit: adding api methods for storage resources
http://git-wip-us.apache.org/repos/asf/airavata/blob/e2799d45/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 62bbc7e..f9be847 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
@@ -21024,11 +21024,11 @@ uint32_t Airavata_deleteComputeResource_presult::read(::apache::thrift::protocol
}
-Airavata_addLocalSubmissionDetails_args::~Airavata_addLocalSubmissionDetails_args() throw() {
+Airavata_registerStorageResource_args::~Airavata_registerStorageResource_args() throw() {
}
-uint32_t Airavata_addLocalSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_registerStorageResource_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21040,9 +21040,7 @@ uint32_t Airavata_addLocalSubmissionDetails_args::read(::apache::thrift::protoco
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_computeResourceId = false;
- bool isset_priorityOrder = false;
- bool isset_localSubmission = false;
+ bool isset_storageResourceDescription = false;
while (true)
{
@@ -21061,25 +21059,9 @@ uint32_t Airavata_addLocalSubmissionDetails_args::read(::apache::thrift::protoco
}
break;
case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->computeResourceId);
- isset_computeResourceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->priorityOrder);
- isset_priorityOrder = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->localSubmission.read(iprot);
- isset_localSubmission = true;
+ xfer += this->storageResourceDescription.read(iprot);
+ isset_storageResourceDescription = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -21095,34 +21077,22 @@ uint32_t Airavata_addLocalSubmissionDetails_args::read(::apache::thrift::protoco
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_computeResourceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_priorityOrder)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_localSubmission)
+ if (!isset_storageResourceDescription)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_addLocalSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_registerStorageResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_registerStorageResource_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->computeResourceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->priorityOrder);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += this->localSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceDescription", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->storageResourceDescription.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -21132,29 +21102,21 @@ uint32_t Airavata_addLocalSubmissionDetails_args::write(::apache::thrift::protoc
}
-Airavata_addLocalSubmissionDetails_pargs::~Airavata_addLocalSubmissionDetails_pargs() throw() {
+Airavata_registerStorageResource_pargs::~Airavata_registerStorageResource_pargs() throw() {
}
-uint32_t Airavata_addLocalSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_registerStorageResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_registerStorageResource_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->computeResourceId)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((*(this->priorityOrder)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += (*(this->localSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceDescription", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += (*(this->storageResourceDescription)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -21164,11 +21126,11 @@ uint32_t Airavata_addLocalSubmissionDetails_pargs::write(::apache::thrift::proto
}
-Airavata_addLocalSubmissionDetails_result::~Airavata_addLocalSubmissionDetails_result() throw() {
+Airavata_registerStorageResource_result::~Airavata_registerStorageResource_result() throw() {
}
-uint32_t Airavata_addLocalSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_registerStorageResource_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21240,11 +21202,11 @@ uint32_t Airavata_addLocalSubmissionDetails_result::read(::apache::thrift::proto
return xfer;
}
-uint32_t Airavata_addLocalSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_registerStorageResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_registerStorageResource_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
@@ -21273,11 +21235,11 @@ uint32_t Airavata_addLocalSubmissionDetails_result::write(::apache::thrift::prot
}
-Airavata_addLocalSubmissionDetails_presult::~Airavata_addLocalSubmissionDetails_presult() throw() {
+Airavata_registerStorageResource_presult::~Airavata_registerStorageResource_presult() throw() {
}
-uint32_t Airavata_addLocalSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_registerStorageResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21350,11 +21312,11 @@ uint32_t Airavata_addLocalSubmissionDetails_presult::read(::apache::thrift::prot
}
-Airavata_updateLocalSubmissionDetails_args::~Airavata_updateLocalSubmissionDetails_args() throw() {
+Airavata_getStorageResource_args::~Airavata_getStorageResource_args() throw() {
}
-uint32_t Airavata_updateLocalSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getStorageResource_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21366,8 +21328,7 @@ uint32_t Airavata_updateLocalSubmissionDetails_args::read(::apache::thrift::prot
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_jobSubmissionInterfaceId = false;
- bool isset_localSubmission = false;
+ bool isset_storageResourceId = false;
while (true)
{
@@ -21387,16 +21348,8 @@ uint32_t Airavata_updateLocalSubmissionDetails_args::read(::apache::thrift::prot
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->localSubmission.read(iprot);
- isset_localSubmission = true;
+ xfer += iprot->readString(this->storageResourceId);
+ isset_storageResourceId = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -21412,28 +21365,22 @@ uint32_t Airavata_updateLocalSubmissionDetails_args::read(::apache::thrift::prot
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_localSubmission)
+ if (!isset_storageResourceId)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_updateLocalSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getStorageResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_updateLocalSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_getStorageResource_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 3);
- xfer += this->localSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->storageResourceId);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -21443,25 +21390,21 @@ uint32_t Airavata_updateLocalSubmissionDetails_args::write(::apache::thrift::pro
}
-Airavata_updateLocalSubmissionDetails_pargs::~Airavata_updateLocalSubmissionDetails_pargs() throw() {
+Airavata_getStorageResource_pargs::~Airavata_getStorageResource_pargs() throw() {
}
-uint32_t Airavata_updateLocalSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getStorageResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_updateLocalSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_getStorageResource_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->jobSubmissionInterfaceId)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 3);
- xfer += (*(this->localSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->storageResourceId)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -21471,11 +21414,11 @@ uint32_t Airavata_updateLocalSubmissionDetails_pargs::write(::apache::thrift::pr
}
-Airavata_updateLocalSubmissionDetails_result::~Airavata_updateLocalSubmissionDetails_result() throw() {
+Airavata_getStorageResource_result::~Airavata_getStorageResource_result() throw() {
}
-uint32_t Airavata_updateLocalSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getStorageResource_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21496,8 +21439,8 @@ uint32_t Airavata_updateLocalSubmissionDetails_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_STRUCT) {
+ xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -21547,15 +21490,15 @@ uint32_t Airavata_updateLocalSubmissionDetails_result::read(::apache::thrift::pr
return xfer;
}
-uint32_t Airavata_updateLocalSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getStorageResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_updateLocalSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_getStorageResource_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_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);
@@ -21580,11 +21523,11 @@ uint32_t Airavata_updateLocalSubmissionDetails_result::write(::apache::thrift::p
}
-Airavata_updateLocalSubmissionDetails_presult::~Airavata_updateLocalSubmissionDetails_presult() throw() {
+Airavata_getStorageResource_presult::~Airavata_getStorageResource_presult() throw() {
}
-uint32_t Airavata_updateLocalSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getStorageResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21605,8 +21548,8 @@ uint32_t Airavata_updateLocalSubmissionDetails_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_STRUCT) {
+ xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -21657,11 +21600,11 @@ uint32_t Airavata_updateLocalSubmissionDetails_presult::read(::apache::thrift::p
}
-Airavata_getLocalJobSubmission_args::~Airavata_getLocalJobSubmission_args() throw() {
+Airavata_getAllStorageResourceNames_args::~Airavata_getAllStorageResourceNames_args() throw() {
}
-uint32_t Airavata_getLocalJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getAllStorageResourceNames_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21673,7 +21616,6 @@ uint32_t Airavata_getLocalJobSubmission_args::read(::apache::thrift::protocol::T
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_jobSubmissionId = false;
while (true)
{
@@ -21691,14 +21633,6 @@ uint32_t Airavata_getLocalJobSubmission_args::read(::apache::thrift::protocol::T
xfer += iprot->skip(ftype);
}
break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionId);
- isset_jobSubmissionId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
default:
xfer += iprot->skip(ftype);
break;
@@ -21710,24 +21644,18 @@ uint32_t Airavata_getLocalJobSubmission_args::read(::apache::thrift::protocol::T
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_getLocalJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getAllStorageResourceNames_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_args");
+ xfer += oprot->writeStructBegin("Airavata_getAllStorageResourceNames_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->jobSubmissionId);
- xfer += oprot->writeFieldEnd();
-
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
oprot->decrementRecursionDepth();
@@ -21735,23 +21663,19 @@ uint32_t Airavata_getLocalJobSubmission_args::write(::apache::thrift::protocol::
}
-Airavata_getLocalJobSubmission_pargs::~Airavata_getLocalJobSubmission_pargs() throw() {
+Airavata_getAllStorageResourceNames_pargs::~Airavata_getAllStorageResourceNames_pargs() throw() {
}
-uint32_t Airavata_getLocalJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getAllStorageResourceNames_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_pargs");
+ xfer += oprot->writeStructBegin("Airavata_getAllStorageResourceNames_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->jobSubmissionId)));
- xfer += oprot->writeFieldEnd();
-
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
oprot->decrementRecursionDepth();
@@ -21759,11 +21683,11 @@ uint32_t Airavata_getLocalJobSubmission_pargs::write(::apache::thrift::protocol:
}
-Airavata_getLocalJobSubmission_result::~Airavata_getLocalJobSubmission_result() throw() {
+Airavata_getAllStorageResourceNames_result::~Airavata_getAllStorageResourceNames_result() throw() {
}
-uint32_t Airavata_getLocalJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getAllStorageResourceNames_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21784,8 +21708,23 @@ uint32_t Airavata_getLocalJobSubmission_result::read(::apache::thrift::protocol:
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->success.read(iprot);
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->success.clear();
+ uint32_t _size317;
+ ::apache::thrift::protocol::TType _ktype318;
+ ::apache::thrift::protocol::TType _vtype319;
+ xfer += iprot->readMapBegin(_ktype318, _vtype319, _size317);
+ uint32_t _i321;
+ for (_i321 = 0; _i321 < _size317; ++_i321)
+ {
+ std::string _key322;
+ xfer += iprot->readString(_key322);
+ std::string& _val323 = this->success[_key322];
+ xfer += iprot->readString(_val323);
+ }
+ xfer += iprot->readMapEnd();
+ }
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -21835,15 +21774,24 @@ uint32_t Airavata_getLocalJobSubmission_result::read(::apache::thrift::protocol:
return xfer;
}
-uint32_t Airavata_getLocalJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getAllStorageResourceNames_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_result");
+ xfer += oprot->writeStructBegin("Airavata_getAllStorageResourceNames_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
- xfer += this->success.write(oprot);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
+ std::map<std::string, std::string> ::const_iterator _iter324;
+ for (_iter324 = this->success.begin(); _iter324 != this->success.end(); ++_iter324)
+ {
+ xfer += oprot->writeString(_iter324->first);
+ xfer += oprot->writeString(_iter324->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -21868,11 +21816,11 @@ uint32_t Airavata_getLocalJobSubmission_result::write(::apache::thrift::protocol
}
-Airavata_getLocalJobSubmission_presult::~Airavata_getLocalJobSubmission_presult() throw() {
+Airavata_getAllStorageResourceNames_presult::~Airavata_getAllStorageResourceNames_presult() throw() {
}
-uint32_t Airavata_getLocalJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getAllStorageResourceNames_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21893,8 +21841,23 @@ uint32_t Airavata_getLocalJobSubmission_presult::read(::apache::thrift::protocol
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += (*(this->success)).read(iprot);
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ (*(this->success)).clear();
+ uint32_t _size325;
+ ::apache::thrift::protocol::TType _ktype326;
+ ::apache::thrift::protocol::TType _vtype327;
+ xfer += iprot->readMapBegin(_ktype326, _vtype327, _size325);
+ uint32_t _i329;
+ for (_i329 = 0; _i329 < _size325; ++_i329)
+ {
+ std::string _key330;
+ xfer += iprot->readString(_key330);
+ std::string& _val331 = (*(this->success))[_key330];
+ xfer += iprot->readString(_val331);
+ }
+ xfer += iprot->readMapEnd();
+ }
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -21945,11 +21908,11 @@ uint32_t Airavata_getLocalJobSubmission_presult::read(::apache::thrift::protocol
}
-Airavata_addSSHJobSubmissionDetails_args::~Airavata_addSSHJobSubmissionDetails_args() throw() {
+Airavata_updateStorageResource_args::~Airavata_updateStorageResource_args() throw() {
}
-uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_updateStorageResource_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -21961,9 +21924,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protoc
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_computeResourceId = false;
- bool isset_priorityOrder = false;
- bool isset_sshJobSubmission = false;
+ bool isset_storageResourceId = false;
+ bool isset_storageResourceDescription = false;
while (true)
{
@@ -21983,24 +21945,16 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protoc
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->computeResourceId);
- isset_computeResourceId = true;
+ xfer += iprot->readString(this->storageResourceId);
+ isset_storageResourceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->priorityOrder);
- isset_priorityOrder = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->sshJobSubmission.read(iprot);
- isset_sshJobSubmission = true;
+ xfer += this->storageResourceDescription.read(iprot);
+ isset_storageResourceDescription = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -22016,34 +21970,28 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protoc
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_computeResourceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_priorityOrder)
+ if (!isset_storageResourceId)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_sshJobSubmission)
+ if (!isset_storageResourceDescription)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_addSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_updateStorageResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_updateStorageResource_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->computeResourceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->priorityOrder);
+ xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->storageResourceId);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += this->sshJobSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceDescription", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->storageResourceDescription.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22053,29 +22001,25 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::write(::apache::thrift::proto
}
-Airavata_addSSHJobSubmissionDetails_pargs::~Airavata_addSSHJobSubmissionDetails_pargs() throw() {
+Airavata_updateStorageResource_pargs::~Airavata_updateStorageResource_pargs() throw() {
}
-uint32_t Airavata_addSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_updateStorageResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_updateStorageResource_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->computeResourceId)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((*(this->priorityOrder)));
+ xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->storageResourceId)));
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += (*(this->sshJobSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceDescription", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += (*(this->storageResourceDescription)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22085,11 +22029,11 @@ uint32_t Airavata_addSSHJobSubmissionDetails_pargs::write(::apache::thrift::prot
}
-Airavata_addSSHJobSubmissionDetails_result::~Airavata_addSSHJobSubmissionDetails_result() throw() {
+Airavata_updateStorageResource_result::~Airavata_updateStorageResource_result() throw() {
}
-uint32_t Airavata_addSSHJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_updateStorageResource_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22110,8 +22054,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_result::read(::apache::thrift::prot
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->success);
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22161,15 +22105,15 @@ uint32_t Airavata_addSSHJobSubmissionDetails_result::read(::apache::thrift::prot
return xfer;
}
-uint32_t Airavata_addSSHJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_updateStorageResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_updateStorageResource_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
- xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
+ xfer += oprot->writeBool(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -22194,11 +22138,11 @@ uint32_t Airavata_addSSHJobSubmissionDetails_result::write(::apache::thrift::pro
}
-Airavata_addSSHJobSubmissionDetails_presult::~Airavata_addSSHJobSubmissionDetails_presult() throw() {
+Airavata_updateStorageResource_presult::~Airavata_updateStorageResource_presult() throw() {
}
-uint32_t Airavata_addSSHJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_updateStorageResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22219,8 +22163,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_presult::read(::apache::thrift::pro
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22271,11 +22215,11 @@ uint32_t Airavata_addSSHJobSubmissionDetails_presult::read(::apache::thrift::pro
}
-Airavata_addSSHForkJobSubmissionDetails_args::~Airavata_addSSHForkJobSubmissionDetails_args() throw() {
+Airavata_deleteStorageResource_args::~Airavata_deleteStorageResource_args() throw() {
}
-uint32_t Airavata_addSSHForkJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_deleteStorageResource_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22287,9 +22231,7 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_args::read(::apache::thrift::pr
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_computeResourceId = false;
- bool isset_priorityOrder = false;
- bool isset_sshJobSubmission = false;
+ bool isset_storageResourceId = false;
while (true)
{
@@ -22309,30 +22251,14 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_args::read(::apache::thrift::pr
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->computeResourceId);
- isset_computeResourceId = true;
+ xfer += iprot->readString(this->storageResourceId);
+ isset_storageResourceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->priorityOrder);
- isset_priorityOrder = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->sshJobSubmission.read(iprot);
- isset_sshJobSubmission = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
+ default:
+ xfer += iprot->skip(ftype);
break;
}
xfer += iprot->readFieldEnd();
@@ -22342,34 +22268,22 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_args::read(::apache::thrift::pr
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_computeResourceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_priorityOrder)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_sshJobSubmission)
+ if (!isset_storageResourceId)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_addSSHForkJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_deleteStorageResource_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addSSHForkJobSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_deleteStorageResource_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->computeResourceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->priorityOrder);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += this->sshJobSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->storageResourceId);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22379,29 +22293,21 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_args::write(::apache::thrift::p
}
-Airavata_addSSHForkJobSubmissionDetails_pargs::~Airavata_addSSHForkJobSubmissionDetails_pargs() throw() {
+Airavata_deleteStorageResource_pargs::~Airavata_deleteStorageResource_pargs() throw() {
}
-uint32_t Airavata_addSSHForkJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_deleteStorageResource_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addSSHForkJobSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_deleteStorageResource_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->computeResourceId)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((*(this->priorityOrder)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += (*(this->sshJobSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("storageResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->storageResourceId)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22411,11 +22317,11 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_pargs::write(::apache::thrift::
}
-Airavata_addSSHForkJobSubmissionDetails_result::~Airavata_addSSHForkJobSubmissionDetails_result() throw() {
+Airavata_deleteStorageResource_result::~Airavata_deleteStorageResource_result() throw() {
}
-uint32_t Airavata_addSSHForkJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_deleteStorageResource_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22436,8 +22342,8 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_result::read(::apache::thrift::
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->success);
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22487,15 +22393,15 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_result::read(::apache::thrift::
return xfer;
}
-uint32_t Airavata_addSSHForkJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_deleteStorageResource_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_addSSHForkJobSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_deleteStorageResource_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
- xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
+ xfer += oprot->writeBool(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -22520,11 +22426,11 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_result::write(::apache::thrift:
}
-Airavata_addSSHForkJobSubmissionDetails_presult::~Airavata_addSSHForkJobSubmissionDetails_presult() throw() {
+Airavata_deleteStorageResource_presult::~Airavata_deleteStorageResource_presult() throw() {
}
-uint32_t Airavata_addSSHForkJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_deleteStorageResource_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22545,8 +22451,8 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_presult::read(::apache::thrift:
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22597,11 +22503,11 @@ uint32_t Airavata_addSSHForkJobSubmissionDetails_presult::read(::apache::thrift:
}
-Airavata_getSSHJobSubmission_args::~Airavata_getSSHJobSubmission_args() throw() {
+Airavata_addLocalSubmissionDetails_args::~Airavata_addLocalSubmissionDetails_args() throw() {
}
-uint32_t Airavata_getSSHJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addLocalSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22613,7 +22519,9 @@ uint32_t Airavata_getSSHJobSubmission_args::read(::apache::thrift::protocol::TPr
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_jobSubmissionId = false;
+ bool isset_computeResourceId = false;
+ bool isset_priorityOrder = false;
+ bool isset_localSubmission = false;
while (true)
{
@@ -22633,8 +22541,24 @@ uint32_t Airavata_getSSHJobSubmission_args::read(::apache::thrift::protocol::TPr
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionId);
- isset_jobSubmissionId = true;
+ xfer += iprot->readString(this->computeResourceId);
+ isset_computeResourceId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->priorityOrder);
+ isset_priorityOrder = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->localSubmission.read(iprot);
+ isset_localSubmission = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -22650,22 +22574,34 @@ uint32_t Airavata_getSSHJobSubmission_args::read(::apache::thrift::protocol::TPr
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionId)
+ if (!isset_computeResourceId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_priorityOrder)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_localSubmission)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_getSSHJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addLocalSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_args");
+ xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->jobSubmissionId);
+ xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->computeResourceId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32(this->priorityOrder);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += this->localSubmission.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22675,21 +22611,29 @@ uint32_t Airavata_getSSHJobSubmission_args::write(::apache::thrift::protocol::TP
}
-Airavata_getSSHJobSubmission_pargs::~Airavata_getSSHJobSubmission_pargs() throw() {
+Airavata_addLocalSubmissionDetails_pargs::~Airavata_addLocalSubmissionDetails_pargs() throw() {
}
-uint32_t Airavata_getSSHJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addLocalSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_pargs");
+ xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->jobSubmissionId)));
+ xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->computeResourceId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32((*(this->priorityOrder)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += (*(this->localSubmission)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22699,11 +22643,11 @@ uint32_t Airavata_getSSHJobSubmission_pargs::write(::apache::thrift::protocol::T
}
-Airavata_getSSHJobSubmission_result::~Airavata_getSSHJobSubmission_result() throw() {
+Airavata_addLocalSubmissionDetails_result::~Airavata_addLocalSubmissionDetails_result() throw() {
}
-uint32_t Airavata_getSSHJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addLocalSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22724,8 +22668,8 @@ uint32_t Airavata_getSSHJobSubmission_result::read(::apache::thrift::protocol::T
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->success.read(iprot);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22775,15 +22719,15 @@ uint32_t Airavata_getSSHJobSubmission_result::read(::apache::thrift::protocol::T
return xfer;
}
-uint32_t Airavata_getSSHJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addLocalSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_result");
+ xfer += oprot->writeStructBegin("Airavata_addLocalSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
- xfer += this->success.write(oprot);
+ 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);
@@ -22808,11 +22752,11 @@ uint32_t Airavata_getSSHJobSubmission_result::write(::apache::thrift::protocol::
}
-Airavata_getSSHJobSubmission_presult::~Airavata_getSSHJobSubmission_presult() throw() {
+Airavata_addLocalSubmissionDetails_presult::~Airavata_addLocalSubmissionDetails_presult() throw() {
}
-uint32_t Airavata_getSSHJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addLocalSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22833,8 +22777,8 @@ uint32_t Airavata_getSSHJobSubmission_presult::read(::apache::thrift::protocol::
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += (*(this->success)).read(iprot);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -22885,11 +22829,11 @@ uint32_t Airavata_getSSHJobSubmission_presult::read(::apache::thrift::protocol::
}
-Airavata_addUNICOREJobSubmissionDetails_args::~Airavata_addUNICOREJobSubmissionDetails_args() throw() {
+Airavata_updateLocalSubmissionDetails_args::~Airavata_updateLocalSubmissionDetails_args() throw() {
}
-uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_updateLocalSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -22901,9 +22845,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::pr
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_computeResourceId = false;
- bool isset_priorityOrder = false;
- bool isset_unicoreJobSubmission = false;
+ bool isset_jobSubmissionInterfaceId = false;
+ bool isset_localSubmission = false;
while (true)
{
@@ -22923,24 +22866,16 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::pr
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->computeResourceId);
- isset_computeResourceId = true;
+ xfer += iprot->readString(this->jobSubmissionInterfaceId);
+ isset_jobSubmissionInterfaceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->priorityOrder);
- isset_priorityOrder = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->unicoreJobSubmission.read(iprot);
- isset_unicoreJobSubmission = true;
+ xfer += this->localSubmission.read(iprot);
+ isset_localSubmission = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -22956,34 +22891,28 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::pr
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_computeResourceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_priorityOrder)
+ if (!isset_jobSubmissionInterfaceId)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_unicoreJobSubmission)
+ if (!isset_localSubmission)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_addUNICOREJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_updateLocalSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_updateLocalSubmissionDetails_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->computeResourceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->priorityOrder);
+ xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->jobSubmissionInterfaceId);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("unicoreJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += this->unicoreJobSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->localSubmission.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -22993,29 +22922,25 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::write(::apache::thrift::p
}
-Airavata_addUNICOREJobSubmissionDetails_pargs::~Airavata_addUNICOREJobSubmissionDetails_pargs() throw() {
+Airavata_updateLocalSubmissionDetails_pargs::~Airavata_updateLocalSubmissionDetails_pargs() throw() {
}
-uint32_t Airavata_addUNICOREJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_updateLocalSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_updateLocalSubmissionDetails_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->computeResourceId)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((*(this->priorityOrder)));
+ xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->jobSubmissionInterfaceId)));
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("unicoreJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += (*(this->unicoreJobSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("localSubmission", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += (*(this->localSubmission)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -23025,11 +22950,11 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_pargs::write(::apache::thrift::
}
-Airavata_addUNICOREJobSubmissionDetails_result::~Airavata_addUNICOREJobSubmissionDetails_result() throw() {
+Airavata_updateLocalSubmissionDetails_result::~Airavata_updateLocalSubmissionDetails_result() throw() {
}
-uint32_t Airavata_addUNICOREJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_updateLocalSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23050,8 +22975,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_result::read(::apache::thrift::
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->success);
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -23101,15 +23026,15 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_result::read(::apache::thrift::
return xfer;
}
-uint32_t Airavata_addUNICOREJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_updateLocalSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_updateLocalSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
- xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
+ xfer += oprot->writeBool(this->success);
xfer += oprot->writeFieldEnd();
} else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
@@ -23134,11 +23059,11 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_result::write(::apache::thrift:
}
-Airavata_addUNICOREJobSubmissionDetails_presult::~Airavata_addUNICOREJobSubmissionDetails_presult() throw() {
+Airavata_updateLocalSubmissionDetails_presult::~Airavata_updateLocalSubmissionDetails_presult() throw() {
}
-uint32_t Airavata_addUNICOREJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_updateLocalSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23159,8 +23084,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_presult::read(::apache::thrift:
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString((*(this->success)));
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -23211,11 +23136,11 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_presult::read(::apache::thrift:
}
-Airavata_getUnicoreJobSubmission_args::~Airavata_getUnicoreJobSubmission_args() throw() {
+Airavata_getLocalJobSubmission_args::~Airavata_getLocalJobSubmission_args() throw() {
}
-uint32_t Airavata_getUnicoreJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getLocalJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23269,10 +23194,10 @@ uint32_t Airavata_getUnicoreJobSubmission_args::read(::apache::thrift::protocol:
return xfer;
}
-uint32_t Airavata_getUnicoreJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getLocalJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getUnicoreJobSubmission_args");
+ xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
@@ -23289,14 +23214,14 @@ uint32_t Airavata_getUnicoreJobSubmission_args::write(::apache::thrift::protocol
}
-Airavata_getUnicoreJobSubmission_pargs::~Airavata_getUnicoreJobSubmission_pargs() throw() {
+Airavata_getLocalJobSubmission_pargs::~Airavata_getLocalJobSubmission_pargs() throw() {
}
-uint32_t Airavata_getUnicoreJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getLocalJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getUnicoreJobSubmission_pargs");
+ xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
@@ -23313,11 +23238,11 @@ uint32_t Airavata_getUnicoreJobSubmission_pargs::write(::apache::thrift::protoco
}
-Airavata_getUnicoreJobSubmission_result::~Airavata_getUnicoreJobSubmission_result() throw() {
+Airavata_getLocalJobSubmission_result::~Airavata_getLocalJobSubmission_result() throw() {
}
-uint32_t Airavata_getUnicoreJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getLocalJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23389,11 +23314,11 @@ uint32_t Airavata_getUnicoreJobSubmission_result::read(::apache::thrift::protoco
return xfer;
}
-uint32_t Airavata_getUnicoreJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getLocalJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_getUnicoreJobSubmission_result");
+ xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
@@ -23422,11 +23347,11 @@ uint32_t Airavata_getUnicoreJobSubmission_result::write(::apache::thrift::protoc
}
-Airavata_getUnicoreJobSubmission_presult::~Airavata_getUnicoreJobSubmission_presult() throw() {
+Airavata_getLocalJobSubmission_presult::~Airavata_getLocalJobSubmission_presult() throw() {
}
-uint32_t Airavata_getUnicoreJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getLocalJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23499,11 +23424,11 @@ uint32_t Airavata_getUnicoreJobSubmission_presult::read(::apache::thrift::protoc
}
-Airavata_addCloudJobSubmissionDetails_args::~Airavata_addCloudJobSubmissionDetails_args() throw() {
+Airavata_addSSHJobSubmissionDetails_args::~Airavata_addSSHJobSubmissionDetails_args() throw() {
}
-uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23517,7 +23442,7 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::prot
bool isset_authzToken = false;
bool isset_computeResourceId = false;
bool isset_priorityOrder = false;
- bool isset_cloudSubmission = false;
+ bool isset_sshJobSubmission = false;
while (true)
{
@@ -23553,8 +23478,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::prot
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->cloudSubmission.read(iprot);
- isset_cloudSubmission = true;
+ xfer += this->sshJobSubmission.read(iprot);
+ isset_sshJobSubmission = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -23574,15 +23499,15 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::prot
throw TProtocolException(TProtocolException::INVALID_DATA);
if (!isset_priorityOrder)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_cloudSubmission)
+ if (!isset_sshJobSubmission)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_addCloudJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
@@ -23596,8 +23521,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::write(::apache::thrift::pro
xfer += oprot->writeI32(this->priorityOrder);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("cloudSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += this->cloudSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += this->sshJobSubmission.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -23607,14 +23532,14 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::write(::apache::thrift::pro
}
-Airavata_addCloudJobSubmissionDetails_pargs::~Airavata_addCloudJobSubmissionDetails_pargs() throw() {
+Airavata_addSSHJobSubmissionDetails_pargs::~Airavata_addSSHJobSubmissionDetails_pargs() throw() {
}
-uint32_t Airavata_addCloudJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
@@ -23628,8 +23553,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_pargs::write(::apache::thrift::pr
xfer += oprot->writeI32((*(this->priorityOrder)));
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("cloudSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
- xfer += (*(this->cloudSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += (*(this->sshJobSubmission)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -23639,11 +23564,11 @@ uint32_t Airavata_addCloudJobSubmissionDetails_pargs::write(::apache::thrift::pr
}
-Airavata_addCloudJobSubmissionDetails_result::~Airavata_addCloudJobSubmissionDetails_result() throw() {
+Airavata_addSSHJobSubmissionDetails_result::~Airavata_addSSHJobSubmissionDetails_result() throw() {
}
-uint32_t Airavata_addCloudJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addSSHJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23715,11 +23640,11 @@ uint32_t Airavata_addCloudJobSubmissionDetails_result::read(::apache::thrift::pr
return xfer;
}
-uint32_t Airavata_addCloudJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addSSHJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_result");
if (this->__isset.success) {
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
@@ -23748,11 +23673,11 @@ uint32_t Airavata_addCloudJobSubmissionDetails_result::write(::apache::thrift::p
}
-Airavata_addCloudJobSubmissionDetails_presult::~Airavata_addCloudJobSubmissionDetails_presult() throw() {
+Airavata_addSSHJobSubmissionDetails_presult::~Airavata_addSSHJobSubmissionDetails_presult() throw() {
}
-uint32_t Airavata_addCloudJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addSSHJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23825,11 +23750,11 @@ uint32_t Airavata_addCloudJobSubmissionDetails_presult::read(::apache::thrift::p
}
-Airavata_getCloudJobSubmission_args::~Airavata_getCloudJobSubmission_args() throw() {
+Airavata_addSSHForkJobSubmissionDetails_args::~Airavata_addSSHForkJobSubmissionDetails_args() throw() {
}
-uint32_t Airavata_getCloudJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addSSHForkJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23841,7 +23766,9 @@ uint32_t Airavata_getCloudJobSubmission_args::read(::apache::thrift::protocol::T
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_jobSubmissionId = false;
+ bool isset_computeResourceId = false;
+ bool isset_priorityOrder = false;
+ bool isset_sshJobSubmission = false;
while (true)
{
@@ -23861,8 +23788,24 @@ uint32_t Airavata_getCloudJobSubmission_args::read(::apache::thrift::protocol::T
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionId);
- isset_jobSubmissionId = true;
+ xfer += iprot->readString(this->computeResourceId);
+ isset_computeResourceId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->priorityOrder);
+ isset_priorityOrder = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->sshJobSubmission.read(iprot);
+ isset_sshJobSubmission = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -23878,22 +23821,34 @@ uint32_t Airavata_getCloudJobSubmission_args::read(::apache::thrift::protocol::T
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionId)
+ if (!isset_computeResourceId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_priorityOrder)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_sshJobSubmission)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_getCloudJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addSSHForkJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getCloudJobSubmission_args");
+ xfer += oprot->writeStructBegin("Airavata_addSSHForkJobSubmissionDetails_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->jobSubmissionId);
+ xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->computeResourceId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32(this->priorityOrder);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += this->sshJobSubmission.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -23903,21 +23858,29 @@ uint32_t Airavata_getCloudJobSubmission_args::write(::apache::thrift::protocol::
}
-Airavata_getCloudJobSubmission_pargs::~Airavata_getCloudJobSubmission_pargs() throw() {
+Airavata_addSSHForkJobSubmissionDetails_pargs::~Airavata_addSSHForkJobSubmissionDetails_pargs() throw() {
}
-uint32_t Airavata_getCloudJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addSSHForkJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_getCloudJobSubmission_pargs");
+ xfer += oprot->writeStructBegin("Airavata_addSSHForkJobSubmissionDetails_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->jobSubmissionId)));
+ xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->computeResourceId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32((*(this->priorityOrder)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += (*(this->sshJobSubmission)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -23927,11 +23890,11 @@ uint32_t Airavata_getCloudJobSubmission_pargs::write(::apache::thrift::protocol:
}
-Airavata_getCloudJobSubmission_result::~Airavata_getCloudJobSubmission_result() throw() {
+Airavata_addSSHForkJobSubmissionDetails_result::~Airavata_addSSHForkJobSubmissionDetails_result() throw() {
}
-uint32_t Airavata_getCloudJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addSSHForkJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -23952,8 +23915,8 @@ uint32_t Airavata_getCloudJobSubmission_result::read(::apache::thrift::protocol:
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->success.read(iprot);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -24003,15 +23966,15 @@ uint32_t Airavata_getCloudJobSubmission_result::read(::apache::thrift::protocol:
return xfer;
}
-uint32_t Airavata_getCloudJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_addSSHForkJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_getCloudJobSubmission_result");
+ xfer += oprot->writeStructBegin("Airavata_addSSHForkJobSubmissionDetails_result");
if (this->__isset.success) {
- xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
- xfer += this->success.write(oprot);
+ 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);
@@ -24036,11 +23999,11 @@ uint32_t Airavata_getCloudJobSubmission_result::write(::apache::thrift::protocol
}
-Airavata_getCloudJobSubmission_presult::~Airavata_getCloudJobSubmission_presult() throw() {
+Airavata_addSSHForkJobSubmissionDetails_presult::~Airavata_addSSHForkJobSubmissionDetails_presult() throw() {
}
-uint32_t Airavata_getCloudJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addSSHForkJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -24061,8 +24024,8 @@ uint32_t Airavata_getCloudJobSubmission_presult::read(::apache::thrift::protocol
switch (fid)
{
case 0:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += (*(this->success)).read(iprot);
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -24113,11 +24076,11 @@ uint32_t Airavata_getCloudJobSubmission_presult::read(::apache::thrift::protocol
}
-Airavata_updateSSHJobSubmissionDetails_args::~Airavata_updateSSHJobSubmissionDetails_args() throw() {
+Airavata_getSSHJobSubmission_args::~Airavata_getSSHJobSubmission_args() throw() {
}
-uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getSSHJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -24129,8 +24092,7 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::pro
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_jobSubmissionInterfaceId = false;
- bool isset_sshJobSubmission = false;
+ bool isset_jobSubmissionId = false;
while (true)
{
@@ -24150,16 +24112,8 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::pro
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->sshJobSubmission.read(iprot);
- isset_sshJobSubmission = true;
+ xfer += iprot->readString(this->jobSubmissionId);
+ isset_jobSubmissionId = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -24175,28 +24129,22 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::pro
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionInterfaceId)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_sshJobSubmission)
+ if (!isset_jobSubmissionId)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_updateSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getSSHJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_args");
+ xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_args");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->authzToken.write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->jobSubmissionInterfaceId);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3);
- xfer += this->sshJobSubmission.write(oprot);
+ xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->jobSubmissionId);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -24206,25 +24154,21 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::write(::apache::thrift::pr
}
-Airavata_updateSSHJobSubmissionDetails_pargs::~Airavata_updateSSHJobSubmissionDetails_pargs() throw() {
+Airavata_getSSHJobSubmission_pargs::~Airavata_getSSHJobSubmission_pargs() throw() {
}
-uint32_t Airavata_updateSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getSSHJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
oprot->incrementRecursionDepth();
- xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_pargs");
+ xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_pargs");
xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += (*(this->authzToken)).write(oprot);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->jobSubmissionInterfaceId)));
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3);
- xfer += (*(this->sshJobSubmission)).write(oprot);
+ xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->jobSubmissionId)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -24234,11 +24178,11 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_pargs::write(::apache::thrift::p
}
-Airavata_updateSSHJobSubmissionDetails_result::~Airavata_updateSSHJobSubmissionDetails_result() throw() {
+Airavata_getSSHJobSubmission_result::~Airavata_getSSHJobSubmission_result() throw() {
}
-uint32_t Airavata_updateSSHJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getSSHJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -24259,8 +24203,8 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_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_STRUCT) {
+ xfer += this->success.read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -24310,15 +24254,15 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_result::read(::apache::thrift::p
return xfer;
}
-uint32_t Airavata_updateSSHJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+uint32_t Airavata_getSSHJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
uint32_t xfer = 0;
- xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_result");
+ xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_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_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);
@@ -24343,11 +24287,11 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_result::write(::apache::thrift::
}
-Airavata_updateSSHJobSubmissionDetails_presult::~Airavata_updateSSHJobSubmissionDetails_presult() throw() {
+Airavata_getSSHJobSubmission_presult::~Airavata_getSSHJobSubmission_presult() throw() {
}
-uint32_t Airavata_updateSSHJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_getSSHJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -24368,8 +24312,8 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_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_STRUCT) {
+ xfer += (*(this->success)).read(iprot);
this->__isset.success = true;
} else {
xfer += iprot->skip(ftype);
@@ -24420,11 +24364,11 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_presult::read(::apache::thrift::
}
-Airavata_updateCloudJobSubmissionDetails_args::~Airavata_updateCloudJobSubmissionDetails_args() throw() {
+Airavata_addUNICOREJobSubmissionDetails_args::~Airavata_addUNICOREJobSubmissionDetails_args() throw() {
}
-uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -24436,8 +24380,9 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::p
using ::apache::thrift::protocol::TProtocolException;
bool isset_authzToken = false;
- bool isset_jobSubmissionInterfaceId = false;
- bool isset_sshJobSubmission = false;
+ bool isset_computeResourceId = false;
+ bool isset_priorityOrder = false;
+ bool isset_unicoreJobSubmission = false;
while (true)
{
@@ -24457,16 +24402,24 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::p
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->jobSubmissionInterfaceId);
- isset_jobSubmissionInterfaceId = true;
+ xfer += iprot->readString(this->computeResourceId);
+ isset_computeResourceId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->priorityOrder);
+ isset_priorityOrder = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->sshJobSubmission.read(iprot);
- isset_sshJobSubmission = true;
+ xfer += this->unicoreJobSubmission.read(iprot);
+ isset_unicoreJobSubmission = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -24482,28 +24435,34 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::p
if (!isset_authzToken)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_jobSubmissionInterfaceId)
+ if (!isset_computeResourceId)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_sshJobSubmission)
+ if (!isset_priorityOrder)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_unicoreJobSubmission)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
}
-uint32_t Airavata_updateCloudJobSubmissionDetails_args::write(::apache::thrift::protocol::
<TRUNCATED>