http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Status/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Status/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Status/Types.php new file mode 100644 index 0000000..603e75b --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Status/Types.php @@ -0,0 +1,607 @@ +<?php +namespace Airavata\Model\Status; + +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * 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 ExperimentState { + const CREATED = 0; + const VALIDATED = 1; + const SCHEDULED = 2; + const LAUNCHED = 3; + const EXECUTING = 4; + const CANCELING = 5; + const CANCELED = 6; + const COMPLETED = 7; + const FAILED = 8; + static public $__names = array( + 0 => 'CREATED', + 1 => 'VALIDATED', + 2 => 'SCHEDULED', + 3 => 'LAUNCHED', + 4 => 'EXECUTING', + 5 => 'CANCELING', + 6 => 'CANCELED', + 7 => 'COMPLETED', + 8 => 'FAILED', + ); +} + +final class TaskState { + const CREATED = 0; + const EXECUTING = 1; + const COMPLETED = 2; + const FAILED = 3; + const CANCELED = 4; + static public $__names = array( + 0 => 'CREATED', + 1 => 'EXECUTING', + 2 => 'COMPLETED', + 3 => 'FAILED', + 4 => 'CANCELED', + ); +} + +final class ProcessState { + const CREATED = 0; + const VALIDATED = 1; + const PRE_PROCESSING = 2; + const CONFIGURING_WORKSPACE = 3; + const INPUT_DATA_STAGING = 4; + const EXECUTING = 5; + const MONITORING = 6; + const OUTPUT_DATA_STAGING = 7; + const POST_PROCESSING = 8; + const COMPLETED = 9; + const FAILED = 10; + const CANCELLING = 11; + const CANCELED = 12; + static public $__names = array( + 0 => 'CREATED', + 1 => 'VALIDATED', + 2 => 'PRE_PROCESSING', + 3 => 'CONFIGURING_WORKSPACE', + 4 => 'INPUT_DATA_STAGING', + 5 => 'EXECUTING', + 6 => 'MONITORING', + 7 => 'OUTPUT_DATA_STAGING', + 8 => 'POST_PROCESSING', + 9 => 'COMPLETED', + 10 => 'FAILED', + 11 => 'CANCELLING', + 12 => 'CANCELED', + ); +} + +final class JobState { + const SUBMITTED = 0; + const QUEUED = 1; + const ACTIVE = 2; + const COMPLETE = 3; + const CANCELED = 4; + const FAILED = 5; + const SUSPENDED = 6; + const UNKNOWN = 7; + static public $__names = array( + 0 => 'SUBMITTED', + 1 => 'QUEUED', + 2 => 'ACTIVE', + 3 => 'COMPLETE', + 4 => 'CANCELED', + 5 => 'FAILED', + 6 => 'SUSPENDED', + 7 => 'UNKNOWN', + ); +} + +/** + * Status: A generic status object. + * + * state: + * State . + * + * timeOfStateChange: + * time the status was last updated. + * + * reason: + * User friendly reason on how the state is inferred. + * + */ +class ExperimentStatus { + static $_TSPEC; + + /** + * @var int + */ + public $state = null; + /** + * @var int + */ + public $timeOfStateChange = null; + /** + * @var string + */ + public $reason = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'state', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + 3 => array( + 'var' => 'reason', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['state'])) { + $this->state = $vals['state']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + if (isset($vals['reason'])) { + $this->reason = $vals['reason']; + } + } + } + + 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->state); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->reason); + } 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->state !== null) { + $xfer += $output->writeFieldBegin('state', TType::I32, 1); + $xfer += $output->writeI32($this->state); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + if ($this->reason !== null) { + $xfer += $output->writeFieldBegin('reason', TType::STRING, 3); + $xfer += $output->writeString($this->reason); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ProcessStatus { + static $_TSPEC; + + /** + * @var int + */ + public $state = null; + /** + * @var int + */ + public $timeOfStateChange = null; + /** + * @var string + */ + public $reason = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'state', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + 3 => array( + 'var' => 'reason', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['state'])) { + $this->state = $vals['state']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + if (isset($vals['reason'])) { + $this->reason = $vals['reason']; + } + } + } + + public function getName() { + return 'ProcessStatus'; + } + + 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->state); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->reason); + } 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('ProcessStatus'); + if ($this->state !== null) { + $xfer += $output->writeFieldBegin('state', TType::I32, 1); + $xfer += $output->writeI32($this->state); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + if ($this->reason !== null) { + $xfer += $output->writeFieldBegin('reason', TType::STRING, 3); + $xfer += $output->writeString($this->reason); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class TaskStatus { + static $_TSPEC; + + /** + * @var int + */ + public $state = null; + /** + * @var int + */ + public $timeOfStateChange = null; + /** + * @var string + */ + public $reason = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'state', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'timeOfStateChange', + 'type' => TType::I64, + ), + 3 => array( + 'var' => 'reason', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['state'])) { + $this->state = $vals['state']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + if (isset($vals['reason'])) { + $this->reason = $vals['reason']; + } + } + } + + public function getName() { + return 'TaskStatus'; + } + + 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->state); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->timeOfStateChange); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->reason); + } 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('TaskStatus'); + if ($this->state !== null) { + $xfer += $output->writeFieldBegin('state', TType::I32, 1); + $xfer += $output->writeI32($this->state); + $xfer += $output->writeFieldEnd(); + } + if ($this->timeOfStateChange !== null) { + $xfer += $output->writeFieldBegin('timeOfStateChange', TType::I64, 2); + $xfer += $output->writeI64($this->timeOfStateChange); + $xfer += $output->writeFieldEnd(); + } + if ($this->reason !== null) { + $xfer += $output->writeFieldBegin('reason', TType::STRING, 3); + $xfer += $output->writeString($this->reason); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class JobStatus { + static $_TSPEC; + + /** + * @var int + */ + public $jobState = null; + /** + * @var int + */ + public $timeOfStateChange = null; + /** + * @var string + */ + public $reason = 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, + ), + 3 => array( + 'var' => 'reason', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['jobState'])) { + $this->jobState = $vals['jobState']; + } + if (isset($vals['timeOfStateChange'])) { + $this->timeOfStateChange = $vals['timeOfStateChange']; + } + if (isset($vals['reason'])) { + $this->reason = $vals['reason']; + } + } + } + + public function getName() { + return 'JobStatus'; + } + + 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; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->reason); + } 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('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(); + } + if ($this->reason !== null) { + $xfer += $output->writeFieldBegin('reason', TType::STRING, 3); + $xfer += $output->writeString($this->reason); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +
http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Task/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Task/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Task/Types.php new file mode 100644 index 0000000..66b5cfa --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Task/Types.php @@ -0,0 +1,491 @@ +<?php +namespace Airavata\Model\Task; + +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * 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; + + +/** + * TaskTypes: An enumerated list of TaskTypes. Task being generic, the task type will provide the concrete interpretation. + * + */ +final class TaskTypes { + const ENV_SETUP = 0; + const DATA_STAGING = 1; + const JOB_SUBMISSION = 2; + const ENV_CLEANUP = 3; + const MONITORING = 4; + static public $__names = array( + 0 => 'ENV_SETUP', + 1 => 'DATA_STAGING', + 2 => 'JOB_SUBMISSION', + 3 => 'ENV_CLEANUP', + 4 => 'MONITORING', + ); +} + +/** + * TaskModel: A structure holding the generic task details. + * + * taskDetail: + * A friendly description of the task, usally used to communicate information to users. + * + * subTaskModel: + * A generic byte object for the Task developer to store internal serialized data into registry catalogs. + */ +class TaskModel { + static $_TSPEC; + + /** + * @var string + */ + public $taskId = "DO_NOT_SET_AT_CLIENTS"; + /** + * @var int + */ + public $taskType = null; + /** + * @var string + */ + public $parentProcessId = null; + /** + * @var int + */ + public $creationTime = null; + /** + * @var int + */ + public $lastUpdateTime = null; + /** + * @var \Airavata\Model\Status\TaskStatus + */ + public $taskStatus = null; + /** + * @var string + */ + public $taskDetail = null; + /** + * @var string + */ + public $subTaskModel = null; + /** + * @var \Airavata\Model\Commons\ErrorModel + */ + public $taskError = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'taskId', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'taskType', + 'type' => TType::I32, + ), + 3 => array( + 'var' => 'parentProcessId', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'creationTime', + 'type' => TType::I64, + ), + 5 => array( + 'var' => 'lastUpdateTime', + 'type' => TType::I64, + ), + 6 => array( + 'var' => 'taskStatus', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Status\TaskStatus', + ), + 7 => array( + 'var' => 'taskDetail', + 'type' => TType::STRING, + ), + 8 => array( + 'var' => 'subTaskModel', + 'type' => TType::STRING, + ), + 9 => array( + 'var' => 'taskError', + 'type' => TType::STRUCT, + 'class' => '\Airavata\Model\Commons\ErrorModel', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['taskId'])) { + $this->taskId = $vals['taskId']; + } + if (isset($vals['taskType'])) { + $this->taskType = $vals['taskType']; + } + if (isset($vals['parentProcessId'])) { + $this->parentProcessId = $vals['parentProcessId']; + } + if (isset($vals['creationTime'])) { + $this->creationTime = $vals['creationTime']; + } + if (isset($vals['lastUpdateTime'])) { + $this->lastUpdateTime = $vals['lastUpdateTime']; + } + if (isset($vals['taskStatus'])) { + $this->taskStatus = $vals['taskStatus']; + } + if (isset($vals['taskDetail'])) { + $this->taskDetail = $vals['taskDetail']; + } + if (isset($vals['subTaskModel'])) { + $this->subTaskModel = $vals['subTaskModel']; + } + if (isset($vals['taskError'])) { + $this->taskError = $vals['taskError']; + } + } + } + + public function getName() { + return 'TaskModel'; + } + + 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->taskId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->taskType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->parentProcessId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->creationTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastUpdateTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRUCT) { + $this->taskStatus = new \Airavata\Model\Status\TaskStatus(); + $xfer += $this->taskStatus->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->taskDetail); + } else { + $xfer += $input->skip($ftype); + } + break; + case 8: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->subTaskModel); + } else { + $xfer += $input->skip($ftype); + } + break; + case 9: + if ($ftype == TType::STRUCT) { + $this->taskError = new \Airavata\Model\Commons\ErrorModel(); + $xfer += $this->taskError->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('TaskModel'); + if ($this->taskId !== null) { + $xfer += $output->writeFieldBegin('taskId', TType::STRING, 1); + $xfer += $output->writeString($this->taskId); + $xfer += $output->writeFieldEnd(); + } + if ($this->taskType !== null) { + $xfer += $output->writeFieldBegin('taskType', TType::I32, 2); + $xfer += $output->writeI32($this->taskType); + $xfer += $output->writeFieldEnd(); + } + if ($this->parentProcessId !== null) { + $xfer += $output->writeFieldBegin('parentProcessId', TType::STRING, 3); + $xfer += $output->writeString($this->parentProcessId); + $xfer += $output->writeFieldEnd(); + } + if ($this->creationTime !== null) { + $xfer += $output->writeFieldBegin('creationTime', TType::I64, 4); + $xfer += $output->writeI64($this->creationTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->lastUpdateTime !== null) { + $xfer += $output->writeFieldBegin('lastUpdateTime', TType::I64, 5); + $xfer += $output->writeI64($this->lastUpdateTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->taskStatus !== null) { + if (!is_object($this->taskStatus)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('taskStatus', TType::STRUCT, 6); + $xfer += $this->taskStatus->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->taskDetail !== null) { + $xfer += $output->writeFieldBegin('taskDetail', TType::STRING, 7); + $xfer += $output->writeString($this->taskDetail); + $xfer += $output->writeFieldEnd(); + } + if ($this->subTaskModel !== null) { + $xfer += $output->writeFieldBegin('subTaskModel', TType::STRING, 8); + $xfer += $output->writeString($this->subTaskModel); + $xfer += $output->writeFieldEnd(); + } + if ($this->taskError !== null) { + if (!is_object($this->taskError)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('taskError', TType::STRUCT, 9); + $xfer += $this->taskError->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +/** + * DataStagingTaskModel: A structure holding the data staging task details. + * + * Source and Destination locations includes standard representation of protocol, host, port and path + * A friendly description of the task, usally used to communicate information to users. + * + */ +class DataStagingTaskModel { + static $_TSPEC; + + /** + * @var string + */ + public $source = null; + /** + * @var string + */ + public $destination = null; + /** + * @var int + */ + public $transferStartTime = null; + /** + * @var int + */ + public $transferEndTime = null; + /** + * @var string + */ + public $transferRate = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'source', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'destination', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'transferStartTime', + 'type' => TType::I64, + ), + 4 => array( + 'var' => 'transferEndTime', + 'type' => TType::I64, + ), + 5 => array( + 'var' => 'transferRate', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['source'])) { + $this->source = $vals['source']; + } + if (isset($vals['destination'])) { + $this->destination = $vals['destination']; + } + if (isset($vals['transferStartTime'])) { + $this->transferStartTime = $vals['transferStartTime']; + } + if (isset($vals['transferEndTime'])) { + $this->transferEndTime = $vals['transferEndTime']; + } + if (isset($vals['transferRate'])) { + $this->transferRate = $vals['transferRate']; + } + } + } + + public function getName() { + return 'DataStagingTaskModel'; + } + + 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->source); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->destination); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->transferStartTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->transferEndTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->transferRate); + } 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('DataStagingTaskModel'); + if ($this->source !== null) { + $xfer += $output->writeFieldBegin('source', TType::STRING, 1); + $xfer += $output->writeString($this->source); + $xfer += $output->writeFieldEnd(); + } + if ($this->destination !== null) { + $xfer += $output->writeFieldBegin('destination', TType::STRING, 2); + $xfer += $output->writeString($this->destination); + $xfer += $output->writeFieldEnd(); + } + if ($this->transferStartTime !== null) { + $xfer += $output->writeFieldBegin('transferStartTime', TType::I64, 3); + $xfer += $output->writeI64($this->transferStartTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->transferEndTime !== null) { + $xfer += $output->writeFieldBegin('transferEndTime', TType::I64, 4); + $xfer += $output->writeI64($this->transferEndTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->transferRate !== null) { + $xfer += $output->writeFieldBegin('transferRate', TType::STRING, 5); + $xfer += $output->writeString($this->transferRate); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + + http://git-wip-us.apache.org/repos/asf/airavata/blob/57164c7a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Types.php index 21d877c..1304f75 100644 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Types.php +++ b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/Types.php @@ -263,12 +263,4 @@ class Workflow { } -final class Constant extends \Thrift\Type\TConstant { - static protected $DEFAULT_ID; - - static protected function init_DEFAULT_ID() { - return "DO_NOT_SET_AT_CLIENTS"; - } -} -
