| <?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 UGE = 2; |
| const SLURM = 3; |
| static public $__names = array( |
| 0 => 'FORK', |
| 1 => 'PBS', |
| 2 => 'UGE', |
| 3 => 'SLURM', |
| ); |
| } |
| |
| 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 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 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, |
| ), |
| ); |
| } |
| 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']; |
| } |
| } |
| } |
| |
| 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; |
| 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(); |
| } |
| $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 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, |
| ), |
| ); |
| } |
| 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']; |
| } |
| } |
| } |
| |
| 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; |
| 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(); |
| } |
| $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 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::SET, |
| 'etype' => TType::STRING, |
| 'elem' => array( |
| 'type' => TType::STRING, |
| ), |
| ), |
| 4 => array( |
| 'var' => 'ipAddresses', |
| 'type' => TType::SET, |
| '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', |
| ), |
| ), |
| ); |
| } |
| 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']; |
| } |
| } |
| } |
| |
| 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::SET) { |
| $this->hostAliases = array(); |
| $_size23 = 0; |
| $_etype26 = 0; |
| $xfer += $input->readSetBegin($_etype26, $_size23); |
| for ($_i27 = 0; $_i27 < $_size23; ++$_i27) |
| { |
| $elem28 = null; |
| $xfer += $input->readString($elem28); |
| if (is_scalar($elem28)) { |
| $this->hostAliases[$elem28] = true; |
| } else { |
| $this->hostAliases []= $elem28; |
| } |
| } |
| $xfer += $input->readSetEnd(); |
| } else { |
| $xfer += $input->skip($ftype); |
| } |
| break; |
| case 4: |
| if ($ftype == TType::SET) { |
| $this->ipAddresses = array(); |
| $_size29 = 0; |
| $_etype32 = 0; |
| $xfer += $input->readSetBegin($_etype32, $_size29); |
| for ($_i33 = 0; $_i33 < $_size29; ++$_i33) |
| { |
| $elem34 = null; |
| $xfer += $input->readString($elem34); |
| if (is_scalar($elem34)) { |
| $this->ipAddresses[$elem34] = true; |
| } else { |
| $this->ipAddresses []= $elem34; |
| } |
| } |
| $xfer += $input->readSetEnd(); |
| } 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; |
| 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::SET, 3); |
| { |
| $output->writeSetBegin(TType::STRING, count($this->hostAliases)); |
| { |
| foreach ($this->hostAliases as $iter60 => $iter61) |
| { |
| if (is_scalar($iter61)) { |
| $xfer += $output->writeString($iter60); |
| } else { |
| $xfer += $output->writeString($iter61); |
| } |
| } |
| } |
| $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, 4); |
| { |
| $output->writeSetBegin(TType::STRING, count($this->ipAddresses)); |
| { |
| foreach ($this->ipAddresses as $iter62 => $iter63) |
| { |
| if (is_scalar($iter63)) { |
| $xfer += $output->writeString($iter62); |
| } else { |
| $xfer += $output->writeString($iter63); |
| } |
| } |
| } |
| $output->writeSetEnd(); |
| } |
| $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 $iter64) |
| { |
| $xfer += $iter64->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 $kiter65 => $viter66) |
| { |
| $xfer += $output->writeI32($kiter65); |
| $xfer += $output->writeString($viter66); |
| } |
| } |
| $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 $iter67) |
| { |
| $xfer += $iter67->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 $iter68) |
| { |
| $xfer += $iter68->write($output); |
| } |
| } |
| $output->writeListEnd(); |
| } |
| $xfer += $output->writeFieldEnd(); |
| } |
| $xfer += $output->writeFieldStop(); |
| $xfer += $output->writeStructEnd(); |
| return $xfer; |
| } |
| |
| } |
| |
| $GLOBALS['computeResourceModel_CONSTANTS']['DEFAULT_ID'] = "DO_NOT_SET_AT_CLIENTS"; |
| |
| |
