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 2014/08/18 18:22:02 UTC
[1/4] fixing AIRAVATA-1360
Repository: airavata
Updated Branches:
refs/heads/master bb8e448cf -> 3cab2d63a
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/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 8351cea..8a73055 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
@@ -27,6 +27,7 @@ interface AiravataIf {
public function searchExperimentsByName($userName, $expName);
public function searchExperimentsByDesc($userName, $description);
public function searchExperimentsByApplication($userName, $applicationId);
+ public function searchExperimentsByStatus($userName, $experimentState);
public function getAllExperimentsInProject($projectId);
public function getAllUserExperiments($userName);
public function createExperiment(\Airavata\Model\Workspace\Experiment\Experiment $experiment);
@@ -712,6 +713,67 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("searchExperimentsByApplication failed: unknown result");
}
+ public function searchExperimentsByStatus($userName, $experimentState)
+ {
+ $this->send_searchExperimentsByStatus($userName, $experimentState);
+ return $this->recv_searchExperimentsByStatus();
+ }
+
+ public function send_searchExperimentsByStatus($userName, $experimentState)
+ {
+ $args = new \Airavata\API\Airavata_searchExperimentsByStatus_args();
+ $args->userName = $userName;
+ $args->experimentState = $experimentState;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'searchExperimentsByStatus', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('searchExperimentsByStatus', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_searchExperimentsByStatus()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByStatus_result', $this->input_->isStrictRead());
+ 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_searchExperimentsByStatus_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ throw new \Exception("searchExperimentsByStatus failed: unknown result");
+ }
+
public function getAllExperimentsInProject($projectId)
{
$this->send_getAllExperimentsInProject($projectId);
@@ -6970,6 +7032,264 @@ class Airavata_searchExperimentsByApplication_result {
}
+class Airavata_searchExperimentsByStatus_args {
+ static $_TSPEC;
+
+ public $userName = null;
+ public $experimentState = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'userName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'experimentState',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['userName'])) {
+ $this->userName = $vals['userName'];
+ }
+ if (isset($vals['experimentState'])) {
+ $this->experimentState = $vals['experimentState'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_searchExperimentsByStatus_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->userName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->experimentState);
+ } 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_searchExperimentsByStatus_args');
+ if ($this->userName !== null) {
+ $xfer += $output->writeFieldBegin('userName', TType::STRING, 1);
+ $xfer += $output->writeString($this->userName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->experimentState !== null) {
+ $xfer += $output->writeFieldBegin('experimentState', TType::I32, 2);
+ $xfer += $output->writeI32($this->experimentState);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_searchExperimentsByStatus_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $ire = null;
+ public $ace = null;
+ public $ase = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\Workspace\Experiment\ExperimentSummary',
+ ),
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_searchExperimentsByStatus_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();
+ $_size42 = 0;
+ $_etype45 = 0;
+ $xfer += $input->readListBegin($_etype45, $_size42);
+ for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
+ {
+ $elem47 = null;
+ $elem47 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem47->read($input);
+ $this->success []= $elem47;
+ }
+ $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->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('Airavata_searchExperimentsByStatus_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 $iter48)
+ {
+ $xfer += $iter48->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->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class Airavata_getAllExperimentsInProject_args {
static $_TSPEC;
@@ -7126,15 +7446,15 @@ class Airavata_getAllExperimentsInProject_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size42 = 0;
- $_etype45 = 0;
- $xfer += $input->readListBegin($_etype45, $_size42);
- for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
+ $_size49 = 0;
+ $_etype52 = 0;
+ $xfer += $input->readListBegin($_etype52, $_size49);
+ for ($_i53 = 0; $_i53 < $_size49; ++$_i53)
{
- $elem47 = null;
- $elem47 = new \Airavata\Model\Workspace\Experiment\Experiment();
- $xfer += $elem47->read($input);
- $this->success []= $elem47;
+ $elem54 = null;
+ $elem54 = new \Airavata\Model\Workspace\Experiment\Experiment();
+ $xfer += $elem54->read($input);
+ $this->success []= $elem54;
}
$xfer += $input->readListEnd();
} else {
@@ -7194,9 +7514,9 @@ class Airavata_getAllExperimentsInProject_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter48)
+ foreach ($this->success as $iter55)
{
- $xfer += $iter48->write($output);
+ $xfer += $iter55->write($output);
}
}
$output->writeListEnd();
@@ -7377,15 +7697,15 @@ class Airavata_getAllUserExperiments_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size49 = 0;
- $_etype52 = 0;
- $xfer += $input->readListBegin($_etype52, $_size49);
- for ($_i53 = 0; $_i53 < $_size49; ++$_i53)
+ $_size56 = 0;
+ $_etype59 = 0;
+ $xfer += $input->readListBegin($_etype59, $_size56);
+ for ($_i60 = 0; $_i60 < $_size56; ++$_i60)
{
- $elem54 = null;
- $elem54 = new \Airavata\Model\Workspace\Experiment\Experiment();
- $xfer += $elem54->read($input);
- $this->success []= $elem54;
+ $elem61 = null;
+ $elem61 = new \Airavata\Model\Workspace\Experiment\Experiment();
+ $xfer += $elem61->read($input);
+ $this->success []= $elem61;
}
$xfer += $input->readListEnd();
} else {
@@ -7437,9 +7757,9 @@ class Airavata_getAllUserExperiments_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter55)
+ foreach ($this->success as $iter62)
{
- $xfer += $iter55->write($output);
+ $xfer += $iter62->write($output);
}
}
$output->writeListEnd();
@@ -9294,15 +9614,15 @@ class Airavata_getExperimentOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size56 = 0;
- $_etype59 = 0;
- $xfer += $input->readListBegin($_etype59, $_size56);
- for ($_i60 = 0; $_i60 < $_size56; ++$_i60)
+ $_size63 = 0;
+ $_etype66 = 0;
+ $xfer += $input->readListBegin($_etype66, $_size63);
+ for ($_i67 = 0; $_i67 < $_size63; ++$_i67)
{
- $elem61 = null;
- $elem61 = new \Airavata\Model\Workspace\Experiment\DataObjectType();
- $xfer += $elem61->read($input);
- $this->success []= $elem61;
+ $elem68 = null;
+ $elem68 = new \Airavata\Model\Workspace\Experiment\DataObjectType();
+ $xfer += $elem68->read($input);
+ $this->success []= $elem68;
}
$xfer += $input->readListEnd();
} else {
@@ -9330,9 +9650,9 @@ class Airavata_getExperimentOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter62)
+ foreach ($this->success as $iter69)
{
- $xfer += $iter62->write($output);
+ $xfer += $iter69->write($output);
}
}
$output->writeListEnd();
@@ -9470,18 +9790,18 @@ class Airavata_getJobStatuses_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size63 = 0;
- $_ktype64 = 0;
- $_vtype65 = 0;
- $xfer += $input->readMapBegin($_ktype64, $_vtype65, $_size63);
- for ($_i67 = 0; $_i67 < $_size63; ++$_i67)
+ $_size70 = 0;
+ $_ktype71 = 0;
+ $_vtype72 = 0;
+ $xfer += $input->readMapBegin($_ktype71, $_vtype72, $_size70);
+ for ($_i74 = 0; $_i74 < $_size70; ++$_i74)
{
- $key68 = '';
- $val69 = new \Airavata\Model\Workspace\Experiment\JobStatus();
- $xfer += $input->readString($key68);
- $val69 = new \Airavata\Model\Workspace\Experiment\JobStatus();
- $xfer += $val69->read($input);
- $this->success[$key68] = $val69;
+ $key75 = '';
+ $val76 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $input->readString($key75);
+ $val76 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $val76->read($input);
+ $this->success[$key75] = $val76;
}
$xfer += $input->readMapEnd();
} else {
@@ -9509,10 +9829,10 @@ class Airavata_getJobStatuses_result {
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter70 => $viter71)
+ foreach ($this->success as $kiter77 => $viter78)
{
- $xfer += $output->writeString($kiter70);
- $xfer += $viter71->write($output);
+ $xfer += $output->writeString($kiter77);
+ $xfer += $viter78->write($output);
}
}
$output->writeMapEnd();
@@ -11886,14 +12206,14 @@ class Airavata_getAppModuleDeployedResources_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size72 = 0;
- $_etype75 = 0;
- $xfer += $input->readListBegin($_etype75, $_size72);
- for ($_i76 = 0; $_i76 < $_size72; ++$_i76)
+ $_size79 = 0;
+ $_etype82 = 0;
+ $xfer += $input->readListBegin($_etype82, $_size79);
+ for ($_i83 = 0; $_i83 < $_size79; ++$_i83)
{
- $elem77 = null;
- $xfer += $input->readString($elem77);
- $this->success []= $elem77;
+ $elem84 = null;
+ $xfer += $input->readString($elem84);
+ $this->success []= $elem84;
}
$xfer += $input->readListEnd();
} else {
@@ -11945,9 +12265,9 @@ class Airavata_getAppModuleDeployedResources_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter78)
+ foreach ($this->success as $iter85)
{
- $xfer += $output->writeString($iter78);
+ $xfer += $output->writeString($iter85);
}
}
$output->writeListEnd();
@@ -12979,17 +13299,17 @@ class Airavata_getAllApplicationInterfaceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size79 = 0;
- $_ktype80 = 0;
- $_vtype81 = 0;
- $xfer += $input->readMapBegin($_ktype80, $_vtype81, $_size79);
- for ($_i83 = 0; $_i83 < $_size79; ++$_i83)
+ $_size86 = 0;
+ $_ktype87 = 0;
+ $_vtype88 = 0;
+ $xfer += $input->readMapBegin($_ktype87, $_vtype88, $_size86);
+ for ($_i90 = 0; $_i90 < $_size86; ++$_i90)
{
- $key84 = '';
- $val85 = '';
- $xfer += $input->readString($key84);
- $xfer += $input->readString($val85);
- $this->success[$key84] = $val85;
+ $key91 = '';
+ $val92 = '';
+ $xfer += $input->readString($key91);
+ $xfer += $input->readString($val92);
+ $this->success[$key91] = $val92;
}
$xfer += $input->readMapEnd();
} else {
@@ -13041,10 +13361,10 @@ class Airavata_getAllApplicationInterfaceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter86 => $viter87)
+ foreach ($this->success as $kiter93 => $viter94)
{
- $xfer += $output->writeString($kiter86);
- $xfer += $output->writeString($viter87);
+ $xfer += $output->writeString($kiter93);
+ $xfer += $output->writeString($viter94);
}
}
$output->writeMapEnd();
@@ -13198,15 +13518,15 @@ class Airavata_getAllApplicationInterfaces_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size88 = 0;
- $_etype91 = 0;
- $xfer += $input->readListBegin($_etype91, $_size88);
- for ($_i92 = 0; $_i92 < $_size88; ++$_i92)
+ $_size95 = 0;
+ $_etype98 = 0;
+ $xfer += $input->readListBegin($_etype98, $_size95);
+ for ($_i99 = 0; $_i99 < $_size95; ++$_i99)
{
- $elem93 = null;
- $elem93 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
- $xfer += $elem93->read($input);
- $this->success []= $elem93;
+ $elem100 = null;
+ $elem100 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
+ $xfer += $elem100->read($input);
+ $this->success []= $elem100;
}
$xfer += $input->readListEnd();
} else {
@@ -13258,9 +13578,9 @@ class Airavata_getAllApplicationInterfaces_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter94)
+ foreach ($this->success as $iter101)
{
- $xfer += $iter94->write($output);
+ $xfer += $iter101->write($output);
}
}
$output->writeListEnd();
@@ -13436,15 +13756,15 @@ class Airavata_getApplicationInputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size95 = 0;
- $_etype98 = 0;
- $xfer += $input->readListBegin($_etype98, $_size95);
- for ($_i99 = 0; $_i99 < $_size95; ++$_i99)
+ $_size102 = 0;
+ $_etype105 = 0;
+ $xfer += $input->readListBegin($_etype105, $_size102);
+ for ($_i106 = 0; $_i106 < $_size102; ++$_i106)
{
- $elem100 = null;
- $elem100 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
- $xfer += $elem100->read($input);
- $this->success []= $elem100;
+ $elem107 = null;
+ $elem107 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
+ $xfer += $elem107->read($input);
+ $this->success []= $elem107;
}
$xfer += $input->readListEnd();
} else {
@@ -13496,9 +13816,9 @@ class Airavata_getApplicationInputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter101)
+ foreach ($this->success as $iter108)
{
- $xfer += $iter101->write($output);
+ $xfer += $iter108->write($output);
}
}
$output->writeListEnd();
@@ -13674,15 +13994,15 @@ class Airavata_getApplicationOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size102 = 0;
- $_etype105 = 0;
- $xfer += $input->readListBegin($_etype105, $_size102);
- for ($_i106 = 0; $_i106 < $_size102; ++$_i106)
+ $_size109 = 0;
+ $_etype112 = 0;
+ $xfer += $input->readListBegin($_etype112, $_size109);
+ for ($_i113 = 0; $_i113 < $_size109; ++$_i113)
{
- $elem107 = null;
- $elem107 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
- $xfer += $elem107->read($input);
- $this->success []= $elem107;
+ $elem114 = null;
+ $elem114 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem114->read($input);
+ $this->success []= $elem114;
}
$xfer += $input->readListEnd();
} else {
@@ -13734,9 +14054,9 @@ class Airavata_getApplicationOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter108)
+ foreach ($this->success as $iter115)
{
- $xfer += $iter108->write($output);
+ $xfer += $iter115->write($output);
}
}
$output->writeListEnd();
@@ -13915,17 +14235,17 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size109 = 0;
- $_ktype110 = 0;
- $_vtype111 = 0;
- $xfer += $input->readMapBegin($_ktype110, $_vtype111, $_size109);
- for ($_i113 = 0; $_i113 < $_size109; ++$_i113)
+ $_size116 = 0;
+ $_ktype117 = 0;
+ $_vtype118 = 0;
+ $xfer += $input->readMapBegin($_ktype117, $_vtype118, $_size116);
+ for ($_i120 = 0; $_i120 < $_size116; ++$_i120)
{
- $key114 = '';
- $val115 = '';
- $xfer += $input->readString($key114);
- $xfer += $input->readString($val115);
- $this->success[$key114] = $val115;
+ $key121 = '';
+ $val122 = '';
+ $xfer += $input->readString($key121);
+ $xfer += $input->readString($val122);
+ $this->success[$key121] = $val122;
}
$xfer += $input->readMapEnd();
} else {
@@ -13977,10 +14297,10 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter116 => $viter117)
+ foreach ($this->success as $kiter123 => $viter124)
{
- $xfer += $output->writeString($kiter116);
- $xfer += $output->writeString($viter117);
+ $xfer += $output->writeString($kiter123);
+ $xfer += $output->writeString($viter124);
}
}
$output->writeMapEnd();
@@ -14567,17 +14887,17 @@ class Airavata_getAllComputeResourceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size118 = 0;
- $_ktype119 = 0;
- $_vtype120 = 0;
- $xfer += $input->readMapBegin($_ktype119, $_vtype120, $_size118);
- for ($_i122 = 0; $_i122 < $_size118; ++$_i122)
+ $_size125 = 0;
+ $_ktype126 = 0;
+ $_vtype127 = 0;
+ $xfer += $input->readMapBegin($_ktype126, $_vtype127, $_size125);
+ for ($_i129 = 0; $_i129 < $_size125; ++$_i129)
{
- $key123 = '';
- $val124 = '';
- $xfer += $input->readString($key123);
- $xfer += $input->readString($val124);
- $this->success[$key123] = $val124;
+ $key130 = '';
+ $val131 = '';
+ $xfer += $input->readString($key130);
+ $xfer += $input->readString($val131);
+ $this->success[$key130] = $val131;
}
$xfer += $input->readMapEnd();
} else {
@@ -14629,10 +14949,10 @@ class Airavata_getAllComputeResourceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter125 => $viter126)
+ foreach ($this->success as $kiter132 => $viter133)
{
- $xfer += $output->writeString($kiter125);
- $xfer += $output->writeString($viter126);
+ $xfer += $output->writeString($kiter132);
+ $xfer += $output->writeString($viter133);
}
}
$output->writeMapEnd();
@@ -18557,17 +18877,17 @@ class Airavata_changeJobSubmissionPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->jobSubmissionPriorityMap = array();
- $_size127 = 0;
- $_ktype128 = 0;
- $_vtype129 = 0;
- $xfer += $input->readMapBegin($_ktype128, $_vtype129, $_size127);
- for ($_i131 = 0; $_i131 < $_size127; ++$_i131)
+ $_size134 = 0;
+ $_ktype135 = 0;
+ $_vtype136 = 0;
+ $xfer += $input->readMapBegin($_ktype135, $_vtype136, $_size134);
+ for ($_i138 = 0; $_i138 < $_size134; ++$_i138)
{
- $key132 = '';
- $val133 = 0;
- $xfer += $input->readString($key132);
- $xfer += $input->readI32($val133);
- $this->jobSubmissionPriorityMap[$key132] = $val133;
+ $key139 = '';
+ $val140 = 0;
+ $xfer += $input->readString($key139);
+ $xfer += $input->readI32($val140);
+ $this->jobSubmissionPriorityMap[$key139] = $val140;
}
$xfer += $input->readMapEnd();
} else {
@@ -18595,10 +18915,10 @@ class Airavata_changeJobSubmissionPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionPriorityMap));
{
- foreach ($this->jobSubmissionPriorityMap as $kiter134 => $viter135)
+ foreach ($this->jobSubmissionPriorityMap as $kiter141 => $viter142)
{
- $xfer += $output->writeString($kiter134);
- $xfer += $output->writeI32($viter135);
+ $xfer += $output->writeString($kiter141);
+ $xfer += $output->writeI32($viter142);
}
}
$output->writeMapEnd();
@@ -18801,17 +19121,17 @@ class Airavata_changeDataMovementPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->dataMovementPriorityMap = array();
- $_size136 = 0;
- $_ktype137 = 0;
- $_vtype138 = 0;
- $xfer += $input->readMapBegin($_ktype137, $_vtype138, $_size136);
- for ($_i140 = 0; $_i140 < $_size136; ++$_i140)
+ $_size143 = 0;
+ $_ktype144 = 0;
+ $_vtype145 = 0;
+ $xfer += $input->readMapBegin($_ktype144, $_vtype145, $_size143);
+ for ($_i147 = 0; $_i147 < $_size143; ++$_i147)
{
- $key141 = '';
- $val142 = 0;
- $xfer += $input->readString($key141);
- $xfer += $input->readI32($val142);
- $this->dataMovementPriorityMap[$key141] = $val142;
+ $key148 = '';
+ $val149 = 0;
+ $xfer += $input->readString($key148);
+ $xfer += $input->readI32($val149);
+ $this->dataMovementPriorityMap[$key148] = $val149;
}
$xfer += $input->readMapEnd();
} else {
@@ -18839,10 +19159,10 @@ class Airavata_changeDataMovementPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementPriorityMap));
{
- foreach ($this->dataMovementPriorityMap as $kiter143 => $viter144)
+ foreach ($this->dataMovementPriorityMap as $kiter150 => $viter151)
{
- $xfer += $output->writeString($kiter143);
- $xfer += $output->writeI32($viter144);
+ $xfer += $output->writeString($kiter150);
+ $xfer += $output->writeI32($viter151);
}
}
$output->writeMapEnd();
@@ -20926,15 +21246,15 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size145 = 0;
- $_etype148 = 0;
- $xfer += $input->readListBegin($_etype148, $_size145);
- for ($_i149 = 0; $_i149 < $_size145; ++$_i149)
+ $_size152 = 0;
+ $_etype155 = 0;
+ $xfer += $input->readListBegin($_etype155, $_size152);
+ for ($_i156 = 0; $_i156 < $_size152; ++$_i156)
{
- $elem150 = null;
- $elem150 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
- $xfer += $elem150->read($input);
- $this->success []= $elem150;
+ $elem157 = null;
+ $elem157 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $elem157->read($input);
+ $this->success []= $elem157;
}
$xfer += $input->readListEnd();
} else {
@@ -20986,9 +21306,9 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter151)
+ foreach ($this->success as $iter158)
{
- $xfer += $iter151->write($output);
+ $xfer += $iter158->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
index f0c932d..4317ce0 100644
--- a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
+++ b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
@@ -62,10 +62,10 @@ public class CreateLaunchExperiment {
private static final String DEFAULT_USER = "default.registry.user";
private static final String DEFAULT_GATEWAY = "default.registry.gateway";
private static Airavata.Client client;
- private static String localHostAppId = "localhost_33e36776-9e85-4a59-996c-9f558c2693fa,SimpleEcho0_e04db7e1-6984-46a5-9046-639bb827886b";
+ private static String localHostAppId = "localhost_3b5962d3-5e7e-4a97-9d1f-25c5ec436ba5,SimpleEcho0_44c34394-ca27-4fa9-bb2d-87f95a02352a";
private static String sshHostAppId;
- private static String pbsEchoAppId = "trestles.sdsc.edu_3380f118-a66e-44f2-9e35-341db37b8cb5,SimpleEcho2_3cdaae1e-d4cc-40f6-a0fc-de1aca14b316";
- private static String pbsWRFAppId = "trestles.sdsc.edu_03d239f1-b923-487a-9aa4-fcc7aed8628e,WRF_a5a7372d-2c59-4986-8351-eac563b53f89";
+ private static String pbsEchoAppId = "trestles.sdsc.edu_6dc7de3d-0d18-4933-bd96-b40c425f44c5,SimpleEcho2_8cc763c9-c57c-4a23-890c-4d3cee413c68";
+ private static String pbsWRFAppId = "trestles.sdsc.edu_6ba292ab-573b-4b48-b72d-8006c8ced713,WRF_73b3356e-0596-4542-80b7-9048d9103cef";
private static String slurmAppId = "stampede.tacc.xsede.org_b2ef59cb-f626-4767-9ca0-601f94c42ba4,SimpleEcho3_b81c2559-a088-42a3-84ce-40119d874918";
private static String sgeAppId;
private static String br2EchoAppId = "bigred2_9c1e6be8-f7d8-4494-98f2-bf508790e8c6,SimpleEchoBR_149fd613-98e2-46e7-ac7c-4d393349469e";
@@ -85,11 +85,11 @@ public class CreateLaunchExperiment {
// addDescriptors();
//// final String expId = createExperimentForSSHHost(airavata);
- final String expId = createExperimentForTrestles(client);
+// final String expId = createExperimentForTrestles(client);
//// final String expId = createExperimentForStampede(client);
// final String expId = createExperimentForLocalHost(client);
// final String expId = createExperimentForLonestar(airavata);
-// final String expId = createExperimentWRFTrestles(client);
+ final String expId = createExperimentWRFTrestles(client);
// final String expId = createExperimentForBR2(client);
// final String expId = createExperimentForBR2Amber(client);
// final String expId = createExperimentWRFStampede(client);
@@ -253,17 +253,17 @@ public class CreateLaunchExperiment {
DataObjectType input = new DataObjectType();
input.setKey("WRF_Namelist");
input.setType(DataType.URI);
- input.setValue("/Users/chathuri/Downloads/wrf_sample_inputs/namelist1.input");
+ input.setValue("/Users/chathuri/Downloads/wrf_sample_inputs/namelist.input");
DataObjectType input1 = new DataObjectType();
input1.setKey("WRF_Input_File");
input1.setType(DataType.URI);
- input1.setValue("/Users/chathuri/Downloads/wrf_sample_inputs/wrfinput1_d01");
+ input1.setValue("/Users/chathuri/Downloads/wrf_sample_inputs/wrfinput_d01");
DataObjectType input2 = new DataObjectType();
input2.setKey("WRF_Boundary_File");
input2.setType(DataType.URI);
- input2.setValue("/Users/chathuri/Downloads/wrf_sample_inputs/wrfbdy_d011");
+ input2.setValue("/Users/chathuri/Downloads/wrf_sample_inputs/wrfbdy_d01");
exInputs.add(input);
exInputs.add(input1);
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/TestCreateLaunchExperiment.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/TestCreateLaunchExperiment.java b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/TestCreateLaunchExperiment.java
index f5612aa..7cfb504 100644
--- a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/TestCreateLaunchExperiment.java
+++ b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/TestCreateLaunchExperiment.java
@@ -52,8 +52,8 @@ import java.util.*;
public class TestCreateLaunchExperiment {
//FIXME: Read from a config file
- public static final String THRIFT_SERVER_HOST = "gw111.iu.xsede.org";
- public static final int THRIFT_SERVER_PORT = 9930;
+ public static final String THRIFT_SERVER_HOST = "localhost";
+ public static final int THRIFT_SERVER_PORT = 8930;
private final static Logger logger = LoggerFactory.getLogger(TestCreateLaunchExperiment.class);
private static final String DEFAULT_USER = "default.registry.user";
private static final String DEFAULT_GATEWAY = "default.registry.gateway";
@@ -63,8 +63,13 @@ public class TestCreateLaunchExperiment {
AiravataUtils.setExecutionAsClient();
final Airavata.Client airavata = AiravataClientFactory.createAiravataClient(THRIFT_SERVER_HOST, THRIFT_SERVER_PORT);
System.out.println("API version is " + airavata.getAPIVersion());
- getAllComputeResources(airavata);
- getAppModule(airavata, "amber_c476de64-ca5c-415a-94e9-b77fbe67b806");
+ List<ExperimentSummary> experiments = searchExperimentsByStatus(airavata, "admin", ExperimentState.FAILED);
+ for (ExperimentSummary experimentSummary : experiments){
+ System.out.println(experimentSummary.getExperimentID());
+ System.out.println(experimentSummary.getExperimentStatus().getExperimentState().toString());
+ }
+// getAllComputeResources(airavata);
+// getAppModule(airavata, "amber_c476de64-ca5c-415a-94e9-b77fbe67b806");
// getAVailableComputeResourcesForApp(airavata, "Amber_0cecdf39-1ce2-4d98-bc76-87447e10fd4d");
// for (int i = 0; i < 10 ; i++){
// long time = System.currentTimeMillis();
@@ -132,6 +137,21 @@ public class TestCreateLaunchExperiment {
return null;
}
+ public static List<ExperimentSummary> searchExperimentsByStatus (Airavata.Client client, String user, ExperimentState experimentState){
+ try {
+ return client.searchExperimentsByStatus(user, experimentState);
+ } catch (AiravataSystemException e) {
+ e.printStackTrace();
+ } catch (InvalidRequestException e) {
+ e.printStackTrace();
+ } catch (AiravataClientException e) {
+ e.printStackTrace();
+ }catch (TException e){
+ e.printStackTrace();
+ }
+ return null;
+ }
+
public static void getAllComputeResources (Airavata.Client client){
try {
Map<String, String> allComputeResourceNames = client.getAllComputeResourceNames();
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/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 f71d6d1..441d1eb 100644
--- a/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
+++ b/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
@@ -156,6 +156,15 @@ service Airavata {
3: airavataErrors.AiravataSystemException ase)
/**
+ * Search Experiments by experiment status
+ *
+ */
+ list<experimentModel.ExperimentSummary> searchExperimentsByStatus (1: required string userName, 2: required experimentModel.ExperimentState experimentState)
+ throws (1: airavataErrors.InvalidRequestException ire,
+ 2: airavataErrors.AiravataClientException ace,
+ 3: airavataErrors.AiravataSystemException ase)
+
+ /**
* Get all Experiments within a Project
*
*/
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/impl/ExperimentRegistry.java
----------------------------------------------------------------------
diff --git a/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/impl/ExperimentRegistry.java b/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/impl/ExperimentRegistry.java
index 30838b5..f6968ae 100644
--- a/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/impl/ExperimentRegistry.java
+++ b/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/impl/ExperimentRegistry.java
@@ -2645,8 +2645,8 @@ public class ExperimentRegistry {
fil.put(AbstractResource.ExperimentConstants.EXECUTION_USER, filters.get(field));
}else if (field.equals(Constants.FieldConstants.ExperimentConstants.EXPERIMENT_DESC)){
fil.put(AbstractResource.ExperimentConstants.DESCRIPTION, filters.get(field));
- }else if (field.equals(Constants.FieldConstants.ExperimentConstants.APPLICATION_ID)){
- fil.put(AbstractResource.ExperimentConstants.APPLICATION_ID, filters.get(field));
+ }else if (field.equals(Constants.FieldConstants.ExperimentConstants.EXPERIMENT_STATUS)){
+ return searchExperimentsByStatus(ExperimentState.valueOf(filters.get(field)));
}
}
List<ExperimentResource> experimentResources = workerResource.searchExperiments(fil);
@@ -2665,4 +2665,21 @@ public class ExperimentRegistry {
return null;
}
+ public List<ExperimentSummary> searchExperimentsByStatus (ExperimentState experimentState) throws RegistryException {
+ try {
+ List<ExperimentSummary> experimentSummaries = new ArrayList<ExperimentSummary>();
+ List<ExperimentResource> experimentResources = workerResource.searchExperimentsByState(experimentState.toString());
+ if (experimentResources != null && !experimentResources.isEmpty()) {
+ for (ExperimentResource ex : experimentResources) {
+ experimentSummaries.add(ThriftDataModelConversion.getExperimentSummary(ex));
+ }
+ }
+ return experimentSummaries;
+
+ } catch (Exception e) {
+ logger.error("Error while retrieving experiment summary from registry", e);
+ throw new RegistryException(e);
+ }
+ }
+
}
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/WorkerResource.java
----------------------------------------------------------------------
diff --git a/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/WorkerResource.java b/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/WorkerResource.java
index a044d66..d9790c0 100644
--- a/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/WorkerResource.java
+++ b/modules/registry/airavata-jpa-registry/src/main/java/org/apache/airavata/persistance/registry/jpa/resources/WorkerResource.java
@@ -26,6 +26,7 @@ import org.apache.airavata.persistance.registry.jpa.ResourceType;
import org.apache.airavata.persistance.registry.jpa.ResourceUtils;
import org.apache.airavata.persistance.registry.jpa.model.*;
import org.apache.airavata.persistance.registry.jpa.utils.QueryGenerator;
+import org.apache.airavata.registry.cpi.utils.StatusType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.airavata.registry.cpi.RegistryException;
@@ -621,6 +622,39 @@ public class WorkerResource extends AbstractResource {
return result;
}
+ public List<ExperimentResource> searchExperimentsByState (String experimentState) throws RegistryException{
+ List<ExperimentResource> result = new ArrayList<ExperimentResource>();
+ EntityManager em = null;
+ try {
+ String query = "SELECT e FROM Status s " +
+ "JOIN s.experiment e " +
+ "WHERE s.state='" + experimentState + "' " +
+ "AND s.statusType='" + StatusType.EXPERIMENT + "'";
+ em = ResourceUtils.getEntityManager();
+ em.getTransaction().begin();
+ Query q = em.createQuery(query);
+ List resultList = q.getResultList();
+ for (Object o : resultList) {
+ Experiment experiment = (Experiment) o;
+ ExperimentResource experimentResource = (ExperimentResource) Utils.getResource(ResourceType.EXPERIMENT, experiment);
+ result.add(experimentResource);
+ }
+ em.getTransaction().commit();
+ em.close();
+ } catch (Exception e) {
+ logger.error(e.getMessage(), e);
+ throw new RegistryException(e);
+ } finally {
+ if (em != null && em.isOpen()) {
+ if (em.getTransaction().isActive()){
+ em.getTransaction().rollback();
+ }
+ em.close();
+ }
+ }
+ return result;
+ }
+
/**
*
* @return list of experiments for the user
[2/4] fixing AIRAVATA-1360
Posted by ch...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/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 ab65b1e..6aac2e5 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
@@ -2577,6 +2577,284 @@ uint32_t Airavata_searchExperimentsByApplication_presult::read(::apache::thrift:
return xfer;
}
+uint32_t Airavata_searchExperimentsByStatus_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_userName = false;
+ bool isset_experimentState = 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->userName);
+ isset_userName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_I32) {
+ int32_t ecast66;
+ xfer += iprot->readI32(ecast66);
+ this->experimentState = ( ::apache::airavata::model::workspace::experiment::ExperimentState::type)ecast66;
+ isset_experimentState = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_userName)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_experimentState)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByStatus_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchExperimentsByStatus_args");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->userName);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("experimentState", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)this->experimentState);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByStatus_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchExperimentsByStatus_pargs");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->userName)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("experimentState", ::apache::thrift::protocol::T_I32, 2);
+ xfer += oprot->writeI32((int32_t)(*(this->experimentState)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByStatus_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 _size67;
+ ::apache::thrift::protocol::TType _etype70;
+ xfer += iprot->readListBegin(_etype70, _size67);
+ this->success.resize(_size67);
+ uint32_t _i71;
+ for (_i71 = 0; _i71 < _size67; ++_i71)
+ {
+ xfer += this->success[_i71].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->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ 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_searchExperimentsByStatus_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_searchExperimentsByStatus_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::workspace::experiment::ExperimentSummary> ::const_iterator _iter72;
+ for (_iter72 = this->success.begin(); _iter72 != this->success.end(); ++_iter72)
+ {
+ xfer += (*_iter72).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.ace) {
+ xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->ace.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ } else if (this->__isset.ase) {
+ xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += this->ase.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByStatus_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 _size73;
+ ::apache::thrift::protocol::TType _etype76;
+ xfer += iprot->readListBegin(_etype76, _size73);
+ (*(this->success)).resize(_size73);
+ uint32_t _i77;
+ for (_i77 = 0; _i77 < _size73; ++_i77)
+ {
+ xfer += (*(this->success))[_i77].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->ace.read(iprot);
+ this->__isset.ace = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ 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_getAllExperimentsInProject_args::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
@@ -2670,14 +2948,14 @@ uint32_t Airavata_getAllExperimentsInProject_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size66;
- ::apache::thrift::protocol::TType _etype69;
- xfer += iprot->readListBegin(_etype69, _size66);
- this->success.resize(_size66);
- uint32_t _i70;
- for (_i70 = 0; _i70 < _size66; ++_i70)
+ uint32_t _size78;
+ ::apache::thrift::protocol::TType _etype81;
+ xfer += iprot->readListBegin(_etype81, _size78);
+ this->success.resize(_size78);
+ uint32_t _i82;
+ for (_i82 = 0; _i82 < _size78; ++_i82)
{
- xfer += this->success[_i70].read(iprot);
+ xfer += this->success[_i82].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -2740,10 +3018,10 @@ uint32_t Airavata_getAllExperimentsInProject_result::write(::apache::thrift::pro
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::Experiment> ::const_iterator _iter71;
- for (_iter71 = this->success.begin(); _iter71 != this->success.end(); ++_iter71)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter83;
+ for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83)
{
- xfer += (*_iter71).write(oprot);
+ xfer += (*_iter83).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2794,14 +3072,14 @@ uint32_t Airavata_getAllExperimentsInProject_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size72;
- ::apache::thrift::protocol::TType _etype75;
- xfer += iprot->readListBegin(_etype75, _size72);
- (*(this->success)).resize(_size72);
- uint32_t _i76;
- for (_i76 = 0; _i76 < _size72; ++_i76)
+ uint32_t _size84;
+ ::apache::thrift::protocol::TType _etype87;
+ xfer += iprot->readListBegin(_etype87, _size84);
+ (*(this->success)).resize(_size84);
+ uint32_t _i88;
+ for (_i88 = 0; _i88 < _size84; ++_i88)
{
- xfer += (*(this->success))[_i76].read(iprot);
+ xfer += (*(this->success))[_i88].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -2947,14 +3225,14 @@ uint32_t Airavata_getAllUserExperiments_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size77;
- ::apache::thrift::protocol::TType _etype80;
- xfer += iprot->readListBegin(_etype80, _size77);
- this->success.resize(_size77);
- uint32_t _i81;
- for (_i81 = 0; _i81 < _size77; ++_i81)
+ uint32_t _size89;
+ ::apache::thrift::protocol::TType _etype92;
+ xfer += iprot->readListBegin(_etype92, _size89);
+ this->success.resize(_size89);
+ uint32_t _i93;
+ for (_i93 = 0; _i93 < _size89; ++_i93)
{
- xfer += this->success[_i81].read(iprot);
+ xfer += this->success[_i93].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3009,10 +3287,10 @@ uint32_t Airavata_getAllUserExperiments_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::workspace::experiment::Experiment> ::const_iterator _iter82;
- for (_iter82 = this->success.begin(); _iter82 != this->success.end(); ++_iter82)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter94;
+ for (_iter94 = this->success.begin(); _iter94 != this->success.end(); ++_iter94)
{
- xfer += (*_iter82).write(oprot);
+ xfer += (*_iter94).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3059,14 +3337,14 @@ uint32_t Airavata_getAllUserExperiments_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size83;
- ::apache::thrift::protocol::TType _etype86;
- xfer += iprot->readListBegin(_etype86, _size83);
- (*(this->success)).resize(_size83);
- uint32_t _i87;
- for (_i87 = 0; _i87 < _size83; ++_i87)
+ uint32_t _size95;
+ ::apache::thrift::protocol::TType _etype98;
+ xfer += iprot->readListBegin(_etype98, _size95);
+ (*(this->success)).resize(_size95);
+ uint32_t _i99;
+ for (_i99 = 0; _i99 < _size95; ++_i99)
{
- xfer += (*(this->success))[_i87].read(iprot);
+ xfer += (*(this->success))[_i99].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -4978,14 +5256,14 @@ uint32_t Airavata_getExperimentOutputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size88;
- ::apache::thrift::protocol::TType _etype91;
- xfer += iprot->readListBegin(_etype91, _size88);
- this->success.resize(_size88);
- uint32_t _i92;
- for (_i92 = 0; _i92 < _size88; ++_i92)
+ uint32_t _size100;
+ ::apache::thrift::protocol::TType _etype103;
+ xfer += iprot->readListBegin(_etype103, _size100);
+ this->success.resize(_size100);
+ uint32_t _i104;
+ for (_i104 = 0; _i104 < _size100; ++_i104)
{
- xfer += this->success[_i92].read(iprot);
+ xfer += this->success[_i104].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -5016,10 +5294,10 @@ uint32_t Airavata_getExperimentOutputs_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::workspace::experiment::DataObjectType> ::const_iterator _iter93;
- for (_iter93 = this->success.begin(); _iter93 != this->success.end(); ++_iter93)
+ std::vector< ::apache::airavata::model::workspace::experiment::DataObjectType> ::const_iterator _iter105;
+ for (_iter105 = this->success.begin(); _iter105 != this->success.end(); ++_iter105)
{
- xfer += (*_iter93).write(oprot);
+ xfer += (*_iter105).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -5054,14 +5332,14 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size94;
- ::apache::thrift::protocol::TType _etype97;
- xfer += iprot->readListBegin(_etype97, _size94);
- (*(this->success)).resize(_size94);
- uint32_t _i98;
- for (_i98 = 0; _i98 < _size94; ++_i98)
+ uint32_t _size106;
+ ::apache::thrift::protocol::TType _etype109;
+ xfer += iprot->readListBegin(_etype109, _size106);
+ (*(this->success)).resize(_size106);
+ uint32_t _i110;
+ for (_i110 = 0; _i110 < _size106; ++_i110)
{
- xfer += (*(this->success))[_i98].read(iprot);
+ xfer += (*(this->success))[_i110].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -5175,17 +5453,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size99;
- ::apache::thrift::protocol::TType _ktype100;
- ::apache::thrift::protocol::TType _vtype101;
- xfer += iprot->readMapBegin(_ktype100, _vtype101, _size99);
- uint32_t _i103;
- for (_i103 = 0; _i103 < _size99; ++_i103)
+ uint32_t _size111;
+ ::apache::thrift::protocol::TType _ktype112;
+ ::apache::thrift::protocol::TType _vtype113;
+ xfer += iprot->readMapBegin(_ktype112, _vtype113, _size111);
+ uint32_t _i115;
+ for (_i115 = 0; _i115 < _size111; ++_i115)
{
- std::string _key104;
- xfer += iprot->readString(_key104);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val105 = this->success[_key104];
- xfer += _val105.read(iprot);
+ std::string _key116;
+ xfer += iprot->readString(_key116);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val117 = this->success[_key116];
+ xfer += _val117.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -5216,11 +5494,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 _iter106;
- for (_iter106 = this->success.begin(); _iter106 != this->success.end(); ++_iter106)
+ std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter118;
+ for (_iter118 = this->success.begin(); _iter118 != this->success.end(); ++_iter118)
{
- xfer += oprot->writeString(_iter106->first);
- xfer += _iter106->second.write(oprot);
+ xfer += oprot->writeString(_iter118->first);
+ xfer += _iter118->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -5255,17 +5533,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size107;
- ::apache::thrift::protocol::TType _ktype108;
- ::apache::thrift::protocol::TType _vtype109;
- xfer += iprot->readMapBegin(_ktype108, _vtype109, _size107);
- uint32_t _i111;
- for (_i111 = 0; _i111 < _size107; ++_i111)
+ uint32_t _size119;
+ ::apache::thrift::protocol::TType _ktype120;
+ ::apache::thrift::protocol::TType _vtype121;
+ xfer += iprot->readMapBegin(_ktype120, _vtype121, _size119);
+ uint32_t _i123;
+ for (_i123 = 0; _i123 < _size119; ++_i123)
{
- std::string _key112;
- xfer += iprot->readString(_key112);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val113 = (*(this->success))[_key112];
- xfer += _val113.read(iprot);
+ std::string _key124;
+ xfer += iprot->readString(_key124);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val125 = (*(this->success))[_key124];
+ xfer += _val125.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -7697,14 +7975,14 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size114;
- ::apache::thrift::protocol::TType _etype117;
- xfer += iprot->readListBegin(_etype117, _size114);
- this->success.resize(_size114);
- uint32_t _i118;
- for (_i118 = 0; _i118 < _size114; ++_i118)
+ uint32_t _size126;
+ ::apache::thrift::protocol::TType _etype129;
+ xfer += iprot->readListBegin(_etype129, _size126);
+ this->success.resize(_size126);
+ uint32_t _i130;
+ for (_i130 = 0; _i130 < _size126; ++_i130)
{
- xfer += iprot->readString(this->success[_i118]);
+ xfer += iprot->readString(this->success[_i130]);
}
xfer += iprot->readListEnd();
}
@@ -7759,10 +8037,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 _iter119;
- for (_iter119 = this->success.begin(); _iter119 != this->success.end(); ++_iter119)
+ std::vector<std::string> ::const_iterator _iter131;
+ for (_iter131 = this->success.begin(); _iter131 != this->success.end(); ++_iter131)
{
- xfer += oprot->writeString((*_iter119));
+ xfer += oprot->writeString((*_iter131));
}
xfer += oprot->writeListEnd();
}
@@ -7809,14 +8087,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size120;
- ::apache::thrift::protocol::TType _etype123;
- xfer += iprot->readListBegin(_etype123, _size120);
- (*(this->success)).resize(_size120);
- uint32_t _i124;
- for (_i124 = 0; _i124 < _size120; ++_i124)
+ uint32_t _size132;
+ ::apache::thrift::protocol::TType _etype135;
+ xfer += iprot->readListBegin(_etype135, _size132);
+ (*(this->success)).resize(_size132);
+ uint32_t _i136;
+ for (_i136 = 0; _i136 < _size132; ++_i136)
{
- xfer += iprot->readString((*(this->success))[_i124]);
+ xfer += iprot->readString((*(this->success))[_i136]);
}
xfer += iprot->readListEnd();
}
@@ -8849,17 +9127,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size125;
- ::apache::thrift::protocol::TType _ktype126;
- ::apache::thrift::protocol::TType _vtype127;
- xfer += iprot->readMapBegin(_ktype126, _vtype127, _size125);
- uint32_t _i129;
- for (_i129 = 0; _i129 < _size125; ++_i129)
+ uint32_t _size137;
+ ::apache::thrift::protocol::TType _ktype138;
+ ::apache::thrift::protocol::TType _vtype139;
+ xfer += iprot->readMapBegin(_ktype138, _vtype139, _size137);
+ uint32_t _i141;
+ for (_i141 = 0; _i141 < _size137; ++_i141)
{
- std::string _key130;
- xfer += iprot->readString(_key130);
- std::string& _val131 = this->success[_key130];
- xfer += iprot->readString(_val131);
+ std::string _key142;
+ xfer += iprot->readString(_key142);
+ std::string& _val143 = this->success[_key142];
+ xfer += iprot->readString(_val143);
}
xfer += iprot->readMapEnd();
}
@@ -8914,11 +9192,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 _iter132;
- for (_iter132 = this->success.begin(); _iter132 != this->success.end(); ++_iter132)
+ std::map<std::string, std::string> ::const_iterator _iter144;
+ for (_iter144 = this->success.begin(); _iter144 != this->success.end(); ++_iter144)
{
- xfer += oprot->writeString(_iter132->first);
- xfer += oprot->writeString(_iter132->second);
+ xfer += oprot->writeString(_iter144->first);
+ xfer += oprot->writeString(_iter144->second);
}
xfer += oprot->writeMapEnd();
}
@@ -8965,17 +9243,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift
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 _size145;
+ ::apache::thrift::protocol::TType _ktype146;
+ ::apache::thrift::protocol::TType _vtype147;
+ xfer += iprot->readMapBegin(_ktype146, _vtype147, _size145);
+ uint32_t _i149;
+ for (_i149 = 0; _i149 < _size145; ++_i149)
{
- std::string _key138;
- xfer += iprot->readString(_key138);
- std::string& _val139 = (*(this->success))[_key138];
- xfer += iprot->readString(_val139);
+ std::string _key150;
+ xfer += iprot->readString(_key150);
+ std::string& _val151 = (*(this->success))[_key150];
+ xfer += iprot->readString(_val151);
}
xfer += iprot->readMapEnd();
}
@@ -9089,14 +9367,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size140;
- ::apache::thrift::protocol::TType _etype143;
- xfer += iprot->readListBegin(_etype143, _size140);
- this->success.resize(_size140);
- uint32_t _i144;
- for (_i144 = 0; _i144 < _size140; ++_i144)
+ uint32_t _size152;
+ ::apache::thrift::protocol::TType _etype155;
+ xfer += iprot->readListBegin(_etype155, _size152);
+ this->success.resize(_size152);
+ uint32_t _i156;
+ for (_i156 = 0; _i156 < _size152; ++_i156)
{
- xfer += this->success[_i144].read(iprot);
+ xfer += this->success[_i156].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9151,10 +9429,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 _iter145;
- for (_iter145 = this->success.begin(); _iter145 != this->success.end(); ++_iter145)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter157;
+ for (_iter157 = this->success.begin(); _iter157 != this->success.end(); ++_iter157)
{
- xfer += (*_iter145).write(oprot);
+ xfer += (*_iter157).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9201,14 +9479,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size146;
- ::apache::thrift::protocol::TType _etype149;
- xfer += iprot->readListBegin(_etype149, _size146);
- (*(this->success)).resize(_size146);
- uint32_t _i150;
- for (_i150 = 0; _i150 < _size146; ++_i150)
+ uint32_t _size158;
+ ::apache::thrift::protocol::TType _etype161;
+ xfer += iprot->readListBegin(_etype161, _size158);
+ (*(this->success)).resize(_size158);
+ uint32_t _i162;
+ for (_i162 = 0; _i162 < _size158; ++_i162)
{
- xfer += (*(this->success))[_i150].read(iprot);
+ xfer += (*(this->success))[_i162].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9346,14 +9624,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size151;
- ::apache::thrift::protocol::TType _etype154;
- xfer += iprot->readListBegin(_etype154, _size151);
- this->success.resize(_size151);
- uint32_t _i155;
- for (_i155 = 0; _i155 < _size151; ++_i155)
+ uint32_t _size163;
+ ::apache::thrift::protocol::TType _etype166;
+ xfer += iprot->readListBegin(_etype166, _size163);
+ this->success.resize(_size163);
+ uint32_t _i167;
+ for (_i167 = 0; _i167 < _size163; ++_i167)
{
- xfer += this->success[_i155].read(iprot);
+ xfer += this->success[_i167].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9408,10 +9686,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 _iter156;
- for (_iter156 = this->success.begin(); _iter156 != this->success.end(); ++_iter156)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter168;
+ for (_iter168 = this->success.begin(); _iter168 != this->success.end(); ++_iter168)
{
- xfer += (*_iter156).write(oprot);
+ xfer += (*_iter168).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9458,14 +9736,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size157;
- ::apache::thrift::protocol::TType _etype160;
- xfer += iprot->readListBegin(_etype160, _size157);
- (*(this->success)).resize(_size157);
- uint32_t _i161;
- for (_i161 = 0; _i161 < _size157; ++_i161)
+ uint32_t _size169;
+ ::apache::thrift::protocol::TType _etype172;
+ xfer += iprot->readListBegin(_etype172, _size169);
+ (*(this->success)).resize(_size169);
+ uint32_t _i173;
+ for (_i173 = 0; _i173 < _size169; ++_i173)
{
- xfer += (*(this->success))[_i161].read(iprot);
+ xfer += (*(this->success))[_i173].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9603,14 +9881,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size162;
- ::apache::thrift::protocol::TType _etype165;
- xfer += iprot->readListBegin(_etype165, _size162);
- this->success.resize(_size162);
- uint32_t _i166;
- for (_i166 = 0; _i166 < _size162; ++_i166)
+ uint32_t _size174;
+ ::apache::thrift::protocol::TType _etype177;
+ xfer += iprot->readListBegin(_etype177, _size174);
+ this->success.resize(_size174);
+ uint32_t _i178;
+ for (_i178 = 0; _i178 < _size174; ++_i178)
{
- xfer += this->success[_i166].read(iprot);
+ xfer += this->success[_i178].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9665,10 +9943,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 _iter167;
- for (_iter167 = this->success.begin(); _iter167 != this->success.end(); ++_iter167)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter179;
+ for (_iter179 = this->success.begin(); _iter179 != this->success.end(); ++_iter179)
{
- xfer += (*_iter167).write(oprot);
+ xfer += (*_iter179).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9715,14 +9993,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size168;
- ::apache::thrift::protocol::TType _etype171;
- xfer += iprot->readListBegin(_etype171, _size168);
- (*(this->success)).resize(_size168);
- uint32_t _i172;
- for (_i172 = 0; _i172 < _size168; ++_i172)
+ uint32_t _size180;
+ ::apache::thrift::protocol::TType _etype183;
+ xfer += iprot->readListBegin(_etype183, _size180);
+ (*(this->success)).resize(_size180);
+ uint32_t _i184;
+ for (_i184 = 0; _i184 < _size180; ++_i184)
{
- xfer += (*(this->success))[_i172].read(iprot);
+ xfer += (*(this->success))[_i184].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9860,17 +10138,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size173;
- ::apache::thrift::protocol::TType _ktype174;
- ::apache::thrift::protocol::TType _vtype175;
- xfer += iprot->readMapBegin(_ktype174, _vtype175, _size173);
- uint32_t _i177;
- for (_i177 = 0; _i177 < _size173; ++_i177)
+ uint32_t _size185;
+ ::apache::thrift::protocol::TType _ktype186;
+ ::apache::thrift::protocol::TType _vtype187;
+ xfer += iprot->readMapBegin(_ktype186, _vtype187, _size185);
+ uint32_t _i189;
+ for (_i189 = 0; _i189 < _size185; ++_i189)
{
- std::string _key178;
- xfer += iprot->readString(_key178);
- std::string& _val179 = this->success[_key178];
- xfer += iprot->readString(_val179);
+ std::string _key190;
+ xfer += iprot->readString(_key190);
+ std::string& _val191 = this->success[_key190];
+ xfer += iprot->readString(_val191);
}
xfer += iprot->readMapEnd();
}
@@ -9925,11 +10203,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 _iter180;
- for (_iter180 = this->success.begin(); _iter180 != this->success.end(); ++_iter180)
+ std::map<std::string, std::string> ::const_iterator _iter192;
+ for (_iter192 = this->success.begin(); _iter192 != this->success.end(); ++_iter192)
{
- xfer += oprot->writeString(_iter180->first);
- xfer += oprot->writeString(_iter180->second);
+ xfer += oprot->writeString(_iter192->first);
+ xfer += oprot->writeString(_iter192->second);
}
xfer += oprot->writeMapEnd();
}
@@ -9976,17 +10254,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size181;
- ::apache::thrift::protocol::TType _ktype182;
- ::apache::thrift::protocol::TType _vtype183;
- xfer += iprot->readMapBegin(_ktype182, _vtype183, _size181);
- uint32_t _i185;
- for (_i185 = 0; _i185 < _size181; ++_i185)
+ uint32_t _size193;
+ ::apache::thrift::protocol::TType _ktype194;
+ ::apache::thrift::protocol::TType _vtype195;
+ xfer += iprot->readMapBegin(_ktype194, _vtype195, _size193);
+ uint32_t _i197;
+ for (_i197 = 0; _i197 < _size193; ++_i197)
{
- std::string _key186;
- xfer += iprot->readString(_key186);
- std::string& _val187 = (*(this->success))[_key186];
- xfer += iprot->readString(_val187);
+ std::string _key198;
+ xfer += iprot->readString(_key198);
+ std::string& _val199 = (*(this->success))[_key198];
+ xfer += iprot->readString(_val199);
}
xfer += iprot->readMapEnd();
}
@@ -10550,17 +10828,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size188;
- ::apache::thrift::protocol::TType _ktype189;
- ::apache::thrift::protocol::TType _vtype190;
- xfer += iprot->readMapBegin(_ktype189, _vtype190, _size188);
- uint32_t _i192;
- for (_i192 = 0; _i192 < _size188; ++_i192)
+ uint32_t _size200;
+ ::apache::thrift::protocol::TType _ktype201;
+ ::apache::thrift::protocol::TType _vtype202;
+ xfer += iprot->readMapBegin(_ktype201, _vtype202, _size200);
+ uint32_t _i204;
+ for (_i204 = 0; _i204 < _size200; ++_i204)
{
- std::string _key193;
- xfer += iprot->readString(_key193);
- std::string& _val194 = this->success[_key193];
- xfer += iprot->readString(_val194);
+ std::string _key205;
+ xfer += iprot->readString(_key205);
+ std::string& _val206 = this->success[_key205];
+ xfer += iprot->readString(_val206);
}
xfer += iprot->readMapEnd();
}
@@ -10615,11 +10893,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 _iter195;
- for (_iter195 = this->success.begin(); _iter195 != this->success.end(); ++_iter195)
+ std::map<std::string, std::string> ::const_iterator _iter207;
+ for (_iter207 = this->success.begin(); _iter207 != this->success.end(); ++_iter207)
{
- xfer += oprot->writeString(_iter195->first);
- xfer += oprot->writeString(_iter195->second);
+ xfer += oprot->writeString(_iter207->first);
+ xfer += oprot->writeString(_iter207->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10666,17 +10944,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size196;
- ::apache::thrift::protocol::TType _ktype197;
- ::apache::thrift::protocol::TType _vtype198;
- xfer += iprot->readMapBegin(_ktype197, _vtype198, _size196);
- uint32_t _i200;
- for (_i200 = 0; _i200 < _size196; ++_i200)
+ uint32_t _size208;
+ ::apache::thrift::protocol::TType _ktype209;
+ ::apache::thrift::protocol::TType _vtype210;
+ xfer += iprot->readMapBegin(_ktype209, _vtype210, _size208);
+ uint32_t _i212;
+ for (_i212 = 0; _i212 < _size208; ++_i212)
{
- std::string _key201;
- xfer += iprot->readString(_key201);
- std::string& _val202 = (*(this->success))[_key201];
- xfer += iprot->readString(_val202);
+ std::string _key213;
+ xfer += iprot->readString(_key213);
+ std::string& _val214 = (*(this->success))[_key213];
+ xfer += iprot->readString(_val214);
}
xfer += iprot->readMapEnd();
}
@@ -14745,17 +15023,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->jobSubmissionPriorityMap.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 _size215;
+ ::apache::thrift::protocol::TType _ktype216;
+ ::apache::thrift::protocol::TType _vtype217;
+ xfer += iprot->readMapBegin(_ktype216, _vtype217, _size215);
+ uint32_t _i219;
+ for (_i219 = 0; _i219 < _size215; ++_i219)
{
- std::string _key208;
- xfer += iprot->readString(_key208);
- int32_t& _val209 = this->jobSubmissionPriorityMap[_key208];
- xfer += iprot->readI32(_val209);
+ std::string _key220;
+ xfer += iprot->readString(_key220);
+ int32_t& _val221 = this->jobSubmissionPriorityMap[_key220];
+ xfer += iprot->readI32(_val221);
}
xfer += iprot->readMapEnd();
}
@@ -14785,11 +15063,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 _iter210;
- for (_iter210 = this->jobSubmissionPriorityMap.begin(); _iter210 != this->jobSubmissionPriorityMap.end(); ++_iter210)
+ std::map<std::string, int32_t> ::const_iterator _iter222;
+ for (_iter222 = this->jobSubmissionPriorityMap.begin(); _iter222 != this->jobSubmissionPriorityMap.end(); ++_iter222)
{
- xfer += oprot->writeString(_iter210->first);
- xfer += oprot->writeI32(_iter210->second);
+ xfer += oprot->writeString(_iter222->first);
+ xfer += oprot->writeI32(_iter222->second);
}
xfer += oprot->writeMapEnd();
}
@@ -14807,11 +15085,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 _iter211;
- for (_iter211 = (*(this->jobSubmissionPriorityMap)).begin(); _iter211 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter211)
+ std::map<std::string, int32_t> ::const_iterator _iter223;
+ for (_iter223 = (*(this->jobSubmissionPriorityMap)).begin(); _iter223 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter223)
{
- xfer += oprot->writeString(_iter211->first);
- xfer += oprot->writeI32(_iter211->second);
+ xfer += oprot->writeString(_iter223->first);
+ xfer += oprot->writeI32(_iter223->second);
}
xfer += oprot->writeMapEnd();
}
@@ -15003,17 +15281,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->dataMovementPriorityMap.clear();
- uint32_t _size212;
- ::apache::thrift::protocol::TType _ktype213;
- ::apache::thrift::protocol::TType _vtype214;
- xfer += iprot->readMapBegin(_ktype213, _vtype214, _size212);
- uint32_t _i216;
- for (_i216 = 0; _i216 < _size212; ++_i216)
+ uint32_t _size224;
+ ::apache::thrift::protocol::TType _ktype225;
+ ::apache::thrift::protocol::TType _vtype226;
+ xfer += iprot->readMapBegin(_ktype225, _vtype226, _size224);
+ uint32_t _i228;
+ for (_i228 = 0; _i228 < _size224; ++_i228)
{
- std::string _key217;
- xfer += iprot->readString(_key217);
- int32_t& _val218 = this->dataMovementPriorityMap[_key217];
- xfer += iprot->readI32(_val218);
+ std::string _key229;
+ xfer += iprot->readString(_key229);
+ int32_t& _val230 = this->dataMovementPriorityMap[_key229];
+ xfer += iprot->readI32(_val230);
}
xfer += iprot->readMapEnd();
}
@@ -15043,11 +15321,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 _iter219;
- for (_iter219 = this->dataMovementPriorityMap.begin(); _iter219 != this->dataMovementPriorityMap.end(); ++_iter219)
+ std::map<std::string, int32_t> ::const_iterator _iter231;
+ for (_iter231 = this->dataMovementPriorityMap.begin(); _iter231 != this->dataMovementPriorityMap.end(); ++_iter231)
{
- xfer += oprot->writeString(_iter219->first);
- xfer += oprot->writeI32(_iter219->second);
+ xfer += oprot->writeString(_iter231->first);
+ xfer += oprot->writeI32(_iter231->second);
}
xfer += oprot->writeMapEnd();
}
@@ -15065,11 +15343,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 _iter220;
- for (_iter220 = (*(this->dataMovementPriorityMap)).begin(); _iter220 != (*(this->dataMovementPriorityMap)).end(); ++_iter220)
+ std::map<std::string, int32_t> ::const_iterator _iter232;
+ for (_iter232 = (*(this->dataMovementPriorityMap)).begin(); _iter232 != (*(this->dataMovementPriorityMap)).end(); ++_iter232)
{
- xfer += oprot->writeString(_iter220->first);
- xfer += oprot->writeI32(_iter220->second);
+ xfer += oprot->writeString(_iter232->first);
+ xfer += oprot->writeI32(_iter232->second);
}
xfer += oprot->writeMapEnd();
}
@@ -17205,14 +17483,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size221;
- ::apache::thrift::protocol::TType _etype224;
- xfer += iprot->readListBegin(_etype224, _size221);
- this->success.resize(_size221);
- uint32_t _i225;
- for (_i225 = 0; _i225 < _size221; ++_i225)
+ uint32_t _size233;
+ ::apache::thrift::protocol::TType _etype236;
+ xfer += iprot->readListBegin(_etype236, _size233);
+ this->success.resize(_size233);
+ uint32_t _i237;
+ for (_i237 = 0; _i237 < _size233; ++_i237)
{
- xfer += this->success[_i225].read(iprot);
+ xfer += this->success[_i237].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17267,10 +17545,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 _iter226;
- for (_iter226 = this->success.begin(); _iter226 != this->success.end(); ++_iter226)
+ std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter238;
+ for (_iter238 = this->success.begin(); _iter238 != this->success.end(); ++_iter238)
{
- xfer += (*_iter226).write(oprot);
+ xfer += (*_iter238).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -17317,14 +17595,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size227;
- ::apache::thrift::protocol::TType _etype230;
- xfer += iprot->readListBegin(_etype230, _size227);
- (*(this->success)).resize(_size227);
- uint32_t _i231;
- for (_i231 = 0; _i231 < _size227; ++_i231)
+ uint32_t _size239;
+ ::apache::thrift::protocol::TType _etype242;
+ xfer += iprot->readListBegin(_etype242, _size239);
+ (*(this->success)).resize(_size239);
+ uint32_t _i243;
+ for (_i243 = 0; _i243 < _size239; ++_i243)
{
- xfer += (*(this->success))[_i231].read(iprot);
+ xfer += (*(this->success))[_i243].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -18552,6 +18830,74 @@ void AiravataClient::recv_searchExperimentsByApplication(std::vector< ::apache::
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperimentsByApplication failed: unknown result");
}
+void AiravataClient::searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState)
+{
+ send_searchExperimentsByStatus(userName, experimentState);
+ recv_searchExperimentsByStatus(_return);
+}
+
+void AiravataClient::send_searchExperimentsByStatus(const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState)
+{
+ int32_t cseqid = 0;
+ oprot_->writeMessageBegin("searchExperimentsByStatus", ::apache::thrift::protocol::T_CALL, cseqid);
+
+ Airavata_searchExperimentsByStatus_pargs args;
+ args.userName = &userName;
+ args.experimentState = &experimentState;
+ args.write(oprot_);
+
+ oprot_->writeMessageEnd();
+ oprot_->getTransport()->writeEnd();
+ oprot_->getTransport()->flush();
+}
+
+void AiravataClient::recv_searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _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("searchExperimentsByStatus") != 0) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ Airavata_searchExperimentsByStatus_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.ace) {
+ throw result.ace;
+ }
+ if (result.__isset.ase) {
+ throw result.ase;
+ }
+ throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperimentsByStatus failed: unknown result");
+}
+
void AiravataClient::getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId)
{
send_getAllExperimentsInProject(projectId);
@@ -23493,6 +23839,69 @@ void AiravataProcessor::process_searchExperimentsByApplication(int32_t seqid, ::
}
}
+void AiravataProcessor::process_searchExperimentsByStatus(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.searchExperimentsByStatus", callContext);
+ }
+ ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.searchExperimentsByStatus");
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preRead(ctx, "Airavata.searchExperimentsByStatus");
+ }
+
+ Airavata_searchExperimentsByStatus_args args;
+ args.read(iprot);
+ iprot->readMessageEnd();
+ uint32_t bytes = iprot->getTransport()->readEnd();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postRead(ctx, "Airavata.searchExperimentsByStatus", bytes);
+ }
+
+ Airavata_searchExperimentsByStatus_result result;
+ try {
+ iface_->searchExperimentsByStatus(result.success, args.userName, args.experimentState);
+ result.__isset.success = true;
+ } catch ( ::apache::airavata::api::error::InvalidRequestException &ire) {
+ result.ire = ire;
+ result.__isset.ire = 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.searchExperimentsByStatus");
+ }
+
+ ::apache::thrift::TApplicationException x(e.what());
+ oprot->writeMessageBegin("searchExperimentsByStatus", ::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.searchExperimentsByStatus");
+ }
+
+ oprot->writeMessageBegin("searchExperimentsByStatus", ::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.searchExperimentsByStatus", bytes);
+ }
+}
+
void AiravataProcessor::process_getAllExperimentsInProject(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/3cab2d63/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 96fc55c..bd09cc7 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
@@ -42,6 +42,7 @@ class AiravataIf {
virtual void searchExperimentsByName(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const std::string& expName) = 0;
virtual void searchExperimentsByDesc(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const std::string& description) = 0;
virtual void searchExperimentsByApplication(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const std::string& applicationId) = 0;
+ virtual void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState) = 0;
virtual void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) = 0;
virtual void getAllUserExperiments(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& userName) = 0;
virtual void createExperiment(std::string& _return, const ::apache::airavata::model::workspace::experiment::Experiment& experiment) = 0;
@@ -165,6 +166,9 @@ class AiravataNull : virtual public AiravataIf {
void searchExperimentsByApplication(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & /* _return */, const std::string& /* userName */, const std::string& /* applicationId */) {
return;
}
+ void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & /* _return */, const std::string& /* userName */, const ::apache::airavata::model::workspace::experiment::ExperimentState::type /* experimentState */) {
+ return;
+ }
void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & /* _return */, const std::string& /* projectId */) {
return;
}
@@ -1762,6 +1766,146 @@ class Airavata_searchExperimentsByApplication_presult {
};
+class Airavata_searchExperimentsByStatus_args {
+ public:
+
+ Airavata_searchExperimentsByStatus_args() : userName(), experimentState(( ::apache::airavata::model::workspace::experiment::ExperimentState::type)0) {
+ }
+
+ virtual ~Airavata_searchExperimentsByStatus_args() throw() {}
+
+ std::string userName;
+ ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState;
+
+ void __set_userName(const std::string& val) {
+ userName = val;
+ }
+
+ void __set_experimentState(const ::apache::airavata::model::workspace::experiment::ExperimentState::type val) {
+ experimentState = val;
+ }
+
+ bool operator == (const Airavata_searchExperimentsByStatus_args & rhs) const
+ {
+ if (!(userName == rhs.userName))
+ return false;
+ if (!(experimentState == rhs.experimentState))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchExperimentsByStatus_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchExperimentsByStatus_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_searchExperimentsByStatus_pargs {
+ public:
+
+
+ virtual ~Airavata_searchExperimentsByStatus_pargs() throw() {}
+
+ const std::string* userName;
+ const ::apache::airavata::model::workspace::experiment::ExperimentState::type* experimentState;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchExperimentsByStatus_result__isset {
+ _Airavata_searchExperimentsByStatus_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchExperimentsByStatus_result__isset;
+
+class Airavata_searchExperimentsByStatus_result {
+ public:
+
+ Airavata_searchExperimentsByStatus_result() {
+ }
+
+ virtual ~Airavata_searchExperimentsByStatus_result() throw() {}
+
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_searchExperimentsByStatus_result__isset __isset;
+
+ void __set_success(const std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & val) {
+ success = val;
+ }
+
+ void __set_ire(const ::apache::airavata::api::error::InvalidRequestException& val) {
+ ire = 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_searchExperimentsByStatus_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(ire == rhs.ire))
+ return false;
+ if (!(ace == rhs.ace))
+ return false;
+ if (!(ase == rhs.ase))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchExperimentsByStatus_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchExperimentsByStatus_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchExperimentsByStatus_presult__isset {
+ _Airavata_searchExperimentsByStatus_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchExperimentsByStatus_presult__isset;
+
+class Airavata_searchExperimentsByStatus_presult {
+ public:
+
+
+ virtual ~Airavata_searchExperimentsByStatus_presult() throw() {}
+
+ std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> * success;
+ ::apache::airavata::api::error::InvalidRequestException ire;
+ ::apache::airavata::api::error::AiravataClientException ace;
+ ::apache::airavata::api::error::AiravataSystemException ase;
+
+ _Airavata_searchExperimentsByStatus_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
class Airavata_getAllExperimentsInProject_args {
public:
@@ -10436,6 +10580,9 @@ class AiravataClient : virtual public AiravataIf {
void searchExperimentsByApplication(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const std::string& applicationId);
void send_searchExperimentsByApplication(const std::string& userName, const std::string& applicationId);
void recv_searchExperimentsByApplication(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return);
+ void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState);
+ void send_searchExperimentsByStatus(const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState);
+ void recv_searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return);
void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId);
void send_getAllExperimentsInProject(const std::string& projectId);
void recv_getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return);
@@ -10653,6 +10800,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
void process_searchExperimentsByName(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_searchExperimentsByDesc(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_searchExperimentsByApplication(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_searchExperimentsByStatus(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getAllExperimentsInProject(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_getAllUserExperiments(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_createExperiment(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -10730,6 +10878,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
processMap_["searchExperimentsByName"] = &AiravataProcessor::process_searchExperimentsByName;
processMap_["searchExperimentsByDesc"] = &AiravataProcessor::process_searchExperimentsByDesc;
processMap_["searchExperimentsByApplication"] = &AiravataProcessor::process_searchExperimentsByApplication;
+ processMap_["searchExperimentsByStatus"] = &AiravataProcessor::process_searchExperimentsByStatus;
processMap_["getAllExperimentsInProject"] = &AiravataProcessor::process_getAllExperimentsInProject;
processMap_["getAllUserExperiments"] = &AiravataProcessor::process_getAllUserExperiments;
processMap_["createExperiment"] = &AiravataProcessor::process_createExperiment;
@@ -10921,6 +11070,16 @@ class AiravataMultiface : virtual public AiravataIf {
return;
}
+ void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->searchExperimentsByStatus(_return, userName, experimentState);
+ }
+ ifaces_[i]->searchExperimentsByStatus(_return, userName, experimentState);
+ return;
+ }
+
void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) {
size_t sz = ifaces_.size();
size_t i = 0;
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/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 33b598f..2106a0b 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
@@ -89,6 +89,11 @@ class AiravataHandler : virtual public AiravataIf {
printf("searchExperimentsByApplication\n");
}
+ void searchExperimentsByStatus(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const ::apache::airavata::model::workspace::experiment::ExperimentState::type experimentState) {
+ // Your implementation goes here
+ printf("searchExperimentsByStatus\n");
+ }
+
void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) {
// Your implementation goes here
printf("getAllExperimentsInProject\n");
[3/4] fixing AIRAVATA-1360
Posted by ch...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/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 045b33b..9e312dc 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
@@ -137,6 +137,15 @@ import org.slf4j.LoggerFactory;
public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByApplication(String userName, String applicationId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
/**
+ * Search Experiments by experiment status
+ *
+ *
+ * @param userName
+ * @param experimentState
+ */
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+
+ /**
* Get all Experiments within a Project
*
*
@@ -1274,6 +1283,8 @@ import org.slf4j.LoggerFactory;
public void searchExperimentsByApplication(String userName, String applicationId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getAllExperimentsInProject(String projectId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getAllUserExperiments(String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -1752,6 +1763,39 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "searchExperimentsByApplication failed: unknown result");
}
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_searchExperimentsByStatus(userName, experimentState);
+ return recv_searchExperimentsByStatus();
+ }
+
+ public void send_searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState) throws org.apache.thrift.TException
+ {
+ searchExperimentsByStatus_args args = new searchExperimentsByStatus_args();
+ args.setUserName(userName);
+ args.setExperimentState(experimentState);
+ sendBase("searchExperimentsByStatus", args);
+ }
+
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> recv_searchExperimentsByStatus() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
+ receiveBase(result, "searchExperimentsByStatus");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "searchExperimentsByStatus failed: unknown result");
+ }
+
public List<org.apache.airavata.model.workspace.experiment.Experiment> getAllExperimentsInProject(String projectId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.ProjectNotFoundException, org.apache.thrift.TException
{
send_getAllExperimentsInProject(projectId);
@@ -4162,6 +4206,41 @@ import org.slf4j.LoggerFactory;
}
}
+ public void searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ searchExperimentsByStatus_call method_call = new searchExperimentsByStatus_call(userName, experimentState, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class searchExperimentsByStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String userName;
+ private org.apache.airavata.model.workspace.experiment.ExperimentState experimentState;
+ public searchExperimentsByStatus_call(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState, 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.userName = userName;
+ this.experimentState = experimentState;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("searchExperimentsByStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ searchExperimentsByStatus_args args = new searchExperimentsByStatus_args();
+ args.setUserName(userName);
+ args.setExperimentState(experimentState);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_searchExperimentsByStatus();
+ }
+ }
+
public void getAllExperimentsInProject(String projectId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getAllExperimentsInProject_call method_call = new getAllExperimentsInProject_call(projectId, resultHandler, this, ___protocolFactory, ___transport);
@@ -6332,6 +6411,7 @@ import org.slf4j.LoggerFactory;
processMap.put("searchExperimentsByName", new searchExperimentsByName());
processMap.put("searchExperimentsByDesc", new searchExperimentsByDesc());
processMap.put("searchExperimentsByApplication", new searchExperimentsByApplication());
+ processMap.put("searchExperimentsByStatus", new searchExperimentsByStatus());
processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject());
processMap.put("getAllUserExperiments", new getAllUserExperiments());
processMap.put("createExperiment", new createExperiment());
@@ -6683,6 +6763,34 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class searchExperimentsByStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, searchExperimentsByStatus_args> {
+ public searchExperimentsByStatus() {
+ super("searchExperimentsByStatus");
+ }
+
+ public searchExperimentsByStatus_args getEmptyArgsInstance() {
+ return new searchExperimentsByStatus_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public searchExperimentsByStatus_result getResult(I iface, searchExperimentsByStatus_args args) throws org.apache.thrift.TException {
+ searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
+ try {
+ result.success = iface.searchExperimentsByStatus(args.userName, args.experimentState);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } 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 getAllExperimentsInProject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllExperimentsInProject_args> {
public getAllExperimentsInProject() {
super("getAllExperimentsInProject");
@@ -8516,6 +8624,7 @@ import org.slf4j.LoggerFactory;
processMap.put("searchExperimentsByName", new searchExperimentsByName());
processMap.put("searchExperimentsByDesc", new searchExperimentsByDesc());
processMap.put("searchExperimentsByApplication", new searchExperimentsByApplication());
+ processMap.put("searchExperimentsByStatus", new searchExperimentsByStatus());
processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject());
processMap.put("getAllUserExperiments", new getAllUserExperiments());
processMap.put("createExperiment", new createExperiment());
@@ -9262,20 +9371,20 @@ import org.slf4j.LoggerFactory;
}
}
- public static class getAllExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllExperimentsInProject_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> {
- public getAllExperimentsInProject() {
- super("getAllExperimentsInProject");
+ public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> {
+ public searchExperimentsByStatus() {
+ super("searchExperimentsByStatus");
}
- public getAllExperimentsInProject_args getEmptyArgsInstance() {
- return new getAllExperimentsInProject_args();
+ public searchExperimentsByStatus_args getEmptyArgsInstance() {
+ return new searchExperimentsByStatus_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() {
- public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) {
- getAllExperimentsInProject_result result = new getAllExperimentsInProject_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) {
+ searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -9288,7 +9397,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllExperimentsInProject_result result = new getAllExperimentsInProject_result();
+ searchExperimentsByStatus_result result = new searchExperimentsByStatus_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -9304,11 +9413,6 @@ import org.slf4j.LoggerFactory;
result.setAseIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
- result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
- result.setPnfeIsSet(true);
- msg = result;
- }
else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
@@ -9329,25 +9433,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAllExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException {
- iface.getAllExperimentsInProject(args.projectId,resultHandler);
+ public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException {
+ iface.searchExperimentsByStatus(args.userName, args.experimentState,resultHandler);
}
}
- public static class getAllUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserExperiments_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> {
- public getAllUserExperiments() {
- super("getAllUserExperiments");
+ public static class getAllExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllExperimentsInProject_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> {
+ public getAllExperimentsInProject() {
+ super("getAllExperimentsInProject");
}
- public getAllUserExperiments_args getEmptyArgsInstance() {
- return new getAllUserExperiments_args();
+ public getAllExperimentsInProject_args getEmptyArgsInstance() {
+ return new getAllExperimentsInProject_args();
}
public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() {
public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) {
- getAllUserExperiments_result result = new getAllUserExperiments_result();
+ getAllExperimentsInProject_result result = new getAllExperimentsInProject_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -9360,7 +9464,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllUserExperiments_result result = new getAllUserExperiments_result();
+ getAllExperimentsInProject_result result = new getAllExperimentsInProject_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -9376,71 +9480,9 @@ import org.slf4j.LoggerFactory;
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, getAllUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException {
- iface.getAllUserExperiments(args.userName,resultHandler);
- }
- }
-
- public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> {
- public createExperiment() {
- super("createExperiment");
- }
-
- public createExperiment_args getEmptyArgsInstance() {
- return new createExperiment_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) {
- createExperiment_result result = new createExperiment_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;
- createExperiment_result result = new createExperiment_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);
+ else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) {
+ result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e;
+ result.setPnfeIsSet(true);
msg = result;
}
else
@@ -9463,25 +9505,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.createExperiment(args.experiment,resultHandler);
+ public void start(I iface, getAllExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException {
+ iface.getAllExperimentsInProject(args.projectId,resultHandler);
}
}
- public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.workspace.experiment.Experiment> {
- public getExperiment() {
- super("getExperiment");
+ public static class getAllUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserExperiments_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> {
+ public getAllUserExperiments() {
+ super("getAllUserExperiments");
}
- public getExperiment_args getEmptyArgsInstance() {
- return new getExperiment_args();
+ public getAllUserExperiments_args getEmptyArgsInstance() {
+ return new getAllUserExperiments_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment>() {
- public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) {
- getExperiment_result result = new getExperiment_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) {
+ getAllUserExperiments_result result = new getAllUserExperiments_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -9494,17 +9536,12 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getExperiment_result result = new getExperiment_result();
+ getAllUserExperiments_result result = new getAllUserExperiments_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);
@@ -9535,25 +9572,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> resultHandler) throws TException {
- iface.getExperiment(args.airavataExperimentId,resultHandler);
+ public void start(I iface, getAllUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException {
+ iface.getAllUserExperiments(args.userName,resultHandler);
}
}
- public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> {
- public updateExperiment() {
- super("updateExperiment");
+ public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> {
+ public createExperiment() {
+ super("createExperiment");
}
- public updateExperiment_args getEmptyArgsInstance() {
- return new updateExperiment_args();
+ public createExperiment_args getEmptyArgsInstance() {
+ return new createExperiment_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- updateExperiment_result result = new updateExperiment_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ createExperiment_result result = new createExperiment_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9565,17 +9603,12 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateExperiment_result result = new updateExperiment_result();
+ createExperiment_result result = new createExperiment_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);
@@ -9606,127 +9639,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.updateExperiment(args.airavataExperimentId, args.experiment,resultHandler);
- }
- }
-
- public static class updateExperimentConfiguration<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperimentConfiguration_args, Void> {
- public updateExperimentConfiguration() {
- super("updateExperimentConfiguration");
- }
-
- public updateExperimentConfiguration_args getEmptyArgsInstance() {
- return new updateExperimentConfiguration_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) {
- updateExperimentConfiguration_result result = new updateExperimentConfiguration_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;
- updateExperimentConfiguration_result result = new updateExperimentConfiguration_result();
- {
- 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, updateExperimentConfiguration_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.updateExperimentConfiguration(args.airavataExperimentId, args.userConfiguration,resultHandler);
- }
- }
-
- public static class updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> {
- public updateResourceScheduleing() {
- super("updateResourceScheduleing");
- }
-
- public updateResourceScheduleing_args getEmptyArgsInstance() {
- return new updateResourceScheduleing_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) {
- updateResourceScheduleing_result result = new updateResourceScheduleing_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;
- updateResourceScheduleing_result result = new updateResourceScheduleing_result();
- {
- 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, updateResourceScheduleing_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.updateResourceScheduleing(args.airavataExperimentId, args.resourceScheduling,resultHandler);
+ public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.createExperiment(args.experiment,resultHandler);
}
}
- public static class validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> {
- public validateExperiment() {
- super("validateExperiment");
+ public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.workspace.experiment.Experiment> {
+ public getExperiment() {
+ super("getExperiment");
}
- public validateExperiment_args getEmptyArgsInstance() {
- return new validateExperiment_args();
+ public getExperiment_args getEmptyArgsInstance() {
+ return new getExperiment_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- validateExperiment_result result = new validateExperiment_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment>() {
+ public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) {
+ getExperiment_result result = new getExperiment_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9738,7 +9670,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- validateExperiment_result result = new validateExperiment_result();
+ getExperiment_result result = new getExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -9779,25 +9711,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, validateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.validateExperiment(args.airavataExperimentId,resultHandler);
+ public void start(I iface, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> resultHandler) throws TException {
+ iface.getExperiment(args.airavataExperimentId,resultHandler);
}
}
- public static class launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> {
- public launchExperiment() {
- super("launchExperiment");
+ public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> {
+ public updateExperiment() {
+ super("updateExperiment");
}
- public launchExperiment_args getEmptyArgsInstance() {
- return new launchExperiment_args();
+ public updateExperiment_args getEmptyArgsInstance() {
+ return new updateExperiment_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) {
- launchExperiment_result result = new launchExperiment_result();
+ updateExperiment_result result = new updateExperiment_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9809,7 +9741,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- launchExperiment_result result = new launchExperiment_result();
+ updateExperiment_result result = new updateExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -9830,11 +9762,6 @@ import org.slf4j.LoggerFactory;
result.setAseIsSet(true);
msg = result;
}
- else if (e instanceof org.apache.airavata.model.error.LaunchValidationException) {
- result.lve = (org.apache.airavata.model.error.LaunchValidationException) e;
- result.setLveIsSet(true);
- msg = result;
- }
else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
@@ -9855,26 +9782,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, launchExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.launchExperiment(args.airavataExperimentId, args.airavataCredStoreToken,resultHandler);
+ public void start(I iface, updateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateExperiment(args.airavataExperimentId, args.experiment,resultHandler);
}
}
- public static class getExperimentStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatus_args, org.apache.airavata.model.workspace.experiment.ExperimentStatus> {
- public getExperimentStatus() {
- super("getExperimentStatus");
+ public static class updateExperimentConfiguration<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperimentConfiguration_args, Void> {
+ public updateExperimentConfiguration() {
+ super("updateExperimentConfiguration");
}
- public getExperimentStatus_args getEmptyArgsInstance() {
- return new getExperimentStatus_args();
+ public updateExperimentConfiguration_args getEmptyArgsInstance() {
+ return new updateExperimentConfiguration_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> 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<org.apache.airavata.model.workspace.experiment.ExperimentStatus>() {
- public void onComplete(org.apache.airavata.model.workspace.experiment.ExperimentStatus o) {
- getExperimentStatus_result result = new getExperimentStatus_result();
- result.success = o;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ updateExperimentConfiguration_result result = new updateExperimentConfiguration_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9886,28 +9812,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getExperimentStatus_result result = new getExperimentStatus_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
+ updateExperimentConfiguration_result result = new updateExperimentConfiguration_result();
{
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());
@@ -9927,26 +9832,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getExperimentStatus_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> resultHandler) throws TException {
- iface.getExperimentStatus(args.airavataExperimentId,resultHandler);
+ public void start(I iface, updateExperimentConfiguration_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateExperimentConfiguration(args.airavataExperimentId, args.userConfiguration,resultHandler);
}
}
- public static class getExperimentOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentOutputs_args, List<org.apache.airavata.model.workspace.experiment.DataObjectType>> {
- public getExperimentOutputs() {
- super("getExperimentOutputs");
+ public static class updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> {
+ public updateResourceScheduleing() {
+ super("updateResourceScheduleing");
}
- public getExperimentOutputs_args getEmptyArgsInstance() {
- return new getExperimentOutputs_args();
+ public updateResourceScheduleing_args getEmptyArgsInstance() {
+ return new updateResourceScheduleing_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> 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<List<org.apache.airavata.model.workspace.experiment.DataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataObjectType> o) {
- getExperimentOutputs_result result = new getExperimentOutputs_result();
- result.success = o;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ updateResourceScheduleing_result result = new updateResourceScheduleing_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9958,7 +9862,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getExperimentOutputs_result result = new getExperimentOutputs_result();
+ updateResourceScheduleing_result result = new updateResourceScheduleing_result();
{
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());
@@ -9978,26 +9882,27 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getExperimentOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> resultHandler) throws TException {
- iface.getExperimentOutputs(args.airavataExperimentId,resultHandler);
+ public void start(I iface, updateResourceScheduleing_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateResourceScheduleing(args.airavataExperimentId, args.resourceScheduling,resultHandler);
}
}
- 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 validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> {
+ public validateExperiment() {
+ super("validateExperiment");
}
- public getJobStatuses_args getEmptyArgsInstance() {
- return new getJobStatuses_args();
+ public validateExperiment_args getEmptyArgsInstance() {
+ return new validateExperiment_args();
}
- public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> 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,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<Boolean>() {
+ public void onComplete(Boolean o) {
+ validateExperiment_result result = new validateExperiment_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10009,7 +9914,28 @@ 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();
+ validateExperiment_result result = new validateExperiment_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());
@@ -10029,26 +9955,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, validateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.validateExperiment(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 launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> {
+ public launchExperiment() {
+ super("launchExperiment");
}
- public cloneExperiment_args getEmptyArgsInstance() {
- return new cloneExperiment_args();
+ public launchExperiment_args getEmptyArgsInstance() {
+ return new launchExperiment_args();
}
- public AsyncMethodCallback<String> 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<String>() {
- public void onComplete(String o) {
- cloneExperiment_result result = new cloneExperiment_result();
- result.success = o;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ launchExperiment_result result = new launchExperiment_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10060,7 +9985,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();
+ launchExperiment_result result = new launchExperiment_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -10081,6 +10006,11 @@ import org.slf4j.LoggerFactory;
result.setAseIsSet(true);
msg = result;
}
+ else if (e instanceof org.apache.airavata.model.error.LaunchValidationException) {
+ result.lve = (org.apache.airavata.model.error.LaunchValidationException) e;
+ result.setLveIsSet(true);
+ msg = result;
+ }
else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
@@ -10101,25 +10031,26 @@ import org.slf4j.LoggerFactory;
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 void start(I iface, launchExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.launchExperiment(args.airavataExperimentId, args.airavataCredStoreToken,resultHandler);
}
}
- public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> {
- public terminateExperiment() {
- super("terminateExperiment");
+ public static class getExperimentStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatus_args, org.apache.airavata.model.workspace.experiment.ExperimentStatus> {
+ public getExperimentStatus() {
+ super("getExperimentStatus");
}
- public terminateExperiment_args getEmptyArgsInstance() {
- return new terminateExperiment_args();
+ public getExperimentStatus_args getEmptyArgsInstance() {
+ return new getExperimentStatus_args();
}
- public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> 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();
+ return new AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus>() {
+ public void onComplete(org.apache.airavata.model.workspace.experiment.ExperimentStatus o) {
+ getExperimentStatus_result result = new getExperimentStatus_result();
+ result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10131,7 +10062,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- terminateExperiment_result result = new terminateExperiment_result();
+ getExperimentStatus_result result = new getExperimentStatus_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -10172,25 +10103,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, getExperimentStatus_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> resultHandler) throws TException {
+ iface.getExperimentStatus(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 getExperimentOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentOutputs_args, List<org.apache.airavata.model.workspace.experiment.DataObjectType>> {
+ public getExperimentOutputs() {
+ super("getExperimentOutputs");
}
- public registerApplicationModule_args getEmptyArgsInstance() {
- return new registerApplicationModule_args();
+ public getExperimentOutputs_args getEmptyArgsInstance() {
+ return new getExperimentOutputs_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> 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();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>>() {
+ public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataObjectType> o) {
+ getExperimentOutputs_result result = new getExperimentOutputs_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -10203,23 +10134,7 @@ 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();
- 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
+ getExperimentOutputs_result result = new getExperimentOutputs_result();
{
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());
@@ -10239,25 +10154,25 @@ import org.slf4j.LoggerFactory;
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 void start(I iface, getExperimentOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> resultHandler) throws TException {
+ iface.getExperimentOutputs(args.airavataExperimentId,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 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 getApplicationModule_args getEmptyArgsInstance() {
- return new getApplicationModule_args();
+ public getJobStatuses_args getEmptyArgsInstance() {
+ return new getJobStatuses_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> 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<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>() {
- public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule o) {
- getApplicationModule_result result = new getApplicationModule_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);
@@ -10270,23 +10185,7 @@ import org.slf4j.LoggerFactory;
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);
- 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
+ getJobStatuses_result result = new getJobStatuses_result();
{
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());
@@ -10306,27 +10205,26 @@ 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, 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 updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> {
- public updateApplicationModule() {
- super("updateApplicationModule");
+ public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> {
+ public cloneExperiment() {
+ super("cloneExperiment");
}
- public updateApplicationModule_args getEmptyArgsInstance() {
- return new updateApplicationModule_args();
+ public cloneExperiment_args getEmptyArgsInstance() {
+ return new cloneExperiment_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) {
- updateApplicationModule_result result = new updateApplicationModule_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ cloneExperiment_result result = new cloneExperiment_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10338,12 +10236,17 @@ 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();
+ 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);
@@ -10374,27 +10277,25 @@ import org.slf4j.LoggerFactory;
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 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 deleteApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationModule_args, Boolean> {
- public deleteApplicationModule() {
- super("deleteApplicationModule");
+ public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> {
+ public terminateExperiment() {
+ super("terminateExperiment");
}
- public deleteApplicationModule_args getEmptyArgsInstance() {
- return new deleteApplicationModule_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) {
- deleteApplicationModule_result result = new deleteApplicationModule_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;
@@ -10406,12 +10307,17 @@ 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();
+ 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.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);
@@ -10442,25 +10348,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, terminateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.terminateExperiment(args.airavataExperimentId,resultHandler);
}
}
- public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> {
- public registerApplicationDeployment() {
- super("registerApplicationDeployment");
+ public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> {
+ public registerApplicationModule() {
+ super("registerApplicationModule");
}
- public registerApplicationDeployment_args getEmptyArgsInstance() {
- return new registerApplicationDeployment_args();
+ public registerApplicationModule_args getEmptyArgsInstance() {
+ return new registerApplicationModule_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) {
- registerApplicationDeployment_result result = new registerApplicationDeployment_result();
+ registerApplicationModule_result result = new registerApplicationModule_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -10473,7 +10379,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();
+ 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);
@@ -10509,25 +10415,25 @@ 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, registerApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerApplicationModule(args.applicationModule,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 getApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationModule_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> {
+ public getApplicationModule() {
+ super("getApplicationModule");
}
- public getApplicationDeployment_args getEmptyArgsInstance() {
- return new getApplicationDeployment_args();
+ public getApplicationModule_args getEmptyArgsInstance() {
+ return new getApplicationModule_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> 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<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<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);
@@ -10540,7 +10446,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();
+ 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);
@@ -10576,25 +10482,25 @@ 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, 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 updateApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationDeployment_args, Boolean> {
- public updateApplicationDeployment() {
- super("updateApplicationDeployment");
+ public static class updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> {
+ public updateApplicationModule() {
+ super("updateApplicationModule");
}
- public updateApplicationDeployment_args getEmptyArgsInstance() {
- return new updateApplicationDeployment_args();
+ public updateApplicationModule_args getEmptyArgsInstance() {
+ return new updateApplicationModule_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) {
- updateApplicationDeployment_result result = new updateApplicationDeployment_result();
+ updateApplicationModule_result result = new updateApplicationModule_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -10608,7 +10514,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();
+ 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);
@@ -10644,25 +10550,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, updateApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateApplicationModule(args.appModuleId, args.applicationModule,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 {
@@ -10676,7 +10582,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);
@@ -10712,25 +10618,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 getAppModuleDeployedResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAppModuleDeployedResources_args, List<String>> {
- public getAppModuleDeployedResources() {
- super("getAppModuleDeployedResources");
+ public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> {
+ public registerApplicationDeployment() {
+ super("registerApplicationDeployment");
}
- public getAppModuleDeployedResources_args getEmptyArgsInstance() {
- return new getAppModuleDeployedResources_args();
+ public registerApplicationDeployment_args getEmptyArgsInstance() {
+ return new registerApplicationDeployment_args();
}
- public AsyncMethodCallback<List<String>> 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<String>>() {
- public void onComplete(List<String> o) {
- getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_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);
@@ -10743,7 +10649,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();
+ 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);
@@ -10779,25 +10685,25 @@ 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 void start(I iface, registerApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerApplicationDeployment(args.applicationDeployment,resultHandler);
}
}
- public static class registerApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationInterface_args, String> {
- public registerApplicationInterface() {
- super("registerApplicationInterface");
+ 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 registerApplicationInterface_args getEmptyArgsInstance() {
- return new registerApplicationInterface_args();
+ public getApplicationDeployment_args getEmptyArgsInstance() {
+ return new getApplicationDeployment_args();
}
- public AsyncMethodCallback<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<String>() {
- public void onComplete(String o) {
- registerApplicationInterface_result result = new registerApplicationInterface_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);
@@ -10810,7 +10716,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerApplicationInterface_result result = new registerApplicationInterface_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);
@@ -10846,26 +10752,27 @@ import org.slf4j.LoggerFactory;
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 TExc
<TRUNCATED>
[4/4] git commit: fixing AIRAVATA-1360
Posted by ch...@apache.org.
fixing AIRAVATA-1360
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/3cab2d63
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/3cab2d63
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/3cab2d63
Branch: refs/heads/master
Commit: 3cab2d63a4c82a85795c8742442300e0247854bc
Parents: bb8e448
Author: Chathuri Wimalasena <ka...@gmail.com>
Authored: Mon Aug 18 12:21:55 2014 -0400
Committer: Chathuri Wimalasena <ka...@gmail.com>
Committed: Mon Aug 18 12:21:55 2014 -0400
----------------------------------------------------------------------
.../server/handler/AiravataServerHandler.java | 36 +
.../java/org/apache/airavata/api/Airavata.java | 6301 +++++++++++-------
.../main/resources/lib/airavata/Airavata.cpp | 945 ++-
.../src/main/resources/lib/airavata/Airavata.h | 159 +
.../lib/airavata/Airavata_server.skeleton.cpp | 5 +
.../resources/lib/Airavata/API/Airavata.php | 636 +-
.../client/samples/CreateLaunchExperiment.java | 16 +-
.../samples/TestCreateLaunchExperiment.java | 28 +-
.../airavataAPI.thrift | 9 +
.../registry/jpa/impl/ExperimentRegistry.java | 21 +-
.../registry/jpa/resources/WorkerResource.java | 34 +
11 files changed, 5274 insertions(+), 2916 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/3cab2d63/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 0edb752..32800cd 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
@@ -502,6 +502,42 @@ public class AiravataServerHandler implements Airavata.Iface, Watcher {
}
}
+ @Override
+ public List<ExperimentSummary> searchExperimentsByStatus(String userName, ExperimentState experimentState) throws InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
+ if (!validateString(userName)){
+ logger.error("Username cannot be empty. Please provide a valid user..");
+ AiravataSystemException exception = new AiravataSystemException();
+ exception.setAiravataErrorType(AiravataErrorType.INTERNAL_ERROR);
+ exception.setMessage("Username cannot be empty. Please provide a valid user..");
+ throw exception;
+ }
+ try {
+ if (!ResourceUtils.isUserExist(userName)){
+ logger.error("User does not exist in the system. Please provide a valid user..");
+ AiravataSystemException exception = new AiravataSystemException();
+ exception.setAiravataErrorType(AiravataErrorType.INTERNAL_ERROR);
+ exception.setMessage("User does not exist in the system. Please provide a valid user..");
+ throw exception;
+ }
+ List<ExperimentSummary> summaries = new ArrayList<ExperimentSummary>();
+ registry = RegistryFactory.getDefaultRegistry();
+ Map<String, String> filters = new HashMap<String, String>();
+ filters.put(Constants.FieldConstants.ExperimentConstants.USER_NAME, userName);
+ filters.put(Constants.FieldConstants.ExperimentConstants.EXPERIMENT_STATUS, experimentState.toString());
+ List<Object> results = registry.search(RegistryModelType.EXPERIMENT, filters);
+ for (Object object : results) {
+ summaries.add((ExperimentSummary) object);
+ }
+ return summaries;
+ }catch (Exception e) {
+ logger.error("Error while retrieving experiments", e);
+ AiravataSystemException exception = new AiravataSystemException();
+ exception.setAiravataErrorType(AiravataErrorType.INTERNAL_ERROR);
+ exception.setMessage("Error while retrieving experiments. More info : " + e.getMessage());
+ throw exception;
+ }
+ }
+
/**
* Get all Experiments within a Project
*