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/19 16:43:40 UTC
[1/4] fixing AIRAVATA-1361
Repository: airavata
Updated Branches:
refs/heads/master 414f2b9cf -> 9c1f44d04
http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 8a73055..56a7425 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
@@ -28,6 +28,7 @@ interface AiravataIf {
public function searchExperimentsByDesc($userName, $description);
public function searchExperimentsByApplication($userName, $applicationId);
public function searchExperimentsByStatus($userName, $experimentState);
+ public function searchExperimentsByCreationTime($userName, $fromTime, $toTime);
public function getAllExperimentsInProject($projectId);
public function getAllUserExperiments($userName);
public function createExperiment(\Airavata\Model\Workspace\Experiment\Experiment $experiment);
@@ -774,6 +775,68 @@ class AiravataClient implements \Airavata\API\AiravataIf {
throw new \Exception("searchExperimentsByStatus failed: unknown result");
}
+ public function searchExperimentsByCreationTime($userName, $fromTime, $toTime)
+ {
+ $this->send_searchExperimentsByCreationTime($userName, $fromTime, $toTime);
+ return $this->recv_searchExperimentsByCreationTime();
+ }
+
+ public function send_searchExperimentsByCreationTime($userName, $fromTime, $toTime)
+ {
+ $args = new \Airavata\API\Airavata_searchExperimentsByCreationTime_args();
+ $args->userName = $userName;
+ $args->fromTime = $fromTime;
+ $args->toTime = $toTime;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'searchExperimentsByCreationTime', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('searchExperimentsByCreationTime', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_searchExperimentsByCreationTime()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\Airavata_searchExperimentsByCreationTime_result', $this->input_->isStrictRead());
+ 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_searchExperimentsByCreationTime_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("searchExperimentsByCreationTime failed: unknown result");
+ }
+
public function getAllExperimentsInProject($projectId)
{
$this->send_getAllExperimentsInProject($projectId);
@@ -7290,6 +7353,284 @@ class Airavata_searchExperimentsByStatus_result {
}
+class Airavata_searchExperimentsByCreationTime_args {
+ static $_TSPEC;
+
+ public $userName = null;
+ public $fromTime = null;
+ public $toTime = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'userName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'fromTime',
+ 'type' => TType::I64,
+ ),
+ 3 => array(
+ 'var' => 'toTime',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['userName'])) {
+ $this->userName = $vals['userName'];
+ }
+ if (isset($vals['fromTime'])) {
+ $this->fromTime = $vals['fromTime'];
+ }
+ if (isset($vals['toTime'])) {
+ $this->toTime = $vals['toTime'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Airavata_searchExperimentsByCreationTime_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::I64) {
+ $xfer += $input->readI64($this->fromTime);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->toTime);
+ } 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_searchExperimentsByCreationTime_args');
+ if ($this->userName !== null) {
+ $xfer += $output->writeFieldBegin('userName', TType::STRING, 1);
+ $xfer += $output->writeString($this->userName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->fromTime !== null) {
+ $xfer += $output->writeFieldBegin('fromTime', TType::I64, 2);
+ $xfer += $output->writeI64($this->fromTime);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->toTime !== null) {
+ $xfer += $output->writeFieldBegin('toTime', TType::I64, 3);
+ $xfer += $output->writeI64($this->toTime);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class Airavata_searchExperimentsByCreationTime_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_searchExperimentsByCreationTime_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();
+ $_size49 = 0;
+ $_etype52 = 0;
+ $xfer += $input->readListBegin($_etype52, $_size49);
+ for ($_i53 = 0; $_i53 < $_size49; ++$_i53)
+ {
+ $elem54 = null;
+ $elem54 = new \Airavata\Model\Workspace\Experiment\ExperimentSummary();
+ $xfer += $elem54->read($input);
+ $this->success []= $elem54;
+ }
+ $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_searchExperimentsByCreationTime_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 $iter55)
+ {
+ $xfer += $iter55->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;
@@ -7446,15 +7787,15 @@ class Airavata_getAllExperimentsInProject_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 {
@@ -7514,9 +7855,9 @@ class Airavata_getAllExperimentsInProject_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();
@@ -7697,15 +8038,15 @@ class Airavata_getAllUserExperiments_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\Experiment();
- $xfer += $elem61->read($input);
- $this->success []= $elem61;
+ $elem68 = null;
+ $elem68 = new \Airavata\Model\Workspace\Experiment\Experiment();
+ $xfer += $elem68->read($input);
+ $this->success []= $elem68;
}
$xfer += $input->readListEnd();
} else {
@@ -7757,9 +8098,9 @@ class Airavata_getAllUserExperiments_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();
@@ -9614,15 +9955,15 @@ class Airavata_getExperimentOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size63 = 0;
- $_etype66 = 0;
- $xfer += $input->readListBegin($_etype66, $_size63);
- for ($_i67 = 0; $_i67 < $_size63; ++$_i67)
+ $_size70 = 0;
+ $_etype73 = 0;
+ $xfer += $input->readListBegin($_etype73, $_size70);
+ for ($_i74 = 0; $_i74 < $_size70; ++$_i74)
{
- $elem68 = null;
- $elem68 = new \Airavata\Model\Workspace\Experiment\DataObjectType();
- $xfer += $elem68->read($input);
- $this->success []= $elem68;
+ $elem75 = null;
+ $elem75 = new \Airavata\Model\Workspace\Experiment\DataObjectType();
+ $xfer += $elem75->read($input);
+ $this->success []= $elem75;
}
$xfer += $input->readListEnd();
} else {
@@ -9650,9 +9991,9 @@ class Airavata_getExperimentOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter69)
+ foreach ($this->success as $iter76)
{
- $xfer += $iter69->write($output);
+ $xfer += $iter76->write($output);
}
}
$output->writeListEnd();
@@ -9790,18 +10131,18 @@ class Airavata_getJobStatuses_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size70 = 0;
- $_ktype71 = 0;
- $_vtype72 = 0;
- $xfer += $input->readMapBegin($_ktype71, $_vtype72, $_size70);
- for ($_i74 = 0; $_i74 < $_size70; ++$_i74)
+ $_size77 = 0;
+ $_ktype78 = 0;
+ $_vtype79 = 0;
+ $xfer += $input->readMapBegin($_ktype78, $_vtype79, $_size77);
+ for ($_i81 = 0; $_i81 < $_size77; ++$_i81)
{
- $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;
+ $key82 = '';
+ $val83 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $input->readString($key82);
+ $val83 = new \Airavata\Model\Workspace\Experiment\JobStatus();
+ $xfer += $val83->read($input);
+ $this->success[$key82] = $val83;
}
$xfer += $input->readMapEnd();
} else {
@@ -9829,10 +10170,10 @@ class Airavata_getJobStatuses_result {
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter77 => $viter78)
+ foreach ($this->success as $kiter84 => $viter85)
{
- $xfer += $output->writeString($kiter77);
- $xfer += $viter78->write($output);
+ $xfer += $output->writeString($kiter84);
+ $xfer += $viter85->write($output);
}
}
$output->writeMapEnd();
@@ -12206,14 +12547,14 @@ class Airavata_getAppModuleDeployedResources_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size79 = 0;
- $_etype82 = 0;
- $xfer += $input->readListBegin($_etype82, $_size79);
- for ($_i83 = 0; $_i83 < $_size79; ++$_i83)
+ $_size86 = 0;
+ $_etype89 = 0;
+ $xfer += $input->readListBegin($_etype89, $_size86);
+ for ($_i90 = 0; $_i90 < $_size86; ++$_i90)
{
- $elem84 = null;
- $xfer += $input->readString($elem84);
- $this->success []= $elem84;
+ $elem91 = null;
+ $xfer += $input->readString($elem91);
+ $this->success []= $elem91;
}
$xfer += $input->readListEnd();
} else {
@@ -12265,9 +12606,9 @@ class Airavata_getAppModuleDeployedResources_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter85)
+ foreach ($this->success as $iter92)
{
- $xfer += $output->writeString($iter85);
+ $xfer += $output->writeString($iter92);
}
}
$output->writeListEnd();
@@ -13299,17 +13640,17 @@ class Airavata_getAllApplicationInterfaceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size86 = 0;
- $_ktype87 = 0;
- $_vtype88 = 0;
- $xfer += $input->readMapBegin($_ktype87, $_vtype88, $_size86);
- for ($_i90 = 0; $_i90 < $_size86; ++$_i90)
+ $_size93 = 0;
+ $_ktype94 = 0;
+ $_vtype95 = 0;
+ $xfer += $input->readMapBegin($_ktype94, $_vtype95, $_size93);
+ for ($_i97 = 0; $_i97 < $_size93; ++$_i97)
{
- $key91 = '';
- $val92 = '';
- $xfer += $input->readString($key91);
- $xfer += $input->readString($val92);
- $this->success[$key91] = $val92;
+ $key98 = '';
+ $val99 = '';
+ $xfer += $input->readString($key98);
+ $xfer += $input->readString($val99);
+ $this->success[$key98] = $val99;
}
$xfer += $input->readMapEnd();
} else {
@@ -13361,10 +13702,10 @@ class Airavata_getAllApplicationInterfaceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter93 => $viter94)
+ foreach ($this->success as $kiter100 => $viter101)
{
- $xfer += $output->writeString($kiter93);
- $xfer += $output->writeString($viter94);
+ $xfer += $output->writeString($kiter100);
+ $xfer += $output->writeString($viter101);
}
}
$output->writeMapEnd();
@@ -13518,15 +13859,15 @@ class Airavata_getAllApplicationInterfaces_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\ApplicationInterfaceDescription();
- $xfer += $elem100->read($input);
- $this->success []= $elem100;
+ $elem107 = null;
+ $elem107 = new \Airavata\Model\AppCatalog\AppInterface\ApplicationInterfaceDescription();
+ $xfer += $elem107->read($input);
+ $this->success []= $elem107;
}
$xfer += $input->readListEnd();
} else {
@@ -13578,9 +13919,9 @@ class Airavata_getAllApplicationInterfaces_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();
@@ -13756,15 +14097,15 @@ class Airavata_getApplicationInputs_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\InputDataObjectType();
- $xfer += $elem107->read($input);
- $this->success []= $elem107;
+ $elem114 = null;
+ $elem114 = new \Airavata\Model\AppCatalog\AppInterface\InputDataObjectType();
+ $xfer += $elem114->read($input);
+ $this->success []= $elem114;
}
$xfer += $input->readListEnd();
} else {
@@ -13816,9 +14157,9 @@ class Airavata_getApplicationInputs_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();
@@ -13994,15 +14335,15 @@ class Airavata_getApplicationOutputs_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size109 = 0;
- $_etype112 = 0;
- $xfer += $input->readListBegin($_etype112, $_size109);
- for ($_i113 = 0; $_i113 < $_size109; ++$_i113)
+ $_size116 = 0;
+ $_etype119 = 0;
+ $xfer += $input->readListBegin($_etype119, $_size116);
+ for ($_i120 = 0; $_i120 < $_size116; ++$_i120)
{
- $elem114 = null;
- $elem114 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
- $xfer += $elem114->read($input);
- $this->success []= $elem114;
+ $elem121 = null;
+ $elem121 = new \Airavata\Model\AppCatalog\AppInterface\OutputDataObjectType();
+ $xfer += $elem121->read($input);
+ $this->success []= $elem121;
}
$xfer += $input->readListEnd();
} else {
@@ -14054,9 +14395,9 @@ class Airavata_getApplicationOutputs_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter115)
+ foreach ($this->success as $iter122)
{
- $xfer += $iter115->write($output);
+ $xfer += $iter122->write($output);
}
}
$output->writeListEnd();
@@ -14235,17 +14576,17 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size116 = 0;
- $_ktype117 = 0;
- $_vtype118 = 0;
- $xfer += $input->readMapBegin($_ktype117, $_vtype118, $_size116);
- for ($_i120 = 0; $_i120 < $_size116; ++$_i120)
+ $_size123 = 0;
+ $_ktype124 = 0;
+ $_vtype125 = 0;
+ $xfer += $input->readMapBegin($_ktype124, $_vtype125, $_size123);
+ for ($_i127 = 0; $_i127 < $_size123; ++$_i127)
{
- $key121 = '';
- $val122 = '';
- $xfer += $input->readString($key121);
- $xfer += $input->readString($val122);
- $this->success[$key121] = $val122;
+ $key128 = '';
+ $val129 = '';
+ $xfer += $input->readString($key128);
+ $xfer += $input->readString($val129);
+ $this->success[$key128] = $val129;
}
$xfer += $input->readMapEnd();
} else {
@@ -14297,10 +14638,10 @@ class Airavata_getAvailableAppInterfaceComputeResources_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter123 => $viter124)
+ foreach ($this->success as $kiter130 => $viter131)
{
- $xfer += $output->writeString($kiter123);
- $xfer += $output->writeString($viter124);
+ $xfer += $output->writeString($kiter130);
+ $xfer += $output->writeString($viter131);
}
}
$output->writeMapEnd();
@@ -14887,17 +15228,17 @@ class Airavata_getAllComputeResourceNames_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size125 = 0;
- $_ktype126 = 0;
- $_vtype127 = 0;
- $xfer += $input->readMapBegin($_ktype126, $_vtype127, $_size125);
- for ($_i129 = 0; $_i129 < $_size125; ++$_i129)
+ $_size132 = 0;
+ $_ktype133 = 0;
+ $_vtype134 = 0;
+ $xfer += $input->readMapBegin($_ktype133, $_vtype134, $_size132);
+ for ($_i136 = 0; $_i136 < $_size132; ++$_i136)
{
- $key130 = '';
- $val131 = '';
- $xfer += $input->readString($key130);
- $xfer += $input->readString($val131);
- $this->success[$key130] = $val131;
+ $key137 = '';
+ $val138 = '';
+ $xfer += $input->readString($key137);
+ $xfer += $input->readString($val138);
+ $this->success[$key137] = $val138;
}
$xfer += $input->readMapEnd();
} else {
@@ -14949,10 +15290,10 @@ class Airavata_getAllComputeResourceNames_result {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter132 => $viter133)
+ foreach ($this->success as $kiter139 => $viter140)
{
- $xfer += $output->writeString($kiter132);
- $xfer += $output->writeString($viter133);
+ $xfer += $output->writeString($kiter139);
+ $xfer += $output->writeString($viter140);
}
}
$output->writeMapEnd();
@@ -18877,17 +19218,17 @@ class Airavata_changeJobSubmissionPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->jobSubmissionPriorityMap = array();
- $_size134 = 0;
- $_ktype135 = 0;
- $_vtype136 = 0;
- $xfer += $input->readMapBegin($_ktype135, $_vtype136, $_size134);
- for ($_i138 = 0; $_i138 < $_size134; ++$_i138)
+ $_size141 = 0;
+ $_ktype142 = 0;
+ $_vtype143 = 0;
+ $xfer += $input->readMapBegin($_ktype142, $_vtype143, $_size141);
+ for ($_i145 = 0; $_i145 < $_size141; ++$_i145)
{
- $key139 = '';
- $val140 = 0;
- $xfer += $input->readString($key139);
- $xfer += $input->readI32($val140);
- $this->jobSubmissionPriorityMap[$key139] = $val140;
+ $key146 = '';
+ $val147 = 0;
+ $xfer += $input->readString($key146);
+ $xfer += $input->readI32($val147);
+ $this->jobSubmissionPriorityMap[$key146] = $val147;
}
$xfer += $input->readMapEnd();
} else {
@@ -18915,10 +19256,10 @@ class Airavata_changeJobSubmissionPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionPriorityMap));
{
- foreach ($this->jobSubmissionPriorityMap as $kiter141 => $viter142)
+ foreach ($this->jobSubmissionPriorityMap as $kiter148 => $viter149)
{
- $xfer += $output->writeString($kiter141);
- $xfer += $output->writeI32($viter142);
+ $xfer += $output->writeString($kiter148);
+ $xfer += $output->writeI32($viter149);
}
}
$output->writeMapEnd();
@@ -19121,17 +19462,17 @@ class Airavata_changeDataMovementPriorities_args {
case 1:
if ($ftype == TType::MAP) {
$this->dataMovementPriorityMap = array();
- $_size143 = 0;
- $_ktype144 = 0;
- $_vtype145 = 0;
- $xfer += $input->readMapBegin($_ktype144, $_vtype145, $_size143);
- for ($_i147 = 0; $_i147 < $_size143; ++$_i147)
+ $_size150 = 0;
+ $_ktype151 = 0;
+ $_vtype152 = 0;
+ $xfer += $input->readMapBegin($_ktype151, $_vtype152, $_size150);
+ for ($_i154 = 0; $_i154 < $_size150; ++$_i154)
{
- $key148 = '';
- $val149 = 0;
- $xfer += $input->readString($key148);
- $xfer += $input->readI32($val149);
- $this->dataMovementPriorityMap[$key148] = $val149;
+ $key155 = '';
+ $val156 = 0;
+ $xfer += $input->readString($key155);
+ $xfer += $input->readI32($val156);
+ $this->dataMovementPriorityMap[$key155] = $val156;
}
$xfer += $input->readMapEnd();
} else {
@@ -19159,10 +19500,10 @@ class Airavata_changeDataMovementPriorities_args {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementPriorityMap));
{
- foreach ($this->dataMovementPriorityMap as $kiter150 => $viter151)
+ foreach ($this->dataMovementPriorityMap as $kiter157 => $viter158)
{
- $xfer += $output->writeString($kiter150);
- $xfer += $output->writeI32($viter151);
+ $xfer += $output->writeString($kiter157);
+ $xfer += $output->writeI32($viter158);
}
}
$output->writeMapEnd();
@@ -21246,15 +21587,15 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size152 = 0;
- $_etype155 = 0;
- $xfer += $input->readListBegin($_etype155, $_size152);
- for ($_i156 = 0; $_i156 < $_size152; ++$_i156)
+ $_size159 = 0;
+ $_etype162 = 0;
+ $xfer += $input->readListBegin($_etype162, $_size159);
+ for ($_i163 = 0; $_i163 < $_size159; ++$_i163)
{
- $elem157 = null;
- $elem157 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
- $xfer += $elem157->read($input);
- $this->success []= $elem157;
+ $elem164 = null;
+ $elem164 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $elem164->read($input);
+ $this->success []= $elem164;
}
$xfer += $input->readListEnd();
} else {
@@ -21306,9 +21647,9 @@ class Airavata_getAllGatewayComputeResourcePreferences_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter158)
+ foreach ($this->success as $iter165)
{
- $xfer += $iter158->write($output);
+ $xfer += $iter165->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 7cfb504..c191f91 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
@@ -63,10 +63,16 @@ 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());
- List<ExperimentSummary> experiments = searchExperimentsByStatus(airavata, "admin", ExperimentState.FAILED);
+ Calendar cal1 = Calendar.getInstance();
+ cal1.add(Calendar.DATE, -1);
+ Long from = cal1.getTimeInMillis();
+ Calendar cal2 = Calendar.getInstance();
+ Long to = cal2.getTimeInMillis();
+
+ List<ExperimentSummary> experiments = searchExperimentsByDate(airavata, "admin", from, to);
for (ExperimentSummary experimentSummary : experiments){
System.out.println(experimentSummary.getExperimentID());
- System.out.println(experimentSummary.getExperimentStatus().getExperimentState().toString());
+// System.out.println(experimentSummary.getExperimentStatus().getExperimentState().toString());
}
// getAllComputeResources(airavata);
// getAppModule(airavata, "amber_c476de64-ca5c-415a-94e9-b77fbe67b806");
@@ -152,6 +158,22 @@ public class TestCreateLaunchExperiment {
return null;
}
+ public static List<ExperimentSummary> searchExperimentsByDate (Airavata.Client client, String user, Long from, Long to){
+ try {
+ return client.searchExperimentsByCreationTime(user, from, to);
+ } 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/9c1f44d0/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 441d1eb..631747b 100644
--- a/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
+++ b/airavata-api/thrift-interface-descriptions/airavataAPI.thrift
@@ -155,7 +155,7 @@ service Airavata {
2: airavataErrors.AiravataClientException ace,
3: airavataErrors.AiravataSystemException ase)
- /**
+ /**
* Search Experiments by experiment status
*
*/
@@ -164,6 +164,15 @@ service Airavata {
2: airavataErrors.AiravataClientException ace,
3: airavataErrors.AiravataSystemException ase)
+ /**
+ * Search Experiments by experiment status
+ *
+ */
+ list<experimentModel.ExperimentSummary> searchExperimentsByCreationTime (1: required string userName, 2: required i64 fromTime, 3: required i64 toTime)
+ 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/9c1f44d0/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 f6968ae..b8f7b0d 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
@@ -36,6 +36,7 @@ import org.apache.airavata.registry.cpi.utils.StatusType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.sql.Timestamp;
import java.util.*;
public class ExperimentRegistry {
@@ -2637,6 +2638,8 @@ public class ExperimentRegistry {
Map<String, String> fil = new HashMap<String, String>();
if (filters != null && filters.size() != 0){
List<ExperimentSummary> experimentSummaries = new ArrayList<ExperimentSummary>();
+ long fromTime = 0;
+ long toTime = 0;
try {
for (String field : filters.keySet()){
if (field.equals(Constants.FieldConstants.ExperimentConstants.EXPERIMENT_NAME)){
@@ -2647,8 +2650,15 @@ public class ExperimentRegistry {
fil.put(AbstractResource.ExperimentConstants.DESCRIPTION, filters.get(field));
}else if (field.equals(Constants.FieldConstants.ExperimentConstants.EXPERIMENT_STATUS)){
return searchExperimentsByStatus(ExperimentState.valueOf(filters.get(field)));
+ }else if (field.equals(Constants.FieldConstants.ExperimentConstants.FROM_DATE)){
+ fromTime = Long.parseLong(filters.get(field));
+ }else if (field.equals(Constants.FieldConstants.ExperimentConstants.TO_DATE)){
+ toTime = Long.parseLong(filters.get(field));
}
}
+ if (fromTime != 0 && toTime != 0){
+ return searchExperimentsByCreationTime(new Timestamp(fromTime), new Timestamp(toTime));
+ }
List<ExperimentResource> experimentResources = workerResource.searchExperiments(fil);
if (experimentResources != null && !experimentResources.isEmpty()){
for (ExperimentResource ex : experimentResources){
@@ -2682,4 +2692,21 @@ public class ExperimentRegistry {
}
}
+ public List<ExperimentSummary> searchExperimentsByCreationTime (Timestamp fromTime, Timestamp toTime) throws RegistryException {
+ try {
+ List<ExperimentSummary> experimentSummaries = new ArrayList<ExperimentSummary>();
+ List<ExperimentResource> experimentResources = workerResource.searchExperimentsByCreationTime(fromTime, toTime);
+ 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/9c1f44d0/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 d9790c0..63939ca 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
@@ -33,6 +33,7 @@ import org.apache.airavata.registry.cpi.RegistryException;
import javax.persistence.EntityManager;
import javax.persistence.Query;
+import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@@ -655,6 +656,38 @@ public class WorkerResource extends AbstractResource {
return result;
}
+ public List<ExperimentResource> searchExperimentsByCreationTime (Timestamp fromTime, Timestamp toTime) throws RegistryException{
+ List<ExperimentResource> result = new ArrayList<ExperimentResource>();
+ EntityManager em = null;
+ try {
+ String query = "SELECT e FROM Experiment e " +
+ "WHERE e.creationTime > '" + fromTime + "' " +
+ "AND e.creationTime <'" + toTime + "'";
+ 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
http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/modules/registry/registry-cpi/src/main/java/org/apache/airavata/registry/cpi/utils/Constants.java
----------------------------------------------------------------------
diff --git a/modules/registry/registry-cpi/src/main/java/org/apache/airavata/registry/cpi/utils/Constants.java b/modules/registry/registry-cpi/src/main/java/org/apache/airavata/registry/cpi/utils/Constants.java
index 7c573d2..f7ef9ff 100644
--- a/modules/registry/registry-cpi/src/main/java/org/apache/airavata/registry/cpi/utils/Constants.java
+++ b/modules/registry/registry-cpi/src/main/java/org/apache/airavata/registry/cpi/utils/Constants.java
@@ -49,6 +49,8 @@ public class Constants {
public static final String STATE_CHANGE_LIST = "stateChangeList";
public static final String WORKFLOW_NODE_LIST = "workflowNodeDetailsList";
public static final String ERROR_DETAIL_LIST = "errors";
+ public static final String FROM_DATE = "fromDate";
+ public static final String TO_DATE = "toDate";
}
[2/4] fixing AIRAVATA-1361
Posted by ch...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 6aac2e5..383d43e 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
@@ -2855,6 +2855,301 @@ uint32_t Airavata_searchExperimentsByStatus_presult::read(::apache::thrift::prot
return xfer;
}
+uint32_t Airavata_searchExperimentsByCreationTime_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_fromTime = false;
+ bool isset_toTime = 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_I64) {
+ xfer += iprot->readI64(this->fromTime);
+ isset_fromTime = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->toTime);
+ isset_toTime = 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_fromTime)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_toTime)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByCreationTime_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchExperimentsByCreationTime_args");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->userName);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("fromTime", ::apache::thrift::protocol::T_I64, 2);
+ xfer += oprot->writeI64(this->fromTime);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("toTime", ::apache::thrift::protocol::T_I64, 3);
+ xfer += oprot->writeI64(this->toTime);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByCreationTime_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Airavata_searchExperimentsByCreationTime_pargs");
+
+ xfer += oprot->writeFieldBegin("userName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString((*(this->userName)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("fromTime", ::apache::thrift::protocol::T_I64, 2);
+ xfer += oprot->writeI64((*(this->fromTime)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("toTime", ::apache::thrift::protocol::T_I64, 3);
+ xfer += oprot->writeI64((*(this->toTime)));
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+uint32_t Airavata_searchExperimentsByCreationTime_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 _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[_i82].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_searchExperimentsByCreationTime_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+
+ uint32_t xfer = 0;
+
+ xfer += oprot->writeStructBegin("Airavata_searchExperimentsByCreationTime_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 _iter83;
+ for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83)
+ {
+ xfer += (*_iter83).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_searchExperimentsByCreationTime_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 _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))[_i88].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;
@@ -2948,14 +3243,14 @@ uint32_t Airavata_getAllExperimentsInProject_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ 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[_i82].read(iprot);
+ xfer += this->success[_i93].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3018,10 +3313,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 _iter83;
- for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter94;
+ for (_iter94 = this->success.begin(); _iter94 != this->success.end(); ++_iter94)
{
- xfer += (*_iter83).write(oprot);
+ xfer += (*_iter94).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3072,14 +3367,14 @@ uint32_t Airavata_getAllExperimentsInProject_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ 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))[_i88].read(iprot);
+ xfer += (*(this->success))[_i99].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3225,14 +3520,14 @@ uint32_t Airavata_getAllUserExperiments_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ 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[_i93].read(iprot);
+ xfer += this->success[_i104].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -3287,10 +3582,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 _iter94;
- for (_iter94 = this->success.begin(); _iter94 != this->success.end(); ++_iter94)
+ std::vector< ::apache::airavata::model::workspace::experiment::Experiment> ::const_iterator _iter105;
+ for (_iter105 = this->success.begin(); _iter105 != this->success.end(); ++_iter105)
{
- xfer += (*_iter94).write(oprot);
+ xfer += (*_iter105).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3337,14 +3632,14 @@ uint32_t Airavata_getAllUserExperiments_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ 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))[_i99].read(iprot);
+ xfer += (*(this->success))[_i110].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -5256,14 +5551,14 @@ uint32_t Airavata_getExperimentOutputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ uint32_t _size111;
+ ::apache::thrift::protocol::TType _etype114;
+ xfer += iprot->readListBegin(_etype114, _size111);
+ this->success.resize(_size111);
+ uint32_t _i115;
+ for (_i115 = 0; _i115 < _size111; ++_i115)
{
- xfer += this->success[_i104].read(iprot);
+ xfer += this->success[_i115].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -5294,10 +5589,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 _iter105;
- for (_iter105 = this->success.begin(); _iter105 != this->success.end(); ++_iter105)
+ std::vector< ::apache::airavata::model::workspace::experiment::DataObjectType> ::const_iterator _iter116;
+ for (_iter116 = this->success.begin(); _iter116 != this->success.end(); ++_iter116)
{
- xfer += (*_iter105).write(oprot);
+ xfer += (*_iter116).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -5332,14 +5627,14 @@ uint32_t Airavata_getExperimentOutputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size117;
+ ::apache::thrift::protocol::TType _etype120;
+ xfer += iprot->readListBegin(_etype120, _size117);
+ (*(this->success)).resize(_size117);
+ uint32_t _i121;
+ for (_i121 = 0; _i121 < _size117; ++_i121)
{
- xfer += (*(this->success))[_i110].read(iprot);
+ xfer += (*(this->success))[_i121].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -5453,17 +5748,17 @@ uint32_t Airavata_getJobStatuses_result::read(::apache::thrift::protocol::TProto
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- 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)
+ uint32_t _size122;
+ ::apache::thrift::protocol::TType _ktype123;
+ ::apache::thrift::protocol::TType _vtype124;
+ xfer += iprot->readMapBegin(_ktype123, _vtype124, _size122);
+ uint32_t _i126;
+ for (_i126 = 0; _i126 < _size122; ++_i126)
{
- std::string _key116;
- xfer += iprot->readString(_key116);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val117 = this->success[_key116];
- xfer += _val117.read(iprot);
+ std::string _key127;
+ xfer += iprot->readString(_key127);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val128 = this->success[_key127];
+ xfer += _val128.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -5494,11 +5789,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 _iter118;
- for (_iter118 = this->success.begin(); _iter118 != this->success.end(); ++_iter118)
+ std::map<std::string, ::apache::airavata::model::workspace::experiment::JobStatus> ::const_iterator _iter129;
+ for (_iter129 = this->success.begin(); _iter129 != this->success.end(); ++_iter129)
{
- xfer += oprot->writeString(_iter118->first);
- xfer += _iter118->second.write(oprot);
+ xfer += oprot->writeString(_iter129->first);
+ xfer += _iter129->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -5533,17 +5828,17 @@ uint32_t Airavata_getJobStatuses_presult::read(::apache::thrift::protocol::TProt
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size130;
+ ::apache::thrift::protocol::TType _ktype131;
+ ::apache::thrift::protocol::TType _vtype132;
+ xfer += iprot->readMapBegin(_ktype131, _vtype132, _size130);
+ uint32_t _i134;
+ for (_i134 = 0; _i134 < _size130; ++_i134)
{
- std::string _key124;
- xfer += iprot->readString(_key124);
- ::apache::airavata::model::workspace::experiment::JobStatus& _val125 = (*(this->success))[_key124];
- xfer += _val125.read(iprot);
+ std::string _key135;
+ xfer += iprot->readString(_key135);
+ ::apache::airavata::model::workspace::experiment::JobStatus& _val136 = (*(this->success))[_key135];
+ xfer += _val136.read(iprot);
}
xfer += iprot->readMapEnd();
}
@@ -7975,14 +8270,14 @@ uint32_t Airavata_getAppModuleDeployedResources_result::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ uint32_t _size137;
+ ::apache::thrift::protocol::TType _etype140;
+ xfer += iprot->readListBegin(_etype140, _size137);
+ this->success.resize(_size137);
+ uint32_t _i141;
+ for (_i141 = 0; _i141 < _size137; ++_i141)
{
- xfer += iprot->readString(this->success[_i130]);
+ xfer += iprot->readString(this->success[_i141]);
}
xfer += iprot->readListEnd();
}
@@ -8037,10 +8332,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 _iter131;
- for (_iter131 = this->success.begin(); _iter131 != this->success.end(); ++_iter131)
+ std::vector<std::string> ::const_iterator _iter142;
+ for (_iter142 = this->success.begin(); _iter142 != this->success.end(); ++_iter142)
{
- xfer += oprot->writeString((*_iter131));
+ xfer += oprot->writeString((*_iter142));
}
xfer += oprot->writeListEnd();
}
@@ -8087,14 +8382,14 @@ uint32_t Airavata_getAppModuleDeployedResources_presult::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size143;
+ ::apache::thrift::protocol::TType _etype146;
+ xfer += iprot->readListBegin(_etype146, _size143);
+ (*(this->success)).resize(_size143);
+ uint32_t _i147;
+ for (_i147 = 0; _i147 < _size143; ++_i147)
{
- xfer += iprot->readString((*(this->success))[_i136]);
+ xfer += iprot->readString((*(this->success))[_i147]);
}
xfer += iprot->readListEnd();
}
@@ -9127,17 +9422,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_result::read(::apache::thrift:
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- 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)
+ uint32_t _size148;
+ ::apache::thrift::protocol::TType _ktype149;
+ ::apache::thrift::protocol::TType _vtype150;
+ xfer += iprot->readMapBegin(_ktype149, _vtype150, _size148);
+ uint32_t _i152;
+ for (_i152 = 0; _i152 < _size148; ++_i152)
{
- std::string _key142;
- xfer += iprot->readString(_key142);
- std::string& _val143 = this->success[_key142];
- xfer += iprot->readString(_val143);
+ std::string _key153;
+ xfer += iprot->readString(_key153);
+ std::string& _val154 = this->success[_key153];
+ xfer += iprot->readString(_val154);
}
xfer += iprot->readMapEnd();
}
@@ -9192,11 +9487,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 _iter144;
- for (_iter144 = this->success.begin(); _iter144 != this->success.end(); ++_iter144)
+ std::map<std::string, std::string> ::const_iterator _iter155;
+ for (_iter155 = this->success.begin(); _iter155 != this->success.end(); ++_iter155)
{
- xfer += oprot->writeString(_iter144->first);
- xfer += oprot->writeString(_iter144->second);
+ xfer += oprot->writeString(_iter155->first);
+ xfer += oprot->writeString(_iter155->second);
}
xfer += oprot->writeMapEnd();
}
@@ -9243,17 +9538,17 @@ uint32_t Airavata_getAllApplicationInterfaceNames_presult::read(::apache::thrift
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size156;
+ ::apache::thrift::protocol::TType _ktype157;
+ ::apache::thrift::protocol::TType _vtype158;
+ xfer += iprot->readMapBegin(_ktype157, _vtype158, _size156);
+ uint32_t _i160;
+ for (_i160 = 0; _i160 < _size156; ++_i160)
{
- std::string _key150;
- xfer += iprot->readString(_key150);
- std::string& _val151 = (*(this->success))[_key150];
- xfer += iprot->readString(_val151);
+ std::string _key161;
+ xfer += iprot->readString(_key161);
+ std::string& _val162 = (*(this->success))[_key161];
+ xfer += iprot->readString(_val162);
}
xfer += iprot->readMapEnd();
}
@@ -9367,14 +9662,14 @@ uint32_t Airavata_getAllApplicationInterfaces_result::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ 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[_i156].read(iprot);
+ xfer += this->success[_i167].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9429,10 +9724,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 _iter157;
- for (_iter157 = this->success.begin(); _iter157 != this->success.end(); ++_iter157)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::ApplicationInterfaceDescription> ::const_iterator _iter168;
+ for (_iter168 = this->success.begin(); _iter168 != this->success.end(); ++_iter168)
{
- xfer += (*_iter157).write(oprot);
+ xfer += (*_iter168).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9479,14 +9774,14 @@ uint32_t Airavata_getAllApplicationInterfaces_presult::read(::apache::thrift::pr
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ 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))[_i162].read(iprot);
+ xfer += (*(this->success))[_i173].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9624,14 +9919,14 @@ uint32_t Airavata_getApplicationInputs_result::read(::apache::thrift::protocol::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ 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[_i167].read(iprot);
+ xfer += this->success[_i178].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9686,10 +9981,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 _iter168;
- for (_iter168 = this->success.begin(); _iter168 != this->success.end(); ++_iter168)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::InputDataObjectType> ::const_iterator _iter179;
+ for (_iter179 = this->success.begin(); _iter179 != this->success.end(); ++_iter179)
{
- xfer += (*_iter168).write(oprot);
+ xfer += (*_iter179).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9736,14 +10031,14 @@ uint32_t Airavata_getApplicationInputs_presult::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ 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))[_i173].read(iprot);
+ xfer += (*(this->success))[_i184].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9881,14 +10176,14 @@ uint32_t Airavata_getApplicationOutputs_result::read(::apache::thrift::protocol:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ uint32_t _size185;
+ ::apache::thrift::protocol::TType _etype188;
+ xfer += iprot->readListBegin(_etype188, _size185);
+ this->success.resize(_size185);
+ uint32_t _i189;
+ for (_i189 = 0; _i189 < _size185; ++_i189)
{
- xfer += this->success[_i178].read(iprot);
+ xfer += this->success[_i189].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9943,10 +10238,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 _iter179;
- for (_iter179 = this->success.begin(); _iter179 != this->success.end(); ++_iter179)
+ std::vector< ::apache::airavata::model::appcatalog::appinterface::OutputDataObjectType> ::const_iterator _iter190;
+ for (_iter190 = this->success.begin(); _iter190 != this->success.end(); ++_iter190)
{
- xfer += (*_iter179).write(oprot);
+ xfer += (*_iter190).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9993,14 +10288,14 @@ uint32_t Airavata_getApplicationOutputs_presult::read(::apache::thrift::protocol
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size191;
+ ::apache::thrift::protocol::TType _etype194;
+ xfer += iprot->readListBegin(_etype194, _size191);
+ (*(this->success)).resize(_size191);
+ uint32_t _i195;
+ for (_i195 = 0; _i195 < _size191; ++_i195)
{
- xfer += (*(this->success))[_i184].read(iprot);
+ xfer += (*(this->success))[_i195].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10138,17 +10433,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_result::read(::apache
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- 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)
+ 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)
{
- std::string _key190;
- xfer += iprot->readString(_key190);
- std::string& _val191 = this->success[_key190];
- xfer += iprot->readString(_val191);
+ std::string _key201;
+ xfer += iprot->readString(_key201);
+ std::string& _val202 = this->success[_key201];
+ xfer += iprot->readString(_val202);
}
xfer += iprot->readMapEnd();
}
@@ -10203,11 +10498,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 _iter192;
- for (_iter192 = this->success.begin(); _iter192 != this->success.end(); ++_iter192)
+ std::map<std::string, std::string> ::const_iterator _iter203;
+ for (_iter203 = this->success.begin(); _iter203 != this->success.end(); ++_iter203)
{
- xfer += oprot->writeString(_iter192->first);
- xfer += oprot->writeString(_iter192->second);
+ xfer += oprot->writeString(_iter203->first);
+ xfer += oprot->writeString(_iter203->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10254,17 +10549,17 @@ uint32_t Airavata_getAvailableAppInterfaceComputeResources_presult::read(::apach
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size204;
+ ::apache::thrift::protocol::TType _ktype205;
+ ::apache::thrift::protocol::TType _vtype206;
+ xfer += iprot->readMapBegin(_ktype205, _vtype206, _size204);
+ uint32_t _i208;
+ for (_i208 = 0; _i208 < _size204; ++_i208)
{
- std::string _key198;
- xfer += iprot->readString(_key198);
- std::string& _val199 = (*(this->success))[_key198];
- xfer += iprot->readString(_val199);
+ std::string _key209;
+ xfer += iprot->readString(_key209);
+ std::string& _val210 = (*(this->success))[_key209];
+ xfer += iprot->readString(_val210);
}
xfer += iprot->readMapEnd();
}
@@ -10828,17 +11123,17 @@ uint32_t Airavata_getAllComputeResourceNames_result::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- 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)
+ uint32_t _size211;
+ ::apache::thrift::protocol::TType _ktype212;
+ ::apache::thrift::protocol::TType _vtype213;
+ xfer += iprot->readMapBegin(_ktype212, _vtype213, _size211);
+ uint32_t _i215;
+ for (_i215 = 0; _i215 < _size211; ++_i215)
{
- std::string _key205;
- xfer += iprot->readString(_key205);
- std::string& _val206 = this->success[_key205];
- xfer += iprot->readString(_val206);
+ std::string _key216;
+ xfer += iprot->readString(_key216);
+ std::string& _val217 = this->success[_key216];
+ xfer += iprot->readString(_val217);
}
xfer += iprot->readMapEnd();
}
@@ -10893,11 +11188,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 _iter207;
- for (_iter207 = this->success.begin(); _iter207 != this->success.end(); ++_iter207)
+ std::map<std::string, std::string> ::const_iterator _iter218;
+ for (_iter218 = this->success.begin(); _iter218 != this->success.end(); ++_iter218)
{
- xfer += oprot->writeString(_iter207->first);
- xfer += oprot->writeString(_iter207->second);
+ xfer += oprot->writeString(_iter218->first);
+ xfer += oprot->writeString(_iter218->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10944,17 +11239,17 @@ uint32_t Airavata_getAllComputeResourceNames_presult::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size219;
+ ::apache::thrift::protocol::TType _ktype220;
+ ::apache::thrift::protocol::TType _vtype221;
+ xfer += iprot->readMapBegin(_ktype220, _vtype221, _size219);
+ uint32_t _i223;
+ for (_i223 = 0; _i223 < _size219; ++_i223)
{
- std::string _key213;
- xfer += iprot->readString(_key213);
- std::string& _val214 = (*(this->success))[_key213];
- xfer += iprot->readString(_val214);
+ std::string _key224;
+ xfer += iprot->readString(_key224);
+ std::string& _val225 = (*(this->success))[_key224];
+ xfer += iprot->readString(_val225);
}
xfer += iprot->readMapEnd();
}
@@ -15023,17 +15318,17 @@ uint32_t Airavata_changeJobSubmissionPriorities_args::read(::apache::thrift::pro
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->jobSubmissionPriorityMap.clear();
- 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)
+ uint32_t _size226;
+ ::apache::thrift::protocol::TType _ktype227;
+ ::apache::thrift::protocol::TType _vtype228;
+ xfer += iprot->readMapBegin(_ktype227, _vtype228, _size226);
+ uint32_t _i230;
+ for (_i230 = 0; _i230 < _size226; ++_i230)
{
- std::string _key220;
- xfer += iprot->readString(_key220);
- int32_t& _val221 = this->jobSubmissionPriorityMap[_key220];
- xfer += iprot->readI32(_val221);
+ std::string _key231;
+ xfer += iprot->readString(_key231);
+ int32_t& _val232 = this->jobSubmissionPriorityMap[_key231];
+ xfer += iprot->readI32(_val232);
}
xfer += iprot->readMapEnd();
}
@@ -15063,11 +15358,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 _iter222;
- for (_iter222 = this->jobSubmissionPriorityMap.begin(); _iter222 != this->jobSubmissionPriorityMap.end(); ++_iter222)
+ std::map<std::string, int32_t> ::const_iterator _iter233;
+ for (_iter233 = this->jobSubmissionPriorityMap.begin(); _iter233 != this->jobSubmissionPriorityMap.end(); ++_iter233)
{
- xfer += oprot->writeString(_iter222->first);
- xfer += oprot->writeI32(_iter222->second);
+ xfer += oprot->writeString(_iter233->first);
+ xfer += oprot->writeI32(_iter233->second);
}
xfer += oprot->writeMapEnd();
}
@@ -15085,11 +15380,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 _iter223;
- for (_iter223 = (*(this->jobSubmissionPriorityMap)).begin(); _iter223 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter223)
+ std::map<std::string, int32_t> ::const_iterator _iter234;
+ for (_iter234 = (*(this->jobSubmissionPriorityMap)).begin(); _iter234 != (*(this->jobSubmissionPriorityMap)).end(); ++_iter234)
{
- xfer += oprot->writeString(_iter223->first);
- xfer += oprot->writeI32(_iter223->second);
+ xfer += oprot->writeString(_iter234->first);
+ xfer += oprot->writeI32(_iter234->second);
}
xfer += oprot->writeMapEnd();
}
@@ -15281,17 +15576,17 @@ uint32_t Airavata_changeDataMovementPriorities_args::read(::apache::thrift::prot
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->dataMovementPriorityMap.clear();
- 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)
+ uint32_t _size235;
+ ::apache::thrift::protocol::TType _ktype236;
+ ::apache::thrift::protocol::TType _vtype237;
+ xfer += iprot->readMapBegin(_ktype236, _vtype237, _size235);
+ uint32_t _i239;
+ for (_i239 = 0; _i239 < _size235; ++_i239)
{
- std::string _key229;
- xfer += iprot->readString(_key229);
- int32_t& _val230 = this->dataMovementPriorityMap[_key229];
- xfer += iprot->readI32(_val230);
+ std::string _key240;
+ xfer += iprot->readString(_key240);
+ int32_t& _val241 = this->dataMovementPriorityMap[_key240];
+ xfer += iprot->readI32(_val241);
}
xfer += iprot->readMapEnd();
}
@@ -15321,11 +15616,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 _iter231;
- for (_iter231 = this->dataMovementPriorityMap.begin(); _iter231 != this->dataMovementPriorityMap.end(); ++_iter231)
+ std::map<std::string, int32_t> ::const_iterator _iter242;
+ for (_iter242 = this->dataMovementPriorityMap.begin(); _iter242 != this->dataMovementPriorityMap.end(); ++_iter242)
{
- xfer += oprot->writeString(_iter231->first);
- xfer += oprot->writeI32(_iter231->second);
+ xfer += oprot->writeString(_iter242->first);
+ xfer += oprot->writeI32(_iter242->second);
}
xfer += oprot->writeMapEnd();
}
@@ -15343,11 +15638,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 _iter232;
- for (_iter232 = (*(this->dataMovementPriorityMap)).begin(); _iter232 != (*(this->dataMovementPriorityMap)).end(); ++_iter232)
+ std::map<std::string, int32_t> ::const_iterator _iter243;
+ for (_iter243 = (*(this->dataMovementPriorityMap)).begin(); _iter243 != (*(this->dataMovementPriorityMap)).end(); ++_iter243)
{
- xfer += oprot->writeString(_iter232->first);
- xfer += oprot->writeI32(_iter232->second);
+ xfer += oprot->writeString(_iter243->first);
+ xfer += oprot->writeI32(_iter243->second);
}
xfer += oprot->writeMapEnd();
}
@@ -17483,14 +17778,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_result::read(::apache:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- 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)
+ uint32_t _size244;
+ ::apache::thrift::protocol::TType _etype247;
+ xfer += iprot->readListBegin(_etype247, _size244);
+ this->success.resize(_size244);
+ uint32_t _i248;
+ for (_i248 = 0; _i248 < _size244; ++_i248)
{
- xfer += this->success[_i237].read(iprot);
+ xfer += this->success[_i248].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -17545,10 +17840,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 _iter238;
- for (_iter238 = this->success.begin(); _iter238 != this->success.end(); ++_iter238)
+ std::vector< ::apache::airavata::model::appcatalog::gatewayprofile::ComputeResourcePreference> ::const_iterator _iter249;
+ for (_iter249 = this->success.begin(); _iter249 != this->success.end(); ++_iter249)
{
- xfer += (*_iter238).write(oprot);
+ xfer += (*_iter249).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -17595,14 +17890,14 @@ uint32_t Airavata_getAllGatewayComputeResourcePreferences_presult::read(::apache
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- 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)
+ uint32_t _size250;
+ ::apache::thrift::protocol::TType _etype253;
+ xfer += iprot->readListBegin(_etype253, _size250);
+ (*(this->success)).resize(_size250);
+ uint32_t _i254;
+ for (_i254 = 0; _i254 < _size250; ++_i254)
{
- xfer += (*(this->success))[_i243].read(iprot);
+ xfer += (*(this->success))[_i254].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -18898,6 +19193,75 @@ void AiravataClient::recv_searchExperimentsByStatus(std::vector< ::apache::airav
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "searchExperimentsByStatus failed: unknown result");
}
+void AiravataClient::searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime)
+{
+ send_searchExperimentsByCreationTime(userName, fromTime, toTime);
+ recv_searchExperimentsByCreationTime(_return);
+}
+
+void AiravataClient::send_searchExperimentsByCreationTime(const std::string& userName, const int64_t fromTime, const int64_t toTime)
+{
+ int32_t cseqid = 0;
+ oprot_->writeMessageBegin("searchExperimentsByCreationTime", ::apache::thrift::protocol::T_CALL, cseqid);
+
+ Airavata_searchExperimentsByCreationTime_pargs args;
+ args.userName = &userName;
+ args.fromTime = &fromTime;
+ args.toTime = &toTime;
+ args.write(oprot_);
+
+ oprot_->writeMessageEnd();
+ oprot_->getTransport()->writeEnd();
+ oprot_->getTransport()->flush();
+}
+
+void AiravataClient::recv_searchExperimentsByCreationTime(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("searchExperimentsByCreationTime") != 0) {
+ iprot_->skip(::apache::thrift::protocol::T_STRUCT);
+ iprot_->readMessageEnd();
+ iprot_->getTransport()->readEnd();
+ }
+ Airavata_searchExperimentsByCreationTime_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, "searchExperimentsByCreationTime failed: unknown result");
+}
+
void AiravataClient::getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId)
{
send_getAllExperimentsInProject(projectId);
@@ -23902,6 +24266,69 @@ void AiravataProcessor::process_searchExperimentsByStatus(int32_t seqid, ::apach
}
}
+void AiravataProcessor::process_searchExperimentsByCreationTime(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.searchExperimentsByCreationTime", callContext);
+ }
+ ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "Airavata.searchExperimentsByCreationTime");
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->preRead(ctx, "Airavata.searchExperimentsByCreationTime");
+ }
+
+ Airavata_searchExperimentsByCreationTime_args args;
+ args.read(iprot);
+ iprot->readMessageEnd();
+ uint32_t bytes = iprot->getTransport()->readEnd();
+
+ if (this->eventHandler_.get() != NULL) {
+ this->eventHandler_->postRead(ctx, "Airavata.searchExperimentsByCreationTime", bytes);
+ }
+
+ Airavata_searchExperimentsByCreationTime_result result;
+ try {
+ iface_->searchExperimentsByCreationTime(result.success, args.userName, args.fromTime, args.toTime);
+ 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.searchExperimentsByCreationTime");
+ }
+
+ ::apache::thrift::TApplicationException x(e.what());
+ oprot->writeMessageBegin("searchExperimentsByCreationTime", ::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.searchExperimentsByCreationTime");
+ }
+
+ oprot->writeMessageBegin("searchExperimentsByCreationTime", ::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.searchExperimentsByCreationTime", 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/9c1f44d0/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 bd09cc7..727ae9e 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
@@ -43,6 +43,7 @@ class AiravataIf {
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 searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) = 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;
@@ -169,6 +170,9 @@ class AiravataNull : virtual public AiravataIf {
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 searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & /* _return */, const std::string& /* userName */, const int64_t /* fromTime */, const int64_t /* toTime */) {
+ return;
+ }
void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & /* _return */, const std::string& /* projectId */) {
return;
}
@@ -1906,6 +1910,154 @@ class Airavata_searchExperimentsByStatus_presult {
};
+class Airavata_searchExperimentsByCreationTime_args {
+ public:
+
+ Airavata_searchExperimentsByCreationTime_args() : userName(), fromTime(0), toTime(0) {
+ }
+
+ virtual ~Airavata_searchExperimentsByCreationTime_args() throw() {}
+
+ std::string userName;
+ int64_t fromTime;
+ int64_t toTime;
+
+ void __set_userName(const std::string& val) {
+ userName = val;
+ }
+
+ void __set_fromTime(const int64_t val) {
+ fromTime = val;
+ }
+
+ void __set_toTime(const int64_t val) {
+ toTime = val;
+ }
+
+ bool operator == (const Airavata_searchExperimentsByCreationTime_args & rhs) const
+ {
+ if (!(userName == rhs.userName))
+ return false;
+ if (!(fromTime == rhs.fromTime))
+ return false;
+ if (!(toTime == rhs.toTime))
+ return false;
+ return true;
+ }
+ bool operator != (const Airavata_searchExperimentsByCreationTime_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchExperimentsByCreationTime_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class Airavata_searchExperimentsByCreationTime_pargs {
+ public:
+
+
+ virtual ~Airavata_searchExperimentsByCreationTime_pargs() throw() {}
+
+ const std::string* userName;
+ const int64_t* fromTime;
+ const int64_t* toTime;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchExperimentsByCreationTime_result__isset {
+ _Airavata_searchExperimentsByCreationTime_result__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchExperimentsByCreationTime_result__isset;
+
+class Airavata_searchExperimentsByCreationTime_result {
+ public:
+
+ Airavata_searchExperimentsByCreationTime_result() {
+ }
+
+ virtual ~Airavata_searchExperimentsByCreationTime_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_searchExperimentsByCreationTime_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_searchExperimentsByCreationTime_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_searchExperimentsByCreationTime_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Airavata_searchExperimentsByCreationTime_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _Airavata_searchExperimentsByCreationTime_presult__isset {
+ _Airavata_searchExperimentsByCreationTime_presult__isset() : success(false), ire(false), ace(false), ase(false) {}
+ bool success;
+ bool ire;
+ bool ace;
+ bool ase;
+} _Airavata_searchExperimentsByCreationTime_presult__isset;
+
+class Airavata_searchExperimentsByCreationTime_presult {
+ public:
+
+
+ virtual ~Airavata_searchExperimentsByCreationTime_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_searchExperimentsByCreationTime_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+
class Airavata_getAllExperimentsInProject_args {
public:
@@ -10583,6 +10735,9 @@ class AiravataClient : virtual public AiravataIf {
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 searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime);
+ void send_searchExperimentsByCreationTime(const std::string& userName, const int64_t fromTime, const int64_t toTime);
+ void recv_searchExperimentsByCreationTime(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);
@@ -10801,6 +10956,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
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_searchExperimentsByCreationTime(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);
@@ -10879,6 +11035,7 @@ class AiravataProcessor : public ::apache::thrift::TDispatchProcessor {
processMap_["searchExperimentsByDesc"] = &AiravataProcessor::process_searchExperimentsByDesc;
processMap_["searchExperimentsByApplication"] = &AiravataProcessor::process_searchExperimentsByApplication;
processMap_["searchExperimentsByStatus"] = &AiravataProcessor::process_searchExperimentsByStatus;
+ processMap_["searchExperimentsByCreationTime"] = &AiravataProcessor::process_searchExperimentsByCreationTime;
processMap_["getAllExperimentsInProject"] = &AiravataProcessor::process_getAllExperimentsInProject;
processMap_["getAllUserExperiments"] = &AiravataProcessor::process_getAllUserExperiments;
processMap_["createExperiment"] = &AiravataProcessor::process_createExperiment;
@@ -11080,6 +11237,16 @@ class AiravataMultiface : virtual public AiravataIf {
return;
}
+ void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->searchExperimentsByCreationTime(_return, userName, fromTime, toTime);
+ }
+ ifaces_[i]->searchExperimentsByCreationTime(_return, userName, fromTime, toTime);
+ 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/9c1f44d0/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 2106a0b..a9a0b83 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
@@ -94,6 +94,11 @@ class AiravataHandler : virtual public AiravataIf {
printf("searchExperimentsByStatus\n");
}
+ void searchExperimentsByCreationTime(std::vector< ::apache::airavata::model::workspace::experiment::ExperimentSummary> & _return, const std::string& userName, const int64_t fromTime, const int64_t toTime) {
+ // Your implementation goes here
+ printf("searchExperimentsByCreationTime\n");
+ }
+
void getAllExperimentsInProject(std::vector< ::apache::airavata::model::workspace::experiment::Experiment> & _return, const std::string& projectId) {
// Your implementation goes here
printf("getAllExperimentsInProject\n");
[4/4] git commit: fixing AIRAVATA-1361
Posted by ch...@apache.org.
fixing AIRAVATA-1361
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/9c1f44d0
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/9c1f44d0
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/9c1f44d0
Branch: refs/heads/master
Commit: 9c1f44d04b768f4f9d360d71e19aeaaf7c25a218
Parents: 414f2b9
Author: Chathuri Wimalasena <ka...@gmail.com>
Authored: Tue Aug 19 10:43:34 2014 -0400
Committer: Chathuri Wimalasena <ka...@gmail.com>
Committed: Tue Aug 19 10:43:34 2014 -0400
----------------------------------------------------------------------
.../server/handler/AiravataServerHandler.java | 37 +
.../java/org/apache/airavata/api/Airavata.java | 6908 +++++++++++-------
.../main/resources/lib/airavata/Airavata.cpp | 963 ++-
.../src/main/resources/lib/airavata/Airavata.h | 167 +
.../lib/airavata/Airavata_server.skeleton.cpp | 5 +
.../resources/lib/Airavata/API/Airavata.php | 657 +-
.../samples/TestCreateLaunchExperiment.java | 26 +-
.../airavataAPI.thrift | 11 +-
.../registry/jpa/impl/ExperimentRegistry.java | 27 +
.../registry/jpa/resources/WorkerResource.java | 33 +
.../airavata/registry/cpi/utils/Constants.java | 2 +
11 files changed, 5667 insertions(+), 3169 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 32800cd..4e4bab9 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
@@ -538,6 +538,43 @@ public class AiravataServerHandler implements Airavata.Iface, Watcher {
}
}
+ @Override
+ public List<ExperimentSummary> searchExperimentsByCreationTime(String userName, long fromTime, long toTime) 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.FROM_DATE, String.valueOf(fromTime));
+ filters.put(Constants.FieldConstants.ExperimentConstants.TO_DATE, String.valueOf(toTime));
+ 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
*
[3/4] fixing AIRAVATA-1361
Posted by ch...@apache.org.
http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 9e312dc..eb9a6f0 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
@@ -146,6 +146,16 @@ import org.slf4j.LoggerFactory;
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;
/**
+ * Search Experiments by experiment status
+ *
+ *
+ * @param userName
+ * @param fromTime
+ * @param toTime
+ */
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByCreationTime(String userName, long fromTime, long toTime) 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
*
*
@@ -1285,6 +1295,8 @@ 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;
+ public void searchExperimentsByCreationTime(String userName, long fromTime, long toTime, 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;
@@ -1796,6 +1808,40 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "searchExperimentsByStatus failed: unknown result");
}
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByCreationTime(String userName, long fromTime, long toTime) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_searchExperimentsByCreationTime(userName, fromTime, toTime);
+ return recv_searchExperimentsByCreationTime();
+ }
+
+ public void send_searchExperimentsByCreationTime(String userName, long fromTime, long toTime) throws org.apache.thrift.TException
+ {
+ searchExperimentsByCreationTime_args args = new searchExperimentsByCreationTime_args();
+ args.setUserName(userName);
+ args.setFromTime(fromTime);
+ args.setToTime(toTime);
+ sendBase("searchExperimentsByCreationTime", args);
+ }
+
+ public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> recv_searchExperimentsByCreationTime() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
+ receiveBase(result, "searchExperimentsByCreationTime");
+ 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, "searchExperimentsByCreationTime 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);
@@ -4241,6 +4287,44 @@ import org.slf4j.LoggerFactory;
}
}
+ public void searchExperimentsByCreationTime(String userName, long fromTime, long toTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ searchExperimentsByCreationTime_call method_call = new searchExperimentsByCreationTime_call(userName, fromTime, toTime, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class searchExperimentsByCreationTime_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String userName;
+ private long fromTime;
+ private long toTime;
+ public searchExperimentsByCreationTime_call(String userName, long fromTime, long toTime, 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.fromTime = fromTime;
+ this.toTime = toTime;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("searchExperimentsByCreationTime", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ searchExperimentsByCreationTime_args args = new searchExperimentsByCreationTime_args();
+ args.setUserName(userName);
+ args.setFromTime(fromTime);
+ args.setToTime(toTime);
+ 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_searchExperimentsByCreationTime();
+ }
+ }
+
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);
@@ -6412,6 +6496,7 @@ import org.slf4j.LoggerFactory;
processMap.put("searchExperimentsByDesc", new searchExperimentsByDesc());
processMap.put("searchExperimentsByApplication", new searchExperimentsByApplication());
processMap.put("searchExperimentsByStatus", new searchExperimentsByStatus());
+ processMap.put("searchExperimentsByCreationTime", new searchExperimentsByCreationTime());
processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject());
processMap.put("getAllUserExperiments", new getAllUserExperiments());
processMap.put("createExperiment", new createExperiment());
@@ -6791,6 +6876,34 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class searchExperimentsByCreationTime<I extends Iface> extends org.apache.thrift.ProcessFunction<I, searchExperimentsByCreationTime_args> {
+ public searchExperimentsByCreationTime() {
+ super("searchExperimentsByCreationTime");
+ }
+
+ public searchExperimentsByCreationTime_args getEmptyArgsInstance() {
+ return new searchExperimentsByCreationTime_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public searchExperimentsByCreationTime_result getResult(I iface, searchExperimentsByCreationTime_args args) throws org.apache.thrift.TException {
+ searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
+ try {
+ result.success = iface.searchExperimentsByCreationTime(args.userName, args.fromTime, args.toTime);
+ } 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");
@@ -8625,6 +8738,7 @@ import org.slf4j.LoggerFactory;
processMap.put("searchExperimentsByDesc", new searchExperimentsByDesc());
processMap.put("searchExperimentsByApplication", new searchExperimentsByApplication());
processMap.put("searchExperimentsByStatus", new searchExperimentsByStatus());
+ processMap.put("searchExperimentsByCreationTime", new searchExperimentsByCreationTime());
processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject());
processMap.put("getAllUserExperiments", new getAllUserExperiments());
processMap.put("createExperiment", new createExperiment());
@@ -9438,20 +9552,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 searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> {
+ public searchExperimentsByCreationTime() {
+ super("searchExperimentsByCreationTime");
}
- public getAllExperimentsInProject_args getEmptyArgsInstance() {
- return new getAllExperimentsInProject_args();
+ public searchExperimentsByCreationTime_args getEmptyArgsInstance() {
+ return new searchExperimentsByCreationTime_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) {
+ searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -9464,7 +9578,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();
+ searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -9480,11 +9594,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;
@@ -9505,159 +9614,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, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException {
+ iface.searchExperimentsByCreationTime(args.userName, args.fromTime, args.toTime,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();
- 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;
- 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.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, 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);
- 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, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.createExperiment(args.experiment,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 getExperiment_args getEmptyArgsInstance() {
- return new getExperiment_args();
- }
-
- 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<org.apache.airavata.model.workspace.experiment.Experiment>() {
- public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) {
- getExperiment_result result = new getExperiment_result();
+ getAllExperimentsInProject_result result = new getAllExperimentsInProject_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -9670,17 +9645,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();
+ 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);
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);
@@ -9691,75 +9661,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, 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 updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> {
- public updateExperiment() {
- super("updateExperiment");
- }
-
- 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) {
- updateExperiment_result result = new updateExperiment_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;
- 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);
- 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);
+ 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
@@ -9782,25 +9686,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 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 updateExperimentConfiguration<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperimentConfiguration_args, Void> {
- public updateExperimentConfiguration() {
- super("updateExperimentConfiguration");
+ 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 updateExperimentConfiguration_args getEmptyArgsInstance() {
- return new updateExperimentConfiguration_args();
+ public getAllUserExperiments_args getEmptyArgsInstance() {
+ return new getAllUserExperiments_args();
}
- public AsyncMethodCallback<Void> 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<Void>() {
- public void onComplete(Void o) {
- updateExperimentConfiguration_result result = new updateExperimentConfiguration_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);
return;
@@ -9812,57 +9717,23 @@ import org.slf4j.LoggerFactory;
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());
+ 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;
}
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
+ else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
+ result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
+ result.setAceIsSet(true);
+ msg = result;
}
- 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);
+ else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
+ result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
+ result.setAseIsSet(true);
+ msg = result;
}
- 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();
+ 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());
@@ -9882,27 +9753,26 @@ import org.slf4j.LoggerFactory;
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, 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 validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> {
- public validateExperiment() {
- super("validateExperiment");
+ public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> {
+ public createExperiment() {
+ super("createExperiment");
}
- public validateExperiment_args getEmptyArgsInstance() {
- return new validateExperiment_args();
+ public createExperiment_args getEmptyArgsInstance() {
+ return new createExperiment_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) {
- validateExperiment_result result = new validateExperiment_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ createExperiment_result result = new createExperiment_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9914,17 +9784,12 @@ 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();
+ 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);
@@ -9955,25 +9820,26 @@ 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, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.createExperiment(args.experiment,resultHandler);
}
}
- public static class launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> {
- public launchExperiment() {
- super("launchExperiment");
+ 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 launchExperiment_args getEmptyArgsInstance() {
- return new launchExperiment_args();
+ public getExperiment_args getEmptyArgsInstance() {
+ return new getExperiment_args();
}
- public AsyncMethodCallback<Void> 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<Void>() {
- public void onComplete(Void o) {
- launchExperiment_result result = new launchExperiment_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;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -9985,7 +9851,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();
+ 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);
@@ -10006,11 +9872,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;
@@ -10031,26 +9892,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, 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 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 updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> {
+ public updateExperiment() {
+ super("updateExperiment");
}
- public getExperimentStatus_args getEmptyArgsInstance() {
- return new getExperimentStatus_args();
+ public updateExperiment_args getEmptyArgsInstance() {
+ return new updateExperiment_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) {
+ updateExperiment_result result = new updateExperiment_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10062,7 +9922,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();
+ 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);
@@ -10103,26 +9963,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, updateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateExperiment(args.airavataExperimentId, args.experiment,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 updateExperimentConfiguration<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperimentConfiguration_args, Void> {
+ public updateExperimentConfiguration() {
+ super("updateExperimentConfiguration");
}
- public getExperimentOutputs_args getEmptyArgsInstance() {
- return new getExperimentOutputs_args();
+ public updateExperimentConfiguration_args getEmptyArgsInstance() {
+ return new updateExperimentConfiguration_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) {
+ updateExperimentConfiguration_result result = new updateExperimentConfiguration_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10134,7 +9993,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();
+ 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());
@@ -10154,26 +10013,25 @@ 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, updateExperimentConfiguration_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateExperimentConfiguration(args.airavataExperimentId, args.userConfiguration,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 updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> {
+ public updateResourceScheduleing() {
+ super("updateResourceScheduleing");
}
- public getJobStatuses_args getEmptyArgsInstance() {
- return new getJobStatuses_args();
+ public updateResourceScheduleing_args getEmptyArgsInstance() {
+ return new updateResourceScheduleing_args();
}
- public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> 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<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;
+ 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;
@@ -10185,7 +10043,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getJobStatuses_result result = new getJobStatuses_result();
+ 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());
@@ -10205,26 +10063,27 @@ 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, updateResourceScheduleing_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.updateResourceScheduleing(args.airavataExperimentId, args.resourceScheduling,resultHandler);
}
}
- public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> {
- public cloneExperiment() {
- super("cloneExperiment");
+ public static class validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> {
+ public validateExperiment() {
+ super("validateExperiment");
}
- public cloneExperiment_args getEmptyArgsInstance() {
- return new cloneExperiment_args();
+ public validateExperiment_args getEmptyArgsInstance() {
+ return new validateExperiment_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- cloneExperiment_result result = new cloneExperiment_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;
@@ -10236,7 +10095,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();
+ 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);
@@ -10277,25 +10136,25 @@ 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, validateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.validateExperiment(args.airavataExperimentId,resultHandler);
}
}
- public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> {
- public terminateExperiment() {
- super("terminateExperiment");
+ public static class launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> {
+ public launchExperiment() {
+ super("launchExperiment");
}
- public terminateExperiment_args getEmptyArgsInstance() {
- return new terminateExperiment_args();
+ public launchExperiment_args getEmptyArgsInstance() {
+ return new launchExperiment_args();
}
public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Void>() {
public void onComplete(Void o) {
- terminateExperiment_result result = new terminateExperiment_result();
+ launchExperiment_result result = new launchExperiment_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -10307,7 +10166,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();
+ 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);
@@ -10328,6 +10187,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;
@@ -10348,25 +10212,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, launchExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.launchExperiment(args.airavataExperimentId, args.airavataCredStoreToken,resultHandler);
}
}
- public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> {
- public registerApplicationModule() {
- super("registerApplicationModule");
+ 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 registerApplicationModule_args getEmptyArgsInstance() {
- return new registerApplicationModule_args();
+ public getExperimentStatus_args getEmptyArgsInstance() {
+ return new getExperimentStatus_args();
}
- public AsyncMethodCallback<String> 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<String>() {
- public void onComplete(String o) {
- registerApplicationModule_result result = new registerApplicationModule_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);
@@ -10379,12 +10243,17 @@ 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();
+ 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);
@@ -10415,25 +10284,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, 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 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 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 getApplicationModule_args getEmptyArgsInstance() {
- return new getApplicationModule_args();
+ public getExperimentOutputs_args getEmptyArgsInstance() {
+ return new getExperimentOutputs_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> 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<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<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);
@@ -10446,23 +10315,58 @@ 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;
+ 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());
}
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
}
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ 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 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 getJobStatuses_args getEmptyArgsInstance() {
+ return new getJobStatuses_args();
+ }
+
+ 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<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);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
}
- else
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ 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());
@@ -10482,27 +10386,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;
@@ -10514,12 +10417,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);
@@ -10550,27 +10458,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;
@@ -10582,12 +10488,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);
@@ -10618,25 +10529,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);
@@ -10649,7 +10560,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);
@@ -10685,25 +10596,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);
@@ -10716,7 +10627,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);
@@ -10752,25 +10663,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 {
@@ -10784,7 +10695,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);
@@ -10820,25 +10731,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 {
@@ -10852,7 +10763,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);
@@ -10888,25 +10799,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);
@@ -10919,7 +10830,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);
@@ -10955,25 +10866,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
<TRUNCATED>