http://git-wip-us.apache.org/repos/asf/airavata/blob/47e82148/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 f166f89..1aa8caa 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 @@ -12984,7 +12984,7 @@ uint32_t Airavata_updateLocalSubmissionDetails_presult::read(::apache::thrift::p return xfer; } -uint32_t Airavata_addSSHJobSubmissionDetails_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; @@ -12995,9 +12995,7 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protoc using ::apache::thrift::protocol::TProtocolException; - bool isset_computeResourceId = false; - bool isset_priorityOrder = false; - bool isset_sshJobSubmission = false; + bool isset_jobSubmissionId = false; while (true) { @@ -13009,24 +13007,8 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protoc { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->priorityOrder); - isset_priorityOrder = 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); } @@ -13040,29 +13022,17 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::read(::apache::thrift::protoc xfer += iprot->readStructEnd(); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_priorityOrder) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_sshJobSubmission) + if (!isset_jobSubmissionId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getLocalJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_args"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32(this->priorityOrder); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_args"); - xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->sshJobSubmission.write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->jobSubmissionId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13070,20 +13040,12 @@ uint32_t Airavata_addSSHJobSubmissionDetails_args::write(::apache::thrift::proto return xfer; } -uint32_t Airavata_addSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getLocalJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_pargs"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((*(this->priorityOrder))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_pargs"); - xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->sshJobSubmission)).write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->jobSubmissionId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13091,7 +13053,7 @@ uint32_t Airavata_addSSHJobSubmissionDetails_pargs::write(::apache::thrift::prot return xfer; } -uint32_t Airavata_addSSHJobSubmissionDetails_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; @@ -13112,8 +13074,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_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -13155,15 +13117,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_getLocalJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_result"); + xfer += oprot->writeStructBegin("Airavata_getLocalJobSubmission_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_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); @@ -13183,7 +13145,7 @@ uint32_t Airavata_addSSHJobSubmissionDetails_result::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_addSSHJobSubmissionDetails_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; @@ -13204,8 +13166,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_STRUCT) { + xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -13247,7 +13209,7 @@ uint32_t Airavata_addSSHJobSubmissionDetails_presult::read(::apache::thrift::pro return xfer; } -uint32_t Airavata_addUNICOREJobSubmissionDetails_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; @@ -13260,7 +13222,7 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::pr bool isset_computeResourceId = false; bool isset_priorityOrder = false; - bool isset_unicoreJobSubmission = false; + bool isset_sshJobSubmission = false; while (true) { @@ -13288,8 +13250,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::pr break; case 3: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->unicoreJobSubmission.read(iprot); - isset_unicoreJobSubmission = true; + xfer += this->sshJobSubmission.read(iprot); + isset_sshJobSubmission = true; } else { xfer += iprot->skip(ftype); } @@ -13307,14 +13269,14 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::read(::apache::thrift::pr throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_priorityOrder) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_unicoreJobSubmission) + if (!isset_sshJobSubmission) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addUNICOREJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_args"); + xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_args"); xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->computeResourceId); @@ -13324,8 +13286,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::write(::apache::thrift::p xfer += oprot->writeI32(this->priorityOrder); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("unicoreJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->unicoreJobSubmission.write(oprot); + xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->sshJobSubmission.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13333,9 +13295,9 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_args::write(::apache::thrift::p return xfer; } -uint32_t Airavata_addUNICOREJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_pargs"); + xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_pargs"); xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->computeResourceId))); @@ -13345,8 +13307,8 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_pargs::write(::apache::thrift:: xfer += oprot->writeI32((*(this->priorityOrder))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("unicoreJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->unicoreJobSubmission)).write(oprot); + xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->sshJobSubmission)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13354,7 +13316,7 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_pargs::write(::apache::thrift:: return xfer; } -uint32_t Airavata_addUNICOREJobSubmissionDetails_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; @@ -13418,11 +13380,11 @@ 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_addSSHJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_result"); + xfer += oprot->writeStructBegin("Airavata_addSSHJobSubmissionDetails_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); @@ -13446,7 +13408,7 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_result::write(::apache::thrift: return xfer; } -uint32_t Airavata_addUNICOREJobSubmissionDetails_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; @@ -13510,7 +13472,7 @@ uint32_t Airavata_addUNICOREJobSubmissionDetails_presult::read(::apache::thrift: return xfer; } -uint32_t Airavata_addCloudJobSubmissionDetails_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; @@ -13521,9 +13483,7 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::prot using ::apache::thrift::protocol::TProtocolException; - bool isset_computeResourceId = false; - bool isset_priorityOrder = false; - bool isset_cloudSubmission = false; + bool isset_jobSubmissionId = false; while (true) { @@ -13535,24 +13495,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::prot { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->computeResourceId); - isset_computeResourceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->priorityOrder); - isset_priorityOrder = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->cloudSubmission.read(iprot); - isset_cloudSubmission = true; + xfer += iprot->readString(this->jobSubmissionId); + isset_jobSubmissionId = true; } else { xfer += iprot->skip(ftype); } @@ -13566,29 +13510,17 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::prot xfer += iprot->readStructEnd(); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_priorityOrder) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_cloudSubmission) + if (!isset_jobSubmissionId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addCloudJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getSSHJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_args"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32(this->priorityOrder); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_args"); - xfer += oprot->writeFieldBegin("cloudSubmission", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->cloudSubmission.write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->jobSubmissionId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13596,20 +13528,12 @@ uint32_t Airavata_addCloudJobSubmissionDetails_args::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_addCloudJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getSSHJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_pargs"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((*(this->priorityOrder))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_pargs"); - xfer += oprot->writeFieldBegin("cloudSubmission", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->cloudSubmission)).write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->jobSubmissionId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13617,7 +13541,7 @@ uint32_t Airavata_addCloudJobSubmissionDetails_pargs::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_addCloudJobSubmissionDetails_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; @@ -13638,8 +13562,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_result::read(::apache::thrift::pr switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->success); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -13681,15 +13605,15 @@ 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_getSSHJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_result"); + xfer += oprot->writeStructBegin("Airavata_getSSHJobSubmission_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_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); @@ -13709,7 +13633,7 @@ uint32_t Airavata_addCloudJobSubmissionDetails_result::write(::apache::thrift::p return xfer; } -uint32_t Airavata_addCloudJobSubmissionDetails_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; @@ -13730,8 +13654,8 @@ uint32_t Airavata_addCloudJobSubmissionDetails_presult::read(::apache::thrift::p switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -13773,7 +13697,7 @@ uint32_t Airavata_addCloudJobSubmissionDetails_presult::read(::apache::thrift::p return xfer; } -uint32_t Airavata_updateSSHJobSubmissionDetails_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; @@ -13784,8 +13708,9 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::pro using ::apache::thrift::protocol::TProtocolException; - bool isset_jobSubmissionInterfaceId = false; - bool isset_sshJobSubmission = false; + bool isset_computeResourceId = false; + bool isset_priorityOrder = false; + bool isset_unicoreJobSubmission = false; while (true) { @@ -13797,16 +13722,24 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::pro { case 1: 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 2: + if (ftype == ::apache::thrift::protocol::T_I32) { + xfer += iprot->readI32(this->priorityOrder); + isset_priorityOrder = 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 += this->unicoreJobSubmission.read(iprot); + isset_unicoreJobSubmission = true; } else { xfer += iprot->skip(ftype); } @@ -13820,23 +13753,29 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::pro xfer += iprot->readStructEnd(); - 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_updateSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addUNICOREJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_args"); + xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_args"); - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->jobSubmissionInterfaceId); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->computeResourceId); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->sshJobSubmission.write(oprot); + xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); + xfer += oprot->writeI32(this->priorityOrder); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("unicoreJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->unicoreJobSubmission.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13844,16 +13783,20 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_args::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_updateSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addUNICOREJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_pargs"); + xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_pargs"); - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->computeResourceId))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->sshJobSubmission)).write(oprot); + xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); + xfer += oprot->writeI32((*(this->priorityOrder))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("unicoreJobSubmission", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->unicoreJobSubmission)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -13861,7 +13804,7 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_pargs::write(::apache::thrift::p return xfer; } -uint32_t Airavata_updateSSHJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addUNICOREJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -13882,8 +13825,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_STRING) { + xfer += iprot->readString(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -13925,15 +13868,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_addUNICOREJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_result"); + xfer += oprot->writeStructBegin("Airavata_addUNICOREJobSubmissionDetails_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); - xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); + xfer += oprot->writeString(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -13953,7 +13896,7 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_result::write(::apache::thrift:: return xfer; } -uint32_t Airavata_updateSSHJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addUNICOREJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -13974,8 +13917,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_STRING) { + xfer += iprot->readString((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -14017,7 +13960,7 @@ uint32_t Airavata_updateSSHJobSubmissionDetails_presult::read(::apache::thrift:: return xfer; } -uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getUnicoreJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14028,8 +13971,7 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::p using ::apache::thrift::protocol::TProtocolException; - bool isset_jobSubmissionInterfaceId = false; - bool isset_sshJobSubmission = false; + bool isset_jobSubmissionId = false; while (true) { @@ -14041,16 +13983,8 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::p { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->jobSubmissionInterfaceId); - isset_jobSubmissionInterfaceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - 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); } @@ -14064,23 +13998,17 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::p xfer += iprot->readStructEnd(); - if (!isset_jobSubmissionInterfaceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_sshJobSubmission) + if (!isset_jobSubmissionId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateCloudJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getUnicoreJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateCloudJobSubmissionDetails_args"); - - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->jobSubmissionInterfaceId); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getUnicoreJobSubmission_args"); - xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->sshJobSubmission.write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->jobSubmissionId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14088,16 +14016,12 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_args::write(::apache::thrift:: return xfer; } -uint32_t Airavata_updateCloudJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getUnicoreJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateCloudJobSubmissionDetails_pargs"); - - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getUnicoreJobSubmission_pargs"); - xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->sshJobSubmission)).write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->jobSubmissionId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14105,7 +14029,7 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_pargs::write(::apache::thrift: return xfer; } -uint32_t Airavata_updateCloudJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getUnicoreJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14126,8 +14050,8 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_result::read(::apache::thrift: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -14169,15 +14093,15 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_result::read(::apache::thrift: return xfer; } -uint32_t Airavata_updateCloudJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getUnicoreJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateCloudJobSubmissionDetails_result"); + xfer += oprot->writeStructBegin("Airavata_getUnicoreJobSubmission_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); @@ -14197,7 +14121,7 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_result::write(::apache::thrift return xfer; } -uint32_t Airavata_updateCloudJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getUnicoreJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14218,8 +14142,8 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_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); @@ -14261,7 +14185,7 @@ uint32_t Airavata_updateCloudJobSubmissionDetails_presult::read(::apache::thrift return xfer; } -uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addCloudJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14274,7 +14198,7 @@ uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::proto bool isset_computeResourceId = false; bool isset_priorityOrder = false; - bool isset_localDataMovement = false; + bool isset_cloudSubmission = false; while (true) { @@ -14302,8 +14226,8 @@ uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::proto break; case 3: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->localDataMovement.read(iprot); - isset_localDataMovement = true; + xfer += this->cloudSubmission.read(iprot); + isset_cloudSubmission = true; } else { xfer += iprot->skip(ftype); } @@ -14321,14 +14245,14 @@ uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::proto throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_priorityOrder) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_localDataMovement) + if (!isset_cloudSubmission) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addLocalDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addCloudJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_args"); + xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_args"); xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->computeResourceId); @@ -14338,8 +14262,8 @@ uint32_t Airavata_addLocalDataMovementDetails_args::write(::apache::thrift::prot xfer += oprot->writeI32(this->priorityOrder); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->localDataMovement.write(oprot); + xfer += oprot->writeFieldBegin("cloudSubmission", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->cloudSubmission.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14347,9 +14271,9 @@ uint32_t Airavata_addLocalDataMovementDetails_args::write(::apache::thrift::prot return xfer; } -uint32_t Airavata_addLocalDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addCloudJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_pargs"); + xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_pargs"); xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->computeResourceId))); @@ -14359,8 +14283,8 @@ uint32_t Airavata_addLocalDataMovementDetails_pargs::write(::apache::thrift::pro xfer += oprot->writeI32((*(this->priorityOrder))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->localDataMovement)).write(oprot); + xfer += oprot->writeFieldBegin("cloudSubmission", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->cloudSubmission)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14368,7 +14292,7 @@ uint32_t Airavata_addLocalDataMovementDetails_pargs::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_addLocalDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addCloudJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14432,11 +14356,11 @@ uint32_t Airavata_addLocalDataMovementDetails_result::read(::apache::thrift::pro return xfer; } -uint32_t Airavata_addLocalDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addCloudJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_result"); + xfer += oprot->writeStructBegin("Airavata_addCloudJobSubmissionDetails_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); @@ -14460,7 +14384,7 @@ uint32_t Airavata_addLocalDataMovementDetails_result::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_addLocalDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addCloudJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14524,7 +14448,7 @@ uint32_t Airavata_addLocalDataMovementDetails_presult::read(::apache::thrift::pr return xfer; } -uint32_t Airavata_updateLocalDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getCloudJobSubmission_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14535,8 +14459,7 @@ uint32_t Airavata_updateLocalDataMovementDetails_args::read(::apache::thrift::pr using ::apache::thrift::protocol::TProtocolException; - bool isset_jobSubmissionInterfaceId = false; - bool isset_localDataMovement = false; + bool isset_jobSubmissionId = false; while (true) { @@ -14548,16 +14471,8 @@ uint32_t Airavata_updateLocalDataMovementDetails_args::read(::apache::thrift::pr { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->jobSubmissionInterfaceId); - isset_jobSubmissionInterfaceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->localDataMovement.read(iprot); - isset_localDataMovement = true; + xfer += iprot->readString(this->jobSubmissionId); + isset_jobSubmissionId = true; } else { xfer += iprot->skip(ftype); } @@ -14571,23 +14486,17 @@ uint32_t Airavata_updateLocalDataMovementDetails_args::read(::apache::thrift::pr xfer += iprot->readStructEnd(); - if (!isset_jobSubmissionInterfaceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_localDataMovement) + if (!isset_jobSubmissionId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateLocalDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getCloudJobSubmission_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateLocalDataMovementDetails_args"); - - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->jobSubmissionInterfaceId); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getCloudJobSubmission_args"); - xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->localDataMovement.write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->jobSubmissionId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14595,16 +14504,12 @@ uint32_t Airavata_updateLocalDataMovementDetails_args::write(::apache::thrift::p return xfer; } -uint32_t Airavata_updateLocalDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getCloudJobSubmission_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateLocalDataMovementDetails_pargs"); - - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getCloudJobSubmission_pargs"); - xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->localDataMovement)).write(oprot); + xfer += oprot->writeFieldBegin("jobSubmissionId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->jobSubmissionId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14612,7 +14517,7 @@ uint32_t Airavata_updateLocalDataMovementDetails_pargs::write(::apache::thrift:: return xfer; } -uint32_t Airavata_updateLocalDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getCloudJobSubmission_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14633,8 +14538,8 @@ uint32_t Airavata_updateLocalDataMovementDetails_result::read(::apache::thrift:: switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -14676,15 +14581,15 @@ uint32_t Airavata_updateLocalDataMovementDetails_result::read(::apache::thrift:: return xfer; } -uint32_t Airavata_updateLocalDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getCloudJobSubmission_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateLocalDataMovementDetails_result"); + xfer += oprot->writeStructBegin("Airavata_getCloudJobSubmission_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); @@ -14704,7 +14609,7 @@ uint32_t Airavata_updateLocalDataMovementDetails_result::write(::apache::thrift: return xfer; } -uint32_t Airavata_updateLocalDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getCloudJobSubmission_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14725,8 +14630,8 @@ uint32_t Airavata_updateLocalDataMovementDetails_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); @@ -14768,7 +14673,7 @@ uint32_t Airavata_updateLocalDataMovementDetails_presult::read(::apache::thrift: return xfer; } -uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateSSHJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14779,9 +14684,8 @@ uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protoco using ::apache::thrift::protocol::TProtocolException; - bool isset_computeResourceId = false; - bool isset_priorityOrder = false; - bool isset_scpDataMovement = false; + bool isset_jobSubmissionInterfaceId = false; + bool isset_sshJobSubmission = false; while (true) { @@ -14793,24 +14697,16 @@ uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protoco { case 1: 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 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->priorityOrder); - isset_priorityOrder = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->scpDataMovement.read(iprot); - isset_scpDataMovement = true; + xfer += this->sshJobSubmission.read(iprot); + isset_sshJobSubmission = true; } else { xfer += iprot->skip(ftype); } @@ -14824,29 +14720,23 @@ uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protoco xfer += iprot->readStructEnd(); - if (!isset_computeResourceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_priorityOrder) + if (!isset_jobSubmissionInterfaceId) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_scpDataMovement) + if (!isset_sshJobSubmission) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addSCPDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateSSHJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_args"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->computeResourceId); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_args"); - xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32(this->priorityOrder); + xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->jobSubmissionInterfaceId); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->scpDataMovement.write(oprot); + xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->sshJobSubmission.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14854,20 +14744,16 @@ uint32_t Airavata_addSCPDataMovementDetails_args::write(::apache::thrift::protoc return xfer; } -uint32_t Airavata_addSCPDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateSSHJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_pargs"); - - xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->computeResourceId))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_pargs"); - xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((*(this->priorityOrder))); + xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->scpDataMovement)).write(oprot); + xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->sshJobSubmission)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -14875,7 +14761,7 @@ uint32_t Airavata_addSCPDataMovementDetails_pargs::write(::apache::thrift::proto return xfer; } -uint32_t Airavata_addSCPDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateSSHJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14896,8 +14782,8 @@ uint32_t Airavata_addSCPDataMovementDetails_result::read(::apache::thrift::proto 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); @@ -14939,15 +14825,15 @@ uint32_t Airavata_addSCPDataMovementDetails_result::read(::apache::thrift::proto return xfer; } -uint32_t Airavata_addSCPDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateSSHJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_result"); + xfer += oprot->writeStructBegin("Airavata_updateSSHJobSubmissionDetails_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); @@ -14967,7 +14853,7 @@ uint32_t Airavata_addSCPDataMovementDetails_result::write(::apache::thrift::prot return xfer; } -uint32_t Airavata_addSCPDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateSSHJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -14988,8 +14874,8 @@ uint32_t Airavata_addSCPDataMovementDetails_presult::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); @@ -15031,7 +14917,7 @@ uint32_t Airavata_addSCPDataMovementDetails_presult::read(::apache::thrift::prot return xfer; } -uint32_t Airavata_updateSCPDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateCloudJobSubmissionDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15043,7 +14929,7 @@ uint32_t Airavata_updateSCPDataMovementDetails_args::read(::apache::thrift::prot using ::apache::thrift::protocol::TProtocolException; bool isset_jobSubmissionInterfaceId = false; - bool isset_scpDataMovement = false; + bool isset_sshJobSubmission = false; while (true) { @@ -15063,8 +14949,8 @@ uint32_t Airavata_updateSCPDataMovementDetails_args::read(::apache::thrift::prot break; case 2: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->scpDataMovement.read(iprot); - isset_scpDataMovement = true; + xfer += this->sshJobSubmission.read(iprot); + isset_sshJobSubmission = true; } else { xfer += iprot->skip(ftype); } @@ -15080,21 +14966,21 @@ uint32_t Airavata_updateSCPDataMovementDetails_args::read(::apache::thrift::prot if (!isset_jobSubmissionInterfaceId) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_scpDataMovement) + if (!isset_sshJobSubmission) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateSCPDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateCloudJobSubmissionDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateSCPDataMovementDetails_args"); + xfer += oprot->writeStructBegin("Airavata_updateCloudJobSubmissionDetails_args"); xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->jobSubmissionInterfaceId); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->scpDataMovement.write(oprot); + xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->sshJobSubmission.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15102,16 +14988,16 @@ uint32_t Airavata_updateSCPDataMovementDetails_args::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_updateSCPDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateCloudJobSubmissionDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateSCPDataMovementDetails_pargs"); + xfer += oprot->writeStructBegin("Airavata_updateCloudJobSubmissionDetails_pargs"); xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->scpDataMovement)).write(oprot); + xfer += oprot->writeFieldBegin("sshJobSubmission", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->sshJobSubmission)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15119,7 +15005,7 @@ uint32_t Airavata_updateSCPDataMovementDetails_pargs::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_updateSCPDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateCloudJobSubmissionDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15183,11 +15069,11 @@ uint32_t Airavata_updateSCPDataMovementDetails_result::read(::apache::thrift::pr return xfer; } -uint32_t Airavata_updateSCPDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateCloudJobSubmissionDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateSCPDataMovementDetails_result"); + xfer += oprot->writeStructBegin("Airavata_updateCloudJobSubmissionDetails_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); @@ -15211,7 +15097,7 @@ uint32_t Airavata_updateSCPDataMovementDetails_result::write(::apache::thrift::p return xfer; } -uint32_t Airavata_updateSCPDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateCloudJobSubmissionDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15275,7 +15161,7 @@ uint32_t Airavata_updateSCPDataMovementDetails_presult::read(::apache::thrift::p return xfer; } -uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addLocalDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15288,7 +15174,7 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::pro bool isset_computeResourceId = false; bool isset_priorityOrder = false; - bool isset_gridFTPDataMovement = false; + bool isset_localDataMovement = false; while (true) { @@ -15316,8 +15202,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::pro break; case 3: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->gridFTPDataMovement.read(iprot); - isset_gridFTPDataMovement = true; + xfer += this->localDataMovement.read(iprot); + isset_localDataMovement = true; } else { xfer += iprot->skip(ftype); } @@ -15335,14 +15221,14 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::read(::apache::thrift::pro throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_priorityOrder) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_gridFTPDataMovement) + if (!isset_localDataMovement) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_addGridFTPDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addLocalDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addGridFTPDataMovementDetails_args"); + xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_args"); xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->computeResourceId); @@ -15352,8 +15238,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::write(::apache::thrift::pr xfer += oprot->writeI32(this->priorityOrder); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gridFTPDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->gridFTPDataMovement.write(oprot); + xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->localDataMovement.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15361,9 +15247,9 @@ uint32_t Airavata_addGridFTPDataMovementDetails_args::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_addGridFTPDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addLocalDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addGridFTPDataMovementDetails_pargs"); + xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_pargs"); xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->computeResourceId))); @@ -15373,8 +15259,8 @@ uint32_t Airavata_addGridFTPDataMovementDetails_pargs::write(::apache::thrift::p xfer += oprot->writeI32((*(this->priorityOrder))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gridFTPDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += (*(this->gridFTPDataMovement)).write(oprot); + xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->localDataMovement)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15382,7 +15268,7 @@ uint32_t Airavata_addGridFTPDataMovementDetails_pargs::write(::apache::thrift::p return xfer; } -uint32_t Airavata_addGridFTPDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addLocalDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15446,11 +15332,11 @@ uint32_t Airavata_addGridFTPDataMovementDetails_result::read(::apache::thrift::p return xfer; } -uint32_t Airavata_addGridFTPDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addLocalDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_addGridFTPDataMovementDetails_result"); + xfer += oprot->writeStructBegin("Airavata_addLocalDataMovementDetails_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); @@ -15474,7 +15360,7 @@ uint32_t Airavata_addGridFTPDataMovementDetails_result::write(::apache::thrift:: return xfer; } -uint32_t Airavata_addGridFTPDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addLocalDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15538,7 +15424,7 @@ uint32_t Airavata_addGridFTPDataMovementDetails_presult::read(::apache::thrift:: return xfer; } -uint32_t Airavata_updateGridFTPDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateLocalDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15550,7 +15436,7 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_args::read(::apache::thrift:: using ::apache::thrift::protocol::TProtocolException; bool isset_jobSubmissionInterfaceId = false; - bool isset_gridFTPDataMovement = false; + bool isset_localDataMovement = false; while (true) { @@ -15570,8 +15456,8 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_args::read(::apache::thrift:: break; case 2: if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->gridFTPDataMovement.read(iprot); - isset_gridFTPDataMovement = true; + xfer += this->localDataMovement.read(iprot); + isset_localDataMovement = true; } else { xfer += iprot->skip(ftype); } @@ -15587,21 +15473,21 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_args::read(::apache::thrift:: if (!isset_jobSubmissionInterfaceId) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_gridFTPDataMovement) + if (!isset_localDataMovement) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_updateGridFTPDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateLocalDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGridFTPDataMovementDetails_args"); + xfer += oprot->writeStructBegin("Airavata_updateLocalDataMovementDetails_args"); xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->jobSubmissionInterfaceId); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gridFTPDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += this->gridFTPDataMovement.write(oprot); + xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->localDataMovement.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15609,16 +15495,16 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_args::write(::apache::thrift: return xfer; } -uint32_t Airavata_updateGridFTPDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateLocalDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGridFTPDataMovementDetails_pargs"); + xfer += oprot->writeStructBegin("Airavata_updateLocalDataMovementDetails_pargs"); xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("gridFTPDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); - xfer += (*(this->gridFTPDataMovement)).write(oprot); + xfer += oprot->writeFieldBegin("localDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += (*(this->localDataMovement)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15626,7 +15512,7 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_pargs::write(::apache::thrift return xfer; } -uint32_t Airavata_updateGridFTPDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateLocalDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15690,11 +15576,11 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_result::read(::apache::thrift return xfer; } -uint32_t Airavata_updateGridFTPDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateLocalDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_updateGridFTPDataMovementDetails_result"); + xfer += oprot->writeStructBegin("Airavata_updateLocalDataMovementDetails_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); @@ -15718,7 +15604,7 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_result::write(::apache::thrif return xfer; } -uint32_t Airavata_updateGridFTPDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateLocalDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15782,7 +15668,7 @@ uint32_t Airavata_updateGridFTPDataMovementDetails_presult::read(::apache::thrif return xfer; } -uint32_t Airavata_changeJobSubmissionPriority_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getLocalDataMovement_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15793,8 +15679,7 @@ uint32_t Airavata_changeJobSubmissionPriority_args::read(::apache::thrift::proto using ::apache::thrift::protocol::TProtocolException; - bool isset_jobSubmissionInterfaceId = false; - bool isset_newPriorityOrder = false; + bool isset_dataMovementId = false; while (true) { @@ -15806,16 +15691,8 @@ uint32_t Airavata_changeJobSubmissionPriority_args::read(::apache::thrift::proto { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->jobSubmissionInterfaceId); - isset_jobSubmissionInterfaceId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->newPriorityOrder); - isset_newPriorityOrder = true; + xfer += iprot->readString(this->dataMovementId); + isset_dataMovementId = true; } else { xfer += iprot->skip(ftype); } @@ -15829,23 +15706,17 @@ uint32_t Airavata_changeJobSubmissionPriority_args::read(::apache::thrift::proto xfer += iprot->readStructEnd(); - if (!isset_jobSubmissionInterfaceId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_newPriorityOrder) + if (!isset_dataMovementId) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_changeJobSubmissionPriority_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getLocalDataMovement_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeJobSubmissionPriority_args"); - - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->jobSubmissionInterfaceId); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getLocalDataMovement_args"); - xfer += oprot->writeFieldBegin("newPriorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32(this->newPriorityOrder); + xfer += oprot->writeFieldBegin("dataMovementId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->dataMovementId); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15853,16 +15724,12 @@ uint32_t Airavata_changeJobSubmissionPriority_args::write(::apache::thrift::prot return xfer; } -uint32_t Airavata_changeJobSubmissionPriority_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getLocalDataMovement_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeJobSubmissionPriority_pargs"); - - xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->jobSubmissionInterfaceId))); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("Airavata_getLocalDataMovement_pargs"); - xfer += oprot->writeFieldBegin("newPriorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((*(this->newPriorityOrder))); + xfer += oprot->writeFieldBegin("dataMovementId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->dataMovementId))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -15870,7 +15737,7 @@ uint32_t Airavata_changeJobSubmissionPriority_pargs::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_changeJobSubmissionPriority_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getLocalDataMovement_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15891,8 +15758,8 @@ uint32_t Airavata_changeJobSubmissionPriority_result::read(::apache::thrift::pro switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -15934,15 +15801,15 @@ uint32_t Airavata_changeJobSubmissionPriority_result::read(::apache::thrift::pro return xfer; } -uint32_t Airavata_changeJobSubmissionPriority_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_getLocalDataMovement_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeJobSubmissionPriority_result"); + xfer += oprot->writeStructBegin("Airavata_getLocalDataMovement_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); @@ -15962,7 +15829,7 @@ uint32_t Airavata_changeJobSubmissionPriority_result::write(::apache::thrift::pr return xfer; } -uint32_t Airavata_changeJobSubmissionPriority_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_getLocalDataMovement_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -15983,8 +15850,8 @@ uint32_t Airavata_changeJobSubmissionPriority_presult::read(::apache::thrift::pr switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -16026,7 +15893,7 @@ uint32_t Airavata_changeJobSubmissionPriority_presult::read(::apache::thrift::pr return xfer; } -uint32_t Airavata_changeDataMovementPriority_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addSCPDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -16037,8 +15904,9 @@ uint32_t Airavata_changeDataMovementPriority_args::read(::apache::thrift::protoc using ::apache::thrift::protocol::TProtocolException; - bool isset_dataMovementInterfaceId = false; - bool isset_newPriorityOrder = false; + bool isset_computeResourceId = false; + bool isset_priorityOrder = false; + bool isset_scpDataMovement = false; while (true) { @@ -16050,16 +15918,24 @@ uint32_t Airavata_changeDataMovementPriority_args::read(::apache::thrift::protoc { case 1: if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->dataMovementInterfaceId); - isset_dataMovementInterfaceId = true; + xfer += iprot->readString(this->computeResourceId); + isset_computeResourceId = true; } else { xfer += iprot->skip(ftype); } break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - xfer += iprot->readI32(this->newPriorityOrder); - isset_newPriorityOrder = true; + xfer += iprot->readI32(this->priorityOrder); + isset_priorityOrder = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->scpDataMovement.read(iprot); + isset_scpDataMovement = true; } else { xfer += iprot->skip(ftype); } @@ -16073,23 +15949,29 @@ uint32_t Airavata_changeDataMovementPriority_args::read(::apache::thrift::protoc xfer += iprot->readStructEnd(); - if (!isset_dataMovementInterfaceId) + if (!isset_computeResourceId) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_newPriorityOrder) + if (!isset_priorityOrder) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_scpDataMovement) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_changeDataMovementPriority_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addSCPDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeDataMovementPriority_args"); + xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_args"); - xfer += oprot->writeFieldBegin("dataMovementInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->dataMovementInterfaceId); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->computeResourceId); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("newPriorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32(this->newPriorityOrder); + xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); + xfer += oprot->writeI32(this->priorityOrder); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->scpDataMovement.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -16097,16 +15979,20 @@ uint32_t Airavata_changeDataMovementPriority_args::write(::apache::thrift::proto return xfer; } -uint32_t Airavata_changeDataMovementPriority_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addSCPDataMovementDetails_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeDataMovementPriority_pargs"); + xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_pargs"); - xfer += oprot->writeFieldBegin("dataMovementInterfaceId", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString((*(this->dataMovementInterfaceId))); + xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString((*(this->computeResourceId))); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("newPriorityOrder", ::apache::thrift::protocol::T_I32, 2); - xfer += oprot->writeI32((*(this->newPriorityOrder))); + xfer += oprot->writeFieldBegin("priorityOrder", ::apache::thrift::protocol::T_I32, 2); + xfer += oprot->writeI32((*(this->priorityOrder))); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += (*(this->scpDataMovement)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -16114,7 +16000,7 @@ uint32_t Airavata_changeDataMovementPriority_pargs::write(::apache::thrift::prot return xfer; } -uint32_t Airavata_changeDataMovementPriority_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addSCPDataMovementDetails_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -16135,8 +16021,8 @@ uint32_t Airavata_changeDataMovementPriority_result::read(::apache::thrift::prot switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->success); + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -16178,15 +16064,15 @@ uint32_t Airavata_changeDataMovementPriority_result::read(::apache::thrift::prot return xfer; } -uint32_t Airavata_changeDataMovementPriority_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_addSCPDataMovementDetails_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeDataMovementPriority_result"); + xfer += oprot->writeStructBegin("Airavata_addSCPDataMovementDetails_result"); if (this->__isset.success) { - xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); - xfer += oprot->writeBool(this->success); + xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); + xfer += oprot->writeString(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.ire) { xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1); @@ -16206,7 +16092,7 @@ uint32_t Airavata_changeDataMovementPriority_result::write(::apache::thrift::pro return xfer; } -uint32_t Airavata_changeDataMovementPriority_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_addSCPDataMovementDetails_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -16227,8 +16113,8 @@ uint32_t Airavata_changeDataMovementPriority_presult::read(::apache::thrift::pro switch (fid) { case 0: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool((*(this->success))); + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); @@ -16270,7 +16156,7 @@ uint32_t Airavata_changeDataMovementPriority_presult::read(::apache::thrift::pro return xfer; } -uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t Airavata_updateSCPDataMovementDetails_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -16281,7 +16167,8 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro using ::apache::thrift::protocol::TProtocolException; - bool isset_jobSubmissionPriorityMap = false; + bool isset_jobSubmissionInterfaceId = false; + bool isset_scpDataMovement = false; while (true) { @@ -16292,24 +16179,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro switch (fid) { case 1: - if (ftype == ::apache::thrift::protocol::T_MAP) { - { - this->jobSubmissionPriorityMap.clear(); - uint32_t _size248; - ::apache::thrift::protocol::TType _ktype249; - ::apache::thrift::protocol::TType _vtype250; - xfer += iprot->readMapBegin(_ktype249, _vtype250, _size248); - uint32_t _i252; - for (_i252 = 0; _i252 < _size248; ++_i252) - { - std::string _key253; - xfer += iprot->readString(_key253); - int32_t& _val254 = this->jobSubmissionPriorityMap[_key253]; - xfer += iprot->readI32(_val254); - } - xfer += iprot->readMapEnd(); - } - isset_jobSubmissionPriorityMap = true; + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->jobSubmissionInterfaceId); + isset_jobSubmissionInterfaceId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->scpDataMovement.read(iprot); + isset_scpDataMovement = true; } else { xfer += iprot->skip(ftype); } @@ -16323,26 +16203,23 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro xfer += iprot->readStructEnd(); - if (!isset_jobSubmissionPriorityMap) + if (!isset_jobSubmissionInterfaceId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_scpDataMovement) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t Airavata_changeJobSubmissionPriorities_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t Airavata_updateSCPDataMovementDetails_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("Airavata_changeJobSubmissionPriorities_args"); + xfer += oprot->writeStructBegin("Airavata_updateSCPDataMovementDetails_args"); - xfer += oprot->writeFieldBegin("jobSubmissionPriorityMap", ::apache::thrift::protocol::T_MAP, 1); - { - xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->jobSubmissionPriorityMap.size())); - std::map<std::string, int32_t> ::const_iterator _iter255; - for (_iter255 = this->jobSubmissionPriorityMap.begin(); _iter255 != this->jobSubmissionPriorityMap.end(); ++_iter255) - { - xfer += oprot->writeString(_iter255->first); - xfer += oprot->writeI32(_iter255->second); - } - xfer += oprot->writeMapEnd(); - } + xfer += oprot->writeFieldBegin("jobSubmissionInterfaceId", ::apache::thrift::protocol::T_STRING, 1); + xfer += oprot->writeString(this->jobSubmissionInterfaceId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("scpDataMovement", ::apache::thrift::protocol::T_STRUCT, 2); + xfer += this->scpDataMovement.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -16350,29 +16227,2
<TRUNCATED>
