You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2014/05/22 02:26:16 UTC
[2/4] fixing AIRAVATA-1249
http://git-wip-us.apache.org/repos/asf/airavata/blob/6f1ed7f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.cpp
index 483aa12..f1d6f77 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.cpp
@@ -1061,6 +1061,558 @@ uint32_t Airavata_getAllUserProjects_presult::read(::apache::thrift::protocol::T
return xfer;
}
+uint32_t Airavata_searchProjectsByProjectName_args::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_userName = false;
+ bool isset_projectName = 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->userName);
+ isset_userName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->projectName);
+ isset_projectName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_userName)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_projectName)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectName_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchProjectsByProjectName_args");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->userName);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("projectName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->projectName);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectName_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchProjectsByProjectName_pargs");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->userName)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("projectName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->projectName)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectName_result::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 0:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->success.clear();
+ uint32_t _size11;
+ ::apache::thrift::protocol::TType _etype14;
+ xfer += iprot->readListBegin(_etype14, _size11);
+ this->success.resize(_size11);
+ uint32_t _i15;
+ for (_i15 = 0; _i15 < _size11; ++_i15)
+ {
+ xfer += this->success[_i15].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectName_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_searchProjectsByProjectName_result");
+
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
+ std::vector< ::Project> ::const_iterator _iter16;
+ for (_iter16 = this->success.begin(); _iter16 != this->success.end(); ++_iter16)
+ {
+ xfer += (*_iter16).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
+ xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->ire.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectName_presult::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 0:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ (*(this->success)).clear();
+ uint32_t _size17;
+ ::apache::thrift::protocol::TType _etype20;
+ xfer += iprot->readListBegin(_etype20, _size17);
+ (*(this->success)).resize(_size17);
+ uint32_t _i21;
+ for (_i21 = 0; _i21 < _size17; ++_i21)
+ {
+ xfer += (*(this->success))[_i21].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectDesc_args::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_userName = false;
+ bool isset_description = 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->userName);
+ isset_userName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->description);
+ isset_description = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_userName)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_description)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectDesc_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchProjectsByProjectDesc_args");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->userName);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("description", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->description);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectDesc_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchProjectsByProjectDesc_pargs");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->userName)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("description", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->description)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectDesc_result::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 0:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->success.clear();
+ uint32_t _size22;
+ ::apache::thrift::protocol::TType _etype25;
+ xfer += iprot->readListBegin(_etype25, _size22);
+ this->success.resize(_size22);
+ uint32_t _i26;
+ for (_i26 = 0; _i26 < _size22; ++_i26)
+ {
+ xfer += this->success[_i26].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectDesc_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_searchProjectsByProjectDesc_result");
+
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
+ std::vector< ::Project> ::const_iterator _iter27;
+ for (_iter27 = this->success.begin(); _iter27 != this->success.end(); ++_iter27)
+ {
+ xfer += (*_iter27).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
+ xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->ire.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchProjectsByProjectDesc_presult::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 0:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ (*(this->success)).clear();
+ uint32_t _size28;
+ ::apache::thrift::protocol::TType _etype31;
+ xfer += iprot->readListBegin(_etype31, _size28);
+ (*(this->success)).resize(_size28);
+ uint32_t _i32;
+ for (_i32 = 0; _i32 < _size28; ++_i32)
+ {
+ xfer += (*(this->success))[_i32].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
uint32_t Airavata_getAllExperimentsInProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
@@ -1154,14 +1706,14 @@ uint32_t Airavata_getAllExperimentsInProject_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size11;
- ::apache::thrift::protocol::TType _etype14;
- xfer += iprot->readListBegin(_etype14, _size11);
- this->success.resize(_size11);
- uint32_t _i15;
- for (_i15 = 0; _i15 < _size11; ++_i15)
+ uint32_t _size33;
+ ::apache::thrift::protocol::TType _etype36;
+ xfer += iprot->readListBegin(_etype36, _size33);
+ this->success.resize(_size33);
+ uint32_t _i37;
+ for (_i37 = 0; _i37 < _size33; ++_i37)
{
- xfer += this->success[_i15].read(iprot);
+ xfer += this->success[_i37].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -1216,10 +1768,10 @@ uint32_t Airavata_getAllExperimentsInProject_result::write(::apache::thrift::pro
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::Experiment> ::const_iterator _iter16;
- for (_iter16 = this->success.begin(); _iter16 != this->success.end(); ++_iter16)
+ std::vector< ::Experiment> ::const_iterator _iter38;
+ for (_iter38 = this->success.begin(); _iter38 != this->success.end(); ++_iter38)
{
- xfer += (*_iter16).write(oprot);
+ xfer += (*_iter38).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1266,14 +1818,14 @@ uint32_t Airavata_getAllExperimentsInProject_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size17;
- ::apache::thrift::protocol::TType _etype20;
- xfer += iprot->readListBegin(_etype20, _size17);
- (*(this->success)).resize(_size17);
- uint32_t _i21;
- for (_i21 = 0; _i21 < _size17; ++_i21)
+ uint32_t _size39;
+ ::apache::thrift::protocol::TType _etype42;
+ xfer += iprot->readListBegin(_etype42, _size39);
+ (*(this->success)).resize(_size39);
+ uint32_t _i43;
+ for (_i43 = 0; _i43 < _size39; ++_i43)
{
- xfer += (*(this->success))[_i21].read(iprot);
+ xfer += (*(this->success))[_i43].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -1411,14 +1963,14 @@ uint32_t Airavata_getAllUserExperiments_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size22;
- ::apache::thrift::protocol::TType _etype25;
- xfer += iprot->readListBegin(_etype25, _size22);
- this->success.resize(_size22);
- uint32_t _i26;
- for (_i26 = 0; _i26 < _size22; ++_i26)
+ uint32_t _size44;
+ ::apache::thrift::protocol::TType _etype47;
+ xfer += iprot->readListBegin(_etype47, _size44);
+ this->success.resize(_size44);
+ uint32_t _i48;
+ for (_i48 = 0; _i48 < _size44; ++_i48)
{
- xfer += this->success[_i26].read(iprot);
+ xfer += this->success[_i48].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -1473,10 +2025,10 @@ uint32_t Airavata_getAllUserExperiments_result::write(::apache::thrift::protocol
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::Experiment> ::const_iterator _iter27;
- for (_iter27 = this->success.begin(); _iter27 != this->success.end(); ++_iter27)
+ std::vector< ::Experiment> ::const_iterator _iter49;
+ for (_iter49 = this->success.begin(); _iter49 != this->success.end(); ++_iter49)
{
- xfer += (*_iter27).write(oprot);
+ xfer += (*_iter49).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1523,14 +2075,14 @@ uint32_t Airavata_getAllUserExperiments_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size28;
- ::apache::thrift::protocol::TType _etype31;
- xfer += iprot->readListBegin(_etype31, _size28);
- (*(this->success)).resize(_size28);
- uint32_t _i32;
- for (_i32 = 0; _i32 < _size28; ++_i32)
+ uint32_t _size50;
+ ::apache::thrift::protocol::TType _etype53;
+ xfer += iprot->readListBegin(_etype53, _size50);
+ (*(this->success)).resize(_size50);
+ uint32_t _i54;
+ for (_i54 = 0; _i54 < _size50; ++_i54)
{
- xfer += (*(this->success))[_i32].read(iprot);
+ xfer += (*(this->success))[_i54].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3442,14 +3994,14 @@ uint32_t Airavata_getExperimentOutputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size33;
- ::apache::thrift::protocol::TType _etype36;
- xfer += iprot->readListBegin(_etype36, _size33);
- this->success.resize(_size33);
- uint32_t _i37;
- for (_i37 = 0; _i37 < _size33; ++_i37)
+ uint32_t _size55;
+ ::apache::thrift::protocol::TType _etype58;
+ xfer += iprot->readListBegin(_etype58, _size55);
+ this->success.resize(_size55);
+ uint32_t _i59;
+ for (_i59 = 0; _i59 < _size55; ++_i59)
{
- xfer += this->success[_i37].read(iprot);
+ xfer += this->success[_i59].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3480,10 +4032,10 @@ uint32_t Airavata_getExperimentOutputs_result::write(::apache::thrift::protocol:
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::DataObjectType> ::const_iterator _iter38;
- for (_iter38 = this->success.begin(); _iter38 != this->success.end(); ++_iter38)
+ std::vector< ::DataObjectType> ::const_iterator _iter60;
+ for (_iter60 = this->success.begin(); _iter60 != this->success.end(); ++_iter60)
{
- xfer += (*_iter38).write(oprot);
+ xfer += (*_iter60).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3518,14 +4070,14 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size39;
- ::apache::thrift::protocol::TType _etype42;
- xfer += iprot->readListBegin(_etype42, _size39);
- (*(this->success)).resize(_size39);
- uint32_t _i43;
- for (_i43 = 0; _i43 < _size39; ++_i43)
+ uint32_t _size61;
+ ::apache::thrift::protocol::TType _etype64;
+ xfer += iprot->readListBegin(_etype64, _size61);
+ (*(this->success)).resize(_size61);
+ uint32_t _i65;
+ for (_i65 = 0; _i65 < _size61; ++_i65)
{
- xfer += (*(this->success))[_i43].read(iprot);
+ xfer += (*(this->success))[_i65].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3639,17 +4191,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size44;
- ::apache::thrift::protocol::TType _ktype45;
- ::apache::thrift::protocol::TType _vtype46;
- xfer += iprot->readMapBegin(_ktype45, _vtype46, _size44);
- uint32_t _i48;
- for (_i48 = 0; _i48 < _size44; ++_i48)
+ uint32_t _size66;
+ ::apache::thrift::protocol::TType _ktype67;
+ ::apache::thrift::protocol::TType _vtype68;
+ xfer += iprot->readMapBegin(_ktype67, _vtype68, _size66);
+ uint32_t _i70;
+ for (_i70 = 0; _i70 < _size66; ++_i70)
{
- std::string _key49;
- xfer += iprot->readString(_key49);
- ::JobStatus& _val50 = this->success[_key49];
- xfer += _val50.read(iprot);
+ std::string _key71;
+ xfer += iprot->readString(_key71);
+ ::JobStatus& _val72 = this->success[_key71];
+ xfer += _val72.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -3680,11 +4232,11 @@ uint32_t Airavata_getJobStatuses_result::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, ::JobStatus> ::const_iterator _iter51;
- for (_iter51 = this->success.begin(); _iter51 != this->success.end(); ++_iter51)
+ std::map<std::string, ::JobStatus> ::const_iterator _iter73;
+ for (_iter73 = this->success.begin(); _iter73 != this->success.end(); ++_iter73)
{
- xfer += oprot->writeString(_iter51->first);
- xfer += _iter51->second.write(oprot);
+ xfer += oprot->writeString(_iter73->first);
+ xfer += _iter73->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -3719,17 +4271,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size52;
- ::apache::thrift::protocol::TType _ktype53;
- ::apache::thrift::protocol::TType _vtype54;
- xfer += iprot->readMapBegin(_ktype53, _vtype54, _size52);
- uint32_t _i56;
- for (_i56 = 0; _i56 < _size52; ++_i56)
+ uint32_t _size74;
+ ::apache::thrift::protocol::TType _ktype75;
+ ::apache::thrift::protocol::TType _vtype76;
+ xfer += iprot->readMapBegin(_ktype75, _vtype76, _size74);
+ uint32_t _i78;
+ for (_i78 = 0; _i78 < _size74; ++_i78)
{
- std::string _key57;
- xfer += iprot->readString(_key57);
- ::JobStatus& _val58 = (*(this->success))[_key57];
- xfer += _val58.read(iprot);
+ std::string _key79;
+ xfer += iprot->readString(_key79);
+ ::JobStatus& _val80 = (*(this->success))[_key79];
+ xfer += _val80.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -3780,8 +4332,8 @@ uint32_t Airavata_cloneExperiment_args::read(::apache::thrift::protocol::TProtoc
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->newExperiementName);
- this->__isset.newExperiementName = true;
+ xfer += iprot->readString(this->newExperimentName);
+ this->__isset.newExperimentName = true;
} else {
xfer += iprot->skip(ftype);
}
@@ -3806,8 +4358,8 @@ uint32_t Airavata_cloneExperiment_args::write(::apache::thrift::protocol::TProto
xfer += oprot->writeString(this->existingExperimentID);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("newExperiementName", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->newExperiementName);
+ xfer += oprot->writeFieldBegin("newExperimentName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->newExperimentName);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -3823,8 +4375,8 @@ uint32_t Airavata_cloneExperiment_pargs::write(::apache::thrift::protocol::TProt
xfer += oprot->writeString((*(this->existingExperimentID)));
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("newExperiementName", ::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString((*(this->newExperiementName)));
+ xfer += oprot->writeFieldBegin("newExperimentName", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString((*(this->newExperimentName)));
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -4550,6 +5102,142 @@ void AiravataClient::recv_getAllUserProjects(std::vector< ::Project> & _return)
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllUserProjects failed: unknown result");
}
+void AiravataClient::searchProjectsByProjectName(std::vector< ::Project> & _return, const std::string& userName, const std::string& projectName)
+{
+ send_searchProjectsByProjectName(userName, projectName);
+ recv_searchProjectsByProjectName(_return);
+}
+
+void AiravataClient::send_searchProjectsByProjectName(const std::string& userName, const std::string& projectName)
+{
+ int32_t cseqid = 0;
+ oprot_->writeMessageBegin("searchProjectsByProjectName", ::apache::thrift::protocol::T_CALL, cseqid);
+
+ Airavata_searchProjectsByProjectName_pargs args;
+ args.userName = &userName;
+ args.projectName = &projectName;
+ args.write(oprot_);
+
+ oprot_->writeMessageEnd();
+ oprot_->getTransport()->writeEnd();
+ oprot_->getTransport()->flush();
+}
+
+void AiravataClient::recv_searchProjectsByProjectName(std::vector< ::Project> & _return)
+{
+
+ int32_t rseqid = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TMessageType mtype;
+
+ iprot_->readMessageBegin(fname, mtype, rseqid);
+ if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
+ ::apache::thrift::TApplicationException x;
+ x.read(iprot_);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ throw x;
+ }
+ if (mtype != ::apache::thrift::protocol::T_REPLY) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ if (fname.compare("searchProjectsByProjectName") != 0) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ Airavata_searchProjectsByProjectName_presult result;
+ result.success = &_return;
+ result.read(iprot_);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
+ if (result.__isset.ire) {
+ throw result.ire;
+ }
+ if (result.__isset.ace) {
+ throw result.ace;
+ }
+ if (result.__isset.ase) {
+ throw result.ase;
+ }
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchProjectsByProjectName failed: unknown result");
+}
+
+void AiravataClient::searchProjectsByProjectDesc(std::vector< ::Project> & _return, const std::string& userName, const std::string& description)
+{
+ send_searchProjectsByProjectDesc(userName, description);
+ recv_searchProjectsByProjectDesc(_return);
+}
+
+void AiravataClient::send_searchProjectsByProjectDesc(const std::string& userName, const std::string& description)
+{
+ int32_t cseqid = 0;
+ oprot_->writeMessageBegin("searchProjectsByProjectDesc", ::apache::thrift::protocol::T_CALL, cseqid);
+
+ Airavata_searchProjectsByProjectDesc_pargs args;
+ args.userName = &userName;
+ args.description = &description;
+ args.write(oprot_);
+
+ oprot_->writeMessageEnd();
+ oprot_->getTransport()->writeEnd();
+ oprot_->getTransport()->flush();
+}
+
+void AiravataClient::recv_searchProjectsByProjectDesc(std::vector< ::Project> & _return)
+{
+
+ int32_t rseqid = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TMessageType mtype;
+
+ iprot_->readMessageBegin(fname, mtype, rseqid);
+ if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
+ ::apache::thrift::TApplicationException x;
+ x.read(iprot_);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ throw x;
+ }
+ if (mtype != ::apache::thrift::protocol::T_REPLY) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ if (fname.compare("searchProjectsByProjectDesc") != 0) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ Airavata_searchProjectsByProjectDesc_presult result;
+ result.success = &_return;
+ result.read(iprot_);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
+ if (result.__isset.ire) {
+ throw result.ire;
+ }
+ if (result.__isset.ace) {
+ throw result.ace;
+ }
+ if (result.__isset.ase) {
+ throw result.ase;
+ }
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchProjectsByProjectDesc failed: unknown result");
+}
+
void AiravataClient::getAllExperimentsInProject(std::vector< ::Experiment> & _return, const std::string& projectId)
{
send_getAllExperimentsInProject(projectId);
@@ -5320,20 +6008,20 @@ void AiravataClient::recv_getJobStatuses(std::map<std::string, ::JobStatus> & _
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getJobStatuses failed: unknown result");
}
-void AiravataClient::cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperiementName)
+void AiravataClient::cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperimentName)
{
- send_cloneExperiment(existingExperimentID, newExperiementName);
+ send_cloneExperiment(existingExperimentID, newExperimentName);
recv_cloneExperiment(_return);
}
-void AiravataClient::send_cloneExperiment(const std::string& existingExperimentID, const std::string& newExperiementName)
+void AiravataClient::send_cloneExperiment(const std::string& existingExperimentID, const std::string& newExperimentName)
{
int32_t cseqid = 0;
oprot_->writeMessageBegin("cloneExperiment", ::apache::thrift::protocol::T_CALL, cseqid);
Airavata_cloneExperiment_pargs args;
args.existingExperimentID = &existingExperimentID;
- args.newExperiementName = &newExperiementName;
+ args.newExperimentName = &newExperimentName;
args.write(oprot_);
oprot_->writeMessageEnd();
@@ -5780,6 +6468,132 @@ void AiravataProcessor::process_getAllUserProjects(int32_t seqid, ::apache::thri
}
}
+void AiravataProcessor::process_searchProjectsByProjectName(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
+{
+ void* ctx = NULL;
+ if (this->eventHandler_.get() != NULL) {
+ ctx = this->eventHandler_->getContext("Airavata.searchProjectsByProjectName", callContext);
+ }
+ ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.searchProjectsByProjectName");
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preRead(ctx, "Airavata.searchProjectsByProjectName");
+ }
+
+ Airavata_searchProjectsByProjectName_args args;
+ args.read(iprot);
+ iprot->readMessageEnd();
+ uint32_t bytes = iprot->getTransport()->readEnd();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postRead(ctx, "Airavata.searchProjectsByProjectName", bytes);
+ }
+
+ Airavata_searchProjectsByProjectName_result result;
+ try {
+ iface_->searchProjectsByProjectName(result.success, args.userName, args.projectName);
+ result.__isset.success = true;
+ } catch ( ::airavata::api::error::InvalidRequestException &ire) {
+ result.ire = ire;
+ result.__isset.ire = true;
+ } catch ( ::airavata::api::error::AiravataClientException &ace) {
+ result.ace = ace;
+ result.__isset.ace = true;
+ } catch ( ::airavata::api::error::AiravataSystemException &ase) {
+ result.ase = ase;
+ result.__isset.ase = true;
+ } catch (const std::exception& e) {
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->handlerError(ctx, "Airavata.searchProjectsByProjectName");
+ }
+
+ ::apache::thrift::TApplicationException x(e.what());
+ oprot->writeMessageBegin("searchProjectsByProjectName", ::apache::thrift::protocol::T_EXCEPTION, seqid);
+ x.write(oprot);
+ oprot->writeMessageEnd();
+ oprot->getTransport()->writeEnd();
+ oprot->getTransport()->flush();
+ return;
+ }
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preWrite(ctx, "Airavata.searchProjectsByProjectName");
+ }
+
+ oprot->writeMessageBegin("searchProjectsByProjectName", ::apache::thrift::protocol::T_REPLY, seqid);
+ result.write(oprot);
+ oprot->writeMessageEnd();
+ bytes = oprot->getTransport()->writeEnd();
+ oprot->getTransport()->flush();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postWrite(ctx, "Airavata.searchProjectsByProjectName", bytes);
+ }
+}
+
+void AiravataProcessor::process_searchProjectsByProjectDesc(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
+{
+ void* ctx = NULL;
+ if (this->eventHandler_.get() != NULL) {
+ ctx = this->eventHandler_->getContext("Airavata.searchProjectsByProjectDesc", callContext);
+ }
+ ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.searchProjectsByProjectDesc");
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preRead(ctx, "Airavata.searchProjectsByProjectDesc");
+ }
+
+ Airavata_searchProjectsByProjectDesc_args args;
+ args.read(iprot);
+ iprot->readMessageEnd();
+ uint32_t bytes = iprot->getTransport()->readEnd();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postRead(ctx, "Airavata.searchProjectsByProjectDesc", bytes);
+ }
+
+ Airavata_searchProjectsByProjectDesc_result result;
+ try {
+ iface_->searchProjectsByProjectDesc(result.success, args.userName, args.description);
+ result.__isset.success = true;
+ } catch ( ::airavata::api::error::InvalidRequestException &ire) {
+ result.ire = ire;
+ result.__isset.ire = true;
+ } catch ( ::airavata::api::error::AiravataClientException &ace) {
+ result.ace = ace;
+ result.__isset.ace = true;
+ } catch ( ::airavata::api::error::AiravataSystemException &ase) {
+ result.ase = ase;
+ result.__isset.ase = true;
+ } catch (const std::exception& e) {
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->handlerError(ctx, "Airavata.searchProjectsByProjectDesc");
+ }
+
+ ::apache::thrift::TApplicationException x(e.what());
+ oprot->writeMessageBegin("searchProjectsByProjectDesc", ::apache::thrift::protocol::T_EXCEPTION, seqid);
+ x.write(oprot);
+ oprot->writeMessageEnd();
+ oprot->getTransport()->writeEnd();
+ oprot->getTransport()->flush();
+ return;
+ }
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preWrite(ctx, "Airavata.searchProjectsByProjectDesc");
+ }
+
+ oprot->writeMessageBegin("searchProjectsByProjectDesc", ::apache::thrift::protocol::T_REPLY, seqid);
+ result.write(oprot);
+ oprot->writeMessageEnd();
+ bytes = oprot->getTransport()->writeEnd();
+ oprot->getTransport()->flush();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postWrite(ctx, "Airavata.searchProjectsByProjectDesc", bytes);
+ }
+}
+
void AiravataProcessor::process_getAllExperimentsInProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
{
void* ctx = NULL;
@@ -6537,7 +7351,7 @@ void AiravataProcessor::process_cloneExperiment(int32_t seqid, ::apache::thrift:
Airavata_cloneExperiment_result result;
try {
- iface_->cloneExperiment(result.success, args.existingExperimentID, args.newExperiementName);
+ iface_->cloneExperiment(result.success, args.existingExperimentID, args.newExperimentName);
result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
http://git-wip-us.apache.org/repos/asf/airavata/blob/6f1ed7f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.h
index 54d9d6c..9770d4b 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata.h
@@ -20,6 +20,8 @@ class AiravataIf {
virtual void updateProject(const ::Project& project) = 0;
virtual void getProject( ::Project& _return, const std::string& projectId) = 0;
virtual void getAllUserProjects(std::vector< ::Project> & _return, const std::string& userName) = 0;
+ virtual void searchProjectsByProjectName(std::vector< ::Project> & _return, const std::string& userName, const std::string& projectName) = 0;
+ virtual void searchProjectsByProjectDesc(std::vector< ::Project> & _return, const std::string& userName, const std::string& description) = 0;
virtual void getAllExperimentsInProject(std::vector< ::Experiment> & _return, const std::string& projectId) = 0;
virtual void getAllUserExperiments(std::vector< ::Experiment> & _return, const std::string& userName) = 0;
virtual void createExperiment(std::string& _return, const ::Experiment& experiment) = 0;
@@ -32,7 +34,7 @@ class AiravataIf {
virtual void getExperimentStatus( ::ExperimentStatus& _return, const std::string& airavataExperimentId) = 0;
virtual void getExperimentOutputs(std::vector< ::DataObjectType> & _return, const std::string& airavataExperimentId) = 0;
virtual void getJobStatuses(std::map<std::string, ::JobStatus> & _return, const std::string& airavataExperimentId) = 0;
- virtual void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperiementName) = 0;
+ virtual void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperimentName) = 0;
virtual void terminateExperiment(const std::string& airavataExperimentId) = 0;
};
@@ -78,6 +80,12 @@ class AiravataNull : virtual public AiravataIf {
void getAllUserProjects(std::vector< ::Project> & /* _return */, const std::string& /* userName */) {
return;
}
+ void searchProjectsByProjectName(std::vector< ::Project> & /* _return */, const std::string& /* userName */, const std::string& /* projectName */) {
+ return;
+ }
+ void searchProjectsByProjectDesc(std::vector< ::Project> & /* _return */, const std::string& /* userName */, const std::string& /* description */) {
+ return;
+ }
void getAllExperimentsInProject(std::vector< ::Experiment> & /* _return */, const std::string& /* projectId */) {
return;
}
@@ -115,7 +123,7 @@ class AiravataNull : virtual public AiravataIf {
void getJobStatuses(std::map<std::string, ::JobStatus> & /* _return */, const std::string& /* airavataExperimentId */) {
return;
}
- void cloneExperiment(std::string& /* _return */, const std::string& /* existingExperimentID */, const std::string& /* newExperiementName */) {
+ void cloneExperiment(std::string& /* _return */, const std::string& /* existingExperimentID */, const std::string& /* newExperimentName */) {
return;
}
void terminateExperiment(const std::string& /* airavataExperimentId */) {
@@ -736,6 +744,286 @@ class Airavata_getAllUserProjects_presult {
};
+class Airavata_searchProjectsByProjectName_args {
+ public:
+
+ Airavata_searchProjectsByProjectName_args() : userName(), projectName() {
+ }
+
+ virtual ~Airavata_searchProjectsByProjectName_args() throw() {}
+
+ std::string userName;
+ std::string projectName;
+
+ void __set_userName(const std::string& val) {
+ userName = val;
+ }
+
+ void __set_projectName(const std::string& val) {
+ projectName = val;
+ }
+
+ bool operator == (const Airavata_searchProjectsByProjectName_args & rhs) const
+ {
+ if (!(userName == rhs.userName))
+ return false;
+ if (!(projectName == rhs.projectName))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchProjectsByProjectName_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchProjectsByProjectName_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_searchProjectsByProjectName_pargs {
+ public:
+
+
+ virtual ~Airavata_searchProjectsByProjectName_pargs() throw() {}
+
+ const std::string* userName;
+ const std::string* projectName;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchProjectsByProjectName_result__isset {
+ _Airavata_searchProjectsByProjectName_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchProjectsByProjectName_result__isset;
+
+class Airavata_searchProjectsByProjectName_result {
+ public:
+
+ Airavata_searchProjectsByProjectName_result() {
+ }
+
+ virtual ~Airavata_searchProjectsByProjectName_result() throw() {}
+
+ std::vector< ::Project> success;
+ ::airavata::api::error::InvalidRequestException ire;
+ ::airavata::api::error::AiravataClientException ace;
+ ::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_searchProjectsByProjectName_result__isset __isset;
+
+ void __set_success(const std::vector< ::Project> & val) {
+ success = val;
+ }
+
+ void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
+ ire = val;
+ }
+
+ void __set_ace(const ::airavata::api::error::AiravataClientException& val) {
+ ace = val;
+ }
+
+ void __set_ase(const ::airavata::api::error::AiravataSystemException& val) {
+ ase = val;
+ }
+
+ bool operator == (const Airavata_searchProjectsByProjectName_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchProjectsByProjectName_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchProjectsByProjectName_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchProjectsByProjectName_presult__isset {
+ _Airavata_searchProjectsByProjectName_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchProjectsByProjectName_presult__isset;
+
+class Airavata_searchProjectsByProjectName_presult {
+ public:
+
+
+ virtual ~Airavata_searchProjectsByProjectName_presult() throw() {}
+
+ std::vector< ::Project> * success;
+ ::airavata::api::error::InvalidRequestException ire;
+ ::airavata::api::error::AiravataClientException ace;
+ ::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_searchProjectsByProjectName_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
+class Airavata_searchProjectsByProjectDesc_args {
+ public:
+
+ Airavata_searchProjectsByProjectDesc_args() : userName(), description() {
+ }
+
+ virtual ~Airavata_searchProjectsByProjectDesc_args() throw() {}
+
+ std::string userName;
+ std::string description;
+
+ void __set_userName(const std::string& val) {
+ userName = val;
+ }
+
+ void __set_description(const std::string& val) {
+ description = val;
+ }
+
+ bool operator == (const Airavata_searchProjectsByProjectDesc_args & rhs) const
+ {
+ if (!(userName == rhs.userName))
+ return false;
+ if (!(description == rhs.description))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchProjectsByProjectDesc_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchProjectsByProjectDesc_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_searchProjectsByProjectDesc_pargs {
+ public:
+
+
+ virtual ~Airavata_searchProjectsByProjectDesc_pargs() throw() {}
+
+ const std::string* userName;
+ const std::string* description;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchProjectsByProjectDesc_result__isset {
+ _Airavata_searchProjectsByProjectDesc_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchProjectsByProjectDesc_result__isset;
+
+class Airavata_searchProjectsByProjectDesc_result {
+ public:
+
+ Airavata_searchProjectsByProjectDesc_result() {
+ }
+
+ virtual ~Airavata_searchProjectsByProjectDesc_result() throw() {}
+
+ std::vector< ::Project> success;
+ ::airavata::api::error::InvalidRequestException ire;
+ ::airavata::api::error::AiravataClientException ace;
+ ::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_searchProjectsByProjectDesc_result__isset __isset;
+
+ void __set_success(const std::vector< ::Project> & val) {
+ success = val;
+ }
+
+ void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
+ ire = val;
+ }
+
+ void __set_ace(const ::airavata::api::error::AiravataClientException& val) {
+ ace = val;
+ }
+
+ void __set_ase(const ::airavata::api::error::AiravataSystemException& val) {
+ ase = val;
+ }
+
+ bool operator == (const Airavata_searchProjectsByProjectDesc_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchProjectsByProjectDesc_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchProjectsByProjectDesc_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchProjectsByProjectDesc_presult__isset {
+ _Airavata_searchProjectsByProjectDesc_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchProjectsByProjectDesc_presult__isset;
+
+class Airavata_searchProjectsByProjectDesc_presult {
+ public:
+
+
+ virtual ~Airavata_searchProjectsByProjectDesc_presult() throw() {}
+
+ std::vector< ::Project> * success;
+ ::airavata::api::error::InvalidRequestException ire;
+ ::airavata::api::error::AiravataClientException ace;
+ ::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_searchProjectsByProjectDesc_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
class Airavata_getAllExperimentsInProject_args {
public:
@@ -2232,21 +2520,21 @@ class Airavata_getJobStatuses_presult {
};
typedef struct _Airavata_cloneExperiment_args__isset {
- _Airavata_cloneExperiment_args__isset() : existingExperimentID(false), newExperiementName(false) {}
+ _Airavata_cloneExperiment_args__isset() : existingExperimentID(false), newExperimentName(false) {}
bool existingExperimentID;
- bool newExperiementName;
+ bool newExperimentName;
} _Airavata_cloneExperiment_args__isset;
class Airavata_cloneExperiment_args {
public:
- Airavata_cloneExperiment_args() : existingExperimentID(), newExperiementName() {
+ Airavata_cloneExperiment_args() : existingExperimentID(), newExperimentName() {
}
virtual ~Airavata_cloneExperiment_args() throw() {}
std::string existingExperimentID;
- std::string newExperiementName;
+ std::string newExperimentName;
_Airavata_cloneExperiment_args__isset __isset;
@@ -2254,15 +2542,15 @@ class Airavata_cloneExperiment_args {
existingExperimentID = val;
}
- void __set_newExperiementName(const std::string& val) {
- newExperiementName = val;
+ void __set_newExperimentName(const std::string& val) {
+ newExperimentName = val;
}
bool operator == (const Airavata_cloneExperiment_args & rhs) const
{
if (!(existingExperimentID == rhs.existingExperimentID))
return false;
- if (!(newExperiementName == rhs.newExperiementName))
+ if (!(newExperimentName == rhs.newExperimentName))
return false;
return true;
}
@@ -2285,7 +2573,7 @@ class Airavata_cloneExperiment_pargs {
virtual ~Airavata_cloneExperiment_pargs() throw() {}
const std::string* existingExperimentID;
- const std::string* newExperiementName;
+ const std::string* newExperimentName;
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
@@ -2561,6 +2849,12 @@ class AiravataClient : virtual public AiravataIf {
void getAllUserProjects(std::vector< ::Project> & _return, const std::string& userName);
void send_getAllUserProjects(const std::string& userName);
void recv_getAllUserProjects(std::vector< ::Project> & _return);
+ void searchProjectsByProjectName(std::vector< ::Project> & _return, const std::string& userName, const std::string& projectName);
+ void send_searchProjectsByProjectName(const std::string& userName, const std::string& projectName);
+ void recv_searchProjectsByProjectName(std::vector< ::Project> & _return);
+ void searchProjectsByProjectDesc(std::vector< ::Project> & _return, const std::string& userName, const std::string& description);
+ void send_searchProjectsByProjectDesc(const std::string& userName, const std::string& description);
+ void recv_searchProjectsByProjectDesc(std::vector< ::Project> & _return);
void getAllExperimentsInProject(std::vector< ::Experiment> & _return, const std::string& projectId);
void send_getAllExperimentsInProject(const std::string& projectId);
void recv_getAllExperimentsInProject(std::vector< ::Experiment> & _return);
@@ -2597,8 +2891,8 @@ class AiravataClient : virtual public AiravataIf {
void getJobStatuses(std::map<std::string, ::JobStatus> & _return, const std::string& airavataExperimentId);
void send_getJobStatuses(const std::string& airavataExperimentId);
void recv_getJobStatuses(std::map<std::string, ::JobStatus> & _return);
- void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperiementName);
- void send_cloneExperiment(const std::string& existingExperimentID, const std::string& newExperiementName);
+ void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperimentName);
+ void send_cloneExperiment(const std::string& existingExperimentID, const std::string& newExperimentName);
void recv_cloneExperiment(std::string& _return);
void terminateExperiment(const std::string& airavataExperimentId);
void send_terminateExperiment(const std::string& airavataExperimentId);
@@ -2623,6 +2917,8 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
void process_updateProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getAllUserProjects(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_searchProjectsByProjectName(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_searchProjectsByProjectDesc(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getAllExperimentsInProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getAllUserExperiments(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_createExperiment(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -2645,6 +2941,8 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
processMap_["updateProject"] = &AiravataProcessor::process_updateProject;
processMap_["getProject"] = &AiravataProcessor::process_getProject;
processMap_["getAllUserProjects"] = &AiravataProcessor::process_getAllUserProjects;
+ processMap_["searchProjectsByProjectName"] = &AiravataProcessor::process_searchProjectsByProjectName;
+ processMap_["searchProjectsByProjectDesc"] = &AiravataProcessor::process_searchProjectsByProjectDesc;
processMap_["getAllExperimentsInProject"] = &AiravataProcessor::process_getAllExperimentsInProject;
processMap_["getAllUserExperiments"] = &AiravataProcessor::process_getAllUserExperiments;
processMap_["createExperiment"] = &AiravataProcessor::process_createExperiment;
@@ -2736,6 +3034,26 @@ class AiravataMultiface : virtual public AiravataIf {
return;
}
+ void searchProjectsByProjectName(std::vector< ::Project> & _return, const std::string& userName, const std::string& projectName) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->searchProjectsByProjectName(_return, userName, projectName);
+ }
+ ifaces_[i]->searchProjectsByProjectName(_return, userName, projectName);
+ return;
+ }
+
+ void searchProjectsByProjectDesc(std::vector< ::Project> & _return, const std::string& userName, const std::string& description) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->searchProjectsByProjectDesc(_return, userName, description);
+ }
+ ifaces_[i]->searchProjectsByProjectDesc(_return, userName, description);
+ return;
+ }
+
void getAllExperimentsInProject(std::vector< ::Experiment> & _return, const std::string& projectId) {
size_t sz = ifaces_.size();
size_t i = 0;
@@ -2851,13 +3169,13 @@ class AiravataMultiface : virtual public AiravataIf {
return;
}
- void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperiementName) {
+ void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperimentName) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->cloneExperiment(_return, existingExperimentID, newExperiementName);
+ ifaces_[i]->cloneExperiment(_return, existingExperimentID, newExperimentName);
}
- ifaces_[i]->cloneExperiment(_return, existingExperimentID, newExperiementName);
+ ifaces_[i]->cloneExperiment(_return, existingExperimentID, newExperimentName);
return;
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/6f1ed7f0/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata_server.skeleton.cpp
index 30e57c0..172fe05 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata_server.skeleton.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/Airavata_server.skeleton.cpp
@@ -47,6 +47,16 @@ class AiravataHandler : virtual public AiravataIf {
printf("getAllUserProjects\n");
}
+ void searchProjectsByProjectName(std::vector< ::Project> & _return, const std::string& userName, const std::string& projectName) {
+ // Your implementation goes here
+ printf("searchProjectsByProjectName\n");
+ }
+
+ void searchProjectsByProjectDesc(std::vector< ::Project> & _return, const std::string& userName, const std::string& description) {
+ // Your implementation goes here
+ printf("searchProjectsByProjectDesc\n");
+ }
+
void getAllExperimentsInProject(std::vector< ::Experiment> & _return, const std::string& projectId) {
// Your implementation goes here
printf("getAllExperimentsInProject\n");
@@ -107,7 +117,7 @@ class AiravataHandler : virtual public AiravataIf {
printf("getJobStatuses\n");
}
- void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperiementName) {
+ void cloneExperiment(std::string& _return, const std::string& existingExperimentID, const std::string& newExperimentName) {
// Your implementation goes here
printf("cloneExperiment\n");
}