You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by nd...@apache.org on 2015/05/01 23:33:31 UTC
[44/57] [partial] airavata-php-gateway git commit: AIRAVATA 1632 +
Job Description for Admin Dashboard
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/01413d65/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php b/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
new file mode 100644
index 0000000..be0f776
--- /dev/null
+++ b/app/libraries/Airavata/Model/AppCatalog/ComputeResource/Types.php
@@ -0,0 +1,2312 @@
+<?php
+namespace Airavata\Model\AppCatalog\ComputeResource;
+
+/**
+ * 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 ResourceJobManagerType {
+ const FORK = 0;
+ const PBS = 1;
+ const SLURM = 2;
+ const LSF = 3;
+ const UGE = 4;
+ static public $__names = array(
+ 0 => 'FORK',
+ 1 => 'PBS',
+ 2 => 'SLURM',
+ 3 => 'LSF',
+ 4 => 'UGE',
+ );
+}
+
+final class JobManagerCommand {
+ const SUBMISSION = 0;
+ const JOB_MONITORING = 1;
+ const DELETION = 2;
+ const CHECK_JOB = 3;
+ const SHOW_QUEUE = 4;
+ const SHOW_RESERVATION = 5;
+ const SHOW_START = 6;
+ static public $__names = array(
+ 0 => 'SUBMISSION',
+ 1 => 'JOB_MONITORING',
+ 2 => 'DELETION',
+ 3 => 'CHECK_JOB',
+ 4 => 'SHOW_QUEUE',
+ 5 => 'SHOW_RESERVATION',
+ 6 => 'SHOW_START',
+ );
+}
+
+final class FileSystems {
+ const HOME = 0;
+ const WORK = 1;
+ const LOCALTMP = 2;
+ const SCRATCH = 3;
+ const ARCHIVE = 4;
+ static public $__names = array(
+ 0 => 'HOME',
+ 1 => 'WORK',
+ 2 => 'LOCALTMP',
+ 3 => 'SCRATCH',
+ 4 => 'ARCHIVE',
+ );
+}
+
+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',
+ );
+}
+
+final class JobSubmissionProtocol {
+ const LOCAL = 0;
+ const SSH = 1;
+ const GLOBUS = 2;
+ const UNICORE = 3;
+ const CLOUD = 4;
+ static public $__names = array(
+ 0 => 'LOCAL',
+ 1 => 'SSH',
+ 2 => 'GLOBUS',
+ 3 => 'UNICORE',
+ 4 => 'CLOUD',
+ );
+}
+
+final class MonitorMode {
+ const POLL_JOB_MANAGER = 0;
+ const JOB_EMAIL_NOTIFICATION_MONITOR = 1;
+ const XSEDE_AMQP_SUBSCRIBE = 2;
+ static public $__names = array(
+ 0 => 'POLL_JOB_MANAGER',
+ 1 => 'JOB_EMAIL_NOTIFICATION_MONITOR',
+ 2 => 'XSEDE_AMQP_SUBSCRIBE',
+ );
+}
+
+final class DataMovementProtocol {
+ const LOCAL = 0;
+ const SCP = 1;
+ const SFTP = 2;
+ const GridFTP = 3;
+ const UNICORE_STORAGE_SERVICE = 4;
+ static public $__names = array(
+ 0 => 'LOCAL',
+ 1 => 'SCP',
+ 2 => 'SFTP',
+ 3 => 'GridFTP',
+ 4 => 'UNICORE_STORAGE_SERVICE',
+ );
+}
+
+final class ProviderName {
+ const EC2 = 0;
+ const AWSEC2 = 1;
+ const RACKSPACE = 2;
+ static public $__names = array(
+ 0 => 'EC2',
+ 1 => 'AWSEC2',
+ 2 => 'RACKSPACE',
+ );
+}
+
+class ResourceJobManager {
+ static $_TSPEC;
+
+ public $resourceJobManagerId = "DO_NOT_SET_AT_CLIENTS";
+ public $resourceJobManagerType = null;
+ public $pushMonitoringEndpoint = null;
+ public $jobManagerBinPath = null;
+ public $jobManagerCommands = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'resourceJobManagerId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'resourceJobManagerType',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'pushMonitoringEndpoint',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'jobManagerBinPath',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'jobManagerCommands',
+ 'type' => TType::MAP,
+ 'ktype' => TType::I32,
+ 'vtype' => TType::STRING,
+ 'key' => array(
+ 'type' => TType::I32,
+ ),
+ 'val' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['resourceJobManagerId'])) {
+ $this->resourceJobManagerId = $vals['resourceJobManagerId'];
+ }
+ if (isset($vals['resourceJobManagerType'])) {
+ $this->resourceJobManagerType = $vals['resourceJobManagerType'];
+ }
+ if (isset($vals['pushMonitoringEndpoint'])) {
+ $this->pushMonitoringEndpoint = $vals['pushMonitoringEndpoint'];
+ }
+ if (isset($vals['jobManagerBinPath'])) {
+ $this->jobManagerBinPath = $vals['jobManagerBinPath'];
+ }
+ if (isset($vals['jobManagerCommands'])) {
+ $this->jobManagerCommands = $vals['jobManagerCommands'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ResourceJobManager';
+ }
+
+ 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->resourceJobManagerId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->resourceJobManagerType);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->pushMonitoringEndpoint);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->jobManagerBinPath);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::MAP) {
+ $this->jobManagerCommands = array();
+ $_size0 = 0;
+ $_ktype1 = 0;
+ $_vtype2 = 0;
+ $xfer += $input->readMapBegin($_ktype1, $_vtype2, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $key5 = 0;
+ $val6 = '';
+ $xfer += $input->readI32($key5);
+ $xfer += $input->readString($val6);
+ $this->jobManagerCommands[$key5] = $val6;
+ }
+ $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('ResourceJobManager');
+ if ($this->resourceJobManagerId !== null) {
+ $xfer += $output->writeFieldBegin('resourceJobManagerId', TType::STRING, 1);
+ $xfer += $output->writeString($this->resourceJobManagerId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceJobManagerType !== null) {
+ $xfer += $output->writeFieldBegin('resourceJobManagerType', TType::I32, 2);
+ $xfer += $output->writeI32($this->resourceJobManagerType);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->pushMonitoringEndpoint !== null) {
+ $xfer += $output->writeFieldBegin('pushMonitoringEndpoint', TType::STRING, 3);
+ $xfer += $output->writeString($this->pushMonitoringEndpoint);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->jobManagerBinPath !== null) {
+ $xfer += $output->writeFieldBegin('jobManagerBinPath', TType::STRING, 4);
+ $xfer += $output->writeString($this->jobManagerBinPath);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->jobManagerCommands !== null) {
+ if (!is_array($this->jobManagerCommands)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('jobManagerCommands', TType::MAP, 5);
+ {
+ $output->writeMapBegin(TType::I32, TType::STRING, count($this->jobManagerCommands));
+ {
+ foreach ($this->jobManagerCommands as $kiter7 => $viter8)
+ {
+ $xfer += $output->writeI32($kiter7);
+ $xfer += $output->writeString($viter8);
+ }
+ }
+ $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class BatchQueue {
+ static $_TSPEC;
+
+ public $queueName = null;
+ public $queueDescription = null;
+ public $maxRunTime = null;
+ public $maxNodes = null;
+ public $maxProcessors = null;
+ public $maxJobsInQueue = null;
+ public $maxMemory = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'queueName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'queueDescription',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'maxRunTime',
+ 'type' => TType::I32,
+ ),
+ 4 => array(
+ 'var' => 'maxNodes',
+ 'type' => TType::I32,
+ ),
+ 5 => array(
+ 'var' => 'maxProcessors',
+ 'type' => TType::I32,
+ ),
+ 6 => array(
+ 'var' => 'maxJobsInQueue',
+ 'type' => TType::I32,
+ ),
+ 7 => array(
+ 'var' => 'maxMemory',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['queueName'])) {
+ $this->queueName = $vals['queueName'];
+ }
+ if (isset($vals['queueDescription'])) {
+ $this->queueDescription = $vals['queueDescription'];
+ }
+ if (isset($vals['maxRunTime'])) {
+ $this->maxRunTime = $vals['maxRunTime'];
+ }
+ if (isset($vals['maxNodes'])) {
+ $this->maxNodes = $vals['maxNodes'];
+ }
+ if (isset($vals['maxProcessors'])) {
+ $this->maxProcessors = $vals['maxProcessors'];
+ }
+ if (isset($vals['maxJobsInQueue'])) {
+ $this->maxJobsInQueue = $vals['maxJobsInQueue'];
+ }
+ if (isset($vals['maxMemory'])) {
+ $this->maxMemory = $vals['maxMemory'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'BatchQueue';
+ }
+
+ 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->queueName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->queueDescription);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxRunTime);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxNodes);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxProcessors);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxJobsInQueue);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxMemory);
+ } 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('BatchQueue');
+ if ($this->queueName !== null) {
+ $xfer += $output->writeFieldBegin('queueName', TType::STRING, 1);
+ $xfer += $output->writeString($this->queueName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->queueDescription !== null) {
+ $xfer += $output->writeFieldBegin('queueDescription', TType::STRING, 2);
+ $xfer += $output->writeString($this->queueDescription);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->maxRunTime !== null) {
+ $xfer += $output->writeFieldBegin('maxRunTime', TType::I32, 3);
+ $xfer += $output->writeI32($this->maxRunTime);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->maxNodes !== null) {
+ $xfer += $output->writeFieldBegin('maxNodes', TType::I32, 4);
+ $xfer += $output->writeI32($this->maxNodes);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->maxProcessors !== null) {
+ $xfer += $output->writeFieldBegin('maxProcessors', TType::I32, 5);
+ $xfer += $output->writeI32($this->maxProcessors);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->maxJobsInQueue !== null) {
+ $xfer += $output->writeFieldBegin('maxJobsInQueue', TType::I32, 6);
+ $xfer += $output->writeI32($this->maxJobsInQueue);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->maxMemory !== null) {
+ $xfer += $output->writeFieldBegin('maxMemory', TType::I32, 7);
+ $xfer += $output->writeI32($this->maxMemory);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class SCPDataMovement {
+ static $_TSPEC;
+
+ public $dataMovementInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $alternativeSCPHostName = null;
+ public $sshPort = 22;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovementInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'alternativeSCPHostName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'sshPort',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementInterfaceId'])) {
+ $this->dataMovementInterfaceId = $vals['dataMovementInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['alternativeSCPHostName'])) {
+ $this->alternativeSCPHostName = $vals['alternativeSCPHostName'];
+ }
+ 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->dataMovementInterfaceId);
+ } 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::STRING) {
+ $xfer += $input->readString($this->alternativeSCPHostName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ 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->dataMovementInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->alternativeSCPHostName !== null) {
+ $xfer += $output->writeFieldBegin('alternativeSCPHostName', TType::STRING, 3);
+ $xfer += $output->writeString($this->alternativeSCPHostName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->sshPort !== null) {
+ $xfer += $output->writeFieldBegin('sshPort', TType::I32, 4);
+ $xfer += $output->writeI32($this->sshPort);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class GridFTPDataMovement {
+ static $_TSPEC;
+
+ public $dataMovementInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $gridFTPEndPoints = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovementInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'gridFTPEndPoints',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementInterfaceId'])) {
+ $this->dataMovementInterfaceId = $vals['dataMovementInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['gridFTPEndPoints'])) {
+ $this->gridFTPEndPoints = $vals['gridFTPEndPoints'];
+ }
+ }
+ }
+
+ 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->dataMovementInterfaceId);
+ } 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->gridFTPEndPoints = array();
+ $_size9 = 0;
+ $_etype12 = 0;
+ $xfer += $input->readListBegin($_etype12, $_size9);
+ for ($_i13 = 0; $_i13 < $_size9; ++$_i13)
+ {
+ $elem14 = null;
+ $xfer += $input->readString($elem14);
+ $this->gridFTPEndPoints []= $elem14;
+ }
+ $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->dataMovementInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->gridFTPEndPoints !== null) {
+ if (!is_array($this->gridFTPEndPoints)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('gridFTPEndPoints', TType::LST, 3);
+ {
+ $output->writeListBegin(TType::STRING, count($this->gridFTPEndPoints));
+ {
+ foreach ($this->gridFTPEndPoints as $iter15)
+ {
+ $xfer += $output->writeString($iter15);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class UnicoreDataMovement {
+ static $_TSPEC;
+
+ public $dataMovementInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $unicoreEndPointURL = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovementInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'unicoreEndPointURL',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementInterfaceId'])) {
+ $this->dataMovementInterfaceId = $vals['dataMovementInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['unicoreEndPointURL'])) {
+ $this->unicoreEndPointURL = $vals['unicoreEndPointURL'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'UnicoreDataMovement';
+ }
+
+ 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->dataMovementInterfaceId);
+ } 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::STRING) {
+ $xfer += $input->readString($this->unicoreEndPointURL);
+ } 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('UnicoreDataMovement');
+ if ($this->dataMovementInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->unicoreEndPointURL !== null) {
+ $xfer += $output->writeFieldBegin('unicoreEndPointURL', TType::STRING, 3);
+ $xfer += $output->writeString($this->unicoreEndPointURL);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class LOCALSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $resourceJobManager = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'resourceJobManager',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResource\ResourceJobManager',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionInterfaceId'])) {
+ $this->jobSubmissionInterfaceId = $vals['jobSubmissionInterfaceId'];
+ }
+ if (isset($vals['resourceJobManager'])) {
+ $this->resourceJobManager = $vals['resourceJobManager'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'LOCALSubmission';
+ }
+
+ 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->jobSubmissionInterfaceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->resourceJobManager = new \Airavata\Model\AppCatalog\ComputeResource\ResourceJobManager();
+ $xfer += $this->resourceJobManager->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('LOCALSubmission');
+ if ($this->jobSubmissionInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceJobManager !== null) {
+ if (!is_object($this->resourceJobManager)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('resourceJobManager', TType::STRUCT, 2);
+ $xfer += $this->resourceJobManager->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class LOCALDataMovement {
+ static $_TSPEC;
+
+ public $dataMovementInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovementInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementInterfaceId'])) {
+ $this->dataMovementInterfaceId = $vals['dataMovementInterfaceId'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'LOCALDataMovement';
+ }
+
+ 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->dataMovementInterfaceId);
+ } 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('LOCALDataMovement');
+ if ($this->dataMovementInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class SSHJobSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $resourceJobManager = null;
+ public $alternativeSSHHostName = null;
+ public $sshPort = 22;
+ public $monitorMode = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'resourceJobManager',
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResource\ResourceJobManager',
+ ),
+ 4 => array(
+ 'var' => 'alternativeSSHHostName',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'sshPort',
+ 'type' => TType::I32,
+ ),
+ 6 => array(
+ 'var' => 'monitorMode',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionInterfaceId'])) {
+ $this->jobSubmissionInterfaceId = $vals['jobSubmissionInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['resourceJobManager'])) {
+ $this->resourceJobManager = $vals['resourceJobManager'];
+ }
+ if (isset($vals['alternativeSSHHostName'])) {
+ $this->alternativeSSHHostName = $vals['alternativeSSHHostName'];
+ }
+ if (isset($vals['sshPort'])) {
+ $this->sshPort = $vals['sshPort'];
+ }
+ if (isset($vals['monitorMode'])) {
+ $this->monitorMode = $vals['monitorMode'];
+ }
+ }
+ }
+
+ 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->jobSubmissionInterfaceId);
+ } 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::STRUCT) {
+ $this->resourceJobManager = new \Airavata\Model\AppCatalog\ComputeResource\ResourceJobManager();
+ $xfer += $this->resourceJobManager->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->alternativeSSHHostName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->sshPort);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($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('SSHJobSubmission');
+ if ($this->jobSubmissionInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionInterfaceId);
+ $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) {
+ if (!is_object($this->resourceJobManager)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('resourceJobManager', TType::STRUCT, 3);
+ $xfer += $this->resourceJobManager->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->alternativeSSHHostName !== null) {
+ $xfer += $output->writeFieldBegin('alternativeSSHHostName', TType::STRING, 4);
+ $xfer += $output->writeString($this->alternativeSSHHostName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->sshPort !== null) {
+ $xfer += $output->writeFieldBegin('sshPort', TType::I32, 5);
+ $xfer += $output->writeI32($this->sshPort);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->monitorMode !== null) {
+ $xfer += $output->writeFieldBegin('monitorMode', TType::I32, 6);
+ $xfer += $output->writeI32($this->monitorMode);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class GlobusJobSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $globusGateKeeperEndPoint = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'globusGateKeeperEndPoint',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionInterfaceId'])) {
+ $this->jobSubmissionInterfaceId = $vals['jobSubmissionInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ 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->jobSubmissionInterfaceId);
+ } 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->globusGateKeeperEndPoint = array();
+ $_size16 = 0;
+ $_etype19 = 0;
+ $xfer += $input->readListBegin($_etype19, $_size16);
+ for ($_i20 = 0; $_i20 < $_size16; ++$_i20)
+ {
+ $elem21 = null;
+ $xfer += $input->readString($elem21);
+ $this->globusGateKeeperEndPoint []= $elem21;
+ }
+ $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->jobSubmissionInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $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, 3);
+ {
+ $output->writeListBegin(TType::STRING, count($this->globusGateKeeperEndPoint));
+ {
+ foreach ($this->globusGateKeeperEndPoint as $iter22)
+ {
+ $xfer += $output->writeString($iter22);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class UnicoreJobSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $unicoreEndPointURL = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'unicoreEndPointURL',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionInterfaceId'])) {
+ $this->jobSubmissionInterfaceId = $vals['jobSubmissionInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['unicoreEndPointURL'])) {
+ $this->unicoreEndPointURL = $vals['unicoreEndPointURL'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'UnicoreJobSubmission';
+ }
+
+ 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->jobSubmissionInterfaceId);
+ } 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::STRING) {
+ $xfer += $input->readString($this->unicoreEndPointURL);
+ } 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('UnicoreJobSubmission');
+ if ($this->jobSubmissionInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->unicoreEndPointURL !== null) {
+ $xfer += $output->writeFieldBegin('unicoreEndPointURL', TType::STRING, 3);
+ $xfer += $output->writeString($this->unicoreEndPointURL);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class CloudJobSubmission {
+ static $_TSPEC;
+
+ public $jobSubmissionInterfaceId = "DO_NOT_SET_AT_CLIENTS";
+ public $securityProtocol = null;
+ public $nodeId = null;
+ public $executableType = null;
+ public $providerName = null;
+ public $userAccountName = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'securityProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'nodeId',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'executableType',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'providerName',
+ 'type' => TType::I32,
+ ),
+ 6 => array(
+ 'var' => 'userAccountName',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionInterfaceId'])) {
+ $this->jobSubmissionInterfaceId = $vals['jobSubmissionInterfaceId'];
+ }
+ if (isset($vals['securityProtocol'])) {
+ $this->securityProtocol = $vals['securityProtocol'];
+ }
+ if (isset($vals['nodeId'])) {
+ $this->nodeId = $vals['nodeId'];
+ }
+ if (isset($vals['executableType'])) {
+ $this->executableType = $vals['executableType'];
+ }
+ if (isset($vals['providerName'])) {
+ $this->providerName = $vals['providerName'];
+ }
+ if (isset($vals['userAccountName'])) {
+ $this->userAccountName = $vals['userAccountName'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'CloudJobSubmission';
+ }
+
+ 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->jobSubmissionInterfaceId);
+ } 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::STRING) {
+ $xfer += $input->readString($this->nodeId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->executableType);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->providerName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->userAccountName);
+ } 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('CloudJobSubmission');
+ if ($this->jobSubmissionInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->securityProtocol !== null) {
+ $xfer += $output->writeFieldBegin('securityProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->securityProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->nodeId !== null) {
+ $xfer += $output->writeFieldBegin('nodeId', TType::STRING, 3);
+ $xfer += $output->writeString($this->nodeId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->executableType !== null) {
+ $xfer += $output->writeFieldBegin('executableType', TType::STRING, 4);
+ $xfer += $output->writeString($this->executableType);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->providerName !== null) {
+ $xfer += $output->writeFieldBegin('providerName', TType::I32, 5);
+ $xfer += $output->writeI32($this->providerName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->userAccountName !== null) {
+ $xfer += $output->writeFieldBegin('userAccountName', TType::STRING, 6);
+ $xfer += $output->writeString($this->userAccountName);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class JobSubmissionInterface {
+ static $_TSPEC;
+
+ public $jobSubmissionInterfaceId = null;
+ public $jobSubmissionProtocol = null;
+ public $priorityOrder = 0;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'jobSubmissionInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'jobSubmissionProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'priorityOrder',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['jobSubmissionInterfaceId'])) {
+ $this->jobSubmissionInterfaceId = $vals['jobSubmissionInterfaceId'];
+ }
+ if (isset($vals['jobSubmissionProtocol'])) {
+ $this->jobSubmissionProtocol = $vals['jobSubmissionProtocol'];
+ }
+ if (isset($vals['priorityOrder'])) {
+ $this->priorityOrder = $vals['priorityOrder'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'JobSubmissionInterface';
+ }
+
+ 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->jobSubmissionInterfaceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->jobSubmissionProtocol);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->priorityOrder);
+ } 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('JobSubmissionInterface');
+ if ($this->jobSubmissionInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->jobSubmissionInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->jobSubmissionProtocol !== null) {
+ $xfer += $output->writeFieldBegin('jobSubmissionProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->jobSubmissionProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->priorityOrder !== null) {
+ $xfer += $output->writeFieldBegin('priorityOrder', TType::I32, 3);
+ $xfer += $output->writeI32($this->priorityOrder);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class DataMovementInterface {
+ static $_TSPEC;
+
+ public $dataMovementInterfaceId = null;
+ public $dataMovementProtocol = null;
+ public $priorityOrder = 0;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dataMovementInterfaceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'dataMovementProtocol',
+ 'type' => TType::I32,
+ ),
+ 3 => array(
+ 'var' => 'priorityOrder',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dataMovementInterfaceId'])) {
+ $this->dataMovementInterfaceId = $vals['dataMovementInterfaceId'];
+ }
+ if (isset($vals['dataMovementProtocol'])) {
+ $this->dataMovementProtocol = $vals['dataMovementProtocol'];
+ }
+ if (isset($vals['priorityOrder'])) {
+ $this->priorityOrder = $vals['priorityOrder'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'DataMovementInterface';
+ }
+
+ 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->dataMovementInterfaceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->dataMovementProtocol);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->priorityOrder);
+ } 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('DataMovementInterface');
+ if ($this->dataMovementInterfaceId !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementInterfaceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->dataMovementInterfaceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMovementProtocol !== null) {
+ $xfer += $output->writeFieldBegin('dataMovementProtocol', TType::I32, 2);
+ $xfer += $output->writeI32($this->dataMovementProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->priorityOrder !== null) {
+ $xfer += $output->writeFieldBegin('priorityOrder', TType::I32, 3);
+ $xfer += $output->writeI32($this->priorityOrder);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ComputeResourceDescription {
+ static $_TSPEC;
+
+ public $computeResourceId = "DO_NOT_SET_AT_CLIENTS";
+ public $hostName = null;
+ public $hostAliases = null;
+ public $ipAddresses = null;
+ public $resourceDescription = null;
+ public $batchQueues = null;
+ public $fileSystems = null;
+ public $jobSubmissionInterfaces = null;
+ public $dataMovementInterfaces = null;
+ public $maxMemoryPerNode = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'computeResourceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'hostName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'hostAliases',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 4 => array(
+ 'var' => 'ipAddresses',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 5 => array(
+ 'var' => 'resourceDescription',
+ 'type' => TType::STRING,
+ ),
+ 6 => array(
+ 'var' => 'batchQueues',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResource\BatchQueue',
+ ),
+ ),
+ 7 => array(
+ 'var' => 'fileSystems',
+ 'type' => TType::MAP,
+ 'ktype' => TType::I32,
+ 'vtype' => TType::STRING,
+ 'key' => array(
+ 'type' => TType::I32,
+ ),
+ 'val' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 8 => array(
+ 'var' => 'jobSubmissionInterfaces',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResource\JobSubmissionInterface',
+ ),
+ ),
+ 9 => array(
+ 'var' => 'dataMovementInterfaces',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\ComputeResource\DataMovementInterface',
+ ),
+ ),
+ 10 => array(
+ 'var' => 'maxMemoryPerNode',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['computeResourceId'])) {
+ $this->computeResourceId = $vals['computeResourceId'];
+ }
+ 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['batchQueues'])) {
+ $this->batchQueues = $vals['batchQueues'];
+ }
+ if (isset($vals['fileSystems'])) {
+ $this->fileSystems = $vals['fileSystems'];
+ }
+ if (isset($vals['jobSubmissionInterfaces'])) {
+ $this->jobSubmissionInterfaces = $vals['jobSubmissionInterfaces'];
+ }
+ if (isset($vals['dataMovementInterfaces'])) {
+ $this->dataMovementInterfaces = $vals['dataMovementInterfaces'];
+ }
+ if (isset($vals['maxMemoryPerNode'])) {
+ $this->maxMemoryPerNode = $vals['maxMemoryPerNode'];
+ }
+ }
+ }
+
+ 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::STRING) {
+ $xfer += $input->readString($this->computeResourceId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->hostName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::LST) {
+ $this->hostAliases = array();
+ $_size23 = 0;
+ $_etype26 = 0;
+ $xfer += $input->readListBegin($_etype26, $_size23);
+ for ($_i27 = 0; $_i27 < $_size23; ++$_i27)
+ {
+ $elem28 = null;
+ $xfer += $input->readString($elem28);
+ $this->hostAliases []= $elem28;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->ipAddresses = array();
+ $_size29 = 0;
+ $_etype32 = 0;
+ $xfer += $input->readListBegin($_etype32, $_size29);
+ for ($_i33 = 0; $_i33 < $_size29; ++$_i33)
+ {
+ $elem34 = null;
+ $xfer += $input->readString($elem34);
+ $this->ipAddresses []= $elem34;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->resourceDescription);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->batchQueues = array();
+ $_size35 = 0;
+ $_etype38 = 0;
+ $xfer += $input->readListBegin($_etype38, $_size35);
+ for ($_i39 = 0; $_i39 < $_size35; ++$_i39)
+ {
+ $elem40 = null;
+ $elem40 = new \Airavata\Model\AppCatalog\ComputeResource\BatchQueue();
+ $xfer += $elem40->read($input);
+ $this->batchQueues []= $elem40;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::MAP) {
+ $this->fileSystems = array();
+ $_size41 = 0;
+ $_ktype42 = 0;
+ $_vtype43 = 0;
+ $xfer += $input->readMapBegin($_ktype42, $_vtype43, $_size41);
+ for ($_i45 = 0; $_i45 < $_size41; ++$_i45)
+ {
+ $key46 = 0;
+ $val47 = '';
+ $xfer += $input->readI32($key46);
+ $xfer += $input->readString($val47);
+ $this->fileSystems[$key46] = $val47;
+ }
+ $xfer += $input->readMapEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::LST) {
+ $this->jobSubmissionInterfaces = array();
+ $_size48 = 0;
+ $_etype51 = 0;
+ $xfer += $input->readListBegin($_etype51, $_size48);
+ for ($_i52 = 0; $_i52 < $_size48; ++$_i52)
+ {
+ $elem53 = null;
+ $elem53 = new \Airavata\Model\AppCatalog\ComputeResource\JobSubmissionInterface();
+ $xfer += $elem53->read($input);
+ $this->jobSubmissionInterfaces []= $elem53;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 9:
+ if ($ftype == TType::LST) {
+ $this->dataMovementInterfaces = array();
+ $_size54 = 0;
+ $_etype57 = 0;
+ $xfer += $input->readListBegin($_etype57, $_size54);
+ for ($_i58 = 0; $_i58 < $_size54; ++$_i58)
+ {
+ $elem59 = null;
+ $elem59 = new \Airavata\Model\AppCatalog\ComputeResource\DataMovementInterface();
+ $xfer += $elem59->read($input);
+ $this->dataMovementInterfaces []= $elem59;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 10:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->maxMemoryPerNode);
+ } 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->computeResourceId !== null) {
+ $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->computeResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->hostName !== null) {
+ $xfer += $output->writeFieldBegin('hostName', TType::STRING, 2);
+ $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::LST, 3);
+ {
+ $output->writeListBegin(TType::STRING, count($this->hostAliases));
+ {
+ foreach ($this->hostAliases as $iter60)
+ {
+ $xfer += $output->writeString($iter60);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $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::LST, 4);
+ {
+ $output->writeListBegin(TType::STRING, count($this->ipAddresses));
+ {
+ foreach ($this->ipAddresses as $iter61)
+ {
+ $xfer += $output->writeString($iter61);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->resourceDescription !== null) {
+ $xfer += $output->writeFieldBegin('resourceDescription', TType::STRING, 5);
+ $xfer += $output->writeString($this->resourceDescription);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->batchQueues !== null) {
+ if (!is_array($this->batchQueues)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('batchQueues', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->batchQueues));
+ {
+ foreach ($this->batchQueues as $iter62)
+ {
+ $xfer += $iter62->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->fileSystems !== null) {
+ if (!is_array($this->fileSystems)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('fileSystems', TType::MAP, 7);
+ {
+ $output->writeMapBegin(TType::I32, TType::STRING, count($this->fileSystems));
+ {
+ foreach ($this->fileSystems as $kiter63 => $viter64)
+ {
+ $xfer += $output->writeI32($kiter63);
+ $xfer += $output->writeString($viter64);
+ }
+ }
+ $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->jobSubmissionInterfaces !== null) {
+ if (!is_array($this->jobSubmissionInterfaces)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('jobSubmissionInterfaces', TType::LST, 8);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->jobSubmissionInterfaces));
+ {
+ foreach ($this->jobSubmissionInterfaces as $iter65)
+ {
+ $xfer += $iter65->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dataMovementInterfaces !== null) {
+ if (!is_array($this->dataMovementInterfaces)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('dataMovementInterfaces', TType::LST, 9);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->dataMovementInterfaces));
+ {
+ foreach ($this->dataMovementInterfaces as $iter66)
+ {
+ $xfer += $iter66->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->maxMemoryPerNode !== null) {
+ $xfer += $output->writeFieldBegin('maxMemoryPerNode', TType::I32, 10);
+ $xfer += $output->writeI32($this->maxMemoryPerNode);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+$GLOBALS['computeResourceModel_CONSTANTS']['DEFAULT_ID'] = "DO_NOT_SET_AT_CLIENTS";
+
+
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/01413d65/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
----------------------------------------------------------------------
diff --git a/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php b/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
new file mode 100644
index 0000000..e0e6227
--- /dev/null
+++ b/app/libraries/Airavata/Model/AppCatalog/GatewayProfile/Types.php
@@ -0,0 +1,352 @@
+<?php
+namespace Airavata\Model\AppCatalog\GatewayProfile;
+
+/**
+ * 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;
+
+
+class ComputeResourcePreference {
+ static $_TSPEC;
+
+ public $computeResourceId = null;
+ public $overridebyAiravata = true;
+ public $loginUserName = null;
+ public $preferredJobSubmissionProtocol = null;
+ public $preferredDataMovementProtocol = null;
+ public $preferredBatchQueue = null;
+ public $scratchLocation = null;
+ public $allocationProjectNumber = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'computeResourceId',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'overridebyAiravata',
+ 'type' => TType::BOOL,
+ ),
+ 3 => array(
+ 'var' => 'loginUserName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'preferredJobSubmissionProtocol',
+ 'type' => TType::I32,
+ ),
+ 5 => array(
+ 'var' => 'preferredDataMovementProtocol',
+ 'type' => TType::I32,
+ ),
+ 6 => array(
+ 'var' => 'preferredBatchQueue',
+ 'type' => TType::STRING,
+ ),
+ 7 => array(
+ 'var' => 'scratchLocation',
+ 'type' => TType::STRING,
+ ),
+ 8 => array(
+ 'var' => 'allocationProjectNumber',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['computeResourceId'])) {
+ $this->computeResourceId = $vals['computeResourceId'];
+ }
+ if (isset($vals['overridebyAiravata'])) {
+ $this->overridebyAiravata = $vals['overridebyAiravata'];
+ }
+ if (isset($vals['loginUserName'])) {
+ $this->loginUserName = $vals['loginUserName'];
+ }
+ if (isset($vals['preferredJobSubmissionProtocol'])) {
+ $this->preferredJobSubmissionProtocol = $vals['preferredJobSubmissionProtocol'];
+ }
+ if (isset($vals['preferredDataMovementProtocol'])) {
+ $this->preferredDataMovementProtocol = $vals['preferredDataMovementProtocol'];
+ }
+ if (isset($vals['preferredBatchQueue'])) {
+ $this->preferredBatchQueue = $vals['preferredBatchQueue'];
+ }
+ if (isset($vals['scratchLocation'])) {
+ $this->scratchLocation = $vals['scratchLocation'];
+ }
+ if (isset($vals['allocationProjectNumber'])) {
+ $this->allocationProjectNumber = $vals['allocationProjectNumber'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ComputeResourcePreference';
+ }
+
+ 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::BOOL) {
+ $xfer += $input->readBool($this->overridebyAiravata);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->loginUserName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->preferredJobSubmissionProtocol);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->preferredDataMovementProtocol);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->preferredBatchQueue);
+ } 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->allocationProjectNumber);
+ } 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('ComputeResourcePreference');
+ if ($this->computeResourceId !== null) {
+ $xfer += $output->writeFieldBegin('computeResourceId', TType::STRING, 1);
+ $xfer += $output->writeString($this->computeResourceId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->overridebyAiravata !== null) {
+ $xfer += $output->writeFieldBegin('overridebyAiravata', TType::BOOL, 2);
+ $xfer += $output->writeBool($this->overridebyAiravata);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->loginUserName !== null) {
+ $xfer += $output->writeFieldBegin('loginUserName', TType::STRING, 3);
+ $xfer += $output->writeString($this->loginUserName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->preferredJobSubmissionProtocol !== null) {
+ $xfer += $output->writeFieldBegin('preferredJobSubmissionProtocol', TType::I32, 4);
+ $xfer += $output->writeI32($this->preferredJobSubmissionProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->preferredDataMovementProtocol !== null) {
+ $xfer += $output->writeFieldBegin('preferredDataMovementProtocol', TType::I32, 5);
+ $xfer += $output->writeI32($this->preferredDataMovementProtocol);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->preferredBatchQueue !== null) {
+ $xfer += $output->writeFieldBegin('preferredBatchQueue', TType::STRING, 6);
+ $xfer += $output->writeString($this->preferredBatchQueue);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->scratchLocation !== null) {
+ $xfer += $output->writeFieldBegin('scratchLocation', TType::STRING, 7);
+ $xfer += $output->writeString($this->scratchLocation);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->allocationProjectNumber !== null) {
+ $xfer += $output->writeFieldBegin('allocationProjectNumber', TType::STRING, 8);
+ $xfer += $output->writeString($this->allocationProjectNumber);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class GatewayResourceProfile {
+ static $_TSPEC;
+
+ public $gatewayID = null;
+ public $computeResourcePreferences = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'gatewayID',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'computeResourcePreferences',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference',
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['gatewayID'])) {
+ $this->gatewayID = $vals['gatewayID'];
+ }
+ if (isset($vals['computeResourcePreferences'])) {
+ $this->computeResourcePreferences = $vals['computeResourcePreferences'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'GatewayResourceProfile';
+ }
+
+ 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->gatewayID);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::LST) {
+ $this->computeResourcePreferences = array();
+ $_size0 = 0;
+ $_etype3 = 0;
+ $xfer += $input->readListBegin($_etype3, $_size0);
+ for ($_i4 = 0; $_i4 < $_size0; ++$_i4)
+ {
+ $elem5 = null;
+ $elem5 = new \Airavata\Model\AppCatalog\GatewayProfile\ComputeResourcePreference();
+ $xfer += $elem5->read($input);
+ $this->computeResourcePreferences []= $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('GatewayResourceProfile');
+ if ($this->gatewayID !== null) {
+ $xfer += $output->writeFieldBegin('gatewayID', TType::STRING, 1);
+ $xfer += $output->writeString($this->gatewayID);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->computeResourcePreferences !== null) {
+ if (!is_array($this->computeResourcePreferences)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('computeResourcePreferences', TType::LST, 2);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->computeResourcePreferences));
+ {
+ foreach ($this->computeResourcePreferences as $iter6)
+ {
+ $xfer += $iter6->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+