adding useremails to experiment and task models - AIRAVATA-1563
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/7a6fbdb2 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/7a6fbdb2 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/7a6fbdb2 Branch: refs/heads/master Commit: 7a6fbdb25530028c0f9c04e02c556ce4e65394d5 Parents: 92888e5 Author: Chathuri Wimalasena <[email protected]> Authored: Wed Feb 4 12:16:59 2015 -0500 Committer: Chathuri Wimalasena <[email protected]> Committed: Wed Feb 4 12:16:59 2015 -0500 ---------------------------------------------------------------------- .../lib/airavata/experimentModel_types.cpp | 394 ++++++++------ .../lib/airavata/experimentModel_types.h | 64 ++- .../Model/Workspace/Experiment/Types.php | 416 ++++++++++----- .../model/workspace/experiment/Experiment.java | 524 ++++++++++++++----- .../workspace/experiment/ExperimentSummary.java | 36 +- .../model/workspace/experiment/TaskDetails.java | 362 ++++++++++--- .../workspace/experiment/ValidationResults.java | 36 +- .../experiment/WorkflowNodeDetails.java | 144 ++--- .../experimentModel.thrift | 22 +- .../persistance/registry/jpa/ResourceType.java | 1 + .../registry/jpa/impl/ExperimentRegistry.java | 54 +- .../registry/jpa/model/Experiment.java | 11 +- .../registry/jpa/model/Notification_Email.java | 97 ++++ .../registry/jpa/model/TaskDetail.java | 10 + .../jpa/resources/AbstractResource.java | 7 + .../jpa/resources/ExperimentResource.java | 53 ++ .../resources/NotificationEmailResource.java | 125 +++++ .../jpa/resources/TaskDetailResource.java | 54 +- .../registry/jpa/resources/Utils.java | 21 + .../jpa/utils/ThriftDataModelConversion.java | 42 +- .../src/main/resources/META-INF/persistence.xml | 1 + .../src/main/resources/registry-derby.sql | 15 + .../src/main/resources/registry-mysql.sql | 13 +- .../src/test/resources/registry-derby.sql | 9 + 24 files changed, 1870 insertions(+), 641 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/7a6fbdb2/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.cpp index c9ed366..d6e6b07 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.cpp @@ -1843,8 +1843,8 @@ void swap(DataTransferDetails &a, DataTransferDetails &b) { swap(a.__isset, b.__isset); } -const char* TaskDetails::ascii_fingerprint = "6FF0ECF6FE53D283757211BADE659108"; -const uint8_t TaskDetails::binary_fingerprint[16] = {0x6F,0xF0,0xEC,0xF6,0xFE,0x53,0xD2,0x83,0x75,0x72,0x11,0xBA,0xDE,0x65,0x91,0x08}; +const char* TaskDetails::ascii_fingerprint = "6EAEEB62655ECD5CA7A24BFDE46F678C"; +const uint8_t TaskDetails::binary_fingerprint[16] = {0x6E,0xAE,0xEB,0x62,0x65,0x5E,0xCD,0x5C,0xA7,0xA2,0x4B,0xFD,0xE4,0x6F,0x67,0x8C}; uint32_t TaskDetails::read(::apache::thrift::protocol::TProtocol* iprot) { @@ -2039,6 +2039,34 @@ uint32_t TaskDetails::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; + case 15: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->enableEmailNotification); + this->__isset.enableEmailNotification = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 16: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->emailAddresses.clear(); + uint32_t _size45; + ::apache::thrift::protocol::TType _etype48; + xfer += iprot->readListBegin(_etype48, _size45); + this->emailAddresses.resize(_size45); + uint32_t _i49; + for (_i49 = 0; _i49 < _size45; ++_i49) + { + xfer += iprot->readString(this->emailAddresses[_i49]); + } + xfer += iprot->readListEnd(); + } + this->__isset.emailAddresses = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -2085,10 +2113,10 @@ uint32_t TaskDetails::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("applicationInputs", ::apache::thrift::protocol::T_LIST, 6); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->applicationInputs.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter45; - for (_iter45 = this->applicationInputs.begin(); _iter45 != this->applicationInputs.end(); ++_iter45) + std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter50; + for (_iter50 = this->applicationInputs.begin(); _iter50 != this->applicationInputs.end(); ++_iter50) { - xfer += (*_iter45).write(oprot); + xfer += (*_iter50).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2098,10 +2126,10 @@ uint32_t TaskDetails::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("applicationOutputs", ::apache::thrift::protocol::T_LIST, 7); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->applicationOutputs.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter46; - for (_iter46 = this->applicationOutputs.begin(); _iter46 != this->applicationOutputs.end(); ++_iter46) + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter51; + for (_iter51 = this->applicationOutputs.begin(); _iter51 != this->applicationOutputs.end(); ++_iter51) { - xfer += (*_iter46).write(oprot); + xfer += (*_iter51).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2131,10 +2159,10 @@ uint32_t TaskDetails::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("jobDetailsList", ::apache::thrift::protocol::T_LIST, 12); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->jobDetailsList.size())); - std::vector<JobDetails> ::const_iterator _iter47; - for (_iter47 = this->jobDetailsList.begin(); _iter47 != this->jobDetailsList.end(); ++_iter47) + std::vector<JobDetails> ::const_iterator _iter52; + for (_iter52 = this->jobDetailsList.begin(); _iter52 != this->jobDetailsList.end(); ++_iter52) { - xfer += (*_iter47).write(oprot); + xfer += (*_iter52).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2144,10 +2172,10 @@ uint32_t TaskDetails::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("dataTransferDetailsList", ::apache::thrift::protocol::T_LIST, 13); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->dataTransferDetailsList.size())); - std::vector<DataTransferDetails> ::const_iterator _iter48; - for (_iter48 = this->dataTransferDetailsList.begin(); _iter48 != this->dataTransferDetailsList.end(); ++_iter48) + std::vector<DataTransferDetails> ::const_iterator _iter53; + for (_iter53 = this->dataTransferDetailsList.begin(); _iter53 != this->dataTransferDetailsList.end(); ++_iter53) { - xfer += (*_iter48).write(oprot); + xfer += (*_iter53).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2157,10 +2185,28 @@ uint32_t TaskDetails::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("errors", ::apache::thrift::protocol::T_LIST, 14); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->errors.size())); - std::vector<ErrorDetails> ::const_iterator _iter49; - for (_iter49 = this->errors.begin(); _iter49 != this->errors.end(); ++_iter49) + std::vector<ErrorDetails> ::const_iterator _iter54; + for (_iter54 = this->errors.begin(); _iter54 != this->errors.end(); ++_iter54) { - xfer += (*_iter49).write(oprot); + xfer += (*_iter54).write(oprot); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.enableEmailNotification) { + xfer += oprot->writeFieldBegin("enableEmailNotification", ::apache::thrift::protocol::T_BOOL, 15); + xfer += oprot->writeBool(this->enableEmailNotification); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.emailAddresses) { + xfer += oprot->writeFieldBegin("emailAddresses", ::apache::thrift::protocol::T_LIST, 16); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->emailAddresses.size())); + std::vector<std::string> ::const_iterator _iter55; + for (_iter55 = this->emailAddresses.begin(); _iter55 != this->emailAddresses.end(); ++_iter55) + { + xfer += oprot->writeString((*_iter55)); } xfer += oprot->writeListEnd(); } @@ -2187,11 +2233,13 @@ void swap(TaskDetails &a, TaskDetails &b) { swap(a.jobDetailsList, b.jobDetailsList); swap(a.dataTransferDetailsList, b.dataTransferDetailsList); swap(a.errors, b.errors); + swap(a.enableEmailNotification, b.enableEmailNotification); + swap(a.emailAddresses, b.emailAddresses); swap(a.__isset, b.__isset); } -const char* WorkflowNodeDetails::ascii_fingerprint = "D2AF8FCCA5B9C08220AE508BA2D7FB06"; -const uint8_t WorkflowNodeDetails::binary_fingerprint[16] = {0xD2,0xAF,0x8F,0xCC,0xA5,0xB9,0xC0,0x82,0x20,0xAE,0x50,0x8B,0xA2,0xD7,0xFB,0x06}; +const char* WorkflowNodeDetails::ascii_fingerprint = "CDDA44A784FD60829B4F4EAA67D71C72"; +const uint8_t WorkflowNodeDetails::binary_fingerprint[16] = {0xCD,0xDA,0x44,0xA7,0x84,0xFD,0x60,0x82,0x9B,0x4F,0x4E,0xAA,0x67,0xD7,0x1C,0x72}; uint32_t WorkflowNodeDetails::read(::apache::thrift::protocol::TProtocol* iprot) { @@ -2242,9 +2290,9 @@ uint32_t WorkflowNodeDetails::read(::apache::thrift::protocol::TProtocol* iprot) break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast50; - xfer += iprot->readI32(ecast50); - this->executionUnit = (ExecutionUnit::type)ecast50; + int32_t ecast56; + xfer += iprot->readI32(ecast56); + this->executionUnit = (ExecutionUnit::type)ecast56; isset_executionUnit = true; } else { xfer += iprot->skip(ftype); @@ -2262,14 +2310,14 @@ uint32_t WorkflowNodeDetails::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->nodeInputs.clear(); - uint32_t _size51; - ::apache::thrift::protocol::TType _etype54; - xfer += iprot->readListBegin(_etype54, _size51); - this->nodeInputs.resize(_size51); - uint32_t _i55; - for (_i55 = 0; _i55 < _size51; ++_i55) + uint32_t _size57; + ::apache::thrift::protocol::TType _etype60; + xfer += iprot->readListBegin(_etype60, _size57); + this->nodeInputs.resize(_size57); + uint32_t _i61; + for (_i61 = 0; _i61 < _size57; ++_i61) { - xfer += this->nodeInputs[_i55].read(iprot); + xfer += this->nodeInputs[_i61].read(iprot); } xfer += iprot->readListEnd(); } @@ -2282,14 +2330,14 @@ uint32_t WorkflowNodeDetails::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->nodeOutputs.clear(); - uint32_t _size56; - ::apache::thrift::protocol::TType _etype59; - xfer += iprot->readListBegin(_etype59, _size56); - this->nodeOutputs.resize(_size56); - uint32_t _i60; - for (_i60 = 0; _i60 < _size56; ++_i60) + uint32_t _size62; + ::apache::thrift::protocol::TType _etype65; + xfer += iprot->readListBegin(_etype65, _size62); + this->nodeOutputs.resize(_size62); + uint32_t _i66; + for (_i66 = 0; _i66 < _size62; ++_i66) { - xfer += this->nodeOutputs[_i60].read(iprot); + xfer += this->nodeOutputs[_i66].read(iprot); } xfer += iprot->readListEnd(); } @@ -2310,14 +2358,14 @@ uint32_t WorkflowNodeDetails::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->taskDetailsList.clear(); - uint32_t _size61; - ::apache::thrift::protocol::TType _etype64; - xfer += iprot->readListBegin(_etype64, _size61); - this->taskDetailsList.resize(_size61); - uint32_t _i65; - for (_i65 = 0; _i65 < _size61; ++_i65) + uint32_t _size67; + ::apache::thrift::protocol::TType _etype70; + xfer += iprot->readListBegin(_etype70, _size67); + this->taskDetailsList.resize(_size67); + uint32_t _i71; + for (_i71 = 0; _i71 < _size67; ++_i71) { - xfer += this->taskDetailsList[_i65].read(iprot); + xfer += this->taskDetailsList[_i71].read(iprot); } xfer += iprot->readListEnd(); } @@ -2330,14 +2378,14 @@ uint32_t WorkflowNodeDetails::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->errors.clear(); - uint32_t _size66; - ::apache::thrift::protocol::TType _etype69; - xfer += iprot->readListBegin(_etype69, _size66); - this->errors.resize(_size66); - uint32_t _i70; - for (_i70 = 0; _i70 < _size66; ++_i70) + uint32_t _size72; + ::apache::thrift::protocol::TType _etype75; + xfer += iprot->readListBegin(_etype75, _size72); + this->errors.resize(_size72); + uint32_t _i76; + for (_i76 = 0; _i76 < _size72; ++_i76) { - xfer += this->errors[_i70].read(iprot); + xfer += this->errors[_i76].read(iprot); } xfer += iprot->readListEnd(); } @@ -2394,10 +2442,10 @@ uint32_t WorkflowNodeDetails::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("nodeInputs", ::apache::thrift::protocol::T_LIST, 6); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->nodeInputs.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter71; - for (_iter71 = this->nodeInputs.begin(); _iter71 != this->nodeInputs.end(); ++_iter71) + std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter77; + for (_iter77 = this->nodeInputs.begin(); _iter77 != this->nodeInputs.end(); ++_iter77) { - xfer += (*_iter71).write(oprot); + xfer += (*_iter77).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2407,10 +2455,10 @@ uint32_t WorkflowNodeDetails::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("nodeOutputs", ::apache::thrift::protocol::T_LIST, 7); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->nodeOutputs.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter72; - for (_iter72 = this->nodeOutputs.begin(); _iter72 != this->nodeOutputs.end(); ++_iter72) + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter78; + for (_iter78 = this->nodeOutputs.begin(); _iter78 != this->nodeOutputs.end(); ++_iter78) { - xfer += (*_iter72).write(oprot); + xfer += (*_iter78).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2425,10 +2473,10 @@ uint32_t WorkflowNodeDetails::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("taskDetailsList", ::apache::thrift::protocol::T_LIST, 9); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->taskDetailsList.size())); - std::vector<TaskDetails> ::const_iterator _iter73; - for (_iter73 = this->taskDetailsList.begin(); _iter73 != this->taskDetailsList.end(); ++_iter73) + std::vector<TaskDetails> ::const_iterator _iter79; + for (_iter79 = this->taskDetailsList.begin(); _iter79 != this->taskDetailsList.end(); ++_iter79) { - xfer += (*_iter73).write(oprot); + xfer += (*_iter79).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2438,10 +2486,10 @@ uint32_t WorkflowNodeDetails::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldBegin("errors", ::apache::thrift::protocol::T_LIST, 10); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->errors.size())); - std::vector<ErrorDetails> ::const_iterator _iter74; - for (_iter74 = this->errors.begin(); _iter74 != this->errors.end(); ++_iter74) + std::vector<ErrorDetails> ::const_iterator _iter80; + for (_iter80 = this->errors.begin(); _iter80 != this->errors.end(); ++_iter80) { - xfer += (*_iter74).write(oprot); + xfer += (*_iter80).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2583,14 +2631,14 @@ uint32_t ValidationResults::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->validationResultList.clear(); - uint32_t _size75; - ::apache::thrift::protocol::TType _etype78; - xfer += iprot->readListBegin(_etype78, _size75); - this->validationResultList.resize(_size75); - uint32_t _i79; - for (_i79 = 0; _i79 < _size75; ++_i79) + uint32_t _size81; + ::apache::thrift::protocol::TType _etype84; + xfer += iprot->readListBegin(_etype84, _size81); + this->validationResultList.resize(_size81); + uint32_t _i85; + for (_i85 = 0; _i85 < _size81; ++_i85) { - xfer += this->validationResultList[_i79].read(iprot); + xfer += this->validationResultList[_i85].read(iprot); } xfer += iprot->readListEnd(); } @@ -2626,10 +2674,10 @@ uint32_t ValidationResults::write(::apache::thrift::protocol::TProtocol* oprot) xfer += oprot->writeFieldBegin("validationResultList", ::apache::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->validationResultList.size())); - std::vector<ValidatorResult> ::const_iterator _iter80; - for (_iter80 = this->validationResultList.begin(); _iter80 != this->validationResultList.end(); ++_iter80) + std::vector<ValidatorResult> ::const_iterator _iter86; + for (_iter86 = this->validationResultList.begin(); _iter86 != this->validationResultList.end(); ++_iter86) { - xfer += (*_iter80).write(oprot); + xfer += (*_iter86).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2646,8 +2694,8 @@ void swap(ValidationResults &a, ValidationResults &b) { swap(a.validationResultList, b.validationResultList); } -const char* Experiment::ascii_fingerprint = "4CE20099975A60F2FE0D6D1139972D1A"; -const uint8_t Experiment::binary_fingerprint[16] = {0x4C,0xE2,0x00,0x99,0x97,0x5A,0x60,0xF2,0xFE,0x0D,0x6D,0x11,0x39,0x97,0x2D,0x1A}; +const char* Experiment::ascii_fingerprint = "145D3134FA7C46D3D99051850C4984FF"; +const uint8_t Experiment::binary_fingerprint[16] = {0x14,0x5D,0x31,0x34,0xFA,0x7C,0x46,0xD3,0xD9,0x90,0x51,0x85,0x0C,0x49,0x84,0xFF}; uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { @@ -2754,6 +2802,34 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { } break; case 11: + if (ftype == ::apache::thrift::protocol::T_BOOL) { + xfer += iprot->readBool(this->enableEmailNotification); + this->__isset.enableEmailNotification = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 12: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->emailAddresses.clear(); + uint32_t _size87; + ::apache::thrift::protocol::TType _etype90; + xfer += iprot->readListBegin(_etype90, _size87); + this->emailAddresses.resize(_size87); + uint32_t _i91; + for (_i91 = 0; _i91 < _size87; ++_i91) + { + xfer += iprot->readString(this->emailAddresses[_i91]); + } + xfer += iprot->readListEnd(); + } + this->__isset.emailAddresses = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 13: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->userConfigurationData.read(iprot); this->__isset.userConfigurationData = true; @@ -2761,7 +2837,7 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 12: + case 14: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->workflowExecutionInstanceId); this->__isset.workflowExecutionInstanceId = true; @@ -2769,18 +2845,18 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 13: + case 15: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->experimentInputs.clear(); - uint32_t _size81; - ::apache::thrift::protocol::TType _etype84; - xfer += iprot->readListBegin(_etype84, _size81); - this->experimentInputs.resize(_size81); - uint32_t _i85; - for (_i85 = 0; _i85 < _size81; ++_i85) + uint32_t _size92; + ::apache::thrift::protocol::TType _etype95; + xfer += iprot->readListBegin(_etype95, _size92); + this->experimentInputs.resize(_size92); + uint32_t _i96; + for (_i96 = 0; _i96 < _size92; ++_i96) { - xfer += this->experimentInputs[_i85].read(iprot); + xfer += this->experimentInputs[_i96].read(iprot); } xfer += iprot->readListEnd(); } @@ -2789,18 +2865,18 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 14: + case 16: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->experimentOutputs.clear(); - uint32_t _size86; - ::apache::thrift::protocol::TType _etype89; - xfer += iprot->readListBegin(_etype89, _size86); - this->experimentOutputs.resize(_size86); - uint32_t _i90; - for (_i90 = 0; _i90 < _size86; ++_i90) + uint32_t _size97; + ::apache::thrift::protocol::TType _etype100; + xfer += iprot->readListBegin(_etype100, _size97); + this->experimentOutputs.resize(_size97); + uint32_t _i101; + for (_i101 = 0; _i101 < _size97; ++_i101) { - xfer += this->experimentOutputs[_i90].read(iprot); + xfer += this->experimentOutputs[_i101].read(iprot); } xfer += iprot->readListEnd(); } @@ -2809,7 +2885,7 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 15: + case 17: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->experimentStatus.read(iprot); this->__isset.experimentStatus = true; @@ -2817,18 +2893,18 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 16: + case 18: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->stateChangeList.clear(); - uint32_t _size91; - ::apache::thrift::protocol::TType _etype94; - xfer += iprot->readListBegin(_etype94, _size91); - this->stateChangeList.resize(_size91); - uint32_t _i95; - for (_i95 = 0; _i95 < _size91; ++_i95) + uint32_t _size102; + ::apache::thrift::protocol::TType _etype105; + xfer += iprot->readListBegin(_etype105, _size102); + this->stateChangeList.resize(_size102); + uint32_t _i106; + for (_i106 = 0; _i106 < _size102; ++_i106) { - xfer += this->stateChangeList[_i95].read(iprot); + xfer += this->stateChangeList[_i106].read(iprot); } xfer += iprot->readListEnd(); } @@ -2837,18 +2913,18 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 17: + case 19: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->workflowNodeDetailsList.clear(); - uint32_t _size96; - ::apache::thrift::protocol::TType _etype99; - xfer += iprot->readListBegin(_etype99, _size96); - this->workflowNodeDetailsList.resize(_size96); - uint32_t _i100; - for (_i100 = 0; _i100 < _size96; ++_i100) + uint32_t _size107; + ::apache::thrift::protocol::TType _etype110; + xfer += iprot->readListBegin(_etype110, _size107); + this->workflowNodeDetailsList.resize(_size107); + uint32_t _i111; + for (_i111 = 0; _i111 < _size107; ++_i111) { - xfer += this->workflowNodeDetailsList[_i100].read(iprot); + xfer += this->workflowNodeDetailsList[_i111].read(iprot); } xfer += iprot->readListEnd(); } @@ -2857,18 +2933,18 @@ uint32_t Experiment::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 18: + case 20: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->errors.clear(); - uint32_t _size101; - ::apache::thrift::protocol::TType _etype104; - xfer += iprot->readListBegin(_etype104, _size101); - this->errors.resize(_size101); - uint32_t _i105; - for (_i105 = 0; _i105 < _size101; ++_i105) + uint32_t _size112; + ::apache::thrift::protocol::TType _etype115; + xfer += iprot->readListBegin(_etype115, _size112); + this->errors.resize(_size112); + uint32_t _i116; + for (_i116 = 0; _i116 < _size112; ++_i116) { - xfer += this->errors[_i105].read(iprot); + xfer += this->errors[_i116].read(iprot); } xfer += iprot->readListEnd(); } @@ -2947,81 +3023,99 @@ uint32_t Experiment::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeString(this->workflowTemplateVersion); xfer += oprot->writeFieldEnd(); } + if (this->__isset.enableEmailNotification) { + xfer += oprot->writeFieldBegin("enableEmailNotification", ::apache::thrift::protocol::T_BOOL, 11); + xfer += oprot->writeBool(this->enableEmailNotification); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.emailAddresses) { + xfer += oprot->writeFieldBegin("emailAddresses", ::apache::thrift::protocol::T_LIST, 12); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->emailAddresses.size())); + std::vector<std::string> ::const_iterator _iter117; + for (_iter117 = this->emailAddresses.begin(); _iter117 != this->emailAddresses.end(); ++_iter117) + { + xfer += oprot->writeString((*_iter117)); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } if (this->__isset.userConfigurationData) { - xfer += oprot->writeFieldBegin("userConfigurationData", ::apache::thrift::protocol::T_STRUCT, 11); + xfer += oprot->writeFieldBegin("userConfigurationData", ::apache::thrift::protocol::T_STRUCT, 13); xfer += this->userConfigurationData.write(oprot); xfer += oprot->writeFieldEnd(); } if (this->__isset.workflowExecutionInstanceId) { - xfer += oprot->writeFieldBegin("workflowExecutionInstanceId", ::apache::thrift::protocol::T_STRING, 12); + xfer += oprot->writeFieldBegin("workflowExecutionInstanceId", ::apache::thrift::protocol::T_STRING, 14); xfer += oprot->writeString(this->workflowExecutionInstanceId); xfer += oprot->writeFieldEnd(); } if (this->__isset.experimentInputs) { - xfer += oprot->writeFieldBegin("experimentInputs", ::apache::thrift::protocol::T_LIST, 13); + xfer += oprot->writeFieldBegin("experimentInputs", ::apache::thrift::protocol::T_LIST, 15); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->experimentInputs.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter106; - for (_iter106 = this->experimentInputs.begin(); _iter106 != this->experimentInputs.end(); ++_iter106) + std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter118; + for (_iter118 = this->experimentInputs.begin(); _iter118 != this->experimentInputs.end(); ++_iter118) { - xfer += (*_iter106).write(oprot); + xfer += (*_iter118).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } if (this->__isset.experimentOutputs) { - xfer += oprot->writeFieldBegin("experimentOutputs", ::apache::thrift::protocol::T_LIST, 14); + xfer += oprot->writeFieldBegin("experimentOutputs", ::apache::thrift::protocol::T_LIST, 16); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->experimentOutputs.size())); - std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter107; - for (_iter107 = this->experimentOutputs.begin(); _iter107 != this->experimentOutputs.end(); ++_iter107) + std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter119; + for (_iter119 = this->experimentOutputs.begin(); _iter119 != this->experimentOutputs.end(); ++_iter119) { - xfer += (*_iter107).write(oprot); + xfer += (*_iter119).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } if (this->__isset.experimentStatus) { - xfer += oprot->writeFieldBegin("experimentStatus", ::apache::thrift::protocol::T_STRUCT, 15); + xfer += oprot->writeFieldBegin("experimentStatus", ::apache::thrift::protocol::T_STRUCT, 17); xfer += this->experimentStatus.write(oprot); xfer += oprot->writeFieldEnd(); } if (this->__isset.stateChangeList) { - xfer += oprot->writeFieldBegin("stateChangeList", ::apache::thrift::protocol::T_LIST, 16); + xfer += oprot->writeFieldBegin("stateChangeList", ::apache::thrift::protocol::T_LIST, 18); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->stateChangeList.size())); - std::vector<WorkflowNodeStatus> ::const_iterator _iter108; - for (_iter108 = this->stateChangeList.begin(); _iter108 != this->stateChangeList.end(); ++_iter108) + std::vector<WorkflowNodeStatus> ::const_iterator _iter120; + for (_iter120 = this->stateChangeList.begin(); _iter120 != this->stateChangeList.end(); ++_iter120) { - xfer += (*_iter108).write(oprot); + xfer += (*_iter120).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } if (this->__isset.workflowNodeDetailsList) { - xfer += oprot->writeFieldBegin("workflowNodeDetailsList", ::apache::thrift::protocol::T_LIST, 17); + xfer += oprot->writeFieldBegin("workflowNodeDetailsList", ::apache::thrift::protocol::T_LIST, 19); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->workflowNodeDetailsList.size())); - std::vector<WorkflowNodeDetails> ::const_iterator _iter109; - for (_iter109 = this->workflowNodeDetailsList.begin(); _iter109 != this->workflowNodeDetailsList.end(); ++_iter109) + std::vector<WorkflowNodeDetails> ::const_iterator _iter121; + for (_iter121 = this->workflowNodeDetailsList.begin(); _iter121 != this->workflowNodeDetailsList.end(); ++_iter121) { - xfer += (*_iter109).write(oprot); + xfer += (*_iter121).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } if (this->__isset.errors) { - xfer += oprot->writeFieldBegin("errors", ::apache::thrift::protocol::T_LIST, 18); + xfer += oprot->writeFieldBegin("errors", ::apache::thrift::protocol::T_LIST, 20); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->errors.size())); - std::vector<ErrorDetails> ::const_iterator _iter110; - for (_iter110 = this->errors.begin(); _iter110 != this->errors.end(); ++_iter110) + std::vector<ErrorDetails> ::const_iterator _iter122; + for (_iter122 = this->errors.begin(); _iter122 != this->errors.end(); ++_iter122) { - xfer += (*_iter110).write(oprot); + xfer += (*_iter122).write(oprot); } xfer += oprot->writeListEnd(); } @@ -3044,6 +3138,8 @@ void swap(Experiment &a, Experiment &b) { swap(a.applicationVersion, b.applicationVersion); swap(a.workflowTemplateId, b.workflowTemplateId); swap(a.workflowTemplateVersion, b.workflowTemplateVersion); + swap(a.enableEmailNotification, b.enableEmailNotification); + swap(a.emailAddresses, b.emailAddresses); swap(a.userConfigurationData, b.userConfigurationData); swap(a.workflowExecutionInstanceId, b.workflowExecutionInstanceId); swap(a.experimentInputs, b.experimentInputs); @@ -3150,14 +3246,14 @@ uint32_t ExperimentSummary::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->errors.clear(); - uint32_t _size111; - ::apache::thrift::protocol::TType _etype114; - xfer += iprot->readListBegin(_etype114, _size111); - this->errors.resize(_size111); - uint32_t _i115; - for (_i115 = 0; _i115 < _size111; ++_i115) + uint32_t _size123; + ::apache::thrift::protocol::TType _etype126; + xfer += iprot->readListBegin(_etype126, _size123); + this->errors.resize(_size123); + uint32_t _i127; + for (_i127 = 0; _i127 < _size123; ++_i127) { - xfer += this->errors[_i115].read(iprot); + xfer += this->errors[_i127].read(iprot); } xfer += iprot->readListEnd(); } @@ -3230,10 +3326,10 @@ uint32_t ExperimentSummary::write(::apache::thrift::protocol::TProtocol* oprot) xfer += oprot->writeFieldBegin("errors", ::apache::thrift::protocol::T_LIST, 9); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->errors.size())); - std::vector<ErrorDetails> ::const_iterator _iter116; - for (_iter116 = this->errors.begin(); _iter116 != this->errors.end(); ++_iter116) + std::vector<ErrorDetails> ::const_iterator _iter128; + for (_iter128 = this->errors.begin(); _iter128 != this->errors.end(); ++_iter128) { - xfer += (*_iter116).write(oprot); + xfer += (*_iter128).write(oprot); } xfer += oprot->writeListEnd(); } http://git-wip-us.apache.org/repos/asf/airavata/blob/7a6fbdb2/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.h index b5e1e57..1b5306e 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/experimentModel_types.h @@ -1275,7 +1275,7 @@ class DataTransferDetails { void swap(DataTransferDetails &a, DataTransferDetails &b); typedef struct _TaskDetails__isset { - _TaskDetails__isset() : creationTime(false), applicationId(false), applicationVersion(false), applicationDeploymentId(false), applicationInputs(false), applicationOutputs(false), taskScheduling(false), advancedInputDataHandling(false), advancedOutputDataHandling(false), taskStatus(false), jobDetailsList(false), dataTransferDetailsList(false), errors(false) {} + _TaskDetails__isset() : creationTime(false), applicationId(false), applicationVersion(false), applicationDeploymentId(false), applicationInputs(false), applicationOutputs(false), taskScheduling(false), advancedInputDataHandling(false), advancedOutputDataHandling(false), taskStatus(false), jobDetailsList(false), dataTransferDetailsList(false), errors(false), enableEmailNotification(false), emailAddresses(false) {} bool creationTime; bool applicationId; bool applicationVersion; @@ -1289,15 +1289,17 @@ typedef struct _TaskDetails__isset { bool jobDetailsList; bool dataTransferDetailsList; bool errors; + bool enableEmailNotification; + bool emailAddresses; } _TaskDetails__isset; class TaskDetails { public: - static const char* ascii_fingerprint; // = "6FF0ECF6FE53D283757211BADE659108"; - static const uint8_t binary_fingerprint[16]; // = {0x6F,0xF0,0xEC,0xF6,0xFE,0x53,0xD2,0x83,0x75,0x72,0x11,0xBA,0xDE,0x65,0x91,0x08}; + static const char* ascii_fingerprint; // = "6EAEEB62655ECD5CA7A24BFDE46F678C"; + static const uint8_t binary_fingerprint[16]; // = {0x6E,0xAE,0xEB,0x62,0x65,0x5E,0xCD,0x5C,0xA7,0xA2,0x4B,0xFD,0xE4,0x6F,0x67,0x8C}; - TaskDetails() : taskID("DO_NOT_SET_AT_CLIENTS"), creationTime(0), applicationId(), applicationVersion(), applicationDeploymentId() { + TaskDetails() : taskID("DO_NOT_SET_AT_CLIENTS"), creationTime(0), applicationId(), applicationVersion(), applicationDeploymentId(), enableEmailNotification(0) { } virtual ~TaskDetails() throw() {} @@ -1316,6 +1318,8 @@ class TaskDetails { std::vector<JobDetails> jobDetailsList; std::vector<DataTransferDetails> dataTransferDetailsList; std::vector<ErrorDetails> errors; + bool enableEmailNotification; + std::vector<std::string> emailAddresses; _TaskDetails__isset __isset; @@ -1388,6 +1392,16 @@ class TaskDetails { __isset.errors = true; } + void __set_enableEmailNotification(const bool val) { + enableEmailNotification = val; + __isset.enableEmailNotification = true; + } + + void __set_emailAddresses(const std::vector<std::string> & val) { + emailAddresses = val; + __isset.emailAddresses = true; + } + bool operator == (const TaskDetails & rhs) const { if (!(taskID == rhs.taskID)) @@ -1444,6 +1458,14 @@ class TaskDetails { return false; else if (__isset.errors && !(errors == rhs.errors)) 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 TaskDetails &rhs) const { @@ -1473,8 +1495,8 @@ typedef struct _WorkflowNodeDetails__isset { class WorkflowNodeDetails { public: - static const char* ascii_fingerprint; // = "D2AF8FCCA5B9C08220AE508BA2D7FB06"; - static const uint8_t binary_fingerprint[16]; // = {0xD2,0xAF,0x8F,0xCC,0xA5,0xB9,0xC0,0x82,0x20,0xAE,0x50,0x8B,0xA2,0xD7,0xFB,0x06}; + static const char* ascii_fingerprint; // = "CDDA44A784FD60829B4F4EAA67D71C72"; + static const uint8_t binary_fingerprint[16]; // = {0xCD,0xDA,0x44,0xA7,0x84,0xFD,0x60,0x82,0x9B,0x4F,0x4E,0xAA,0x67,0xD7,0x1C,0x72}; WorkflowNodeDetails() : nodeInstanceId("DO_NOT_SET_AT_CLIENTS"), creationTime(0), nodeName("SINGLE_APP_NODE"), executionUnit((ExecutionUnit::type)1), executionUnitData() { executionUnit = (ExecutionUnit::type)1; @@ -1692,13 +1714,15 @@ class ValidationResults { void swap(ValidationResults &a, ValidationResults &b); typedef struct _Experiment__isset { - _Experiment__isset() : creationTime(false), description(false), applicationId(false), applicationVersion(false), workflowTemplateId(false), workflowTemplateVersion(false), userConfigurationData(false), workflowExecutionInstanceId(false), experimentInputs(false), experimentOutputs(false), experimentStatus(false), stateChangeList(false), workflowNodeDetailsList(false), errors(false) {} + _Experiment__isset() : creationTime(false), description(false), applicationId(false), applicationVersion(false), workflowTemplateId(false), workflowTemplateVersion(false), enableEmailNotification(false), emailAddresses(false), userConfigurationData(false), workflowExecutionInstanceId(false), experimentInputs(false), experimentOutputs(false), experimentStatus(false), stateChangeList(false), workflowNodeDetailsList(false), errors(false) {} bool creationTime; bool description; bool applicationId; bool applicationVersion; bool workflowTemplateId; bool workflowTemplateVersion; + bool enableEmailNotification; + bool emailAddresses; bool userConfigurationData; bool workflowExecutionInstanceId; bool experimentInputs; @@ -1712,10 +1736,10 @@ typedef struct _Experiment__isset { class Experiment { public: - static const char* ascii_fingerprint; // = "4CE20099975A60F2FE0D6D1139972D1A"; - static const uint8_t binary_fingerprint[16]; // = {0x4C,0xE2,0x00,0x99,0x97,0x5A,0x60,0xF2,0xFE,0x0D,0x6D,0x11,0x39,0x97,0x2D,0x1A}; + static const char* ascii_fingerprint; // = "145D3134FA7C46D3D99051850C4984FF"; + static const uint8_t binary_fingerprint[16]; // = {0x14,0x5D,0x31,0x34,0xFA,0x7C,0x46,0xD3,0xD9,0x90,0x51,0x85,0x0C,0x49,0x84,0xFF}; - Experiment() : experimentID("DO_NOT_SET_AT_CLIENTS"), projectID("DEFAULT"), creationTime(0), userName(), name(), description(), applicationId(), applicationVersion(), workflowTemplateId(), workflowTemplateVersion(), workflowExecutionInstanceId() { + Experiment() : experimentID("DO_NOT_SET_AT_CLIENTS"), projectID("DEFAULT"), creationTime(0), userName(), name(), description(), applicationId(), applicationVersion(), workflowTemplateId(), workflowTemplateVersion(), enableEmailNotification(0), workflowExecutionInstanceId() { } virtual ~Experiment() throw() {} @@ -1730,6 +1754,8 @@ class Experiment { std::string applicationVersion; std::string workflowTemplateId; std::string workflowTemplateVersion; + bool enableEmailNotification; + std::vector<std::string> emailAddresses; UserConfigurationData userConfigurationData; std::string workflowExecutionInstanceId; std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> experimentInputs; @@ -1787,6 +1813,16 @@ class Experiment { __isset.workflowTemplateVersion = true; } + void __set_enableEmailNotification(const bool val) { + enableEmailNotification = val; + __isset.enableEmailNotification = true; + } + + void __set_emailAddresses(const std::vector<std::string> & val) { + emailAddresses = val; + __isset.emailAddresses = true; + } + void __set_userConfigurationData(const UserConfigurationData& val) { userConfigurationData = val; __isset.userConfigurationData = true; @@ -1861,6 +1897,14 @@ class Experiment { return false; else if (__isset.workflowTemplateVersion && !(workflowTemplateVersion == rhs.workflowTemplateVersion)) 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; if (__isset.userConfigurationData != rhs.__isset.userConfigurationData) return false; else if (__isset.userConfigurationData && !(userConfigurationData == rhs.userConfigurationData)) http://git-wip-us.apache.org/repos/asf/airavata/blob/7a6fbdb2/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Workspace/Experiment/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Workspace/Experiment/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Workspace/Experiment/Types.php index c6037f7..1fbcd0b 100644 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Workspace/Experiment/Types.php +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Workspace/Experiment/Types.php @@ -2250,6 +2250,8 @@ class TaskDetails { public $jobDetailsList = null; public $dataTransferDetailsList = null; public $errors = null; + public $enableEmailNotification = null; + public $emailAddresses = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -2339,6 +2341,18 @@ class TaskDetails { 'class' => '\Airavata\Model\Workspace\Experiment\ErrorDetails', ), ), + 15 => array( + 'var' => 'enableEmailNotification', + 'type' => TType::BOOL, + ), + 16 => array( + 'var' => 'emailAddresses', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), ); } if (is_array($vals)) { @@ -2384,6 +2398,12 @@ class TaskDetails { if (isset($vals['errors'])) { $this->errors = $vals['errors']; } + if (isset($vals['enableEmailNotification'])) { + $this->enableEmailNotification = $vals['enableEmailNotification']; + } + if (isset($vals['emailAddresses'])) { + $this->emailAddresses = $vals['emailAddresses']; + } } } @@ -2563,6 +2583,30 @@ class TaskDetails { $xfer += $input->skip($ftype); } break; + case 15: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->enableEmailNotification); + } else { + $xfer += $input->skip($ftype); + } + break; + case 16: + if ($ftype == TType::LST) { + $this->emailAddresses = array(); + $_size44 = 0; + $_etype47 = 0; + $xfer += $input->readListBegin($_etype47, $_size44); + for ($_i48 = 0; $_i48 < $_size44; ++$_i48) + { + $elem49 = null; + $xfer += $input->readString($elem49); + $this->emailAddresses []= $elem49; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -2609,9 +2653,9 @@ class TaskDetails { { $output->writeListBegin(TType::STRUCT, count($this->applicationInputs)); { - foreach ($this->applicationInputs as $iter44) + foreach ($this->applicationInputs as $iter50) { - $xfer += $iter44->write($output); + $xfer += $iter50->write($output); } } $output->writeListEnd(); @@ -2626,9 +2670,9 @@ class TaskDetails { { $output->writeListBegin(TType::STRUCT, count($this->applicationOutputs)); { - foreach ($this->applicationOutputs as $iter45) + foreach ($this->applicationOutputs as $iter51) { - $xfer += $iter45->write($output); + $xfer += $iter51->write($output); } } $output->writeListEnd(); @@ -2675,9 +2719,9 @@ class TaskDetails { { $output->writeListBegin(TType::STRUCT, count($this->jobDetailsList)); { - foreach ($this->jobDetailsList as $iter46) + foreach ($this->jobDetailsList as $iter52) { - $xfer += $iter46->write($output); + $xfer += $iter52->write($output); } } $output->writeListEnd(); @@ -2692,9 +2736,9 @@ class TaskDetails { { $output->writeListBegin(TType::STRUCT, count($this->dataTransferDetailsList)); { - foreach ($this->dataTransferDetailsList as $iter47) + foreach ($this->dataTransferDetailsList as $iter53) { - $xfer += $iter47->write($output); + $xfer += $iter53->write($output); } } $output->writeListEnd(); @@ -2709,9 +2753,31 @@ class TaskDetails { { $output->writeListBegin(TType::STRUCT, count($this->errors)); { - foreach ($this->errors as $iter48) + foreach ($this->errors as $iter54) { - $xfer += $iter48->write($output); + $xfer += $iter54->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + if ($this->enableEmailNotification !== null) { + $xfer += $output->writeFieldBegin('enableEmailNotification', TType::BOOL, 15); + $xfer += $output->writeBool($this->enableEmailNotification); + $xfer += $output->writeFieldEnd(); + } + if ($this->emailAddresses !== null) { + if (!is_array($this->emailAddresses)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('emailAddresses', TType::LST, 16); + { + $output->writeListBegin(TType::STRING, count($this->emailAddresses)); + { + foreach ($this->emailAddresses as $iter55) + { + $xfer += $output->writeString($iter55); } } $output->writeListEnd(); @@ -2896,15 +2962,15 @@ class WorkflowNodeDetails { case 6: if ($ftype == TType::LST) { $this->nodeInputs = array(); - $_size49 = 0; - $_etype52 = 0; - $xfer += $input->readListBegin($_etype52, $_size49); - for ($_i53 = 0; $_i53 < $_size49; ++$_i53) + $_size56 = 0; + $_etype59 = 0; + $xfer += $input->readListBegin($_etype59, $_size56); + for ($_i60 = 0; $_i60 < $_size56; ++$_i60) { - $elem54 = null; - $elem54 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType(); - $xfer += $elem54->read($input); - $this->nodeInputs []= $elem54; + $elem61 = null; + $elem61 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType(); + $xfer += $elem61->read($input); + $this->nodeInputs []= $elem61; } $xfer += $input->readListEnd(); } else { @@ -2914,15 +2980,15 @@ class WorkflowNodeDetails { case 7: if ($ftype == TType::LST) { $this->nodeOutputs = array(); - $_size55 = 0; - $_etype58 = 0; - $xfer += $input->readListBegin($_etype58, $_size55); - for ($_i59 = 0; $_i59 < $_size55; ++$_i59) + $_size62 = 0; + $_etype65 = 0; + $xfer += $input->readListBegin($_etype65, $_size62); + for ($_i66 = 0; $_i66 < $_size62; ++$_i66) { - $elem60 = null; - $elem60 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType(); - $xfer += $elem60->read($input); - $this->nodeOutputs []= $elem60; + $elem67 = null; + $elem67 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType(); + $xfer += $elem67->read($input); + $this->nodeOutputs []= $elem67; } $xfer += $input->readListEnd(); } else { @@ -2940,15 +3006,15 @@ class WorkflowNodeDetails { case 9: if ($ftype == TType::LST) { $this->taskDetailsList = array(); - $_size61 = 0; - $_etype64 = 0; - $xfer += $input->readListBegin($_etype64, $_size61); - for ($_i65 = 0; $_i65 < $_size61; ++$_i65) + $_size68 = 0; + $_etype71 = 0; + $xfer += $input->readListBegin($_etype71, $_size68); + for ($_i72 = 0; $_i72 < $_size68; ++$_i72) { - $elem66 = null; - $elem66 = new \Airavata\Model\Workspace\Experiment\TaskDetails(); - $xfer += $elem66->read($input); - $this->taskDetailsList []= $elem66; + $elem73 = null; + $elem73 = new \Airavata\Model\Workspace\Experiment\TaskDetails(); + $xfer += $elem73->read($input); + $this->taskDetailsList []= $elem73; } $xfer += $input->readListEnd(); } else { @@ -2958,15 +3024,15 @@ class WorkflowNodeDetails { case 10: if ($ftype == TType::LST) { $this->errors = array(); - $_size67 = 0; - $_etype70 = 0; - $xfer += $input->readListBegin($_etype70, $_size67); - for ($_i71 = 0; $_i71 < $_size67; ++$_i71) + $_size74 = 0; + $_etype77 = 0; + $xfer += $input->readListBegin($_etype77, $_size74); + for ($_i78 = 0; $_i78 < $_size74; ++$_i78) { - $elem72 = null; - $elem72 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); - $xfer += $elem72->read($input); - $this->errors []= $elem72; + $elem79 = null; + $elem79 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); + $xfer += $elem79->read($input); + $this->errors []= $elem79; } $xfer += $input->readListEnd(); } else { @@ -3019,9 +3085,9 @@ class WorkflowNodeDetails { { $output->writeListBegin(TType::STRUCT, count($this->nodeInputs)); { - foreach ($this->nodeInputs as $iter73) + foreach ($this->nodeInputs as $iter80) { - $xfer += $iter73->write($output); + $xfer += $iter80->write($output); } } $output->writeListEnd(); @@ -3036,9 +3102,9 @@ class WorkflowNodeDetails { { $output->writeListBegin(TType::STRUCT, count($this->nodeOutputs)); { - foreach ($this->nodeOutputs as $iter74) + foreach ($this->nodeOutputs as $iter81) { - $xfer += $iter74->write($output); + $xfer += $iter81->write($output); } } $output->writeListEnd(); @@ -3061,9 +3127,9 @@ class WorkflowNodeDetails { { $output->writeListBegin(TType::STRUCT, count($this->taskDetailsList)); { - foreach ($this->taskDetailsList as $iter75) + foreach ($this->taskDetailsList as $iter82) { - $xfer += $iter75->write($output); + $xfer += $iter82->write($output); } } $output->writeListEnd(); @@ -3078,9 +3144,9 @@ class WorkflowNodeDetails { { $output->writeListBegin(TType::STRUCT, count($this->errors)); { - foreach ($this->errors as $iter76) + foreach ($this->errors as $iter83) { - $xfer += $iter76->write($output); + $xfer += $iter83->write($output); } } $output->writeListEnd(); @@ -3249,15 +3315,15 @@ class ValidationResults { case 2: if ($ftype == TType::LST) { $this->validationResultList = array(); - $_size77 = 0; - $_etype80 = 0; - $xfer += $input->readListBegin($_etype80, $_size77); - for ($_i81 = 0; $_i81 < $_size77; ++$_i81) + $_size84 = 0; + $_etype87 = 0; + $xfer += $input->readListBegin($_etype87, $_size84); + for ($_i88 = 0; $_i88 < $_size84; ++$_i88) { - $elem82 = null; - $elem82 = new \Airavata\Model\Workspace\Experiment\ValidatorResult(); - $xfer += $elem82->read($input); - $this->validationResultList []= $elem82; + $elem89 = null; + $elem89 = new \Airavata\Model\Workspace\Experiment\ValidatorResult(); + $xfer += $elem89->read($input); + $this->validationResultList []= $elem89; } $xfer += $input->readListEnd(); } else { @@ -3290,9 +3356,9 @@ class ValidationResults { { $output->writeListBegin(TType::STRUCT, count($this->validationResultList)); { - foreach ($this->validationResultList as $iter83) + foreach ($this->validationResultList as $iter90) { - $xfer += $iter83->write($output); + $xfer += $iter90->write($output); } } $output->writeListEnd(); @@ -3319,6 +3385,8 @@ class Experiment { public $applicationVersion = null; public $workflowTemplateId = null; public $workflowTemplateVersion = null; + public $enableEmailNotification = null; + public $emailAddresses = null; public $userConfigurationData = null; public $workflowExecutionInstanceId = null; public $experimentInputs = null; @@ -3372,15 +3440,27 @@ class Experiment { 'type' => TType::STRING, ), 11 => array( + 'var' => 'enableEmailNotification', + 'type' => TType::BOOL, + ), + 12 => array( + 'var' => 'emailAddresses', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), + 13 => array( 'var' => 'userConfigurationData', 'type' => TType::STRUCT, 'class' => '\Airavata\Model\Workspace\Experiment\UserConfigurationData', ), - 12 => array( + 14 => array( 'var' => 'workflowExecutionInstanceId', 'type' => TType::STRING, ), - 13 => array( + 15 => array( 'var' => 'experimentInputs', 'type' => TType::LST, 'etype' => TType::STRUCT, @@ -3389,7 +3469,7 @@ class Experiment { 'class' => '\Airavata\Model\AppCatalog\AppInterface\InputDataObjectType', ), ), - 14 => array( + 16 => array( 'var' => 'experimentOutputs', 'type' => TType::LST, 'etype' => TType::STRUCT, @@ -3398,12 +3478,12 @@ class Experiment { 'class' => '\Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType', ), ), - 15 => array( + 17 => array( 'var' => 'experimentStatus', 'type' => TType::STRUCT, 'class' => '\Airavata\Model\Workspace\Experiment\ExperimentStatus', ), - 16 => array( + 18 => array( 'var' => 'stateChangeList', 'type' => TType::LST, 'etype' => TType::STRUCT, @@ -3412,7 +3492,7 @@ class Experiment { 'class' => '\Airavata\Model\Workspace\Experiment\WorkflowNodeStatus', ), ), - 17 => array( + 19 => array( 'var' => 'workflowNodeDetailsList', 'type' => TType::LST, 'etype' => TType::STRUCT, @@ -3421,7 +3501,7 @@ class Experiment { 'class' => '\Airavata\Model\Workspace\Experiment\WorkflowNodeDetails', ), ), - 18 => array( + 20 => array( 'var' => 'errors', 'type' => TType::LST, 'etype' => TType::STRUCT, @@ -3463,6 +3543,12 @@ class Experiment { if (isset($vals['workflowTemplateVersion'])) { $this->workflowTemplateVersion = $vals['workflowTemplateVersion']; } + if (isset($vals['enableEmailNotification'])) { + $this->enableEmailNotification = $vals['enableEmailNotification']; + } + if (isset($vals['emailAddresses'])) { + $this->emailAddresses = $vals['emailAddresses']; + } if (isset($vals['userConfigurationData'])) { $this->userConfigurationData = $vals['userConfigurationData']; } @@ -3580,6 +3666,30 @@ class Experiment { } break; case 11: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->enableEmailNotification); + } else { + $xfer += $input->skip($ftype); + } + break; + case 12: + if ($ftype == TType::LST) { + $this->emailAddresses = array(); + $_size91 = 0; + $_etype94 = 0; + $xfer += $input->readListBegin($_etype94, $_size91); + for ($_i95 = 0; $_i95 < $_size91; ++$_i95) + { + $elem96 = null; + $xfer += $input->readString($elem96); + $this->emailAddresses []= $elem96; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + case 13: if ($ftype == TType::STRUCT) { $this->userConfigurationData = new \Airavata\Model\Workspace\Experiment\UserConfigurationData(); $xfer += $this->userConfigurationData->read($input); @@ -3587,50 +3697,50 @@ class Experiment { $xfer += $input->skip($ftype); } break; - case 12: + case 14: if ($ftype == TType::STRING) { $xfer += $input->readString($this->workflowExecutionInstanceId); } else { $xfer += $input->skip($ftype); } break; - case 13: + case 15: if ($ftype == TType::LST) { $this->experimentInputs = array(); - $_size84 = 0; - $_etype87 = 0; - $xfer += $input->readListBegin($_etype87, $_size84); - for ($_i88 = 0; $_i88 < $_size84; ++$_i88) + $_size97 = 0; + $_etype100 = 0; + $xfer += $input->readListBegin($_etype100, $_size97); + for ($_i101 = 0; $_i101 < $_size97; ++$_i101) { - $elem89 = null; - $elem89 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType(); - $xfer += $elem89->read($input); - $this->experimentInputs []= $elem89; + $elem102 = null; + $elem102 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType(); + $xfer += $elem102->read($input); + $this->experimentInputs []= $elem102; } $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } break; - case 14: + case 16: if ($ftype == TType::LST) { $this->experimentOutputs = array(); - $_size90 = 0; - $_etype93 = 0; - $xfer += $input->readListBegin($_etype93, $_size90); - for ($_i94 = 0; $_i94 < $_size90; ++$_i94) + $_size103 = 0; + $_etype106 = 0; + $xfer += $input->readListBegin($_etype106, $_size103); + for ($_i107 = 0; $_i107 < $_size103; ++$_i107) { - $elem95 = null; - $elem95 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType(); - $xfer += $elem95->read($input); - $this->experimentOutputs []= $elem95; + $elem108 = null; + $elem108 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType(); + $xfer += $elem108->read($input); + $this->experimentOutputs []= $elem108; } $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } break; - case 15: + case 17: if ($ftype == TType::STRUCT) { $this->experimentStatus = new \Airavata\Model\Workspace\Experiment\ExperimentStatus(); $xfer += $this->experimentStatus->read($input); @@ -3638,54 +3748,54 @@ class Experiment { $xfer += $input->skip($ftype); } break; - case 16: + case 18: if ($ftype == TType::LST) { $this->stateChangeList = array(); - $_size96 = 0; - $_etype99 = 0; - $xfer += $input->readListBegin($_etype99, $_size96); - for ($_i100 = 0; $_i100 < $_size96; ++$_i100) + $_size109 = 0; + $_etype112 = 0; + $xfer += $input->readListBegin($_etype112, $_size109); + for ($_i113 = 0; $_i113 < $_size109; ++$_i113) { - $elem101 = null; - $elem101 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeStatus(); - $xfer += $elem101->read($input); - $this->stateChangeList []= $elem101; + $elem114 = null; + $elem114 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeStatus(); + $xfer += $elem114->read($input); + $this->stateChangeList []= $elem114; } $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } break; - case 17: + case 19: if ($ftype == TType::LST) { $this->workflowNodeDetailsList = array(); - $_size102 = 0; - $_etype105 = 0; - $xfer += $input->readListBegin($_etype105, $_size102); - for ($_i106 = 0; $_i106 < $_size102; ++$_i106) + $_size115 = 0; + $_etype118 = 0; + $xfer += $input->readListBegin($_etype118, $_size115); + for ($_i119 = 0; $_i119 < $_size115; ++$_i119) { - $elem107 = null; - $elem107 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeDetails(); - $xfer += $elem107->read($input); - $this->workflowNodeDetailsList []= $elem107; + $elem120 = null; + $elem120 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeDetails(); + $xfer += $elem120->read($input); + $this->workflowNodeDetailsList []= $elem120; } $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } break; - case 18: + case 20: if ($ftype == TType::LST) { $this->errors = array(); - $_size108 = 0; - $_etype111 = 0; - $xfer += $input->readListBegin($_etype111, $_size108); - for ($_i112 = 0; $_i112 < $_size108; ++$_i112) + $_size121 = 0; + $_etype124 = 0; + $xfer += $input->readListBegin($_etype124, $_size121); + for ($_i125 = 0; $_i125 < $_size121; ++$_i125) { - $elem113 = null; - $elem113 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); - $xfer += $elem113->read($input); - $this->errors []= $elem113; + $elem126 = null; + $elem126 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); + $xfer += $elem126->read($input); + $this->errors []= $elem126; } $xfer += $input->readListEnd(); } else { @@ -3755,16 +3865,38 @@ class Experiment { $xfer += $output->writeString($this->workflowTemplateVersion); $xfer += $output->writeFieldEnd(); } + if ($this->enableEmailNotification !== null) { + $xfer += $output->writeFieldBegin('enableEmailNotification', TType::BOOL, 11); + $xfer += $output->writeBool($this->enableEmailNotification); + $xfer += $output->writeFieldEnd(); + } + if ($this->emailAddresses !== null) { + if (!is_array($this->emailAddresses)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('emailAddresses', TType::LST, 12); + { + $output->writeListBegin(TType::STRING, count($this->emailAddresses)); + { + foreach ($this->emailAddresses as $iter127) + { + $xfer += $output->writeString($iter127); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } if ($this->userConfigurationData !== null) { if (!is_object($this->userConfigurationData)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('userConfigurationData', TType::STRUCT, 11); + $xfer += $output->writeFieldBegin('userConfigurationData', TType::STRUCT, 13); $xfer += $this->userConfigurationData->write($output); $xfer += $output->writeFieldEnd(); } if ($this->workflowExecutionInstanceId !== null) { - $xfer += $output->writeFieldBegin('workflowExecutionInstanceId', TType::STRING, 12); + $xfer += $output->writeFieldBegin('workflowExecutionInstanceId', TType::STRING, 14); $xfer += $output->writeString($this->workflowExecutionInstanceId); $xfer += $output->writeFieldEnd(); } @@ -3772,13 +3904,13 @@ class Experiment { if (!is_array($this->experimentInputs)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('experimentInputs', TType::LST, 13); + $xfer += $output->writeFieldBegin('experimentInputs', TType::LST, 15); { $output->writeListBegin(TType::STRUCT, count($this->experimentInputs)); { - foreach ($this->experimentInputs as $iter114) + foreach ($this->experimentInputs as $iter128) { - $xfer += $iter114->write($output); + $xfer += $iter128->write($output); } } $output->writeListEnd(); @@ -3789,13 +3921,13 @@ class Experiment { if (!is_array($this->experimentOutputs)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('experimentOutputs', TType::LST, 14); + $xfer += $output->writeFieldBegin('experimentOutputs', TType::LST, 16); { $output->writeListBegin(TType::STRUCT, count($this->experimentOutputs)); { - foreach ($this->experimentOutputs as $iter115) + foreach ($this->experimentOutputs as $iter129) { - $xfer += $iter115->write($output); + $xfer += $iter129->write($output); } } $output->writeListEnd(); @@ -3806,7 +3938,7 @@ class Experiment { if (!is_object($this->experimentStatus)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('experimentStatus', TType::STRUCT, 15); + $xfer += $output->writeFieldBegin('experimentStatus', TType::STRUCT, 17); $xfer += $this->experimentStatus->write($output); $xfer += $output->writeFieldEnd(); } @@ -3814,13 +3946,13 @@ class Experiment { if (!is_array($this->stateChangeList)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('stateChangeList', TType::LST, 16); + $xfer += $output->writeFieldBegin('stateChangeList', TType::LST, 18); { $output->writeListBegin(TType::STRUCT, count($this->stateChangeList)); { - foreach ($this->stateChangeList as $iter116) + foreach ($this->stateChangeList as $iter130) { - $xfer += $iter116->write($output); + $xfer += $iter130->write($output); } } $output->writeListEnd(); @@ -3831,13 +3963,13 @@ class Experiment { if (!is_array($this->workflowNodeDetailsList)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('workflowNodeDetailsList', TType::LST, 17); + $xfer += $output->writeFieldBegin('workflowNodeDetailsList', TType::LST, 19); { $output->writeListBegin(TType::STRUCT, count($this->workflowNodeDetailsList)); { - foreach ($this->workflowNodeDetailsList as $iter117) + foreach ($this->workflowNodeDetailsList as $iter131) { - $xfer += $iter117->write($output); + $xfer += $iter131->write($output); } } $output->writeListEnd(); @@ -3848,13 +3980,13 @@ class Experiment { if (!is_array($this->errors)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('errors', TType::LST, 18); + $xfer += $output->writeFieldBegin('errors', TType::LST, 20); { $output->writeListBegin(TType::STRUCT, count($this->errors)); { - foreach ($this->errors as $iter118) + foreach ($this->errors as $iter132) { - $xfer += $iter118->write($output); + $xfer += $iter132->write($output); } } $output->writeListEnd(); @@ -4038,15 +4170,15 @@ class ExperimentSummary { case 9: if ($ftype == TType::LST) { $this->errors = array(); - $_size119 = 0; - $_etype122 = 0; - $xfer += $input->readListBegin($_etype122, $_size119); - for ($_i123 = 0; $_i123 < $_size119; ++$_i123) + $_size133 = 0; + $_etype136 = 0; + $xfer += $input->readListBegin($_etype136, $_size133); + for ($_i137 = 0; $_i137 < $_size133; ++$_i137) { - $elem124 = null; - $elem124 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); - $xfer += $elem124->read($input); - $this->errors []= $elem124; + $elem138 = null; + $elem138 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); + $xfer += $elem138->read($input); + $this->errors []= $elem138; } $xfer += $input->readListEnd(); } else { @@ -4117,9 +4249,9 @@ class ExperimentSummary { { $output->writeListBegin(TType::STRUCT, count($this->errors)); { - foreach ($this->errors as $iter125) + foreach ($this->errors as $iter139) { - $xfer += $iter125->write($output); + $xfer += $iter139->write($output); } } $output->writeListEnd();
