airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sma...@apache.org
Subject [7/9] airavata git commit: adding api methods for storage resources
Date Thu, 12 Nov 2015 19:55:55 GMT
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>

Mime
View raw message