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/23 14:27:35 UTC
[2/3] git commit: introducing a namespace for php app catalog models
introducing a namespace for php app catalog models
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/2c24439c
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/2c24439c
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/2c24439c
Branch: refs/heads/master
Commit: 2c24439cc4ce4436cb6c32d6a436290ed48992ba
Parents: 1d76b48
Author: samindaw <sa...@gmail.com>
Authored: Fri May 23 05:26:44 2014 -0700
Committer: samindaw <sa...@gmail.com>
Committed: Fri May 23 05:26:44 2014 -0700
----------------------------------------------------------------------
.../API/AppCatalog/ApplicationCatalogAPI.php | 116 +-
.../lib/Airavata/Model/AppCatalog/Types.php | 1636 ++++++++++++++++++
.../src/main/resources/lib/Types.php | 1636 ------------------
.../applicationCatalogDataModel.thrift | 1 +
4 files changed, 1695 insertions(+), 1694 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/2c24439c/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 b8cc4be..e2082cb 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
@@ -18,12 +18,12 @@ use Thrift\Exception\TApplicationException;
interface ApplicationCatalogAPIIf {
public function GetAPIVersion();
- public function addComputeResourceDescription(\ComputeResourceDescription $computeResourceDescription);
- public function addSSHJobSubmissionProtocol($computeResourceId, \SSHJobSubmission $jobSubmission);
- 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 addComputeResourceDescription(\Airavata\Model\AppCatalog\ComputeResourceDescription $computeResourceDescription);
+ public function addSSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\SSHJobSubmission $jobSubmission);
+ public function addGSISSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GSISSHJobSubmission $jobSubmission);
+ public function addGlobusJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GlobusJobSubmission $jobSubmission);
+ public function addSCPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\SCPDataMovement $dataMovement);
+ public function addGridFTPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\GridFTPDataMovement $dataMovement);
public function listComputeResourceDescriptions();
public function getComputeResourceDescription($computeResourceId);
public function getSSHJobSubmissionProtocol($sshJobSubmissionProtocolResourceId);
@@ -33,10 +33,10 @@ interface ApplicationCatalogAPIIf {
public function getGridFTPDataMovementProtocol($gridFTPDataMovementResourceId);
public function isComputeResourceDescriptionRegistered($hostName);
public function getComputeResourceDescriptionFromHostName($hostName);
- public function addApplicationInterface(\ApplicationInterface $applicationInterface);
+ public function addApplicationInterface(\Airavata\Model\AppCatalog\ApplicationInterface $applicationInterface);
public function listApplicationInterfaceIds();
public function getApplicationInterface($applicationInterfaceId);
- public function addApplicationDeployment($applicationInterfaceId, \ApplicationDeployment $applicationDeployment);
+ public function addApplicationDeployment($applicationInterfaceId, \Airavata\Model\AppCatalog\ApplicationDeployment $applicationDeployment);
public function listApplicationDeploymentIds($applicationInterfaceId);
public function getApplicationDeployment($applicationInterfaceId, $applicationDeploymentId);
}
@@ -102,13 +102,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("GetAPIVersion failed: unknown result");
}
- public function addComputeResourceDescription(\ComputeResourceDescription $computeResourceDescription)
+ public function addComputeResourceDescription(\Airavata\Model\AppCatalog\ComputeResourceDescription $computeResourceDescription)
{
$this->send_addComputeResourceDescription($computeResourceDescription);
return $this->recv_addComputeResourceDescription();
}
- public function send_addComputeResourceDescription(\ComputeResourceDescription $computeResourceDescription)
+ public function send_addComputeResourceDescription(\Airavata\Model\AppCatalog\ComputeResourceDescription $computeResourceDescription)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addComputeResourceDescription_args();
$args->computeResourceDescription = $computeResourceDescription;
@@ -162,13 +162,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("addComputeResourceDescription failed: unknown result");
}
- public function addSSHJobSubmissionProtocol($computeResourceId, \SSHJobSubmission $jobSubmission)
+ public function addSSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\SSHJobSubmission $jobSubmission)
{
$this->send_addSSHJobSubmissionProtocol($computeResourceId, $jobSubmission);
return $this->recv_addSSHJobSubmissionProtocol();
}
- public function send_addSSHJobSubmissionProtocol($computeResourceId, \SSHJobSubmission $jobSubmission)
+ public function send_addSSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\SSHJobSubmission $jobSubmission)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addSSHJobSubmissionProtocol_args();
$args->computeResourceId = $computeResourceId;
@@ -223,13 +223,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("addSSHJobSubmissionProtocol failed: unknown result");
}
- public function addGSISSHJobSubmissionProtocol($computeResourceId, \GSISSHJobSubmission $jobSubmission)
+ public function addGSISSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GSISSHJobSubmission $jobSubmission)
{
$this->send_addGSISSHJobSubmissionProtocol($computeResourceId, $jobSubmission);
return $this->recv_addGSISSHJobSubmissionProtocol();
}
- public function send_addGSISSHJobSubmissionProtocol($computeResourceId, \GSISSHJobSubmission $jobSubmission)
+ public function send_addGSISSHJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GSISSHJobSubmission $jobSubmission)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_args();
$args->computeResourceId = $computeResourceId;
@@ -284,13 +284,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("addGSISSHJobSubmissionProtocol failed: unknown result");
}
- public function addGlobusJobSubmissionProtocol($computeResourceId, \GlobusJobSubmission $jobSubmission)
+ public function addGlobusJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GlobusJobSubmission $jobSubmission)
{
$this->send_addGlobusJobSubmissionProtocol($computeResourceId, $jobSubmission);
return $this->recv_addGlobusJobSubmissionProtocol();
}
- public function send_addGlobusJobSubmissionProtocol($computeResourceId, \GlobusJobSubmission $jobSubmission)
+ public function send_addGlobusJobSubmissionProtocol($computeResourceId, \Airavata\Model\AppCatalog\GlobusJobSubmission $jobSubmission)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_args();
$args->computeResourceId = $computeResourceId;
@@ -345,13 +345,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("addGlobusJobSubmissionProtocol failed: unknown result");
}
- public function addSCPDataMovementProtocol($computeResourceId, \SCPDataMovement $dataMovement)
+ public function addSCPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\SCPDataMovement $dataMovement)
{
$this->send_addSCPDataMovementProtocol($computeResourceId, $dataMovement);
return $this->recv_addSCPDataMovementProtocol();
}
- public function send_addSCPDataMovementProtocol($computeResourceId, \SCPDataMovement $dataMovement)
+ public function send_addSCPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\SCPDataMovement $dataMovement)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addSCPDataMovementProtocol_args();
$args->computeResourceId = $computeResourceId;
@@ -406,13 +406,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("addSCPDataMovementProtocol failed: unknown result");
}
- public function addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement)
+ public function addGridFTPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\GridFTPDataMovement $dataMovement)
{
$this->send_addGridFTPDataMovementProtocol($computeResourceId, $dataMovement);
return $this->recv_addGridFTPDataMovementProtocol();
}
- public function send_addGridFTPDataMovementProtocol($computeResourceId, \GridFTPDataMovement $dataMovement)
+ public function send_addGridFTPDataMovementProtocol($computeResourceId, \Airavata\Model\AppCatalog\GridFTPDataMovement $dataMovement)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args();
$args->computeResourceId = $computeResourceId;
@@ -1006,13 +1006,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("getComputeResourceDescriptionFromHostName failed: unknown result");
}
- public function addApplicationInterface(\ApplicationInterface $applicationInterface)
+ public function addApplicationInterface(\Airavata\Model\AppCatalog\ApplicationInterface $applicationInterface)
{
$this->send_addApplicationInterface($applicationInterface);
return $this->recv_addApplicationInterface();
}
- public function send_addApplicationInterface(\ApplicationInterface $applicationInterface)
+ public function send_addApplicationInterface(\Airavata\Model\AppCatalog\ApplicationInterface $applicationInterface)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addApplicationInterface_args();
$args->applicationInterface = $applicationInterface;
@@ -1185,13 +1185,13 @@ class ApplicationCatalogAPIClient implements \Airavata\API\AppCatalog\Applicatio
throw new \Exception("getApplicationInterface failed: unknown result");
}
- public function addApplicationDeployment($applicationInterfaceId, \ApplicationDeployment $applicationDeployment)
+ public function addApplicationDeployment($applicationInterfaceId, \Airavata\Model\AppCatalog\ApplicationDeployment $applicationDeployment)
{
$this->send_addApplicationDeployment($applicationInterfaceId, $applicationDeployment);
return $this->recv_addApplicationDeployment();
}
- public function send_addApplicationDeployment($applicationInterfaceId, \ApplicationDeployment $applicationDeployment)
+ public function send_addApplicationDeployment($applicationInterfaceId, \Airavata\Model\AppCatalog\ApplicationDeployment $applicationDeployment)
{
$args = new \Airavata\API\AppCatalog\ApplicationCatalogAPI_addApplicationDeployment_args();
$args->applicationInterfaceId = $applicationInterfaceId;
@@ -1504,7 +1504,7 @@ class ApplicationCatalogAPI_addComputeResourceDescription_args {
1 => array(
'var' => 'computeResourceDescription',
'type' => TType::STRUCT,
- 'class' => '\ComputeResourceDescription',
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResourceDescription',
),
);
}
@@ -1536,7 +1536,7 @@ class ApplicationCatalogAPI_addComputeResourceDescription_args {
{
case 1:
if ($ftype == TType::STRUCT) {
- $this->computeResourceDescription = new \ComputeResourceDescription();
+ $this->computeResourceDescription = new \Airavata\Model\AppCatalog\ComputeResourceDescription();
$xfer += $this->computeResourceDescription->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -1724,7 +1724,7 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_args {
2 => array(
'var' => 'jobSubmission',
'type' => TType::STRUCT,
- 'class' => '\SSHJobSubmission',
+ 'class' => '\Airavata\Model\AppCatalog\SSHJobSubmission',
),
);
}
@@ -1766,7 +1766,7 @@ class ApplicationCatalogAPI_addSSHJobSubmissionProtocol_args {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->jobSubmission = new \SSHJobSubmission();
+ $this->jobSubmission = new \Airavata\Model\AppCatalog\SSHJobSubmission();
$xfer += $this->jobSubmission->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -1959,7 +1959,7 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_args {
2 => array(
'var' => 'jobSubmission',
'type' => TType::STRUCT,
- 'class' => '\GSISSHJobSubmission',
+ 'class' => '\Airavata\Model\AppCatalog\GSISSHJobSubmission',
),
);
}
@@ -2001,7 +2001,7 @@ class ApplicationCatalogAPI_addGSISSHJobSubmissionProtocol_args {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->jobSubmission = new \GSISSHJobSubmission();
+ $this->jobSubmission = new \Airavata\Model\AppCatalog\GSISSHJobSubmission();
$xfer += $this->jobSubmission->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -2194,7 +2194,7 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_args {
2 => array(
'var' => 'jobSubmission',
'type' => TType::STRUCT,
- 'class' => '\GlobusJobSubmission',
+ 'class' => '\Airavata\Model\AppCatalog\GlobusJobSubmission',
),
);
}
@@ -2236,7 +2236,7 @@ class ApplicationCatalogAPI_addGlobusJobSubmissionProtocol_args {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->jobSubmission = new \GlobusJobSubmission();
+ $this->jobSubmission = new \Airavata\Model\AppCatalog\GlobusJobSubmission();
$xfer += $this->jobSubmission->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -2429,7 +2429,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args {
2 => array(
'var' => 'dataMovement',
'type' => TType::STRUCT,
- 'class' => '\SCPDataMovement',
+ 'class' => '\Airavata\Model\AppCatalog\SCPDataMovement',
),
);
}
@@ -2471,7 +2471,7 @@ class ApplicationCatalogAPI_addSCPDataMovementProtocol_args {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->dataMovement = new \SCPDataMovement();
+ $this->dataMovement = new \Airavata\Model\AppCatalog\SCPDataMovement();
$xfer += $this->dataMovement->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -2664,7 +2664,7 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args {
2 => array(
'var' => 'dataMovement',
'type' => TType::STRUCT,
- 'class' => '\GridFTPDataMovement',
+ 'class' => '\Airavata\Model\AppCatalog\GridFTPDataMovement',
),
);
}
@@ -2706,7 +2706,7 @@ class ApplicationCatalogAPI_addGridFTPDataMovementProtocol_args {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->dataMovement = new \GridFTPDataMovement();
+ $this->dataMovement = new \Airavata\Model\AppCatalog\GridFTPDataMovement();
$xfer += $this->dataMovement->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -3183,7 +3183,7 @@ class ApplicationCatalogAPI_getComputeResourceDescription_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\ComputeResourceDescription',
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResourceDescription',
),
1 => array(
'var' => 'ire',
@@ -3239,7 +3239,7 @@ class ApplicationCatalogAPI_getComputeResourceDescription_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \ComputeResourceDescription();
+ $this->success = new \Airavata\Model\AppCatalog\ComputeResourceDescription();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -3398,7 +3398,7 @@ class ApplicationCatalogAPI_getSSHJobSubmissionProtocol_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\SSHJobSubmission',
+ 'class' => '\Airavata\Model\AppCatalog\SSHJobSubmission',
),
1 => array(
'var' => 'ire',
@@ -3454,7 +3454,7 @@ class ApplicationCatalogAPI_getSSHJobSubmissionProtocol_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \SSHJobSubmission();
+ $this->success = new \Airavata\Model\AppCatalog\SSHJobSubmission();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -3613,7 +3613,7 @@ class ApplicationCatalogAPI_getGSISSHJobSubmissionProtocol_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\GSISSHJobSubmission',
+ 'class' => '\Airavata\Model\AppCatalog\GSISSHJobSubmission',
),
1 => array(
'var' => 'ire',
@@ -3669,7 +3669,7 @@ class ApplicationCatalogAPI_getGSISSHJobSubmissionProtocol_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \GSISSHJobSubmission();
+ $this->success = new \Airavata\Model\AppCatalog\GSISSHJobSubmission();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -3828,7 +3828,7 @@ class ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\GlobusJobSubmission',
+ 'class' => '\Airavata\Model\AppCatalog\GlobusJobSubmission',
),
1 => array(
'var' => 'ire',
@@ -3884,7 +3884,7 @@ class ApplicationCatalogAPI_getGlobusJobSubmissionProtocol_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \GlobusJobSubmission();
+ $this->success = new \Airavata\Model\AppCatalog\GlobusJobSubmission();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -4043,7 +4043,7 @@ class ApplicationCatalogAPI_getSCPDataMovementProtocol_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\SCPDataMovement',
+ 'class' => '\Airavata\Model\AppCatalog\SCPDataMovement',
),
1 => array(
'var' => 'ire',
@@ -4099,7 +4099,7 @@ class ApplicationCatalogAPI_getSCPDataMovementProtocol_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \SCPDataMovement();
+ $this->success = new \Airavata\Model\AppCatalog\SCPDataMovement();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -4258,7 +4258,7 @@ class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\GridFTPDataMovement',
+ 'class' => '\Airavata\Model\AppCatalog\GridFTPDataMovement',
),
1 => array(
'var' => 'ire',
@@ -4314,7 +4314,7 @@ class ApplicationCatalogAPI_getGridFTPDataMovementProtocol_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \GridFTPDataMovement();
+ $this->success = new \Airavata\Model\AppCatalog\GridFTPDataMovement();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -4683,7 +4683,7 @@ class ApplicationCatalogAPI_getComputeResourceDescriptionFromHostName_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\ComputeResourceDescription',
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResourceDescription',
),
1 => array(
'var' => 'ire',
@@ -4739,7 +4739,7 @@ class ApplicationCatalogAPI_getComputeResourceDescriptionFromHostName_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \ComputeResourceDescription();
+ $this->success = new \Airavata\Model\AppCatalog\ComputeResourceDescription();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -4823,7 +4823,7 @@ class ApplicationCatalogAPI_addApplicationInterface_args {
1 => array(
'var' => 'applicationInterface',
'type' => TType::STRUCT,
- 'class' => '\ApplicationInterface',
+ 'class' => '\Airavata\Model\AppCatalog\ApplicationInterface',
),
);
}
@@ -4855,7 +4855,7 @@ class ApplicationCatalogAPI_addApplicationInterface_args {
{
case 1:
if ($ftype == TType::STRUCT) {
- $this->applicationInterface = new \ApplicationInterface();
+ $this->applicationInterface = new \Airavata\Model\AppCatalog\ApplicationInterface();
$xfer += $this->applicationInterface->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -5327,7 +5327,7 @@ class ApplicationCatalogAPI_getApplicationInterface_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\ApplicationInterface',
+ 'class' => '\Airavata\Model\AppCatalog\ApplicationInterface',
),
1 => array(
'var' => 'ire',
@@ -5383,7 +5383,7 @@ class ApplicationCatalogAPI_getApplicationInterface_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \ApplicationInterface();
+ $this->success = new \Airavata\Model\AppCatalog\ApplicationInterface();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -5472,7 +5472,7 @@ class ApplicationCatalogAPI_addApplicationDeployment_args {
2 => array(
'var' => 'applicationDeployment',
'type' => TType::STRUCT,
- 'class' => '\ApplicationDeployment',
+ 'class' => '\Airavata\Model\AppCatalog\ApplicationDeployment',
),
);
}
@@ -5514,7 +5514,7 @@ class ApplicationCatalogAPI_addApplicationDeployment_args {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->applicationDeployment = new \ApplicationDeployment();
+ $this->applicationDeployment = new \Airavata\Model\AppCatalog\ApplicationDeployment();
$xfer += $this->applicationDeployment->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -6033,7 +6033,7 @@ class ApplicationCatalogAPI_getApplicationDeployment_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\ApplicationDeployment',
+ 'class' => '\Airavata\Model\AppCatalog\ApplicationDeployment',
),
1 => array(
'var' => 'ire',
@@ -6089,7 +6089,7 @@ class ApplicationCatalogAPI_getApplicationDeployment_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \ApplicationDeployment();
+ $this->success = new \Airavata\Model\AppCatalog\ApplicationDeployment();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
http://git-wip-us.apache.org/repos/asf/airavata/blob/2c24439c/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/Types.php
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/Types.php
new file mode 100644
index 0000000..2e4c195
--- /dev/null
+++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/AppCatalog/Types.php
@@ -0,0 +1,1636 @@
+<?php
+namespace Airavata\Model\AppCatalog;
+
+/**
+ * Autogenerated by Thrift Compiler (0.9.1)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+use Thrift\Base\TBase;
+use Thrift\Type\TType;
+use Thrift\Type\TMessageType;
+use Thrift\Exception\TException;
+use Thrift\Exception\TProtocolException;
+use Thrift\Protocol\TProtocol;
+use Thrift\Protocol\TBinaryProtocolAccelerated;
+use Thrift\Exception\TApplicationException;
+
+
+final class ResourceJobManager {
+ const FORK = 0;
+ const PBS = 1;
+ const UGE = 2;
+ const SLURM = 3;
+ static public $__names = array(
+ 0 => 'FORK',
+ 1 => 'PBS',
+ 2 => 'UGE',
+ 3 => 'SLURM',
+ );
+}
+
+final class JobSubmissionProtocol {
+ const SSH = 0;
+ const GSISSH = 1;
+ const GRAM = 2;
+ const UNICORE = 3;
+ static public $__names = array(
+ 0 => 'SSH',
+ 1 => 'GSISSH',
+ 2 => 'GRAM',
+ 3 => 'UNICORE',
+ );
+}
+
+final class DataMovementProtocol {
+ const SCP = 0;
+ const SFTP = 1;
+ const GridFTP = 2;
+ const UNICORE_STORAGE_SERVICE = 3;
+ static public $__names = array(
+ 0 => 'SCP',
+ 1 => 'SFTP',
+ 2 => 'GridFTP',
+ 3 => 'UNICORE_STORAGE_SERVICE',
+ );
+}
+
+final class SecurityProtocol {
+ const USERNAME_PASSWORD = 0;
+ const SSH_KEYS = 1;
+ const GSI = 2;
+ const KERBEROS = 3;
+ const OAUTH = 4;
+ static public $__names = array(
+ 0 => 'USERNAME_PASSWORD',
+ 1 => 'SSH_KEYS',
+ 2 => 'GSI',
+ 3 => 'KERBEROS',
+ 4 => 'OAUTH',
+ );
+}
+
+class SCPDataMovement {
+ static $_TSPEC;
+
+ public $dataMovementDataID = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $sshPort = 22;
+
+ 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' => 'sshPort',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementDataID'])) {
+ $this->dataMovementDataID = $vals['dataMovementDataID'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['sshPort'])) {
+ $this->sshPort = $vals['sshPort'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'SCPDataMovement';
+ }
+
+ 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::I32) {
+ $xfer += $input->readI32($this->sshPort);
+ } 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('SCPDataMovement');
+ 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->sshPort !== null) {
+ $xfer += $output->writeFieldBegin('sshPort', TType::I32, 3);
+ $xfer += $output->writeI32($this->sshPort);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+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;
+
+ public $jobSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
+ public $resourceJobManager = null;
+ public $sshPort = 22;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionDataID',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'resourceJobManager',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'sshPort',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionDataID'])) {
+ $this->jobSubmissionDataID = $vals['jobSubmissionDataID'];
+ }
+ if (isset($vals['resourceJobManager'])) {
+ $this->resourceJobManager = $vals['resourceJobManager'];
+ }
+ if (isset($vals['sshPort'])) {
+ $this->sshPort = $vals['sshPort'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'SSHJobSubmission';
+ }
+
+ 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->jobSubmissionDataID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->resourceJobManager);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->sshPort);
+ } 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('SSHJobSubmission');
+ if ($this->jobSubmissionDataID !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionDataID', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionDataID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceJobManager !== null) {
+ $xfer += $output->writeFieldBegin('resourceJobManager', TType::I32, 2);
+ $xfer += $output->writeI32($this->resourceJobManager);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->sshPort !== null) {
+ $xfer += $output->writeFieldBegin('sshPort', TType::I32, 3);
+ $xfer += $output->writeI32($this->sshPort);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class GlobusJobSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $resourceJobManager = null;
+ public $globusGateKeeperEndPoint = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionDataID',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'resourceJobManager',
+ 'type' => TType::I32,
+ ),
+ 4 => array(
+ 'var' => 'globusGateKeeperEndPoint',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionDataID'])) {
+ $this->jobSubmissionDataID = $vals['jobSubmissionDataID'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['resourceJobManager'])) {
+ $this->resourceJobManager = $vals['resourceJobManager'];
+ }
+ if (isset($vals['globusGateKeeperEndPoint'])) {
+ $this->globusGateKeeperEndPoint = $vals['globusGateKeeperEndPoint'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'GlobusJobSubmission';
+ }
+
+ 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->jobSubmissionDataID);
+ } 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::I32) {
+ $xfer += $input->readI32($this->resourceJobManager);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->globusGateKeeperEndPoint = array();
+ $_size7 = 0;
+ $_etype10 = 0;
+ $xfer += $input->readListBegin($_etype10, $_size7);
+ for ($_i11 = 0; $_i11 < $_size7; ++$_i11)
+ {
+ $elem12 = null;
+ $xfer += $input->readString($elem12);
+ $this->globusGateKeeperEndPoint []= $elem12;
+ }
+ $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('GlobusJobSubmission');
+ if ($this->jobSubmissionDataID !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionDataID', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionDataID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceJobManager !== null) {
+ $xfer += $output->writeFieldBegin('resourceJobManager', TType::I32, 3);
+ $xfer += $output->writeI32($this->resourceJobManager);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->globusGateKeeperEndPoint !== null) {
+ if (!is_array($this->globusGateKeeperEndPoint)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('globusGateKeeperEndPoint', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRING, count($this->globusGateKeeperEndPoint));
+ {
+ foreach ($this->globusGateKeeperEndPoint as $iter13)
+ {
+ $xfer += $output->writeString($iter13);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class GSISSHJobSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionDataID = "DO_NOT_SET_AT_CLIENTS";
+ public $resourceJobManager = null;
+ public $sshPort = 22;
+ public $exports = null;
+ public $preJobCommands = null;
+ public $postJobCommands = null;
+ public $installedPath = null;
+ public $monitorMode = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionDataID',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'resourceJobManager',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'sshPort',
+ 'type' => TType::I32,
+ ),
+ 4 => array(
+ 'var' => 'exports',
+ 'type' => TType::SET,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 5 => array(
+ 'var' => 'preJobCommands',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 6 => array(
+ 'var' => 'postJobCommands',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 7 => array(
+ 'var' => 'installedPath',
+ 'type' => TType::STRING,
+ ),
+ 8 => array(
+ 'var' => 'monitorMode',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionDataID'])) {
+ $this->jobSubmissionDataID = $vals['jobSubmissionDataID'];
+ }
+ if (isset($vals['resourceJobManager'])) {
+ $this->resourceJobManager = $vals['resourceJobManager'];
+ }
+ if (isset($vals['sshPort'])) {
+ $this->sshPort = $vals['sshPort'];
+ }
+ if (isset($vals['exports'])) {
+ $this->exports = $vals['exports'];
+ }
+ if (isset($vals['preJobCommands'])) {
+ $this->preJobCommands = $vals['preJobCommands'];
+ }
+ if (isset($vals['postJobCommands'])) {
+ $this->postJobCommands = $vals['postJobCommands'];
+ }
+ if (isset($vals['installedPath'])) {
+ $this->installedPath = $vals['installedPath'];
+ }
+ if (isset($vals['monitorMode'])) {
+ $this->monitorMode = $vals['monitorMode'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'GSISSHJobSubmission';
+ }
+
+ 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->jobSubmissionDataID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->resourceJobManager);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->sshPort);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::SET) {
+ $this->exports = array();
+ $_size14 = 0;
+ $_etype17 = 0;
+ $xfer += $input->readSetBegin($_etype17, $_size14);
+ for ($_i18 = 0; $_i18 < $_size14; ++$_i18)
+ {
+ $elem19 = null;
+ $xfer += $input->readString($elem19);
+ if (is_scalar($elem19)) {
+ $this->exports[$elem19] = true;
+ } else {
+ $this->exports []= $elem19;
+ }
+ }
+ $xfer += $input->readSetEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::LST) {
+ $this->preJobCommands = array();
+ $_size20 = 0;
+ $_etype23 = 0;
+ $xfer += $input->readListBegin($_etype23, $_size20);
+ for ($_i24 = 0; $_i24 < $_size20; ++$_i24)
+ {
+ $elem25 = null;
+ $xfer += $input->readString($elem25);
+ $this->preJobCommands []= $elem25;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->postJobCommands = array();
+ $_size26 = 0;
+ $_etype29 = 0;
+ $xfer += $input->readListBegin($_etype29, $_size26);
+ for ($_i30 = 0; $_i30 < $_size26; ++$_i30)
+ {
+ $elem31 = null;
+ $xfer += $input->readString($elem31);
+ $this->postJobCommands []= $elem31;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->installedPath);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->monitorMode);
+ } 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('GSISSHJobSubmission');
+ if ($this->jobSubmissionDataID !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionDataID', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionDataID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceJobManager !== null) {
+ $xfer += $output->writeFieldBegin('resourceJobManager', TType::I32, 2);
+ $xfer += $output->writeI32($this->resourceJobManager);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->sshPort !== null) {
+ $xfer += $output->writeFieldBegin('sshPort', TType::I32, 3);
+ $xfer += $output->writeI32($this->sshPort);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->exports !== null) {
+ if (!is_array($this->exports)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('exports', TType::SET, 4);
+ {
+ $output->writeSetBegin(TType::STRING, count($this->exports));
+ {
+ foreach ($this->exports as $iter32 => $iter33)
+ {
+ if (is_scalar($iter33)) {
+ $xfer += $output->writeString($iter32);
+ } else {
+ $xfer += $output->writeString($iter33);
+ }
+ }
+ }
+ $output->writeSetEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->preJobCommands !== null) {
+ if (!is_array($this->preJobCommands)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('preJobCommands', TType::LST, 5);
+ {
+ $output->writeListBegin(TType::STRING, count($this->preJobCommands));
+ {
+ foreach ($this->preJobCommands as $iter34)
+ {
+ $xfer += $output->writeString($iter34);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->postJobCommands !== null) {
+ if (!is_array($this->postJobCommands)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('postJobCommands', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRING, count($this->postJobCommands));
+ {
+ foreach ($this->postJobCommands as $iter35)
+ {
+ $xfer += $output->writeString($iter35);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->installedPath !== null) {
+ $xfer += $output->writeFieldBegin('installedPath', TType::STRING, 7);
+ $xfer += $output->writeString($this->installedPath);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->monitorMode !== null) {
+ $xfer += $output->writeFieldBegin('monitorMode', TType::STRING, 8);
+ $xfer += $output->writeString($this->monitorMode);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ComputeResourceDescription {
+ static $_TSPEC;
+
+ public $isEmpty = false;
+ public $resourceId = "DO_NOT_SET_AT_CLIENTS";
+ public $hostName = null;
+ public $hostAliases = null;
+ public $ipAddresses = null;
+ public $resourceDescription = null;
+ public $scratchLocation = null;
+ public $preferredJobSubmissionProtocol = null;
+ public $jobSubmissionProtocols = null;
+ public $dataMovementProtocols = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'isEmpty',
+ 'type' => TType::BOOL,
+ ),
+ 2 => array(
+ 'var' => 'resourceId',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'hostName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'hostAliases',
+ 'type' => TType::SET,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 5 => array(
+ 'var' => 'ipAddresses',
+ 'type' => TType::SET,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 6 => array(
+ 'var' => 'resourceDescription',
+ 'type' => TType::STRING,
+ ),
+ 7 => array(
+ 'var' => 'scratchLocation',
+ 'type' => TType::STRING,
+ ),
+ 8 => array(
+ 'var' => 'preferredJobSubmissionProtocol',
+ 'type' => TType::STRING,
+ ),
+ 9 => array(
+ 'var' => 'jobSubmissionProtocols',
+ 'type' => TType::MAP,
+ 'ktype' => TType::STRING,
+ 'vtype' => TType::I32,
+ 'key' => array(
+ 'type' => TType::STRING,
+ ),
+ 'val' => array(
+ 'type' => TType::I32,
+ ),
+ ),
+ 10 => array(
+ 'var' => 'dataMovementProtocols',
+ 'type' => TType::MAP,
+ 'ktype' => TType::STRING,
+ 'vtype' => TType::I32,
+ 'key' => array(
+ 'type' => TType::STRING,
+ ),
+ 'val' => array(
+ 'type' => TType::I32,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['isEmpty'])) {
+ $this->isEmpty = $vals['isEmpty'];
+ }
+ if (isset($vals['resourceId'])) {
+ $this->resourceId = $vals['resourceId'];
+ }
+ if (isset($vals['hostName'])) {
+ $this->hostName = $vals['hostName'];
+ }
+ if (isset($vals['hostAliases'])) {
+ $this->hostAliases = $vals['hostAliases'];
+ }
+ if (isset($vals['ipAddresses'])) {
+ $this->ipAddresses = $vals['ipAddresses'];
+ }
+ if (isset($vals['resourceDescription'])) {
+ $this->resourceDescription = $vals['resourceDescription'];
+ }
+ if (isset($vals['scratchLocation'])) {
+ $this->scratchLocation = $vals['scratchLocation'];
+ }
+ if (isset($vals['preferredJobSubmissionProtocol'])) {
+ $this->preferredJobSubmissionProtocol = $vals['preferredJobSubmissionProtocol'];
+ }
+ if (isset($vals['jobSubmissionProtocols'])) {
+ $this->jobSubmissionProtocols = $vals['jobSubmissionProtocols'];
+ }
+ if (isset($vals['dataMovementProtocols'])) {
+ $this->dataMovementProtocols = $vals['dataMovementProtocols'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ComputeResourceDescription';
+ }
+
+ 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::BOOL) {
+ $xfer += $input->readBool($this->isEmpty);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->resourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->hostName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::SET) {
+ $this->hostAliases = array();
+ $_size36 = 0;
+ $_etype39 = 0;
+ $xfer += $input->readSetBegin($_etype39, $_size36);
+ for ($_i40 = 0; $_i40 < $_size36; ++$_i40)
+ {
+ $elem41 = null;
+ $xfer += $input->readString($elem41);
+ if (is_scalar($elem41)) {
+ $this->hostAliases[$elem41] = true;
+ } else {
+ $this->hostAliases []= $elem41;
+ }
+ }
+ $xfer += $input->readSetEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::SET) {
+ $this->ipAddresses = array();
+ $_size42 = 0;
+ $_etype45 = 0;
+ $xfer += $input->readSetBegin($_etype45, $_size42);
+ for ($_i46 = 0; $_i46 < $_size42; ++$_i46)
+ {
+ $elem47 = null;
+ $xfer += $input->readString($elem47);
+ if (is_scalar($elem47)) {
+ $this->ipAddresses[$elem47] = true;
+ } else {
+ $this->ipAddresses []= $elem47;
+ }
+ }
+ $xfer += $input->readSetEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->resourceDescription);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->scratchLocation);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->preferredJobSubmissionProtocol);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 9:
+ if ($ftype == TType::MAP) {
+ $this->jobSubmissionProtocols = array();
+ $_size48 = 0;
+ $_ktype49 = 0;
+ $_vtype50 = 0;
+ $xfer += $input->readMapBegin($_ktype49, $_vtype50, $_size48);
+ for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
+ {
+ $key53 = '';
+ $val54 = 0;
+ $xfer += $input->readString($key53);
+ $xfer += $input->readI32($val54);
+ $this->jobSubmissionProtocols[$key53] = $val54;
+ }
+ $xfer += $input->readMapEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 10:
+ if ($ftype == TType::MAP) {
+ $this->dataMovementProtocols = array();
+ $_size55 = 0;
+ $_ktype56 = 0;
+ $_vtype57 = 0;
+ $xfer += $input->readMapBegin($_ktype56, $_vtype57, $_size55);
+ for ($_i59 = 0; $_i59 < $_size55; ++$_i59)
+ {
+ $key60 = '';
+ $val61 = 0;
+ $xfer += $input->readString($key60);
+ $xfer += $input->readI32($val61);
+ $this->dataMovementProtocols[$key60] = $val61;
+ }
+ $xfer += $input->readMapEnd();
+ } 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('ComputeResourceDescription');
+ if ($this->isEmpty !== null) {
+ $xfer += $output->writeFieldBegin('isEmpty', TType::BOOL, 1);
+ $xfer += $output->writeBool($this->isEmpty);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceId !== null) {
+ $xfer += $output->writeFieldBegin('resourceId', TType::STRING, 2);
+ $xfer += $output->writeString($this->resourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->hostName !== null) {
+ $xfer += $output->writeFieldBegin('hostName', TType::STRING, 3);
+ $xfer += $output->writeString($this->hostName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->hostAliases !== null) {
+ if (!is_array($this->hostAliases)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('hostAliases', TType::SET, 4);
+ {
+ $output->writeSetBegin(TType::STRING, count($this->hostAliases));
+ {
+ foreach ($this->hostAliases as $iter62 => $iter63)
+ {
+ if (is_scalar($iter63)) {
+ $xfer += $output->writeString($iter62);
+ } else {
+ $xfer += $output->writeString($iter63);
+ }
+ }
+ }
+ $output->writeSetEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ipAddresses !== null) {
+ if (!is_array($this->ipAddresses)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('ipAddresses', TType::SET, 5);
+ {
+ $output->writeSetBegin(TType::STRING, count($this->ipAddresses));
+ {
+ foreach ($this->ipAddresses as $iter64 => $iter65)
+ {
+ if (is_scalar($iter65)) {
+ $xfer += $output->writeString($iter64);
+ } else {
+ $xfer += $output->writeString($iter65);
+ }
+ }
+ }
+ $output->writeSetEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceDescription !== null) {
+ $xfer += $output->writeFieldBegin('resourceDescription', TType::STRING, 6);
+ $xfer += $output->writeString($this->resourceDescription);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->scratchLocation !== null) {
+ $xfer += $output->writeFieldBegin('scratchLocation', TType::STRING, 7);
+ $xfer += $output->writeString($this->scratchLocation);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->preferredJobSubmissionProtocol !== null) {
+ $xfer += $output->writeFieldBegin('preferredJobSubmissionProtocol', TType::STRING, 8);
+ $xfer += $output->writeString($this->preferredJobSubmissionProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->jobSubmissionProtocols !== null) {
+ if (!is_array($this->jobSubmissionProtocols)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('jobSubmissionProtocols', TType::MAP, 9);
+ {
+ $output->writeMapBegin(TType::STRING, TType::I32, count($this->jobSubmissionProtocols));
+ {
+ foreach ($this->jobSubmissionProtocols as $kiter66 => $viter67)
+ {
+ $xfer += $output->writeString($kiter66);
+ $xfer += $output->writeI32($viter67);
+ }
+ }
+ $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMovementProtocols !== null) {
+ if (!is_array($this->dataMovementProtocols)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataMovementProtocols', TType::MAP, 10);
+ {
+ $output->writeMapBegin(TType::STRING, TType::I32, count($this->dataMovementProtocols));
+ {
+ foreach ($this->dataMovementProtocols as $kiter68 => $viter69)
+ {
+ $xfer += $output->writeString($kiter68);
+ $xfer += $output->writeI32($viter69);
+ }
+ }
+ $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ApplicationDescriptor {
+ static $_TSPEC;
+
+ public $applicationDescriptorId = "DO_NOT_SET_AT_CLIENTS";
+ public $applicationDescriptorData = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'applicationDescriptorId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'applicationDescriptorData',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['applicationDescriptorId'])) {
+ $this->applicationDescriptorId = $vals['applicationDescriptorId'];
+ }
+ if (isset($vals['applicationDescriptorData'])) {
+ $this->applicationDescriptorData = $vals['applicationDescriptorData'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationDescriptor';
+ }
+
+ 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->applicationDescriptorId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->applicationDescriptorData);
+ } 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('ApplicationDescriptor');
+ if ($this->applicationDescriptorId !== null) {
+ $xfer += $output->writeFieldBegin('applicationDescriptorId', TType::STRING, 1);
+ $xfer += $output->writeString($this->applicationDescriptorId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationDescriptorData !== null) {
+ $xfer += $output->writeFieldBegin('applicationDescriptorData', TType::STRING, 2);
+ $xfer += $output->writeString($this->applicationDescriptorData);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ApplicationDeployment {
+ static $_TSPEC;
+
+ public $deploymentId = "DO_NOT_SET_AT_CLIENTS";
+ public $computeResourceDescription = null;
+ public $applicationDescriptor = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'deploymentId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'computeResourceDescription',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResourceDescription',
+ ),
+ 3 => array(
+ 'var' => 'applicationDescriptor',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ApplicationDescriptor',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['deploymentId'])) {
+ $this->deploymentId = $vals['deploymentId'];
+ }
+ if (isset($vals['computeResourceDescription'])) {
+ $this->computeResourceDescription = $vals['computeResourceDescription'];
+ }
+ if (isset($vals['applicationDescriptor'])) {
+ $this->applicationDescriptor = $vals['applicationDescriptor'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationDeployment';
+ }
+
+ 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->deploymentId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->computeResourceDescription = new \Airavata\Model\AppCatalog\ComputeResourceDescription();
+ $xfer += $this->computeResourceDescription->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->applicationDescriptor = new \Airavata\Model\AppCatalog\ApplicationDescriptor();
+ $xfer += $this->applicationDescriptor->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('ApplicationDeployment');
+ if ($this->deploymentId !== null) {
+ $xfer += $output->writeFieldBegin('deploymentId', TType::STRING, 1);
+ $xfer += $output->writeString($this->deploymentId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->computeResourceDescription !== null) {
+ if (!is_object($this->computeResourceDescription)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('computeResourceDescription', TType::STRUCT, 2);
+ $xfer += $this->computeResourceDescription->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationDescriptor !== null) {
+ if (!is_object($this->applicationDescriptor)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('applicationDescriptor', TType::STRUCT, 3);
+ $xfer += $this->applicationDescriptor->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ApplicationInterface {
+ static $_TSPEC;
+
+ public $applicationInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $applicationInterfaceData = null;
+ public $applicationDeployments = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'applicationInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'applicationInterfaceData',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'applicationDeployments',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ApplicationDeployment',
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['applicationInterfaceId'])) {
+ $this->applicationInterfaceId = $vals['applicationInterfaceId'];
+ }
+ if (isset($vals['applicationInterfaceData'])) {
+ $this->applicationInterfaceData = $vals['applicationInterfaceData'];
+ }
+ if (isset($vals['applicationDeployments'])) {
+ $this->applicationDeployments = $vals['applicationDeployments'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ApplicationInterface';
+ }
+
+ 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->applicationInterfaceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->applicationInterfaceData);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::LST) {
+ $this->applicationDeployments = array();
+ $_size70 = 0;
+ $_etype73 = 0;
+ $xfer += $input->readListBegin($_etype73, $_size70);
+ for ($_i74 = 0; $_i74 < $_size70; ++$_i74)
+ {
+ $elem75 = null;
+ $elem75 = new \Airavata\Model\AppCatalog\ApplicationDeployment();
+ $xfer += $elem75->read($input);
+ $this->applicationDeployments []= $elem75;
+ }
+ $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('ApplicationInterface');
+ if ($this->applicationInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('applicationInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->applicationInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationInterfaceData !== null) {
+ $xfer += $output->writeFieldBegin('applicationInterfaceData', TType::STRING, 2);
+ $xfer += $output->writeString($this->applicationInterfaceData);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->applicationDeployments !== null) {
+ if (!is_array($this->applicationDeployments)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('applicationDeployments', TType::LST, 3);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->applicationDeployments));
+ {
+ foreach ($this->applicationDeployments as $iter76)
+ {
+ $xfer += $iter76->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+$GLOBALS['applicationCatalogDataModel_CONSTANTS']['DEFAULT_ID'] = "DO_NOT_SET_AT_CLIENTS";
+
+