You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/03/22 21:46:27 UTC
[5/9] airavata git commit: adding replica catalog related API methods
http://git-wip-us.apache.org/repos/asf/airavata/blob/6c5645d3/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
index 7756b6c..650bcac 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.cpp
@@ -622,14 +622,15 @@ void LOCALSubmission::__set_jobSubmissionInterfaceId(const std::string& val) {
this->jobSubmissionInterfaceId = val;
}
-void LOCALSubmission::__set_securityProtocol(const ::apache::airavata::model::data::movement::SecurityProtocol::type val) {
- this->securityProtocol = val;
-}
-
void LOCALSubmission::__set_resourceJobManager(const ResourceJobManager& val) {
this->resourceJobManager = val;
}
+void LOCALSubmission::__set_securityProtocol(const ::apache::airavata::model::data::movement::SecurityProtocol::type val) {
+ this->securityProtocol = val;
+__isset.securityProtocol = true;
+}
+
uint32_t LOCALSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
@@ -643,7 +644,6 @@ uint32_t LOCALSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
using ::apache::thrift::protocol::TProtocolException;
bool isset_jobSubmissionInterfaceId = false;
- bool isset_securityProtocol = false;
bool isset_resourceJobManager = false;
while (true)
@@ -663,19 +663,19 @@ uint32_t LOCALSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
}
break;
case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast23;
- xfer += iprot->readI32(ecast23);
- this->securityProtocol = ( ::apache::airavata::model::data::movement::SecurityProtocol::type)ecast23;
- isset_securityProtocol = true;
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->resourceJobManager.read(iprot);
+ isset_resourceJobManager = true;
} else {
xfer += iprot->skip(ftype);
}
break;
case 3:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->resourceJobManager.read(iprot);
- isset_resourceJobManager = true;
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast23;
+ xfer += iprot->readI32(ecast23);
+ this->securityProtocol = ( ::apache::airavata::model::data::movement::SecurityProtocol::type)ecast23;
+ this->__isset.securityProtocol = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -691,8 +691,6 @@ uint32_t LOCALSubmission::read(::apache::thrift::protocol::TProtocol* iprot) {
if (!isset_jobSubmissionInterfaceId)
throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_securityProtocol)
- throw TProtocolException(TProtocolException::INVALID_DATA);
if (!isset_resourceJobManager)
throw TProtocolException(TProtocolException::INVALID_DATA);
return xfer;
@@ -707,14 +705,15 @@ uint32_t LOCALSubmission::write(::apache::thrift::protocol::TProtocol* oprot) co
xfer += oprot->writeString(this->jobSubmissionInterfaceId);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->securityProtocol);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += oprot->writeFieldBegin("resourceJobManager", ::apache::thrift::protocol::T_STRUCT, 2);
xfer += this->resourceJobManager.write(oprot);
xfer += oprot->writeFieldEnd();
+ if (this->__isset.securityProtocol) {
+ xfer += oprot->writeFieldBegin("securityProtocol", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32((int32_t)this->securityProtocol);
+ xfer += oprot->writeFieldEnd();
+ }
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
@@ -723,27 +722,30 @@ uint32_t LOCALSubmission::write(::apache::thrift::protocol::TProtocol* oprot) co
void swap(LOCALSubmission &a, LOCALSubmission &b) {
using ::std::swap;
swap(a.jobSubmissionInterfaceId, b.jobSubmissionInterfaceId);
- swap(a.securityProtocol, b.securityProtocol);
swap(a.resourceJobManager, b.resourceJobManager);
+ swap(a.securityProtocol, b.securityProtocol);
+ swap(a.__isset, b.__isset);
}
LOCALSubmission::LOCALSubmission(const LOCALSubmission& other24) {
jobSubmissionInterfaceId = other24.jobSubmissionInterfaceId;
- securityProtocol = other24.securityProtocol;
resourceJobManager = other24.resourceJobManager;
+ securityProtocol = other24.securityProtocol;
+ __isset = other24.__isset;
}
LOCALSubmission& LOCALSubmission::operator=(const LOCALSubmission& other25) {
jobSubmissionInterfaceId = other25.jobSubmissionInterfaceId;
- securityProtocol = other25.securityProtocol;
resourceJobManager = other25.resourceJobManager;
+ securityProtocol = other25.securityProtocol;
+ __isset = other25.__isset;
return *this;
}
void LOCALSubmission::printTo(std::ostream& out) const {
using ::apache::thrift::to_string;
out << "LOCALSubmission(";
out << "jobSubmissionInterfaceId=" << to_string(jobSubmissionInterfaceId);
- out << ", " << "securityProtocol=" << to_string(securityProtocol);
out << ", " << "resourceJobManager=" << to_string(resourceJobManager);
+ out << ", " << "securityProtocol="; (__isset.securityProtocol ? (out << to_string(securityProtocol)) : (out << "<null>"));
out << ")";
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/6c5645d3/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.h
index ff02515..f18dcd6 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/compute_resource_model_types.h
@@ -314,6 +314,10 @@ inline std::ostream& operator<<(std::ostream& out, const BatchQueue& obj)
return out;
}
+typedef struct _LOCALSubmission__isset {
+ _LOCALSubmission__isset() : securityProtocol(false) {}
+ bool securityProtocol :1;
+} _LOCALSubmission__isset;
class LOCALSubmission {
public:
@@ -325,23 +329,27 @@ class LOCALSubmission {
virtual ~LOCALSubmission() throw();
std::string jobSubmissionInterfaceId;
- ::apache::airavata::model::data::movement::SecurityProtocol::type securityProtocol;
ResourceJobManager resourceJobManager;
+ ::apache::airavata::model::data::movement::SecurityProtocol::type securityProtocol;
- void __set_jobSubmissionInterfaceId(const std::string& val);
+ _LOCALSubmission__isset __isset;
- void __set_securityProtocol(const ::apache::airavata::model::data::movement::SecurityProtocol::type val);
+ void __set_jobSubmissionInterfaceId(const std::string& val);
void __set_resourceJobManager(const ResourceJobManager& val);
+ void __set_securityProtocol(const ::apache::airavata::model::data::movement::SecurityProtocol::type val);
+
bool operator == (const LOCALSubmission & rhs) const
{
if (!(jobSubmissionInterfaceId == rhs.jobSubmissionInterfaceId))
return false;
- if (!(securityProtocol == rhs.securityProtocol))
- return false;
if (!(resourceJobManager == rhs.resourceJobManager))
return false;
+ if (__isset.securityProtocol != rhs.__isset.securityProtocol)
+ return false;
+ else if (__isset.securityProtocol && !(securityProtocol == rhs.securityProtocol))
+ return false;
return true;
}
bool operator != (const LOCALSubmission &rhs) const {