You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2014/07/01 05:01:59 UTC
[11/14] moving php command line samples and pointing to airavata sdk
- AIRAVATA-1274
http://git-wip-us.apache.org/repos/asf/airavata/blob/c09963aa/Airavata-PHP-Client-Samples/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
----------------------------------------------------------------------
diff --git a/Airavata-PHP-Client-Samples/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php b/Airavata-PHP-Client-Samples/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
deleted file mode 100644
index e2082cb..0000000
--- a/Airavata-PHP-Client-Samples/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
+++ /dev/null
@@ -1,6165 +0,0 @@
-<?php
-namespace Airavata\API\AppCatalog;
-/**
- * Autogenerated by Thrift Compiler (0.9.1)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-use Thrift\Base\TBase;
-use Thrift\Type\TType;
-use Thrift\Type\TMessageType;
-use Thrift\Exception\TException;
-use Thrift\Exception\TProtocolException;
-use Thrift\Protocol\TProtocol;
-use Thrift\Protocol\TBinaryProtocolAccelerated;
-use Thrift\Exception\TApplicationException;
-
-
-interface ApplicationCatalogAPIIf {
- public function GetAPIVersion();
- public function addComputeResourceDescription(\Airavata\Model\AppCatalog\ComputeResourceDescription $computeResourceDescription);
- public function addSSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\SSHJobSubmission $jobSubmission);
- public function addGSISSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GSISSHJobSubmission $jobSubmission);
- public function addGlobusJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GlobusJobSubmission $jobSubmission);
- public function addSCPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\SCPDataMovement $dataMovement);
- public function addGridFTPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\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(\Airavata\Model\AppCatalog\ApplicationInterface $applicationInterface);
- public function listApplicationInterfaceIds();
- public function getApplicationInterface($applicationInterfaceId);
- public function addApplicationDeployment($applicationInterfaceId, \Airavata\Model\AppCatalog\ApplicationDeployment $applicationDeployment);
- public function listApplicationDeploymentIds($applicationInterfaceId);
- public function getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId);
-}
-
-class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\ApplicationCatalogAPIIf {
- protected $input_ = null;
- protected $output_ = null;
-
- protected $seqid_ = 0;
-
- public function __construct($input, $output=null) {
- $this->input_ = $input;
- $this->output_ = $output ? $output : $input;
- }
-
- public function GetAPIVersion()
- {
- $this->send_GetAPIVersion();
- return $this->recv_GetAPIVersion();
- }
-
- public function send_GetAPIVersion()
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_GetAPIVersion_args();
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'GetAPIVersion', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('GetAPIVersion', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_GetAPIVersion()
- {
- $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_GetAPIVersion_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_GetAPIVersion_result();
- $result->read($this->input_);
- $this->input_->readMessageEnd();
- }
- if ($result->success !== null) {
- return $result->success;
- }
- throw new \Exception("GetAPIVersion failed: unknown result");
- }
-
- public function addComputeResourceDescription(\Airavata\Model\AppCatalog\ComputeResourceDescription $computeResourceDescription)
- {
- $this->send_addComputeResourceDescription($computeResourceDescription);
- return $this->recv_addComputeResourceDescription();
- }
-
- public function send_addComputeResourceDescription(\Airavata\Model\AppCatalog\ComputeResourceDescription $computeResourceDescription)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addComputeResourceDescription_args();
- $args->computeResourceDescription = $computeResourceDescription;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'addComputeResourceDescription', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addComputeResourceDescription', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addComputeResourceDescription()
- {
- $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_addComputeResourceDescription_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_addComputeResourceDescription_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("addComputeResourceDescription failed: unknown result");
- }
-
- public function addSSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\SSHJobSubmission $jobSubmission)
- {
- $this->send_addSSHJobSubmissionProtocol($computeResourceId, $jobSubmission);
- return $this->recv_addSSHJobSubmissionProtocol();
- }
-
- public function send_addSSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\SSHJobSubmission $jobSubmission)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addSSHJobSubmissionProtocol_args();
- $args->computeResourceId = $computeResourceId;
- $args->jobSubmission = $jobSubmission;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'addSSHJobSubmissionProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addSSHJobSubmissionProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addSSHJobSubmissionProtocol()
- {
- $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_addSSHJobSubmissionProtocol_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_addSSHJobSubmissionProtocol_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("addSSHJobSubmissionProtocol failed: unknown result");
- }
-
- public function addGSISSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GSISSHJobSubmission $jobSubmission)
- {
- $this->send_addGSISSHJobSubmissionProtocol($computeResourceId, $jobSubmission);
- return $this->recv_addGSISSHJobSubmissionProtocol();
- }
-
- public function send_addGSISSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GSISSHJobSubmission $jobSubmission)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_args();
- $args->computeResourceId = $computeResourceId;
- $args->jobSubmission = $jobSubmission;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'addGSISSHJobSubmissionProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addGSISSHJobSubmissionProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addGSISSHJobSubmissionProtocol()
- {
- $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_addGSISSHJobSubmissionProtocol_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_addGSISSHJobSubmissionProtocol_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("addGSISSHJobSubmissionProtocol failed: unknown result");
- }
-
- public function addGlobusJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GlobusJobSubmission $jobSubmission)
- {
- $this->send_addGlobusJobSubmissionProtocol($computeResourceId, $jobSubmission);
- return $this->recv_addGlobusJobSubmissionProtocol();
- }
-
- public function send_addGlobusJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GlobusJobSubmission $jobSubmission)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_args();
- $args->computeResourceId = $computeResourceId;
- $args->jobSubmission = $jobSubmission;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'addGlobusJobSubmissionProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addGlobusJobSubmissionProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addGlobusJobSubmissionProtocol()
- {
- $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_addGlobusJobSubmissionProtocol_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_addGlobusJobSubmissionProtocol_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("addGlobusJobSubmissionProtocol failed: unknown result");
- }
-
- public function addSCPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\SCPDataMovement $dataMovement)
- {
- $this->send_addSCPDataMovementProtocol($computeResourceId, $dataMovement);
- return $this->recv_addSCPDataMovementProtocol();
- }
-
- public function send_addSCPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\SCPDataMovement $dataMovement)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addSCPDataMovementProtocol_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_, 'addSCPDataMovementProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addSCPDataMovementProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addSCPDataMovementProtocol()
- {
- $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_addSCPDataMovementProtocol_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_addSCPDataMovementProtocol_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("addSCPDataMovementProtocol failed: unknown result");
- }
-
- public function addGridFTPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\GridFTPDataMovement $dataMovement)
- {
- $this->send_addGridFTPDataMovementProtocol($computeResourceId, $dataMovement);
- return $this->recv_addGridFTPDataMovementProtocol();
- }
-
- public function send_addGridFTPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\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->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("addGridFTPDataMovementProtocol failed: unknown result");
- }
-
- public function listComputeResourceDescriptions()
- {
- $this->send_listComputeResourceDescriptions();
- return $this->recv_listComputeResourceDescriptions();
- }
-
- public function send_listComputeResourceDescriptions()
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_listComputeResourceDescriptions_args();
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'listComputeResourceDescriptions', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('listComputeResourceDescriptions', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_listComputeResourceDescriptions()
- {
- $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_listComputeResourceDescriptions_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_listComputeResourceDescriptions_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("listComputeResourceDescriptions failed: unknown result");
- }
-
- public function getComputeResourceDescription($computeResourceId)
- {
- $this->send_getComputeResourceDescription($computeResourceId);
- return $this->recv_getComputeResourceDescription();
- }
-
- public function send_getComputeResourceDescription($computeResourceId)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getComputeResourceDescription_args();
- $args->computeResourceId = $computeResourceId;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getComputeResourceDescription', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getComputeResourceDescription', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getComputeResourceDescription()
- {
- $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_getComputeResourceDescription_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_getComputeResourceDescription_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("getComputeResourceDescription failed: unknown result");
- }
-
- public function getSSHJobSubmissionProtocol($sshJobSubmissionProtocolResourceId)
- {
- $this->send_getSSHJobSubmissionProtocol($sshJobSubmissionProtocolResourceId);
- return $this->recv_getSSHJobSubmissionProtocol();
- }
-
- public function send_getSSHJobSubmissionProtocol($sshJobSubmissionProtocolResourceId)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getSSHJobSubmissionProtocol_args();
- $args->sshJobSubmissionProtocolResourceId = $sshJobSubmissionProtocolResourceId;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getSSHJobSubmissionProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getSSHJobSubmissionProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getSSHJobSubmissionProtocol()
- {
- $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_getSSHJobSubmissionProtocol_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_getSSHJobSubmissionProtocol_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("getSSHJobSubmissionProtocol failed: unknown result");
- }
-
- public function getGSISSHJobSubmissionProtocol($gsisshJobSubmissionProtocolResourceId)
- {
- $this->send_getGSISSHJobSubmissionProtocol($gsisshJobSubmissionProtocolResourceId);
- return $this->recv_getGSISSHJobSubmissionProtocol();
- }
-
- public function send_getGSISSHJobSubmissionProtocol($gsisshJobSubmissionProtocolResourceId)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getGSISSHJobSubmissionProtocol_args();
- $args->gsisshJobSubmissionProtocolResourceId = $gsisshJobSubmissionProtocolResourceId;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getGSISSHJobSubmissionProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getGSISSHJobSubmissionProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getGSISSHJobSubmissionProtocol()
- {
- $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_getGSISSHJobSubmissionProtocol_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_getGSISSHJobSubmissionProtocol_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("getGSISSHJobSubmissionProtocol failed: unknown result");
- }
-
- public function getGlobusJobSubmissionProtocol($globusJobSubmissionProtocolResourceId)
- {
- $this->send_getGlobusJobSubmissionProtocol($globusJobSubmissionProtocolResourceId);
- return $this->recv_getGlobusJobSubmissionProtocol();
- }
-
- public function send_getGlobusJobSubmissionProtocol($globusJobSubmissionProtocolResourceId)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_args();
- $args->globusJobSubmissionProtocolResourceId = $globusJobSubmissionProtocolResourceId;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getGlobusJobSubmissionProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getGlobusJobSubmissionProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getGlobusJobSubmissionProtocol()
- {
- $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_getGlobusJobSubmissionProtocol_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_getGlobusJobSubmissionProtocol_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("getGlobusJobSubmissionProtocol failed: unknown result");
- }
-
- public function getSCPDataMovementProtocol($scpDataMovementResourceId)
- {
- $this->send_getSCPDataMovementProtocol($scpDataMovementResourceId);
- return $this->recv_getSCPDataMovementProtocol();
- }
-
- public function send_getSCPDataMovementProtocol($scpDataMovementResourceId)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getSCPDataMovementProtocol_args();
- $args->scpDataMovementResourceId = $scpDataMovementResourceId;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getSCPDataMovementProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getSCPDataMovementProtocol', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getSCPDataMovementProtocol()
- {
- $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_getSCPDataMovementProtocol_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_getSCPDataMovementProtocol_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("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);
- return $this->recv_isComputeResourceDescriptionRegistered();
- }
-
- public function send_isComputeResourceDescriptionRegistered($hostName)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_isComputeResourceDescriptionRegistered_args();
- $args->hostName = $hostName;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'isComputeResourceDescriptionRegistered', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('isComputeResourceDescriptionRegistered', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_isComputeResourceDescriptionRegistered()
- {
- $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_isComputeResourceDescriptionRegistered_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_isComputeResourceDescriptionRegistered_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("isComputeResourceDescriptionRegistered failed: unknown result");
- }
-
- public function getComputeResourceDescriptionFromHostName($hostName)
- {
- $this->send_getComputeResourceDescriptionFromHostName($hostName);
- return $this->recv_getComputeResourceDescriptionFromHostName();
- }
-
- public function send_getComputeResourceDescriptionFromHostName($hostName)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getComputeResourceDescriptionFromHostName_args();
- $args->hostName = $hostName;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getComputeResourceDescriptionFromHostName', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getComputeResourceDescriptionFromHostName', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getComputeResourceDescriptionFromHostName()
- {
- $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_getComputeResourceDescriptionFromHostName_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_getComputeResourceDescriptionFromHostName_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("getComputeResourceDescriptionFromHostName failed: unknown result");
- }
-
- public function addApplicationInterface(\Airavata\Model\AppCatalog\ApplicationInterface $applicationInterface)
- {
- $this->send_addApplicationInterface($applicationInterface);
- return $this->recv_addApplicationInterface();
- }
-
- public function send_addApplicationInterface(\Airavata\Model\AppCatalog\ApplicationInterface $applicationInterface)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addApplicationInterface_args();
- $args->applicationInterface = $applicationInterface;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'addApplicationInterface', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addApplicationInterface', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addApplicationInterface()
- {
- $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_addApplicationInterface_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_addApplicationInterface_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("addApplicationInterface failed: unknown result");
- }
-
- public function listApplicationInterfaceIds()
- {
- $this->send_listApplicationInterfaceIds();
- return $this->recv_listApplicationInterfaceIds();
- }
-
- public function send_listApplicationInterfaceIds()
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_listApplicationInterfaceIds_args();
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'listApplicationInterfaceIds', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('listApplicationInterfaceIds', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_listApplicationInterfaceIds()
- {
- $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_listApplicationInterfaceIds_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_listApplicationInterfaceIds_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("listApplicationInterfaceIds failed: unknown result");
- }
-
- public function getApplicationInterface($applicationInterfaceId)
- {
- $this->send_getApplicationInterface($applicationInterfaceId);
- return $this->recv_getApplicationInterface();
- }
-
- public function send_getApplicationInterface($applicationInterfaceId)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getApplicationInterface_args();
- $args->applicationInterfaceId = $applicationInterfaceId;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'getApplicationInterface', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getApplicationInterface', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getApplicationInterface()
- {
- $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_getApplicationInterface_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_getApplicationInterface_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("getApplicationInterface failed: unknown result");
- }
-
- public function addApplicationDeployment($applicationInterfaceId, \Airavata\Model\AppCatalog\ApplicationDeployment $applicationDeployment)
- {
- $this->send_addApplicationDeployment($applicationInterfaceId, $applicationDeployment);
- return $this->recv_addApplicationDeployment();
- }
-
- public function send_addApplicationDeployment($applicationInterfaceId, \Airavata\Model\AppCatalog\ApplicationDeployment $applicationDeployment)
- {
- $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addApplicationDeployment_args();
- $args->applicationInterfaceId = $applicationInterfaceId;
- $args->applicationDeployment = $applicationDeployment;
- $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
- if ($bin_accel)
- {
- thrift_protocol_write_binary($this->output_, 'addApplicationDeployment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('addApplicationDeployment', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_addApplicationDeployment()
- {
- $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_addApplicationDeployment_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_addApplicationDeployment_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("addApplicationDeployment failed: unknown result");
- }
-
- public function listApplicationDeploymentIds($applicationInterfaceId)
- {
- $this->send_listApplicationDeploymentIds($applicationInterfaceId);
- return $this->recv_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)
- {
- thrift_protocol_write_binary($this->output_, 'listApplicationDeploymentIds', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('listApplicationDeploymentIds', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_listApplicationDeploymentIds()
- {
- $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_listApplicationDeploymentIds_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_listApplicationDeploymentIds_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("listApplicationDeploymentIds failed: unknown result");
- }
-
- public function getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId)
- {
- $this->send_getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId);
- return $this->recv_getApplicationDeployment();
- }
-
- 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)
- {
- thrift_protocol_write_binary($this->output_, 'getApplicationDeployment', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
- }
- else
- {
- $this->output_->writeMessageBegin('getApplicationDeployment', TMessageType::CALL, $this->seqid_);
- $args->write($this->output_);
- $this->output_->writeMessageEnd();
- $this->output_->getTransport()->flush();
- }
- }
-
- public function recv_getApplicationDeployment()
- {
- $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_getApplicationDeployment_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_getApplicationDeployment_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("getApplicationDeployment failed: unknown result");
- }
-
-}
-
-// HELPER FUNCTIONS AND STRUCTURES
-
-class ApplicationCatalogAPI_GetAPIVersion_args {
- static $_TSPEC;
-
-
- public function __construct() {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- );
- }
- }
-
- public function getName() {
- return 'ApplicationCatalogAPI_GetAPIVersion_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)
- {
- default:
- $xfer += $input->skip($ftype);
- break;
- }
- $xfer += $input->readFieldEnd();
- }
- $xfer += $input->readStructEnd();
- return $xfer;
- }
-
- public function write($output) {
- $xfer = 0;
- $xfer += $output->writeStructBegin('ApplicationCatalogAPI_GetAPIVersion_args');
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ApplicationCatalogAPI_GetAPIVersion_result {
- static $_TSPEC;
-
- public $success = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 0 => array(
- 'var' => 'success',
- 'type' => TType::STRING,
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['success'])) {
- $this->success = $vals['success'];
- }
- }
- }
-
- public function getName() {
- return 'ApplicationCatalogAPI_GetAPIVersion_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::STRING) {
- $xfer += $input->readString($this->success);
- } 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_GetAPIVersion_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ApplicationCatalogAPI_addComputeResourceDescription_args {
- static $_TSPEC;
-
- public $computeResourceDescription = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'computeResourceDescription',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\ComputeResourceDescription',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['computeResourceDescription'])) {
- $this->computeResourceDescription = $vals['computeResourceDescription'];
- }
- }
- }
-
- public function getName() {
- return 'ApplicationCatalogAPI_addComputeResourceDescription_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::STRUCT) {
- $this->computeResourceDescription = new \Airavata\Model\AppCatalog\ComputeResourceDescription();
- $xfer += $this->computeResourceDescription->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_addComputeResourceDescription_args');
- if ($this->computeResourceDescription !== null) {
- if (!is_object($this->computeResourceDescription)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('computeResourceDescription', TType::STRUCT, 1);
- $xfer += $this->computeResourceDescription->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ApplicationCatalogAPI_addComputeResourceDescription_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::STRING,
- ),
- 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_addComputeResourceDescription_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::STRING) {
- $xfer += $input->readString($this->success);
- } 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_addComputeResourceDescription_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $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_addSSHJobSubmissionProtocol_args {
- static $_TSPEC;
-
- public $computeResourceId = null;
- public $jobSubmission = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'computeResourceId',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'jobSubmission',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\SSHJobSubmission',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['computeResourceId'])) {
- $this->computeResourceId = $vals['computeResourceId'];
- }
- if (isset($vals['jobSubmission'])) {
- $this->jobSubmission = $vals['jobSubmission'];
- }
- }
- }
-
- public function getName() {
- return 'ApplicationCatalogAPI_addSSHJobSubmissionProtocol_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->jobSubmission = new \Airavata\Model\AppCatalog\SSHJobSubmission();
- $xfer += $this->jobSubmission->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_addSSHJobSubmissionProtocol_args');
- if ($this->computeResourceId !== null) {
- $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1);
- $xfer += $output->writeString($this->computeResourceId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->jobSubmission !== null) {
- if (!is_object($this->jobSubmission)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('jobSubmission', TType::STRUCT, 2);
- $xfer += $this->jobSubmission->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_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::STRING,
- ),
- 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_addSSHJobSubmissionProtocol_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::STRING) {
- $xfer += $input->readString($this->success);
- } 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_addSSHJobSubmissionProtocol_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $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_addGSISSHJobSubmissionProtocol_args {
- static $_TSPEC;
-
- public $computeResourceId = null;
- public $jobSubmission = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'computeResourceId',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'jobSubmission',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\GSISSHJobSubmission',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['computeResourceId'])) {
- $this->computeResourceId = $vals['computeResourceId'];
- }
- if (isset($vals['jobSubmission'])) {
- $this->jobSubmission = $vals['jobSubmission'];
- }
- }
- }
-
- public function getName() {
- return 'ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_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->jobSubmission = new \Airavata\Model\AppCatalog\GSISSHJobSubmission();
- $xfer += $this->jobSubmission->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_addGSISSHJobSubmissionProtocol_args');
- if ($this->computeResourceId !== null) {
- $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1);
- $xfer += $output->writeString($this->computeResourceId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->jobSubmission !== null) {
- if (!is_object($this->jobSubmission)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('jobSubmission', TType::STRUCT, 2);
- $xfer += $this->jobSubmission->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_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::STRING,
- ),
- 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_addGSISSHJobSubmissionProtocol_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::STRING) {
- $xfer += $input->readString($this->success);
- } 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_addGSISSHJobSubmissionProtocol_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $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_addGlobusJobSubmissionProtocol_args {
- static $_TSPEC;
-
- public $computeResourceId = null;
- public $jobSubmission = null;
-
- public function __construct($vals=null) {
- if (!isset(self::$_TSPEC)) {
- self::$_TSPEC = array(
- 1 => array(
- 'var' => 'computeResourceId',
- 'type' => TType::STRING,
- ),
- 2 => array(
- 'var' => 'jobSubmission',
- 'type' => TType::STRUCT,
- 'class' => '\Airavata\Model\AppCatalog\GlobusJobSubmission',
- ),
- );
- }
- if (is_array($vals)) {
- if (isset($vals['computeResourceId'])) {
- $this->computeResourceId = $vals['computeResourceId'];
- }
- if (isset($vals['jobSubmission'])) {
- $this->jobSubmission = $vals['jobSubmission'];
- }
- }
- }
-
- public function getName() {
- return 'ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_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->jobSubmission = new \Airavata\Model\AppCatalog\GlobusJobSubmission();
- $xfer += $this->jobSubmission->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_args');
- if ($this->computeResourceId !== null) {
- $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1);
- $xfer += $output->writeString($this->computeResourceId);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->jobSubmission !== null) {
- if (!is_object($this->jobSubmission)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('jobSubmission', TType::STRUCT, 2);
- $xfer += $this->jobSubmission->write($output);
- $xfer += $output->writeFieldEnd();
- }
- $xfer += $output->writeFieldStop();
- $xfer += $output->writeStructEnd();
- return $xfer;
- }
-
-}
-
-class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_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::STRING,
- ),
- 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_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 0:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->success);
- } 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_addGlobusJobSubmissionProtocol_result');
- if ($this->success !== null) {
- $xfer += $output->writeFieldBegin('success', TType::STRING, 0);
- $xfer += $output->writeString($this->success);
- $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_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' => '\Airavata\Model\AppCatalog\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 \Airavata\Model\AppCatalog\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 $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::STRING,
- ),
- 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'];
- }
<TRUNCATED>