http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/83b53328/app/libraries/Airavata/API/Airavata.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/API/Airavata.php b/app/libraries/Airavata/API/Airavata.php index 8a3cc2c..690b75b 100644 --- a/app/libraries/Airavata/API/Airavata.php +++ b/app/libraries/Airavata/API/Airavata.php @@ -71,6 +71,26 @@ interface AiravataIf { */ public function addGateway(\Airavata\Model\Security\AuthzToken $authzToken, \Airavata\Model\Workspace\Gateway $gateway); /** + * Get all users in the gateway + * + * @param gatewayId + * The gateway data model. + * + * @return users + * list of usernames of the users in the gateway + * + * + * + * @param \Airavata\Model\Security\AuthzToken $authzToken + * @param string $gatewayId + * @return string[] + * @throws \Airavata\API\Error\InvalidRequestException + * @throws \Airavata\API\Error\AiravataClientException + * @throws \Airavata\API\Error\AiravataSystemException + * @throws \Airavata\API\Error\AuthorizationException + */ + public function getAllUsersInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId); + /** * Update previously registered Gateway metadata. * * @param gatewayId @@ -488,66 +508,32 @@ interface AiravataIf { */ public function getUserProjects(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $limit, $offset); /** - * - * Search User Projects by Project Name - * Get all Project for user by project name with pagination.Results will be ordered based on creation time DESC. - * - * @param gatewayId - * The unique identifier for the requested gateway. - * - * @param userName - * The identifier of the user. - * - * @param projectName - * The name of the project on which the results to be fetched. - * - * @param limit - * The amount results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * - * - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param string $gatewayId - * @param string $userName - * @param string $projectName - * @param int $limit - * @param int $offset - * @return \Airavata\Model\Workspace\Project[] - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function searchProjectsByProjectName(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $projectName, $limit, $offset); - /** - * - * Search User Projects by Project Description - * Search and get all Projects for user by project description with pagination. Results will be ordered based on creation time DESC. - * - * @param gatewayId - * The unique identifier of the gateway making the request. - * - * @param userName - * The identifier of the user. - * - * @param description - * The description to be matched. - * - * @param limit - * The amount results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * + * * + * * Search User Projects + * * Search and get all Projects for user by project description or/and project name with pagination. + * * Results will be ordered based on creation time DESC. + * * + * * @param gatewayId + * * The unique identifier of the gateway making the request. + * * + * * @param userName + * * The identifier of the user. + * * + * * @param filters + * * Map of multiple filter criteria. Currenlt search filters includes Project Name and Project Description + * * + * * @param limit + * * The amount results to be fetched. + * * + * * @param offset + * * The starting point of the results to be fetched. + * * + * * * * @param \Airavata\Model\Security\AuthzToken $authzToken * @param string $gatewayId * @param string $userName - * @param string $description + * @param array $filters * @param int $limit * @param int $offset * @return \Airavata\Model\Workspace\Project[] @@ -556,189 +542,7 @@ interface AiravataIf { * @throws \Airavata\API\Error\AiravataSystemException * @throws \Airavata\API\Error\AuthorizationException */ - public function searchProjectsByProjectDesc(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description, $limit, $offset); - /** - * - * Search User Experiments by Name - * Search user Experiments using experiment name with pagination. Results will be sorted based on creation time DESC. - * - * @param gatewayId - * Unique identifier of the requested gateway. - * - * @param userName - * Username of the user who created the experiments. - * - * @param expName - * Experiment name to be matched. - * - * @param limit - * Amount of results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * - * - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param string $gatewayId - * @param string $userName - * @param string $expName - * @param int $limit - * @param int $offset - * @return \Airavata\Model\Experiment\ExperimentSummaryModel[] - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function searchExperimentsByName(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $expName, $limit, $offset); - /** - * - * Search By Experiment Description - * Search Experiments by experiment description with pagination. Results will be sorted based on creation time DESC. - * - * @param gatewayId - * Unique identifier of the requested gateway. - * - * @param userName - * Username of the requested user. - * - * @param description - * Experiment description to be matched. - * - * @param limit - * Amount of results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * - * - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param string $gatewayId - * @param string $userName - * @param string $description - * @param int $limit - * @param int $offset - * @return \Airavata\Model\Experiment\ExperimentSummaryModel[] - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function searchExperimentsByDesc(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description, $limit, $offset); - /** - * - * Search Experiment By the Application - * Search Experiments of a particular application id with pagination. Results will be sorted based on creation time DESC - * - * @param gatewayId - * Unique identifier of the requested gateway. - * - * @param userName - * Username of the requested user. - * - * @param applicationId - * Application id to be matched. - * - * @param limit - * Amount of results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * - * - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param string $gatewayId - * @param string $userName - * @param string $applicationId - * @param int $limit - * @param int $offset - * @return \Airavata\Model\Experiment\ExperimentSummaryModel[] - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function searchExperimentsByApplication(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $applicationId, $limit, $offset); - /** - * - * Search User Experiments by Status - * Search all the Experiments of the given user by experiment status with pagination. Results will be sorted based on creation time DESC - * - * @param gatewayId - * Unique identifier of the requested gateway. - * - * @param userName - * Username of the user making the request. - * - * @param experimentState - * Experiement state to be matched. - * - * @param limit - * Amount of results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * - * - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param string $gatewayId - * @param string $userName - * @param int $experimentState - * @param int $limit - * @param int $offset - * @return \Airavata\Model\Experiment\ExperimentSummaryModel[] - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function searchExperimentsByStatus(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $experimentState, $limit, $offset); - /** - * - * Search User Experiments by the Creation Time - * This will search all the experiments of the given user by experiment creation time with pagination. Results will be sorted based on creation time DESC. - * - * @param gatewayId - * Unique identifier of the requested gateway. - * - * @param userName - * Username of the requested user. - * - * @param fromTime - * Start time of the experiments creation time. - * - * @param toTime - * End time of the experiement creation time. - * - * @param limit - * Amount of results to be fetched. - * - * @param offset - * The starting point of the results to be fetched. - * - * @return ExperimentSummaryModel - * List of experiments for the given search filter. Here only the Experiment summary will be returned. - * - * - * - * @param \Airavata\Model\Security\AuthzToken $authzToken - * @param string $gatewayId - * @param string $userName - * @param int $fromTime - * @param int $toTime - * @param int $limit - * @param int $offset - * @return \Airavata\Model\Experiment\ExperimentSummaryModel[] - * @throws \Airavata\API\Error\InvalidRequestException - * @throws \Airavata\API\Error\AiravataClientException - * @throws \Airavata\API\Error\AiravataSystemException - * @throws \Airavata\API\Error\AuthorizationException - */ - public function searchExperimentsByCreationTime(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $fromTime, $toTime, $limit, $offset); + public function searchProjects(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset); /** * Search Experiments. * Search Experiments by using multiple filter criteria with pagination. Results will be sorted based on creation time DESC. @@ -3767,6 +3571,70 @@ class AiravataClient implements \Airavata\API\AiravataIf { throw new \Exception("addGateway failed: unknown result"); } + public function getAllUsersInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) + { + $this->send_getAllUsersInGateway($authzToken, $gatewayId); + return $this->recv_getAllUsersInGateway(); + } + + public function send_getAllUsersInGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId) + { + $args = new \Airavata\API\Airavata_getAllUsersInGateway_args(); + $args->authzToken = $authzToken; + $args->gatewayId = $gatewayId; + $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'getAllUsersInGateway', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('getAllUsersInGateway', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_getAllUsersInGateway() + { + $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getAllUsersInGateway_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\Airavata_getAllUsersInGateway_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; + } + if ($result->ae !== null) { + throw $result->ae; + } + throw new \Exception("getAllUsersInGateway failed: unknown result"); + } + public function updateGateway(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\Workspace\Gateway $updatedGateway) { $this->send_updateGateway($authzToken, $gatewayId, $updatedGateway); @@ -5172,39 +5040,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { throw new \Exception("getUserProjects failed: unknown result"); } - public function searchProjectsByProjectName(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $projectName, $limit, $offset) + public function searchProjects(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset) { - $this->send_searchProjectsByProjectName($authzToken, $gatewayId, $userName, $projectName, $limit, $offset); - return $this->recv_searchProjectsByProjectName(); + $this->send_searchProjects($authzToken, $gatewayId, $userName, $filters, $limit, $offset); + return $this->recv_searchProjects(); } - public function send_searchProjectsByProjectName(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $projectName, $limit, $offset) + public function send_searchProjects(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset) { - $args = new \Airavata\API\Airavata_searchProjectsByProjectName_args(); + $args = new \Airavata\API\Airavata_searchProjects_args(); $args->authzToken = $authzToken; $args->gatewayId = $gatewayId; $args->userName = $userName; - $args->projectName = $projectName; + $args->filters = $filters; $args->limit = $limit; $args->offset = $offset; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchProjectsByProjectName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'searchProjects', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchProjectsByProjectName', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('searchProjects', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchProjectsByProjectName() + public function recv_searchProjects() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchProjectsByProjectName_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchProjects_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5218,7 +5086,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchProjectsByProjectName_result(); + $result = new \Airavata\API\Airavata_searchProjects_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5237,42 +5105,42 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchProjectsByProjectName failed: unknown result"); + throw new \Exception("searchProjects failed: unknown result"); } - public function searchProjectsByProjectDesc(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description, $limit, $offset) + public function searchExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset) { - $this->send_searchProjectsByProjectDesc($authzToken, $gatewayId, $userName, $description, $limit, $offset); - return $this->recv_searchProjectsByProjectDesc(); + $this->send_searchExperiments($authzToken, $gatewayId, $userName, $filters, $limit, $offset); + return $this->recv_searchExperiments(); } - public function send_searchProjectsByProjectDesc(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description, $limit, $offset) + public function send_searchExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset) { - $args = new \Airavata\API\Airavata_searchProjectsByProjectDesc_args(); + $args = new \Airavata\API\Airavata_searchExperiments_args(); $args->authzToken = $authzToken; $args->gatewayId = $gatewayId; $args->userName = $userName; - $args->description = $description; + $args->filters = $filters; $args->limit = $limit; $args->offset = $offset; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchProjectsByProjectDesc', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'searchExperiments', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchProjectsByProjectDesc', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('searchExperiments', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchProjectsByProjectDesc() + public function recv_searchExperiments() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchProjectsByProjectDesc_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperiments_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5286,7 +5154,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchProjectsByProjectDesc_result(); + $result = new \Airavata\API\Airavata_searchExperiments_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5305,42 +5173,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchProjectsByProjectDesc failed: unknown result"); + throw new \Exception("searchExperiments failed: unknown result"); } - public function searchExperimentsByName(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $expName, $limit, $offset) + public function getExperimentStatistics(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $fromTime, $toTime) { - $this->send_searchExperimentsByName($authzToken, $gatewayId, $userName, $expName, $limit, $offset); - return $this->recv_searchExperimentsByName(); + $this->send_getExperimentStatistics($authzToken, $gatewayId, $fromTime, $toTime); + return $this->recv_getExperimentStatistics(); } - public function send_searchExperimentsByName(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $expName, $limit, $offset) + public function send_getExperimentStatistics(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $fromTime, $toTime) { - $args = new \Airavata\API\Airavata_searchExperimentsByName_args(); + $args = new \Airavata\API\Airavata_getExperimentStatistics_args(); $args->authzToken = $authzToken; $args->gatewayId = $gatewayId; - $args->userName = $userName; - $args->expName = $expName; - $args->limit = $limit; - $args->offset = $offset; + $args->fromTime = $fromTime; + $args->toTime = $toTime; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchExperimentsByName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getExperimentStatistics', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchExperimentsByName', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getExperimentStatistics', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchExperimentsByName() + public function recv_getExperimentStatistics() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByName_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperimentStatistics_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5354,7 +5220,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchExperimentsByName_result(); + $result = new \Airavata\API\Airavata_getExperimentStatistics_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5373,42 +5239,40 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchExperimentsByName failed: unknown result"); + throw new \Exception("getExperimentStatistics failed: unknown result"); } - public function searchExperimentsByDesc(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description, $limit, $offset) + public function getExperimentsInProject(\Airavata\Model\Security\AuthzToken $authzToken, $projectId, $limit, $offset) { - $this->send_searchExperimentsByDesc($authzToken, $gatewayId, $userName, $description, $limit, $offset); - return $this->recv_searchExperimentsByDesc(); + $this->send_getExperimentsInProject($authzToken, $projectId, $limit, $offset); + return $this->recv_getExperimentsInProject(); } - public function send_searchExperimentsByDesc(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $description, $limit, $offset) + public function send_getExperimentsInProject(\Airavata\Model\Security\AuthzToken $authzToken, $projectId, $limit, $offset) { - $args = new \Airavata\API\Airavata_searchExperimentsByDesc_args(); + $args = new \Airavata\API\Airavata_getExperimentsInProject_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->userName = $userName; - $args->description = $description; + $args->projectId = $projectId; $args->limit = $limit; $args->offset = $offset; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchExperimentsByDesc', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getExperimentsInProject', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchExperimentsByDesc', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getExperimentsInProject', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchExperimentsByDesc() + public function recv_getExperimentsInProject() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByDesc_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperimentsInProject_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5422,7 +5286,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchExperimentsByDesc_result(); + $result = new \Airavata\API\Airavata_getExperimentsInProject_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5438,45 +5302,47 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ase !== null) { throw $result->ase; } + if ($result->pnfe !== null) { + throw $result->pnfe; + } if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchExperimentsByDesc failed: unknown result"); + throw new \Exception("getExperimentsInProject failed: unknown result"); } - public function searchExperimentsByApplication(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $applicationId, $limit, $offset) + public function getUserExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $limit, $offset) { - $this->send_searchExperimentsByApplication($authzToken, $gatewayId, $userName, $applicationId, $limit, $offset); - return $this->recv_searchExperimentsByApplication(); + $this->send_getUserExperiments($authzToken, $gatewayId, $userName, $limit, $offset); + return $this->recv_getUserExperiments(); } - public function send_searchExperimentsByApplication(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $applicationId, $limit, $offset) + public function send_getUserExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $limit, $offset) { - $args = new \Airavata\API\Airavata_searchExperimentsByApplication_args(); + $args = new \Airavata\API\Airavata_getUserExperiments_args(); $args->authzToken = $authzToken; $args->gatewayId = $gatewayId; $args->userName = $userName; - $args->applicationId = $applicationId; $args->limit = $limit; $args->offset = $offset; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchExperimentsByApplication', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getUserExperiments', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchExperimentsByApplication', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getUserExperiments', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchExperimentsByApplication() + public function recv_getUserExperiments() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByApplication_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserExperiments_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5490,7 +5356,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchExperimentsByApplication_result(); + $result = new \Airavata\API\Airavata_getUserExperiments_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5509,42 +5375,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchExperimentsByApplication failed: unknown result"); + throw new \Exception("getUserExperiments failed: unknown result"); } - public function searchExperimentsByStatus(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $experimentState, $limit, $offset) + public function createExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\Experiment\ExperimentModel $experiment) { - $this->send_searchExperimentsByStatus($authzToken, $gatewayId, $userName, $experimentState, $limit, $offset); - return $this->recv_searchExperimentsByStatus(); + $this->send_createExperiment($authzToken, $gatewayId, $experiment); + return $this->recv_createExperiment(); } - public function send_searchExperimentsByStatus(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $experimentState, $limit, $offset) + public function send_createExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\Experiment\ExperimentModel $experiment) { - $args = new \Airavata\API\Airavata_searchExperimentsByStatus_args(); + $args = new \Airavata\API\Airavata_createExperiment_args(); $args->authzToken = $authzToken; $args->gatewayId = $gatewayId; - $args->userName = $userName; - $args->experimentState = $experimentState; - $args->limit = $limit; - $args->offset = $offset; + $args->experiment = $experiment; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchExperimentsByStatus', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'createExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchExperimentsByStatus', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('createExperiment', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchExperimentsByStatus() + public function recv_createExperiment() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByStatus_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_createExperiment_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5558,7 +5421,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchExperimentsByStatus_result(); + $result = new \Airavata\API\Airavata_createExperiment_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5577,43 +5440,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchExperimentsByStatus failed: unknown result"); + throw new \Exception("createExperiment failed: unknown result"); } - public function searchExperimentsByCreationTime(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $fromTime, $toTime, $limit, $offset) + public function deleteExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $experimentId) { - $this->send_searchExperimentsByCreationTime($authzToken, $gatewayId, $userName, $fromTime, $toTime, $limit, $offset); - return $this->recv_searchExperimentsByCreationTime(); + $this->send_deleteExperiment($authzToken, $experimentId); + return $this->recv_deleteExperiment(); } - public function send_searchExperimentsByCreationTime(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $fromTime, $toTime, $limit, $offset) + public function send_deleteExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $experimentId) { - $args = new \Airavata\API\Airavata_searchExperimentsByCreationTime_args(); + $args = new \Airavata\API\Airavata_deleteExperiment_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->userName = $userName; - $args->fromTime = $fromTime; - $args->toTime = $toTime; - $args->limit = $limit; - $args->offset = $offset; + $args->experimentId = $experimentId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchExperimentsByCreationTime', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'deleteExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchExperimentsByCreationTime', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('deleteExperiment', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchExperimentsByCreationTime() + public function recv_deleteExperiment() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByCreationTime_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteExperiment_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5627,7 +5485,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchExperimentsByCreationTime_result(); + $result = new \Airavata\API\Airavata_deleteExperiment_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5646,42 +5504,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchExperimentsByCreationTime failed: unknown result"); + throw new \Exception("deleteExperiment failed: unknown result"); } - public function searchExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset) + public function getExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $this->send_searchExperiments($authzToken, $gatewayId, $userName, $filters, $limit, $offset); - return $this->recv_searchExperiments(); + $this->send_getExperiment($authzToken, $airavataExperimentId); + return $this->recv_getExperiment(); } - public function send_searchExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, array $filters, $limit, $offset) + public function send_getExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $args = new \Airavata\API\Airavata_searchExperiments_args(); + $args = new \Airavata\API\Airavata_getExperiment_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->userName = $userName; - $args->filters = $filters; - $args->limit = $limit; - $args->offset = $offset; + $args->airavataExperimentId = $airavataExperimentId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'searchExperiments', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('searchExperiments', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getExperiment', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_searchExperiments() + public function recv_getExperiment() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperiments_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperiment_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5695,7 +5549,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_searchExperiments_result(); + $result = new \Airavata\API\Airavata_getExperiment_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5705,6 +5559,9 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ire !== null) { throw $result->ire; } + if ($result->enf !== null) { + throw $result->enf; + } if ($result->ace !== null) { throw $result->ace; } @@ -5714,40 +5571,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("searchExperiments failed: unknown result"); + throw new \Exception("getExperiment failed: unknown result"); } - public function getExperimentStatistics(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $fromTime, $toTime) + public function getDetailedExperimentTree(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $this->send_getExperimentStatistics($authzToken, $gatewayId, $fromTime, $toTime); - return $this->recv_getExperimentStatistics(); + $this->send_getDetailedExperimentTree($authzToken, $airavataExperimentId); + return $this->recv_getDetailedExperimentTree(); } - public function send_getExperimentStatistics(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $fromTime, $toTime) + public function send_getDetailedExperimentTree(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $args = new \Airavata\API\Airavata_getExperimentStatistics_args(); + $args = new \Airavata\API\Airavata_getDetailedExperimentTree_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->fromTime = $fromTime; - $args->toTime = $toTime; + $args->airavataExperimentId = $airavataExperimentId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getExperimentStatistics', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getDetailedExperimentTree', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getExperimentStatistics', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getDetailedExperimentTree', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getExperimentStatistics() + public function recv_getDetailedExperimentTree() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperimentStatistics_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getDetailedExperimentTree_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5761,7 +5616,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getExperimentStatistics_result(); + $result = new \Airavata\API\Airavata_getDetailedExperimentTree_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -5771,6 +5626,9 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ire !== null) { throw $result->ire; } + if ($result->enf !== null) { + throw $result->enf; + } if ($result->ace !== null) { throw $result->ace; } @@ -5780,40 +5638,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getExperimentStatistics failed: unknown result"); + throw new \Exception("getDetailedExperimentTree failed: unknown result"); } - public function getExperimentsInProject(\Airavata\Model\Security\AuthzToken $authzToken, $projectId, $limit, $offset) + public function updateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\ExperimentModel $experiment) { - $this->send_getExperimentsInProject($authzToken, $projectId, $limit, $offset); - return $this->recv_getExperimentsInProject(); + $this->send_updateExperiment($authzToken, $airavataExperimentId, $experiment); + $this->recv_updateExperiment(); } - public function send_getExperimentsInProject(\Airavata\Model\Security\AuthzToken $authzToken, $projectId, $limit, $offset) + public function send_updateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\ExperimentModel $experiment) { - $args = new \Airavata\API\Airavata_getExperimentsInProject_args(); + $args = new \Airavata\API\Airavata_updateExperiment_args(); $args->authzToken = $authzToken; - $args->projectId = $projectId; - $args->limit = $limit; - $args->offset = $offset; + $args->airavataExperimentId = $airavataExperimentId; + $args->experiment = $experiment; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getExperimentsInProject', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'updateExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getExperimentsInProject', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('updateExperiment', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getExperimentsInProject() + public function recv_updateExperiment() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperimentsInProject_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateExperiment_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5827,63 +5684,58 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getExperimentsInProject_result(); + $result = new \Airavata\API\Airavata_updateExperiment_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } - if ($result->success !== null) { - return $result->success; - } if ($result->ire !== null) { throw $result->ire; } + if ($result->enf !== null) { + throw $result->enf; + } if ($result->ace !== null) { throw $result->ace; } if ($result->ase !== null) { throw $result->ase; } - if ($result->pnfe !== null) { - throw $result->pnfe; - } if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getExperimentsInProject failed: unknown result"); + return; } - public function getUserExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $limit, $offset) + public function updateExperimentConfiguration(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\UserConfigurationDataModel $userConfiguration) { - $this->send_getUserExperiments($authzToken, $gatewayId, $userName, $limit, $offset); - return $this->recv_getUserExperiments(); + $this->send_updateExperimentConfiguration($authzToken, $airavataExperimentId, $userConfiguration); + $this->recv_updateExperimentConfiguration(); } - public function send_getUserExperiments(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, $userName, $limit, $offset) + public function send_updateExperimentConfiguration(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\UserConfigurationDataModel $userConfiguration) { - $args = new \Airavata\API\Airavata_getUserExperiments_args(); + $args = new \Airavata\API\Airavata_updateExperimentConfiguration_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->userName = $userName; - $args->limit = $limit; - $args->offset = $offset; + $args->airavataExperimentId = $airavataExperimentId; + $args->userConfiguration = $userConfiguration; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getUserExperiments', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'updateExperimentConfiguration', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getUserExperiments', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('updateExperimentConfiguration', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getUserExperiments() + public function recv_updateExperimentConfiguration() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getUserExperiments_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateExperimentConfiguration_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5897,58 +5749,46 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getUserExperiments_result(); + $result = new \Airavata\API\Airavata_updateExperimentConfiguration_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; - } if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getUserExperiments failed: unknown result"); + return; } - public function createExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\Experiment\ExperimentModel $experiment) + public function updateResourceScheduleing(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel $resourceScheduling) { - $this->send_createExperiment($authzToken, $gatewayId, $experiment); - return $this->recv_createExperiment(); + $this->send_updateResourceScheduleing($authzToken, $airavataExperimentId, $resourceScheduling); + $this->recv_updateResourceScheduleing(); } - public function send_createExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $gatewayId, \Airavata\Model\Experiment\ExperimentModel $experiment) + public function send_updateResourceScheduleing(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel $resourceScheduling) { - $args = new \Airavata\API\Airavata_createExperiment_args(); + $args = new \Airavata\API\Airavata_updateResourceScheduleing_args(); $args->authzToken = $authzToken; - $args->gatewayId = $gatewayId; - $args->experiment = $experiment; + $args->airavataExperimentId = $airavataExperimentId; + $args->resourceScheduling = $resourceScheduling; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'createExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'updateResourceScheduleing', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('createExperiment', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('updateResourceScheduleing', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_createExperiment() + public function recv_updateResourceScheduleing() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_createExperiment_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateResourceScheduleing_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -5962,57 +5802,45 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_createExperiment_result(); + $result = new \Airavata\API\Airavata_updateResourceScheduleing_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; - } if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("createExperiment failed: unknown result"); + return; } - public function deleteExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $experimentId) + public function validateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $this->send_deleteExperiment($authzToken, $experimentId); - return $this->recv_deleteExperiment(); + $this->send_validateExperiment($authzToken, $airavataExperimentId); + return $this->recv_validateExperiment(); } - public function send_deleteExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $experimentId) + public function send_validateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $args = new \Airavata\API\Airavata_deleteExperiment_args(); + $args = new \Airavata\API\Airavata_validateExperiment_args(); $args->authzToken = $authzToken; - $args->experimentId = $experimentId; + $args->airavataExperimentId = $airavataExperimentId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'deleteExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'validateExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('deleteExperiment', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('validateExperiment', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_deleteExperiment() + public function recv_validateExperiment() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_deleteExperiment_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_validateExperiment_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6026,7 +5854,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_deleteExperiment_result(); + $result = new \Airavata\API\Airavata_validateExperiment_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -6036,6 +5864,9 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ire !== null) { throw $result->ire; } + if ($result->enf !== null) { + throw $result->enf; + } if ($result->ace !== null) { throw $result->ace; } @@ -6045,38 +5876,39 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("deleteExperiment failed: unknown result"); + throw new \Exception("validateExperiment failed: unknown result"); } - public function getExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) + public function launchExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, $gatewayId) { - $this->send_getExperiment($authzToken, $airavataExperimentId); - return $this->recv_getExperiment(); + $this->send_launchExperiment($authzToken, $airavataExperimentId, $gatewayId); + $this->recv_launchExperiment(); } - public function send_getExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) + public function send_launchExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, $gatewayId) { - $args = new \Airavata\API\Airavata_getExperiment_args(); + $args = new \Airavata\API\Airavata_launchExperiment_args(); $args->authzToken = $authzToken; $args->airavataExperimentId = $airavataExperimentId; + $args->gatewayId = $gatewayId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'launchExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getExperiment', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('launchExperiment', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getExperiment() + public function recv_launchExperiment() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperiment_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_launchExperiment_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6090,13 +5922,10 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getExperiment_result(); + $result = new \Airavata\API\Airavata_launchExperiment_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } - if ($result->success !== null) { - return $result->success; - } if ($result->ire !== null) { throw $result->ire; } @@ -6112,38 +5941,38 @@ class AiravataClient implements \Airavata\API\AiravataIf { if ($result->ae !== null) { throw $result->ae; } - throw new \Exception("getExperiment failed: unknown result"); + return; } - public function getDetailedExperimentTree(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) + public function getExperimentStatus(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $this->send_getDetailedExperimentTree($authzToken, $airavataExperimentId); - return $this->recv_getDetailedExperimentTree(); + $this->send_getExperimentStatus($authzToken, $airavataExperimentId); + return $this->recv_getExperimentStatus(); } - public function send_getDetailedExperimentTree(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) + public function send_getExperimentStatus(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) { - $args = new \Airavata\API\Airavata_getDetailedExperimentTree_args(); + $args = new \Airavata\API\Airavata_getExperimentStatus_args(); $args->authzToken = $authzToken; $args->airavataExperimentId = $airavataExperimentId; $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getDetailedExperimentTree', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'getExperimentStatus', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getDetailedExperimentTree', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('getExperimentStatus', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getDetailedExperimentTree() + public function recv_getExperimentStatus() { $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getDetailedExperimentTree_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperimentStatus_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6157,377 +5986,7 @@ class AiravataClient implements \Airavata\API\AiravataIf { $this->input_->readMessageEnd(); throw $x; } - $result = new \Airavata\API\Airavata_getDetailedExperimentTree_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->success !== null) { - return $result->success; - } - if ($result->ire !== null) { - throw $result->ire; - } - if ($result->enf !== null) { - throw $result->enf; - } - if ($result->ace !== null) { - throw $result->ace; - } - if ($result->ase !== null) { - throw $result->ase; - } - if ($result->ae !== null) { - throw $result->ae; - } - throw new \Exception("getDetailedExperimentTree failed: unknown result"); - } - - public function updateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\ExperimentModel $experiment) - { - $this->send_updateExperiment($authzToken, $airavataExperimentId, $experiment); - $this->recv_updateExperiment(); - } - - public function send_updateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\ExperimentModel $experiment) - { - $args = new \Airavata\API\Airavata_updateExperiment_args(); - $args->authzToken = $authzToken; - $args->airavataExperimentId = $airavataExperimentId; - $args->experiment = $experiment; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'updateExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('updateExperiment', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_updateExperiment() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateExperiment_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\Airavata_updateExperiment_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->ire !== null) { - throw $result->ire; - } - if ($result->enf !== null) { - throw $result->enf; - } - if ($result->ace !== null) { - throw $result->ace; - } - if ($result->ase !== null) { - throw $result->ase; - } - if ($result->ae !== null) { - throw $result->ae; - } - return; - } - - public function updateExperimentConfiguration(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\UserConfigurationDataModel $userConfiguration) - { - $this->send_updateExperimentConfiguration($authzToken, $airavataExperimentId, $userConfiguration); - $this->recv_updateExperimentConfiguration(); - } - - public function send_updateExperimentConfiguration(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Experiment\UserConfigurationDataModel $userConfiguration) - { - $args = new \Airavata\API\Airavata_updateExperimentConfiguration_args(); - $args->authzToken = $authzToken; - $args->airavataExperimentId = $airavataExperimentId; - $args->userConfiguration = $userConfiguration; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'updateExperimentConfiguration', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('updateExperimentConfiguration', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_updateExperimentConfiguration() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateExperimentConfiguration_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\Airavata_updateExperimentConfiguration_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->ae !== null) { - throw $result->ae; - } - return; - } - - public function updateResourceScheduleing(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel $resourceScheduling) - { - $this->send_updateResourceScheduleing($authzToken, $airavataExperimentId, $resourceScheduling); - $this->recv_updateResourceScheduleing(); - } - - public function send_updateResourceScheduleing(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, \Airavata\Model\Scheduling\ComputationalResourceSchedulingModel $resourceScheduling) - { - $args = new \Airavata\API\Airavata_updateResourceScheduleing_args(); - $args->authzToken = $authzToken; - $args->airavataExperimentId = $airavataExperimentId; - $args->resourceScheduling = $resourceScheduling; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'updateResourceScheduleing', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('updateResourceScheduleing', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_updateResourceScheduleing() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_updateResourceScheduleing_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\Airavata_updateResourceScheduleing_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->ae !== null) { - throw $result->ae; - } - return; - } - - public function validateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) - { - $this->send_validateExperiment($authzToken, $airavataExperimentId); - return $this->recv_validateExperiment(); - } - - public function send_validateExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) - { - $args = new \Airavata\API\Airavata_validateExperiment_args(); - $args->authzToken = $authzToken; - $args->airavataExperimentId = $airavataExperimentId; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'validateExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('validateExperiment', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_validateExperiment() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_validateExperiment_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\Airavata_validateExperiment_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->success !== null) { - return $result->success; - } - if ($result->ire !== null) { - throw $result->ire; - } - if ($result->enf !== null) { - throw $result->enf; - } - if ($result->ace !== null) { - throw $result->ace; - } - if ($result->ase !== null) { - throw $result->ase; - } - if ($result->ae !== null) { - throw $result->ae; - } - throw new \Exception("validateExperiment failed: unknown result"); - } - - public function launchExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, $gatewayId) - { - $this->send_launchExperiment($authzToken, $airavataExperimentId, $gatewayId); - $this->recv_launchExperiment(); - } - - public function send_launchExperiment(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId, $gatewayId) - { - $args = new \Airavata\API\Airavata_launchExperiment_args(); - $args->authzToken = $authzToken; - $args->airavataExperimentId = $airavataExperimentId; - $args->gatewayId = $gatewayId; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'launchExperiment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('launchExperiment', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_launchExperiment() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_launchExperiment_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\Airavata_launchExperiment_result(); - $result->read($this->input_); - $this->input_->readMessageEnd(); - } - if ($result->ire !== null) { - throw $result->ire; - } - if ($result->enf !== null) { - throw $result->enf; - } - if ($result->ace !== null) { - throw $result->ace; - } - if ($result->ase !== null) { - throw $result->ase; - } - if ($result->ae !== null) { - throw $result->ae; - } - return; - } - - public function getExperimentStatus(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) - { - $this->send_getExperimentStatus($authzToken, $airavataExperimentId); - return $this->recv_getExperimentStatus(); - } - - public function send_getExperimentStatus(\Airavata\Model\Security\AuthzToken $authzToken, $airavataExperimentId) - { - $args = new \Airavata\API\Airavata_getExperimentStatus_args(); - $args->authzToken = $authzToken; - $args->airavataExperimentId = $airavataExperimentId; - $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary'); - if ($bin_accel) - { - thrift_protocol_write_binary($this->output_, 'getExperimentStatus', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); - } - else - { - $this->output_->writeMessageBegin('getExperimentStatus', TMessageType::CALL, $this->seqid_); - $args->write($this->output_); - $this->output_->writeMessageEnd(); - $this->output_->getTransport()->flush(); - } - } - - public function recv_getExperimentStatus() - { - $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getExperimentStatus_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\Airavata_getExperimentStatus_result(); + $result = new \Airavata\API\Airavata_getExperimentStatus_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } @@ -13865,7 +13324,7 @@ class Airavata_addGateway_result { } -class Airavata_updateGateway_args { +class Airavata_getAllUsersInGateway_args { static $_TSPEC; /** @@ -13876,10 +13335,6 @@ class Airavata_updateGateway_args { * @var string */ public $gatewayId = null; - /** - * @var \Airavata\Model\Workspace\Gateway - */ - public $updatedGateway = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -13893,11 +13348,6 @@ class Airavata_updateGateway_args { 'var' => 'gatewayId', 'type' => TType::STRING, ), - 3 => array( - 'var' => 'updatedGateway', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Workspace\Gateway', - ), ); } if (is_array($vals)) { @@ -13907,14 +13357,11 @@ class Airavata_updateGateway_args { if (isset($vals['gatewayId'])) { $this->gatewayId = $vals['gatewayId']; } - if (isset($vals['updatedGateway'])) { - $this->updatedGateway = $vals['updatedGateway']; - } } } public function getName() { - return 'Airavata_updateGateway_args'; + return 'Airavata_getAllUsersInGateway_args'; } public function read($input) @@ -13947,14 +13394,6 @@ class Airavata_updateGateway_args { $xfer += $input->skip($ftype); } break; - case 3: - if ($ftype == TType::STRUCT) { - $this->updatedGateway = new \Airavata\Model\Workspace\Gateway(); - $xfer += $this->updatedGateway->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; default: $xfer += $input->skip($ftype); break; @@ -13967,7 +13406,7 @@ class Airavata_updateGateway_args { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('Airavata_updateGateway_args'); + $xfer += $output->writeStructBegin('Airavata_getAllUsersInGateway_args'); if ($this->authzToken !== null) { if (!is_object($this->authzToken)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); @@ -13981,14 +13420,6 @@ class Airavata_updateGateway_args { $xfer += $output->writeString($this->gatewayId); $xfer += $output->writeFieldEnd(); } - if ($this->updatedGateway !== null) { - if (!is_object($this->updatedGateway)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('updatedGateway', TType::STRUCT, 3); - $xfer += $this->updatedGateway->write($output); - $xfer += $output->writeFieldEnd(); - } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -13996,10 +13427,14 @@ class Airavata_updateGateway_args { } -class Airavata_updateGateway_result { +class Airavata_getAllUsersInGateway_result { static $_TSPEC; /** + * @var string[] + */ + public $success = null; + /** * @var \Airavata\API\Error\InvalidRequestException */ public $ire = null; @@ -14019,6 +13454,14 @@ class Airavata_updateGateway_result { public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( + 0 => array( + 'var' => 'success', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), 1 => array( 'var' => 'ire', 'type' => TType::STRUCT, @@ -14042,6 +13485,9 @@ class Airavata_updateGateway_result { ); } if (is_array($vals)) { + if (isset($vals['success'])) { + $this->success = $vals['success']; + } if (isset($vals['ire'])) { $this->ire = $vals['ire']; } @@ -14058,7 +13504,7 @@ class Airavata_updateGateway_result { } public function getName() { - return 'Airavata_updateGateway_result'; + return 'Airavata_getAllUsersInGateway_result'; } public function read($input) @@ -14076,6 +13522,23 @@ class Airavata_updateGateway_result { } switch ($fid) { + case 0: + if ($ftype == TType::LST) { + $this->success = array(); + $_size0 = 0; + $_etype3 = 0; + $xfer += $input->readListBegin($_etype3, $_size0); + for ($_i4 = 0; $_i4 < $_size0; ++$_i4) + { + $elem5 = null; + $xfer += $input->readString($elem5); + $this->success []= $elem5; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; case 1: if ($ftype == TType::STRUCT) { $this->ire = new \Airavata\API\Error\InvalidRequestException(); @@ -14120,7 +13583,24 @@ class Airavata_updateGateway_result { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('Airavata_updateGateway_result'); + $xfer += $output->writeStructBegin('Airavata_getAllUsersInGateway_result'); + if ($this->success !== null) { + if (!is_array($this->success)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('success', TType::LST, 0); + { + $output->writeListBegin(TType::STRING, count($this->success)); + { + foreach ($this->success as $iter6) + { + $xfer += $output->writeString($iter6); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } if ($this->ire !== null) { $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1); $xfer += $this->ire->write($output); @@ -14148,7 +13628,7 @@ class Airavata_updateGateway_result { } -class Airavata_getGateway_args { +class Airavata_updateGateway_args { static $_TSPEC; /** @@ -14159,6 +13639,10 @@ class Airavata_getGateway_args { * @var string */ public $gatewayId = null; + /** + * @var \Airavata\Model\Workspace\Gateway + */ + public $updatedGateway = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -14172,6 +13656,11 @@ class Airavata_getGateway_args { 'var' => 'gatewayId', 'type' => TType::STRING, ), + 3 => array( + 'var' => 'updatedGateway', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Workspace\Gateway', + ), ); } if (is_array($vals)) { @@ -14181,11 +13670,14 @@ class Airavata_getGateway_args { if (isset($vals['gatewayId'])) { $this->gatewayId = $vals['gatewayId']; } + if (isset($vals['updatedGateway'])) { + $this->updatedGateway = $vals['updatedGateway']; + } } } public function getName() { - return 'Airavata_getGateway_args'; + return 'Airavata_updateGateway_args'; } public function read($input) @@ -14218,6 +13710,14 @@ class Airavata_getGateway_args { $xfer += $input->skip($ftype); } break; + case 3: + if ($ftype == TType::STRUCT) { + $this->updatedGateway = new \Airavata\Model\Workspace\Gateway(); + $xfer += $this->updatedGateway->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -14230,7 +13730,7 @@ class Airavata_getGateway_args { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('Airavata_getGateway_args'); + $xfer += $output->writeStructBegin('Airavata_updateGateway_args'); if ($this->authzToken !== null) { if (!is_object($this->authzToken)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); @@ -14244,6 +13744,14 @@ class Airavata_getGateway_args { $xfer += $output->writeString($this->gatewayId); $xfer += $output->writeFieldEnd(); } + if ($this->updatedGateway !== null) { + if (!is_object($this->updatedGateway)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('updatedGateway', TType::STRUCT, 3); + $xfer += $this->updatedGateway->write($output); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -14251,14 +13759,10 @@ class Airavata_getGateway_args { } -class Airavata_getGateway_result { +class Airavata_updateGateway_result { static $_TSPEC; /** - * @var \Airavata\Model\Workspace\Gateway - */ - public $success = null; - /** * @var \Airavata\API\Error\InvalidRequestException */ public $ire = null; @@ -14278,11 +13782,6 @@ class Airavata_getGateway_result { public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( - 0 => array( - 'var' => 'success', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Workspace\Gateway', - ), 1 => array( 'var' => 'ire', 'type' => TType::STRUCT, @@ -14306,9 +13805,6 @@ class Airavata_getGateway_result { ); } if (is_array($vals)) { - if (isset($vals['success'])) { - $this->success = $vals['success']; - } if (isset($vals['ire'])) { $this->ire = $vals['ire']; } @@ -14325,7 +13821,7 @@ class Airavata_getGateway_result { } public function getName() { - return 'Airavata_g
<TRUNCATED>
