Repository: airavata-php-gateway Updated Branches: refs/heads/airavata-php-gateway-0.15-release 48bec91b3 -> e1d623a8b
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/e1d623a8/app/libraries/Airavata/Model/Workspace/Experiment/Types.php ---------------------------------------------------------------------- diff --git a/app/libraries/Airavata/Model/Workspace/Experiment/Types.php b/app/libraries/Airavata/Model/Workspace/Experiment/Types.php index 4b53e09..9e80205 100644 --- a/app/libraries/Airavata/Model/Workspace/Experiment/Types.php +++ b/app/libraries/Airavata/Model/Workspace/Experiment/Types.php @@ -2,4342 +2,5129 @@ namespace Airavata\Model\Workspace\Experiment; /** - * Autogenerated by Thrift Compiler (0.9.1) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated + * @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 ExperimentState { - const CREATED = 0; - const VALIDATED = 1; - const SCHEDULED = 2; - const LAUNCHED = 3; - const EXECUTING = 4; - const CANCELING = 5; - const CANCELED = 6; - const SUSPENDED = 7; - const COMPLETED = 8; - const FAILED = 9; - const UNKNOWN = 10; - static public $__names = array( - 0 => 'CREATED', - 1 => 'VALIDATED', - 2 => 'SCHEDULED', - 3 => 'LAUNCHED', - 4 => 'EXECUTING', - 5 => 'CANCELING', - 6 => 'CANCELED', - 7 => 'SUSPENDED', - 8 => 'COMPLETED', - 9 => 'FAILED', - 10 => 'UNKNOWN', - ); +use Thrift\Type\TType; + + +final class ExperimentState +{ + const CREATED = 0; + const VALIDATED = 1; + const SCHEDULED = 2; + const LAUNCHED = 3; + const EXECUTING = 4; + const CANCELING = 5; + const CANCELED = 6; + const SUSPENDED = 7; + const COMPLETED = 8; + const FAILED = 9; + const UNKNOWN = 10; + static public $__names = array( + 0 => 'CREATED', + 1 => 'VALIDATED', + 2 => 'SCHEDULED', + 3 => 'LAUNCHED', + 4 => 'EXECUTING', + 5 => 'CANCELING', + 6 => 'CANCELED', + 7 => 'SUSPENDED', + 8 => 'COMPLETED', + 9 => 'FAILED', + 10 => 'UNKNOWN', + ); } -final class ExperimentSearchFields { - const EXPERIMENT_NAME = 0; - const EXPERIMENT_DESC = 1; - const APPLICATION_ID = 2; - const FROM_DATE = 3; - const TO_DATE = 4; - const STATUS = 5; - static public $__names = array( - 0 => 'EXPERIMENT_NAME', - 1 => 'EXPERIMENT_DESC', - 2 => 'APPLICATION_ID', - 3 => 'FROM_DATE', - 4 => 'TO_DATE', - 5 => 'STATUS', - ); +final class ExperimentSearchFields +{ + const EXPERIMENT_NAME = 0; + const EXPERIMENT_DESC = 1; + const APPLICATION_ID = 2; + const FROM_DATE = 3; + const TO_DATE = 4; + const STATUS = 5; + static public $__names = array( + 0 => 'EXPERIMENT_NAME', + 1 => 'EXPERIMENT_DESC', + 2 => 'APPLICATION_ID', + 3 => 'FROM_DATE', + 4 => 'TO_DATE', + 5 => 'STATUS', + ); } -final class WorkflowNodeState { - const INVOKED = 0; - const EXECUTING = 1; - const CANCELING = 2; - const CANCELED = 3; - const SUSPENDED = 4; - const COMPLETED = 5; - const FAILED = 6; - const UNKNOWN = 7; - static public $__names = array( - 0 => 'INVOKED', - 1 => 'EXECUTING', - 2 => 'CANCELING', - 3 => 'CANCELED', - 4 => 'SUSPENDED', - 5 => 'COMPLETED', - 6 => 'FAILED', - 7 => 'UNKNOWN', - ); +final class WorkflowNodeState +{ + const INVOKED = 0; + const EXECUTING = 1; + const CANCELING = 2; + const CANCELED = 3; + const SUSPENDED = 4; + const COMPLETED = 5; + const FAILED = 6; + const UNKNOWN = 7; + static public $__names = array( + 0 => 'INVOKED', + 1 => 'EXECUTING', + 2 => 'CANCELING', + 3 => 'CANCELED', + 4 => 'SUSPENDED', + 5 => 'COMPLETED', + 6 => 'FAILED', + 7 => 'UNKNOWN', + ); } -final class TaskState { - const WAITING = 0; - const STARTED = 1; - const PRE_PROCESSING = 2; - const CONFIGURING_WORKSPACE = 3; - const INPUT_DATA_STAGING = 4; - const OUTPUT_DATA_STAGING = 5; - const POST_PROCESSING = 6; - const EXECUTING = 7; - const CANCELING = 8; - const CANCELED = 9; - const COMPLETED = 10; - const FAILED = 11; - const UNKNOWN = 12; - static public $__names = array( - 0 => 'WAITING', - 1 => 'STARTED', - 2 => 'PRE_PROCESSING', - 3 => 'CONFIGURING_WORKSPACE', - 4 => 'INPUT_DATA_STAGING', - 5 => 'OUTPUT_DATA_STAGING', - 6 => 'POST_PROCESSING', - 7 => 'EXECUTING', - 8 => 'CANCELING', - 9 => 'CANCELED', - 10 => 'COMPLETED', - 11 => 'FAILED', - 12 => 'UNKNOWN', - ); +final class TaskState +{ + const WAITING = 0; + const STARTED = 1; + const PRE_PROCESSING = 2; + const CONFIGURING_WORKSPACE = 3; + const INPUT_DATA_STAGING = 4; + const OUTPUT_DATA_STAGING = 5; + const POST_PROCESSING = 6; + const EXECUTING = 7; + const CANCELING = 8; + const CANCELED = 9; + const COMPLETED = 10; + const FAILED = 11; + const UNKNOWN = 12; + static public $__names = array( + 0 => 'WAITING', + 1 => 'STARTED', + 2 => 'PRE_PROCESSING', + 3 => 'CONFIGURING_WORKSPACE', + 4 => 'INPUT_DATA_STAGING', + 5 => 'OUTPUT_DATA_STAGING', + 6 => 'POST_PROCESSING', + 7 => 'EXECUTING', + 8 => 'CANCELING', + 9 => 'CANCELED', + 10 => 'COMPLETED', + 11 => 'FAILED', + 12 => 'UNKNOWN', + ); } -final class JobState { - const SUBMITTED = 0; - const UN_SUBMITTED = 1; - const SETUP = 2; - const QUEUED = 3; - const ACTIVE = 4; - const COMPLETE = 5; - const CANCELING = 6; - const CANCELED = 7; - const FAILED = 8; - const HELD = 9; - const SUSPENDED = 10; - const UNKNOWN = 11; - static public $__names = array( - 0 => 'SUBMITTED', - 1 => 'UN_SUBMITTED', - 2 => 'SETUP', - 3 => 'QUEUED', - 4 => 'ACTIVE', - 5 => 'COMPLETE', - 6 => 'CANCELING', - 7 => 'CANCELED', - 8 => 'FAILED', - 9 => 'HELD', - 10 => 'SUSPENDED', - 11 => 'UNKNOWN', - ); +final class JobState +{ + const SUBMITTED = 0; + const UN_SUBMITTED = 1; + const SETUP = 2; + const QUEUED = 3; + const ACTIVE = 4; + const COMPLETE = 5; + const CANCELING = 6; + const CANCELED = 7; + const FAILED = 8; + const HELD = 9; + const SUSPENDED = 10; + const UNKNOWN = 11; + static public $__names = array( + 0 => 'SUBMITTED', + 1 => 'UN_SUBMITTED', + 2 => 'SETUP', + 3 => 'QUEUED', + 4 => 'ACTIVE', + 5 => 'COMPLETE', + 6 => 'CANCELING', + 7 => 'CANCELED', + 8 => 'FAILED', + 9 => 'HELD', + 10 => 'SUSPENDED', + 11 => 'UNKNOWN', + ); } -final class TransferState { - const DIRECTORY_SETUP = 0; - const UPLOAD = 1; - const DOWNLOAD = 2; - const ACTIVE = 3; - const COMPLETE = 4; - const STDOUT_DOWNLOAD = 5; - const STDERROR_DOWNLOAD = 6; - const CANCELING = 7; - const CANCELED = 8; - const FAILED = 9; - const HELD = 10; - const SUSPENDED = 11; - const UNKNOWN = 12; - static public $__names = array( - 0 => 'DIRECTORY_SETUP', - 1 => 'UPLOAD', - 2 => 'DOWNLOAD', - 3 => 'ACTIVE', - 4 => 'COMPLETE', - 5 => 'STDOUT_DOWNLOAD', - 6 => 'STDERROR_DOWNLOAD', - 7 => 'CANCELING', - 8 => 'CANCELED', - 9 => 'FAILED', - 10 => 'HELD', - 11 => 'SUSPENDED', - 12 => 'UNKNOWN', - ); +final class TransferState +{ + const DIRECTORY_SETUP = 0; + const UPLOAD = 1; + const DOWNLOAD = 2; + const ACTIVE = 3; + const COMPLETE = 4; + const STDOUT_DOWNLOAD = 5; + const STDERROR_DOWNLOAD = 6; + const CANCELING = 7; + const CANCELED = 8; + const FAILED = 9; + const HELD = 10; + const SUSPENDED = 11; + const UNKNOWN = 12; + static public $__names = array( + 0 => 'DIRECTORY_SETUP', + 1 => 'UPLOAD', + 2 => 'DOWNLOAD', + 3 => 'ACTIVE', + 4 => 'COMPLETE', + 5 => 'STDOUT_DOWNLOAD', + 6 => 'STDERROR_DOWNLOAD', + 7 => 'CANCELING', + 8 => 'CANCELED', + 9 => 'FAILED', + 10 => 'HELD', + 11 => 'SUSPENDED', + 12 => 'UNKNOWN', + ); } -final class ActionableGroup { - const RESOURCE_ADMINS = 0; - const AIRAVATA_ADMINS = 1; - const GATEWAYS_ADMINS = 2; - const USER = 3; - const CANNOT_BE_DETERMINED = 4; - static public $__names = array( - 0 => 'RESOURCE_ADMINS', - 1 => 'AIRAVATA_ADMINS', - 2 => 'GATEWAYS_ADMINS', - 3 => 'USER', - 4 => 'CANNOT_BE_DETERMINED', - ); +final class ActionableGroup +{ + const RESOURCE_ADMINS = 0; + const AIRAVATA_ADMINS = 1; + const GATEWAYS_ADMINS = 2; + const USER = 3; + const CANNOT_BE_DETERMINED = 4; + static public $__names = array( + 0 => 'RESOURCE_ADMINS', + 1 => 'AIRAVATA_ADMINS', + 2 => 'GATEWAYS_ADMINS', + 3 => 'USER', + 4 => 'CANNOT_BE_DETERMINED', + ); } -final class ErrorCategory { - const FILE_SYSTEM_FAILURE = 0; - const APPLICATION_FAILURE = 1; - const RESOURCE_NODE_FAILURE = 2; - const DISK_FULL = 3; - const INSUFFICIENT_ALLOCATION = 4; - const SYSTEM_MAINTENANCE = 5; - const AIRAVATA_INTERNAL_ERROR = 6; - const CANNOT_BE_DETERMINED = 7; - static public $__names = array( - 0 => 'FILE_SYSTEM_FAILURE', - 1 => 'APPLICATION_FAILURE', - 2 => 'RESOURCE_NODE_FAILURE', - 3 => 'DISK_FULL', - 4 => 'INSUFFICIENT_ALLOCATION', - 5 => 'SYSTEM_MAINTENANCE', - 6 => 'AIRAVATA_INTERNAL_ERROR', - 7 => 'CANNOT_BE_DETERMINED', - ); +final class ErrorCategory +{ + const FILE_SYSTEM_FAILURE = 0; + const APPLICATION_FAILURE = 1; + const RESOURCE_NODE_FAILURE = 2; + const DISK_FULL = 3; + const INSUFFICIENT_ALLOCATION = 4; + const SYSTEM_MAINTENANCE = 5; + const AIRAVATA_INTERNAL_ERROR = 6; + const CANNOT_BE_DETERMINED = 7; + static public $__names = array( + 0 => 'FILE_SYSTEM_FAILURE', + 1 => 'APPLICATION_FAILURE', + 2 => 'RESOURCE_NODE_FAILURE', + 3 => 'DISK_FULL', + 4 => 'INSUFFICIENT_ALLOCATION', + 5 => 'SYSTEM_MAINTENANCE', + 6 => 'AIRAVATA_INTERNAL_ERROR', + 7 => 'CANNOT_BE_DETERMINED', + ); } -final class CorrectiveAction { - const RETRY_SUBMISSION = 0; - const CONTACT_SUPPORT = 1; - const CANNOT_BE_DETERMINED = 2; - static public $__names = array( - 0 => 'RETRY_SUBMISSION', - 1 => 'CONTACT_SUPPORT', - 2 => 'CANNOT_BE_DETERMINED', - ); +final class CorrectiveAction +{ + const RETRY_SUBMISSION = 0; + const CONTACT_SUPPORT = 1; + const CANNOT_BE_DETERMINED = 2; + static public $__names = array( + 0 => 'RETRY_SUBMISSION', + 1 => 'CONTACT_SUPPORT', + 2 => 'CANNOT_BE_DETERMINED', + ); } -final class ExecutionUnit { - const INPUT = 0; - const APPLICATION = 1; - const OUTPUT = 2; - const OTHER = 3; - static public $__names = array( - 0 => 'INPUT', - 1 => 'APPLICATION', - 2 => 'OUTPUT', - 3 => 'OTHER', - ); +final class ExecutionUnit +{ + const INPUT = 0; + const APPLICATION = 1; + const OUTPUT = 2; + const OTHER = 3; + static public $__names = array( + 0 => 'INPUT', + 1 => 'APPLICATION', + 2 => 'OUTPUT', + 3 => 'OTHER', + ); } -class ExperimentStatus { - static $_TSPEC; - - public $experimentState = null; - public $timeOfStateChange = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'experimentState', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'timeOfStateChange', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['experimentState'])) { - $this->experimentState = $vals['experimentState']; - } - if (isset($vals['timeOfStateChange'])) { - $this->timeOfStateChange = $vals['timeOfStateChange']; - } - } - } - - public function getName() { - return 'ExperimentStatus'; - } - - 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::I32) { - $xfer += $input->readI32($this->experimentState); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->timeOfStateChange); - } 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('ExperimentStatus'); - if ($this->experimentState !== null) { - $xfer += $output->writeFieldBegin('experimentState', TType::I32, 1); - $xfer += $output->writeI32($this->experimentState); - $xfer += $output->writeFieldEnd(); - } - if ($this->timeOfStateChange !== null) { - $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); - $xfer += $output->writeI64($this->timeOfStateChange); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } +class ExperimentStatus +{ + static $_TSPEC; -} + /** + * @var int + */ + public $experimentState = null; + /** + * @var int + */ + public $timeOfStateChange = null; -class WorkflowNodeStatus { - static $_TSPEC; - - public $workflowNodeState = null; - public $timeOfStateChange = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'workflowNodeState', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'timeOfStateChange', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['workflowNodeState'])) { - $this->workflowNodeState = $vals['workflowNodeState']; - } - if (isset($vals['timeOfStateChange'])) { - $this->timeOfStateChange = $vals['timeOfStateChange']; - } - } - } - - public function getName() { - return 'WorkflowNodeStatus'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) + public function __construct($vals = null) { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->workflowNodeState); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->timeOfStateChange); - } 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('WorkflowNodeStatus'); - if ($this->workflowNodeState !== null) { - $xfer += $output->writeFieldBegin('workflowNodeState', TType::I32, 1); - $xfer += $output->writeI32($this->workflowNodeState); - $xfer += $output->writeFieldEnd(); - } - if ($this->timeOfStateChange !== null) { - $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); - $xfer += $output->writeI64($this->timeOfStateChange); - $xfer += $output->writeFieldEnd(); + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'experimentState', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['experimentState'])) { + $this->experimentState = $vals['experimentState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + } } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} -class TaskStatus { - static $_TSPEC; - - public $executionState = null; - public $timeOfStateChange = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'executionState', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'timeOfStateChange', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['executionState'])) { - $this->executionState = $vals['executionState']; - } - if (isset($vals['timeOfStateChange'])) { - $this->timeOfStateChange = $vals['timeOfStateChange']; - } - } - } - - public function getName() { - return 'TaskStatus'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) + public function getName() { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->executionState); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->timeOfStateChange); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); + return 'ExperimentStatus'; } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('TaskStatus'); - if ($this->executionState !== null) { - $xfer += $output->writeFieldBegin('executionState', TType::I32, 1); - $xfer += $output->writeI32($this->executionState); - $xfer += $output->writeFieldEnd(); + + 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::I32) { + $xfer += $input->readI32($this->experimentState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->timeOfStateChange !== null) { - $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); - $xfer += $output->writeI64($this->timeOfStateChange); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('ExperimentStatus'); + if ($this->experimentState !== null) { + $xfer += $output->writeFieldBegin('experimentState', TType::I32, 1); + $xfer += $output->writeI32($this->experimentState); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class JobStatus { - static $_TSPEC; - - public $jobState = null; - public $timeOfStateChange = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'jobState', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'timeOfStateChange', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['jobState'])) { - $this->jobState = $vals['jobState']; - } - if (isset($vals['timeOfStateChange'])) { - $this->timeOfStateChange = $vals['timeOfStateChange']; - } +class WorkflowNodeStatus +{ + static $_TSPEC; + + /** + * @var int + */ + public $workflowNodeState = null; + /** + * @var int + */ + public $timeOfStateChange = null; + + public function __construct($vals = null) + { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'workflowNodeState', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['workflowNodeState'])) { + $this->workflowNodeState = $vals['workflowNodeState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + } } - } - - public function getName() { - return 'JobStatus'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) + + public function getName() { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->jobState); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->timeOfStateChange); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); + return 'WorkflowNodeStatus'; } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('JobStatus'); - if ($this->jobState !== null) { - $xfer += $output->writeFieldBegin('jobState', TType::I32, 1); - $xfer += $output->writeI32($this->jobState); - $xfer += $output->writeFieldEnd(); + + 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::I32) { + $xfer += $input->readI32($this->workflowNodeState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->timeOfStateChange !== null) { - $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); - $xfer += $output->writeI64($this->timeOfStateChange); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('WorkflowNodeStatus'); + if ($this->workflowNodeState !== null) { + $xfer += $output->writeFieldBegin('workflowNodeState', TType::I32, 1); + $xfer += $output->writeI32($this->workflowNodeState); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class TransferStatus { - static $_TSPEC; - - public $transferState = null; - public $timeOfStateChange = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'transferState', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'timeOfStateChange', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['transferState'])) { - $this->transferState = $vals['transferState']; - } - if (isset($vals['timeOfStateChange'])) { - $this->timeOfStateChange = $vals['timeOfStateChange']; - } +class TaskStatus +{ + static $_TSPEC; + + /** + * @var int + */ + public $executionState = null; + /** + * @var int + */ + public $timeOfStateChange = null; + + public function __construct($vals = null) + { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'executionState', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['executionState'])) { + $this->executionState = $vals['executionState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + } } - } - - public function getName() { - return 'TransferStatus'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) + + public function getName() { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->transferState); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->timeOfStateChange); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); + return 'TaskStatus'; } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('TransferStatus'); - if ($this->transferState !== null) { - $xfer += $output->writeFieldBegin('transferState', TType::I32, 1); - $xfer += $output->writeI32($this->transferState); - $xfer += $output->writeFieldEnd(); + + 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::I32) { + $xfer += $input->readI32($this->executionState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->timeOfStateChange !== null) { - $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); - $xfer += $output->writeI64($this->timeOfStateChange); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('TaskStatus'); + if ($this->executionState !== null) { + $xfer += $output->writeFieldBegin('executionState', TType::I32, 1); + $xfer += $output->writeI32($this->executionState); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class ApplicationStatus { - static $_TSPEC; - - public $applicationState = null; - public $timeOfStateChange = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'applicationState', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'timeOfStateChange', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['applicationState'])) { - $this->applicationState = $vals['applicationState']; - } - if (isset($vals['timeOfStateChange'])) { - $this->timeOfStateChange = $vals['timeOfStateChange']; - } +class JobStatus +{ + static $_TSPEC; + + /** + * @var int + */ + public $jobState = null; + /** + * @var int + */ + public $timeOfStateChange = null; + + public function __construct($vals = null) + { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'jobState', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['jobState'])) { + $this->jobState = $vals['jobState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + } } - } - - public function getName() { - return 'ApplicationStatus'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) + + public function getName() { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->applicationState); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->timeOfStateChange); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); + return 'JobStatus'; } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('ApplicationStatus'); - if ($this->applicationState !== null) { - $xfer += $output->writeFieldBegin('applicationState', TType::STRING, 1); - $xfer += $output->writeString($this->applicationState); - $xfer += $output->writeFieldEnd(); + + 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::I32) { + $xfer += $input->readI32($this->jobState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->timeOfStateChange !== null) { - $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); - $xfer += $output->writeI64($this->timeOfStateChange); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('JobStatus'); + if ($this->jobState !== null) { + $xfer += $output->writeFieldBegin('jobState', TType::I32, 1); + $xfer += $output->writeI32($this->jobState); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class ComputationalResourceScheduling { - static $_TSPEC; - - public $resourceHostId = null; - public $totalCPUCount = null; - public $nodeCount = null; - public $numberOfThreads = null; - public $queueName = null; - public $wallTimeLimit = null; - public $jobStartTime = null; - public $totalPhysicalMemory = null; - public $computationalProjectAccount = null; - public $chassisName = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'resourceHostId', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'totalCPUCount', - 'type' => TType::I32, - ), - 3 => array( - 'var' => 'nodeCount', - 'type' => TType::I32, - ), - 4 => array( - 'var' => 'numberOfThreads', - 'type' => TType::I32, - ), - 5 => array( - 'var' => 'queueName', - 'type' => TType::STRING, - ), - 6 => array( - 'var' => 'wallTimeLimit', - 'type' => TType::I32, - ), - 7 => array( - 'var' => 'jobStartTime', - 'type' => TType::I32, - ), - 8 => array( - 'var' => 'totalPhysicalMemory', - 'type' => TType::I32, - ), - 9 => array( - 'var' => 'computationalProjectAccount', - 'type' => TType::STRING, - ), - 10 => array( - 'var' => 'chassisName', - 'type' => TType::STRING, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['resourceHostId'])) { - $this->resourceHostId = $vals['resourceHostId']; - } - if (isset($vals['totalCPUCount'])) { - $this->totalCPUCount = $vals['totalCPUCount']; - } - if (isset($vals['nodeCount'])) { - $this->nodeCount = $vals['nodeCount']; - } - if (isset($vals['numberOfThreads'])) { - $this->numberOfThreads = $vals['numberOfThreads']; - } - if (isset($vals['queueName'])) { - $this->queueName = $vals['queueName']; - } - if (isset($vals['wallTimeLimit'])) { - $this->wallTimeLimit = $vals['wallTimeLimit']; - } - if (isset($vals['jobStartTime'])) { - $this->jobStartTime = $vals['jobStartTime']; - } - if (isset($vals['totalPhysicalMemory'])) { - $this->totalPhysicalMemory = $vals['totalPhysicalMemory']; - } - if (isset($vals['computationalProjectAccount'])) { - $this->computationalProjectAccount = $vals['computationalProjectAccount']; - } - if (isset($vals['chassisName'])) { - $this->chassisName = $vals['chassisName']; - } - } - } - - public function getName() { - return 'ComputationalResourceScheduling'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) +class TransferStatus +{ + static $_TSPEC; + + /** + * @var int + */ + public $transferState = null; + /** + * @var int + */ + public $timeOfStateChange = null; + + public function __construct($vals = null) { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->resourceHostId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->totalCPUCount); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->nodeCount); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->numberOfThreads); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->queueName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->wallTimeLimit); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->jobStartTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->totalPhysicalMemory); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->computationalProjectAccount); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->chassisName); - } 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('ComputationalResourceScheduling'); - if ($this->resourceHostId !== null) { - $xfer += $output->writeFieldBegin('resourceHostId', TType::STRING, 1); - $xfer += $output->writeString($this->resourceHostId); - $xfer += $output->writeFieldEnd(); - } - if ($this->totalCPUCount !== null) { - $xfer += $output->writeFieldBegin('totalCPUCount', TType::I32, 2); - $xfer += $output->writeI32($this->totalCPUCount); - $xfer += $output->writeFieldEnd(); - } - if ($this->nodeCount !== null) { - $xfer += $output->writeFieldBegin('nodeCount', TType::I32, 3); - $xfer += $output->writeI32($this->nodeCount); - $xfer += $output->writeFieldEnd(); - } - if ($this->numberOfThreads !== null) { - $xfer += $output->writeFieldBegin('numberOfThreads', TType::I32, 4); - $xfer += $output->writeI32($this->numberOfThreads); - $xfer += $output->writeFieldEnd(); - } - if ($this->queueName !== null) { - $xfer += $output->writeFieldBegin('queueName', TType::STRING, 5); - $xfer += $output->writeString($this->queueName); - $xfer += $output->writeFieldEnd(); - } - if ($this->wallTimeLimit !== null) { - $xfer += $output->writeFieldBegin('wallTimeLimit', TType::I32, 6); - $xfer += $output->writeI32($this->wallTimeLimit); - $xfer += $output->writeFieldEnd(); - } - if ($this->jobStartTime !== null) { - $xfer += $output->writeFieldBegin('jobStartTime', TType::I32, 7); - $xfer += $output->writeI32($this->jobStartTime); - $xfer += $output->writeFieldEnd(); + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'transferState', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['transferState'])) { + $this->transferState = $vals['transferState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + } } - if ($this->totalPhysicalMemory !== null) { - $xfer += $output->writeFieldBegin('totalPhysicalMemory', TType::I32, 8); - $xfer += $output->writeI32($this->totalPhysicalMemory); - $xfer += $output->writeFieldEnd(); + + public function getName() + { + return 'TransferStatus'; } - if ($this->computationalProjectAccount !== null) { - $xfer += $output->writeFieldBegin('computationalProjectAccount', TType::STRING, 9); - $xfer += $output->writeString($this->computationalProjectAccount); - $xfer += $output->writeFieldEnd(); + + 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::I32) { + $xfer += $input->readI32($this->transferState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->chassisName !== null) { - $xfer += $output->writeFieldBegin('chassisName', TType::STRING, 10); - $xfer += $output->writeString($this->chassisName); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('TransferStatus'); + if ($this->transferState !== null) { + $xfer += $output->writeFieldBegin('transferState', TType::I32, 1); + $xfer += $output->writeI32($this->transferState); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class AdvancedInputDataHandling { - static $_TSPEC; - - public $stageInputFilesToWorkingDir = false; - public $parentWorkingDirectory = null; - public $uniqueWorkingDirectory = null; - public $cleanUpWorkingDirAfterJob = false; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'stageInputFilesToWorkingDir', - 'type' => TType::BOOL, - ), - 2 => array( - 'var' => 'parentWorkingDirectory', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'uniqueWorkingDirectory', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'cleanUpWorkingDirAfterJob', - 'type' => TType::BOOL, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['stageInputFilesToWorkingDir'])) { - $this->stageInputFilesToWorkingDir = $vals['stageInputFilesToWorkingDir']; - } - if (isset($vals['parentWorkingDirectory'])) { - $this->parentWorkingDirectory = $vals['parentWorkingDirectory']; - } - if (isset($vals['uniqueWorkingDirectory'])) { - $this->uniqueWorkingDirectory = $vals['uniqueWorkingDirectory']; - } - if (isset($vals['cleanUpWorkingDirAfterJob'])) { - $this->cleanUpWorkingDirAfterJob = $vals['cleanUpWorkingDirAfterJob']; - } - } - } - - public function getName() { - return 'AdvancedInputDataHandling'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) +class ApplicationStatus +{ + static $_TSPEC; + + /** + * @var string + */ + public $applicationState = null; + /** + * @var int + */ + public $timeOfStateChange = null; + + public function __construct($vals = null) { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->stageInputFilesToWorkingDir); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->parentWorkingDirectory); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->uniqueWorkingDirectory); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->cleanUpWorkingDirAfterJob); - } 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('AdvancedInputDataHandling'); - if ($this->stageInputFilesToWorkingDir !== null) { - $xfer += $output->writeFieldBegin('stageInputFilesToWorkingDir', TType::BOOL, 1); - $xfer += $output->writeBool($this->stageInputFilesToWorkingDir); - $xfer += $output->writeFieldEnd(); + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'applicationState', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['applicationState'])) { + $this->applicationState = $vals['applicationState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + } } - if ($this->parentWorkingDirectory !== null) { - $xfer += $output->writeFieldBegin('parentWorkingDirectory', TType::STRING, 2); - $xfer += $output->writeString($this->parentWorkingDirectory); - $xfer += $output->writeFieldEnd(); + + public function getName() + { + return 'ApplicationStatus'; } - if ($this->uniqueWorkingDirectory !== null) { - $xfer += $output->writeFieldBegin('uniqueWorkingDirectory', TType::STRING, 3); - $xfer += $output->writeString($this->uniqueWorkingDirectory); - $xfer += $output->writeFieldEnd(); + + 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->applicationState); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->cleanUpWorkingDirAfterJob !== null) { - $xfer += $output->writeFieldBegin('cleanUpWorkingDirAfterJob', TType::BOOL, 4); - $xfer += $output->writeBool($this->cleanUpWorkingDirAfterJob); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('ApplicationStatus'); + if ($this->applicationState !== null) { + $xfer += $output->writeFieldBegin('applicationState', TType::STRING, 1); + $xfer += $output->writeString($this->applicationState); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class AdvancedOutputDataHandling { - static $_TSPEC; - - public $outputDataDir = null; - public $dataRegistryURL = null; - public $persistOutputData = true; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 2 => array( - 'var' => 'outputDataDir', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'dataRegistryURL', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'persistOutputData', - 'type' => TType::BOOL, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['outputDataDir'])) { - $this->outputDataDir = $vals['outputDataDir']; - } - if (isset($vals['dataRegistryURL'])) { - $this->dataRegistryURL = $vals['dataRegistryURL']; - } - if (isset($vals['persistOutputData'])) { - $this->persistOutputData = $vals['persistOutputData']; - } - } - } - - public function getName() { - return 'AdvancedOutputDataHandling'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) +/** + * A structure holding the Computational Resource Scheduling. + * + */ +class ComputationalResourceScheduling +{ + static $_TSPEC; + + /** + * @var string + */ + public $resourceHostId = null; + /** + * @var int + */ + public $totalCPUCount = null; + /** + * @var int + */ + public $nodeCount = null; + /** + * @var int + */ + public $numberOfThreads = null; + /** + * @var string + */ + public $queueName = null; + /** + * @var int + */ + public $wallTimeLimit = null; + /** + * @var int + */ + public $jobStartTime = null; + /** + * @var int + */ + public $totalPhysicalMemory = null; + /** + * @var string + */ + public $computationalProjectAccount = null; + /** + * @var string + */ + public $chassisName = null; + + public function __construct($vals = null) { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->outputDataDir); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->dataRegistryURL); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->persistOutputData); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'resourceHostId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'totalCPUCount', + 'type' => TType::I32, + ), + 3 => array( + 'var' => 'nodeCount', + 'type' => TType::I32, + ), + 4 => array( + 'var' => 'numberOfThreads', + 'type' => TType::I32, + ), + 5 => array( + 'var' => 'queueName', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'wallTimeLimit', + 'type' => TType::I32, + ), + 7 => array( + 'var' => 'jobStartTime', + 'type' => TType::I32, + ), + 8 => array( + 'var' => 'totalPhysicalMemory', + 'type' => TType::I32, + ), + 9 => array( + 'var' => 'computationalProjectAccount', + 'type' => TType::STRING, + ), + 10 => array( + 'var' => 'chassisName', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['resourceHostId'])) { + $this->resourceHostId = $vals['resourceHostId']; + } + if (isset($vals['totalCPUCount'])) { + $this->totalCPUCount = $vals['totalCPUCount']; + } + if (isset($vals['nodeCount'])) { + $this->nodeCount = $vals['nodeCount']; + } + if (isset($vals['numberOfThreads'])) { + $this->numberOfThreads = $vals['numberOfThreads']; + } + if (isset($vals['queueName'])) { + $this->queueName = $vals['queueName']; + } + if (isset($vals['wallTimeLimit'])) { + $this->wallTimeLimit = $vals['wallTimeLimit']; + } + if (isset($vals['jobStartTime'])) { + $this->jobStartTime = $vals['jobStartTime']; + } + if (isset($vals['totalPhysicalMemory'])) { + $this->totalPhysicalMemory = $vals['totalPhysicalMemory']; + } + if (isset($vals['computationalProjectAccount'])) { + $this->computationalProjectAccount = $vals['computationalProjectAccount']; + } + if (isset($vals['chassisName'])) { + $this->chassisName = $vals['chassisName']; + } + } } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('AdvancedOutputDataHandling'); - if ($this->outputDataDir !== null) { - $xfer += $output->writeFieldBegin('outputDataDir', TType::STRING, 2); - $xfer += $output->writeString($this->outputDataDir); - $xfer += $output->writeFieldEnd(); + + public function getName() + { + return 'ComputationalResourceScheduling'; } - if ($this->dataRegistryURL !== null) { - $xfer += $output->writeFieldBegin('dataRegistryURL', TType::STRING, 3); - $xfer += $output->writeString($this->dataRegistryURL); - $xfer += $output->writeFieldEnd(); + + 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->resourceHostId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->totalCPUCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->nodeCount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->numberOfThreads); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->queueName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->wallTimeLimit); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->jobStartTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->totalPhysicalMemory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->computationalProjectAccount); + } else { + $xfer += $input->skip($ftype); + } + break; + case 10: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->chassisName); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->persistOutputData !== null) { - $xfer += $output->writeFieldBegin('persistOutputData', TType::BOOL, 4); - $xfer += $output->writeBool($this->persistOutputData); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('ComputationalResourceScheduling'); + if ($this->resourceHostId !== null) { + $xfer += $output->writeFieldBegin('resourceHostId', TType::STRING, 1); + $xfer += $output->writeString($this->resourceHostId); + $xfer += $output->writeFieldEnd(); + } + if ($this->totalCPUCount !== null) { + $xfer += $output->writeFieldBegin('totalCPUCount', TType::I32, 2); + $xfer += $output->writeI32($this->totalCPUCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->nodeCount !== null) { + $xfer += $output->writeFieldBegin('nodeCount', TType::I32, 3); + $xfer += $output->writeI32($this->nodeCount); + $xfer += $output->writeFieldEnd(); + } + if ($this->numberOfThreads !== null) { + $xfer += $output->writeFieldBegin('numberOfThreads', TType::I32, 4); + $xfer += $output->writeI32($this->numberOfThreads); + $xfer += $output->writeFieldEnd(); + } + if ($this->queueName !== null) { + $xfer += $output->writeFieldBegin('queueName', TType::STRING, 5); + $xfer += $output->writeString($this->queueName); + $xfer += $output->writeFieldEnd(); + } + if ($this->wallTimeLimit !== null) { + $xfer += $output->writeFieldBegin('wallTimeLimit', TType::I32, 6); + $xfer += $output->writeI32($this->wallTimeLimit); + $xfer += $output->writeFieldEnd(); + } + if ($this->jobStartTime !== null) { + $xfer += $output->writeFieldBegin('jobStartTime', TType::I32, 7); + $xfer += $output->writeI32($this->jobStartTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->totalPhysicalMemory !== null) { + $xfer += $output->writeFieldBegin('totalPhysicalMemory', TType::I32, 8); + $xfer += $output->writeI32($this->totalPhysicalMemory); + $xfer += $output->writeFieldEnd(); + } + if ($this->computationalProjectAccount !== null) { + $xfer += $output->writeFieldBegin('computationalProjectAccount', TType::STRING, 9); + $xfer += $output->writeString($this->computationalProjectAccount); + $xfer += $output->writeFieldEnd(); + } + if ($this->chassisName !== null) { + $xfer += $output->writeFieldBegin('chassisName', TType::STRING, 10); + $xfer += $output->writeString($this->chassisName); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class QualityOfServiceParams { - static $_TSPEC; - - public $startExecutionAt = null; - public $executeBefore = null; - public $numberofRetries = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'startExecutionAt', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'executeBefore', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'numberofRetries', - 'type' => TType::I32, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['startExecutionAt'])) { - $this->startExecutionAt = $vals['startExecutionAt']; - } - if (isset($vals['executeBefore'])) { - $this->executeBefore = $vals['executeBefore']; - } - if (isset($vals['numberofRetries'])) { - $this->numberofRetries = $vals['numberofRetries']; - } - } - } - - public function getName() { - return 'QualityOfServiceParams'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) +/** + * A structure holding specified input data handling. + * + */ +class AdvancedInputDataHandling +{ + static $_TSPEC; + + /** + * @var bool + */ + public $stageInputFilesToWorkingDir = false; + /** + * @var string + */ + public $parentWorkingDirectory = null; + /** + * @var string + */ + public $uniqueWorkingDirectory = null; + /** + * @var bool + */ + public $cleanUpWorkingDirAfterJob = false; + + public function __construct($vals = null) { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->startExecutionAt); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->executeBefore); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->numberofRetries); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'stageInputFilesToWorkingDir', + 'type' => TType::BOOL, + ), + 2 => array( + 'var' => 'parentWorkingDirectory', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'uniqueWorkingDirectory', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'cleanUpWorkingDirAfterJob', + 'type' => TType::BOOL, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['stageInputFilesToWorkingDir'])) { + $this->stageInputFilesToWorkingDir = $vals['stageInputFilesToWorkingDir']; + } + if (isset($vals['parentWorkingDirectory'])) { + $this->parentWorkingDirectory = $vals['parentWorkingDirectory']; + } + if (isset($vals['uniqueWorkingDirectory'])) { + $this->uniqueWorkingDirectory = $vals['uniqueWorkingDirectory']; + } + if (isset($vals['cleanUpWorkingDirAfterJob'])) { + $this->cleanUpWorkingDirAfterJob = $vals['cleanUpWorkingDirAfterJob']; + } + } } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('QualityOfServiceParams'); - if ($this->startExecutionAt !== null) { - $xfer += $output->writeFieldBegin('startExecutionAt', TType::STRING, 1); - $xfer += $output->writeString($this->startExecutionAt); - $xfer += $output->writeFieldEnd(); + + public function getName() + { + return 'AdvancedInputDataHandling'; } - if ($this->executeBefore !== null) { - $xfer += $output->writeFieldBegin('executeBefore', TType::STRING, 2); - $xfer += $output->writeString($this->executeBefore); - $xfer += $output->writeFieldEnd(); + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) { + case 1: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->stageInputFilesToWorkingDir); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->parentWorkingDirectory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->uniqueWorkingDirectory); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->cleanUpWorkingDirAfterJob); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; } - if ($this->numberofRetries !== null) { - $xfer += $output->writeFieldBegin('numberofRetries', TType::I32, 3); - $xfer += $output->writeI32($this->numberofRetries); - $xfer += $output->writeFieldEnd(); + + public function write($output) + { + $xfer = 0; + $xfer += $output->writeStructBegin('AdvancedInputDataHandling'); + if ($this->stageInputFilesToWorkingDir !== null) { + $xfer += $output->writeFieldBegin('stageInputFilesToWorkingDir', TType::BOOL, 1); + $xfer += $output->writeBool($this->stageInputFilesToWorkingDir); + $xfer += $output->writeFieldEnd(); + } + if ($this->parentWorkingDirectory !== null) { + $xfer += $output->writeFieldBegin('parentWorkingDirectory', TType::STRING, 2); + $xfer += $output->writeString($this->parentWorkingDirectory); + $xfer += $output->writeFieldEnd(); + } + if ($this->uniqueWorkingDirectory !== null) { + $xfer += $output->writeFieldBegin('uniqueWorkingDirectory', TType::STRING, 3); + $xfer += $output->writeString($this->uniqueWorkingDirectory); + $xfer += $output->writeFieldEnd(); + } + if ($this->cleanUpWorkingDirAfterJob !== null) { + $xfer += $output->writeFieldBegin('cleanUpWorkingDirAfterJob', TType::BOOL, 4); + $xfer += $output->writeBool($this->cleanUpWorkingDirAfterJob); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } } -class UserConfigurationData { - static $_TSPEC; - - public $airavataAutoSchedule = false; - public $overrideManualScheduledParams = false; - public $shareExperimentPublicly = false; - public $computationalResourceScheduling = null; - public $advanceInputDataHandling = null; - public $advanceOutputDataHandling = null; - public $qosParams = null; - public $throttleResources = false; - public $userDN = null; - public $generateCert = false; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'airavataAutoSchedule', - 'type' => TType::BOOL, - ), - 2 => array( - 'var' => 'overrideManualScheduledParams', - 'type' => TType::BOOL, - ), - 3 => array( - 'var' => 'shareExperimentPublicly', - 'type' => TType::BOOL, - ), - 4 => array( - 'var' => 'computationalResourceScheduling', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Workspace\Experiment\ComputationalResourceScheduling', - ), - 5 => array( - 'var' => 'advanceInputDataHandling', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Workspace\Experiment\AdvancedInputDataHandling', - ), - 6 => array( - 'var' => 'advanceOutputDataHandling', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Workspace\Experiment\AdvancedOutputDataHandling', - ), - 7 => array( - 'var' => 'qosParams', - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\Workspace\Experiment\QualityOfServiceParams', - ), - 8 => array( - 'var' => 'throttleResources', - 'type' => TType::BOOL, - ), - 9 => array( - 'var' => 'userDN', - 'type' => TType::STRING, - ), - 10 => array( - 'var' => 'generateCert', - 'type' => TType::BOOL, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['airavataAutoSchedule'])) { - $this->airavataAutoSchedule = $vals['airavataAutoSchedule']; - } - if (isset($vals['overrideManualScheduledParams'])) { - $this->overrideManualScheduledParams = $vals['overrideManualScheduledParams']; - } - if (isset($vals['shareExperimentPublicly'])) { - $this->shareExperimentPublicly = $vals['shareExperimentPublicly']; - } - if (isset($vals['computationalResourceScheduling'])) { - $this->computationalResourceScheduling = $vals['computationalResourceScheduling']; - } - if (isset($vals['advanceInputDataHandling'])) { - $this->advanceInputDataHandling = $vals['advanceInputDataHandling']; - } - if (isset($vals['advanceOutputDataHandling'])) { - $this->advanceOutputDataHandling = $vals['advanceOutputDataHandling']; - } - if (isset($vals['qosParams'])) { - $this->qosParams = $vals['qosParams']; - } - if (isset($vals['throttleResources'])) { - $this->throttleResources = $vals['throttleResources']; - } - if (isset($vals['userDN'])) { - $this->userDN = $vals['userDN']; - } - if (isset($vals['generateCert'])) { - $this->generateCert = $vals['generateCert']; - } - } - } - - public function getName() { - return 'UserConfigurationData'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) +/** + * A structure holding specified output data handling. + * + */ +class AdvancedOutputDataHandling +{ + static $_TSPEC; + + /** + * @var string + */ + public $outputDataDir = null; + /** + * @var string + */ + public $dataRegistryURL = null; + /** + * @var bool + */ + public $persistOutputData = true; + + public function __construct($vals = null) { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->airavataAutoSchedule); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->overrideManualScheduledParams); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->shareExperimentPublicly); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::STRUCT) { - $this->computationalResourceScheduling = new \Airavata\Model\Workspace\Experiment\ComputationalResourceScheduling(); - $xfer += $this->computationalResourceScheduling->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::STRUCT) { - $this->advanceInputDataHandling = new \Airavata\Model\Workspace\Experiment\AdvancedInputDataHandling(); - $xfer += $this->advanceInputDataHandling->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::STRUCT) { - $this->advanceOutputDataHandling = new \Airavata\Model\Workspace\Experiment\AdvancedOutputDataHandling(); - $xfer += $this->advanceOutputDataHandling->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::STRUCT) { - $this->qosParams = new \Airavata\Model\Workspace\Experiment\QualityOfServiceParams(); - $xfer += $this->qosParams->read($input); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->throttleResources); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->userDN); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->generateCert); - } 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('UserConfigurationData'); - if ($this->airavataAutoSchedule !== null) { - $xfer += $output->writeFieldBegin('airavataAutoSchedule', TType::BOOL, 1); - $xfer += $output->writeBool($this->airavataAutoSchedule); - $xfer += $output->writeFieldEnd(); - } - if ($this->overrideManualScheduledParams !== null) { - $xfer += $output->writeFieldBegin('overrideManualScheduledParams', TType::BOOL, 2); - $xfer += $output->writeBool($this->overrideManualScheduledParams); - $xfer += $output->writeFieldEnd(); - } - if ($this->shareExperimentPublicly !== null) { - $xfer += $output->writeFieldBegin('shareExperimentPublicly', TType::BOOL, 3); - $xfer += $output->writeBool($this->shareExperimentPublicly); - $xfer += $output->writeFieldEnd(); - } - if ($this->computationalResourceScheduling !== null) { - if (!is_object($this->computationalResourceScheduling)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('computationalResourceScheduling', TType::STRUCT, 4); - $xfer += $this->computationalResourceScheduling->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->advanceInputDataHandling !== null) { - if (!is_object($this->advanceInputDataHandling)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('advanceInputDataHandling', TType::STRUCT, 5); - $xfer += $this->advanceInputDataHandling->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->advanceOutputDataHandling !== null) { - if (!is_object($this->advanceOutputDataHandling)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('advanceOutputDataHandling', TType::STRUCT, 6); - $xfer += $this->advanceOutputDataHandling->write($output); - $xfer += $output->writeFieldEnd(); - } - if ($this->qosParams !== null) { - if (!is_object($this->qosParams)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('qosParams', TType::STRUCT, 7); - $xfer += $this->qosParams->write($output); - $xfer += $output->writeFieldEnd(); + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 2 => array( + 'var' => 'outputDataDir', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'dataRegistryURL', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'persistOutputData', + 'type' => TType::BOOL, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['outputDataDir'])) { + $this->outputDataDir = $vals['outputDataDir']; + } + if (isset($vals['dataRegistryURL'])) { + $this->dataRegistryURL = $vals['dataRegistryURL']; + } + if (isset($vals['persistOutputData'])) { + $this->persistOutputData = $vals['persistOutputData']; + } + } } - if ($this->throttleResources !== null) { - $xfer += $output->writeFieldBegin('throttleResources', TType::BOOL, 8); - $xfer += $output->writeBool($this->throttleResources); - $xfer += $output->writeFieldEnd(); + + public function getName() + { + return 'AdvancedOutputDataHandling'; } - if ($this->userDN !== null) { - $xfer += $output->writeFieldBegin('userDN', TType::STRING, 9); - $xfer += $output->writeString($this->userDN); - $xfer += $output->writeFieldEnd(); + + 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; + } <TRUNCATED>
