Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3F17011545 for ; Mon, 30 Jun 2014 22:56:41 +0000 (UTC) Received: (qmail 17469 invoked by uid 500); 30 Jun 2014 22:56:41 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 17309 invoked by uid 500); 30 Jun 2014 22:56:41 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 17069 invoked by uid 99); 30 Jun 2014 22:56:40 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 30 Jun 2014 22:56:40 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 7B9FB990306; Mon, 30 Jun 2014 22:56:40 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: smarru@apache.org To: commits@airavata.apache.org Date: Mon, 30 Jun 2014 22:56:41 -0000 Message-Id: In-Reply-To: <55eeda5581b6463eafd88ea7e43a4f12@git.apache.org> References: <55eeda5581b6463eafd88ea7e43a4f12@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [02/50] [abbrv] git commit: updated lib updated lib Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/1fd52a12 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/1fd52a12 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/1fd52a12 Branch: refs/heads/master Commit: 1fd52a12dd915a8ae7d07fd59456e34cb1e1f8f8 Parents: 44ebc62 Author: raminder Authored: Wed May 21 11:57:14 2014 -0400 Committer: raminder Committed: Wed May 21 11:57:14 2014 -0400 ---------------------------------------------------------------------- lib/Airavata/API/Airavata.php | 25 + .../API/AppCatalog/ApplicationCatalogAPI.php | 634 ++++++++++++++++++- lib/Airavata/API/Error/Types.php | 309 +++++++++ .../Model/Workspace/Experiment/Types.php | 312 +++++++-- 4 files changed, 1210 insertions(+), 70 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/1fd52a12/lib/Airavata/API/Airavata.php ---------------------------------------------------------------------- diff --git a/lib/Airavata/API/Airavata.php b/lib/Airavata/API/Airavata.php index f5661c0..8600d83 100644 --- a/lib/Airavata/API/Airavata.php +++ b/lib/Airavata/API/Airavata.php @@ -859,6 +859,9 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ase !== null) { throw $result->ase; } + if ($result->lve !== null) { + throw $result->lve; + } return; } @@ -3930,6 +3933,7 @@ class Airavata_launchExperiment_result { public $enf = null; public $ace = null; public $ase = null; + public $lve = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -3954,6 +3958,11 @@ class Airavata_launchExperiment_result { 'type' => TType::STRUCT, 'class' => '\Airavata\API\Error\AiravataSystemException', ), + 5 => array( + 'var' => 'lve', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\LaunchValidationException', + ), ); } if (is_array($vals)) { @@ -3969,6 +3978,9 @@ class Airavata_launchExperiment_result { if (isset($vals['ase'])) { $this->ase = $vals['ase']; } + if (isset($vals['lve'])) { + $this->lve = $vals['lve']; + } } } @@ -4023,6 +4035,14 @@ class Airavata_launchExperiment_result { $xfer += $input->skip($ftype); } break; + case 5: + if ($ftype == TType::STRUCT) { + $this->lve = new \Airavata\API\Error\LaunchValidationException(); + $xfer += $this->lve->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -4056,6 +4076,11 @@ class Airavata_launchExperiment_result { $xfer += $this->ase->write($output); $xfer += $output->writeFieldEnd(); } + if ($this->lve !== null) { + $xfer += $output->writeFieldBegin('lve', TType::STRUCT, 5); + $xfer += $this->lve->write($output); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; http://git-wip-us.apache.org/repos/asf/airavata/blob/1fd52a12/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php ---------------------------------------------------------------------- diff --git a/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php b/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php index de7f2b1..6f5a3a9 100644 --- a/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php +++ b/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php @@ -23,20 +23,22 @@ interface ApplicationCatalogAPIIf { public function addGSISSHJobSubmissionProtocol($computeResourceId, \GSISSHJobSubmission $jobSubmission); public function addGlobusJobSubmissionProtocol($computeResourceId, \GlobusJobSubmission $jobSubmission); public function addSCPDataMovementProtocol($computeResourceId, \SCPDataMovement $dataMovement); + public function addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement); public function listComputeResourceDescriptions(); public function getComputeResourceDescription($computeResourceId); public function getSSHJobSubmissionProtocol($sshJobSubmissionProtocolResourceId); public function getGSISSHJobSubmissionProtocol($gsisshJobSubmissionProtocolResourceId); public function getGlobusJobSubmissionProtocol($globusJobSubmissionProtocolResourceId); public function getSCPDataMovementProtocol($scpDataMovementResourceId); + public function getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId); public function isComputeResourceDescriptionRegistered($hostName); public function getComputeResourceDescriptionFromHostName($hostName); public function addApplicationInterface(\ApplicationInterface $applicationInterface); public function listApplicationInterfaceIds(); public function getApplicationInterface($applicationInterfaceId); public function addApplicationDeployment($applicationInterfaceId, \ApplicationDeployment $applicationDeployment); - public function listApplicationDeploymentIds(); - public function getApplicationDeployment($applicationDeploymentId); + public function listApplicationDeploymentIds($applicationInterfaceId); + public function getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId); } class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\ApplicationCatalogAPIIf { @@ -389,6 +391,64 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio return; } + public function addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement) + { + $this->send_addGridFTPDataMovementProtocol($computeResourceId, $dataMovement); + $this->recv_addGridFTPDataMovementProtocol(); + } + + public function send_addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement) + { + $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args(); + $args->computeResourceId = $computeResourceId; + $args->dataMovement = $dataMovement; + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'addGridFTPDataMovementProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('addGridFTPDataMovementProtocol', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_addGridFTPDataMovementProtocol() + { + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result', $this->input_->isStrictRead()); + else + { + $rseqid = 0; + $fname = null; + $mtype = 0; + + $this->input_->readMessageBegin($fname, $mtype, $rseqid); + if ($mtype == TMessageType::EXCEPTION) { + $x = new TApplicationException(); + $x->read($this->input_); + $this->input_->readMessageEnd(); + throw $x; + } + $result = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result(); + $result->read($this->input_); + $this->input_->readMessageEnd(); + } + if ($result->ire !== null) { + throw $result->ire; + } + if ($result->ace !== null) { + throw $result->ace; + } + if ($result->ase !== null) { + throw $result->ase; + } + return; + } + public function listComputeResourceDescriptions() { $this->send_listComputeResourceDescriptions(); @@ -748,6 +808,66 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio throw new \Exception("getSCPDataMovementProtocol failed: unknown result"); } + public function getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId) + { + $this->send_getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId); + return $this->recv_getGridFTPDataMovementProtocol(); + } + + public function send_getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId) + { + $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args(); + $args->gridFTPDataMovementResourceId = $gridFTPDataMovementResourceId; + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'getGridFTPDataMovementProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('getGridFTPDataMovementProtocol', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_getGridFTPDataMovementProtocol() + { + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\AppCatalog\ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result', $this->input_->isStrictRead()); + else + { + $rseqid = 0; + $fname = null; + $mtype = 0; + + $this->input_->readMessageBegin($fname, $mtype, $rseqid); + if ($mtype == TMessageType::EXCEPTION) { + $x = new TApplicationException(); + $x->read($this->input_); + $this->input_->readMessageEnd(); + throw $x; + } + $result = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result(); + $result->read($this->input_); + $this->input_->readMessageEnd(); + } + if ($result->success !== null) { + return $result->success; + } + if ($result->ire !== null) { + throw $result->ire; + } + if ($result->ace !== null) { + throw $result->ace; + } + if ($result->ase !== null) { + throw $result->ase; + } + throw new \Exception("getGridFTPDataMovementProtocol failed: unknown result"); + } + public function isComputeResourceDescriptionRegistered($hostName) { $this->send_isComputeResourceDescriptionRegistered($hostName); @@ -1102,15 +1222,16 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio return; } - public function listApplicationDeploymentIds() + public function listApplicationDeploymentIds($applicationInterfaceId) { - $this->send_listApplicationDeploymentIds(); + $this->send_listApplicationDeploymentIds($applicationInterfaceId); return $this->recv_listApplicationDeploymentIds(); } - public function send_listApplicationDeploymentIds() + public function send_listApplicationDeploymentIds($applicationInterfaceId) { $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_listApplicationDeploymentIds_args(); + $args->applicationInterfaceId = $applicationInterfaceId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { @@ -1161,15 +1282,16 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio throw new \Exception("listApplicationDeploymentIds failed: unknown result"); } - public function getApplicationDeployment($applicationDeploymentId) + public function getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId) { - $this->send_getApplicationDeployment($applicationDeploymentId); + $this->send_getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId); return $this->recv_getApplicationDeployment(); } - public function send_getApplicationDeployment($applicationDeploymentId) + public function send_getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId) { $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getApplicationDeployment_args(); + $args->applicationInterfaceId = $applicationInterfaceId; $args->applicationDeploymentId = $applicationDeploymentId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) @@ -2110,7 +2232,222 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result { } public function getName() { - return 'ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result'; + return 'ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::STRUCT) { + $this->ire = new \Airavata\API\Error\InvalidRequestException(); + $xfer += $this->ire->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRUCT) { + $this->ace = new \Airavata\API\Error\AiravataClientException(); + $xfer += $this->ace->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRUCT) { + $this->ase = new \Airavata\API\Error\AiravataSystemException(); + $xfer += $this->ase->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result'); + if ($this->ire !== null) { + $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1); + $xfer += $this->ire->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->ace !== null) { + $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2); + $xfer += $this->ace->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->ase !== null) { + $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3); + $xfer += $this->ase->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { + static $_TSPEC; + + public $computeResourceId = null; + public $dataMovement = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'computeResourceId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'dataMovement', + 'type' => TType::STRUCT, + 'class' => '\SCPDataMovement', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['computeResourceId'])) { + $this->computeResourceId = $vals['computeResourceId']; + } + if (isset($vals['dataMovement'])) { + $this->dataMovement = $vals['dataMovement']; + } + } + } + + public function getName() { + return 'ApplicationCatalogAPI_addSCPDataMovementProtocol_args'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->computeResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRUCT) { + $this->dataMovement = new \SCPDataMovement(); + $xfer += $this->dataMovement->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addSCPDataMovementProtocol_args'); + if ($this->computeResourceId !== null) { + $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1); + $xfer += $output->writeString($this->computeResourceId); + $xfer += $output->writeFieldEnd(); + } + if ($this->dataMovement !== null) { + if (!is_object($this->dataMovement)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('dataMovement', TType::STRUCT, 2); + $xfer += $this->dataMovement->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ApplicationCatalogAPI_addSCPDataMovementProtocol_result { + static $_TSPEC; + + public $ire = null; + public $ace = null; + public $ase = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'ire', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\InvalidRequestException', + ), + 2 => array( + 'var' => 'ace', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\AiravataClientException', + ), + 3 => array( + 'var' => 'ase', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\AiravataSystemException', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['ire'])) { + $this->ire = $vals['ire']; + } + if (isset($vals['ace'])) { + $this->ace = $vals['ace']; + } + if (isset($vals['ase'])) { + $this->ase = $vals['ase']; + } + } + } + + public function getName() { + return 'ApplicationCatalogAPI_addSCPDataMovementProtocol_result'; } public function read($input) @@ -2164,7 +2501,7 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result'); + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addSCPDataMovementProtocol_result'); if ($this->ire !== null) { $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1); $xfer += $this->ire->write($output); @@ -2187,7 +2524,7 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result { } -class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { +class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args { static $_TSPEC; public $computeResourceId = null; @@ -2203,7 +2540,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { 2 => array( 'var' => 'dataMovement', 'type' => TType::STRUCT, - 'class' => '\SCPDataMovement', + 'class' => '\GridFTPDataMovement', ), ); } @@ -2218,7 +2555,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { } public function getName() { - return 'ApplicationCatalogAPI_addSCPDataMovementProtocol_args'; + return 'ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args'; } public function read($input) @@ -2245,7 +2582,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { break; case 2: if ($ftype == TType::STRUCT) { - $this->dataMovement = new \SCPDataMovement(); + $this->dataMovement = new \GridFTPDataMovement(); $xfer += $this->dataMovement->read($input); } else { $xfer += $input->skip($ftype); @@ -2263,7 +2600,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addSCPDataMovementProtocol_args'); + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args'); if ($this->computeResourceId !== null) { $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1); $xfer += $output->writeString($this->computeResourceId); @@ -2284,7 +2621,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args { } -class ApplicationCatalogAPI_addSCPDataMovementProtocol_result { +class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result { static $_TSPEC; public $ire = null; @@ -2325,7 +2662,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result { } public function getName() { - return 'ApplicationCatalogAPI_addSCPDataMovementProtocol_result'; + return 'ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result'; } public function read($input) @@ -2379,7 +2716,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addSCPDataMovementProtocol_result'); + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result'); if ($this->ire !== null) { $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1); $xfer += $this->ire->write($output); @@ -3691,6 +4028,221 @@ class ApplicationCatalogAPI_getSCPDataMovementProtocol_result { } +class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args { + static $_TSPEC; + + public $gridFTPDataMovementResourceId = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'gridFTPDataMovementResourceId', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['gridFTPDataMovementResourceId'])) { + $this->gridFTPDataMovementResourceId = $vals['gridFTPDataMovementResourceId']; + } + } + } + + public function getName() { + return 'ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->gridFTPDataMovementResourceId); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args'); + if ($this->gridFTPDataMovementResourceId !== null) { + $xfer += $output->writeFieldBegin('gridFTPDataMovementResourceId', TType::STRING, 1); + $xfer += $output->writeString($this->gridFTPDataMovementResourceId); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result { + static $_TSPEC; + + public $success = null; + public $ire = null; + public $ace = null; + public $ase = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 0 => array( + 'var' => 'success', + 'type' => TType::STRUCT, + 'class' => '\GridFTPDataMovement', + ), + 1 => array( + 'var' => 'ire', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\InvalidRequestException', + ), + 2 => array( + 'var' => 'ace', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\AiravataClientException', + ), + 3 => array( + 'var' => 'ase', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\AiravataSystemException', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['success'])) { + $this->success = $vals['success']; + } + if (isset($vals['ire'])) { + $this->ire = $vals['ire']; + } + if (isset($vals['ace'])) { + $this->ace = $vals['ace']; + } + if (isset($vals['ase'])) { + $this->ase = $vals['ase']; + } + } + } + + public function getName() { + return 'ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 0: + if ($ftype == TType::STRUCT) { + $this->success = new \GridFTPDataMovement(); + $xfer += $this->success->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 1: + if ($ftype == TType::STRUCT) { + $this->ire = new \Airavata\API\Error\InvalidRequestException(); + $xfer += $this->ire->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRUCT) { + $this->ace = new \Airavata\API\Error\AiravataClientException(); + $xfer += $this->ace->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRUCT) { + $this->ase = new \Airavata\API\Error\AiravataSystemException(); + $xfer += $this->ase->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result'); + if ($this->success !== null) { + if (!is_object($this->success)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0); + $xfer += $this->success->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->ire !== null) { + $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1); + $xfer += $this->ire->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->ace !== null) { + $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2); + $xfer += $this->ace->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->ase !== null) { + $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3); + $xfer += $this->ase->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class ApplicationCatalogAPI_isComputeResourceDescriptionRegistered_args { static $_TSPEC; @@ -4958,12 +5510,22 @@ class ApplicationCatalogAPI_addApplicationDeployment_result { class ApplicationCatalogAPI_listApplicationDeploymentIds_args { static $_TSPEC; + public $applicationInterfaceId = null; - public function __construct() { + public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( + 1 => array( + 'var' => 'applicationInterfaceId', + 'type' => TType::STRING, + ), ); } + if (is_array($vals)) { + if (isset($vals['applicationInterfaceId'])) { + $this->applicationInterfaceId = $vals['applicationInterfaceId']; + } + } } public function getName() { @@ -4985,6 +5547,13 @@ class ApplicationCatalogAPI_listApplicationDeploymentIds_args { } switch ($fid) { + case 1: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->applicationInterfaceId); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -4998,6 +5567,11 @@ class ApplicationCatalogAPI_listApplicationDeploymentIds_args { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('ApplicationCatalogAPI_listApplicationDeploymentIds_args'); + if ($this->applicationInterfaceId !== null) { + $xfer += $output->writeFieldBegin('applicationInterfaceId', TType::STRING, 1); + $xfer += $output->writeString($this->applicationInterfaceId); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -5172,18 +5746,26 @@ class ApplicationCatalogAPI_listApplicationDeploymentIds_result { class ApplicationCatalogAPI_getApplicationDeployment_args { static $_TSPEC; + public $applicationInterfaceId = null; public $applicationDeploymentId = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( + 'var' => 'applicationInterfaceId', + 'type' => TType::STRING, + ), + 2 => array( 'var' => 'applicationDeploymentId', 'type' => TType::STRING, ), ); } if (is_array($vals)) { + if (isset($vals['applicationInterfaceId'])) { + $this->applicationInterfaceId = $vals['applicationInterfaceId']; + } if (isset($vals['applicationDeploymentId'])) { $this->applicationDeploymentId = $vals['applicationDeploymentId']; } @@ -5211,6 +5793,13 @@ class ApplicationCatalogAPI_getApplicationDeployment_args { { case 1: if ($ftype == TType::STRING) { + $xfer += $input->readString($this->applicationInterfaceId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { $xfer += $input->readString($this->applicationDeploymentId); } else { $xfer += $input->skip($ftype); @@ -5229,8 +5818,13 @@ class ApplicationCatalogAPI_getApplicationDeployment_args { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('ApplicationCatalogAPI_getApplicationDeployment_args'); + if ($this->applicationInterfaceId !== null) { + $xfer += $output->writeFieldBegin('applicationInterfaceId', TType::STRING, 1); + $xfer += $output->writeString($this->applicationInterfaceId); + $xfer += $output->writeFieldEnd(); + } if ($this->applicationDeploymentId !== null) { - $xfer += $output->writeFieldBegin('applicationDeploymentId', TType::STRING, 1); + $xfer += $output->writeFieldBegin('applicationDeploymentId', TType::STRING, 2); $xfer += $output->writeString($this->applicationDeploymentId); $xfer += $output->writeFieldEnd(); } http://git-wip-us.apache.org/repos/asf/airavata/blob/1fd52a12/lib/Airavata/API/Error/Types.php ---------------------------------------------------------------------- diff --git a/lib/Airavata/API/Error/Types.php b/lib/Airavata/API/Error/Types.php index d63e940..896c6b3 100644 --- a/lib/Airavata/API/Error/Types.php +++ b/lib/Airavata/API/Error/Types.php @@ -468,6 +468,315 @@ class AiravataClientException extends TException { } +class ValidatorResult { + static $_TSPEC; + + public $result = null; + public $errorDetails = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'result', + 'type' => TType::BOOL, + ), + 2 => array( + 'var' => 'errorDetails', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['result'])) { + $this->result = $vals['result']; + } + if (isset($vals['errorDetails'])) { + $this->errorDetails = $vals['errorDetails']; + } + } + } + + public function getName() { + return 'ValidatorResult'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->result); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->errorDetails); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ValidatorResult'); + if ($this->result !== null) { + $xfer += $output->writeFieldBegin('result', TType::BOOL, 1); + $xfer += $output->writeBool($this->result); + $xfer += $output->writeFieldEnd(); + } + if ($this->errorDetails !== null) { + $xfer += $output->writeFieldBegin('errorDetails', TType::STRING, 2); + $xfer += $output->writeString($this->errorDetails); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ValidationResults { + static $_TSPEC; + + public $validationState = null; + public $validationResultList = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'validationState', + 'type' => TType::BOOL, + ), + 2 => array( + 'var' => 'validationResultList', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\ValidatorResult', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['validationState'])) { + $this->validationState = $vals['validationState']; + } + if (isset($vals['validationResultList'])) { + $this->validationResultList = $vals['validationResultList']; + } + } + } + + public function getName() { + return 'ValidationResults'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->validationState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::LST) { + $this->validationResultList = array(); + $_size0 = 0; + $_etype3 = 0; + $xfer += $input->readListBegin($_etype3, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $elem5 = null; + $elem5 = new \Airavata\API\Error\ValidatorResult(); + $xfer += $elem5->read($input); + $this->validationResultList []= $elem5; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ValidationResults'); + if ($this->validationState !== null) { + $xfer += $output->writeFieldBegin('validationState', TType::BOOL, 1); + $xfer += $output->writeBool($this->validationState); + $xfer += $output->writeFieldEnd(); + } + if ($this->validationResultList !== null) { + if (!is_array($this->validationResultList)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('validationResultList', TType::LST, 2); + { + $output->writeListBegin(TType::STRUCT, count($this->validationResultList)); + { + foreach ($this->validationResultList as $iter6) + { + $xfer += $iter6->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class LaunchValidationException extends TException { + static $_TSPEC; + + public $validationResult = null; + public $errorMessage = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'validationResult', + 'type' => TType::STRUCT, + 'class' => '\Airavata\API\Error\ValidationResults', + ), + 2 => array( + 'var' => 'errorMessage', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['validationResult'])) { + $this->validationResult = $vals['validationResult']; + } + if (isset($vals['errorMessage'])) { + $this->errorMessage = $vals['errorMessage']; + } + } + } + + public function getName() { + return 'LaunchValidationException'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::STRUCT) { + $this->validationResult = new \Airavata\API\Error\ValidationResults(); + $xfer += $this->validationResult->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->errorMessage); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('LaunchValidationException'); + if ($this->validationResult !== null) { + if (!is_object($this->validationResult)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('validationResult', TType::STRUCT, 1); + $xfer += $this->validationResult->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->errorMessage !== null) { + $xfer += $output->writeFieldBegin('errorMessage', TType::STRING, 2); + $xfer += $output->writeString($this->errorMessage); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class AiravataSystemException extends TException { static $_TSPEC; http://git-wip-us.apache.org/repos/asf/airavata/blob/1fd52a12/lib/Airavata/Model/Workspace/Experiment/Types.php ---------------------------------------------------------------------- diff --git a/lib/Airavata/Model/Workspace/Experiment/Types.php b/lib/Airavata/Model/Workspace/Experiment/Types.php index b8fc000..456ae7b 100644 --- a/lib/Airavata/Model/Workspace/Experiment/Types.php +++ b/lib/Airavata/Model/Workspace/Experiment/Types.php @@ -3124,6 +3124,218 @@ class WorkflowNodeDetails { } +class ValidatorResult { + static $_TSPEC; + + public $result = null; + public $errorDetails = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'result', + 'type' => TType::BOOL, + ), + 2 => array( + 'var' => 'errorDetails', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['result'])) { + $this->result = $vals['result']; + } + if (isset($vals['errorDetails'])) { + $this->errorDetails = $vals['errorDetails']; + } + } + } + + public function getName() { + return 'ValidatorResult'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->result); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->errorDetails); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ValidatorResult'); + if ($this->result !== null) { + $xfer += $output->writeFieldBegin('result', TType::BOOL, 1); + $xfer += $output->writeBool($this->result); + $xfer += $output->writeFieldEnd(); + } + if ($this->errorDetails !== null) { + $xfer += $output->writeFieldBegin('errorDetails', TType::STRING, 2); + $xfer += $output->writeString($this->errorDetails); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ValidationResults { + static $_TSPEC; + + public $validationState = null; + public $validationResultList = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'validationState', + 'type' => TType::BOOL, + ), + 2 => array( + 'var' => 'validationResultList', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Workspace\Experiment\ValidatorResult', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['validationState'])) { + $this->validationState = $vals['validationState']; + } + if (isset($vals['validationResultList'])) { + $this->validationResultList = $vals['validationResultList']; + } + } + } + + public function getName() { + return 'ValidationResults'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->validationState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::LST) { + $this->validationResultList = array(); + $_size77 = 0; + $_etype80 = 0; + $xfer += $input->readListBegin($_etype80, $_size77); + for ($_i81 = 0; $_i81 < $_size77; ++$_i81) + { + $elem82 = null; + $elem82 = new \Airavata\Model\Workspace\Experiment\ValidatorResult(); + $xfer += $elem82->read($input); + $this->validationResultList []= $elem82; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ValidationResults'); + if ($this->validationState !== null) { + $xfer += $output->writeFieldBegin('validationState', TType::BOOL, 1); + $xfer += $output->writeBool($this->validationState); + $xfer += $output->writeFieldEnd(); + } + if ($this->validationResultList !== null) { + if (!is_array($this->validationResultList)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('validationResultList', TType::LST, 2); + { + $output->writeListBegin(TType::STRUCT, count($this->validationResultList)); + { + foreach ($this->validationResultList as $iter83) + { + $xfer += $iter83->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class Experiment { static $_TSPEC; @@ -3415,15 +3627,15 @@ class Experiment { case 13: if ($ftype == TType::LST) { $this->experimentInputs = 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\DataObjectType(); - $xfer += $elem82->read($input); - $this->experimentInputs []= $elem82; + $elem89 = null; + $elem89 = new \Airavata\Model\Workspace\Experiment\DataObjectType(); + $xfer += $elem89->read($input); + $this->experimentInputs []= $elem89; } $xfer += $input->readListEnd(); } else { @@ -3433,15 +3645,15 @@ class Experiment { case 14: if ($ftype == TType::LST) { $this->experimentOutputs = array(); - $_size83 = 0; - $_etype86 = 0; - $xfer += $input->readListBegin($_etype86, $_size83); - for ($_i87 = 0; $_i87 < $_size83; ++$_i87) + $_size90 = 0; + $_etype93 = 0; + $xfer += $input->readListBegin($_etype93, $_size90); + for ($_i94 = 0; $_i94 < $_size90; ++$_i94) { - $elem88 = null; - $elem88 = new \Airavata\Model\Workspace\Experiment\DataObjectType(); - $xfer += $elem88->read($input); - $this->experimentOutputs []= $elem88; + $elem95 = null; + $elem95 = new \Airavata\Model\Workspace\Experiment\DataObjectType(); + $xfer += $elem95->read($input); + $this->experimentOutputs []= $elem95; } $xfer += $input->readListEnd(); } else { @@ -3459,15 +3671,15 @@ class Experiment { case 16: if ($ftype == TType::LST) { $this->stateChangeList = array(); - $_size89 = 0; - $_etype92 = 0; - $xfer += $input->readListBegin($_etype92, $_size89); - for ($_i93 = 0; $_i93 < $_size89; ++$_i93) + $_size96 = 0; + $_etype99 = 0; + $xfer += $input->readListBegin($_etype99, $_size96); + for ($_i100 = 0; $_i100 < $_size96; ++$_i100) { - $elem94 = null; - $elem94 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeStatus(); - $xfer += $elem94->read($input); - $this->stateChangeList []= $elem94; + $elem101 = null; + $elem101 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeStatus(); + $xfer += $elem101->read($input); + $this->stateChangeList []= $elem101; } $xfer += $input->readListEnd(); } else { @@ -3477,15 +3689,15 @@ class Experiment { case 17: if ($ftype == TType::LST) { $this->workflowNodeDetailsList = array(); - $_size95 = 0; - $_etype98 = 0; - $xfer += $input->readListBegin($_etype98, $_size95); - for ($_i99 = 0; $_i99 < $_size95; ++$_i99) + $_size102 = 0; + $_etype105 = 0; + $xfer += $input->readListBegin($_etype105, $_size102); + for ($_i106 = 0; $_i106 < $_size102; ++$_i106) { - $elem100 = null; - $elem100 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeDetails(); - $xfer += $elem100->read($input); - $this->workflowNodeDetailsList []= $elem100; + $elem107 = null; + $elem107 = new \Airavata\Model\Workspace\Experiment\WorkflowNodeDetails(); + $xfer += $elem107->read($input); + $this->workflowNodeDetailsList []= $elem107; } $xfer += $input->readListEnd(); } else { @@ -3495,15 +3707,15 @@ class Experiment { case 18: if ($ftype == TType::LST) { $this->errors = array(); - $_size101 = 0; - $_etype104 = 0; - $xfer += $input->readListBegin($_etype104, $_size101); - for ($_i105 = 0; $_i105 < $_size101; ++$_i105) + $_size108 = 0; + $_etype111 = 0; + $xfer += $input->readListBegin($_etype111, $_size108); + for ($_i112 = 0; $_i112 < $_size108; ++$_i112) { - $elem106 = null; - $elem106 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); - $xfer += $elem106->read($input); - $this->errors []= $elem106; + $elem113 = null; + $elem113 = new \Airavata\Model\Workspace\Experiment\ErrorDetails(); + $xfer += $elem113->read($input); + $this->errors []= $elem113; } $xfer += $input->readListEnd(); } else { @@ -3594,9 +3806,9 @@ class Experiment { { $output->writeListBegin(TType::STRUCT, count($this->experimentInputs)); { - foreach ($this->experimentInputs as $iter107) + foreach ($this->experimentInputs as $iter114) { - $xfer += $iter107->write($output); + $xfer += $iter114->write($output); } } $output->writeListEnd(); @@ -3611,9 +3823,9 @@ class Experiment { { $output->writeListBegin(TType::STRUCT, count($this->experimentOutputs)); { - foreach ($this->experimentOutputs as $iter108) + foreach ($this->experimentOutputs as $iter115) { - $xfer += $iter108->write($output); + $xfer += $iter115->write($output); } } $output->writeListEnd(); @@ -3636,9 +3848,9 @@ class Experiment { { $output->writeListBegin(TType::STRUCT, count($this->stateChangeList)); { - foreach ($this->stateChangeList as $iter109) + foreach ($this->stateChangeList as $iter116) { - $xfer += $iter109->write($output); + $xfer += $iter116->write($output); } } $output->writeListEnd(); @@ -3653,9 +3865,9 @@ class Experiment { { $output->writeListBegin(TType::STRUCT, count($this->workflowNodeDetailsList)); { - foreach ($this->workflowNodeDetailsList as $iter110) + foreach ($this->workflowNodeDetailsList as $iter117) { - $xfer += $iter110->write($output); + $xfer += $iter117->write($output); } } $output->writeListEnd(); @@ -3670,9 +3882,9 @@ class Experiment { { $output->writeListBegin(TType::STRUCT, count($this->errors)); { - foreach ($this->errors as $iter111) + foreach ($this->errors as $iter118) { - $xfer += $iter111->write($output); + $xfer += $iter118->write($output); } } $output->writeListEnd();