You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sa...@apache.org on 2014/05/21 07:46:58 UTC
[2/5] generated code for gridftp model
http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
index b7f2194..6f5a3a9 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/API/AppCatalog/ApplicationCatalogAPI.php
@@ -23,12 +23,14 @@ interface ApplicationCatalogAPIIf {
public function addGSISSHJobSubmissionProtocol($computeResourceId, \GSISSHJobSubmission $jobSubmission);
public function addGlobusJobSubmissionProtocol($computeResourceId, \GlobusJobSubmission $jobSubmission);
public function addSCPDataMovementProtocol($computeResourceId, \SCPDataMovement $dataMovement);
+ public function addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement);
public function listComputeResourceDescriptions();
public function getComputeResourceDescription($computeResourceId);
public function getSSHJobSubmissionProtocol($sshJobSubmissionProtocolResourceId);
public function getGSISSHJobSubmissionProtocol($gsisshJobSubmissionProtocolResourceId);
public function getGlobusJobSubmissionProtocol($globusJobSubmissionProtocolResourceId);
public function getSCPDataMovementProtocol($scpDataMovementResourceId);
+ public function getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId);
public function isComputeResourceDescriptionRegistered($hostName);
public function getComputeResourceDescriptionFromHostName($hostName);
public function addApplicationInterface(\ApplicationInterface $applicationInterface);
@@ -389,6 +391,64 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
return;
}
+ public function addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement)
+ {
+ $this->send_addGridFTPDataMovementProtocol($computeResourceId, $dataMovement);
+ $this->recv_addGridFTPDataMovementProtocol();
+ }
+
+ public function send_addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement)
+ {
+ $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args();
+ $args->computeResourceId = $computeResourceId;
+ $args->dataMovement = $dataMovement;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'addGridFTPDataMovementProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('addGridFTPDataMovementProtocol', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_addGridFTPDataMovementProtocol()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ return;
+ }
+
public function listComputeResourceDescriptions()
{
$this->send_listComputeResourceDescriptions();
@@ -748,6 +808,66 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("getSCPDataMovementProtocol failed: unknown result");
}
+ public function getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId)
+ {
+ $this->send_getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId);
+ return $this->recv_getGridFTPDataMovementProtocol();
+ }
+
+ public function send_getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId)
+ {
+ $args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args();
+ $args->gridFTPDataMovementResourceId = $gridFTPDataMovementResourceId;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'getGridFTPDataMovementProtocol', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('getGridFTPDataMovementProtocol', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_getGridFTPDataMovementProtocol()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\Airavata\API\AppCatalog\ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->ire !== null) {
+ throw $result->ire;
+ }
+ if ($result->ace !== null) {
+ throw $result->ace;
+ }
+ if ($result->ase !== null) {
+ throw $result->ase;
+ }
+ throw new \Exception("getGridFTPDataMovementProtocol failed: unknown result");
+ }
+
public function isComputeResourceDescriptionRegistered($hostName)
{
$this->send_isComputeResourceDescriptionRegistered($hostName);
@@ -2404,6 +2524,221 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_result {
}
+class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args {
+ static $_TSPEC;
+
+ public $computeResourceId = null;
+ public $dataMovement = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'computeResourceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'dataMovement',
+ 'type' => TType::STRUCT,
+ 'class' => '\GridFTPDataMovement',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['computeResourceId'])) {
+ $this->computeResourceId = $vals['computeResourceId'];
+ }
+ if (isset($vals['dataMovement'])) {
+ $this->dataMovement = $vals['dataMovement'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->computeResourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->dataMovement = new \GridFTPDataMovement();
+ $xfer += $this->dataMovement->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args');
+ if ($this->computeResourceId !== null) {
+ $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->computeResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMovement !== null) {
+ if (!is_object($this->dataMovement)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataMovement', TType::STRUCT, 2);
+ $xfer += $this->dataMovement->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result {
+ static $_TSPEC;
+
+ public $ire = null;
+ public $ace = null;
+ public $ase = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 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['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationCatalogAPI_addGridFTPDataMovementProtocol_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 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ApplicationCatalogAPI_addGridFTPDataMovementProtocol_result');
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class ApplicationCatalogAPI_listComputeResourceDescriptions_args {
static $_TSPEC;
@@ -3693,6 +4028,221 @@ class ApplicationCatalogAPI_getSCPDataMovementProtocol_result {
}
+class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args {
+ static $_TSPEC;
+
+ public $gridFTPDataMovementResourceId = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'gridFTPDataMovementResourceId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['gridFTPDataMovementResourceId'])) {
+ $this->gridFTPDataMovementResourceId = $vals['gridFTPDataMovementResourceId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationCatalogAPI_getGridFTPDataMovementProtocol_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->gridFTPDataMovementResourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ApplicationCatalogAPI_getGridFTPDataMovementProtocol_args');
+ if ($this->gridFTPDataMovementResourceId !== null) {
+ $xfer += $output->writeFieldBegin('gridFTPDataMovementResourceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->gridFTPDataMovementResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_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::STRUCT,
+ 'class' => '\GridFTPDataMovement',
+ ),
+ 1 => array(
+ 'var' => 'ire',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\InvalidRequestException',
+ ),
+ 2 => array(
+ 'var' => 'ace',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataClientException',
+ ),
+ 3 => array(
+ 'var' => 'ase',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\API\Error\AiravataSystemException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['ire'])) {
+ $this->ire = $vals['ire'];
+ }
+ if (isset($vals['ace'])) {
+ $this->ace = $vals['ace'];
+ }
+ if (isset($vals['ase'])) {
+ $this->ase = $vals['ase'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationCatalogAPI_getGridFTPDataMovementProtocol_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::STRUCT) {
+ $this->success = new \GridFTPDataMovement();
+ $xfer += $this->success->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->ire = new \Airavata\API\Error\InvalidRequestException();
+ $xfer += $this->ire->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->ace = new \Airavata\API\Error\AiravataClientException();
+ $xfer += $this->ace->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->ase = new \Airavata\API\Error\AiravataSystemException();
+ $xfer += $this->ase->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result');
+ if ($this->success !== null) {
+ if (!is_object($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ire !== null) {
+ $xfer += $output->writeFieldBegin('ire', TType::STRUCT, 1);
+ $xfer += $this->ire->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ace !== null) {
+ $xfer += $output->writeFieldBegin('ace', TType::STRUCT, 2);
+ $xfer += $this->ace->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ase !== null) {
+ $xfer += $output->writeFieldBegin('ase', TType::STRUCT, 3);
+ $xfer += $this->ase->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class ApplicationCatalogAPI_isComputeResourceDescriptionRegistered_args {
static $_TSPEC;
http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Types.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Types.php
index 495f1b0..f4a3589 100644
--- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Types.php
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Types.php
@@ -74,7 +74,7 @@ final class SecurityProtocol {
class SCPDataMovement {
static $_TSPEC;
- public $dataSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
+ public $dataMovementDataID = "DO_NOT_SET_AT_CLIENTS";
public $securityProtocol = null;
public $sshPort = 22;
@@ -82,7 +82,7 @@ class SCPDataMovement {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
1 => array(
- 'var' => 'dataSubmissionDataID',
+ 'var' => 'dataMovementDataID',
'type' => TType::STRING,
),
2 => array(
@@ -96,8 +96,8 @@ class SCPDataMovement {
);
}
if (is_array($vals)) {
- if (isset($vals['dataSubmissionDataID'])) {
- $this->dataSubmissionDataID = $vals['dataSubmissionDataID'];
+ if (isset($vals['dataMovementDataID'])) {
+ $this->dataMovementDataID = $vals['dataMovementDataID'];
}
if (isset($vals['securityProtocol'])) {
$this->securityProtocol = $vals['securityProtocol'];
@@ -129,7 +129,7 @@ class SCPDataMovement {
{
case 1:
if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->dataSubmissionDataID);
+ $xfer += $input->readString($this->dataMovementDataID);
} else {
$xfer += $input->skip($ftype);
}
@@ -161,9 +161,9 @@ class SCPDataMovement {
public function write($output) {
$xfer = 0;
$xfer += $output->writeStructBegin('SCPDataMovement');
- if ($this->dataSubmissionDataID !== null) {
- $xfer += $output->writeFieldBegin('dataSubmissionDataID', TType::STRING, 1);
- $xfer += $output->writeString($this->dataSubmissionDataID);
+ if ($this->dataMovementDataID !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementDataID', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementDataID);
$xfer += $output->writeFieldEnd();
}
if ($this->securityProtocol !== null) {
@@ -183,6 +183,144 @@ class SCPDataMovement {
}
+class GridFTPDataMovement {
+ static $_TSPEC;
+
+ public $dataMovementDataID = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $gridFTPEndPoint = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovementDataID',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'gridFTPEndPoint',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementDataID'])) {
+ $this->dataMovementDataID = $vals['dataMovementDataID'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['gridFTPEndPoint'])) {
+ $this->gridFTPEndPoint = $vals['gridFTPEndPoint'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'GridFTPDataMovement';
+ }
+
+ 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->dataMovementDataID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->securityProtocol);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::LST) {
+ $this->gridFTPEndPoint = array();
+ $_size0 = 0;
+ $_etype3 = 0;
+ $xfer += $input->readListBegin($_etype3, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $elem5 = null;
+ $xfer += $input->readString($elem5);
+ $this->gridFTPEndPoint []= $elem5;
+ }
+ $xfer += $input->readListEnd();
+ } 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('GridFTPDataMovement');
+ if ($this->dataMovementDataID !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementDataID', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementDataID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gridFTPEndPoint !== null) {
+ if (!is_array($this->gridFTPEndPoint)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('gridFTPEndPoint', TType::LST, 3);
+ {
+ $output->writeListBegin(TType::STRING, count($this->gridFTPEndPoint));
+ {
+ foreach ($this->gridFTPEndPoint as $iter6)
+ {
+ $xfer += $output->writeString($iter6);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class SSHJobSubmission {
static $_TSPEC;
@@ -387,14 +525,14 @@ class GlobusJobSubmission {
case 4:
if ($ftype == TType::LST) {
$this->globusGateKeeperEndPoint = array();
- $_size0 = 0;
- $_etype3 = 0;
- $xfer += $input->readListBegin($_etype3, $_size0);
- for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ $_size7 = 0;
+ $_etype10 = 0;
+ $xfer += $input->readListBegin($_etype10, $_size7);
+ for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
{
- $elem5 = null;
- $xfer += $input->readString($elem5);
- $this->globusGateKeeperEndPoint []= $elem5;
+ $elem12 = null;
+ $xfer += $input->readString($elem12);
+ $this->globusGateKeeperEndPoint []= $elem12;
}
$xfer += $input->readListEnd();
} else {
@@ -437,9 +575,9 @@ class GlobusJobSubmission {
{
$output->writeListBegin(TType::STRING, count($this->globusGateKeeperEndPoint));
{
- foreach ($this->globusGateKeeperEndPoint as $iter6)
+ foreach ($this->globusGateKeeperEndPoint as $iter13)
{
- $xfer += $output->writeString($iter6);
+ $xfer += $output->writeString($iter13);
}
}
$output->writeListEnd();
@@ -585,17 +723,17 @@ class GSISSHJobSubmission {
case 4:
if ($ftype == TType::SET) {
$this->exports = array();
- $_size7 = 0;
- $_etype10 = 0;
- $xfer += $input->readSetBegin($_etype10, $_size7);
- for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
+ $_size14 = 0;
+ $_etype17 = 0;
+ $xfer += $input->readSetBegin($_etype17, $_size14);
+ for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
{
- $elem12 = null;
- $xfer += $input->readString($elem12);
- if (is_scalar($elem12)) {
- $this->exports[$elem12] = true;
+ $elem19 = null;
+ $xfer += $input->readString($elem19);
+ if (is_scalar($elem19)) {
+ $this->exports[$elem19] = true;
} else {
- $this->exports []= $elem12;
+ $this->exports []= $elem19;
}
}
$xfer += $input->readSetEnd();
@@ -606,14 +744,14 @@ class GSISSHJobSubmission {
case 5:
if ($ftype == TType::LST) {
$this->preJobCommands = array();
- $_size13 = 0;
- $_etype16 = 0;
- $xfer += $input->readListBegin($_etype16, $_size13);
- for ($_i17 = 0; $_i17 < $_size13; ++$_i17)
+ $_size20 = 0;
+ $_etype23 = 0;
+ $xfer += $input->readListBegin($_etype23, $_size20);
+ for ($_i24 = 0; $_i24 < $_size20; ++$_i24)
{
- $elem18 = null;
- $xfer += $input->readString($elem18);
- $this->preJobCommands []= $elem18;
+ $elem25 = null;
+ $xfer += $input->readString($elem25);
+ $this->preJobCommands []= $elem25;
}
$xfer += $input->readListEnd();
} else {
@@ -623,14 +761,14 @@ class GSISSHJobSubmission {
case 6:
if ($ftype == TType::LST) {
$this->postJobCommands = array();
- $_size19 = 0;
- $_etype22 = 0;
- $xfer += $input->readListBegin($_etype22, $_size19);
- for ($_i23 = 0; $_i23 < $_size19; ++$_i23)
+ $_size26 = 0;
+ $_etype29 = 0;
+ $xfer += $input->readListBegin($_etype29, $_size26);
+ for ($_i30 = 0; $_i30 < $_size26; ++$_i30)
{
- $elem24 = null;
- $xfer += $input->readString($elem24);
- $this->postJobCommands []= $elem24;
+ $elem31 = null;
+ $xfer += $input->readString($elem31);
+ $this->postJobCommands []= $elem31;
}
$xfer += $input->readListEnd();
} else {
@@ -687,12 +825,12 @@ class GSISSHJobSubmission {
{
$output->writeSetBegin(TType::STRING, count($this->exports));
{
- foreach ($this->exports as $iter25 => $iter26)
+ foreach ($this->exports as $iter32 => $iter33)
{
- if (is_scalar($iter26)) {
- $xfer += $output->writeString($iter25);
+ if (is_scalar($iter33)) {
+ $xfer += $output->writeString($iter32);
} else {
- $xfer += $output->writeString($iter26);
+ $xfer += $output->writeString($iter33);
}
}
}
@@ -708,9 +846,9 @@ class GSISSHJobSubmission {
{
$output->writeListBegin(TType::STRING, count($this->preJobCommands));
{
- foreach ($this->preJobCommands as $iter27)
+ foreach ($this->preJobCommands as $iter34)
{
- $xfer += $output->writeString($iter27);
+ $xfer += $output->writeString($iter34);
}
}
$output->writeListEnd();
@@ -725,9 +863,9 @@ class GSISSHJobSubmission {
{
$output->writeListBegin(TType::STRING, count($this->postJobCommands));
{
- foreach ($this->postJobCommands as $iter28)
+ foreach ($this->postJobCommands as $iter35)
{
- $xfer += $output->writeString($iter28);
+ $xfer += $output->writeString($iter35);
}
}
$output->writeListEnd();
@@ -911,17 +1049,17 @@ class ComputeResourceDescription {
case 4:
if ($ftype == TType::SET) {
$this->hostAliases = array();
- $_size29 = 0;
- $_etype32 = 0;
- $xfer += $input->readSetBegin($_etype32, $_size29);
- for ($_i33 = 0; $_i33 < $_size29; ++$_i33)
+ $_size36 = 0;
+ $_etype39 = 0;
+ $xfer += $input->readSetBegin($_etype39, $_size36);
+ for ($_i40 = 0; $_i40 < $_size36; ++$_i40)
{
- $elem34 = null;
- $xfer += $input->readString($elem34);
- if (is_scalar($elem34)) {
- $this->hostAliases[$elem34] = true;
+ $elem41 = null;
+ $xfer += $input->readString($elem41);
+ if (is_scalar($elem41)) {
+ $this->hostAliases[$elem41] = true;
} else {
- $this->hostAliases []= $elem34;
+ $this->hostAliases []= $elem41;
}
}
$xfer += $input->readSetEnd();
@@ -932,17 +1070,17 @@ class ComputeResourceDescription {
case 5:
if ($ftype == TType::SET) {
$this->ipAddresses = array();
- $_size35 = 0;
- $_etype38 = 0;
- $xfer += $input->readSetBegin($_etype38, $_size35);
- for ($_i39 = 0; $_i39 < $_size35; ++$_i39)
+ $_size42 = 0;
+ $_etype45 = 0;
+ $xfer += $input->readSetBegin($_etype45, $_size42);
+ for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
{
- $elem40 = null;
- $xfer += $input->readString($elem40);
- if (is_scalar($elem40)) {
- $this->ipAddresses[$elem40] = true;
+ $elem47 = null;
+ $xfer += $input->readString($elem47);
+ if (is_scalar($elem47)) {
+ $this->ipAddresses[$elem47] = true;
} else {
- $this->ipAddresses []= $elem40;
+ $this->ipAddresses []= $elem47;
}
}
$xfer += $input->readSetEnd();
@@ -974,17 +1112,17 @@ class ComputeResourceDescription {
case 9:
if ($ftype == TType::MAP) {
$this->jobSubmissionProtocols = array();
- $_size41 = 0;
- $_ktype42 = 0;
- $_vtype43 = 0;
- $xfer += $input->readMapBegin($_ktype42, $_vtype43, $_size41);
- for ($_i45 = 0; $_i45 < $_size41; ++$_i45)
+ $_size48 = 0;
+ $_ktype49 = 0;
+ $_vtype50 = 0;
+ $xfer += $input->readMapBegin($_ktype49, $_vtype50, $_size48);
+ for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
{
- $key46 = '';
- $val47 = 0;
- $xfer += $input->readString($key46);
- $xfer += $input->readI32($val47);
- $this->jobSubmissionProtocols[$key46] = $val47;
+ $key53 = '';
+ $val54 = 0;
+ $xfer += $input->readString($key53);
+ $xfer += $input->readI32($val54);
+ $this->jobSubmissionProtocols[$key53] = $val54;
}
$xfer += $input->readMapEnd();
} else {
@@ -994,17 +1132,17 @@ class ComputeResourceDescription {
case 10:
if ($ftype == TType::MAP) {
$this->dataMovementProtocols = array();
- $_size48 = 0;
- $_ktype49 = 0;
- $_vtype50 = 0;
- $xfer += $input->readMapBegin($_ktype49, $_vtype50, $_size48);
- for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
+ $_size55 = 0;
+ $_ktype56 = 0;
+ $_vtype57 = 0;
+ $xfer += $input->readMapBegin($_ktype56, $_vtype57, $_size55);
+ for ($_i59 = 0; $_i59 < $_size55; ++$_i59)
{
- $key53 = '';
- $val54 = 0;
- $xfer += $input->readString($key53);
- $xfer += $input->readI32($val54);
- $this->dataMovementProtocols[$key53] = $val54;
+ $key60 = '';
+ $val61 = 0;
+ $xfer += $input->readString($key60);
+ $xfer += $input->readI32($val61);
+ $this->dataMovementProtocols[$key60] = $val61;
}
$xfer += $input->readMapEnd();
} else {
@@ -1047,12 +1185,12 @@ class ComputeResourceDescription {
{
$output->writeSetBegin(TType::STRING, count($this->hostAliases));
{
- foreach ($this->hostAliases as $iter55 => $iter56)
+ foreach ($this->hostAliases as $iter62 => $iter63)
{
- if (is_scalar($iter56)) {
- $xfer += $output->writeString($iter55);
+ if (is_scalar($iter63)) {
+ $xfer += $output->writeString($iter62);
} else {
- $xfer += $output->writeString($iter56);
+ $xfer += $output->writeString($iter63);
}
}
}
@@ -1068,12 +1206,12 @@ class ComputeResourceDescription {
{
$output->writeSetBegin(TType::STRING, count($this->ipAddresses));
{
- foreach ($this->ipAddresses as $iter57 => $iter58)
+ foreach ($this->ipAddresses as $iter64 => $iter65)
{
- if (is_scalar($iter58)) {
- $xfer += $output->writeString($iter57);
+ if (is_scalar($iter65)) {
+ $xfer += $output->writeString($iter64);
} else {
- $xfer += $output->writeString($iter58);
+ $xfer += $output->writeString($iter65);
}
}
}
@@ -1104,10 +1242,10 @@ class ComputeResourceDescription {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionProtocols));
{
- foreach ($this->jobSubmissionProtocols as $kiter59 => $viter60)
+ foreach ($this->jobSubmissionProtocols as $kiter66 => $viter67)
{
- $xfer += $output->writeString($kiter59);
- $xfer += $output->writeI32($viter60);
+ $xfer += $output->writeString($kiter66);
+ $xfer += $output->writeI32($viter67);
}
}
$output->writeMapEnd();
@@ -1122,10 +1260,10 @@ class ComputeResourceDescription {
{
$output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementProtocols));
{
- foreach ($this->dataMovementProtocols as $kiter61 => $viter62)
+ foreach ($this->dataMovementProtocols as $kiter68 => $viter69)
{
- $xfer += $output->writeString($kiter61);
- $xfer += $output->writeI32($viter62);
+ $xfer += $output->writeString($kiter68);
+ $xfer += $output->writeI32($viter69);
}
}
$output->writeMapEnd();
@@ -1431,15 +1569,15 @@ class ApplicationInterface {
case 3:
if ($ftype == TType::LST) {
$this->applicationDeployments = 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 \ApplicationDeployment();
- $xfer += $elem68->read($input);
- $this->applicationDeployments []= $elem68;
+ $elem75 = null;
+ $elem75 = new \ApplicationDeployment();
+ $xfer += $elem75->read($input);
+ $this->applicationDeployments []= $elem75;
}
$xfer += $input->readListEnd();
} else {
@@ -1477,9 +1615,9 @@ class ApplicationInterface {
{
$output->writeListBegin(TType::STRUCT, count($this->applicationDeployments));
{
- foreach ($this->applicationDeployments as $iter69)
+ foreach ($this->applicationDeployments as $iter76)
{
- $xfer += $iter69->write($output);
+ $xfer += $iter76->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ApplicationInterface.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ApplicationInterface.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ApplicationInterface.java
index 77db61a..f66753b 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ApplicationInterface.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ApplicationInterface.java
@@ -532,14 +532,14 @@ import org.slf4j.LoggerFactory;
case 3: // APPLICATION_DEPLOYMENTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list68 = iprot.readListBegin();
- struct.applicationDeployments = new ArrayList<ApplicationDeployment>(_list68.size);
- for (int _i69 = 0; _i69 < _list68.size; ++_i69)
+ org.apache.thrift.protocol.TList _list76 = iprot.readListBegin();
+ struct.applicationDeployments = new ArrayList<ApplicationDeployment>(_list76.size);
+ for (int _i77 = 0; _i77 < _list76.size; ++_i77)
{
- ApplicationDeployment _elem70;
- _elem70 = new ApplicationDeployment();
- _elem70.read(iprot);
- struct.applicationDeployments.add(_elem70);
+ ApplicationDeployment _elem78;
+ _elem78 = new ApplicationDeployment();
+ _elem78.read(iprot);
+ struct.applicationDeployments.add(_elem78);
}
iprot.readListEnd();
}
@@ -578,9 +578,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(APPLICATION_DEPLOYMENTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.applicationDeployments.size()));
- for (ApplicationDeployment _iter71 : struct.applicationDeployments)
+ for (ApplicationDeployment _iter79 : struct.applicationDeployments)
{
- _iter71.write(oprot);
+ _iter79.write(oprot);
}
oprot.writeListEnd();
}
@@ -619,9 +619,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetApplicationDeployments()) {
{
oprot.writeI32(struct.applicationDeployments.size());
- for (ApplicationDeployment _iter72 : struct.applicationDeployments)
+ for (ApplicationDeployment _iter80 : struct.applicationDeployments)
{
- _iter72.write(oprot);
+ _iter80.write(oprot);
}
}
}
@@ -639,14 +639,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list73 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.applicationDeployments = new ArrayList<ApplicationDeployment>(_list73.size);
- for (int _i74 = 0; _i74 < _list73.size; ++_i74)
+ org.apache.thrift.protocol.TList _list81 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.applicationDeployments = new ArrayList<ApplicationDeployment>(_list81.size);
+ for (int _i82 = 0; _i82 < _list81.size; ++_i82)
{
- ApplicationDeployment _elem75;
- _elem75 = new ApplicationDeployment();
- _elem75.read(iprot);
- struct.applicationDeployments.add(_elem75);
+ ApplicationDeployment _elem83;
+ _elem83 = new ApplicationDeployment();
+ _elem83.read(iprot);
+ struct.applicationDeployments.add(_elem83);
}
}
struct.setApplicationDeploymentsIsSet(true);
http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ComputeResourceDescription.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ComputeResourceDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ComputeResourceDescription.java
index c08fc85..03e6c1f 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ComputeResourceDescription.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/ComputeResourceDescription.java
@@ -1176,13 +1176,13 @@ import org.slf4j.LoggerFactory;
case 4: // HOST_ALIASES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set32 = iprot.readSetBegin();
- struct.hostAliases = new HashSet<String>(2*_set32.size);
- for (int _i33 = 0; _i33 < _set32.size; ++_i33)
+ org.apache.thrift.protocol.TSet _set40 = iprot.readSetBegin();
+ struct.hostAliases = new HashSet<String>(2*_set40.size);
+ for (int _i41 = 0; _i41 < _set40.size; ++_i41)
{
- String _elem34;
- _elem34 = iprot.readString();
- struct.hostAliases.add(_elem34);
+ String _elem42;
+ _elem42 = iprot.readString();
+ struct.hostAliases.add(_elem42);
}
iprot.readSetEnd();
}
@@ -1194,13 +1194,13 @@ import org.slf4j.LoggerFactory;
case 5: // IP_ADDRESSES
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set35 = iprot.readSetBegin();
- struct.ipAddresses = new HashSet<String>(2*_set35.size);
- for (int _i36 = 0; _i36 < _set35.size; ++_i36)
+ org.apache.thrift.protocol.TSet _set43 = iprot.readSetBegin();
+ struct.ipAddresses = new HashSet<String>(2*_set43.size);
+ for (int _i44 = 0; _i44 < _set43.size; ++_i44)
{
- String _elem37;
- _elem37 = iprot.readString();
- struct.ipAddresses.add(_elem37);
+ String _elem45;
+ _elem45 = iprot.readString();
+ struct.ipAddresses.add(_elem45);
}
iprot.readSetEnd();
}
@@ -1236,15 +1236,15 @@ import org.slf4j.LoggerFactory;
case 9: // JOB_SUBMISSION_PROTOCOLS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map38 = iprot.readMapBegin();
- struct.jobSubmissionProtocols = new HashMap<String,JobSubmissionProtocol>(2*_map38.size);
- for (int _i39 = 0; _i39 < _map38.size; ++_i39)
+ org.apache.thrift.protocol.TMap _map46 = iprot.readMapBegin();
+ struct.jobSubmissionProtocols = new HashMap<String,JobSubmissionProtocol>(2*_map46.size);
+ for (int _i47 = 0; _i47 < _map46.size; ++_i47)
{
- String _key40;
- JobSubmissionProtocol _val41;
- _key40 = iprot.readString();
- _val41 = JobSubmissionProtocol.findByValue(iprot.readI32());
- struct.jobSubmissionProtocols.put(_key40, _val41);
+ String _key48;
+ JobSubmissionProtocol _val49;
+ _key48 = iprot.readString();
+ _val49 = JobSubmissionProtocol.findByValue(iprot.readI32());
+ struct.jobSubmissionProtocols.put(_key48, _val49);
}
iprot.readMapEnd();
}
@@ -1256,15 +1256,15 @@ import org.slf4j.LoggerFactory;
case 10: // DATA_MOVEMENT_PROTOCOLS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map42 = iprot.readMapBegin();
- struct.dataMovementProtocols = new HashMap<String,DataMovementProtocol>(2*_map42.size);
- for (int _i43 = 0; _i43 < _map42.size; ++_i43)
+ org.apache.thrift.protocol.TMap _map50 = iprot.readMapBegin();
+ struct.dataMovementProtocols = new HashMap<String,DataMovementProtocol>(2*_map50.size);
+ for (int _i51 = 0; _i51 < _map50.size; ++_i51)
{
- String _key44;
- DataMovementProtocol _val45;
- _key44 = iprot.readString();
- _val45 = DataMovementProtocol.findByValue(iprot.readI32());
- struct.dataMovementProtocols.put(_key44, _val45);
+ String _key52;
+ DataMovementProtocol _val53;
+ _key52 = iprot.readString();
+ _val53 = DataMovementProtocol.findByValue(iprot.readI32());
+ struct.dataMovementProtocols.put(_key52, _val53);
}
iprot.readMapEnd();
}
@@ -1304,9 +1304,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(HOST_ALIASES_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.hostAliases.size()));
- for (String _iter46 : struct.hostAliases)
+ for (String _iter54 : struct.hostAliases)
{
- oprot.writeString(_iter46);
+ oprot.writeString(_iter54);
}
oprot.writeSetEnd();
}
@@ -1318,9 +1318,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(IP_ADDRESSES_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.ipAddresses.size()));
- for (String _iter47 : struct.ipAddresses)
+ for (String _iter55 : struct.ipAddresses)
{
- oprot.writeString(_iter47);
+ oprot.writeString(_iter55);
}
oprot.writeSetEnd();
}
@@ -1352,10 +1352,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(JOB_SUBMISSION_PROTOCOLS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.jobSubmissionProtocols.size()));
- for (Map.Entry<String, JobSubmissionProtocol> _iter48 : struct.jobSubmissionProtocols.entrySet())
+ for (Map.Entry<String, JobSubmissionProtocol> _iter56 : struct.jobSubmissionProtocols.entrySet())
{
- oprot.writeString(_iter48.getKey());
- oprot.writeI32(_iter48.getValue().getValue());
+ oprot.writeString(_iter56.getKey());
+ oprot.writeI32(_iter56.getValue().getValue());
}
oprot.writeMapEnd();
}
@@ -1365,10 +1365,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(DATA_MOVEMENT_PROTOCOLS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.dataMovementProtocols.size()));
- for (Map.Entry<String, DataMovementProtocol> _iter49 : struct.dataMovementProtocols.entrySet())
+ for (Map.Entry<String, DataMovementProtocol> _iter57 : struct.dataMovementProtocols.entrySet())
{
- oprot.writeString(_iter49.getKey());
- oprot.writeI32(_iter49.getValue().getValue());
+ oprot.writeString(_iter57.getKey());
+ oprot.writeI32(_iter57.getValue().getValue());
}
oprot.writeMapEnd();
}
@@ -1396,18 +1396,18 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.hostName);
{
oprot.writeI32(struct.jobSubmissionProtocols.size());
- for (Map.Entry<String, JobSubmissionProtocol> _iter50 : struct.jobSubmissionProtocols.entrySet())
+ for (Map.Entry<String, JobSubmissionProtocol> _iter58 : struct.jobSubmissionProtocols.entrySet())
{
- oprot.writeString(_iter50.getKey());
- oprot.writeI32(_iter50.getValue().getValue());
+ oprot.writeString(_iter58.getKey());
+ oprot.writeI32(_iter58.getValue().getValue());
}
}
{
oprot.writeI32(struct.dataMovementProtocols.size());
- for (Map.Entry<String, DataMovementProtocol> _iter51 : struct.dataMovementProtocols.entrySet())
+ for (Map.Entry<String, DataMovementProtocol> _iter59 : struct.dataMovementProtocols.entrySet())
{
- oprot.writeString(_iter51.getKey());
- oprot.writeI32(_iter51.getValue().getValue());
+ oprot.writeString(_iter59.getKey());
+ oprot.writeI32(_iter59.getValue().getValue());
}
}
BitSet optionals = new BitSet();
@@ -1430,18 +1430,18 @@ import org.slf4j.LoggerFactory;
if (struct.isSetHostAliases()) {
{
oprot.writeI32(struct.hostAliases.size());
- for (String _iter52 : struct.hostAliases)
+ for (String _iter60 : struct.hostAliases)
{
- oprot.writeString(_iter52);
+ oprot.writeString(_iter60);
}
}
}
if (struct.isSetIpAddresses()) {
{
oprot.writeI32(struct.ipAddresses.size());
- for (String _iter53 : struct.ipAddresses)
+ for (String _iter61 : struct.ipAddresses)
{
- oprot.writeString(_iter53);
+ oprot.writeString(_iter61);
}
}
}
@@ -1466,54 +1466,54 @@ import org.slf4j.LoggerFactory;
struct.hostName = iprot.readString();
struct.setHostNameIsSet(true);
{
- org.apache.thrift.protocol.TMap _map54 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.jobSubmissionProtocols = new HashMap<String,JobSubmissionProtocol>(2*_map54.size);
- for (int _i55 = 0; _i55 < _map54.size; ++_i55)
+ org.apache.thrift.protocol.TMap _map62 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.jobSubmissionProtocols = new HashMap<String,JobSubmissionProtocol>(2*_map62.size);
+ for (int _i63 = 0; _i63 < _map62.size; ++_i63)
{
- String _key56;
- JobSubmissionProtocol _val57;
- _key56 = iprot.readString();
- _val57 = JobSubmissionProtocol.findByValue(iprot.readI32());
- struct.jobSubmissionProtocols.put(_key56, _val57);
+ String _key64;
+ JobSubmissionProtocol _val65;
+ _key64 = iprot.readString();
+ _val65 = JobSubmissionProtocol.findByValue(iprot.readI32());
+ struct.jobSubmissionProtocols.put(_key64, _val65);
}
}
struct.setJobSubmissionProtocolsIsSet(true);
{
- org.apache.thrift.protocol.TMap _map58 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.dataMovementProtocols = new HashMap<String,DataMovementProtocol>(2*_map58.size);
- for (int _i59 = 0; _i59 < _map58.size; ++_i59)
+ org.apache.thrift.protocol.TMap _map66 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.dataMovementProtocols = new HashMap<String,DataMovementProtocol>(2*_map66.size);
+ for (int _i67 = 0; _i67 < _map66.size; ++_i67)
{
- String _key60;
- DataMovementProtocol _val61;
- _key60 = iprot.readString();
- _val61 = DataMovementProtocol.findByValue(iprot.readI32());
- struct.dataMovementProtocols.put(_key60, _val61);
+ String _key68;
+ DataMovementProtocol _val69;
+ _key68 = iprot.readString();
+ _val69 = DataMovementProtocol.findByValue(iprot.readI32());
+ struct.dataMovementProtocols.put(_key68, _val69);
}
}
struct.setDataMovementProtocolsIsSet(true);
BitSet incoming = iprot.readBitSet(5);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TSet _set62 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.hostAliases = new HashSet<String>(2*_set62.size);
- for (int _i63 = 0; _i63 < _set62.size; ++_i63)
+ org.apache.thrift.protocol.TSet _set70 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.hostAliases = new HashSet<String>(2*_set70.size);
+ for (int _i71 = 0; _i71 < _set70.size; ++_i71)
{
- String _elem64;
- _elem64 = iprot.readString();
- struct.hostAliases.add(_elem64);
+ String _elem72;
+ _elem72 = iprot.readString();
+ struct.hostAliases.add(_elem72);
}
}
struct.setHostAliasesIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TSet _set65 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.ipAddresses = new HashSet<String>(2*_set65.size);
- for (int _i66 = 0; _i66 < _set65.size; ++_i66)
+ org.apache.thrift.protocol.TSet _set73 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.ipAddresses = new HashSet<String>(2*_set73.size);
+ for (int _i74 = 0; _i74 < _set73.size; ++_i74)
{
- String _elem67;
- _elem67 = iprot.readString();
- struct.ipAddresses.add(_elem67);
+ String _elem75;
+ _elem75 = iprot.readString();
+ struct.ipAddresses.add(_elem75);
}
}
struct.setIpAddressesIsSet(true);
http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GSISSHJobSubmission.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GSISSHJobSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GSISSHJobSubmission.java
index f634f70..8f29702 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GSISSHJobSubmission.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GSISSHJobSubmission.java
@@ -968,13 +968,13 @@ import org.slf4j.LoggerFactory;
case 4: // EXPORTS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set8 = iprot.readSetBegin();
- struct.exports = new HashSet<String>(2*_set8.size);
- for (int _i9 = 0; _i9 < _set8.size; ++_i9)
+ org.apache.thrift.protocol.TSet _set16 = iprot.readSetBegin();
+ struct.exports = new HashSet<String>(2*_set16.size);
+ for (int _i17 = 0; _i17 < _set16.size; ++_i17)
{
- String _elem10;
- _elem10 = iprot.readString();
- struct.exports.add(_elem10);
+ String _elem18;
+ _elem18 = iprot.readString();
+ struct.exports.add(_elem18);
}
iprot.readSetEnd();
}
@@ -986,13 +986,13 @@ import org.slf4j.LoggerFactory;
case 5: // PRE_JOB_COMMANDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list11 = iprot.readListBegin();
- struct.preJobCommands = new ArrayList<String>(_list11.size);
- for (int _i12 = 0; _i12 < _list11.size; ++_i12)
+ org.apache.thrift.protocol.TList _list19 = iprot.readListBegin();
+ struct.preJobCommands = new ArrayList<String>(_list19.size);
+ for (int _i20 = 0; _i20 < _list19.size; ++_i20)
{
- String _elem13;
- _elem13 = iprot.readString();
- struct.preJobCommands.add(_elem13);
+ String _elem21;
+ _elem21 = iprot.readString();
+ struct.preJobCommands.add(_elem21);
}
iprot.readListEnd();
}
@@ -1004,13 +1004,13 @@ import org.slf4j.LoggerFactory;
case 6: // POST_JOB_COMMANDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list14 = iprot.readListBegin();
- struct.postJobCommands = new ArrayList<String>(_list14.size);
- for (int _i15 = 0; _i15 < _list14.size; ++_i15)
+ org.apache.thrift.protocol.TList _list22 = iprot.readListBegin();
+ struct.postJobCommands = new ArrayList<String>(_list22.size);
+ for (int _i23 = 0; _i23 < _list22.size; ++_i23)
{
- String _elem16;
- _elem16 = iprot.readString();
- struct.postJobCommands.add(_elem16);
+ String _elem24;
+ _elem24 = iprot.readString();
+ struct.postJobCommands.add(_elem24);
}
iprot.readListEnd();
}
@@ -1068,9 +1068,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(EXPORTS_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.exports.size()));
- for (String _iter17 : struct.exports)
+ for (String _iter25 : struct.exports)
{
- oprot.writeString(_iter17);
+ oprot.writeString(_iter25);
}
oprot.writeSetEnd();
}
@@ -1082,9 +1082,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PRE_JOB_COMMANDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.preJobCommands.size()));
- for (String _iter18 : struct.preJobCommands)
+ for (String _iter26 : struct.preJobCommands)
{
- oprot.writeString(_iter18);
+ oprot.writeString(_iter26);
}
oprot.writeListEnd();
}
@@ -1096,9 +1096,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(POST_JOB_COMMANDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.postJobCommands.size()));
- for (String _iter19 : struct.postJobCommands)
+ for (String _iter27 : struct.postJobCommands)
{
- oprot.writeString(_iter19);
+ oprot.writeString(_iter27);
}
oprot.writeListEnd();
}
@@ -1164,27 +1164,27 @@ import org.slf4j.LoggerFactory;
if (struct.isSetExports()) {
{
oprot.writeI32(struct.exports.size());
- for (String _iter20 : struct.exports)
+ for (String _iter28 : struct.exports)
{
- oprot.writeString(_iter20);
+ oprot.writeString(_iter28);
}
}
}
if (struct.isSetPreJobCommands()) {
{
oprot.writeI32(struct.preJobCommands.size());
- for (String _iter21 : struct.preJobCommands)
+ for (String _iter29 : struct.preJobCommands)
{
- oprot.writeString(_iter21);
+ oprot.writeString(_iter29);
}
}
}
if (struct.isSetPostJobCommands()) {
{
oprot.writeI32(struct.postJobCommands.size());
- for (String _iter22 : struct.postJobCommands)
+ for (String _iter30 : struct.postJobCommands)
{
- oprot.writeString(_iter22);
+ oprot.writeString(_iter30);
}
}
}
@@ -1210,39 +1210,39 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TSet _set23 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.exports = new HashSet<String>(2*_set23.size);
- for (int _i24 = 0; _i24 < _set23.size; ++_i24)
+ org.apache.thrift.protocol.TSet _set31 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.exports = new HashSet<String>(2*_set31.size);
+ for (int _i32 = 0; _i32 < _set31.size; ++_i32)
{
- String _elem25;
- _elem25 = iprot.readString();
- struct.exports.add(_elem25);
+ String _elem33;
+ _elem33 = iprot.readString();
+ struct.exports.add(_elem33);
}
}
struct.setExportsIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list26 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.preJobCommands = new ArrayList<String>(_list26.size);
- for (int _i27 = 0; _i27 < _list26.size; ++_i27)
+ org.apache.thrift.protocol.TList _list34 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.preJobCommands = new ArrayList<String>(_list34.size);
+ for (int _i35 = 0; _i35 < _list34.size; ++_i35)
{
- String _elem28;
- _elem28 = iprot.readString();
- struct.preJobCommands.add(_elem28);
+ String _elem36;
+ _elem36 = iprot.readString();
+ struct.preJobCommands.add(_elem36);
}
}
struct.setPreJobCommandsIsSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list29 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.postJobCommands = new ArrayList<String>(_list29.size);
- for (int _i30 = 0; _i30 < _list29.size; ++_i30)
+ org.apache.thrift.protocol.TList _list37 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.postJobCommands = new ArrayList<String>(_list37.size);
+ for (int _i38 = 0; _i38 < _list37.size; ++_i38)
{
- String _elem31;
- _elem31 = iprot.readString();
- struct.postJobCommands.add(_elem31);
+ String _elem39;
+ _elem39 = iprot.readString();
+ struct.postJobCommands.add(_elem39);
}
}
struct.setPostJobCommandsIsSet(true);
http://git-wip-us.apache.org/repos/asf/airavata/blob/fef7c4ac/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GlobusJobSubmission.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GlobusJobSubmission.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GlobusJobSubmission.java
index db7485c..e895d01 100644
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GlobusJobSubmission.java
+++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/GlobusJobSubmission.java
@@ -645,13 +645,13 @@ import org.slf4j.LoggerFactory;
case 4: // GLOBUS_GATE_KEEPER_END_POINT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
- struct.globusGateKeeperEndPoint = new ArrayList<String>(_list0.size);
- for (int _i1 = 0; _i1 < _list0.size; ++_i1)
+ org.apache.thrift.protocol.TList _list8 = iprot.readListBegin();
+ struct.globusGateKeeperEndPoint = new ArrayList<String>(_list8.size);
+ for (int _i9 = 0; _i9 < _list8.size; ++_i9)
{
- String _elem2;
- _elem2 = iprot.readString();
- struct.globusGateKeeperEndPoint.add(_elem2);
+ String _elem10;
+ _elem10 = iprot.readString();
+ struct.globusGateKeeperEndPoint.add(_elem10);
}
iprot.readListEnd();
}
@@ -693,9 +693,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(GLOBUS_GATE_KEEPER_END_POINT_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.globusGateKeeperEndPoint.size()));
- for (String _iter3 : struct.globusGateKeeperEndPoint)
+ for (String _iter11 : struct.globusGateKeeperEndPoint)
{
- oprot.writeString(_iter3);
+ oprot.writeString(_iter11);
}
oprot.writeListEnd();
}
@@ -730,9 +730,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetGlobusGateKeeperEndPoint()) {
{
oprot.writeI32(struct.globusGateKeeperEndPoint.size());
- for (String _iter4 : struct.globusGateKeeperEndPoint)
+ for (String _iter12 : struct.globusGateKeeperEndPoint)
{
- oprot.writeString(_iter4);
+ oprot.writeString(_iter12);
}
}
}
@@ -750,13 +750,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list5 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.globusGateKeeperEndPoint = new ArrayList<String>(_list5.size);
- for (int _i6 = 0; _i6 < _list5.size; ++_i6)
+ org.apache.thrift.protocol.TList _list13 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.globusGateKeeperEndPoint = new ArrayList<String>(_list13.size);
+ for (int _i14 = 0; _i14 < _list13.size; ++_i14)
{
- String _elem7;
- _elem7 = iprot.readString();
- struct.globusGateKeeperEndPoint.add(_elem7);
+ String _elem15;
+ _elem15 = iprot.readString();
+ struct.globusGateKeeperEndPoint.add(_elem15);
}
}
struct.setGlobusGateKeeperEndPointIsSet(true);