You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sa...@apache.org on 2014/05/22 23:57:10 UTC
[1/4] generated code
Repository: airavata
Updated Branches:
refs/heads/master 1a5f1a2b3 -> 1d76b48c1
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d76b48c/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
index 6f5a3a9..b8cc4be 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
@@ -105,7 +105,7 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
public function addComputeResourceDescription(\ComputeResourceDescription $computeResourceDescription)
{
$this->send_addComputeResourceDescription($computeResourceDescription);
- $this->recv_addComputeResourceDescription();
+ return $this->recv_addComputeResourceDescription();
}
public function send_addComputeResourceDescription(\ComputeResourceDescription $computeResourceDescription)
@@ -147,6 +147,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -156,13 +159,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addComputeResourceDescription failed: unknown result");
}
public function addSSHJobSubmissionProtocol($computeResourceId, \SSHJobSubmission $jobSubmission)
{
$this->send_addSSHJobSubmissionProtocol($computeResourceId, $jobSubmission);
- $this->recv_addSSHJobSubmissionProtocol();
+ return $this->recv_addSSHJobSubmissionProtocol();
}
public function send_addSSHJobSubmissionProtocol($computeResourceId, \SSHJobSubmission $jobSubmission)
@@ -205,6 +208,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -214,13 +220,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addSSHJobSubmissionProtocol failed: unknown result");
}
public function addGSISSHJobSubmissionProtocol($computeResourceId, \GSISSHJobSubmission $jobSubmission)
{
$this->send_addGSISSHJobSubmissionProtocol($computeResourceId, $jobSubmission);
- $this->recv_addGSISSHJobSubmissionProtocol();
+ return $this->recv_addGSISSHJobSubmissionProtocol();
}
public function send_addGSISSHJobSubmissionProtocol($computeResourceId, \GSISSHJobSubmission $jobSubmission)
@@ -263,6 +269,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -272,13 +281,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addGSISSHJobSubmissionProtocol failed: unknown result");
}
public function addGlobusJobSubmissionProtocol($computeResourceId, \GlobusJobSubmission $jobSubmission)
{
$this->send_addGlobusJobSubmissionProtocol($computeResourceId, $jobSubmission);
- $this->recv_addGlobusJobSubmissionProtocol();
+ return $this->recv_addGlobusJobSubmissionProtocol();
}
public function send_addGlobusJobSubmissionProtocol($computeResourceId, \GlobusJobSubmission $jobSubmission)
@@ -321,6 +330,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -330,13 +342,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addGlobusJobSubmissionProtocol failed: unknown result");
}
public function addSCPDataMovementProtocol($computeResourceId, \SCPDataMovement $dataMovement)
{
$this->send_addSCPDataMovementProtocol($computeResourceId, $dataMovement);
- $this->recv_addSCPDataMovementProtocol();
+ return $this->recv_addSCPDataMovementProtocol();
}
public function send_addSCPDataMovementProtocol($computeResourceId, \SCPDataMovement $dataMovement)
@@ -379,6 +391,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -388,13 +403,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addSCPDataMovementProtocol failed: unknown result");
}
public function addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement)
{
$this->send_addGridFTPDataMovementProtocol($computeResourceId, $dataMovement);
- $this->recv_addGridFTPDataMovementProtocol();
+ return $this->recv_addGridFTPDataMovementProtocol();
}
public function send_addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement)
@@ -437,6 +452,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -446,7 +464,7 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addGridFTPDataMovementProtocol failed: unknown result");
}
public function listComputeResourceDescriptions()
@@ -991,7 +1009,7 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
public function addApplicationInterface(\ApplicationInterface $applicationInterface)
{
$this->send_addApplicationInterface($applicationInterface);
- $this->recv_addApplicationInterface();
+ return $this->recv_addApplicationInterface();
}
public function send_addApplicationInterface(\ApplicationInterface $applicationInterface)
@@ -1033,6 +1051,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -1042,7 +1063,7 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addApplicationInterface failed: unknown result");
}
public function listApplicationInterfaceIds()
@@ -1167,7 +1188,7 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
public function addApplicationDeployment($applicationInterfaceId, \ApplicationDeployment $applicationDeployment)
{
$this->send_addApplicationDeployment($applicationInterfaceId, $applicationDeployment);
- $this->recv_addApplicationDeployment();
+ return $this->recv_addApplicationDeployment();
}
public function send_addApplicationDeployment($applicationInterfaceId, \ApplicationDeployment $applicationDeployment)
@@ -1210,6 +1231,9 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
$result->read($this->input_);
$this->input_->readMessageEnd();
}
+ if ($result->success !== null) {
+ return $result->success;
+ }
if ($result->ire !== null) {
throw $result->ire;
}
@@ -1219,7 +1243,7 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
if ($result->ase !== null) {
throw $result->ase;
}
- return;
+ throw new \Exception("addApplicationDeployment failed: unknown result");
}
public function listApplicationDeploymentIds($applicationInterfaceId)
@@ -1549,6 +1573,7 @@ class ApplicationCatalogAPI_addComputeResourceDescription_args {
class ApplicationCatalogAPI_addComputeResourceDescription_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -1556,6 +1581,10 @@ class ApplicationCatalogAPI_addComputeResourceDescription_result {
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,
@@ -1574,6 +1603,9 @@ class ApplicationCatalogAPI_addComputeResourceDescription_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -1605,6 +1637,13 @@ class ApplicationCatalogAPI_addComputeResourceDescription_result {
}
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();
@@ -1642,6 +1681,11 @@ class ApplicationCatalogAPI_addComputeResourceDescription_result {
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);
@@ -1764,6 +1808,7 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_args {
class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -1771,6 +1816,10 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
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,
@@ -1789,6 +1838,9 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -1820,6 +1872,13 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
}
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();
@@ -1857,6 +1916,11 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
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);
@@ -1979,6 +2043,7 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_args {
class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -1986,6 +2051,10 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
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,
@@ -2004,6 +2073,9 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -2035,6 +2107,13 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
}
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();
@@ -2072,6 +2151,11 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
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);
@@ -2194,6 +2278,7 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_args {
class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -2201,6 +2286,10 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
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,
@@ -2219,6 +2308,9 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -2250,6 +2342,13 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
}
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();
@@ -2287,6 +2386,11 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
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);
@@ -2409,6 +2513,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args {
class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -2416,6 +2521,10 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
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,
@@ -2434,6 +2543,9 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -2465,6 +2577,13 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
}
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();
@@ -2502,6 +2621,11 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
public function write($output) {
$xfer = 0;
$xfer += $output->writeStructBegin('ApplicationCatalogAPI_addSCPDataMovementProtocol_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);
@@ -2624,6 +2748,7 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args {
class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -2631,6 +2756,10 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
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,
@@ -2649,6 +2778,9 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -2680,6 +2812,13 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
}
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();
@@ -2717,6 +2856,11 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
public function write($output) {
$xfer = 0;
$xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGridFTPDataMovementProtocol_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);
@@ -4748,6 +4892,7 @@ class ApplicationCatalogAPI_addApplicationInterface_args {
class ApplicationCatalogAPI_addApplicationInterface_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -4755,6 +4900,10 @@ class ApplicationCatalogAPI_addApplicationInterface_result {
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,
@@ -4773,6 +4922,9 @@ class ApplicationCatalogAPI_addApplicationInterface_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -4804,6 +4956,13 @@ class ApplicationCatalogAPI_addApplicationInterface_result {
}
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();
@@ -4841,6 +5000,11 @@ class ApplicationCatalogAPI_addApplicationInterface_result {
public function write($output) {
$xfer = 0;
$xfer += $output->writeStructBegin('ApplicationCatalogAPI_addApplicationInterface_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);
@@ -5392,6 +5556,7 @@ class ApplicationCatalogAPI_addApplicationDeployment_args {
class ApplicationCatalogAPI_addApplicationDeployment_result {
static $_TSPEC;
+ public $success = null;
public $ire = null;
public $ace = null;
public $ase = null;
@@ -5399,6 +5564,10 @@ class ApplicationCatalogAPI_addApplicationDeployment_result {
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,
@@ -5417,6 +5586,9 @@ class ApplicationCatalogAPI_addApplicationDeployment_result {
);
}
if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
if (isset($vals['ire'])) {
$this->ire = $vals['ire'];
}
@@ -5448,6 +5620,13 @@ class ApplicationCatalogAPI_addApplicationDeployment_result {
}
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();
@@ -5485,6 +5664,11 @@ class ApplicationCatalogAPI_addApplicationDeployment_result {
public function write($output) {
$xfer = 0;
$xfer += $output->writeStructBegin('ApplicationCatalogAPI_addApplicationDeployment_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);
[3/4] generated code
Posted by sa...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d76b48c/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
index b1a968d..541eafd 100644
--- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
+++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
@@ -62,17 +62,17 @@ import org.slf4j.LoggerFactory;
*
* @param computeResourceDescription
*/
- public void addComputeResourceDescription(org.apache.airavata.model.appcatalog.ComputeResourceDescription computeResourceDescription) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addComputeResourceDescription(org.apache.airavata.model.appcatalog.ComputeResourceDescription computeResourceDescription) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
- public void addSSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addSSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
- public void addGSISSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GSISSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addGSISSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GSISSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
- public void addGlobusJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GlobusJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addGlobusJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GlobusJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
- public void addSCPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SCPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addSCPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SCPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
- public void addGridFTPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GridFTPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addGridFTPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GridFTPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
public List<String> listComputeResourceDescriptions() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
@@ -97,7 +97,7 @@ import org.slf4j.LoggerFactory;
*
* @param applicationInterface
*/
- public void addApplicationInterface(org.apache.airavata.model.appcatalog.ApplicationInterface applicationInterface) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addApplicationInterface(org.apache.airavata.model.appcatalog.ApplicationInterface applicationInterface) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
public List<String> listApplicationInterfaceIds() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
@@ -109,7 +109,7 @@ import org.slf4j.LoggerFactory;
* @param applicationInterfaceId
* @param applicationDeployment
*/
- public void addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.ApplicationDeployment applicationDeployment) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public String addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.ApplicationDeployment applicationDeployment) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
public List<String> listApplicationDeploymentIds(String applicationInterfaceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
@@ -207,10 +207,10 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetAPIVersion failed: unknown result");
}
- public void addComputeResourceDescription(org.apache.airavata.model.appcatalog.ComputeResourceDescription computeResourceDescription) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addComputeResourceDescription(org.apache.airavata.model.appcatalog.ComputeResourceDescription computeResourceDescription) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addComputeResourceDescription(computeResourceDescription);
- recv_addComputeResourceDescription();
+ return recv_addComputeResourceDescription();
}
public void send_addComputeResourceDescription(org.apache.airavata.model.appcatalog.ComputeResourceDescription computeResourceDescription) throws org.apache.thrift.TException
@@ -220,10 +220,13 @@ import org.slf4j.LoggerFactory;
sendBase("addComputeResourceDescription", args);
}
- public void recv_addComputeResourceDescription() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addComputeResourceDescription() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addComputeResourceDescription_result result = new addComputeResourceDescription_result();
receiveBase(result, "addComputeResourceDescription");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -233,13 +236,13 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addComputeResourceDescription failed: unknown result");
}
- public void addSSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addSSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addSSHJobSubmissionProtocol(computeResourceId, jobSubmission);
- recv_addSSHJobSubmissionProtocol();
+ return recv_addSSHJobSubmissionProtocol();
}
public void send_addSSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SSHJobSubmission jobSubmission) throws org.apache.thrift.TException
@@ -250,10 +253,13 @@ import org.slf4j.LoggerFactory;
sendBase("addSSHJobSubmissionProtocol", args);
}
- public void recv_addSSHJobSubmissionProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addSSHJobSubmissionProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addSSHJobSubmissionProtocol_result result = new addSSHJobSubmissionProtocol_result();
receiveBase(result, "addSSHJobSubmissionProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -263,13 +269,13 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addSSHJobSubmissionProtocol failed: unknown result");
}
- public void addGSISSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GSISSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addGSISSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GSISSHJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addGSISSHJobSubmissionProtocol(computeResourceId, jobSubmission);
- recv_addGSISSHJobSubmissionProtocol();
+ return recv_addGSISSHJobSubmissionProtocol();
}
public void send_addGSISSHJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GSISSHJobSubmission jobSubmission) throws org.apache.thrift.TException
@@ -280,10 +286,13 @@ import org.slf4j.LoggerFactory;
sendBase("addGSISSHJobSubmissionProtocol", args);
}
- public void recv_addGSISSHJobSubmissionProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addGSISSHJobSubmissionProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addGSISSHJobSubmissionProtocol_result result = new addGSISSHJobSubmissionProtocol_result();
receiveBase(result, "addGSISSHJobSubmissionProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -293,13 +302,13 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addGSISSHJobSubmissionProtocol failed: unknown result");
}
- public void addGlobusJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GlobusJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addGlobusJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GlobusJobSubmission jobSubmission) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addGlobusJobSubmissionProtocol(computeResourceId, jobSubmission);
- recv_addGlobusJobSubmissionProtocol();
+ return recv_addGlobusJobSubmissionProtocol();
}
public void send_addGlobusJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GlobusJobSubmission jobSubmission) throws org.apache.thrift.TException
@@ -310,10 +319,13 @@ import org.slf4j.LoggerFactory;
sendBase("addGlobusJobSubmissionProtocol", args);
}
- public void recv_addGlobusJobSubmissionProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addGlobusJobSubmissionProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addGlobusJobSubmissionProtocol_result result = new addGlobusJobSubmissionProtocol_result();
receiveBase(result, "addGlobusJobSubmissionProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -323,13 +335,13 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addGlobusJobSubmissionProtocol failed: unknown result");
}
- public void addSCPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SCPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addSCPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SCPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addSCPDataMovementProtocol(computeResourceId, dataMovement);
- recv_addSCPDataMovementProtocol();
+ return recv_addSCPDataMovementProtocol();
}
public void send_addSCPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.SCPDataMovement dataMovement) throws org.apache.thrift.TException
@@ -340,10 +352,13 @@ import org.slf4j.LoggerFactory;
sendBase("addSCPDataMovementProtocol", args);
}
- public void recv_addSCPDataMovementProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addSCPDataMovementProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addSCPDataMovementProtocol_result result = new addSCPDataMovementProtocol_result();
receiveBase(result, "addSCPDataMovementProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -353,13 +368,13 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addSCPDataMovementProtocol failed: unknown result");
}
- public void addGridFTPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GridFTPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addGridFTPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GridFTPDataMovement dataMovement) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addGridFTPDataMovementProtocol(computeResourceId, dataMovement);
- recv_addGridFTPDataMovementProtocol();
+ return recv_addGridFTPDataMovementProtocol();
}
public void send_addGridFTPDataMovementProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.GridFTPDataMovement dataMovement) throws org.apache.thrift.TException
@@ -370,10 +385,13 @@ import org.slf4j.LoggerFactory;
sendBase("addGridFTPDataMovementProtocol", args);
}
- public void recv_addGridFTPDataMovementProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addGridFTPDataMovementProtocol() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addGridFTPDataMovementProtocol_result result = new addGridFTPDataMovementProtocol_result();
receiveBase(result, "addGridFTPDataMovementProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -383,7 +401,7 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addGridFTPDataMovementProtocol failed: unknown result");
}
public List<String> listComputeResourceDescriptions() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
@@ -673,10 +691,10 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getComputeResourceDescriptionFromHostName failed: unknown result");
}
- public void addApplicationInterface(org.apache.airavata.model.appcatalog.ApplicationInterface applicationInterface) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addApplicationInterface(org.apache.airavata.model.appcatalog.ApplicationInterface applicationInterface) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addApplicationInterface(applicationInterface);
- recv_addApplicationInterface();
+ return recv_addApplicationInterface();
}
public void send_addApplicationInterface(org.apache.airavata.model.appcatalog.ApplicationInterface applicationInterface) throws org.apache.thrift.TException
@@ -686,10 +704,13 @@ import org.slf4j.LoggerFactory;
sendBase("addApplicationInterface", args);
}
- public void recv_addApplicationInterface() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addApplicationInterface() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addApplicationInterface_result result = new addApplicationInterface_result();
receiveBase(result, "addApplicationInterface");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -699,7 +720,7 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addApplicationInterface failed: unknown result");
}
public List<String> listApplicationInterfaceIds() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
@@ -765,10 +786,10 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getApplicationInterface failed: unknown result");
}
- public void addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.ApplicationDeployment applicationDeployment) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.ApplicationDeployment applicationDeployment) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_addApplicationDeployment(applicationInterfaceId, applicationDeployment);
- recv_addApplicationDeployment();
+ return recv_addApplicationDeployment();
}
public void send_addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.ApplicationDeployment applicationDeployment) throws org.apache.thrift.TException
@@ -779,10 +800,13 @@ import org.slf4j.LoggerFactory;
sendBase("addApplicationDeployment", args);
}
- public void recv_addApplicationDeployment() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ public String recv_addApplicationDeployment() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
addApplicationDeployment_result result = new addApplicationDeployment_result();
receiveBase(result, "addApplicationDeployment");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.ire != null) {
throw result.ire;
}
@@ -792,7 +816,7 @@ import org.slf4j.LoggerFactory;
if (result.ase != null) {
throw result.ase;
}
- return;
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addApplicationDeployment failed: unknown result");
}
public List<String> listApplicationDeploymentIds(String applicationInterfaceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
@@ -929,13 +953,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addComputeResourceDescription();
+ return (new Client(prot)).recv_addComputeResourceDescription();
}
}
@@ -964,13 +988,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addSSHJobSubmissionProtocol();
+ return (new Client(prot)).recv_addSSHJobSubmissionProtocol();
}
}
@@ -999,13 +1023,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addGSISSHJobSubmissionProtocol();
+ return (new Client(prot)).recv_addGSISSHJobSubmissionProtocol();
}
}
@@ -1034,13 +1058,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addGlobusJobSubmissionProtocol();
+ return (new Client(prot)).recv_addGlobusJobSubmissionProtocol();
}
}
@@ -1069,13 +1093,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addSCPDataMovementProtocol();
+ return (new Client(prot)).recv_addSCPDataMovementProtocol();
}
}
@@ -1104,13 +1128,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addGridFTPDataMovementProtocol();
+ return (new Client(prot)).recv_addGridFTPDataMovementProtocol();
}
}
@@ -1421,13 +1445,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addApplicationInterface();
+ return (new Client(prot)).recv_addApplicationInterface();
}
}
@@ -1517,13 +1541,13 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addApplicationDeployment();
+ return (new Client(prot)).recv_addApplicationDeployment();
}
}
@@ -1668,7 +1692,7 @@ import org.slf4j.LoggerFactory;
public addComputeResourceDescription_result getResult(I iface, addComputeResourceDescription_args args) throws org.apache.thrift.TException {
addComputeResourceDescription_result result = new addComputeResourceDescription_result();
try {
- iface.addComputeResourceDescription(args.computeResourceDescription);
+ result.success = iface.addComputeResourceDescription(args.computeResourceDescription);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -1696,7 +1720,7 @@ import org.slf4j.LoggerFactory;
public addSSHJobSubmissionProtocol_result getResult(I iface, addSSHJobSubmissionProtocol_args args) throws org.apache.thrift.TException {
addSSHJobSubmissionProtocol_result result = new addSSHJobSubmissionProtocol_result();
try {
- iface.addSSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ result.success = iface.addSSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -1724,7 +1748,7 @@ import org.slf4j.LoggerFactory;
public addGSISSHJobSubmissionProtocol_result getResult(I iface, addGSISSHJobSubmissionProtocol_args args) throws org.apache.thrift.TException {
addGSISSHJobSubmissionProtocol_result result = new addGSISSHJobSubmissionProtocol_result();
try {
- iface.addGSISSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ result.success = iface.addGSISSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -1752,7 +1776,7 @@ import org.slf4j.LoggerFactory;
public addGlobusJobSubmissionProtocol_result getResult(I iface, addGlobusJobSubmissionProtocol_args args) throws org.apache.thrift.TException {
addGlobusJobSubmissionProtocol_result result = new addGlobusJobSubmissionProtocol_result();
try {
- iface.addGlobusJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ result.success = iface.addGlobusJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -1780,7 +1804,7 @@ import org.slf4j.LoggerFactory;
public addSCPDataMovementProtocol_result getResult(I iface, addSCPDataMovementProtocol_args args) throws org.apache.thrift.TException {
addSCPDataMovementProtocol_result result = new addSCPDataMovementProtocol_result();
try {
- iface.addSCPDataMovementProtocol(args.computeResourceId, args.dataMovement);
+ result.success = iface.addSCPDataMovementProtocol(args.computeResourceId, args.dataMovement);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -1808,7 +1832,7 @@ import org.slf4j.LoggerFactory;
public addGridFTPDataMovementProtocol_result getResult(I iface, addGridFTPDataMovementProtocol_args args) throws org.apache.thrift.TException {
addGridFTPDataMovementProtocol_result result = new addGridFTPDataMovementProtocol_result();
try {
- iface.addGridFTPDataMovementProtocol(args.computeResourceId, args.dataMovement);
+ result.success = iface.addGridFTPDataMovementProtocol(args.computeResourceId, args.dataMovement);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -2089,7 +2113,7 @@ import org.slf4j.LoggerFactory;
public addApplicationInterface_result getResult(I iface, addApplicationInterface_args args) throws org.apache.thrift.TException {
addApplicationInterface_result result = new addApplicationInterface_result();
try {
- iface.addApplicationInterface(args.applicationInterface);
+ result.success = iface.addApplicationInterface(args.applicationInterface);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -2173,7 +2197,7 @@ import org.slf4j.LoggerFactory;
public addApplicationDeployment_result getResult(I iface, addApplicationDeployment_args args) throws org.apache.thrift.TException {
addApplicationDeployment_result result = new addApplicationDeployment_result();
try {
- iface.addApplicationDeployment(args.applicationInterfaceId, args.applicationDeployment);
+ result.success = iface.addApplicationDeployment(args.applicationInterfaceId, args.applicationDeployment);
} catch (org.apache.airavata.model.error.InvalidRequestException ire) {
result.ire = ire;
} catch (org.apache.airavata.model.error.AiravataClientException ace) {
@@ -2330,7 +2354,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class addComputeResourceDescription<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addComputeResourceDescription_args, Void> {
+ public static class addComputeResourceDescription<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addComputeResourceDescription_args, String> {
public addComputeResourceDescription() {
super("addComputeResourceDescription");
}
@@ -2339,11 +2363,12 @@ import org.slf4j.LoggerFactory;
return new addComputeResourceDescription_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addComputeResourceDescription_result result = new addComputeResourceDescription_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -2391,12 +2416,12 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addComputeResourceDescription_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addComputeResourceDescription_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addComputeResourceDescription(args.computeResourceDescription,resultHandler);
}
}
- public static class addSSHJobSubmissionProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHJobSubmissionProtocol_args, Void> {
+ public static class addSSHJobSubmissionProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHJobSubmissionProtocol_args, String> {
public addSSHJobSubmissionProtocol() {
super("addSSHJobSubmissionProtocol");
}
@@ -2405,11 +2430,12 @@ import org.slf4j.LoggerFactory;
return new addSSHJobSubmissionProtocol_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addSSHJobSubmissionProtocol_result result = new addSSHJobSubmissionProtocol_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -2457,12 +2483,12 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addSSHJobSubmissionProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addSSHJobSubmissionProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addSSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission,resultHandler);
}
}
- public static class addGSISSHJobSubmissionProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGSISSHJobSubmissionProtocol_args, Void> {
+ public static class addGSISSHJobSubmissionProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGSISSHJobSubmissionProtocol_args, String> {
public addGSISSHJobSubmissionProtocol() {
super("addGSISSHJobSubmissionProtocol");
}
@@ -2471,11 +2497,12 @@ import org.slf4j.LoggerFactory;
return new addGSISSHJobSubmissionProtocol_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addGSISSHJobSubmissionProtocol_result result = new addGSISSHJobSubmissionProtocol_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -2523,12 +2550,12 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addGSISSHJobSubmissionProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addGSISSHJobSubmissionProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addGSISSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission,resultHandler);
}
}
- public static class addGlobusJobSubmissionProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGlobusJobSubmissionProtocol_args, Void> {
+ public static class addGlobusJobSubmissionProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGlobusJobSubmissionProtocol_args, String> {
public addGlobusJobSubmissionProtocol() {
super("addGlobusJobSubmissionProtocol");
}
@@ -2537,11 +2564,12 @@ import org.slf4j.LoggerFactory;
return new addGlobusJobSubmissionProtocol_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addGlobusJobSubmissionProtocol_result result = new addGlobusJobSubmissionProtocol_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -2589,12 +2617,12 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addGlobusJobSubmissionProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addGlobusJobSubmissionProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addGlobusJobSubmissionProtocol(args.computeResourceId, args.jobSubmission,resultHandler);
}
}
- public static class addSCPDataMovementProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSCPDataMovementProtocol_args, Void> {
+ public static class addSCPDataMovementProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSCPDataMovementProtocol_args, String> {
public addSCPDataMovementProtocol() {
super("addSCPDataMovementProtocol");
}
@@ -2603,11 +2631,12 @@ import org.slf4j.LoggerFactory;
return new addSCPDataMovementProtocol_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addSCPDataMovementProtocol_result result = new addSCPDataMovementProtocol_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -2655,12 +2684,12 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addSCPDataMovementProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addSCPDataMovementProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addSCPDataMovementProtocol(args.computeResourceId, args.dataMovement,resultHandler);
}
}
- public static class addGridFTPDataMovementProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGridFTPDataMovementProtocol_args, Void> {
+ public static class addGridFTPDataMovementProtocol<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGridFTPDataMovementProtocol_args, String> {
public addGridFTPDataMovementProtocol() {
super("addGridFTPDataMovementProtocol");
}
@@ -2669,11 +2698,12 @@ import org.slf4j.LoggerFactory;
return new addGridFTPDataMovementProtocol_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addGridFTPDataMovementProtocol_result result = new addGridFTPDataMovementProtocol_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -2721,7 +2751,7 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addGridFTPDataMovementProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addGridFTPDataMovementProtocol_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addGridFTPDataMovementProtocol(args.computeResourceId, args.dataMovement,resultHandler);
}
}
@@ -3330,7 +3360,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class addApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addApplicationInterface_args, Void> {
+ public static class addApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addApplicationInterface_args, String> {
public addApplicationInterface() {
super("addApplicationInterface");
}
@@ -3339,11 +3369,12 @@ import org.slf4j.LoggerFactory;
return new addApplicationInterface_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addApplicationInterface_result result = new addApplicationInterface_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -3391,7 +3422,7 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addApplicationInterface(args.applicationInterface,resultHandler);
}
}
@@ -3530,7 +3561,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class addApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addApplicationDeployment_args, Void> {
+ public static class addApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addApplicationDeployment_args, String> {
public addApplicationDeployment() {
super("addApplicationDeployment");
}
@@ -3539,11 +3570,12 @@ import org.slf4j.LoggerFactory;
return new addApplicationDeployment_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
addApplicationDeployment_result result = new addApplicationDeployment_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -3591,7 +3623,7 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ public void start(I iface, addApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
iface.addApplicationDeployment(args.applicationInterfaceId, args.applicationDeployment,resultHandler);
}
}
@@ -4687,6 +4719,7 @@ import org.slf4j.LoggerFactory;
public static class addComputeResourceDescription_result implements org.apache.thrift.TBase<addComputeResourceDescription_result, addComputeResourceDescription_result._Fields>, java.io.Serializable, Cloneable, Comparable<addComputeResourceDescription_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addComputeResourceDescription_result");
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0);
private static final org.apache.thrift.protocol.TField IRE_FIELD_DESC = new org.apache.thrift.protocol.TField("ire", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ACE_FIELD_DESC = new org.apache.thrift.protocol.TField("ace", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField ASE_FIELD_DESC = new org.apache.thrift.protocol.TField("ase", org.apache.thrift.protocol.TType.STRUCT, (short)3);
@@ -4697,12 +4730,14 @@ import org.slf4j.LoggerFactory;
schemes.put(TupleScheme.class, new addComputeResourceDescription_resultTupleSchemeFactory());
}
+ public String success; // required
public org.apache.airavata.model.error.InvalidRequestException ire; // required
public org.apache.airavata.model.error.AiravataClientException ace; // required
public org.apache.airavata.model.error.AiravataSystemException ase; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ SUCCESS((short)0, "success"),
IRE((short)1, "ire"),
ACE((short)2, "ace"),
ASE((short)3, "ase");
@@ -4720,6 +4755,8 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
+ case 0: // SUCCESS
+ return SUCCESS;
case 1: // IRE
return IRE;
case 2: // ACE
@@ -4769,6 +4806,8 @@ import org.slf4j.LoggerFactory;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
tmpMap.put(_Fields.ACE, new org.apache.thrift.meta_data.FieldMetaData("ace", org.apache.thrift.TFieldRequirementType.DEFAULT,
@@ -4783,11 +4822,13 @@ import org.slf4j.LoggerFactory;
}
public addComputeResourceDescription_result(
+ String success,
org.apache.airavata.model.error.InvalidRequestException ire,
org.apache.airavata.model.error.AiravataClientException ace,
org.apache.airavata.model.error.AiravataSystemException ase)
{
this();
+ this.success = success;
this.ire = ire;
this.ace = ace;
this.ase = ase;
@@ -4797,6 +4838,9 @@ import org.slf4j.LoggerFactory;
* Performs a deep copy on <i>other</i>.
*/
public addComputeResourceDescription_result(addComputeResourceDescription_result other) {
+ if (other.isSetSuccess()) {
+ this.success = other.success;
+ }
if (other.isSetIre()) {
this.ire = new org.apache.airavata.model.error.InvalidRequestException(other.ire);
}
@@ -4814,11 +4858,36 @@ import org.slf4j.LoggerFactory;
@Override
public void clear() {
+ this.success = null;
this.ire = null;
this.ace = null;
this.ase = null;
}
+ public String getSuccess() {
+ return this.success;
+ }
+
+ public addComputeResourceDescription_result setSuccess(String success) {
+ this.success = success;
+ return this;
+ }
+
+ public void unsetSuccess() {
+ this.success = null;
+ }
+
+ /** Returns true if field success is set (has been assigned a value) and false otherwise */
+ public boolean isSetSuccess() {
+ return this.success != null;
+ }
+
+ public void setSuccessIsSet(boolean value) {
+ if (!value) {
+ this.success = null;
+ }
+ }
+
public org.apache.airavata.model.error.InvalidRequestException getIre() {
return this.ire;
}
@@ -4893,6 +4962,14 @@ import org.slf4j.LoggerFactory;
public void setFieldValue(_Fields field, Object value) {
switch (field) {
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((String)value);
+ }
+ break;
+
case IRE:
if (value == null) {
unsetIre();
@@ -4922,6 +4999,9 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
+ case SUCCESS:
+ return getSuccess();
+
case IRE:
return getIre();
@@ -4942,6 +5022,8 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
+ case SUCCESS:
+ return isSetSuccess();
case IRE:
return isSetIre();
case ACE:
@@ -4965,6 +5047,15 @@ import org.slf4j.LoggerFactory;
if (that == null)
return false;
+ boolean this_present_success = true && this.isSetSuccess();
+ boolean that_present_success = true && that.isSetSuccess();
+ if (this_present_success || that_present_success) {
+ if (!(this_present_success && that_present_success))
+ return false;
+ if (!this.success.equals(that.success))
+ return false;
+ }
+
boolean this_present_ire = true && this.isSetIre();
boolean that_present_ire = true && that.isSetIre();
if (this_present_ire || that_present_ire) {
@@ -5008,6 +5099,16 @@ import org.slf4j.LoggerFactory;
int lastComparison = 0;
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(isSetIre()).compareTo(other.isSetIre());
if (lastComparison != 0) {
return lastComparison;
@@ -5058,6 +5159,14 @@ import org.slf4j.LoggerFactory;
StringBuilder sb = new StringBuilder("addComputeResourceDescription_result(");
boolean first = true;
+ sb.append("success:");
+ if (this.success == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.success);
+ }
+ first = false;
+ if (!first) sb.append(", ");
sb.append("ire:");
if (this.ire == null) {
sb.append("null");
@@ -5124,6 +5233,14 @@ import org.slf4j.LoggerFactory;
break;
}
switch (schemeField.id) {
+ case 0: // SUCCESS
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.success = iprot.readString();
+ struct.setSuccessIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
case 1: // IRE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.ire = new org.apache.airavata.model.error.InvalidRequestException();
@@ -5166,6 +5283,11 @@ import org.slf4j.LoggerFactory;
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.success != null) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeString(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.ire != null) {
oprot.writeFieldBegin(IRE_FIELD_DESC);
struct.ire.write(oprot);
@@ -5199,16 +5321,22 @@ import org.slf4j.LoggerFactory;
public void write(org.apache.thrift.protocol.TProtocol prot, addComputeResourceDescription_result struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
- if (struct.isSetIre()) {
+ if (struct.isSetSuccess()) {
optionals.set(0);
}
- if (struct.isSetAce()) {
+ if (struct.isSetIre()) {
optionals.set(1);
}
- if (struct.isSetAse()) {
+ if (struct.isSetAce()) {
optionals.set(2);
}
- oprot.writeBitSet(optionals, 3);
+ if (struct.isSetAse()) {
+ optionals.set(3);
+ }
+ oprot.writeBitSet(optionals, 4);
+ if (struct.isSetSuccess()) {
+ oprot.writeString(struct.success);
+ }
if (struct.isSetIre()) {
struct.ire.write(oprot);
}
@@ -5223,18 +5351,22 @@ import org.slf4j.LoggerFactory;
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, addComputeResourceDescription_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(3);
+ BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
+ struct.success = iprot.readString();
+ struct.setSuccessIsSet(true);
+ }
+ if (incoming.get(1)) {
struct.ire = new org.apache.airavata.model.error.InvalidRequestException();
struct.ire.read(iprot);
struct.setIreIsSet(true);
}
- if (incoming.get(1)) {
+ if (incoming.get(2)) {
struct.ace = new org.apache.airavata.model.error.AiravataClientException();
struct.ace.read(iprot);
struct.setAceIsSet(true);
}
- if (incoming.get(2)) {
+ if (incoming.get(3)) {
struct.ase = new org.apache.airavata.model.error.AiravataSystemException();
struct.ase.read(iprot);
struct.setAseIsSet(true);
@@ -5695,6 +5827,7 @@ import org.slf4j.LoggerFactory;
public static class addSSHJobSubmissionProtocol_result implements org.apache.thrift.TBase<addSSHJobSubmissionProtocol_result, addSSHJobSubmissionProtocol_result._Fields>, java.io.Serializable, Cloneable, Comparable<addSSHJobSubmissionProtocol_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addSSHJobSubmissionProtocol_result");
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0);
private static final org.apache.thrift.protocol.TField IRE_FIELD_DESC = new org.apache.thrift.protocol.TField("ire", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ACE_FIELD_DESC = new org.apache.thrift.protocol.TField("ace", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField ASE_FIELD_DESC = new org.apache.thrift.protocol.TField("ase", org.apache.thrift.protocol.TType.STRUCT, (short)3);
@@ -5705,12 +5838,14 @@ import org.slf4j.LoggerFactory;
schemes.put(TupleScheme.class, new addSSHJobSubmissionProtocol_resultTupleSchemeFactory());
}
+ public String success; // required
public org.apache.airavata.model.error.InvalidRequestException ire; // required
public org.apache.airavata.model.error.AiravataClientException ace; // required
public org.apache.airavata.model.error.AiravataSystemException ase; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ SUCCESS((short)0, "success"),
IRE((short)1, "ire"),
ACE((short)2, "ace"),
ASE((short)3, "ase");
@@ -5728,6 +5863,8 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
+ case 0: // SUCCESS
+ return SUCCESS;
case 1: // IRE
return IRE;
case 2: // ACE
@@ -5777,6 +5914,8 @@ import org.slf4j.LoggerFactory;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
tmpMap.put(_Fields.ACE, new org.apache.thrift.meta_data.FieldMetaData("ace", org.apache.thrift.TFieldRequirementType.DEFAULT,
@@ -5791,11 +5930,13 @@ import org.slf4j.LoggerFactory;
}
public addSSHJobSubmissionProtocol_result(
+ String success,
org.apache.airavata.model.error.InvalidRequestException ire,
org.apache.airavata.model.error.AiravataClientException ace,
org.apache.airavata.model.error.AiravataSystemException ase)
{
this();
+ this.success = success;
this.ire = ire;
this.ace = ace;
this.ase = ase;
@@ -5805,6 +5946,9 @@ import org.slf4j.LoggerFactory;
* Performs a deep copy on <i>other</i>.
*/
public addSSHJobSubmissionProtocol_result(addSSHJobSubmissionProtocol_result other) {
+ if (other.isSetSuccess()) {
+ this.success = other.success;
+ }
if (other.isSetIre()) {
this.ire = new org.apache.airavata.model.error.InvalidRequestException(other.ire);
}
@@ -5822,11 +5966,36 @@ import org.slf4j.LoggerFactory;
@Override
public void clear() {
+ this.success = null;
this.ire = null;
this.ace = null;
this.ase = null;
}
+ public String getSuccess() {
+ return this.success;
+ }
+
+ public addSSHJobSubmissionProtocol_result setSuccess(String success) {
+ this.success = success;
+ return this;
+ }
+
+ public void unsetSuccess() {
+ this.success = null;
+ }
+
+ /** Returns true if field success is set (has been assigned a value) and false otherwise */
+ public boolean isSetSuccess() {
+ return this.success != null;
+ }
+
+ public void setSuccessIsSet(boolean value) {
+ if (!value) {
+ this.success = null;
+ }
+ }
+
public org.apache.airavata.model.error.InvalidRequestException getIre() {
return this.ire;
}
@@ -5901,6 +6070,14 @@ import org.slf4j.LoggerFactory;
public void setFieldValue(_Fields field, Object value) {
switch (field) {
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((String)value);
+ }
+ break;
+
case IRE:
if (value == null) {
unsetIre();
@@ -5930,6 +6107,9 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
+ case SUCCESS:
+ return getSuccess();
+
case IRE:
return getIre();
@@ -5950,6 +6130,8 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
+ case SUCCESS:
+ return isSetSuccess();
case IRE:
return isSetIre();
case ACE:
@@ -5973,6 +6155,15 @@ import org.slf4j.LoggerFactory;
if (that == null)
return false;
+ boolean this_present_success = true && this.isSetSuccess();
+ boolean that_present_success = true && that.isSetSuccess();
+ if (this_present_success || that_present_success) {
+ if (!(this_present_success && that_present_success))
+ return false;
+ if (!this.success.equals(that.success))
+ return false;
+ }
+
boolean this_present_ire = true && this.isSetIre();
boolean that_present_ire = true && that.isSetIre();
if (this_present_ire || that_present_ire) {
@@ -6016,6 +6207,16 @@ import org.slf4j.LoggerFactory;
int lastComparison = 0;
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(isSetIre()).compareTo(other.isSetIre());
if (lastComparison != 0) {
return lastComparison;
@@ -6066,6 +6267,14 @@ import org.slf4j.LoggerFactory;
StringBuilder sb = new StringBuilder("addSSHJobSubmissionProtocol_result(");
boolean first = true;
+ sb.append("success:");
+ if (this.success == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.success);
+ }
+ first = false;
+ if (!first) sb.append(", ");
sb.append("ire:");
if (this.ire == null) {
sb.append("null");
@@ -6132,6 +6341,14 @@ import org.slf4j.LoggerFactory;
break;
}
switch (schemeField.id) {
+ case 0: // SUCCESS
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.success = iprot.readString();
+ struct.setSuccessIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
case 1: // IRE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.ire = new org.apache.airavata.model.error.InvalidRequestException();
@@ -6174,6 +6391,11 @@ import org.slf4j.LoggerFactory;
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.success != null) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeString(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.ire != null) {
oprot.writeFieldBegin(IRE_FIELD_DESC);
struct.ire.write(oprot);
@@ -6207,16 +6429,22 @@ import org.slf4j.LoggerFactory;
public void write(org.apache.thrift.protocol.TProtocol prot, addSSHJobSubmissionProtocol_result struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
- if (struct.isSetIre()) {
+ if (struct.isSetSuccess()) {
optionals.set(0);
}
- if (struct.isSetAce()) {
+ if (struct.isSetIre()) {
optionals.set(1);
}
- if (struct.isSetAse()) {
+ if (struct.isSetAce()) {
optionals.set(2);
}
- oprot.writeBitSet(optionals, 3);
+ if (struct.isSetAse()) {
+ optionals.set(3);
+ }
+ oprot.writeBitSet(optionals, 4);
+ if (struct.isSetSuccess()) {
+ oprot.writeString(struct.success);
+ }
if (struct.isSetIre()) {
struct.ire.write(oprot);
}
@@ -6231,18 +6459,22 @@ import org.slf4j.LoggerFactory;
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, addSSHJobSubmissionProtocol_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(3);
+ BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
+ struct.success = iprot.readString();
+ struct.setSuccessIsSet(true);
+ }
+ if (incoming.get(1)) {
struct.ire = new org.apache.airavata.model.error.InvalidRequestException();
struct.ire.read(iprot);
struct.setIreIsSet(true);
}
- if (incoming.get(1)) {
+ if (incoming.get(2)) {
struct.ace = new org.apache.airavata.model.error.AiravataClientException();
struct.ace.read(iprot);
struct.setAceIsSet(true);
}
- if (incoming.get(2)) {
+ if (incoming.get(3)) {
struct.ase = new org.apache.airavata.model.error.AiravataSystemException();
struct.ase.read(iprot);
struct.setAseIsSet(true);
@@ -6703,6 +6935,7 @@ import org.slf4j.LoggerFactory;
public static class addGSISSHJobSubmissionProtocol_result implements org.apache.thrift.TBase<addGSISSHJobSubmissionProtocol_result, addGSISSHJobSubmissionProtocol_result._Fields>, java.io.Serializable, Cloneable, Comparable<addGSISSHJobSubmissionProtocol_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addGSISSHJobSubmissionProtocol_result");
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0);
private static final org.apache.thrift.protocol.TField IRE_FIELD_DESC = new org.apache.thrift.protocol.TField("ire", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField ACE_FIELD_DESC = new org.apache.thrift.protocol.TField("ace", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField ASE_FIELD_DESC = new org.apache.thrift.protocol.TField("ase", org.apache.thrift.protocol.TType.STRUCT, (short)3);
@@ -6713,12 +6946,14 @@ import org.slf4j.LoggerFactory;
schemes.put(TupleScheme.class, new addGSISSHJobSubmissionProtocol_resultTupleSchemeFactory());
}
+ public String success; // required
public org.apache.airavata.model.error.InvalidRequestException ire; // required
public org.apache.airavata.model.error.AiravataClientException ace; // required
public org.apache.airavata.model.error.AiravataSystemException ase; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ SUCCESS((short)0, "success"),
IRE((short)1, "ire"),
ACE((short)2, "ace"),
ASE((short)3, "ase");
@@ -6736,6 +6971,8 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
+ case 0: // SUCCESS
+ return SUCCESS;
case 1: // IRE
return IRE;
case 2: // ACE
@@ -6785,6 +7022,8 @@ import org.slf4j.LoggerFactory;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
tmpMap.put(_Fields.ACE, new org.apache.thrift.meta_data.FieldMetaData("ace", org.apache.thrift.TFieldRequirementType.DEFAULT,
@@ -6799,11 +7038,13 @@ import org.slf4j.LoggerFactory;
}
public addGSISSHJobSubmissionProtocol_result(
+ String success,
org.apache.airavata.model.error.InvalidRequestException ire,
org.apache.airavata.model.error.AiravataClientException ace,
org.apache.airavata.model.error.AiravataSystemException ase)
{
this();
+ this.success = success;
this.ire = ire;
this.ace = ace;
this.ase = ase;
@@ -6813,6 +7054,9 @@ import org.slf4j.LoggerFactory;
* Performs a deep copy on <i>other</i>.
*/
public addGSISSHJobSubmissionProtocol_result(addGSISSHJobSubmissionProtocol_result other) {
+ if (other.isSetSuccess()) {
+ this.success = other.success;
+ }
if (other.isSetIre()) {
this.ire = new org.apache.airavata.model.error.InvalidRequestException(other.ire);
}
@@ -6830,11 +7074,36 @@ import org.slf4j.LoggerFactory;
@Override
public void clear() {
+ this.success = null;
this.ire = null;
this.ace = null;
this.ase = null;
}
+ public String getSuccess() {
+ return this.success;
+ }
+
+ public addGSISSHJobSubmissionProtocol_result setSuccess(String success) {
+ this.success = success;
+ return this;
+ }
+
+ public void unsetSuccess() {
+ this.success = null;
+ }
+
+ /** Returns true if field success is set (has been assigned a value) and false otherwise */
+ public boolean isSetSuccess() {
+ return this.success != null;
+ }
+
+ public void setSuccessIsSet(boolean value) {
+ if (!value) {
+ this.success = null;
+ }
+ }
+
public org.apache.airavata.model.error.InvalidRequestException getIre() {
return this.ire;
}
@@ -6909,6 +7178,14 @@ import org.slf4j.LoggerFactory;
public void setFieldValue(_Fields field, Object value) {
switch (field) {
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((String)value);
+ }
+ break;
+
case IRE:
if (value == null) {
unsetIre();
@@ -6938,6 +7215,9 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
+ case SUCCESS:
+ return getSuccess();
+
case IRE:
return getIre();
@@ -6958,6 +7238,8 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
+ case SUCCESS:
+ return isSetSuccess();
case IRE:
return isSetIre();
case ACE:
@@ -6981,6 +7263,15 @@ import org.slf4j.LoggerFactory;
if (that == null)
return false;
+ boolean this_present_success = true && this.isSetSuccess();
+ boolean that_present_success = true && that.isSetSuccess();
+ if (this_present_success || that_present_success) {
+ if (!(this_present_success && that_present_success))
+ return false;
+ if (!this.success.equals(that.success))
+ return false;
+ }
+
boolean this_present_ire = true && this.isSetIre();
boolean that_present_ire = true && that.isSetIre();
if (this_present_ire || that_present_ire) {
@@ -7024,6 +7315,16 @@ import org.slf4j.LoggerFactory;
int lastComparison = 0;
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(isSetIre()).compareTo(other.isSetIre());
if (lastComparison != 0) {
return lastComparison;
@@ -7074,6 +7375,14 @@ import org.slf4j.LoggerFactory;
StringBuilder sb = new StringBuilder("addGSISSHJobSubmissionProtocol_result(");
boolean first = true;
+ sb.append("success:");
+ if (this.success == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.success);
+ }
+ first = false;
+ if (!first) sb.append(", ");
sb.append("ire:");
if (this.ire == null) {
sb.append("null");
@@ -7140,6 +7449,14 @@ import org.slf4j.LoggerFactory;
break;
}
switch (schemeField.id) {
+ case 0: // SUCCESS
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.success = iprot.readString();
+ struct.setSuccessIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
case 1: // IRE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.ire = new org.apache.airavata.model.error.InvalidRequestException();
@@ -7182,6 +7499,11 @@ import org.slf4j.LoggerFactory;
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.success != null) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeString(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.ire != null) {
oprot.writeFieldBegin(IRE_FIELD_DESC);
struct.ire.write(oprot);
@@ -7215,16 +7537,22 @@ import org.slf4j.LoggerFactory;
public void write(org.apache.thrift.protocol.TProtocol prot, addGSISSHJobSubmissionProtocol_result struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
- if (struct.isSetIre()) {
+ if (struct.isSetSuccess()) {
optionals.set(0);
}
- if (struct.isSetAce()) {
+ if (struct.isSetIre()) {
optionals.set(1);
}
- if (struct.isSetAse()) {
+ if (struct.isSetAce()) {
optionals.set(2);
}
- oprot.writeBitSet(optionals, 3);
+ if (struct.isSetAse()) {
+ optionals.set(3);
+ }
+ oprot.writeBitSet(optionals, 4);
+ if (struct.isSetSuccess()) {
+ oprot.writeString(struct.success);
+ }
if (struct.isSetIre()) {
struct.ire.write(oprot);
}
@@ -7239,18 +7567,22 @@ import org.slf4j.LoggerFactory;
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, addGSISSHJobSubmissionProtocol_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(3);
+ BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
+ struct.success = iprot.readString();
+ struct.setSuccessIsSet(true);
+ }
+ if (incoming.get(1)) {
struct.ire = new org.apache.airavata.model.error.InvalidRequestException();
struct.ire.read(iprot);
struct.setIreIsSet(true);
}
- if (incoming.get(1)) {
+ if (incoming.get(2)) {
struct.ace = new org.apache.airavata.model.error.Airavata
<TRUNCATED>
[2/4] generated code
Posted by sa...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d76b48c/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp
index 032f449..3d0302d 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.cpp
@@ -238,6 +238,14 @@ uint32_t ApplicationCatalogAPI_addComputeResourceDescription_result::read(::apac
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -280,7 +288,11 @@ uint32_t ApplicationCatalogAPI_addComputeResourceDescription_result::write(::apa
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addComputeResourceDescription_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -318,6 +330,14 @@ uint32_t ApplicationCatalogAPI_addComputeResourceDescription_presult::read(::apa
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -462,6 +482,14 @@ uint32_t ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result::read(::apache
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -504,7 +532,11 @@ uint32_t ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result::write(::apach
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -542,6 +574,14 @@ uint32_t ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult::read(::apach
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -686,6 +726,14 @@ uint32_t ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result::read(::apa
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -728,7 +776,11 @@ uint32_t ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result::write(::ap
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -766,6 +818,14 @@ uint32_t ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult::read(::ap
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -910,6 +970,14 @@ uint32_t ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result::read(::apa
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -952,7 +1020,11 @@ uint32_t ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result::write(::ap
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -990,6 +1062,14 @@ uint32_t ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult::read(::ap
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -1134,6 +1214,14 @@ uint32_t ApplicationCatalogAPI_addSCPDataMovementProtocol_result::read(::apache:
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -1176,7 +1264,11 @@ uint32_t ApplicationCatalogAPI_addSCPDataMovementProtocol_result::write(::apache
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addSCPDataMovementProtocol_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -1214,6 +1306,14 @@ uint32_t ApplicationCatalogAPI_addSCPDataMovementProtocol_presult::read(::apache
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -1358,6 +1458,14 @@ uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result::read(::apa
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -1400,7 +1508,11 @@ uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result::write(::ap
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -1438,6 +1550,14 @@ uint32_t ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult::read(::ap
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -3596,6 +3716,14 @@ uint32_t ApplicationCatalogAPI_addApplicationInterface_result::read(::apache::th
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -3638,7 +3766,11 @@ uint32_t ApplicationCatalogAPI_addApplicationInterface_result::write(::apache::t
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addApplicationInterface_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -3676,6 +3808,14 @@ uint32_t ApplicationCatalogAPI_addApplicationInterface_presult::read(::apache::t
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -4278,6 +4418,14 @@ uint32_t ApplicationCatalogAPI_addApplicationDeployment_result::read(::apache::t
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->success);
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -4320,7 +4468,11 @@ uint32_t ApplicationCatalogAPI_addApplicationDeployment_result::write(::apache::
xfer += oprot->writeStructBegin("ApplicationCatalogAPI_addApplicationDeployment_result");
- if (this->__isset.ire) {
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
+ xfer += oprot->writeString(this->success);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ire) {
xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
xfer += this->ire.write(oprot);
xfer += oprot->writeFieldEnd();
@@ -4358,6 +4510,14 @@ uint32_t ApplicationCatalogAPI_addApplicationDeployment_presult::read(::apache::
}
switch (fid)
{
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString((*(this->success)));
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
case 1:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->ire.read(iprot);
@@ -4952,10 +5112,10 @@ void ApplicationCatalogAPIClient::recv_GetAPIVersion(std::string& _return)
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetAPIVersion failed: unknown result");
}
-void ApplicationCatalogAPIClient::addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription)
+void ApplicationCatalogAPIClient::addComputeResourceDescription(std::string& _return, const ::ComputeResourceDescription& computeResourceDescription)
{
send_addComputeResourceDescription(computeResourceDescription);
- recv_addComputeResourceDescription();
+ recv_addComputeResourceDescription(_return);
}
void ApplicationCatalogAPIClient::send_addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription)
@@ -4972,7 +5132,7 @@ void ApplicationCatalogAPIClient::send_addComputeResourceDescription(const ::Co
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addComputeResourceDescription()
+void ApplicationCatalogAPIClient::recv_addComputeResourceDescription(std::string& _return)
{
int32_t rseqid = 0;
@@ -4998,10 +5158,15 @@ void ApplicationCatalogAPIClient::recv_addComputeResourceDescription()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addComputeResourceDescription_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5011,13 +5176,13 @@ void ApplicationCatalogAPIClient::recv_addComputeResourceDescription()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addComputeResourceDescription failed: unknown result");
}
-void ApplicationCatalogAPIClient::addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission)
+void ApplicationCatalogAPIClient::addSSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission)
{
send_addSSHJobSubmissionProtocol(computeResourceId, jobSubmission);
- recv_addSSHJobSubmissionProtocol();
+ recv_addSSHJobSubmissionProtocol(_return);
}
void ApplicationCatalogAPIClient::send_addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission)
@@ -5035,7 +5200,7 @@ void ApplicationCatalogAPIClient::send_addSSHJobSubmissionProtocol(const std::st
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addSSHJobSubmissionProtocol()
+void ApplicationCatalogAPIClient::recv_addSSHJobSubmissionProtocol(std::string& _return)
{
int32_t rseqid = 0;
@@ -5061,10 +5226,15 @@ void ApplicationCatalogAPIClient::recv_addSSHJobSubmissionProtocol()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5074,13 +5244,13 @@ void ApplicationCatalogAPIClient::recv_addSSHJobSubmissionProtocol()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addSSHJobSubmissionProtocol failed: unknown result");
}
-void ApplicationCatalogAPIClient::addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission)
+void ApplicationCatalogAPIClient::addGSISSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission)
{
send_addGSISSHJobSubmissionProtocol(computeResourceId, jobSubmission);
- recv_addGSISSHJobSubmissionProtocol();
+ recv_addGSISSHJobSubmissionProtocol(_return);
}
void ApplicationCatalogAPIClient::send_addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission)
@@ -5098,7 +5268,7 @@ void ApplicationCatalogAPIClient::send_addGSISSHJobSubmissionProtocol(const std:
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addGSISSHJobSubmissionProtocol()
+void ApplicationCatalogAPIClient::recv_addGSISSHJobSubmissionProtocol(std::string& _return)
{
int32_t rseqid = 0;
@@ -5124,10 +5294,15 @@ void ApplicationCatalogAPIClient::recv_addGSISSHJobSubmissionProtocol()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5137,13 +5312,13 @@ void ApplicationCatalogAPIClient::recv_addGSISSHJobSubmissionProtocol()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addGSISSHJobSubmissionProtocol failed: unknown result");
}
-void ApplicationCatalogAPIClient::addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission)
+void ApplicationCatalogAPIClient::addGlobusJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission)
{
send_addGlobusJobSubmissionProtocol(computeResourceId, jobSubmission);
- recv_addGlobusJobSubmissionProtocol();
+ recv_addGlobusJobSubmissionProtocol(_return);
}
void ApplicationCatalogAPIClient::send_addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission)
@@ -5161,7 +5336,7 @@ void ApplicationCatalogAPIClient::send_addGlobusJobSubmissionProtocol(const std:
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addGlobusJobSubmissionProtocol()
+void ApplicationCatalogAPIClient::recv_addGlobusJobSubmissionProtocol(std::string& _return)
{
int32_t rseqid = 0;
@@ -5187,10 +5362,15 @@ void ApplicationCatalogAPIClient::recv_addGlobusJobSubmissionProtocol()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5200,13 +5380,13 @@ void ApplicationCatalogAPIClient::recv_addGlobusJobSubmissionProtocol()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addGlobusJobSubmissionProtocol failed: unknown result");
}
-void ApplicationCatalogAPIClient::addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement)
+void ApplicationCatalogAPIClient::addSCPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::SCPDataMovement& dataMovement)
{
send_addSCPDataMovementProtocol(computeResourceId, dataMovement);
- recv_addSCPDataMovementProtocol();
+ recv_addSCPDataMovementProtocol(_return);
}
void ApplicationCatalogAPIClient::send_addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement)
@@ -5224,7 +5404,7 @@ void ApplicationCatalogAPIClient::send_addSCPDataMovementProtocol(const std::str
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addSCPDataMovementProtocol()
+void ApplicationCatalogAPIClient::recv_addSCPDataMovementProtocol(std::string& _return)
{
int32_t rseqid = 0;
@@ -5250,10 +5430,15 @@ void ApplicationCatalogAPIClient::recv_addSCPDataMovementProtocol()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addSCPDataMovementProtocol_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5263,13 +5448,13 @@ void ApplicationCatalogAPIClient::recv_addSCPDataMovementProtocol()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addSCPDataMovementProtocol failed: unknown result");
}
-void ApplicationCatalogAPIClient::addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement)
+void ApplicationCatalogAPIClient::addGridFTPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement)
{
send_addGridFTPDataMovementProtocol(computeResourceId, dataMovement);
- recv_addGridFTPDataMovementProtocol();
+ recv_addGridFTPDataMovementProtocol(_return);
}
void ApplicationCatalogAPIClient::send_addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement)
@@ -5287,7 +5472,7 @@ void ApplicationCatalogAPIClient::send_addGridFTPDataMovementProtocol(const std:
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addGridFTPDataMovementProtocol()
+void ApplicationCatalogAPIClient::recv_addGridFTPDataMovementProtocol(std::string& _return)
{
int32_t rseqid = 0;
@@ -5313,10 +5498,15 @@ void ApplicationCatalogAPIClient::recv_addGridFTPDataMovementProtocol()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5326,7 +5516,7 @@ void ApplicationCatalogAPIClient::recv_addGridFTPDataMovementProtocol()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addGridFTPDataMovementProtocol failed: unknown result");
}
void ApplicationCatalogAPIClient::listComputeResourceDescriptions(std::vector<std::string> & _return)
@@ -5931,10 +6121,10 @@ void ApplicationCatalogAPIClient::recv_getComputeResourceDescriptionFromHostName
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getComputeResourceDescriptionFromHostName failed: unknown result");
}
-void ApplicationCatalogAPIClient::addApplicationInterface(const ::ApplicationInterface& applicationInterface)
+void ApplicationCatalogAPIClient::addApplicationInterface(std::string& _return, const ::ApplicationInterface& applicationInterface)
{
send_addApplicationInterface(applicationInterface);
- recv_addApplicationInterface();
+ recv_addApplicationInterface(_return);
}
void ApplicationCatalogAPIClient::send_addApplicationInterface(const ::ApplicationInterface& applicationInterface)
@@ -5951,7 +6141,7 @@ void ApplicationCatalogAPIClient::send_addApplicationInterface(const ::Applicat
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addApplicationInterface()
+void ApplicationCatalogAPIClient::recv_addApplicationInterface(std::string& _return)
{
int32_t rseqid = 0;
@@ -5977,10 +6167,15 @@ void ApplicationCatalogAPIClient::recv_addApplicationInterface()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addApplicationInterface_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -5990,7 +6185,7 @@ void ApplicationCatalogAPIClient::recv_addApplicationInterface()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addApplicationInterface failed: unknown result");
}
void ApplicationCatalogAPIClient::listApplicationInterfaceIds(std::vector<std::string> & _return)
@@ -6126,10 +6321,10 @@ void ApplicationCatalogAPIClient::recv_getApplicationInterface( ::ApplicationInt
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getApplicationInterface failed: unknown result");
}
-void ApplicationCatalogAPIClient::addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment)
+void ApplicationCatalogAPIClient::addApplicationDeployment(std::string& _return, const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment)
{
send_addApplicationDeployment(applicationInterfaceId, applicationDeployment);
- recv_addApplicationDeployment();
+ recv_addApplicationDeployment(_return);
}
void ApplicationCatalogAPIClient::send_addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment)
@@ -6147,7 +6342,7 @@ void ApplicationCatalogAPIClient::send_addApplicationDeployment(const std::strin
oprot_->getTransport()->flush();
}
-void ApplicationCatalogAPIClient::recv_addApplicationDeployment()
+void ApplicationCatalogAPIClient::recv_addApplicationDeployment(std::string& _return)
{
int32_t rseqid = 0;
@@ -6173,10 +6368,15 @@ void ApplicationCatalogAPIClient::recv_addApplicationDeployment()
iprot_->getTransport()->readEnd();
}
ApplicationCatalogAPI_addApplicationDeployment_presult result;
+ result.success = &_return;
result.read(iprot_);
iprot_->readMessageEnd();
iprot_->getTransport()->readEnd();
+ if (result.__isset.success) {
+ // _return pointer has now been filled
+ return;
+ }
if (result.__isset.ire) {
throw result.ire;
}
@@ -6186,7 +6386,7 @@ void ApplicationCatalogAPIClient::recv_addApplicationDeployment()
if (result.__isset.ase) {
throw result.ase;
}
- return;
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addApplicationDeployment failed: unknown result");
}
void ApplicationCatalogAPIClient::listApplicationDeploymentIds(std::vector<std::string> & _return, const std::string& applicationInterfaceId)
@@ -6420,7 +6620,8 @@ void ApplicationCatalogAPIProcessor::process_addComputeResourceDescription(int32
ApplicationCatalogAPI_addComputeResourceDescription_result result;
try {
- iface_->addComputeResourceDescription(args.computeResourceDescription);
+ iface_->addComputeResourceDescription(result.success, args.computeResourceDescription);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -6482,7 +6683,8 @@ void ApplicationCatalogAPIProcessor::process_addSSHJobSubmissionProtocol(int32_t
ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result result;
try {
- iface_->addSSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ iface_->addSSHJobSubmissionProtocol(result.success, args.computeResourceId, args.jobSubmission);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -6544,7 +6746,8 @@ void ApplicationCatalogAPIProcessor::process_addGSISSHJobSubmissionProtocol(int3
ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result result;
try {
- iface_->addGSISSHJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ iface_->addGSISSHJobSubmissionProtocol(result.success, args.computeResourceId, args.jobSubmission);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -6606,7 +6809,8 @@ void ApplicationCatalogAPIProcessor::process_addGlobusJobSubmissionProtocol(int3
ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result result;
try {
- iface_->addGlobusJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ iface_->addGlobusJobSubmissionProtocol(result.success, args.computeResourceId, args.jobSubmission);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -6668,7 +6872,8 @@ void ApplicationCatalogAPIProcessor::process_addSCPDataMovementProtocol(int32_t
ApplicationCatalogAPI_addSCPDataMovementProtocol_result result;
try {
- iface_->addSCPDataMovementProtocol(args.computeResourceId, args.dataMovement);
+ iface_->addSCPDataMovementProtocol(result.success, args.computeResourceId, args.dataMovement);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -6730,7 +6935,8 @@ void ApplicationCatalogAPIProcessor::process_addGridFTPDataMovementProtocol(int3
ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result result;
try {
- iface_->addGridFTPDataMovementProtocol(args.computeResourceId, args.dataMovement);
+ iface_->addGridFTPDataMovementProtocol(result.success, args.computeResourceId, args.dataMovement);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -7359,7 +7565,8 @@ void ApplicationCatalogAPIProcessor::process_addApplicationInterface(int32_t seq
ApplicationCatalogAPI_addApplicationInterface_result result;
try {
- iface_->addApplicationInterface(args.applicationInterface);
+ iface_->addApplicationInterface(result.success, args.applicationInterface);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
@@ -7547,7 +7754,8 @@ void ApplicationCatalogAPIProcessor::process_addApplicationDeployment(int32_t se
ApplicationCatalogAPI_addApplicationDeployment_result result;
try {
- iface_->addApplicationDeployment(args.applicationInterfaceId, args.applicationDeployment);
+ iface_->addApplicationDeployment(result.success, args.applicationInterfaceId, args.applicationDeployment);
+ result.__isset.success = true;
} catch ( ::airavata::api::error::InvalidRequestException &ire) {
result.ire = ire;
result.__isset.ire = true;
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d76b48c/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h
index 3d63beb..6cfc0dc 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI.h
@@ -16,12 +16,12 @@ class ApplicationCatalogAPIIf {
public:
virtual ~ApplicationCatalogAPIIf() {}
virtual void GetAPIVersion(std::string& _return) = 0;
- virtual void addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription) = 0;
- virtual void addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission) = 0;
- virtual void addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) = 0;
- virtual void addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) = 0;
- virtual void addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) = 0;
- virtual void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) = 0;
+ virtual void addComputeResourceDescription(std::string& _return, const ::ComputeResourceDescription& computeResourceDescription) = 0;
+ virtual void addSSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission) = 0;
+ virtual void addGSISSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) = 0;
+ virtual void addGlobusJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) = 0;
+ virtual void addSCPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) = 0;
+ virtual void addGridFTPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) = 0;
virtual void listComputeResourceDescriptions(std::vector<std::string> & _return) = 0;
virtual void getComputeResourceDescription( ::ComputeResourceDescription& _return, const std::string& computeResourceId) = 0;
virtual void getSSHJobSubmissionProtocol( ::SSHJobSubmission& _return, const std::string& sshJobSubmissionProtocolResourceId) = 0;
@@ -31,10 +31,10 @@ class ApplicationCatalogAPIIf {
virtual void getGridFTPDataMovementProtocol( ::GridFTPDataMovement& _return, const std::string& gridFTPDataMovementResourceId) = 0;
virtual bool isComputeResourceDescriptionRegistered(const std::string& hostName) = 0;
virtual void getComputeResourceDescriptionFromHostName( ::ComputeResourceDescription& _return, const std::string& hostName) = 0;
- virtual void addApplicationInterface(const ::ApplicationInterface& applicationInterface) = 0;
+ virtual void addApplicationInterface(std::string& _return, const ::ApplicationInterface& applicationInterface) = 0;
virtual void listApplicationInterfaceIds(std::vector<std::string> & _return) = 0;
virtual void getApplicationInterface( ::ApplicationInterface& _return, const std::string& applicationInterfaceId) = 0;
- virtual void addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment) = 0;
+ virtual void addApplicationDeployment(std::string& _return, const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment) = 0;
virtual void listApplicationDeploymentIds(std::vector<std::string> & _return, const std::string& applicationInterfaceId) = 0;
virtual void getApplicationDeployment( ::ApplicationDeployment& _return, const std::string& applicationInterfaceId, const std::string& applicationDeploymentId) = 0;
};
@@ -69,22 +69,22 @@ class ApplicationCatalogAPINull : virtual public ApplicationCatalogAPIIf {
void GetAPIVersion(std::string& /* _return */) {
return;
}
- void addComputeResourceDescription(const ::ComputeResourceDescription& /* computeResourceDescription */) {
+ void addComputeResourceDescription(std::string& /* _return */, const ::ComputeResourceDescription& /* computeResourceDescription */) {
return;
}
- void addSSHJobSubmissionProtocol(const std::string& /* computeResourceId */, const ::SSHJobSubmission& /* jobSubmission */) {
+ void addSSHJobSubmissionProtocol(std::string& /* _return */, const std::string& /* computeResourceId */, const ::SSHJobSubmission& /* jobSubmission */) {
return;
}
- void addGSISSHJobSubmissionProtocol(const std::string& /* computeResourceId */, const ::GSISSHJobSubmission& /* jobSubmission */) {
+ void addGSISSHJobSubmissionProtocol(std::string& /* _return */, const std::string& /* computeResourceId */, const ::GSISSHJobSubmission& /* jobSubmission */) {
return;
}
- void addGlobusJobSubmissionProtocol(const std::string& /* computeResourceId */, const ::GlobusJobSubmission& /* jobSubmission */) {
+ void addGlobusJobSubmissionProtocol(std::string& /* _return */, const std::string& /* computeResourceId */, const ::GlobusJobSubmission& /* jobSubmission */) {
return;
}
- void addSCPDataMovementProtocol(const std::string& /* computeResourceId */, const ::SCPDataMovement& /* dataMovement */) {
+ void addSCPDataMovementProtocol(std::string& /* _return */, const std::string& /* computeResourceId */, const ::SCPDataMovement& /* dataMovement */) {
return;
}
- void addGridFTPDataMovementProtocol(const std::string& /* computeResourceId */, const ::GridFTPDataMovement& /* dataMovement */) {
+ void addGridFTPDataMovementProtocol(std::string& /* _return */, const std::string& /* computeResourceId */, const ::GridFTPDataMovement& /* dataMovement */) {
return;
}
void listComputeResourceDescriptions(std::vector<std::string> & /* _return */) {
@@ -115,7 +115,7 @@ class ApplicationCatalogAPINull : virtual public ApplicationCatalogAPIIf {
void getComputeResourceDescriptionFromHostName( ::ComputeResourceDescription& /* _return */, const std::string& /* hostName */) {
return;
}
- void addApplicationInterface(const ::ApplicationInterface& /* applicationInterface */) {
+ void addApplicationInterface(std::string& /* _return */, const ::ApplicationInterface& /* applicationInterface */) {
return;
}
void listApplicationInterfaceIds(std::vector<std::string> & /* _return */) {
@@ -124,7 +124,7 @@ class ApplicationCatalogAPINull : virtual public ApplicationCatalogAPIIf {
void getApplicationInterface( ::ApplicationInterface& /* _return */, const std::string& /* applicationInterfaceId */) {
return;
}
- void addApplicationDeployment(const std::string& /* applicationInterfaceId */, const ::ApplicationDeployment& /* applicationDeployment */) {
+ void addApplicationDeployment(std::string& /* _return */, const std::string& /* applicationInterfaceId */, const ::ApplicationDeployment& /* applicationDeployment */) {
return;
}
void listApplicationDeploymentIds(std::vector<std::string> & /* _return */, const std::string& /* applicationInterfaceId */) {
@@ -275,7 +275,8 @@ class ApplicationCatalogAPI_addComputeResourceDescription_pargs {
};
typedef struct _ApplicationCatalogAPI_addComputeResourceDescription_result__isset {
- _ApplicationCatalogAPI_addComputeResourceDescription_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addComputeResourceDescription_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -284,17 +285,22 @@ typedef struct _ApplicationCatalogAPI_addComputeResourceDescription_result__isse
class ApplicationCatalogAPI_addComputeResourceDescription_result {
public:
- ApplicationCatalogAPI_addComputeResourceDescription_result() {
+ ApplicationCatalogAPI_addComputeResourceDescription_result() : success() {
}
virtual ~ApplicationCatalogAPI_addComputeResourceDescription_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addComputeResourceDescription_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -309,6 +315,8 @@ class ApplicationCatalogAPI_addComputeResourceDescription_result {
bool operator == (const ApplicationCatalogAPI_addComputeResourceDescription_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -329,7 +337,8 @@ class ApplicationCatalogAPI_addComputeResourceDescription_result {
};
typedef struct _ApplicationCatalogAPI_addComputeResourceDescription_presult__isset {
- _ApplicationCatalogAPI_addComputeResourceDescription_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addComputeResourceDescription_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -341,6 +350,7 @@ class ApplicationCatalogAPI_addComputeResourceDescription_presult {
virtual ~ApplicationCatalogAPI_addComputeResourceDescription_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -405,7 +415,8 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_pargs {
};
typedef struct _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result__isset {
- _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -414,17 +425,22 @@ typedef struct _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result__isset
class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
public:
- ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result() {
+ ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result() : success() {
}
virtual ~ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -439,6 +455,8 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
bool operator == (const ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -459,7 +477,8 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_result {
};
typedef struct _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult__isset {
- _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -471,6 +490,7 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult {
virtual ~ApplicationCatalogAPI_addSSHJobSubmissionProtocol_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -535,7 +555,8 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_pargs {
};
typedef struct _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result__isset {
- _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -544,17 +565,22 @@ typedef struct _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result__iss
class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
public:
- ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result() {
+ ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result() : success() {
}
virtual ~ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -569,6 +595,8 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
bool operator == (const ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -589,7 +617,8 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_result {
};
typedef struct _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult__isset {
- _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -601,6 +630,7 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult {
virtual ~ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -665,7 +695,8 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_pargs {
};
typedef struct _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result__isset {
- _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -674,17 +705,22 @@ typedef struct _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result__iss
class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
public:
- ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result() {
+ ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result() : success() {
}
virtual ~ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -699,6 +735,8 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
bool operator == (const ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -719,7 +757,8 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_result {
};
typedef struct _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult__isset {
- _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -731,6 +770,7 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult {
virtual ~ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -795,7 +835,8 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_pargs {
};
typedef struct _ApplicationCatalogAPI_addSCPDataMovementProtocol_result__isset {
- _ApplicationCatalogAPI_addSCPDataMovementProtocol_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addSCPDataMovementProtocol_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -804,17 +845,22 @@ typedef struct _ApplicationCatalogAPI_addSCPDataMovementProtocol_result__isset {
class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
public:
- ApplicationCatalogAPI_addSCPDataMovementProtocol_result() {
+ ApplicationCatalogAPI_addSCPDataMovementProtocol_result() : success() {
}
virtual ~ApplicationCatalogAPI_addSCPDataMovementProtocol_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addSCPDataMovementProtocol_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -829,6 +875,8 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
bool operator == (const ApplicationCatalogAPI_addSCPDataMovementProtocol_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -849,7 +897,8 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
};
typedef struct _ApplicationCatalogAPI_addSCPDataMovementProtocol_presult__isset {
- _ApplicationCatalogAPI_addSCPDataMovementProtocol_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addSCPDataMovementProtocol_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -861,6 +910,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_presult {
virtual ~ApplicationCatalogAPI_addSCPDataMovementProtocol_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -925,7 +975,8 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_pargs {
};
typedef struct _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset {
- _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -934,17 +985,22 @@ typedef struct _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__iss
class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
public:
- ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result() {
+ ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result() : success() {
}
virtual ~ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -959,6 +1015,8 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
bool operator == (const ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -979,7 +1037,8 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
};
typedef struct _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset {
- _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -991,6 +1050,7 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult {
virtual ~ApplicationCatalogAPI_addGridFTPDataMovementProtocol_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -2227,7 +2287,8 @@ class ApplicationCatalogAPI_addApplicationInterface_pargs {
};
typedef struct _ApplicationCatalogAPI_addApplicationInterface_result__isset {
- _ApplicationCatalogAPI_addApplicationInterface_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addApplicationInterface_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -2236,17 +2297,22 @@ typedef struct _ApplicationCatalogAPI_addApplicationInterface_result__isset {
class ApplicationCatalogAPI_addApplicationInterface_result {
public:
- ApplicationCatalogAPI_addApplicationInterface_result() {
+ ApplicationCatalogAPI_addApplicationInterface_result() : success() {
}
virtual ~ApplicationCatalogAPI_addApplicationInterface_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addApplicationInterface_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -2261,6 +2327,8 @@ class ApplicationCatalogAPI_addApplicationInterface_result {
bool operator == (const ApplicationCatalogAPI_addApplicationInterface_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -2281,7 +2349,8 @@ class ApplicationCatalogAPI_addApplicationInterface_result {
};
typedef struct _ApplicationCatalogAPI_addApplicationInterface_presult__isset {
- _ApplicationCatalogAPI_addApplicationInterface_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addApplicationInterface_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -2293,6 +2362,7 @@ class ApplicationCatalogAPI_addApplicationInterface_presult {
virtual ~ApplicationCatalogAPI_addApplicationInterface_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -2613,7 +2683,8 @@ class ApplicationCatalogAPI_addApplicationDeployment_pargs {
};
typedef struct _ApplicationCatalogAPI_addApplicationDeployment_result__isset {
- _ApplicationCatalogAPI_addApplicationDeployment_result__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addApplicationDeployment_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -2622,17 +2693,22 @@ typedef struct _ApplicationCatalogAPI_addApplicationDeployment_result__isset {
class ApplicationCatalogAPI_addApplicationDeployment_result {
public:
- ApplicationCatalogAPI_addApplicationDeployment_result() {
+ ApplicationCatalogAPI_addApplicationDeployment_result() : success() {
}
virtual ~ApplicationCatalogAPI_addApplicationDeployment_result() throw() {}
+ std::string success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
_ApplicationCatalogAPI_addApplicationDeployment_result__isset __isset;
+ void __set_success(const std::string& val) {
+ success = val;
+ }
+
void __set_ire(const ::airavata::api::error::InvalidRequestException& val) {
ire = val;
}
@@ -2647,6 +2723,8 @@ class ApplicationCatalogAPI_addApplicationDeployment_result {
bool operator == (const ApplicationCatalogAPI_addApplicationDeployment_result & rhs) const
{
+ if (!(success == rhs.success))
+ return false;
if (!(ire == rhs.ire))
return false;
if (!(ace == rhs.ace))
@@ -2667,7 +2745,8 @@ class ApplicationCatalogAPI_addApplicationDeployment_result {
};
typedef struct _ApplicationCatalogAPI_addApplicationDeployment_presult__isset {
- _ApplicationCatalogAPI_addApplicationDeployment_presult__isset() : ire(false), ace(false), ase(false) {}
+ _ApplicationCatalogAPI_addApplicationDeployment_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
bool ire;
bool ace;
bool ase;
@@ -2679,6 +2758,7 @@ class ApplicationCatalogAPI_addApplicationDeployment_presult {
virtual ~ApplicationCatalogAPI_addApplicationDeployment_presult() throw() {}
+ std::string* success;
::airavata::api::error::InvalidRequestException ire;
::airavata::api::error::AiravataClientException ace;
::airavata::api::error::AiravataSystemException ase;
@@ -2984,24 +3064,24 @@ class ApplicationCatalogAPIClient : virtual public ApplicationCatalogAPIIf {
void GetAPIVersion(std::string& _return);
void send_GetAPIVersion();
void recv_GetAPIVersion(std::string& _return);
- void addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription);
+ void addComputeResourceDescription(std::string& _return, const ::ComputeResourceDescription& computeResourceDescription);
void send_addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription);
- void recv_addComputeResourceDescription();
- void addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission);
+ void recv_addComputeResourceDescription(std::string& _return);
+ void addSSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission);
void send_addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission);
- void recv_addSSHJobSubmissionProtocol();
- void addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission);
+ void recv_addSSHJobSubmissionProtocol(std::string& _return);
+ void addGSISSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission);
void send_addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission);
- void recv_addGSISSHJobSubmissionProtocol();
- void addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission);
+ void recv_addGSISSHJobSubmissionProtocol(std::string& _return);
+ void addGlobusJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission);
void send_addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission);
- void recv_addGlobusJobSubmissionProtocol();
- void addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement);
+ void recv_addGlobusJobSubmissionProtocol(std::string& _return);
+ void addSCPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::SCPDataMovement& dataMovement);
void send_addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement);
- void recv_addSCPDataMovementProtocol();
- void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement);
+ void recv_addSCPDataMovementProtocol(std::string& _return);
+ void addGridFTPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement);
void send_addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement);
- void recv_addGridFTPDataMovementProtocol();
+ void recv_addGridFTPDataMovementProtocol(std::string& _return);
void listComputeResourceDescriptions(std::vector<std::string> & _return);
void send_listComputeResourceDescriptions();
void recv_listComputeResourceDescriptions(std::vector<std::string> & _return);
@@ -3029,18 +3109,18 @@ class ApplicationCatalogAPIClient : virtual public ApplicationCatalogAPIIf {
void getComputeResourceDescriptionFromHostName( ::ComputeResourceDescription& _return, const std::string& hostName);
void send_getComputeResourceDescriptionFromHostName(const std::string& hostName);
void recv_getComputeResourceDescriptionFromHostName( ::ComputeResourceDescription& _return);
- void addApplicationInterface(const ::ApplicationInterface& applicationInterface);
+ void addApplicationInterface(std::string& _return, const ::ApplicationInterface& applicationInterface);
void send_addApplicationInterface(const ::ApplicationInterface& applicationInterface);
- void recv_addApplicationInterface();
+ void recv_addApplicationInterface(std::string& _return);
void listApplicationInterfaceIds(std::vector<std::string> & _return);
void send_listApplicationInterfaceIds();
void recv_listApplicationInterfaceIds(std::vector<std::string> & _return);
void getApplicationInterface( ::ApplicationInterface& _return, const std::string& applicationInterfaceId);
void send_getApplicationInterface(const std::string& applicationInterfaceId);
void recv_getApplicationInterface( ::ApplicationInterface& _return);
- void addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment);
+ void addApplicationDeployment(std::string& _return, const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment);
void send_addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment);
- void recv_addApplicationDeployment();
+ void recv_addApplicationDeployment(std::string& _return);
void listApplicationDeploymentIds(std::vector<std::string> & _return, const std::string& applicationInterfaceId);
void send_listApplicationDeploymentIds(const std::string& applicationInterfaceId);
void recv_listApplicationDeploymentIds(std::vector<std::string> & _return);
@@ -3147,58 +3227,64 @@ class ApplicationCatalogAPIMultiface : virtual public ApplicationCatalogAPIIf {
return;
}
- void addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription) {
+ void addComputeResourceDescription(std::string& _return, const ::ComputeResourceDescription& computeResourceDescription) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addComputeResourceDescription(computeResourceDescription);
+ ifaces_[i]->addComputeResourceDescription(_return, computeResourceDescription);
}
- ifaces_[i]->addComputeResourceDescription(computeResourceDescription);
+ ifaces_[i]->addComputeResourceDescription(_return, computeResourceDescription);
+ return;
}
- void addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission) {
+ void addSSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addSSHJobSubmissionProtocol(computeResourceId, jobSubmission);
+ ifaces_[i]->addSSHJobSubmissionProtocol(_return, computeResourceId, jobSubmission);
}
- ifaces_[i]->addSSHJobSubmissionProtocol(computeResourceId, jobSubmission);
+ ifaces_[i]->addSSHJobSubmissionProtocol(_return, computeResourceId, jobSubmission);
+ return;
}
- void addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) {
+ void addGSISSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addGSISSHJobSubmissionProtocol(computeResourceId, jobSubmission);
+ ifaces_[i]->addGSISSHJobSubmissionProtocol(_return, computeResourceId, jobSubmission);
}
- ifaces_[i]->addGSISSHJobSubmissionProtocol(computeResourceId, jobSubmission);
+ ifaces_[i]->addGSISSHJobSubmissionProtocol(_return, computeResourceId, jobSubmission);
+ return;
}
- void addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) {
+ void addGlobusJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addGlobusJobSubmissionProtocol(computeResourceId, jobSubmission);
+ ifaces_[i]->addGlobusJobSubmissionProtocol(_return, computeResourceId, jobSubmission);
}
- ifaces_[i]->addGlobusJobSubmissionProtocol(computeResourceId, jobSubmission);
+ ifaces_[i]->addGlobusJobSubmissionProtocol(_return, computeResourceId, jobSubmission);
+ return;
}
- void addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) {
+ void addSCPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addSCPDataMovementProtocol(computeResourceId, dataMovement);
+ ifaces_[i]->addSCPDataMovementProtocol(_return, computeResourceId, dataMovement);
}
- ifaces_[i]->addSCPDataMovementProtocol(computeResourceId, dataMovement);
+ ifaces_[i]->addSCPDataMovementProtocol(_return, computeResourceId, dataMovement);
+ return;
}
- void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) {
+ void addGridFTPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addGridFTPDataMovementProtocol(computeResourceId, dataMovement);
+ ifaces_[i]->addGridFTPDataMovementProtocol(_return, computeResourceId, dataMovement);
}
- ifaces_[i]->addGridFTPDataMovementProtocol(computeResourceId, dataMovement);
+ ifaces_[i]->addGridFTPDataMovementProtocol(_return, computeResourceId, dataMovement);
+ return;
}
void listComputeResourceDescriptions(std::vector<std::string> & _return) {
@@ -3290,13 +3376,14 @@ class ApplicationCatalogAPIMultiface : virtual public ApplicationCatalogAPIIf {
return;
}
- void addApplicationInterface(const ::ApplicationInterface& applicationInterface) {
+ void addApplicationInterface(std::string& _return, const ::ApplicationInterface& applicationInterface) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addApplicationInterface(applicationInterface);
+ ifaces_[i]->addApplicationInterface(_return, applicationInterface);
}
- ifaces_[i]->addApplicationInterface(applicationInterface);
+ ifaces_[i]->addApplicationInterface(_return, applicationInterface);
+ return;
}
void listApplicationInterfaceIds(std::vector<std::string> & _return) {
@@ -3319,13 +3406,14 @@ class ApplicationCatalogAPIMultiface : virtual public ApplicationCatalogAPIIf {
return;
}
- void addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment) {
+ void addApplicationDeployment(std::string& _return, const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->addApplicationDeployment(applicationInterfaceId, applicationDeployment);
+ ifaces_[i]->addApplicationDeployment(_return, applicationInterfaceId, applicationDeployment);
}
- ifaces_[i]->addApplicationDeployment(applicationInterfaceId, applicationDeployment);
+ ifaces_[i]->addApplicationDeployment(_return, applicationInterfaceId, applicationDeployment);
+ return;
}
void listApplicationDeploymentIds(std::vector<std::string> & _return, const std::string& applicationInterfaceId) {
http://git-wip-us.apache.org/repos/asf/airavata/blob/1d76b48c/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp
index 4a53bfd..ed61bd8 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/ApplicationCatalogAPI_server.skeleton.cpp
@@ -27,32 +27,32 @@ class ApplicationCatalogAPIHandler : virtual public ApplicationCatalogAPIIf {
printf("GetAPIVersion\n");
}
- void addComputeResourceDescription(const ::ComputeResourceDescription& computeResourceDescription) {
+ void addComputeResourceDescription(std::string& _return, const ::ComputeResourceDescription& computeResourceDescription) {
// Your implementation goes here
printf("addComputeResourceDescription\n");
}
- void addSSHJobSubmissionProtocol(const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission) {
+ void addSSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::SSHJobSubmission& jobSubmission) {
// Your implementation goes here
printf("addSSHJobSubmissionProtocol\n");
}
- void addGSISSHJobSubmissionProtocol(const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) {
+ void addGSISSHJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GSISSHJobSubmission& jobSubmission) {
// Your implementation goes here
printf("addGSISSHJobSubmissionProtocol\n");
}
- void addGlobusJobSubmissionProtocol(const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) {
+ void addGlobusJobSubmissionProtocol(std::string& _return, const std::string& computeResourceId, const ::GlobusJobSubmission& jobSubmission) {
// Your implementation goes here
printf("addGlobusJobSubmissionProtocol\n");
}
- void addSCPDataMovementProtocol(const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) {
+ void addSCPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::SCPDataMovement& dataMovement) {
// Your implementation goes here
printf("addSCPDataMovementProtocol\n");
}
- void addGridFTPDataMovementProtocol(const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) {
+ void addGridFTPDataMovementProtocol(std::string& _return, const std::string& computeResourceId, const ::GridFTPDataMovement& dataMovement) {
// Your implementation goes here
printf("addGridFTPDataMovementProtocol\n");
}
@@ -102,7 +102,7 @@ class ApplicationCatalogAPIHandler : virtual public ApplicationCatalogAPIIf {
printf("getComputeResourceDescriptionFromHostName\n");
}
- void addApplicationInterface(const ::ApplicationInterface& applicationInterface) {
+ void addApplicationInterface(std::string& _return, const ::ApplicationInterface& applicationInterface) {
// Your implementation goes here
printf("addApplicationInterface\n");
}
@@ -117,7 +117,7 @@ class ApplicationCatalogAPIHandler : virtual public ApplicationCatalogAPIIf {
printf("getApplicationInterface\n");
}
- void addApplicationDeployment(const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment) {
+ void addApplicationDeployment(std::string& _return, const std::string& applicationInterfaceId, const ::ApplicationDeployment& applicationDeployment) {
// Your implementation goes here
printf("addApplicationDeployment\n");
}
[4/4] git commit: generated code
Posted by sa...@apache.org.
generated code
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/1d76b48c
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/1d76b48c
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/1d76b48c
Branch: refs/heads/master
Commit: 1d76b48c1b6756686ba8aa7312544eabe5d277af
Parents: 1a5f1a2
Author: samindaw <sa...@gmail.com>
Authored: Thu May 22 14:56:40 2014 -0700
Committer: samindaw <sa...@gmail.com>
Committed: Thu May 22 14:56:40 2014 -0700
----------------------------------------------------------------------
.../api/appcatalog/ApplicationCatalogAPI.java | 1152 +++++++++++++++---
.../resources/lib/ApplicationCatalogAPI.cpp | 304 ++++-
.../main/resources/lib/ApplicationCatalogAPI.h | 248 ++--
.../ApplicationCatalogAPI_server.skeleton.cpp | 16 +-
.../API/AppCatalog/ApplicationCatalogAPI.php | 216 +++-
5 files changed, 1624 insertions(+), 312 deletions(-)
----------------------------------------------------------------------