You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2015/07/21 06:41:50 UTC
[07/44] airavata git commit: changing few API methods to adhere to
security solution.
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_constants.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_constants.h
new file mode 100644
index 0000000..d677912
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_constants.h
@@ -0,0 +1,41 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef process_model_CONSTANTS_H
+#define process_model_CONSTANTS_H
+
+#include "process_model_types.h"
+
+namespace apache { namespace airavata { namespace model { namespace process {
+
+class process_modelConstants {
+ public:
+ process_modelConstants();
+
+};
+
+extern const process_modelConstants g_process_model_constants;
+
+}}}} // namespace
+
+#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.cpp
new file mode 100644
index 0000000..9e0c3f9
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.cpp
@@ -0,0 +1,581 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "process_model_types.h"
+
+#include <algorithm>
+#include <ostream>
+
+#include <thrift/TToString.h>
+
+namespace apache { namespace airavata { namespace model { namespace process {
+
+
+ProcessModel::~ProcessModel() throw() {
+}
+
+
+void ProcessModel::__set_processId(const std::string& val) {
+ this->processId = val;
+}
+
+void ProcessModel::__set_experimentId(const std::string& val) {
+ this->experimentId = val;
+}
+
+void ProcessModel::__set_creationTime(const int64_t val) {
+ this->creationTime = val;
+__isset.creationTime = true;
+}
+
+void ProcessModel::__set_lastUpdateTime(const int64_t val) {
+ this->lastUpdateTime = val;
+__isset.lastUpdateTime = true;
+}
+
+void ProcessModel::__set_processStatus(const ::apache::airavata::model::status::ProcessStatus& val) {
+ this->processStatus = val;
+__isset.processStatus = true;
+}
+
+void ProcessModel::__set_processDetail(const std::string& val) {
+ this->processDetail = val;
+__isset.processDetail = true;
+}
+
+void ProcessModel::__set_applicationInterfaceId(const std::string& val) {
+ this->applicationInterfaceId = val;
+__isset.applicationInterfaceId = true;
+}
+
+void ProcessModel::__set_applicationDeploymentId(const std::string& val) {
+ this->applicationDeploymentId = val;
+__isset.applicationDeploymentId = true;
+}
+
+void ProcessModel::__set_computeResourceId(const std::string& val) {
+ this->computeResourceId = val;
+__isset.computeResourceId = true;
+}
+
+void ProcessModel::__set_processInputs(const std::vector< ::apache::airavata::model::application::io::InputDataObjectType> & val) {
+ this->processInputs = val;
+__isset.processInputs = true;
+}
+
+void ProcessModel::__set_processOutputs(const std::vector< ::apache::airavata::model::application::io::OutputDataObjectType> & val) {
+ this->processOutputs = val;
+__isset.processOutputs = true;
+}
+
+void ProcessModel::__set_resourceSchedule(const ::apache::airavata::model::scheduling::ComputationalResourceSchedulingModel& val) {
+ this->resourceSchedule = val;
+__isset.resourceSchedule = true;
+}
+
+void ProcessModel::__set_tasks(const std::vector< ::apache::airavata::model::task::TaskModel> & val) {
+ this->tasks = val;
+__isset.tasks = true;
+}
+
+void ProcessModel::__set_taskDag(const std::string& val) {
+ this->taskDag = val;
+__isset.taskDag = true;
+}
+
+void ProcessModel::__set_processError(const ::apache::airavata::model::commons::ErrorModel& val) {
+ this->processError = val;
+__isset.processError = true;
+}
+
+void ProcessModel::__set_gatewayExecutionId(const std::string& val) {
+ this->gatewayExecutionId = val;
+__isset.gatewayExecutionId = true;
+}
+
+void ProcessModel::__set_enableEmailNotification(const bool val) {
+ this->enableEmailNotification = val;
+__isset.enableEmailNotification = true;
+}
+
+void ProcessModel::__set_emailAddresses(const std::vector<std::string> & val) {
+ this->emailAddresses = val;
+__isset.emailAddresses = true;
+}
+
+const char* ProcessModel::ascii_fingerprint = "784A051111BD540B35328CD018BE3F62";
+const uint8_t ProcessModel::binary_fingerprint[16] = {0x78,0x4A,0x05,0x11,0x11,0xBD,0x54,0x0B,0x35,0x32,0x8C,0xD0,0x18,0xBE,0x3F,0x62};
+
+uint32_t ProcessModel::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_processId = false;
+ bool isset_experimentId = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->processId);
+ isset_processId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->experimentId);
+ isset_experimentId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->creationTime);
+ this->__isset.creationTime = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->lastUpdateTime);
+ this->__isset.lastUpdateTime = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 5:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->processStatus.read(iprot);
+ this->__isset.processStatus = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 6:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->processDetail);
+ this->__isset.processDetail = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 7:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->applicationInterfaceId);
+ this->__isset.applicationInterfaceId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 8:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->applicationDeploymentId);
+ this->__isset.applicationDeploymentId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 9:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->computeResourceId);
+ this->__isset.computeResourceId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 10:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->processInputs.clear();
+ uint32_t _size0;
+ ::apache::thrift::protocol::TType _etype3;
+ xfer += iprot->readListBegin(_etype3, _size0);
+ this->processInputs.resize(_size0);
+ uint32_t _i4;
+ for (_i4 = 0; _i4 < _size0; ++_i4)
+ {
+ xfer += this->processInputs[_i4].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.processInputs = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 11:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->processOutputs.clear();
+ uint32_t _size5;
+ ::apache::thrift::protocol::TType _etype8;
+ xfer += iprot->readListBegin(_etype8, _size5);
+ this->processOutputs.resize(_size5);
+ uint32_t _i9;
+ for (_i9 = 0; _i9 < _size5; ++_i9)
+ {
+ xfer += this->processOutputs[_i9].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.processOutputs = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 12:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->resourceSchedule.read(iprot);
+ this->__isset.resourceSchedule = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 13:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->tasks.clear();
+ uint32_t _size10;
+ ::apache::thrift::protocol::TType _etype13;
+ xfer += iprot->readListBegin(_etype13, _size10);
+ this->tasks.resize(_size10);
+ uint32_t _i14;
+ for (_i14 = 0; _i14 < _size10; ++_i14)
+ {
+ xfer += this->tasks[_i14].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.tasks = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 14:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->taskDag);
+ this->__isset.taskDag = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 15:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->processError.read(iprot);
+ this->__isset.processError = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 16:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->gatewayExecutionId);
+ this->__isset.gatewayExecutionId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 17:
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->enableEmailNotification);
+ this->__isset.enableEmailNotification = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 18:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->emailAddresses.clear();
+ uint32_t _size15;
+ ::apache::thrift::protocol::TType _etype18;
+ xfer += iprot->readListBegin(_etype18, _size15);
+ this->emailAddresses.resize(_size15);
+ uint32_t _i19;
+ for (_i19 = 0; _i19 < _size15; ++_i19)
+ {
+ xfer += iprot->readString(this->emailAddresses[_i19]);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.emailAddresses = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_processId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_experimentId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t ProcessModel::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ oprot->incrementRecursionDepth();
+ xfer += oprot->writeStructBegin("ProcessModel");
+
+ xfer += oprot->writeFieldBegin("processId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->processId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("experimentId", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->experimentId);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.creationTime) {
+ xfer += oprot->writeFieldBegin("creationTime", ::apache::thrift::protocol::T_I64, 3);
+ xfer += oprot->writeI64(this->creationTime);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.lastUpdateTime) {
+ xfer += oprot->writeFieldBegin("lastUpdateTime", ::apache::thrift::protocol::T_I64, 4);
+ xfer += oprot->writeI64(this->lastUpdateTime);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.processStatus) {
+ xfer += oprot->writeFieldBegin("processStatus", ::apache::thrift::protocol::T_STRUCT, 5);
+ xfer += this->processStatus.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.processDetail) {
+ xfer += oprot->writeFieldBegin("processDetail", ::apache::thrift::protocol::T_STRING, 6);
+ xfer += oprot->writeString(this->processDetail);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.applicationInterfaceId) {
+ xfer += oprot->writeFieldBegin("applicationInterfaceId", ::apache::thrift::protocol::T_STRING, 7);
+ xfer += oprot->writeString(this->applicationInterfaceId);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.applicationDeploymentId) {
+ xfer += oprot->writeFieldBegin("applicationDeploymentId", ::apache::thrift::protocol::T_STRING, 8);
+ xfer += oprot->writeString(this->applicationDeploymentId);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.computeResourceId) {
+ xfer += oprot->writeFieldBegin("computeResourceId", ::apache::thrift::protocol::T_STRING, 9);
+ xfer += oprot->writeString(this->computeResourceId);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.processInputs) {
+ xfer += oprot->writeFieldBegin("processInputs", ::apache::thrift::protocol::T_LIST, 10);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->processInputs.size()));
+ std::vector< ::apache::airavata::model::application::io::InputDataObjectType> ::const_iterator _iter20;
+ for (_iter20 = this->processInputs.begin(); _iter20 != this->processInputs.end(); ++_iter20)
+ {
+ xfer += (*_iter20).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.processOutputs) {
+ xfer += oprot->writeFieldBegin("processOutputs", ::apache::thrift::protocol::T_LIST, 11);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->processOutputs.size()));
+ std::vector< ::apache::airavata::model::application::io::OutputDataObjectType> ::const_iterator _iter21;
+ for (_iter21 = this->processOutputs.begin(); _iter21 != this->processOutputs.end(); ++_iter21)
+ {
+ xfer += (*_iter21).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.resourceSchedule) {
+ xfer += oprot->writeFieldBegin("resourceSchedule", ::apache::thrift::protocol::T_STRUCT, 12);
+ xfer += this->resourceSchedule.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.tasks) {
+ xfer += oprot->writeFieldBegin("tasks", ::apache::thrift::protocol::T_LIST, 13);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->tasks.size()));
+ std::vector< ::apache::airavata::model::task::TaskModel> ::const_iterator _iter22;
+ for (_iter22 = this->tasks.begin(); _iter22 != this->tasks.end(); ++_iter22)
+ {
+ xfer += (*_iter22).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.taskDag) {
+ xfer += oprot->writeFieldBegin("taskDag", ::apache::thrift::protocol::T_STRING, 14);
+ xfer += oprot->writeString(this->taskDag);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.processError) {
+ xfer += oprot->writeFieldBegin("processError", ::apache::thrift::protocol::T_STRUCT, 15);
+ xfer += this->processError.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.gatewayExecutionId) {
+ xfer += oprot->writeFieldBegin("gatewayExecutionId", ::apache::thrift::protocol::T_STRING, 16);
+ xfer += oprot->writeString(this->gatewayExecutionId);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.enableEmailNotification) {
+ xfer += oprot->writeFieldBegin("enableEmailNotification", ::apache::thrift::protocol::T_BOOL, 17);
+ xfer += oprot->writeBool(this->enableEmailNotification);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.emailAddresses) {
+ xfer += oprot->writeFieldBegin("emailAddresses", ::apache::thrift::protocol::T_LIST, 18);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->emailAddresses.size()));
+ std::vector<std::string> ::const_iterator _iter23;
+ for (_iter23 = this->emailAddresses.begin(); _iter23 != this->emailAddresses.end(); ++_iter23)
+ {
+ xfer += oprot->writeString((*_iter23));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
+ return xfer;
+}
+
+void swap(ProcessModel &a, ProcessModel &b) {
+ using ::std::swap;
+ swap(a.processId, b.processId);
+ swap(a.experimentId, b.experimentId);
+ swap(a.creationTime, b.creationTime);
+ swap(a.lastUpdateTime, b.lastUpdateTime);
+ swap(a.processStatus, b.processStatus);
+ swap(a.processDetail, b.processDetail);
+ swap(a.applicationInterfaceId, b.applicationInterfaceId);
+ swap(a.applicationDeploymentId, b.applicationDeploymentId);
+ swap(a.computeResourceId, b.computeResourceId);
+ swap(a.processInputs, b.processInputs);
+ swap(a.processOutputs, b.processOutputs);
+ swap(a.resourceSchedule, b.resourceSchedule);
+ swap(a.tasks, b.tasks);
+ swap(a.taskDag, b.taskDag);
+ swap(a.processError, b.processError);
+ swap(a.gatewayExecutionId, b.gatewayExecutionId);
+ swap(a.enableEmailNotification, b.enableEmailNotification);
+ swap(a.emailAddresses, b.emailAddresses);
+ swap(a.__isset, b.__isset);
+}
+
+ProcessModel::ProcessModel(const ProcessModel& other24) {
+ processId = other24.processId;
+ experimentId = other24.experimentId;
+ creationTime = other24.creationTime;
+ lastUpdateTime = other24.lastUpdateTime;
+ processStatus = other24.processStatus;
+ processDetail = other24.processDetail;
+ applicationInterfaceId = other24.applicationInterfaceId;
+ applicationDeploymentId = other24.applicationDeploymentId;
+ computeResourceId = other24.computeResourceId;
+ processInputs = other24.processInputs;
+ processOutputs = other24.processOutputs;
+ resourceSchedule = other24.resourceSchedule;
+ tasks = other24.tasks;
+ taskDag = other24.taskDag;
+ processError = other24.processError;
+ gatewayExecutionId = other24.gatewayExecutionId;
+ enableEmailNotification = other24.enableEmailNotification;
+ emailAddresses = other24.emailAddresses;
+ __isset = other24.__isset;
+}
+ProcessModel& ProcessModel::operator=(const ProcessModel& other25) {
+ processId = other25.processId;
+ experimentId = other25.experimentId;
+ creationTime = other25.creationTime;
+ lastUpdateTime = other25.lastUpdateTime;
+ processStatus = other25.processStatus;
+ processDetail = other25.processDetail;
+ applicationInterfaceId = other25.applicationInterfaceId;
+ applicationDeploymentId = other25.applicationDeploymentId;
+ computeResourceId = other25.computeResourceId;
+ processInputs = other25.processInputs;
+ processOutputs = other25.processOutputs;
+ resourceSchedule = other25.resourceSchedule;
+ tasks = other25.tasks;
+ taskDag = other25.taskDag;
+ processError = other25.processError;
+ gatewayExecutionId = other25.gatewayExecutionId;
+ enableEmailNotification = other25.enableEmailNotification;
+ emailAddresses = other25.emailAddresses;
+ __isset = other25.__isset;
+ return *this;
+}
+std::ostream& operator<<(std::ostream& out, const ProcessModel& obj) {
+ using apache::thrift::to_string;
+ out << "ProcessModel(";
+ out << "processId=" << to_string(obj.processId);
+ out << ", " << "experimentId=" << to_string(obj.experimentId);
+ out << ", " << "creationTime="; (obj.__isset.creationTime ? (out << to_string(obj.creationTime)) : (out << "<null>"));
+ out << ", " << "lastUpdateTime="; (obj.__isset.lastUpdateTime ? (out << to_string(obj.lastUpdateTime)) : (out << "<null>"));
+ out << ", " << "processStatus="; (obj.__isset.processStatus ? (out << to_string(obj.processStatus)) : (out << "<null>"));
+ out << ", " << "processDetail="; (obj.__isset.processDetail ? (out << to_string(obj.processDetail)) : (out << "<null>"));
+ out << ", " << "applicationInterfaceId="; (obj.__isset.applicationInterfaceId ? (out << to_string(obj.applicationInterfaceId)) : (out << "<null>"));
+ out << ", " << "applicationDeploymentId="; (obj.__isset.applicationDeploymentId ? (out << to_string(obj.applicationDeploymentId)) : (out << "<null>"));
+ out << ", " << "computeResourceId="; (obj.__isset.computeResourceId ? (out << to_string(obj.computeResourceId)) : (out << "<null>"));
+ out << ", " << "processInputs="; (obj.__isset.processInputs ? (out << to_string(obj.processInputs)) : (out << "<null>"));
+ out << ", " << "processOutputs="; (obj.__isset.processOutputs ? (out << to_string(obj.processOutputs)) : (out << "<null>"));
+ out << ", " << "resourceSchedule="; (obj.__isset.resourceSchedule ? (out << to_string(obj.resourceSchedule)) : (out << "<null>"));
+ out << ", " << "tasks="; (obj.__isset.tasks ? (out << to_string(obj.tasks)) : (out << "<null>"));
+ out << ", " << "taskDag="; (obj.__isset.taskDag ? (out << to_string(obj.taskDag)) : (out << "<null>"));
+ out << ", " << "processError="; (obj.__isset.processError ? (out << to_string(obj.processError)) : (out << "<null>"));
+ out << ", " << "gatewayExecutionId="; (obj.__isset.gatewayExecutionId ? (out << to_string(obj.gatewayExecutionId)) : (out << "<null>"));
+ out << ", " << "enableEmailNotification="; (obj.__isset.enableEmailNotification ? (out << to_string(obj.enableEmailNotification)) : (out << "<null>"));
+ out << ", " << "emailAddresses="; (obj.__isset.emailAddresses ? (out << to_string(obj.emailAddresses)) : (out << "<null>"));
+ out << ")";
+ return out;
+}
+
+}}}} // namespace
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.h
new file mode 100644
index 0000000..b65d3e3
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/process_model_types.h
@@ -0,0 +1,223 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef process_model_TYPES_H
+#define process_model_TYPES_H
+
+#include <iosfwd>
+
+#include <thrift/Thrift.h>
+#include <thrift/TApplicationException.h>
+#include <thrift/protocol/TProtocol.h>
+#include <thrift/transport/TTransport.h>
+
+#include <thrift/cxxfunctional.h>
+#include "airavata_commons_types.h"
+#include "status_models_types.h"
+#include "task_model_types.h"
+#include "application_io_models_types.h"
+#include "scheduling_model_types.h"
+
+
+namespace apache { namespace airavata { namespace model { namespace process {
+
+class ProcessModel;
+
+typedef struct _ProcessModel__isset {
+ _ProcessModel__isset() : creationTime(false), lastUpdateTime(false), processStatus(false), processDetail(false), applicationInterfaceId(false), applicationDeploymentId(false), computeResourceId(false), processInputs(false), processOutputs(false), resourceSchedule(false), tasks(false), taskDag(false), processError(false), gatewayExecutionId(false), enableEmailNotification(false), emailAddresses(false) {}
+ bool creationTime :1;
+ bool lastUpdateTime :1;
+ bool processStatus :1;
+ bool processDetail :1;
+ bool applicationInterfaceId :1;
+ bool applicationDeploymentId :1;
+ bool computeResourceId :1;
+ bool processInputs :1;
+ bool processOutputs :1;
+ bool resourceSchedule :1;
+ bool tasks :1;
+ bool taskDag :1;
+ bool processError :1;
+ bool gatewayExecutionId :1;
+ bool enableEmailNotification :1;
+ bool emailAddresses :1;
+} _ProcessModel__isset;
+
+class ProcessModel {
+ public:
+
+ static const char* ascii_fingerprint; // = "784A051111BD540B35328CD018BE3F62";
+ static const uint8_t binary_fingerprint[16]; // = {0x78,0x4A,0x05,0x11,0x11,0xBD,0x54,0x0B,0x35,0x32,0x8C,0xD0,0x18,0xBE,0x3F,0x62};
+
+ ProcessModel(const ProcessModel&);
+ ProcessModel& operator=(const ProcessModel&);
+ ProcessModel() : processId("DO_NOT_SET_AT_CLIENTS"), experimentId(), creationTime(0), lastUpdateTime(0), processDetail(), applicationInterfaceId(), applicationDeploymentId(), computeResourceId(), taskDag(), gatewayExecutionId(), enableEmailNotification(0) {
+ }
+
+ virtual ~ProcessModel() throw();
+ std::string processId;
+ std::string experimentId;
+ int64_t creationTime;
+ int64_t lastUpdateTime;
+ ::apache::airavata::model::status::ProcessStatus processStatus;
+ std::string processDetail;
+ std::string applicationInterfaceId;
+ std::string applicationDeploymentId;
+ std::string computeResourceId;
+ std::vector< ::apache::airavata::model::application::io::InputDataObjectType> processInputs;
+ std::vector< ::apache::airavata::model::application::io::OutputDataObjectType> processOutputs;
+ ::apache::airavata::model::scheduling::ComputationalResourceSchedulingModel resourceSchedule;
+ std::vector< ::apache::airavata::model::task::TaskModel> tasks;
+ std::string taskDag;
+ ::apache::airavata::model::commons::ErrorModel processError;
+ std::string gatewayExecutionId;
+ bool enableEmailNotification;
+ std::vector<std::string> emailAddresses;
+
+ _ProcessModel__isset __isset;
+
+ void __set_processId(const std::string& val);
+
+ void __set_experimentId(const std::string& val);
+
+ void __set_creationTime(const int64_t val);
+
+ void __set_lastUpdateTime(const int64_t val);
+
+ void __set_processStatus(const ::apache::airavata::model::status::ProcessStatus& val);
+
+ void __set_processDetail(const std::string& val);
+
+ void __set_applicationInterfaceId(const std::string& val);
+
+ void __set_applicationDeploymentId(const std::string& val);
+
+ void __set_computeResourceId(const std::string& val);
+
+ void __set_processInputs(const std::vector< ::apache::airavata::model::application::io::InputDataObjectType> & val);
+
+ void __set_processOutputs(const std::vector< ::apache::airavata::model::application::io::OutputDataObjectType> & val);
+
+ void __set_resourceSchedule(const ::apache::airavata::model::scheduling::ComputationalResourceSchedulingModel& val);
+
+ void __set_tasks(const std::vector< ::apache::airavata::model::task::TaskModel> & val);
+
+ void __set_taskDag(const std::string& val);
+
+ void __set_processError(const ::apache::airavata::model::commons::ErrorModel& val);
+
+ void __set_gatewayExecutionId(const std::string& val);
+
+ void __set_enableEmailNotification(const bool val);
+
+ void __set_emailAddresses(const std::vector<std::string> & val);
+
+ bool operator == (const ProcessModel & rhs) const
+ {
+ if (!(processId == rhs.processId))
+ return false;
+ if (!(experimentId == rhs.experimentId))
+ return false;
+ if (__isset.creationTime != rhs.__isset.creationTime)
+ return false;
+ else if (__isset.creationTime && !(creationTime == rhs.creationTime))
+ return false;
+ if (__isset.lastUpdateTime != rhs.__isset.lastUpdateTime)
+ return false;
+ else if (__isset.lastUpdateTime && !(lastUpdateTime == rhs.lastUpdateTime))
+ return false;
+ if (__isset.processStatus != rhs.__isset.processStatus)
+ return false;
+ else if (__isset.processStatus && !(processStatus == rhs.processStatus))
+ return false;
+ if (__isset.processDetail != rhs.__isset.processDetail)
+ return false;
+ else if (__isset.processDetail && !(processDetail == rhs.processDetail))
+ return false;
+ if (__isset.applicationInterfaceId != rhs.__isset.applicationInterfaceId)
+ return false;
+ else if (__isset.applicationInterfaceId && !(applicationInterfaceId == rhs.applicationInterfaceId))
+ return false;
+ if (__isset.applicationDeploymentId != rhs.__isset.applicationDeploymentId)
+ return false;
+ else if (__isset.applicationDeploymentId && !(applicationDeploymentId == rhs.applicationDeploymentId))
+ return false;
+ if (__isset.computeResourceId != rhs.__isset.computeResourceId)
+ return false;
+ else if (__isset.computeResourceId && !(computeResourceId == rhs.computeResourceId))
+ return false;
+ if (__isset.processInputs != rhs.__isset.processInputs)
+ return false;
+ else if (__isset.processInputs && !(processInputs == rhs.processInputs))
+ return false;
+ if (__isset.processOutputs != rhs.__isset.processOutputs)
+ return false;
+ else if (__isset.processOutputs && !(processOutputs == rhs.processOutputs))
+ return false;
+ if (__isset.resourceSchedule != rhs.__isset.resourceSchedule)
+ return false;
+ else if (__isset.resourceSchedule && !(resourceSchedule == rhs.resourceSchedule))
+ return false;
+ if (__isset.tasks != rhs.__isset.tasks)
+ return false;
+ else if (__isset.tasks && !(tasks == rhs.tasks))
+ return false;
+ if (__isset.taskDag != rhs.__isset.taskDag)
+ return false;
+ else if (__isset.taskDag && !(taskDag == rhs.taskDag))
+ return false;
+ if (__isset.processError != rhs.__isset.processError)
+ return false;
+ else if (__isset.processError && !(processError == rhs.processError))
+ return false;
+ if (__isset.gatewayExecutionId != rhs.__isset.gatewayExecutionId)
+ return false;
+ else if (__isset.gatewayExecutionId && !(gatewayExecutionId == rhs.gatewayExecutionId))
+ return false;
+ if (__isset.enableEmailNotification != rhs.__isset.enableEmailNotification)
+ return false;
+ else if (__isset.enableEmailNotification && !(enableEmailNotification == rhs.enableEmailNotification))
+ return false;
+ if (__isset.emailAddresses != rhs.__isset.emailAddresses)
+ return false;
+ else if (__isset.emailAddresses && !(emailAddresses == rhs.emailAddresses))
+ return false;
+ return true;
+ }
+ bool operator != (const ProcessModel &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ProcessModel & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ friend std::ostream& operator<<(std::ostream& out, const ProcessModel& obj);
+};
+
+void swap(ProcessModel &a, ProcessModel &b);
+
+}}}} // namespace
+
+#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.cpp
new file mode 100644
index 0000000..7096472
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.cpp
@@ -0,0 +1,34 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "scheduling_model_constants.h"
+
+namespace apache { namespace airavata { namespace model { namespace scheduling {
+
+const scheduling_modelConstants g_scheduling_model_constants;
+
+scheduling_modelConstants::scheduling_modelConstants() {
+}
+
+}}}} // namespace
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.h
new file mode 100644
index 0000000..e18c937
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_constants.h
@@ -0,0 +1,41 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef scheduling_model_CONSTANTS_H
+#define scheduling_model_CONSTANTS_H
+
+#include "scheduling_model_types.h"
+
+namespace apache { namespace airavata { namespace model { namespace scheduling {
+
+class scheduling_modelConstants {
+ public:
+ scheduling_modelConstants();
+
+};
+
+extern const scheduling_modelConstants g_scheduling_model_constants;
+
+}}}} // namespace
+
+#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp
new file mode 100644
index 0000000..0c5741d
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.cpp
@@ -0,0 +1,279 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "scheduling_model_types.h"
+
+#include <algorithm>
+#include <ostream>
+
+#include <thrift/TToString.h>
+
+namespace apache { namespace airavata { namespace model { namespace scheduling {
+
+
+ComputationalResourceSchedulingModel::~ComputationalResourceSchedulingModel() throw() {
+}
+
+
+void ComputationalResourceSchedulingModel::__set_resourceHostId(const std::string& val) {
+ this->resourceHostId = val;
+__isset.resourceHostId = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_totalCPUCount(const int32_t val) {
+ this->totalCPUCount = val;
+__isset.totalCPUCount = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_nodeCount(const int32_t val) {
+ this->nodeCount = val;
+__isset.nodeCount = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_numberOfThreads(const int32_t val) {
+ this->numberOfThreads = val;
+__isset.numberOfThreads = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_queueName(const std::string& val) {
+ this->queueName = val;
+__isset.queueName = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_wallTimeLimit(const int32_t val) {
+ this->wallTimeLimit = val;
+__isset.wallTimeLimit = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_totalPhysicalMemory(const int32_t val) {
+ this->totalPhysicalMemory = val;
+__isset.totalPhysicalMemory = true;
+}
+
+void ComputationalResourceSchedulingModel::__set_chessisNumber(const std::string& val) {
+ this->chessisNumber = val;
+__isset.chessisNumber = true;
+}
+
+const char* ComputationalResourceSchedulingModel::ascii_fingerprint = "40EF337C72E03F608878AED1911454B0";
+const uint8_t ComputationalResourceSchedulingModel::binary_fingerprint[16] = {0x40,0xEF,0x33,0x7C,0x72,0xE0,0x3F,0x60,0x88,0x78,0xAE,0xD1,0x91,0x14,0x54,0xB0};
+
+uint32_t ComputationalResourceSchedulingModel::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->resourceHostId);
+ this->__isset.resourceHostId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->totalCPUCount);
+ this->__isset.totalCPUCount = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->nodeCount);
+ this->__isset.nodeCount = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->numberOfThreads);
+ this->__isset.numberOfThreads = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 5:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->queueName);
+ this->__isset.queueName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 6:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->wallTimeLimit);
+ this->__isset.wallTimeLimit = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 7:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ xfer += iprot->readI32(this->totalPhysicalMemory);
+ this->__isset.totalPhysicalMemory = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 8:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->chessisNumber);
+ this->__isset.chessisNumber = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t ComputationalResourceSchedulingModel::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ oprot->incrementRecursionDepth();
+ xfer += oprot->writeStructBegin("ComputationalResourceSchedulingModel");
+
+ if (this->__isset.resourceHostId) {
+ xfer += oprot->writeFieldBegin("resourceHostId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->resourceHostId);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.totalCPUCount) {
+ xfer += oprot->writeFieldBegin("totalCPUCount", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32(this->totalCPUCount);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.nodeCount) {
+ xfer += oprot->writeFieldBegin("nodeCount", ::apache::thrift::protocol::T_I32, 3);
+ xfer += oprot->writeI32(this->nodeCount);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.numberOfThreads) {
+ xfer += oprot->writeFieldBegin("numberOfThreads", ::apache::thrift::protocol::T_I32, 4);
+ xfer += oprot->writeI32(this->numberOfThreads);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.queueName) {
+ xfer += oprot->writeFieldBegin("queueName", ::apache::thrift::protocol::T_STRING, 5);
+ xfer += oprot->writeString(this->queueName);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.wallTimeLimit) {
+ xfer += oprot->writeFieldBegin("wallTimeLimit", ::apache::thrift::protocol::T_I32, 6);
+ xfer += oprot->writeI32(this->wallTimeLimit);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.totalPhysicalMemory) {
+ xfer += oprot->writeFieldBegin("totalPhysicalMemory", ::apache::thrift::protocol::T_I32, 7);
+ xfer += oprot->writeI32(this->totalPhysicalMemory);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.chessisNumber) {
+ xfer += oprot->writeFieldBegin("chessisNumber", ::apache::thrift::protocol::T_STRING, 8);
+ xfer += oprot->writeString(this->chessisNumber);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
+ return xfer;
+}
+
+void swap(ComputationalResourceSchedulingModel &a, ComputationalResourceSchedulingModel &b) {
+ using ::std::swap;
+ swap(a.resourceHostId, b.resourceHostId);
+ swap(a.totalCPUCount, b.totalCPUCount);
+ swap(a.nodeCount, b.nodeCount);
+ swap(a.numberOfThreads, b.numberOfThreads);
+ swap(a.queueName, b.queueName);
+ swap(a.wallTimeLimit, b.wallTimeLimit);
+ swap(a.totalPhysicalMemory, b.totalPhysicalMemory);
+ swap(a.chessisNumber, b.chessisNumber);
+ swap(a.__isset, b.__isset);
+}
+
+ComputationalResourceSchedulingModel::ComputationalResourceSchedulingModel(const ComputationalResourceSchedulingModel& other0) {
+ resourceHostId = other0.resourceHostId;
+ totalCPUCount = other0.totalCPUCount;
+ nodeCount = other0.nodeCount;
+ numberOfThreads = other0.numberOfThreads;
+ queueName = other0.queueName;
+ wallTimeLimit = other0.wallTimeLimit;
+ totalPhysicalMemory = other0.totalPhysicalMemory;
+ chessisNumber = other0.chessisNumber;
+ __isset = other0.__isset;
+}
+ComputationalResourceSchedulingModel& ComputationalResourceSchedulingModel::operator=(const ComputationalResourceSchedulingModel& other1) {
+ resourceHostId = other1.resourceHostId;
+ totalCPUCount = other1.totalCPUCount;
+ nodeCount = other1.nodeCount;
+ numberOfThreads = other1.numberOfThreads;
+ queueName = other1.queueName;
+ wallTimeLimit = other1.wallTimeLimit;
+ totalPhysicalMemory = other1.totalPhysicalMemory;
+ chessisNumber = other1.chessisNumber;
+ __isset = other1.__isset;
+ return *this;
+}
+std::ostream& operator<<(std::ostream& out, const ComputationalResourceSchedulingModel& obj) {
+ using apache::thrift::to_string;
+ out << "ComputationalResourceSchedulingModel(";
+ out << "resourceHostId="; (obj.__isset.resourceHostId ? (out << to_string(obj.resourceHostId)) : (out << "<null>"));
+ out << ", " << "totalCPUCount="; (obj.__isset.totalCPUCount ? (out << to_string(obj.totalCPUCount)) : (out << "<null>"));
+ out << ", " << "nodeCount="; (obj.__isset.nodeCount ? (out << to_string(obj.nodeCount)) : (out << "<null>"));
+ out << ", " << "numberOfThreads="; (obj.__isset.numberOfThreads ? (out << to_string(obj.numberOfThreads)) : (out << "<null>"));
+ out << ", " << "queueName="; (obj.__isset.queueName ? (out << to_string(obj.queueName)) : (out << "<null>"));
+ out << ", " << "wallTimeLimit="; (obj.__isset.wallTimeLimit ? (out << to_string(obj.wallTimeLimit)) : (out << "<null>"));
+ out << ", " << "totalPhysicalMemory="; (obj.__isset.totalPhysicalMemory ? (out << to_string(obj.totalPhysicalMemory)) : (out << "<null>"));
+ out << ", " << "chessisNumber="; (obj.__isset.chessisNumber ? (out << to_string(obj.chessisNumber)) : (out << "<null>"));
+ out << ")";
+ return out;
+}
+
+}}}} // namespace
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h
new file mode 100644
index 0000000..3312800
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/scheduling_model_types.h
@@ -0,0 +1,144 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef scheduling_model_TYPES_H
+#define scheduling_model_TYPES_H
+
+#include <iosfwd>
+
+#include <thrift/Thrift.h>
+#include <thrift/TApplicationException.h>
+#include <thrift/protocol/TProtocol.h>
+#include <thrift/transport/TTransport.h>
+
+#include <thrift/cxxfunctional.h>
+
+
+namespace apache { namespace airavata { namespace model { namespace scheduling {
+
+class ComputationalResourceSchedulingModel;
+
+typedef struct _ComputationalResourceSchedulingModel__isset {
+ _ComputationalResourceSchedulingModel__isset() : resourceHostId(false), totalCPUCount(false), nodeCount(false), numberOfThreads(false), queueName(false), wallTimeLimit(false), totalPhysicalMemory(false), chessisNumber(false) {}
+ bool resourceHostId :1;
+ bool totalCPUCount :1;
+ bool nodeCount :1;
+ bool numberOfThreads :1;
+ bool queueName :1;
+ bool wallTimeLimit :1;
+ bool totalPhysicalMemory :1;
+ bool chessisNumber :1;
+} _ComputationalResourceSchedulingModel__isset;
+
+class ComputationalResourceSchedulingModel {
+ public:
+
+ static const char* ascii_fingerprint; // = "40EF337C72E03F608878AED1911454B0";
+ static const uint8_t binary_fingerprint[16]; // = {0x40,0xEF,0x33,0x7C,0x72,0xE0,0x3F,0x60,0x88,0x78,0xAE,0xD1,0x91,0x14,0x54,0xB0};
+
+ ComputationalResourceSchedulingModel(const ComputationalResourceSchedulingModel&);
+ ComputationalResourceSchedulingModel& operator=(const ComputationalResourceSchedulingModel&);
+ ComputationalResourceSchedulingModel() : resourceHostId(), totalCPUCount(0), nodeCount(0), numberOfThreads(0), queueName(), wallTimeLimit(0), totalPhysicalMemory(0), chessisNumber() {
+ }
+
+ virtual ~ComputationalResourceSchedulingModel() throw();
+ std::string resourceHostId;
+ int32_t totalCPUCount;
+ int32_t nodeCount;
+ int32_t numberOfThreads;
+ std::string queueName;
+ int32_t wallTimeLimit;
+ int32_t totalPhysicalMemory;
+ std::string chessisNumber;
+
+ _ComputationalResourceSchedulingModel__isset __isset;
+
+ void __set_resourceHostId(const std::string& val);
+
+ void __set_totalCPUCount(const int32_t val);
+
+ void __set_nodeCount(const int32_t val);
+
+ void __set_numberOfThreads(const int32_t val);
+
+ void __set_queueName(const std::string& val);
+
+ void __set_wallTimeLimit(const int32_t val);
+
+ void __set_totalPhysicalMemory(const int32_t val);
+
+ void __set_chessisNumber(const std::string& val);
+
+ bool operator == (const ComputationalResourceSchedulingModel & rhs) const
+ {
+ if (__isset.resourceHostId != rhs.__isset.resourceHostId)
+ return false;
+ else if (__isset.resourceHostId && !(resourceHostId == rhs.resourceHostId))
+ return false;
+ if (__isset.totalCPUCount != rhs.__isset.totalCPUCount)
+ return false;
+ else if (__isset.totalCPUCount && !(totalCPUCount == rhs.totalCPUCount))
+ return false;
+ if (__isset.nodeCount != rhs.__isset.nodeCount)
+ return false;
+ else if (__isset.nodeCount && !(nodeCount == rhs.nodeCount))
+ return false;
+ if (__isset.numberOfThreads != rhs.__isset.numberOfThreads)
+ return false;
+ else if (__isset.numberOfThreads && !(numberOfThreads == rhs.numberOfThreads))
+ return false;
+ if (__isset.queueName != rhs.__isset.queueName)
+ return false;
+ else if (__isset.queueName && !(queueName == rhs.queueName))
+ return false;
+ if (__isset.wallTimeLimit != rhs.__isset.wallTimeLimit)
+ return false;
+ else if (__isset.wallTimeLimit && !(wallTimeLimit == rhs.wallTimeLimit))
+ return false;
+ if (__isset.totalPhysicalMemory != rhs.__isset.totalPhysicalMemory)
+ return false;
+ else if (__isset.totalPhysicalMemory && !(totalPhysicalMemory == rhs.totalPhysicalMemory))
+ return false;
+ if (__isset.chessisNumber != rhs.__isset.chessisNumber)
+ return false;
+ else if (__isset.chessisNumber && !(chessisNumber == rhs.chessisNumber))
+ return false;
+ return true;
+ }
+ bool operator != (const ComputationalResourceSchedulingModel &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ComputationalResourceSchedulingModel & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ friend std::ostream& operator<<(std::ostream& out, const ComputationalResourceSchedulingModel& obj);
+};
+
+void swap(ComputationalResourceSchedulingModel &a, ComputationalResourceSchedulingModel &b);
+
+}}}} // namespace
+
+#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.cpp
new file mode 100644
index 0000000..a8e8de2
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.cpp
@@ -0,0 +1,34 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "security_model_constants.h"
+
+namespace apache { namespace airavata { namespace model { namespace security {
+
+const security_modelConstants g_security_model_constants;
+
+security_modelConstants::security_modelConstants() {
+}
+
+}}}} // namespace
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.h
new file mode 100644
index 0000000..ca65823
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_constants.h
@@ -0,0 +1,41 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef security_model_CONSTANTS_H
+#define security_model_CONSTANTS_H
+
+#include "security_model_types.h"
+
+namespace apache { namespace airavata { namespace model { namespace security {
+
+class security_modelConstants {
+ public:
+ security_modelConstants();
+
+};
+
+extern const security_modelConstants g_security_model_constants;
+
+}}}} // namespace
+
+#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp
new file mode 100644
index 0000000..e81fdc1
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.cpp
@@ -0,0 +1,172 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "security_model_types.h"
+
+#include <algorithm>
+#include <ostream>
+
+#include <thrift/TToString.h>
+
+namespace apache { namespace airavata { namespace model { namespace security {
+
+
+AuthzToken::~AuthzToken() throw() {
+}
+
+
+void AuthzToken::__set_accessToken(const std::string& val) {
+ this->accessToken = val;
+}
+
+void AuthzToken::__set_claimsMap(const std::map<std::string, std::string> & val) {
+ this->claimsMap = val;
+__isset.claimsMap = true;
+}
+
+const char* AuthzToken::ascii_fingerprint = "31FBBEA1FC165CE500F2DE705C5C27CE";
+const uint8_t AuthzToken::binary_fingerprint[16] = {0x31,0xFB,0xBE,0xA1,0xFC,0x16,0x5C,0xE5,0x00,0xF2,0xDE,0x70,0x5C,0x5C,0x27,0xCE};
+
+uint32_t AuthzToken::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_accessToken = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->accessToken);
+ isset_accessToken = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->claimsMap.clear();
+ uint32_t _size0;
+ ::apache::thrift::protocol::TType _ktype1;
+ ::apache::thrift::protocol::TType _vtype2;
+ xfer += iprot->readMapBegin(_ktype1, _vtype2, _size0);
+ uint32_t _i4;
+ for (_i4 = 0; _i4 < _size0; ++_i4)
+ {
+ std::string _key5;
+ xfer += iprot->readString(_key5);
+ std::string& _val6 = this->claimsMap[_key5];
+ xfer += iprot->readString(_val6);
+ }
+ xfer += iprot->readMapEnd();
+ }
+ this->__isset.claimsMap = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_accessToken)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t AuthzToken::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ oprot->incrementRecursionDepth();
+ xfer += oprot->writeStructBegin("AuthzToken");
+
+ xfer += oprot->writeFieldBegin("accessToken", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->accessToken);
+ xfer += oprot->writeFieldEnd();
+
+ if (this->__isset.claimsMap) {
+ xfer += oprot->writeFieldBegin("claimsMap", ::apache::thrift::protocol::T_MAP, 2);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->claimsMap.size()));
+ std::map<std::string, std::string> ::const_iterator _iter7;
+ for (_iter7 = this->claimsMap.begin(); _iter7 != this->claimsMap.end(); ++_iter7)
+ {
+ xfer += oprot->writeString(_iter7->first);
+ xfer += oprot->writeString(_iter7->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ oprot->decrementRecursionDepth();
+ return xfer;
+}
+
+void swap(AuthzToken &a, AuthzToken &b) {
+ using ::std::swap;
+ swap(a.accessToken, b.accessToken);
+ swap(a.claimsMap, b.claimsMap);
+ swap(a.__isset, b.__isset);
+}
+
+AuthzToken::AuthzToken(const AuthzToken& other8) {
+ accessToken = other8.accessToken;
+ claimsMap = other8.claimsMap;
+ __isset = other8.__isset;
+}
+AuthzToken& AuthzToken::operator=(const AuthzToken& other9) {
+ accessToken = other9.accessToken;
+ claimsMap = other9.claimsMap;
+ __isset = other9.__isset;
+ return *this;
+}
+std::ostream& operator<<(std::ostream& out, const AuthzToken& obj) {
+ using apache::thrift::to_string;
+ out << "AuthzToken(";
+ out << "accessToken=" << to_string(obj.accessToken);
+ out << ", " << "claimsMap="; (obj.__isset.claimsMap ? (out << to_string(obj.claimsMap)) : (out << "<null>"));
+ out << ")";
+ return out;
+}
+
+}}}} // namespace
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h
new file mode 100644
index 0000000..1da1f97
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/security_model_types.h
@@ -0,0 +1,93 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef security_model_TYPES_H
+#define security_model_TYPES_H
+
+#include <iosfwd>
+
+#include <thrift/Thrift.h>
+#include <thrift/TApplicationException.h>
+#include <thrift/protocol/TProtocol.h>
+#include <thrift/transport/TTransport.h>
+
+#include <thrift/cxxfunctional.h>
+
+
+namespace apache { namespace airavata { namespace model { namespace security {
+
+class AuthzToken;
+
+typedef struct _AuthzToken__isset {
+ _AuthzToken__isset() : claimsMap(false) {}
+ bool claimsMap :1;
+} _AuthzToken__isset;
+
+class AuthzToken {
+ public:
+
+ static const char* ascii_fingerprint; // = "31FBBEA1FC165CE500F2DE705C5C27CE";
+ static const uint8_t binary_fingerprint[16]; // = {0x31,0xFB,0xBE,0xA1,0xFC,0x16,0x5C,0xE5,0x00,0xF2,0xDE,0x70,0x5C,0x5C,0x27,0xCE};
+
+ AuthzToken(const AuthzToken&);
+ AuthzToken& operator=(const AuthzToken&);
+ AuthzToken() : accessToken() {
+ }
+
+ virtual ~AuthzToken() throw();
+ std::string accessToken;
+ std::map<std::string, std::string> claimsMap;
+
+ _AuthzToken__isset __isset;
+
+ void __set_accessToken(const std::string& val);
+
+ void __set_claimsMap(const std::map<std::string, std::string> & val);
+
+ bool operator == (const AuthzToken & rhs) const
+ {
+ if (!(accessToken == rhs.accessToken))
+ return false;
+ if (__isset.claimsMap != rhs.__isset.claimsMap)
+ return false;
+ else if (__isset.claimsMap && !(claimsMap == rhs.claimsMap))
+ return false;
+ return true;
+ }
+ bool operator != (const AuthzToken &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const AuthzToken & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ friend std::ostream& operator<<(std::ostream& out, const AuthzToken& obj);
+};
+
+void swap(AuthzToken &a, AuthzToken &b);
+
+}}}} // namespace
+
+#endif
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.cpp
new file mode 100644
index 0000000..bc60c21
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.cpp
@@ -0,0 +1,34 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#include "status_models_constants.h"
+
+namespace apache { namespace airavata { namespace model { namespace status {
+
+const status_modelsConstants g_status_models_constants;
+
+status_modelsConstants::status_modelsConstants() {
+}
+
+}}}} // namespace
+
http://git-wip-us.apache.org/repos/asf/airavata/blob/dc524490/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.h
new file mode 100644
index 0000000..a5ee9f7
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/status_models_constants.h
@@ -0,0 +1,41 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+#ifndef status_models_CONSTANTS_H
+#define status_models_CONSTANTS_H
+
+#include "status_models_types.h"
+
+namespace apache { namespace airavata { namespace model { namespace status {
+
+class status_modelsConstants {
+ public:
+ status_modelsConstants();
+
+};
+
+extern const status_modelsConstants g_status_models_constants;
+
+}}}} // namespace
+
+#endif