You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/03/03 16:00:14 UTC
[1/4] airavata git commit: adding getIntermediateOutput method to API
Repository: airavata
Updated Branches:
refs/heads/master 658e5e9e6 -> 25cf3c97b
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
index ebc2b25..9ed696f 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/Airavata.php
@@ -46,6 +46,7 @@ interface AiravataIf {
public function launchExperiment($airavataExperimentId, $airavataCredStoreToken);
public function getExperimentStatus($airavataExperimentId);
public function getExperimentOutputs($airavataExperimentId);
+ public function getIntermediateOutputs($airavataExperimentId);
public function getJobStatuses($airavataExperimentId);
public function getJobDetails($airavataExperimentId);
public function getDataTransferDetails($airavataExperimentId);
@@ -1887,6 +1888,69 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("getExperimentOutputs failed: unknown result");
}
+ public function getIntermediateOutputs($airavataExperimentId)
+ {
+ $this->send_getIntermediateOutputs($airavataExperimentId);
+ return $this->recv_getIntermediateOutputs();
+ }
+
+ public function send_getIntermediateOutputs($airavataExperimentId)
+ {
+ $args = new \Airavata\API\Airavata_getIntermediateOutputs_args();
+ $args->airavataExperimentId = $airavataExperimentId;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getIntermediateOutputs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getIntermediateOutputs', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getIntermediateOutputs()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_getIntermediateOutputs_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\Airavata_getIntermediateOutputs_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->enf !== null) {
+ throw $result->enf;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ throw new \Exception("getIntermediateOutputs failed: unknown result");
+ }
+
public function getJobStatuses($airavataExperimentId)
{
$this->send_getJobStatuses($airavataExperimentId);
@@ -13539,6 +13603,266 @@ class Airavata_getExperimentOutputs_result {
}
+class Airavata_getIntermediateOutputs_args {
+ static $_TSPEC;
+
+ public $airavataExperimentId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'airavataExperimentId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['airavataExperimentId'])) {
+ $this->airavataExperimentId = $vals['airavataExperimentId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getIntermediateOutputs_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->airavataExperimentId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getIntermediateOutputs_args');
+ if ($this->airavataExperimentId !== null) {
+ $xfer += $output->writeFieldBegin('airavataExperimentId', TType::STRING, 1);
+ $xfer += $output->writeString($this->airavataExperimentId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_getIntermediateOutputs_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $ire = null;
+ public $enf = null;
+ public $ace = null;
+ public $ase = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType',
+ ),
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'enf',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\ExperimentNotFoundException',
+ ),
+ 3 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 4 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['enf'])) {
+ $this->enf = $vals['enf'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_getIntermediateOutputs_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::LST) {
+ $this->success = array();
+ $_size84 = 0;
+ $_etype87 = 0;
+ $xfer += $input->readListBegin($_etype87, $_size84);
+ for ($_i88 = 0; $_i88 < $_size84; ++$_i88)
+ {
+ $elem89 = null;
+ $elem89 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem89->read($input);
+ $this->success []= $elem89;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->enf = new \Airavata\API\Error\ExperimentNotFoundException();
+ $xfer += $this->enf->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_getIntermediateOutputs_result');
+ if ($this->success !== null) {
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::LST, 0);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->success));
+ {
+ foreach ($this->success as $iter90)
+ {
+ $xfer += $iter90->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->enf !== null) {
+ $xfer += $output->writeFieldBegin('enf', TType::STRUCT, 2);
+ $xfer += $this->enf->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 3);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 4);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class Airavata_getJobStatuses_args {
static $_TSPEC;
@@ -13699,18 +14023,18 @@ class Airavata_getJobStatuses_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size84 = 0;
- $_ktype85 = 0;
- $_vtype86 = 0;
- $xfer += $input->readMapBegin($_ktype85, $_vtype86, $_size84);
- for ($_i88 = 0; $_i88 < $_size84; ++$_i88)
+ $_size91 = 0;
+ $_ktype92 = 0;
+ $_vtype93 = 0;
+ $xfer += $input->readMapBegin($_ktype92, $_vtype93, $_size91);
+ for ($_i95 = 0; $_i95 < $_size91; ++$_i95)
{
- $key89 = '';
- $val90 = new \Airavata\Model\Workspace\Experiment\JobStatus();
- $xfer += $input->readString($key89);
- $val90 = new \Airavata\Model\Workspace\Experiment\JobStatus();
- $xfer += $val90->read($input);
- $this->success[$key89] = $val90;
+ $key96 = '';
+ $val97 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $input->readString($key96);
+ $val97 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $val97->read($input);
+ $this->success[$key96] = $val97;
}
$xfer += $input->readMapEnd();
} else {
@@ -13770,10 +14094,10 @@ class Airavata_getJobStatuses_result {
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter91 => $viter92)
+ foreach ($this->success as $kiter98 => $viter99)
{
- $xfer += $output->writeString($kiter91);
- $xfer += $viter92->write($output);
+ $xfer += $output->writeString($kiter98);
+ $xfer += $viter99->write($output);
}
}
$output->writeMapEnd();
@@ -13963,15 +14287,15 @@ class Airavata_getJobDetails_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size93 = 0;
- $_etype96 = 0;
- $xfer += $input->readListBegin($_etype96, $_size93);
- for ($_i97 = 0; $_i97 < $_size93; ++$_i97)
+ $_size100 = 0;
+ $_etype103 = 0;
+ $xfer += $input->readListBegin($_etype103, $_size100);
+ for ($_i104 = 0; $_i104 < $_size100; ++$_i104)
{
- $elem98 = null;
- $elem98 = new \Airavata\Model\Workspace\Experiment\JobDetails();
- $xfer += $elem98->read($input);
- $this->success []= $elem98;
+ $elem105 = null;
+ $elem105 = new \Airavata\Model\Workspace\Experiment\JobDetails();
+ $xfer += $elem105->read($input);
+ $this->success []= $elem105;
}
$xfer += $input->readListEnd();
} else {
@@ -14031,9 +14355,9 @@ class Airavata_getJobDetails_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter99)
+ foreach ($this->success as $iter106)
{
- $xfer += $iter99->write($output);
+ $xfer += $iter106->write($output);
}
}
$output->writeListEnd();
@@ -14223,15 +14547,15 @@ class Airavata_getDataTransferDetails_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size100 = 0;
- $_etype103 = 0;
- $xfer += $input->readListBegin($_etype103, $_size100);
- for ($_i104 = 0; $_i104 < $_size100; ++$_i104)
+ $_size107 = 0;
+ $_etype110 = 0;
+ $xfer += $input->readListBegin($_etype110, $_size107);
+ for ($_i111 = 0; $_i111 < $_size107; ++$_i111)
{
- $elem105 = null;
- $elem105 = new \Airavata\Model\Workspace\Experiment\DataTransferDetails();
- $xfer += $elem105->read($input);
- $this->success []= $elem105;
+ $elem112 = null;
+ $elem112 = new \Airavata\Model\Workspace\Experiment\DataTransferDetails();
+ $xfer += $elem112->read($input);
+ $this->success []= $elem112;
}
$xfer += $input->readListEnd();
} else {
@@ -14291,9 +14615,9 @@ class Airavata_getDataTransferDetails_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter106)
+ foreach ($this->success as $iter113)
{
- $xfer += $iter106->write($output);
+ $xfer += $iter113->write($output);
}
}
$output->writeListEnd();
@@ -15581,15 +15905,15 @@ class Airavata_getAllAppModules_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size107 = 0;
- $_etype110 = 0;
- $xfer += $input->readListBegin($_etype110, $_size107);
- for ($_i111 = 0; $_i111 < $_size107; ++$_i111)
+ $_size114 = 0;
+ $_etype117 = 0;
+ $xfer += $input->readListBegin($_etype117, $_size114);
+ for ($_i118 = 0; $_i118 < $_size114; ++$_i118)
{
- $elem112 = null;
- $elem112 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationModule();
- $xfer += $elem112->read($input);
- $this->success []= $elem112;
+ $elem119 = null;
+ $elem119 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationModule();
+ $xfer += $elem119->read($input);
+ $this->success []= $elem119;
}
$xfer += $input->readListEnd();
} else {
@@ -15641,9 +15965,9 @@ class Airavata_getAllAppModules_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter113)
+ foreach ($this->success as $iter120)
{
- $xfer += $iter113->write($output);
+ $xfer += $iter120->write($output);
}
}
$output->writeListEnd();
@@ -16882,15 +17206,15 @@ class Airavata_getAllApplicationDeployments_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size114 = 0;
- $_etype117 = 0;
- $xfer += $input->readListBegin($_etype117, $_size114);
- for ($_i118 = 0; $_i118 < $_size114; ++$_i118)
+ $_size121 = 0;
+ $_etype124 = 0;
+ $xfer += $input->readListBegin($_etype124, $_size121);
+ for ($_i125 = 0; $_i125 < $_size121; ++$_i125)
{
- $elem119 = null;
- $elem119 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationDeploymentDescription();
- $xfer += $elem119->read($input);
- $this->success []= $elem119;
+ $elem126 = null;
+ $elem126 = new \Airavata\Model\AppCatalog\AppDeployment\ApplicationDeploymentDescription();
+ $xfer += $elem126->read($input);
+ $this->success []= $elem126;
}
$xfer += $input->readListEnd();
} else {
@@ -16942,9 +17266,9 @@ class Airavata_getAllApplicationDeployments_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter120)
+ foreach ($this->success as $iter127)
{
- $xfer += $iter120->write($output);
+ $xfer += $iter127->write($output);
}
}
$output->writeListEnd();
@@ -17119,14 +17443,14 @@ class Airavata_getAppModuleDeployedResources_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size121 = 0;
- $_etype124 = 0;
- $xfer += $input->readListBegin($_etype124, $_size121);
- for ($_i125 = 0; $_i125 < $_size121; ++$_i125)
+ $_size128 = 0;
+ $_etype131 = 0;
+ $xfer += $input->readListBegin($_etype131, $_size128);
+ for ($_i132 = 0; $_i132 < $_size128; ++$_i132)
{
- $elem126 = null;
- $xfer += $input->readString($elem126);
- $this->success []= $elem126;
+ $elem133 = null;
+ $xfer += $input->readString($elem133);
+ $this->success []= $elem133;
}
$xfer += $input->readListEnd();
} else {
@@ -17178,9 +17502,9 @@ class Airavata_getAppModuleDeployedResources_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter127)
+ foreach ($this->success as $iter134)
{
- $xfer += $output->writeString($iter127);
+ $xfer += $output->writeString($iter134);
}
}
$output->writeListEnd();
@@ -18212,17 +18536,17 @@ class Airavata_getAllApplicationInterfaceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size128 = 0;
- $_ktype129 = 0;
- $_vtype130 = 0;
- $xfer += $input->readMapBegin($_ktype129, $_vtype130, $_size128);
- for ($_i132 = 0; $_i132 < $_size128; ++$_i132)
+ $_size135 = 0;
+ $_ktype136 = 0;
+ $_vtype137 = 0;
+ $xfer += $input->readMapBegin($_ktype136, $_vtype137, $_size135);
+ for ($_i139 = 0; $_i139 < $_size135; ++$_i139)
{
- $key133 = '';
- $val134 = '';
- $xfer += $input->readString($key133);
- $xfer += $input->readString($val134);
- $this->success[$key133] = $val134;
+ $key140 = '';
+ $val141 = '';
+ $xfer += $input->readString($key140);
+ $xfer += $input->readString($val141);
+ $this->success[$key140] = $val141;
}
$xfer += $input->readMapEnd();
} else {
@@ -18274,10 +18598,10 @@ class Airavata_getAllApplicationInterfaceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter135 => $viter136)
+ foreach ($this->success as $kiter142 => $viter143)
{
- $xfer += $output->writeString($kiter135);
- $xfer += $output->writeString($viter136);
+ $xfer += $output->writeString($kiter142);
+ $xfer += $output->writeString($viter143);
}
}
$output->writeMapEnd();
@@ -18431,15 +18755,15 @@ class Airavata_getAllApplicationInterfaces_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size137 = 0;
- $_etype140 = 0;
- $xfer += $input->readListBegin($_etype140, $_size137);
- for ($_i141 = 0; $_i141 < $_size137; ++$_i141)
+ $_size144 = 0;
+ $_etype147 = 0;
+ $xfer += $input->readListBegin($_etype147, $_size144);
+ for ($_i148 = 0; $_i148 < $_size144; ++$_i148)
{
- $elem142 = null;
- $elem142 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
- $xfer += $elem142->read($input);
- $this->success []= $elem142;
+ $elem149 = null;
+ $elem149 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
+ $xfer += $elem149->read($input);
+ $this->success []= $elem149;
}
$xfer += $input->readListEnd();
} else {
@@ -18491,9 +18815,9 @@ class Airavata_getAllApplicationInterfaces_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter143)
+ foreach ($this->success as $iter150)
{
- $xfer += $iter143->write($output);
+ $xfer += $iter150->write($output);
}
}
$output->writeListEnd();
@@ -18669,15 +18993,15 @@ class Airavata_getApplicationInputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size144 = 0;
- $_etype147 = 0;
- $xfer += $input->readListBegin($_etype147, $_size144);
- for ($_i148 = 0; $_i148 < $_size144; ++$_i148)
+ $_size151 = 0;
+ $_etype154 = 0;
+ $xfer += $input->readListBegin($_etype154, $_size151);
+ for ($_i155 = 0; $_i155 < $_size151; ++$_i155)
{
- $elem149 = null;
- $elem149 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
- $xfer += $elem149->read($input);
- $this->success []= $elem149;
+ $elem156 = null;
+ $elem156 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
+ $xfer += $elem156->read($input);
+ $this->success []= $elem156;
}
$xfer += $input->readListEnd();
} else {
@@ -18729,9 +19053,9 @@ class Airavata_getApplicationInputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter150)
+ foreach ($this->success as $iter157)
{
- $xfer += $iter150->write($output);
+ $xfer += $iter157->write($output);
}
}
$output->writeListEnd();
@@ -18907,15 +19231,15 @@ class Airavata_getApplicationOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size151 = 0;
- $_etype154 = 0;
- $xfer += $input->readListBegin($_etype154, $_size151);
- for ($_i155 = 0; $_i155 < $_size151; ++$_i155)
+ $_size158 = 0;
+ $_etype161 = 0;
+ $xfer += $input->readListBegin($_etype161, $_size158);
+ for ($_i162 = 0; $_i162 < $_size158; ++$_i162)
{
- $elem156 = null;
- $elem156 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
- $xfer += $elem156->read($input);
- $this->success []= $elem156;
+ $elem163 = null;
+ $elem163 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem163->read($input);
+ $this->success []= $elem163;
}
$xfer += $input->readListEnd();
} else {
@@ -18967,9 +19291,9 @@ class Airavata_getApplicationOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter157)
+ foreach ($this->success as $iter164)
{
- $xfer += $iter157->write($output);
+ $xfer += $iter164->write($output);
}
}
$output->writeListEnd();
@@ -19148,17 +19472,17 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size158 = 0;
- $_ktype159 = 0;
- $_vtype160 = 0;
- $xfer += $input->readMapBegin($_ktype159, $_vtype160, $_size158);
- for ($_i162 = 0; $_i162 < $_size158; ++$_i162)
+ $_size165 = 0;
+ $_ktype166 = 0;
+ $_vtype167 = 0;
+ $xfer += $input->readMapBegin($_ktype166, $_vtype167, $_size165);
+ for ($_i169 = 0; $_i169 < $_size165; ++$_i169)
{
- $key163 = '';
- $val164 = '';
- $xfer += $input->readString($key163);
- $xfer += $input->readString($val164);
- $this->success[$key163] = $val164;
+ $key170 = '';
+ $val171 = '';
+ $xfer += $input->readString($key170);
+ $xfer += $input->readString($val171);
+ $this->success[$key170] = $val171;
}
$xfer += $input->readMapEnd();
} else {
@@ -19210,10 +19534,10 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter165 => $viter166)
+ foreach ($this->success as $kiter172 => $viter173)
{
- $xfer += $output->writeString($kiter165);
- $xfer += $output->writeString($viter166);
+ $xfer += $output->writeString($kiter172);
+ $xfer += $output->writeString($viter173);
}
}
$output->writeMapEnd();
@@ -19800,17 +20124,17 @@ class Airavata_getAllComputeResourceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size167 = 0;
- $_ktype168 = 0;
- $_vtype169 = 0;
- $xfer += $input->readMapBegin($_ktype168, $_vtype169, $_size167);
- for ($_i171 = 0; $_i171 < $_size167; ++$_i171)
+ $_size174 = 0;
+ $_ktype175 = 0;
+ $_vtype176 = 0;
+ $xfer += $input->readMapBegin($_ktype175, $_vtype176, $_size174);
+ for ($_i178 = 0; $_i178 < $_size174; ++$_i178)
{
- $key172 = '';
- $val173 = '';
- $xfer += $input->readString($key172);
- $xfer += $input->readString($val173);
- $this->success[$key172] = $val173;
+ $key179 = '';
+ $val180 = '';
+ $xfer += $input->readString($key179);
+ $xfer += $input->readString($val180);
+ $this->success[$key179] = $val180;
}
$xfer += $input->readMapEnd();
} else {
@@ -19862,10 +20186,10 @@ class Airavata_getAllComputeResourceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter174 => $viter175)
+ foreach ($this->success as $kiter181 => $viter182)
{
- $xfer += $output->writeString($kiter174);
- $xfer += $output->writeString($viter175);
+ $xfer += $output->writeString($kiter181);
+ $xfer += $output->writeString($viter182);
}
}
$output->writeMapEnd();
@@ -26490,17 +26814,17 @@ class Airavata_changeJobSubmissionPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->jobSubmissionPriorityMap = array();
- $_size176 = 0;
- $_ktype177 = 0;
- $_vtype178 = 0;
- $xfer += $input->readMapBegin($_ktype177, $_vtype178, $_size176);
- for ($_i180 = 0; $_i180 < $_size176; ++$_i180)
+ $_size183 = 0;
+ $_ktype184 = 0;
+ $_vtype185 = 0;
+ $xfer += $input->readMapBegin($_ktype184, $_vtype185, $_size183);
+ for ($_i187 = 0; $_i187 < $_size183; ++$_i187)
{
- $key181 = '';
- $val182 = 0;
- $xfer += $input->readString($key181);
- $xfer += $input->readI32($val182);
- $this->jobSubmissionPriorityMap[$key181] = $val182;
+ $key188 = '';
+ $val189 = 0;
+ $xfer += $input->readString($key188);
+ $xfer += $input->readI32($val189);
+ $this->jobSubmissionPriorityMap[$key188] = $val189;
}
$xfer += $input->readMapEnd();
} else {
@@ -26528,10 +26852,10 @@ class Airavata_changeJobSubmissionPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionPriorityMap));
{
- foreach ($this->jobSubmissionPriorityMap as $kiter183 => $viter184)
+ foreach ($this->jobSubmissionPriorityMap as $kiter190 => $viter191)
{
- $xfer += $output->writeString($kiter183);
- $xfer += $output->writeI32($viter184);
+ $xfer += $output->writeString($kiter190);
+ $xfer += $output->writeI32($viter191);
}
}
$output->writeMapEnd();
@@ -26734,17 +27058,17 @@ class Airavata_changeDataMovementPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->dataMovementPriorityMap = array();
- $_size185 = 0;
- $_ktype186 = 0;
- $_vtype187 = 0;
- $xfer += $input->readMapBegin($_ktype186, $_vtype187, $_size185);
- for ($_i189 = 0; $_i189 < $_size185; ++$_i189)
+ $_size192 = 0;
+ $_ktype193 = 0;
+ $_vtype194 = 0;
+ $xfer += $input->readMapBegin($_ktype193, $_vtype194, $_size192);
+ for ($_i196 = 0; $_i196 < $_size192; ++$_i196)
{
- $key190 = '';
- $val191 = 0;
- $xfer += $input->readString($key190);
- $xfer += $input->readI32($val191);
- $this->dataMovementPriorityMap[$key190] = $val191;
+ $key197 = '';
+ $val198 = 0;
+ $xfer += $input->readString($key197);
+ $xfer += $input->readI32($val198);
+ $this->dataMovementPriorityMap[$key197] = $val198;
}
$xfer += $input->readMapEnd();
} else {
@@ -26772,10 +27096,10 @@ class Airavata_changeDataMovementPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementPriorityMap));
{
- foreach ($this->dataMovementPriorityMap as $kiter192 => $viter193)
+ foreach ($this->dataMovementPriorityMap as $kiter199 => $viter200)
{
- $xfer += $output->writeString($kiter192);
- $xfer += $output->writeI32($viter193);
+ $xfer += $output->writeString($kiter199);
+ $xfer += $output->writeI32($viter200);
}
}
$output->writeMapEnd();
@@ -30004,15 +30328,15 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size194 = 0;
- $_etype197 = 0;
- $xfer += $input->readListBegin($_etype197, $_size194);
- for ($_i198 = 0; $_i198 < $_size194; ++$_i198)
+ $_size201 = 0;
+ $_etype204 = 0;
+ $xfer += $input->readListBegin($_etype204, $_size201);
+ for ($_i205 = 0; $_i205 < $_size201; ++$_i205)
{
- $elem199 = null;
- $elem199 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
- $xfer += $elem199->read($input);
- $this->success []= $elem199;
+ $elem206 = null;
+ $elem206 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $elem206->read($input);
+ $this->success []= $elem206;
}
$xfer += $input->readListEnd();
} else {
@@ -30064,9 +30388,9 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter200)
+ foreach ($this->success as $iter207)
{
- $xfer += $iter200->write($output);
+ $xfer += $iter207->write($output);
}
}
$output->writeListEnd();
@@ -30220,15 +30544,15 @@ class Airavata_getAllGatewayComputeResources_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size201 = 0;
- $_etype204 = 0;
- $xfer += $input->readListBegin($_etype204, $_size201);
- for ($_i205 = 0; $_i205 < $_size201; ++$_i205)
+ $_size208 = 0;
+ $_etype211 = 0;
+ $xfer += $input->readListBegin($_etype211, $_size208);
+ for ($_i212 = 0; $_i212 < $_size208; ++$_i212)
{
- $elem206 = null;
- $elem206 = new \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile();
- $xfer += $elem206->read($input);
- $this->success []= $elem206;
+ $elem213 = null;
+ $elem213 = new \Airavata\Model\AppCatalog\GatewayProfile\GatewayResourceProfile();
+ $xfer += $elem213->read($input);
+ $this->success []= $elem213;
}
$xfer += $input->readListEnd();
} else {
@@ -30280,9 +30604,9 @@ class Airavata_getAllGatewayComputeResources_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter207)
+ foreach ($this->success as $iter214)
{
- $xfer += $iter207->write($output);
+ $xfer += $iter214->write($output);
}
}
$output->writeListEnd();
@@ -30920,14 +31244,14 @@ class Airavata_getAllWorkflows_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size208 = 0;
- $_etype211 = 0;
- $xfer += $input->readListBegin($_etype211, $_size208);
- for ($_i212 = 0; $_i212 < $_size208; ++$_i212)
+ $_size215 = 0;
+ $_etype218 = 0;
+ $xfer += $input->readListBegin($_etype218, $_size215);
+ for ($_i219 = 0; $_i219 < $_size215; ++$_i219)
{
- $elem213 = null;
- $xfer += $input->readString($elem213);
- $this->success []= $elem213;
+ $elem220 = null;
+ $xfer += $input->readString($elem220);
+ $this->success []= $elem220;
}
$xfer += $input->readListEnd();
} else {
@@ -30979,9 +31303,9 @@ class Airavata_getAllWorkflows_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter214)
+ foreach ($this->success as $iter221)
{
- $xfer += $output->writeString($iter214);
+ $xfer += $output->writeString($iter221);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
----------------------------------------------------------------------
diff --git a/airavata-api/thrift-interface-descriptions/airavataAPI.thrift b/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
index 83a1fc4..cce3563 100644
--- a/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
+++ b/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
@@ -433,6 +433,12 @@ service Airavata {
3: airavataErrors.AiravataClientException ace,
4: airavataErrors.AiravataSystemException ase)
+ list<applicationInterfaceModel.OutputDataObjectType> getIntermediateOutputs (1: required string airavataExperimentId)
+ throws (1: airavataErrors.InvalidRequestException ire,
+ 2: airavataErrors.ExperimentNotFoundException enf,
+ 3: airavataErrors.AiravataClientException ace,
+ 4: airavataErrors.AiravataSystemException ase)
+
map<string, experimentModel.JobStatus> getJobStatuses(1: required string airavataExperimentId)
throws (1: airavataErrors.InvalidRequestException ire,
[2/4] airavata git commit: adding getIntermediateOutput method to API
Posted by ch...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
index 446900c..15015ba 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
@@ -7092,6 +7092,283 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol:
return xfer;
}
+uint32_t Airavata_getIntermediateOutputs_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_airavataExperimentId = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->airavataExperimentId);
+ isset_airavataExperimentId = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_airavataExperimentId)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_getIntermediateOutputs_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_getIntermediateOutputs_args");
+
+ xfer += oprot->writeFieldBegin("airavataExperimentId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->airavataExperimentId);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_getIntermediateOutputs_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_getIntermediateOutputs_pargs");
+
+ xfer += oprot->writeFieldBegin("airavataExperimentId", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->airavataExperimentId)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_getIntermediateOutputs_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->success.clear();
+ uint32_t _size133;
+ ::apache::thrift::protocol::TType _etype136;
+ xfer += iprot->readListBegin(_etype136, _size133);
+ this->success.resize(_size133);
+ uint32_t _i137;
+ for (_i137 = 0; _i137 < _size133; ++_i137)
+ {
+ xfer += this->success[_i137].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->enf.read(iprot);
+ this->__isset.enf = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t Airavata_getIntermediateOutputs_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_getIntermediateOutputs_result");
+
+ if (this->__isset.success) {
+ xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter138;
+ for (_iter138 = this->success.begin(); _iter138 != this->success.end(); ++_iter138)
+ {
+ xfer += (*_iter138).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ 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();
+ } else if (this->__isset.enf) {
+ xfer += oprot->writeFieldBegin("enf", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->enf.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 4);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_getIntermediateOutputs_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 0:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ (*(this->success)).clear();
+ uint32_t _size139;
+ ::apache::thrift::protocol::TType _etype142;
+ xfer += iprot->readListBegin(_etype142, _size139);
+ (*(this->success)).resize(_size139);
+ uint32_t _i143;
+ for (_i143 = 0; _i143 < _size139; ++_i143)
+ {
+ xfer += (*(this->success))[_i143].read(iprot);
+ }
+ xfer += iprot->readListEnd();
+ }
+ this->__isset.success = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ire.read(iprot);
+ this->__isset.ire = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->enf.read(iprot);
+ this->__isset.enf = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->ase.read(iprot);
+ this->__isset.ase = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
uint32_t Airavata_getJobStatuses_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
@@ -7185,17 +7462,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size133;
- ::apache::thrift::protocol::TType _ktype134;
- ::apache::thrift::protocol::TType _vtype135;
- xfer += iprot->readMapBegin(_ktype134, _vtype135, _size133);
- uint32_t _i137;
- for (_i137 = 0; _i137 < _size133; ++_i137)
+ uint32_t _size144;
+ ::apache::thrift::protocol::TType _ktype145;
+ ::apache::thrift::protocol::TType _vtype146;
+ xfer += iprot->readMapBegin(_ktype145, _vtype146, _size144);
+ uint32_t _i148;
+ for (_i148 = 0; _i148 < _size144; ++_i148)
{
- std::string _key138;
- xfer += iprot->readString(_key138);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val139 = this->success[_key138];
- xfer += _val139.read(iprot);
+ std::string _key149;
+ xfer += iprot->readString(_key149);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val150 = this->success[_key149];
+ xfer += _val150.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -7258,11 +7535,11 @@ uint32_t Airavata_getJobStatuses_result::write(::apache::thrift::protocol::TProt
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter140;
- for (_iter140 = this->success.begin(); _iter140 != this->success.end(); ++_iter140)
+ std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter151;
+ for (_iter151 = this->success.begin(); _iter151 != this->success.end(); ++_iter151)
{
- xfer += oprot->writeString(_iter140->first);
- xfer += _iter140->second.write(oprot);
+ xfer += oprot->writeString(_iter151->first);
+ xfer += _iter151->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -7313,17 +7590,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size141;
- ::apache::thrift::protocol::TType _ktype142;
- ::apache::thrift::protocol::TType _vtype143;
- xfer += iprot->readMapBegin(_ktype142, _vtype143, _size141);
- uint32_t _i145;
- for (_i145 = 0; _i145 < _size141; ++_i145)
+ uint32_t _size152;
+ ::apache::thrift::protocol::TType _ktype153;
+ ::apache::thrift::protocol::TType _vtype154;
+ xfer += iprot->readMapBegin(_ktype153, _vtype154, _size152);
+ uint32_t _i156;
+ for (_i156 = 0; _i156 < _size152; ++_i156)
{
- std::string _key146;
- xfer += iprot->readString(_key146);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val147 = (*(this->success))[_key146];
- xfer += _val147.read(iprot);
+ std::string _key157;
+ xfer += iprot->readString(_key157);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val158 = (*(this->success))[_key157];
+ xfer += _val158.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -7469,14 +7746,14 @@ uint32_t Airavata_getJobDetails_result::read(::apache::thrift::protocol::TProtoc
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size148;
- ::apache::thrift::protocol::TType _etype151;
- xfer += iprot->readListBegin(_etype151, _size148);
- this->success.resize(_size148);
- uint32_t _i152;
- for (_i152 = 0; _i152 < _size148; ++_i152)
+ uint32_t _size159;
+ ::apache::thrift::protocol::TType _etype162;
+ xfer += iprot->readListBegin(_etype162, _size159);
+ this->success.resize(_size159);
+ uint32_t _i163;
+ for (_i163 = 0; _i163 < _size159; ++_i163)
{
- xfer += this->success[_i152].read(iprot);
+ xfer += this->success[_i163].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7539,10 +7816,10 @@ uint32_t Airavata_getJobDetails_result::write(::apache::thrift::protocol::TProto
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> ::const_iterator _iter153;
- for (_iter153 = this->success.begin(); _iter153 != this->success.end(); ++_iter153)
+ std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> ::const_iterator _iter164;
+ for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164)
{
- xfer += (*_iter153).write(oprot);
+ xfer += (*_iter164).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7593,14 +7870,14 @@ uint32_t Airavata_getJobDetails_presult::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size154;
- ::apache::thrift::protocol::TType _etype157;
- xfer += iprot->readListBegin(_etype157, _size154);
- (*(this->success)).resize(_size154);
- uint32_t _i158;
- for (_i158 = 0; _i158 < _size154; ++_i158)
+ uint32_t _size165;
+ ::apache::thrift::protocol::TType _etype168;
+ xfer += iprot->readListBegin(_etype168, _size165);
+ (*(this->success)).resize(_size165);
+ uint32_t _i169;
+ for (_i169 = 0; _i169 < _size165; ++_i169)
{
- xfer += (*(this->success))[_i158].read(iprot);
+ xfer += (*(this->success))[_i169].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7746,14 +8023,14 @@ uint32_t Airavata_getDataTransferDetails_result::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size159;
- ::apache::thrift::protocol::TType _etype162;
- xfer += iprot->readListBegin(_etype162, _size159);
- this->success.resize(_size159);
- uint32_t _i163;
- for (_i163 = 0; _i163 < _size159; ++_i163)
+ uint32_t _size170;
+ ::apache::thrift::protocol::TType _etype173;
+ xfer += iprot->readListBegin(_etype173, _size170);
+ this->success.resize(_size170);
+ uint32_t _i174;
+ for (_i174 = 0; _i174 < _size170; ++_i174)
{
- xfer += this->success[_i163].read(iprot);
+ xfer += this->success[_i174].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7816,10 +8093,10 @@ uint32_t Airavata_getDataTransferDetails_result::write(::apache::thrift::protoco
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> ::const_iterator _iter164;
- for (_iter164 = this->success.begin(); _iter164 != this->success.end(); ++_iter164)
+ std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> ::const_iterator _iter175;
+ for (_iter175 = this->success.begin(); _iter175 != this->success.end(); ++_iter175)
{
- xfer += (*_iter164).write(oprot);
+ xfer += (*_iter175).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7870,14 +8147,14 @@ uint32_t Airavata_getDataTransferDetails_presult::read(::apache::thrift::protoco
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size165;
- ::apache::thrift::protocol::TType _etype168;
- xfer += iprot->readListBegin(_etype168, _size165);
- (*(this->success)).resize(_size165);
- uint32_t _i169;
- for (_i169 = 0; _i169 < _size165; ++_i169)
+ uint32_t _size176;
+ ::apache::thrift::protocol::TType _etype179;
+ xfer += iprot->readListBegin(_etype179, _size176);
+ (*(this->success)).resize(_size176);
+ uint32_t _i180;
+ for (_i180 = 0; _i180 < _size176; ++_i180)
{
- xfer += (*(this->success))[_i169].read(iprot);
+ xfer += (*(this->success))[_i180].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9173,14 +9450,14 @@ uint32_t Airavata_getAllAppModules_result::read(::apache::thrift::protocol::TPro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size170;
- ::apache::thrift::protocol::TType _etype173;
- xfer += iprot->readListBegin(_etype173, _size170);
- this->success.resize(_size170);
- uint32_t _i174;
- for (_i174 = 0; _i174 < _size170; ++_i174)
+ uint32_t _size181;
+ ::apache::thrift::protocol::TType _etype184;
+ xfer += iprot->readListBegin(_etype184, _size181);
+ this->success.resize(_size181);
+ uint32_t _i185;
+ for (_i185 = 0; _i185 < _size181; ++_i185)
{
- xfer += this->success[_i174].read(iprot);
+ xfer += this->success[_i185].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9235,10 +9512,10 @@ uint32_t Airavata_getAllAppModules_result::write(::apache::thrift::protocol::TPr
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter175;
- for (_iter175 = this->success.begin(); _iter175 != this->success.end(); ++_iter175)
+ std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationModule> ::const_iterator _iter186;
+ for (_iter186 = this->success.begin(); _iter186 != this->success.end(); ++_iter186)
{
- xfer += (*_iter175).write(oprot);
+ xfer += (*_iter186).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9285,14 +9562,14 @@ uint32_t Airavata_getAllAppModules_presult::read(::apache::thrift::protocol::TPr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size176;
- ::apache::thrift::protocol::TType _etype179;
- xfer += iprot->readListBegin(_etype179, _size176);
- (*(this->success)).resize(_size176);
- uint32_t _i180;
- for (_i180 = 0; _i180 < _size176; ++_i180)
+ uint32_t _size187;
+ ::apache::thrift::protocol::TType _etype190;
+ xfer += iprot->readListBegin(_etype190, _size187);
+ (*(this->success)).resize(_size187);
+ uint32_t _i191;
+ for (_i191 = 0; _i191 < _size187; ++_i191)
{
- xfer += (*(this->success))[_i180].read(iprot);
+ xfer += (*(this->success))[_i191].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10550,14 +10827,14 @@ uint32_t Airavata_getAllApplicationDeployments_result::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size181;
- ::apache::thrift::protocol::TType _etype184;
- xfer += iprot->readListBegin(_etype184, _size181);
- this->success.resize(_size181);
- uint32_t _i185;
- for (_i185 = 0; _i185 < _size181; ++_i185)
+ uint32_t _size192;
+ ::apache::thrift::protocol::TType _etype195;
+ xfer += iprot->readListBegin(_etype195, _size192);
+ this->success.resize(_size192);
+ uint32_t _i196;
+ for (_i196 = 0; _i196 < _size192; ++_i196)
{
- xfer += this->success[_i185].read(iprot);
+ xfer += this->success[_i196].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10612,10 +10889,10 @@ uint32_t Airavata_getAllApplicationDeployments_result::write(::apache::thrift::p
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationDeploymentDescription> ::const_iterator _iter186;
- for (_iter186 = this->success.begin(); _iter186 != this->success.end(); ++_iter186)
+ std::vector< ::apache::airavata::model::appcatalog::appdeployment::ApplicationDeploymentDescription> ::const_iterator _iter197;
+ for (_iter197 = this->success.begin(); _iter197 != this->success.end(); ++_iter197)
{
- xfer += (*_iter186).write(oprot);
+ xfer += (*_iter197).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -10662,14 +10939,14 @@ uint32_t Airavata_getAllApplicationDeployments_presult::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size187;
- ::apache::thrift::protocol::TType _etype190;
- xfer += iprot->readListBegin(_etype190, _size187);
- (*(this->success)).resize(_size187);
- uint32_t _i191;
- for (_i191 = 0; _i191 < _size187; ++_i191)
+ uint32_t _size198;
+ ::apache::thrift::protocol::TType _etype201;
+ xfer += iprot->readListBegin(_etype201, _size198);
+ (*(this->success)).resize(_size198);
+ uint32_t _i202;
+ for (_i202 = 0; _i202 < _size198; ++_i202)
{
- xfer += (*(this->success))[_i191].read(iprot);
+ xfer += (*(this->success))[_i202].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10805,16 +11082,16 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p
{
case 0:
if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->success.clear();
- uint32_t _size192;
- ::apache::thrift::protocol::TType _etype195;
- xfer += iprot->readListBegin(_etype195, _size192);
- this->success.resize(_size192);
- uint32_t _i196;
- for (_i196 = 0; _i196 < _size192; ++_i196)
+ {
+ this->success.clear();
+ uint32_t _size203;
+ ::apache::thrift::protocol::TType _etype206;
+ xfer += iprot->readListBegin(_etype206, _size203);
+ this->success.resize(_size203);
+ uint32_t _i207;
+ for (_i207 = 0; _i207 < _size203; ++_i207)
{
- xfer += iprot->readString(this->success[_i196]);
+ xfer += iprot->readString(this->success[_i207]);
}
xfer += iprot->readListEnd();
}
@@ -10869,10 +11146,10 @@ uint32_t Airavata_getAppModuleDeployedResources_result::write(::apache::thrift::
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::vector<std::string> ::const_iterator _iter197;
- for (_iter197 = this->success.begin(); _iter197 != this->success.end(); ++_iter197)
+ std::vector<std::string> ::const_iterator _iter208;
+ for (_iter208 = this->success.begin(); _iter208 != this->success.end(); ++_iter208)
{
- xfer += oprot->writeString((*_iter197));
+ xfer += oprot->writeString((*_iter208));
}
xfer += oprot->writeListEnd();
}
@@ -10919,14 +11196,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size198;
- ::apache::thrift::protocol::TType _etype201;
- xfer += iprot->readListBegin(_etype201, _size198);
- (*(this->success)).resize(_size198);
- uint32_t _i202;
- for (_i202 = 0; _i202 < _size198; ++_i202)
+ uint32_t _size209;
+ ::apache::thrift::protocol::TType _etype212;
+ xfer += iprot->readListBegin(_etype212, _size209);
+ (*(this->success)).resize(_size209);
+ uint32_t _i213;
+ for (_i213 = 0; _i213 < _size209; ++_i213)
{
- xfer += iprot->readString((*(this->success))[_i202]);
+ xfer += iprot->readString((*(this->success))[_i213]);
}
xfer += iprot->readListEnd();
}
@@ -11959,17 +12236,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size203;
- ::apache::thrift::protocol::TType _ktype204;
- ::apache::thrift::protocol::TType _vtype205;
- xfer += iprot->readMapBegin(_ktype204, _vtype205, _size203);
- uint32_t _i207;
- for (_i207 = 0; _i207 < _size203; ++_i207)
+ uint32_t _size214;
+ ::apache::thrift::protocol::TType _ktype215;
+ ::apache::thrift::protocol::TType _vtype216;
+ xfer += iprot->readMapBegin(_ktype215, _vtype216, _size214);
+ uint32_t _i218;
+ for (_i218 = 0; _i218 < _size214; ++_i218)
{
- std::string _key208;
- xfer += iprot->readString(_key208);
- std::string& _val209 = this->success[_key208];
- xfer += iprot->readString(_val209);
+ std::string _key219;
+ xfer += iprot->readString(_key219);
+ std::string& _val220 = this->success[_key219];
+ xfer += iprot->readString(_val220);
}
xfer += iprot->readMapEnd();
}
@@ -12024,11 +12301,11 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::write(::apache::thrift
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, std::string> ::const_iterator _iter210;
- for (_iter210 = this->success.begin(); _iter210 != this->success.end(); ++_iter210)
+ std::map<std::string, std::string> ::const_iterator _iter221;
+ for (_iter221 = this->success.begin(); _iter221 != this->success.end(); ++_iter221)
{
- xfer += oprot->writeString(_iter210->first);
- xfer += oprot->writeString(_iter210->second);
+ xfer += oprot->writeString(_iter221->first);
+ xfer += oprot->writeString(_iter221->second);
}
xfer += oprot->writeMapEnd();
}
@@ -12075,17 +12352,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size211;
- ::apache::thrift::protocol::TType _ktype212;
- ::apache::thrift::protocol::TType _vtype213;
- xfer += iprot->readMapBegin(_ktype212, _vtype213, _size211);
- uint32_t _i215;
- for (_i215 = 0; _i215 < _size211; ++_i215)
+ uint32_t _size222;
+ ::apache::thrift::protocol::TType _ktype223;
+ ::apache::thrift::protocol::TType _vtype224;
+ xfer += iprot->readMapBegin(_ktype223, _vtype224, _size222);
+ uint32_t _i226;
+ for (_i226 = 0; _i226 < _size222; ++_i226)
{
- std::string _key216;
- xfer += iprot->readString(_key216);
- std::string& _val217 = (*(this->success))[_key216];
- xfer += iprot->readString(_val217);
+ std::string _key227;
+ xfer += iprot->readString(_key227);
+ std::string& _val228 = (*(this->success))[_key227];
+ xfer += iprot->readString(_val228);
}
xfer += iprot->readMapEnd();
}
@@ -12199,14 +12476,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size218;
- ::apache::thrift::protocol::TType _etype221;
- xfer += iprot->readListBegin(_etype221, _size218);
- this->success.resize(_size218);
- uint32_t _i222;
- for (_i222 = 0; _i222 < _size218; ++_i222)
+ uint32_t _size229;
+ ::apache::thrift::protocol::TType _etype232;
+ xfer += iprot->readListBegin(_etype232, _size229);
+ this->success.resize(_size229);
+ uint32_t _i233;
+ for (_i233 = 0; _i233 < _size229; ++_i233)
{
- xfer += this->success[_i222].read(iprot);
+ xfer += this->success[_i233].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12261,10 +12538,10 @@ uint32_t Airavata_getAllApplicationInterfaces_result::write(::apache::thrift::pr
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter223;
- for (_iter223 = this->success.begin(); _iter223 != this->success.end(); ++_iter223)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter234;
+ for (_iter234 = this->success.begin(); _iter234 != this->success.end(); ++_iter234)
{
- xfer += (*_iter223).write(oprot);
+ xfer += (*_iter234).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -12311,14 +12588,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size224;
- ::apache::thrift::protocol::TType _etype227;
- xfer += iprot->readListBegin(_etype227, _size224);
- (*(this->success)).resize(_size224);
- uint32_t _i228;
- for (_i228 = 0; _i228 < _size224; ++_i228)
+ uint32_t _size235;
+ ::apache::thrift::protocol::TType _etype238;
+ xfer += iprot->readListBegin(_etype238, _size235);
+ (*(this->success)).resize(_size235);
+ uint32_t _i239;
+ for (_i239 = 0; _i239 < _size235; ++_i239)
{
- xfer += (*(this->success))[_i228].read(iprot);
+ xfer += (*(this->success))[_i239].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12456,14 +12733,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size229;
- ::apache::thrift::protocol::TType _etype232;
- xfer += iprot->readListBegin(_etype232, _size229);
- this->success.resize(_size229);
- uint32_t _i233;
- for (_i233 = 0; _i233 < _size229; ++_i233)
+ uint32_t _size240;
+ ::apache::thrift::protocol::TType _etype243;
+ xfer += iprot->readListBegin(_etype243, _size240);
+ this->success.resize(_size240);
+ uint32_t _i244;
+ for (_i244 = 0; _i244 < _size240; ++_i244)
{
- xfer += this->success[_i233].read(iprot);
+ xfer += this->success[_i244].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12518,10 +12795,10 @@ uint32_t Airavata_getApplicationInputs_result::write(::apache::thrift::protocol:
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter234;
- for (_iter234 = this->success.begin(); _iter234 != this->success.end(); ++_iter234)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter245;
+ for (_iter245 = this->success.begin(); _iter245 != this->success.end(); ++_iter245)
{
- xfer += (*_iter234).write(oprot);
+ xfer += (*_iter245).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -12568,14 +12845,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size235;
- ::apache::thrift::protocol::TType _etype238;
- xfer += iprot->readListBegin(_etype238, _size235);
- (*(this->success)).resize(_size235);
- uint32_t _i239;
- for (_i239 = 0; _i239 < _size235; ++_i239)
+ uint32_t _size246;
+ ::apache::thrift::protocol::TType _etype249;
+ xfer += iprot->readListBegin(_etype249, _size246);
+ (*(this->success)).resize(_size246);
+ uint32_t _i250;
+ for (_i250 = 0; _i250 < _size246; ++_i250)
{
- xfer += (*(this->success))[_i239].read(iprot);
+ xfer += (*(this->success))[_i250].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12713,14 +12990,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size240;
- ::apache::thrift::protocol::TType _etype243;
- xfer += iprot->readListBegin(_etype243, _size240);
- this->success.resize(_size240);
- uint32_t _i244;
- for (_i244 = 0; _i244 < _size240; ++_i244)
+ uint32_t _size251;
+ ::apache::thrift::protocol::TType _etype254;
+ xfer += iprot->readListBegin(_etype254, _size251);
+ this->success.resize(_size251);
+ uint32_t _i255;
+ for (_i255 = 0; _i255 < _size251; ++_i255)
{
- xfer += this->success[_i244].read(iprot);
+ xfer += this->success[_i255].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12775,10 +13052,10 @@ uint32_t Airavata_getApplicationOutputs_result::write(::apache::thrift::protocol
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter245;
- for (_iter245 = this->success.begin(); _iter245 != this->success.end(); ++_iter245)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter256;
+ for (_iter256 = this->success.begin(); _iter256 != this->success.end(); ++_iter256)
{
- xfer += (*_iter245).write(oprot);
+ xfer += (*_iter256).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -12825,14 +13102,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size246;
- ::apache::thrift::protocol::TType _etype249;
- xfer += iprot->readListBegin(_etype249, _size246);
- (*(this->success)).resize(_size246);
- uint32_t _i250;
- for (_i250 = 0; _i250 < _size246; ++_i250)
+ uint32_t _size257;
+ ::apache::thrift::protocol::TType _etype260;
+ xfer += iprot->readListBegin(_etype260, _size257);
+ (*(this->success)).resize(_size257);
+ uint32_t _i261;
+ for (_i261 = 0; _i261 < _size257; ++_i261)
{
- xfer += (*(this->success))[_i250].read(iprot);
+ xfer += (*(this->success))[_i261].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -12970,17 +13247,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size251;
- ::apache::thrift::protocol::TType _ktype252;
- ::apache::thrift::protocol::TType _vtype253;
- xfer += iprot->readMapBegin(_ktype252, _vtype253, _size251);
- uint32_t _i255;
- for (_i255 = 0; _i255 < _size251; ++_i255)
+ uint32_t _size262;
+ ::apache::thrift::protocol::TType _ktype263;
+ ::apache::thrift::protocol::TType _vtype264;
+ xfer += iprot->readMapBegin(_ktype263, _vtype264, _size262);
+ uint32_t _i266;
+ for (_i266 = 0; _i266 < _size262; ++_i266)
{
- std::string _key256;
- xfer += iprot->readString(_key256);
- std::string& _val257 = this->success[_key256];
- xfer += iprot->readString(_val257);
+ std::string _key267;
+ xfer += iprot->readString(_key267);
+ std::string& _val268 = this->success[_key267];
+ xfer += iprot->readString(_val268);
}
xfer += iprot->readMapEnd();
}
@@ -13035,11 +13312,11 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::write(::apach
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, std::string> ::const_iterator _iter258;
- for (_iter258 = this->success.begin(); _iter258 != this->success.end(); ++_iter258)
+ std::map<std::string, std::string> ::const_iterator _iter269;
+ for (_iter269 = this->success.begin(); _iter269 != this->success.end(); ++_iter269)
{
- xfer += oprot->writeString(_iter258->first);
- xfer += oprot->writeString(_iter258->second);
+ xfer += oprot->writeString(_iter269->first);
+ xfer += oprot->writeString(_iter269->second);
}
xfer += oprot->writeMapEnd();
}
@@ -13086,17 +13363,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size259;
- ::apache::thrift::protocol::TType _ktype260;
- ::apache::thrift::protocol::TType _vtype261;
- xfer += iprot->readMapBegin(_ktype260, _vtype261, _size259);
- uint32_t _i263;
- for (_i263 = 0; _i263 < _size259; ++_i263)
+ uint32_t _size270;
+ ::apache::thrift::protocol::TType _ktype271;
+ ::apache::thrift::protocol::TType _vtype272;
+ xfer += iprot->readMapBegin(_ktype271, _vtype272, _size270);
+ uint32_t _i274;
+ for (_i274 = 0; _i274 < _size270; ++_i274)
{
- std::string _key264;
- xfer += iprot->readString(_key264);
- std::string& _val265 = (*(this->success))[_key264];
- xfer += iprot->readString(_val265);
+ std::string _key275;
+ xfer += iprot->readString(_key275);
+ std::string& _val276 = (*(this->success))[_key275];
+ xfer += iprot->readString(_val276);
}
xfer += iprot->readMapEnd();
}
@@ -13660,17 +13937,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size266;
- ::apache::thrift::protocol::TType _ktype267;
- ::apache::thrift::protocol::TType _vtype268;
- xfer += iprot->readMapBegin(_ktype267, _vtype268, _size266);
- uint32_t _i270;
- for (_i270 = 0; _i270 < _size266; ++_i270)
+ uint32_t _size277;
+ ::apache::thrift::protocol::TType _ktype278;
+ ::apache::thrift::protocol::TType _vtype279;
+ xfer += iprot->readMapBegin(_ktype278, _vtype279, _size277);
+ uint32_t _i281;
+ for (_i281 = 0; _i281 < _size277; ++_i281)
{
- std::string _key271;
- xfer += iprot->readString(_key271);
- std::string& _val272 = this->success[_key271];
- xfer += iprot->readString(_val272);
+ std::string _key282;
+ xfer += iprot->readString(_key282);
+ std::string& _val283 = this->success[_key282];
+ xfer += iprot->readString(_val283);
}
xfer += iprot->readMapEnd();
}
@@ -13725,11 +14002,11 @@ uint32_t Airavata_getAllComputeResourceNames_result::write(::apache::thrift::pro
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, std::string> ::const_iterator _iter273;
- for (_iter273 = this->success.begin(); _iter273 != this->success.end(); ++_iter273)
+ std::map<std::string, std::string> ::const_iterator _iter284;
+ for (_iter284 = this->success.begin(); _iter284 != this->success.end(); ++_iter284)
{
- xfer += oprot->writeString(_iter273->first);
- xfer += oprot->writeString(_iter273->second);
+ xfer += oprot->writeString(_iter284->first);
+ xfer += oprot->writeString(_iter284->second);
}
xfer += oprot->writeMapEnd();
}
@@ -13776,17 +14053,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size274;
- ::apache::thrift::protocol::TType _ktype275;
- ::apache::thrift::protocol::TType _vtype276;
- xfer += iprot->readMapBegin(_ktype275, _vtype276, _size274);
- uint32_t _i278;
- for (_i278 = 0; _i278 < _size274; ++_i278)
+ uint32_t _size285;
+ ::apache::thrift::protocol::TType _ktype286;
+ ::apache::thrift::protocol::TType _vtype287;
+ xfer += iprot->readMapBegin(_ktype286, _vtype287, _size285);
+ uint32_t _i289;
+ for (_i289 = 0; _i289 < _size285; ++_i289)
{
- std::string _key279;
- xfer += iprot->readString(_key279);
- std::string& _val280 = (*(this->success))[_key279];
- xfer += iprot->readString(_val280);
+ std::string _key290;
+ xfer += iprot->readString(_key290);
+ std::string& _val291 = (*(this->success))[_key290];
+ xfer += iprot->readString(_val291);
}
xfer += iprot->readMapEnd();
}
@@ -20669,17 +20946,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->jobSubmissionPriorityMap.clear();
- uint32_t _size281;
- ::apache::thrift::protocol::TType _ktype282;
- ::apache::thrift::protocol::TType _vtype283;
- xfer += iprot->readMapBegin(_ktype282, _vtype283, _size281);
- uint32_t _i285;
- for (_i285 = 0; _i285 < _size281; ++_i285)
+ uint32_t _size292;
+ ::apache::thrift::protocol::TType _ktype293;
+ ::apache::thrift::protocol::TType _vtype294;
+ xfer += iprot->readMapBegin(_ktype293, _vtype294, _size292);
+ uint32_t _i296;
+ for (_i296 = 0; _i296 < _size292; ++_i296)
{
- std::string _key286;
- xfer += iprot->readString(_key286);
- int32_t& _val287 = this->jobSubmissionPriorityMap[_key286];
- xfer += iprot->readI32(_val287);
+ std::string _key297;
+ xfer += iprot->readString(_key297);
+ int32_t& _val298 = this->jobSubmissionPriorityMap[_key297];
+ xfer += iprot->readI32(_val298);
}
xfer += iprot->readMapEnd();
}
@@ -20709,11 +20986,11 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::write(::apache::thrift::pr
xfer += oprot->writeFieldBegin("jobSubmissionPriorityMap", ::apache::thrift::protocol::T_MAP, 1);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->jobSubmissionPriorityMap.size()));
- std::map<std::string, int32_t> ::const_iterator _iter288;
- for (_iter288 = this->jobSubmissionPriorityMap.begin(); _iter288 != this->jobSubmissionPriorityMap.end(); ++_iter288)
+ std::map<std::string, int32_t> ::const_iterator _iter299;
+ for (_iter299 = this->jobSubmissionPriorityMap.begin(); _iter299 != this->jobSubmissionPriorityMap.end(); ++_iter299)
{
- xfer += oprot->writeString(_iter288->first);
- xfer += oprot->writeI32(_iter288->second);
+ xfer += oprot->writeString(_iter299->first);
+ xfer += oprot->writeI32(_iter299->second);
}
xfer += oprot->writeMapEnd();
}
@@ -20731,11 +21008,11 @@ uint32_t Airavata_changeJobSubmissionPriorities_pargs::write(::apache::thrift::p
xfer += oprot->writeFieldBegin("jobSubmissionPriorityMap", ::apache::thrift::protocol::T_MAP, 1);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>((*(this->jobSubmissionPriorityMap)).size()));
- std::map<std::string, int32_t> ::const_iterator _iter289;
- for (_iter289 = (*(this->jobSubmissionPriorityMap)).begin(); _iter289 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter289)
+ std::map<std::string, int32_t> ::const_iterator _iter300;
+ for (_iter300 = (*(this->jobSubmissionPriorityMap)).begin(); _iter300 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter300)
{
- xfer += oprot->writeString(_iter289->first);
- xfer += oprot->writeI32(_iter289->second);
+ xfer += oprot->writeString(_iter300->first);
+ xfer += oprot->writeI32(_iter300->second);
}
xfer += oprot->writeMapEnd();
}
@@ -20927,17 +21204,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->dataMovementPriorityMap.clear();
- uint32_t _size290;
- ::apache::thrift::protocol::TType _ktype291;
- ::apache::thrift::protocol::TType _vtype292;
- xfer += iprot->readMapBegin(_ktype291, _vtype292, _size290);
- uint32_t _i294;
- for (_i294 = 0; _i294 < _size290; ++_i294)
+ uint32_t _size301;
+ ::apache::thrift::protocol::TType _ktype302;
+ ::apache::thrift::protocol::TType _vtype303;
+ xfer += iprot->readMapBegin(_ktype302, _vtype303, _size301);
+ uint32_t _i305;
+ for (_i305 = 0; _i305 < _size301; ++_i305)
{
- std::string _key295;
- xfer += iprot->readString(_key295);
- int32_t& _val296 = this->dataMovementPriorityMap[_key295];
- xfer += iprot->readI32(_val296);
+ std::string _key306;
+ xfer += iprot->readString(_key306);
+ int32_t& _val307 = this->dataMovementPriorityMap[_key306];
+ xfer += iprot->readI32(_val307);
}
xfer += iprot->readMapEnd();
}
@@ -20967,11 +21244,11 @@ uint32_t Airavata_changeDataMovementPriorities_args::write(::apache::thrift::pro
xfer += oprot->writeFieldBegin("dataMovementPriorityMap", ::apache::thrift::protocol::T_MAP, 1);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->dataMovementPriorityMap.size()));
- std::map<std::string, int32_t> ::const_iterator _iter297;
- for (_iter297 = this->dataMovementPriorityMap.begin(); _iter297 != this->dataMovementPriorityMap.end(); ++_iter297)
+ std::map<std::string, int32_t> ::const_iterator _iter308;
+ for (_iter308 = this->dataMovementPriorityMap.begin(); _iter308 != this->dataMovementPriorityMap.end(); ++_iter308)
{
- xfer += oprot->writeString(_iter297->first);
- xfer += oprot->writeI32(_iter297->second);
+ xfer += oprot->writeString(_iter308->first);
+ xfer += oprot->writeI32(_iter308->second);
}
xfer += oprot->writeMapEnd();
}
@@ -20989,11 +21266,11 @@ uint32_t Airavata_changeDataMovementPriorities_pargs::write(::apache::thrift::pr
xfer += oprot->writeFieldBegin("dataMovementPriorityMap", ::apache::thrift::protocol::T_MAP, 1);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_I32, static_cast<uint32_t>((*(this->dataMovementPriorityMap)).size()));
- std::map<std::string, int32_t> ::const_iterator _iter298;
- for (_iter298 = (*(this->dataMovementPriorityMap)).begin(); _iter298 != (*(this->dataMovementPriorityMap)).end(); ++_iter298)
+ std::map<std::string, int32_t> ::const_iterator _iter309;
+ for (_iter309 = (*(this->dataMovementPriorityMap)).begin(); _iter309 != (*(this->dataMovementPriorityMap)).end(); ++_iter309)
{
- xfer += oprot->writeString(_iter298->first);
- xfer += oprot->writeI32(_iter298->second);
+ xfer += oprot->writeString(_iter309->first);
+ xfer += oprot->writeI32(_iter309->second);
}
xfer += oprot->writeMapEnd();
}
@@ -24330,14 +24607,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size299;
- ::apache::thrift::protocol::TType _etype302;
- xfer += iprot->readListBegin(_etype302, _size299);
- this->success.resize(_size299);
- uint32_t _i303;
- for (_i303 = 0; _i303 < _size299; ++_i303)
+ uint32_t _size310;
+ ::apache::thrift::protocol::TType _etype313;
+ xfer += iprot->readListBegin(_etype313, _size310);
+ this->success.resize(_size310);
+ uint32_t _i314;
+ for (_i314 = 0; _i314 < _size310; ++_i314)
{
- xfer += this->success[_i303].read(iprot);
+ xfer += this->success[_i314].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -24392,10 +24669,10 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::write(::apache
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter304;
- for (_iter304 = this->success.begin(); _iter304 != this->success.end(); ++_iter304)
+ std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter315;
+ for (_iter315 = this->success.begin(); _iter315 != this->success.end(); ++_iter315)
{
- xfer += (*_iter304).write(oprot);
+ xfer += (*_iter315).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -24442,14 +24719,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size305;
- ::apache::thrift::protocol::TType _etype308;
- xfer += iprot->readListBegin(_etype308, _size305);
- (*(this->success)).resize(_size305);
- uint32_t _i309;
- for (_i309 = 0; _i309 < _size305; ++_i309)
+ uint32_t _size316;
+ ::apache::thrift::protocol::TType _etype319;
+ xfer += iprot->readListBegin(_etype319, _size316);
+ (*(this->success)).resize(_size316);
+ uint32_t _i320;
+ for (_i320 = 0; _i320 < _size316; ++_i320)
{
- xfer += (*(this->success))[_i309].read(iprot);
+ xfer += (*(this->success))[_i320].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -24563,14 +24840,14 @@ uint32_t Airavata_getAllGatewayComputeResources_result::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size310;
- ::apache::thrift::protocol::TType _etype313;
- xfer += iprot->readListBegin(_etype313, _size310);
- this->success.resize(_size310);
- uint32_t _i314;
- for (_i314 = 0; _i314 < _size310; ++_i314)
+ uint32_t _size321;
+ ::apache::thrift::protocol::TType _etype324;
+ xfer += iprot->readListBegin(_etype324, _size321);
+ this->success.resize(_size321);
+ uint32_t _i325;
+ for (_i325 = 0; _i325 < _size321; ++_i325)
{
- xfer += this->success[_i314].read(iprot);
+ xfer += this->success[_i325].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -24625,10 +24902,10 @@ uint32_t Airavata_getAllGatewayComputeResources_result::write(::apache::thrift::
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::GatewayResourceProfile> ::const_iterator _iter315;
- for (_iter315 = this->success.begin(); _iter315 != this->success.end(); ++_iter315)
+ std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::GatewayResourceProfile> ::const_iterator _iter326;
+ for (_iter326 = this->success.begin(); _iter326 != this->success.end(); ++_iter326)
{
- xfer += (*_iter315).write(oprot);
+ xfer += (*_iter326).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -24675,14 +24952,14 @@ uint32_t Airavata_getAllGatewayComputeResources_presult::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size316;
- ::apache::thrift::protocol::TType _etype319;
- xfer += iprot->readListBegin(_etype319, _size316);
- (*(this->success)).resize(_size316);
- uint32_t _i320;
- for (_i320 = 0; _i320 < _size316; ++_i320)
+ uint32_t _size327;
+ ::apache::thrift::protocol::TType _etype330;
+ xfer += iprot->readListBegin(_etype330, _size327);
+ (*(this->success)).resize(_size327);
+ uint32_t _i331;
+ for (_i331 = 0; _i331 < _size327; ++_i331)
{
- xfer += (*(this->success))[_i320].read(iprot);
+ xfer += (*(this->success))[_i331].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -25303,14 +25580,14 @@ uint32_t Airavata_getAllWorkflows_result::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size321;
- ::apache::thrift::protocol::TType _etype324;
- xfer += iprot->readListBegin(_etype324, _size321);
- this->success.resize(_size321);
- uint32_t _i325;
- for (_i325 = 0; _i325 < _size321; ++_i325)
+ uint32_t _size332;
+ ::apache::thrift::protocol::TType _etype335;
+ xfer += iprot->readListBegin(_etype335, _size332);
+ this->success.resize(_size332);
+ uint32_t _i336;
+ for (_i336 = 0; _i336 < _size332; ++_i336)
{
- xfer += iprot->readString(this->success[_i325]);
+ xfer += iprot->readString(this->success[_i336]);
}
xfer += iprot->readListEnd();
}
@@ -25365,10 +25642,10 @@ uint32_t Airavata_getAllWorkflows_result::write(::apache::thrift::protocol::TPro
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::vector<std::string> ::const_iterator _iter326;
- for (_iter326 = this->success.begin(); _iter326 != this->success.end(); ++_iter326)
+ std::vector<std::string> ::const_iterator _iter337;
+ for (_iter337 = this->success.begin(); _iter337 != this->success.end(); ++_iter337)
{
- xfer += oprot->writeString((*_iter326));
+ xfer += oprot->writeString((*_iter337));
}
xfer += oprot->writeListEnd();
}
@@ -25415,14 +25692,14 @@ uint32_t Airavata_getAllWorkflows_presult::read(::apache::thrift::protocol::TPro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size327;
- ::apache::thrift::protocol::TType _etype330;
- xfer += iprot->readListBegin(_etype330, _size327);
- (*(this->success)).resize(_size327);
- uint32_t _i331;
- for (_i331 = 0; _i331 < _size327; ++_i331)
+ uint32_t _size338;
+ ::apache::thrift::protocol::TType _etype341;
+ xfer += iprot->readListBegin(_etype341, _size338);
+ (*(this->success)).resize(_size338);
+ uint32_t _i342;
+ for (_i342 = 0; _i342 < _size338; ++_i342)
{
- xfer += iprot->readString((*(this->success))[_i331]);
+ xfer += iprot->readString((*(this->success))[_i342]);
}
xfer += iprot->readListEnd();
}
@@ -28733,6 +29010,76 @@ void AiravataClient::recv_getExperimentOutputs(std::vector< ::apache::airavata::
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getExperimentOutputs failed: unknown result");
}
+void AiravataClient::getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId)
+{
+ send_getIntermediateOutputs(airavataExperimentId);
+ recv_getIntermediateOutputs(_return);
+}
+
+void AiravataClient::send_getIntermediateOutputs(const std::string& airavataExperimentId)
+{
+ int32_t cseqid = 0;
+ oprot_->writeMessageBegin("getIntermediateOutputs", ::apache::thrift::protocol::T_CALL, cseqid);
+
+ Airavata_getIntermediateOutputs_pargs args;
+ args.airavataExperimentId = &airavataExperimentId;
+ args.write(oprot_);
+
+ oprot_->writeMessageEnd();
+ oprot_->getTransport()->writeEnd();
+ oprot_->getTransport()->flush();
+}
+
+void AiravataClient::recv_getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return)
+{
+
+ int32_t rseqid = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TMessageType mtype;
+
+ iprot_->readMessageBegin(fname, mtype, rseqid);
+ if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
+ ::apache::thrift::TApplicationException x;
+ x.read(iprot_);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ throw x;
+ }
+ if (mtype != ::apache::thrift::protocol::T_REPLY) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ if (fname.compare("getIntermediateOutputs") != 0) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ Airavata_getIntermediateOutputs_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;
+ }
+ if (result.__isset.enf) {
+ throw result.enf;
+ }
+ if (result.__isset.ace) {
+ throw result.ace;
+ }
+ if (result.__isset.ase) {
+ throw result.ase;
+ }
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getIntermediateOutputs failed: unknown result");
+}
+
void AiravataClient::getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId)
{
send_getJobStatuses(airavataExperimentId);
@@ -36115,6 +36462,72 @@ void AiravataProcessor::process_getExperimentOutputs(int32_t seqid, ::apache::th
}
}
+void AiravataProcessor::process_getIntermediateOutputs(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
+{
+ void* ctx = NULL;
+ if (this->eventHandler_.get() != NULL) {
+ ctx = this->eventHandler_->getContext("Airavata.getIntermediateOutputs", callContext);
+ }
+ ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.getIntermediateOutputs");
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preRead(ctx, "Airavata.getIntermediateOutputs");
+ }
+
+ Airavata_getIntermediateOutputs_args args;
+ args.read(iprot);
+ iprot->readMessageEnd();
+ uint32_t bytes = iprot->getTransport()->readEnd();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postRead(ctx, "Airavata.getIntermediateOutputs", bytes);
+ }
+
+ Airavata_getIntermediateOutputs_result result;
+ try {
+ iface_->getIntermediateOutputs(result.success, args.airavataExperimentId);
+ result.__isset.success = true;
+ } catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
+ result.ire = ire;
+ result.__isset.ire = true;
+ } catch ( ::apache::airavata::api::error::ExperimentNotFoundException &enf) {
+ result.enf = enf;
+ result.__isset.enf = true;
+ } catch ( ::apache::airavata::api::error::AiravataClientException &ace) {
+ result.ace = ace;
+ result.__isset.ace = true;
+ } catch ( ::apache::airavata::api::error::AiravataSystemException &ase) {
+ result.ase = ase;
+ result.__isset.ase = true;
+ } catch (const std::exception& e) {
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->handlerError(ctx, "Airavata.getIntermediateOutputs");
+ }
+
+ ::apache::thrift::TApplicationException x(e.what());
+ oprot->writeMessageBegin("getIntermediateOutputs", ::apache::thrift::protocol::T_EXCEPTION, seqid);
+ x.write(oprot);
+ oprot->writeMessageEnd();
+ oprot->getTransport()->writeEnd();
+ oprot->getTransport()->flush();
+ return;
+ }
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preWrite(ctx, "Airavata.getIntermediateOutputs");
+ }
+
+ oprot->writeMessageBegin("getIntermediateOutputs", ::apache::thrift::protocol::T_REPLY, seqid);
+ result.write(oprot);
+ oprot->writeMessageEnd();
+ bytes = oprot->getTransport()->writeEnd();
+ oprot->getTransport()->flush();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postWrite(ctx, "Airavata.getIntermediateOutputs", bytes);
+ }
+}
+
void AiravataProcessor::process_getJobStatuses(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
{
void* ctx = NULL;
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
index 776ee04..a1ce19d 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
@@ -61,6 +61,7 @@ class AiravataIf {
virtual void launchExperiment(const std::string& airavataExperimentId, const std::string& airavataCredStoreToken) = 0;
virtual void getExperimentStatus( ::apache::airavata::model::workspace::experiment::ExperimentStatus& _return, const std::string& airavataExperimentId) = 0;
virtual void getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) = 0;
+ virtual void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) = 0;
virtual void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) = 0;
virtual void getJobDetails(std::vector< ::apache::airavata::model::workspace::experiment::JobDetails> & _return, const std::string& airavataExperimentId) = 0;
virtual void getDataTransferDetails(std::vector< ::apache::airavata::model::workspace::experiment::DataTransferDetails> & _return, const std::string& airavataExperimentId) = 0;
@@ -262,6 +263,9 @@ class AiravataNull : virtual public AiravataIf {
void getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & /* _return */, const std::string& /* airavataExperimentId */) {
return;
}
+ void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & /* _return */, const std::string& /* airavataExperimentId */) {
+ return;
+ }
void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & /* _return */, const std::string& /* airavataExperimentId */) {
return;
}
@@ -4426,6 +4430,148 @@ class Airavata_getExperimentOutputs_presult {
};
+class Airavata_getIntermediateOutputs_args {
+ public:
+
+ Airavata_getIntermediateOutputs_args() : airavataExperimentId() {
+ }
+
+ virtual ~Airavata_getIntermediateOutputs_args() throw() {}
+
+ std::string airavataExperimentId;
+
+ void __set_airavataExperimentId(const std::string& val) {
+ airavataExperimentId = val;
+ }
+
+ bool operator == (const Airavata_getIntermediateOutputs_args & rhs) const
+ {
+ if (!(airavataExperimentId == rhs.airavataExperimentId))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_getIntermediateOutputs_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_getIntermediateOutputs_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_getIntermediateOutputs_pargs {
+ public:
+
+
+ virtual ~Airavata_getIntermediateOutputs_pargs() throw() {}
+
+ const std::string* airavataExperimentId;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_getIntermediateOutputs_result__isset {
+ _Airavata_getIntermediateOutputs_result__isset() : success(false), ire(false), enf(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool enf;
+ bool ace;
+ bool ase;
+} _Airavata_getIntermediateOutputs_result__isset;
+
+class Airavata_getIntermediateOutputs_result {
+ public:
+
+ Airavata_getIntermediateOutputs_result() {
+ }
+
+ virtual ~Airavata_getIntermediateOutputs_result() throw() {}
+
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::ExperimentNotFoundException enf;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_getIntermediateOutputs_result__isset __isset;
+
+ void __set_success(const std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & val) {
+ success = val;
+ }
+
+ void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) {
+ ire = val;
+ }
+
+ void __set_enf(const ::apache::airavata::api::error::ExperimentNotFoundException& val) {
+ enf = val;
+ }
+
+ void __set_ace(const ::apache::airavata::api::error::AiravataClientException& val) {
+ ace = val;
+ }
+
+ void __set_ase(const ::apache::airavata::api::error::AiravataSystemException& val) {
+ ase = val;
+ }
+
+ bool operator == (const Airavata_getIntermediateOutputs_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(enf == rhs.enf))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_getIntermediateOutputs_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_getIntermediateOutputs_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_getIntermediateOutputs_presult__isset {
+ _Airavata_getIntermediateOutputs_presult__isset() : success(false), ire(false), enf(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool enf;
+ bool ace;
+ bool ase;
+} _Airavata_getIntermediateOutputs_presult__isset;
+
+class Airavata_getIntermediateOutputs_presult {
+ public:
+
+
+ virtual ~Airavata_getIntermediateOutputs_presult() throw() {}
+
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> * success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::ExperimentNotFoundException enf;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_getIntermediateOutputs_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
class Airavata_getJobStatuses_args {
public:
@@ -15677,6 +15823,9 @@ class AiravataClient : virtual public AiravataIf {
void getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId);
void send_getExperimentOutputs(const std::string& airavataExperimentId);
void recv_getExperimentOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return);
+ void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId);
+ void send_getIntermediateOutputs(const std::string& airavataExperimentId);
+ void recv_getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return);
void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId);
void send_getJobStatuses(const std::string& airavataExperimentId);
void recv_getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return);
@@ -15967,6 +16116,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
void process_launchExperiment(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getExperimentStatus(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getExperimentOutputs(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_getIntermediateOutputs(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getJobStatuses(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getJobDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getDataTransferDetails(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -16081,6 +16231,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
processMap_["launchExperiment"] = &AiravataProcessor::process_launchExperiment;
processMap_["getExperimentStatus"] = &AiravataProcessor::process_getExperimentStatus;
processMap_["getExperimentOutputs"] = &AiravataProcessor::process_getExperimentOutputs;
+ processMap_["getIntermediateOutputs"] = &AiravataProcessor::process_getIntermediateOutputs;
processMap_["getJobStatuses"] = &AiravataProcessor::process_getJobStatuses;
processMap_["getJobDetails"] = &AiravataProcessor::process_getJobDetails;
processMap_["getDataTransferDetails"] = &AiravataProcessor::process_getDataTransferDetails;
@@ -16472,6 +16623,16 @@ class AiravataMultiface : virtual public AiravataIf {
return;
}
+ void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->getIntermediateOutputs(_return, airavataExperimentId);
+ }
+ ifaces_[i]->getIntermediateOutputs(_return, airavataExperimentId);
+ return;
+ }
+
void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) {
size_t sz = ifaces_.size();
size_t i = 0;
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
index e68589f..42f63a2 100644
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
@@ -184,6 +184,11 @@ class AiravataHandler : virtual public AiravataIf {
printf("getExperimentOutputs\n");
}
+ void getIntermediateOutputs(std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> & _return, const std::string& airavataExperimentId) {
+ // Your implementation goes here
+ printf("getIntermediateOutputs\n");
+ }
+
void getJobStatuses(std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> & _return, const std::string& airavataExperimentId) {
// Your implementation goes here
printf("getJobStatuses\n");
[4/4] airavata git commit: adding getIntermediateOutput method to API
Posted by ch...@apache.org.
adding getIntermediateOutput method to API
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/25cf3c97
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/25cf3c97
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/25cf3c97
Branch: refs/heads/master
Commit: 25cf3c97b194533e5c83cb38b302a57ae216c4dd
Parents: 658e5e9
Author: Chathuri Wimalasena <ka...@gmail.com>
Authored: Tue Mar 3 10:00:06 2015 -0500
Committer: Chathuri Wimalasena <ka...@gmail.com>
Committed: Tue Mar 3 10:00:06 2015 -0500
----------------------------------------------------------------------
.../server/handler/AiravataServerHandler.java | 5 +
.../java/org/apache/airavata/api/Airavata.java | 5426 +++++++++++-------
.../main/resources/lib/airavata/Airavata.cpp | 1055 ++--
.../src/main/resources/lib/airavata/Airavata.h | 161 +
.../lib/airavata/Airavata_server.skeleton.cpp | 5 +
.../resources/lib/Airavata/API/Airavata.php | 698 ++-
.../airavataAPI.thrift | 6 +
7 files changed, 4804 insertions(+), 2552 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
index c23ad66..e4da984 100644
--- a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
+++ b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
@@ -1047,6 +1047,11 @@ public class AiravataServerHandler implements Airavata.Iface {
}
}
+ @Override
+ public List<OutputDataObjectType> getIntermediateOutputs(String airavataExperimentId) throws InvalidRequestException, ExperimentNotFoundException, AiravataClientException, AiravataSystemException, TException {
+ return null;
+ }
+
public Map<String, JobStatus> getJobStatuses(String airavataExperimentId) throws TException {
Map<String, JobStatus> jobStatus = new HashMap<String, JobStatus>();
try {
[3/4] airavata git commit: adding getIntermediateOutput method to API
Posted by ch...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
index 8ea9fa4..6419290 100644
--- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
+++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
@@ -372,6 +372,8 @@ import org.slf4j.LoggerFactory;
public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getExperimentOutputs(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+ public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getIntermediateOutputs(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+
public Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> getJobStatuses(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
public List<org.apache.airavata.model.workspace.experiment.JobDetails> getJobDetails(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
@@ -1498,6 +1500,8 @@ import org.slf4j.LoggerFactory;
public void getExperimentOutputs(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getIntermediateOutputs(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getJobStatuses(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getJobDetails(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -2618,6 +2622,41 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getExperimentOutputs failed: unknown result");
}
+ public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getIntermediateOutputs(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getIntermediateOutputs(airavataExperimentId);
+ return recv_getIntermediateOutputs();
+ }
+
+ public void send_getIntermediateOutputs(String airavataExperimentId) throws org.apache.thrift.TException
+ {
+ getIntermediateOutputs_args args = new getIntermediateOutputs_args();
+ args.setAiravataExperimentId(airavataExperimentId);
+ sendBase("getIntermediateOutputs", args);
+ }
+
+ public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> recv_getIntermediateOutputs() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getIntermediateOutputs_result result = new getIntermediateOutputs_result();
+ receiveBase(result, "getIntermediateOutputs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.enf != null) {
+ throw result.enf;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getIntermediateOutputs failed: unknown result");
+ }
+
public Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> getJobStatuses(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_getJobStatuses(airavataExperimentId);
@@ -6266,6 +6305,38 @@ import org.slf4j.LoggerFactory;
}
}
+ public void getIntermediateOutputs(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getIntermediateOutputs_call method_call = new getIntermediateOutputs_call(airavataExperimentId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getIntermediateOutputs_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String airavataExperimentId;
+ public getIntermediateOutputs_call(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.airavataExperimentId = airavataExperimentId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getIntermediateOutputs", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getIntermediateOutputs_args args = new getIntermediateOutputs_args();
+ args.setAiravataExperimentId(airavataExperimentId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, 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);
+ return (new Client(prot)).recv_getIntermediateOutputs();
+ }
+ }
+
public void getJobStatuses(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getJobStatuses_call method_call = new getJobStatuses_call(airavataExperimentId, resultHandler, this, ___protocolFactory, ___transport);
@@ -9040,6 +9111,7 @@ import org.slf4j.LoggerFactory;
processMap.put("launchExperiment", new launchExperiment());
processMap.put("getExperimentStatus", new getExperimentStatus());
processMap.put("getExperimentOutputs", new getExperimentOutputs());
+ processMap.put("getIntermediateOutputs", new getIntermediateOutputs());
processMap.put("getJobStatuses", new getJobStatuses());
processMap.put("getJobDetails", new getJobDetails());
processMap.put("getDataTransferDetails", new getDataTransferDetails());
@@ -9944,6 +10016,36 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class getIntermediateOutputs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getIntermediateOutputs_args> {
+ public getIntermediateOutputs() {
+ super("getIntermediateOutputs");
+ }
+
+ public getIntermediateOutputs_args getEmptyArgsInstance() {
+ return new getIntermediateOutputs_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getIntermediateOutputs_result getResult(I iface, getIntermediateOutputs_args args) throws org.apache.thrift.TException {
+ getIntermediateOutputs_result result = new getIntermediateOutputs_result();
+ try {
+ result.success = iface.getIntermediateOutputs(args.airavataExperimentId);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.ExperimentNotFoundException enf) {
+ result.enf = enf;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ }
+ return result;
+ }
+ }
+
public static class getJobStatuses<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobStatuses_args> {
public getJobStatuses() {
super("getJobStatuses");
@@ -12323,6 +12425,7 @@ import org.slf4j.LoggerFactory;
processMap.put("launchExperiment", new launchExperiment());
processMap.put("getExperimentStatus", new getExperimentStatus());
processMap.put("getExperimentOutputs", new getExperimentOutputs());
+ processMap.put("getIntermediateOutputs", new getIntermediateOutputs());
processMap.put("getJobStatuses", new getJobStatuses());
processMap.put("getJobDetails", new getJobDetails());
processMap.put("getDataTransferDetails", new getDataTransferDetails());
@@ -14366,20 +14469,20 @@ import org.slf4j.LoggerFactory;
}
}
- public static class getJobStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobStatuses_args, Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> {
- public getJobStatuses() {
- super("getJobStatuses");
+ public static class getIntermediateOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getIntermediateOutputs_args, List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> {
+ public getIntermediateOutputs() {
+ super("getIntermediateOutputs");
}
- public getJobStatuses_args getEmptyArgsInstance() {
- return new getJobStatuses_args();
+ public getIntermediateOutputs_args getEmptyArgsInstance() {
+ return new getIntermediateOutputs_args();
}
- public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>>() {
- public void onComplete(Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> o) {
- getJobStatuses_result result = new getJobStatuses_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) {
+ getIntermediateOutputs_result result = new getIntermediateOutputs_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -14392,7 +14495,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getJobStatuses_result result = new getJobStatuses_result();
+ getIntermediateOutputs_result result = new getIntermediateOutputs_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -14433,25 +14536,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getJobStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> resultHandler) throws TException {
- iface.getJobStatuses(args.airavataExperimentId,resultHandler);
+ public void start(I iface, getIntermediateOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> resultHandler) throws TException {
+ iface.getIntermediateOutputs(args.airavataExperimentId,resultHandler);
}
}
- public static class getJobDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobDetails_args, List<org.apache.airavata.model.workspace.experiment.JobDetails>> {
- public getJobDetails() {
- super("getJobDetails");
+ public static class getJobStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobStatuses_args, Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> {
+ public getJobStatuses() {
+ super("getJobStatuses");
}
- public getJobDetails_args getEmptyArgsInstance() {
- return new getJobDetails_args();
+ public getJobStatuses_args getEmptyArgsInstance() {
+ return new getJobStatuses_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>>() {
- public void onComplete(List<org.apache.airavata.model.workspace.experiment.JobDetails> o) {
- getJobDetails_result result = new getJobDetails_result();
+ return new AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>>() {
+ public void onComplete(Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> o) {
+ getJobStatuses_result result = new getJobStatuses_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -14464,7 +14567,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getJobDetails_result result = new getJobDetails_result();
+ getJobStatuses_result result = new getJobStatuses_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -14505,25 +14608,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getJobDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> resultHandler) throws TException {
- iface.getJobDetails(args.airavataExperimentId,resultHandler);
+ public void start(I iface, getJobStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> resultHandler) throws TException {
+ iface.getJobStatuses(args.airavataExperimentId,resultHandler);
}
}
- public static class getDataTransferDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getDataTransferDetails_args, List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> {
- public getDataTransferDetails() {
- super("getDataTransferDetails");
+ public static class getJobDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobDetails_args, List<org.apache.airavata.model.workspace.experiment.JobDetails>> {
+ public getJobDetails() {
+ super("getJobDetails");
}
- public getDataTransferDetails_args getEmptyArgsInstance() {
- return new getDataTransferDetails_args();
+ public getJobDetails_args getEmptyArgsInstance() {
+ return new getJobDetails_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>>() {
- public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataTransferDetails> o) {
- getDataTransferDetails_result result = new getDataTransferDetails_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.experiment.JobDetails> o) {
+ getJobDetails_result result = new getJobDetails_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -14536,7 +14639,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getDataTransferDetails_result result = new getDataTransferDetails_result();
+ getJobDetails_result result = new getJobDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -14577,25 +14680,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getDataTransferDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> resultHandler) throws TException {
- iface.getDataTransferDetails(args.airavataExperimentId,resultHandler);
+ public void start(I iface, getJobDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> resultHandler) throws TException {
+ iface.getJobDetails(args.airavataExperimentId,resultHandler);
}
}
- public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> {
- public cloneExperiment() {
- super("cloneExperiment");
+ public static class getDataTransferDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getDataTransferDetails_args, List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> {
+ public getDataTransferDetails() {
+ super("getDataTransferDetails");
}
- public cloneExperiment_args getEmptyArgsInstance() {
- return new cloneExperiment_args();
+ public getDataTransferDetails_args getEmptyArgsInstance() {
+ return new getDataTransferDetails_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- cloneExperiment_result result = new cloneExperiment_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataTransferDetails> o) {
+ getDataTransferDetails_result result = new getDataTransferDetails_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -14608,78 +14711,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- cloneExperiment_result result = new cloneExperiment_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) {
- result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e;
- result.setEnfIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, cloneExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.cloneExperiment(args.existingExperimentID, args.newExperimentName,resultHandler);
- }
- }
-
- public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> {
- public terminateExperiment() {
- super("terminateExperiment");
- }
-
- public terminateExperiment_args getEmptyArgsInstance() {
- return new terminateExperiment_args();
- }
-
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- terminateExperiment_result result = new terminateExperiment_result();
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- terminateExperiment_result result = new terminateExperiment_result();
+ getDataTransferDetails_result result = new getDataTransferDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -14720,25 +14752,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, terminateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.terminateExperiment(args.airavataExperimentId,resultHandler);
+ public void start(I iface, getDataTransferDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> resultHandler) throws TException {
+ iface.getDataTransferDetails(args.airavataExperimentId,resultHandler);
}
}
- public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> {
- public registerApplicationModule() {
- super("registerApplicationModule");
+ public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> {
+ public cloneExperiment() {
+ super("cloneExperiment");
}
- public registerApplicationModule_args getEmptyArgsInstance() {
- return new registerApplicationModule_args();
+ public cloneExperiment_args getEmptyArgsInstance() {
+ return new cloneExperiment_args();
}
public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<String>() {
public void onComplete(String o) {
- registerApplicationModule_result result = new registerApplicationModule_result();
+ cloneExperiment_result result = new cloneExperiment_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -14751,77 +14783,15 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerApplicationModule_result result = new registerApplicationModule_result();
+ cloneExperiment_result result = new cloneExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, registerApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerApplicationModule(args.applicationModule,resultHandler);
- }
- }
-
- public static class getApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationModule_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> {
- public getApplicationModule() {
- super("getApplicationModule");
- }
-
- public getApplicationModule_args getEmptyArgsInstance() {
- return new getApplicationModule_args();
- }
-
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>() {
- public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule o) {
- getApplicationModule_result result = new getApplicationModule_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- getApplicationModule_result result = new getApplicationModule_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
+ else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) {
+ result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e;
+ result.setEnfIsSet(true);
msg = result;
}
else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
@@ -14854,27 +14824,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> resultHandler) throws TException {
- iface.getApplicationModule(args.appModuleId,resultHandler);
+ public void start(I iface, cloneExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.cloneExperiment(args.existingExperimentID, args.newExperimentName,resultHandler);
}
}
- public static class updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> {
- public updateApplicationModule() {
- super("updateApplicationModule");
+ public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> {
+ public terminateExperiment() {
+ super("terminateExperiment");
}
- public updateApplicationModule_args getEmptyArgsInstance() {
- return new updateApplicationModule_args();
+ public terminateExperiment_args getEmptyArgsInstance() {
+ return new terminateExperiment_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateApplicationModule_result result = new updateApplicationModule_result();
- result.success = o;
- result.setSuccessIsSet(true);
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ terminateExperiment_result result = new terminateExperiment_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -14886,77 +14854,15 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateApplicationModule_result result = new updateApplicationModule_result();
+ terminateExperiment_result result = new terminateExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, updateApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateApplicationModule(args.appModuleId, args.applicationModule,resultHandler);
- }
- }
-
- public static class getAllAppModules<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllAppModules_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> {
- public getAllAppModules() {
- super("getAllAppModules");
- }
-
- public getAllAppModules_args getEmptyArgsInstance() {
- return new getAllAppModules_args();
- }
-
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> o) {
- getAllAppModules_result result = new getAllAppModules_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- getAllAppModules_result result = new getAllAppModules_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
+ else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) {
+ result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e;
+ result.setEnfIsSet(true);
msg = result;
}
else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
@@ -14989,27 +14895,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAllAppModules_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> resultHandler) throws TException {
- iface.getAllAppModules(resultHandler);
+ public void start(I iface, terminateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.terminateExperiment(args.airavataExperimentId,resultHandler);
}
}
- public static class deleteApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationModule_args, Boolean> {
- public deleteApplicationModule() {
- super("deleteApplicationModule");
+ public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> {
+ public registerApplicationModule() {
+ super("registerApplicationModule");
}
- public deleteApplicationModule_args getEmptyArgsInstance() {
- return new deleteApplicationModule_args();
+ public registerApplicationModule_args getEmptyArgsInstance() {
+ return new registerApplicationModule_args();
}
- public AsyncMethodCallback<Boolean> 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<Boolean>() {
- public void onComplete(Boolean o) {
- deleteApplicationModule_result result = new deleteApplicationModule_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerApplicationModule_result result = new registerApplicationModule_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15021,7 +14926,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteApplicationModule_result result = new deleteApplicationModule_result();
+ registerApplicationModule_result result = new registerApplicationModule_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15057,25 +14962,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, deleteApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteApplicationModule(args.appModuleId,resultHandler);
+ public void start(I iface, registerApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerApplicationModule(args.applicationModule,resultHandler);
}
}
- public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> {
- public registerApplicationDeployment() {
- super("registerApplicationDeployment");
+ public static class getApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationModule_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> {
+ public getApplicationModule() {
+ super("getApplicationModule");
}
- public registerApplicationDeployment_args getEmptyArgsInstance() {
- return new registerApplicationDeployment_args();
+ public getApplicationModule_args getEmptyArgsInstance() {
+ return new getApplicationModule_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- registerApplicationDeployment_result result = new registerApplicationDeployment_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule o) {
+ getApplicationModule_result result = new getApplicationModule_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15088,7 +14993,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerApplicationDeployment_result result = new registerApplicationDeployment_result();
+ getApplicationModule_result result = new getApplicationModule_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15124,26 +15029,27 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, registerApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerApplicationDeployment(args.applicationDeployment,resultHandler);
+ public void start(I iface, getApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> resultHandler) throws TException {
+ iface.getApplicationModule(args.appModuleId,resultHandler);
}
}
- public static class getApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationDeployment_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> {
- public getApplicationDeployment() {
- super("getApplicationDeployment");
+ public static class updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> {
+ public updateApplicationModule() {
+ super("updateApplicationModule");
}
- public getApplicationDeployment_args getEmptyArgsInstance() {
- return new getApplicationDeployment_args();
+ public updateApplicationModule_args getEmptyArgsInstance() {
+ return new updateApplicationModule_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>() {
- public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription o) {
- getApplicationDeployment_result result = new getApplicationDeployment_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateApplicationModule_result result = new updateApplicationModule_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15155,7 +15061,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationDeployment_result result = new getApplicationDeployment_result();
+ updateApplicationModule_result result = new updateApplicationModule_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15191,27 +15097,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> resultHandler) throws TException {
- iface.getApplicationDeployment(args.appDeploymentId,resultHandler);
+ public void start(I iface, updateApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateApplicationModule(args.appModuleId, args.applicationModule,resultHandler);
}
}
- public static class updateApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationDeployment_args, Boolean> {
- public updateApplicationDeployment() {
- super("updateApplicationDeployment");
+ public static class getAllAppModules<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllAppModules_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> {
+ public getAllAppModules() {
+ super("getAllAppModules");
}
- public updateApplicationDeployment_args getEmptyArgsInstance() {
- return new updateApplicationDeployment_args();
+ public getAllAppModules_args getEmptyArgsInstance() {
+ return new getAllAppModules_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateApplicationDeployment_result result = new updateApplicationDeployment_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> o) {
+ getAllAppModules_result result = new getAllAppModules_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15223,7 +15128,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateApplicationDeployment_result result = new updateApplicationDeployment_result();
+ getAllAppModules_result result = new getAllAppModules_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15259,25 +15164,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateApplicationDeployment(args.appDeploymentId, args.applicationDeployment,resultHandler);
+ public void start(I iface, getAllAppModules_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> resultHandler) throws TException {
+ iface.getAllAppModules(resultHandler);
}
}
- public static class deleteApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationDeployment_args, Boolean> {
- public deleteApplicationDeployment() {
- super("deleteApplicationDeployment");
+ public static class deleteApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationModule_args, Boolean> {
+ public deleteApplicationModule() {
+ super("deleteApplicationModule");
}
- public deleteApplicationDeployment_args getEmptyArgsInstance() {
- return new deleteApplicationDeployment_args();
+ public deleteApplicationModule_args getEmptyArgsInstance() {
+ return new deleteApplicationModule_args();
}
public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Boolean>() {
public void onComplete(Boolean o) {
- deleteApplicationDeployment_result result = new deleteApplicationDeployment_result();
+ deleteApplicationModule_result result = new deleteApplicationModule_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -15291,7 +15196,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteApplicationDeployment_result result = new deleteApplicationDeployment_result();
+ deleteApplicationModule_result result = new deleteApplicationModule_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15327,25 +15232,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, deleteApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteApplicationDeployment(args.appDeploymentId,resultHandler);
+ public void start(I iface, deleteApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteApplicationModule(args.appModuleId,resultHandler);
}
}
- public static class getAllApplicationDeployments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationDeployments_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> {
- public getAllApplicationDeployments() {
- super("getAllApplicationDeployments");
+ public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> {
+ public registerApplicationDeployment() {
+ super("registerApplicationDeployment");
}
- public getAllApplicationDeployments_args getEmptyArgsInstance() {
- return new getAllApplicationDeployments_args();
+ public registerApplicationDeployment_args getEmptyArgsInstance() {
+ return new registerApplicationDeployment_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> 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<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> o) {
- getAllApplicationDeployments_result result = new getAllApplicationDeployments_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerApplicationDeployment_result result = new registerApplicationDeployment_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15358,7 +15263,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllApplicationDeployments_result result = new getAllApplicationDeployments_result();
+ registerApplicationDeployment_result result = new registerApplicationDeployment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15394,25 +15299,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAllApplicationDeployments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> resultHandler) throws TException {
- iface.getAllApplicationDeployments(resultHandler);
+ public void start(I iface, registerApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerApplicationDeployment(args.applicationDeployment,resultHandler);
}
}
- public static class getAppModuleDeployedResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAppModuleDeployedResources_args, List<String>> {
- public getAppModuleDeployedResources() {
- super("getAppModuleDeployedResources");
+ public static class getApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationDeployment_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> {
+ public getApplicationDeployment() {
+ super("getApplicationDeployment");
}
- public getAppModuleDeployedResources_args getEmptyArgsInstance() {
- return new getAppModuleDeployedResources_args();
+ public getApplicationDeployment_args getEmptyArgsInstance() {
+ return new getApplicationDeployment_args();
}
- public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<String>>() {
- public void onComplete(List<String> o) {
- getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription o) {
+ getApplicationDeployment_result result = new getApplicationDeployment_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15425,7 +15330,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result();
+ getApplicationDeployment_result result = new getApplicationDeployment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15461,93 +15366,27 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAppModuleDeployedResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.getAppModuleDeployedResources(args.appModuleId,resultHandler);
- }
- }
-
- public static class registerApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationInterface_args, String> {
- public registerApplicationInterface() {
- super("registerApplicationInterface");
- }
-
- public registerApplicationInterface_args getEmptyArgsInstance() {
- return new registerApplicationInterface_args();
- }
-
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- registerApplicationInterface_result result = new registerApplicationInterface_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- registerApplicationInterface_result result = new registerApplicationInterface_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, registerApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerApplicationInterface(args.applicationInterface,resultHandler);
+ public void start(I iface, getApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> resultHandler) throws TException {
+ iface.getApplicationDeployment(args.appDeploymentId,resultHandler);
}
}
- public static class getApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInterface_args, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> {
- public getApplicationInterface() {
- super("getApplicationInterface");
+ public static class updateApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationDeployment_args, Boolean> {
+ public updateApplicationDeployment() {
+ super("updateApplicationDeployment");
}
- public getApplicationInterface_args getEmptyArgsInstance() {
- return new getApplicationInterface_args();
+ public updateApplicationDeployment_args getEmptyArgsInstance() {
+ return new updateApplicationDeployment_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>() {
- public void onComplete(org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription o) {
- getApplicationInterface_result result = new getApplicationInterface_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateApplicationDeployment_result result = new updateApplicationDeployment_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15559,7 +15398,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationInterface_result result = new getApplicationInterface_result();
+ updateApplicationDeployment_result result = new updateApplicationDeployment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15595,25 +15434,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> resultHandler) throws TException {
- iface.getApplicationInterface(args.appInterfaceId,resultHandler);
+ public void start(I iface, updateApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateApplicationDeployment(args.appDeploymentId, args.applicationDeployment,resultHandler);
}
}
- public static class updateApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationInterface_args, Boolean> {
- public updateApplicationInterface() {
- super("updateApplicationInterface");
+ public static class deleteApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationDeployment_args, Boolean> {
+ public deleteApplicationDeployment() {
+ super("deleteApplicationDeployment");
}
- public updateApplicationInterface_args getEmptyArgsInstance() {
- return new updateApplicationInterface_args();
+ public deleteApplicationDeployment_args getEmptyArgsInstance() {
+ return new deleteApplicationDeployment_args();
}
public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Boolean>() {
public void onComplete(Boolean o) {
- updateApplicationInterface_result result = new updateApplicationInterface_result();
+ deleteApplicationDeployment_result result = new deleteApplicationDeployment_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -15627,7 +15466,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateApplicationInterface_result result = new updateApplicationInterface_result();
+ deleteApplicationDeployment_result result = new deleteApplicationDeployment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15663,27 +15502,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateApplicationInterface(args.appInterfaceId, args.applicationInterface,resultHandler);
+ public void start(I iface, deleteApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteApplicationDeployment(args.appDeploymentId,resultHandler);
}
}
- public static class deleteApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationInterface_args, Boolean> {
- public deleteApplicationInterface() {
- super("deleteApplicationInterface");
+ public static class getAllApplicationDeployments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationDeployments_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> {
+ public getAllApplicationDeployments() {
+ super("getAllApplicationDeployments");
}
- public deleteApplicationInterface_args getEmptyArgsInstance() {
- return new deleteApplicationInterface_args();
+ public getAllApplicationDeployments_args getEmptyArgsInstance() {
+ return new getAllApplicationDeployments_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteApplicationInterface_result result = new deleteApplicationInterface_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> o) {
+ getAllApplicationDeployments_result result = new getAllApplicationDeployments_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15695,7 +15533,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteApplicationInterface_result result = new deleteApplicationInterface_result();
+ getAllApplicationDeployments_result result = new getAllApplicationDeployments_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15731,25 +15569,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, deleteApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteApplicationInterface(args.appInterfaceId,resultHandler);
+ public void start(I iface, getAllApplicationDeployments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> resultHandler) throws TException {
+ iface.getAllApplicationDeployments(resultHandler);
}
}
- public static class getAllApplicationInterfaceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaceNames_args, Map<String,String>> {
- public getAllApplicationInterfaceNames() {
- super("getAllApplicationInterfaceNames");
+ public static class getAppModuleDeployedResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAppModuleDeployedResources_args, List<String>> {
+ public getAppModuleDeployedResources() {
+ super("getAppModuleDeployedResources");
}
- public getAllApplicationInterfaceNames_args getEmptyArgsInstance() {
- return new getAllApplicationInterfaceNames_args();
+ public getAppModuleDeployedResources_args getEmptyArgsInstance() {
+ return new getAppModuleDeployedResources_args();
}
- public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
+ return new AsyncMethodCallback<List<String>>() {
+ public void onComplete(List<String> o) {
+ getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15762,7 +15600,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
+ getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15798,25 +15636,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAllApplicationInterfaceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllApplicationInterfaceNames(resultHandler);
+ public void start(I iface, getAppModuleDeployedResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
+ iface.getAppModuleDeployedResources(args.appModuleId,resultHandler);
}
}
- public static class getAllApplicationInterfaces<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaces_args, List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> {
- public getAllApplicationInterfaces() {
- super("getAllApplicationInterfaces");
+ public static class registerApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationInterface_args, String> {
+ public registerApplicationInterface() {
+ super("registerApplicationInterface");
}
- public getAllApplicationInterfaces_args getEmptyArgsInstance() {
- return new getAllApplicationInterfaces_args();
+ public registerApplicationInterface_args getEmptyArgsInstance() {
+ return new registerApplicationInterface_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> 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<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> o) {
- getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerApplicationInterface_result result = new registerApplicationInterface_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15829,7 +15667,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
+ registerApplicationInterface_result result = new registerApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15865,25 +15703,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAllApplicationInterfaces_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> resultHandler) throws TException {
- iface.getAllApplicationInterfaces(resultHandler);
+ public void start(I iface, registerApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerApplicationInterface(args.applicationInterface,resultHandler);
}
}
- public static class getApplicationInputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInputs_args, List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> {
- public getApplicationInputs() {
- super("getApplicationInputs");
+ public static class getApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInterface_args, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> {
+ public getApplicationInterface() {
+ super("getApplicationInterface");
}
- public getApplicationInputs_args getEmptyArgsInstance() {
- return new getApplicationInputs_args();
+ public getApplicationInterface_args getEmptyArgsInstance() {
+ return new getApplicationInterface_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> o) {
- getApplicationInputs_result result = new getApplicationInputs_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription o) {
+ getApplicationInterface_result result = new getApplicationInterface_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15896,7 +15734,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationInputs_result result = new getApplicationInputs_result();
+ getApplicationInterface_result result = new getApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15932,26 +15770,27 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationInputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> resultHandler) throws TException {
- iface.getApplicationInputs(args.appInterfaceId,resultHandler);
+ public void start(I iface, getApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> resultHandler) throws TException {
+ iface.getApplicationInterface(args.appInterfaceId,resultHandler);
}
}
- public static class getApplicationOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationOutputs_args, List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> {
- public getApplicationOutputs() {
- super("getApplicationOutputs");
+ public static class updateApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationInterface_args, Boolean> {
+ public updateApplicationInterface() {
+ super("updateApplicationInterface");
}
- public getApplicationOutputs_args getEmptyArgsInstance() {
- return new getApplicationOutputs_args();
+ public updateApplicationInterface_args getEmptyArgsInstance() {
+ return new updateApplicationInterface_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) {
- getApplicationOutputs_result result = new getApplicationOutputs_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateApplicationInterface_result result = new updateApplicationInterface_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15963,7 +15802,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationOutputs_result result = new getApplicationOutputs_result();
+ updateApplicationInterface_result result = new updateApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -15999,26 +15838,27 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> resultHandler) throws TException {
- iface.getApplicationOutputs(args.appInterfaceId,resultHandler);
+ public void start(I iface, updateApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateApplicationInterface(args.appInterfaceId, args.applicationInterface,resultHandler);
}
}
- public static class getAvailableAppInterfaceComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAvailableAppInterfaceComputeResources_args, Map<String,String>> {
- public getAvailableAppInterfaceComputeResources() {
- super("getAvailableAppInterfaceComputeResources");
+ public static class deleteApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationInterface_args, Boolean> {
+ public deleteApplicationInterface() {
+ super("deleteApplicationInterface");
}
- public getAvailableAppInterfaceComputeResources_args getEmptyArgsInstance() {
- return new getAvailableAppInterfaceComputeResources_args();
+ public deleteApplicationInterface_args getEmptyArgsInstance() {
+ return new deleteApplicationInterface_args();
}
- public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteApplicationInterface_result result = new deleteApplicationInterface_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -16030,7 +15870,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceCompu
<TRUNCATED>